diff --git a/fairmq/ofi/Socket.cxx b/fairmq/ofi/Socket.cxx index 3a2438de..ef67fae9 100644 --- a/fairmq/ofi/Socket.cxx +++ b/fairmq/ofi/Socket.cxx @@ -43,8 +43,6 @@ Socket::Socket(Context& context, const string& type, const string& name, const s , fBytesRx(0) , fMessagesTx(0) , fMessagesRx(0) - , fSndTimeout(100) - , fRcvTimeout(100) , fMultiPartRecvCounter(-1) , fSendPushSem(fContext.GetIoContext(), 384) , fSendPopSem(fContext.GetIoContext(), 0) diff --git a/fairmq/ofi/Socket.h b/fairmq/ofi/Socket.h index 4e05caed..d10679f4 100644 --- a/fairmq/ofi/Socket.h +++ b/fairmq/ofi/Socket.h @@ -93,8 +93,6 @@ class Socket final : public fair::mq::Socket std::atomic fMessagesRx; Address fRemoteAddr; Address fLocalAddr; - int fSndTimeout; - int fRcvTimeout; std::mutex fSendQueueMutex, fRecvQueueMutex; std::queue> fSendQueue, fRecvQueue; std::vector fInflightMultiPartMessage;