Skip to content

Commit

Permalink
changing zeromq dependency, and updating deprecated socket option (#122)
Browse files Browse the repository at this point in the history
  • Loading branch information
csegarragonz committed Jun 23, 2021
1 parent 1f3b249 commit 2d7fb18
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
3 changes: 2 additions & 1 deletion cmake/ExternalProjects.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -122,12 +122,13 @@ ExternalProject_Add(libzeromq_ext
GIT_REPOSITORY "https://github.com/zeromq/libzmq.git"
GIT_TAG "v4.3.4"
CMAKE_CACHE_ARGS "-DCMAKE_INSTALL_PREFIX:STRING=${CMAKE_INSTALL_PREFIX}"
"-DCMAKE_BUILD_TESTS:BOOL=OFF"
BUILD_BYPRODUCTS ${ZEROMQ_LIBRARY}
)
ExternalProject_Get_Property(libzeromq_ext SOURCE_DIR)
set(LIBZEROMQ_INCLUDE_DIR ${SOURCE_DIR})
ExternalProject_Add(cppzeromq_ext
GIT_REPOSITORY "https://github.com/faasm/cppzmq.git"
GIT_REPOSITORY "https://github.com/zeromq/cppzmq.git"
GIT_TAG "v4.7.1"
CMAKE_CACHE_ARGS "-DCPPZMQ_BUILD_TESTS:BOOL=OFF"
"-DCMAKE_INSTALL_PREFIX:STRING=${CMAKE_INSTALL_PREFIX}"
Expand Down
4 changes: 2 additions & 2 deletions src/transport/MessageEndpoint.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -81,8 +81,8 @@ void MessageEndpoint::open(faabric::transport::MessageContext& context,
}

// Set socket options
this->socket->setsockopt(ZMQ_RCVTIMEO, recvTimeoutMs);
this->socket->setsockopt(ZMQ_SNDTIMEO, sendTimeoutMs);
this->socket->set(zmq::sockopt::rcvtimeo, recvTimeoutMs);
this->socket->set(zmq::sockopt::sndtimeo, recvTimeoutMs);
}

void MessageEndpoint::send(uint8_t* serialisedMsg, size_t msgSize, bool more)
Expand Down

0 comments on commit 2d7fb18

Please sign in to comment.