Searched refs:peerProcess (Results 1 – 1 of 1) sorted by relevance
186 this->peerProcess = peer->process; in connect()191 …auto latency = g_clogging.setPairLatencyIfNotSet( peerProcess->address.ip, process->address.ip, FL… in connect()208 return !peer || peerProcess->failed; in isPeerGone()275 ISimulator::ProcessInfo* process, *peerProcess; member303 ASSERT( g_simulator.getCurrentProcess() == self->peerProcess ); in sender()311 wait( g_simulator.onProcess( self->peerProcess ) ); in receiver()314 ASSERT( g_simulator.getCurrentProcess() == self->peerProcess ); in receiver()316 wait( delay( g_clogging.getSendDelay( self->process->address, self->peerProcess->address ) ) ); in receiver()319 wait( delay( g_clogging.getRecvDelay( self->process->address, self->peerProcess->address ) ) ); in receiver()351 ASSERT( g_simulator.getCurrentProcess() == self->peerProcess ); in whenWritable()[all …]