tno/mpc/protocols/secure_inner_join/helper.py
async def _process_share(self, party_1: str, party_2: str) -> None:
        """
        Receive a random share from party_1, add these to the encrypted
        attributes of party_2, and send the results to party_2

        :param party_1: party to receive from
        :param party_2: party to send results to
        :raise ValueError: raised when there are no feature columns determined,
            or when the is no known intersection yet.
        """
        random_share = await self.receive_message(party_1, "random_share")
        if self._feature_columns is None:
            raise ValueError("Did not determine feature columns yet.")
        features = self._feature_columns[party_2]
        if self._intersection is None:
            raise ValueError("Did not compute intersection yet.")
        real_share = np.subtract(self._intersection[:, features], random_share)
        await self.send_message(party_2, real_share, "real_share")
        self._logger.info(
            f"Obtained share from {party_2}, subtracted from overlap,"
            f"and sent resulting share to {party_1}"
        )

        Receive a random share from party_1, add these to the encrypted
        attributes of party_2, and send the results to party_2

        :param party_1: party to receive from
        :param party_2: party to send results to
        :raise ValueError: raised when there are no feature columns determined,
            or when the is no known intersection yet.
        
Receive a random share from party_1, add these to the encrypted
attributes of party_2, and send the results to party_2
Receive a random share from party_1 add these to the encrypted attributes of party_2 and send the results to party_2
async def _process_share(self, party_1: str, party_2: str) -> None:
        random_share = await self.receive_message(party_1, "random_share")
        if self._feature_columns is None:
            raise ValueError("Did not determine feature columns yet.")
        features = self._feature_columns[party_2]
        if self._intersection is None:
            raise ValueError("Did not compute intersection yet.")
        real_share = np.subtract(self._intersection[:, features], random_share)
        await self.send_message(party_2, real_share, "real_share")
        self._logger.info(
            f"Obtained share from {party_2}, subtracted from overlap,"
            f"and sent resulting share to {party_1}"
        )
async def _process_share ( self , party_1 : str , party_2 : str ) -> None : random_share = await self . receive_message ( party_1 , "random_share" ) if self . _feature_columns is None : raise ValueError ( "Did not determine feature columns yet." ) features = self . _feature_columns [ party_2 ] if self . _intersection is None : raise ValueError ( "Did not compute intersection yet." ) real_share = np . subtract ( self . _intersection [ : , features ] , random_share ) await self . send_message ( party_2 , real_share , "real_share" ) self . _logger . info ( f"Obtained share from {party_2}, subtracted from overlap," f"and sent resulting share to {party_1}" )
Receive a random share from party_1, add these to the encrypted
attributes of party_2, and send the results to party_2
Receive a random share from party_1 add these to the encrypted attributes of party_2 and send the results to party_2
"""
        Receive a random share from party_1, add these to the encrypted
        attributes of party_2, and send the results to party_2

        :param party_1: party to receive from
        :param party_2: party to send results to
        :raise ValueError: raised when there are no feature columns determined,
            or when the is no known intersection yet.
        """
raised when there are no feature columns determined,
or when the is no known intersection yet.
raised when there are no feature columns determined or when the is no known intersection yet .
ValueError
self
party_1
str
party to receive from
party to receive from
party_2
str
party to send results to
party to send results to