- PeerID peerID = 0;
- auto newPeerCallback = [&cv, &peerID, &mutex](const PeerID newPeerID) {
+ FileDescriptor peerFD = 0;
+ auto newPeerCallback = [&cv, &peerFD, &mutex](const FileDescriptor newFileDescriptor) {
- std::shared_ptr<SendData> recvData = s.callSync<SendData, SendData>(methodID, peerID, sentData);
+ std::shared_ptr<SendData> recvData = s.callSync<SendData, SendData>(methodID, peerFD, sentData);
c.addMethodHandler<EmptyData, EmptyData>(1, returnEmptyCallback);
c.addMethodHandler<SendData, SendData>(1, returnDataCallback);
c.addMethodHandler<EmptyData, EmptyData>(1, returnEmptyCallback);
c.addMethodHandler<SendData, SendData>(1, returnDataCallback);
c.addMethodHandler<SendData, SendData>(1, echoCallback);
c.addMethodHandler<SendData, SendData>(2, returnDataCallback);
c.addMethodHandler<SendData, SendData>(1, echoCallback);
c.addMethodHandler<SendData, SendData>(2, returnDataCallback);
- BOOST_CHECK_THROW(testEcho(s, 1, peerID), IPCException);
+ BOOST_CHECK_THROW(testEcho(s, 1, peerFD), IPCException);
- std::shared_ptr<SendData> recvData = s.callSync<SendData, SendData>(1, peerID, sentData);
+ std::shared_ptr<SendData> recvData = s.callSync<SendData, SendData>(1, peerFD, sentData);
- s.callAsync<SendData, SendData>(1, peerID, sentData, dataBack);
+ s.callAsync<SendData, SendData>(1, peerFD, sentData, dataBack);
return std::shared_ptr<LongSendData>(new LongSendData(data->intVal));
};
s.addMethodHandler<LongSendData, SendData>(1, longEchoCallback);
return std::shared_ptr<LongSendData>(new LongSendData(data->intVal));
};
s.addMethodHandler<LongSendData, SendData>(1, longEchoCallback);