Skip to content

Commit

Permalink
Merge pull request zeromq#109 from jhawk28/master
Browse files Browse the repository at this point in the history
lowered version requirement for SNDTIMEO and RCVTIMEO
  • Loading branch information
gonzus committed Apr 4, 2012
2 parents ea14860 + 34f7486 commit fe47a77
Show file tree
Hide file tree
Showing 3 changed files with 27 additions and 14 deletions.
3 changes: 3 additions & 0 deletions .gitignore
Expand Up @@ -51,3 +51,6 @@ debian/jzmq.substvars
debian/jzmq/
debian/tmp/
.DS_Store
*.iml
config/
build/
18 changes: 14 additions & 4 deletions src/Socket.cpp
Expand Up @@ -106,13 +106,15 @@ JNIEXPORT jlong JNICALL Java_org_zeromq_ZMQ_00024Socket_getLongSockopt (JNIEnv *
case ZMQ_SNDHWM:
case ZMQ_RCVHWM:
case ZMQ_MULTICAST_HOPS:
case ZMQ_RCVTIMEO:
case ZMQ_SNDTIMEO:
#else
case ZMQ_HWM:
case ZMQ_SWAP:
case ZMQ_MCAST_LOOP:
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,2,0)
case ZMQ_RCVTIMEO:
case ZMQ_SNDTIMEO:
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,1,10)
case ZMQ_RECONNECT_IVL:
case ZMQ_RECONNECT_IVL_MAX:
Expand Down Expand Up @@ -207,13 +209,15 @@ JNIEXPORT void JNICALL Java_org_zeromq_ZMQ_00024Socket_setLongSockopt (JNIEnv *e
case ZMQ_SNDHWM:
case ZMQ_RCVHWM:
case ZMQ_MULTICAST_HOPS:
case ZMQ_RCVTIMEO:
case ZMQ_SNDTIMEO:
#else
case ZMQ_HWM:
case ZMQ_SWAP:
case ZMQ_MCAST_LOOP:
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,2,0)
case ZMQ_RCVTIMEO:
case ZMQ_SNDTIMEO:
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,1,10)
case ZMQ_RECONNECT_IVL:
case ZMQ_RECONNECT_IVL_MAX:
Expand All @@ -235,10 +239,16 @@ JNIEXPORT void JNICALL Java_org_zeromq_ZMQ_00024Socket_setLongSockopt (JNIEnv *e
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,1,0)
if(
(option == ZMQ_LINGER)
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,1,10)
|| (option == ZMQ_RECONNECT_IVL)
|| (option == ZMQ_RECONNECT_IVL_MAX)
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,2,0)
|| (option == ZMQ_SNDTIMEO)
|| (option == ZMQ_RCVTIMEO)
#endif
#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(2,1,0)
) {
int ival = (int) optval;
size_t optvallen = sizeof(ival);
Expand Down
20 changes: 10 additions & 10 deletions src/org/zeromq/ZMQ.java
Expand Up @@ -582,8 +582,8 @@ public long getMulticastHops () {
*
* @param timeout
*/
public void setReceiveTimeOut (long timeout) {
if (ZMQ.version_full() < ZMQ.make_version(3, 0, 0))
public void setReceiveTimeOut (int timeout) {
if (ZMQ.version_full() < ZMQ.make_version(2, 2, 0))
return;

setLongSockopt (RCVTIMEO, timeout);
Expand All @@ -594,10 +594,10 @@ public void setReceiveTimeOut (long timeout) {
*
* @return the Receive Timeout
*/
public long getReceiveTimeOut () {
if (ZMQ.version_full() < ZMQ.make_version(3, 0, 0))
public int getReceiveTimeOut () {
if (ZMQ.version_full() < ZMQ.make_version(2, 2, 0))
return -1;
return getLongSockopt (RCVTIMEO);
return (int) getLongSockopt (RCVTIMEO);
}

/**
Expand All @@ -609,8 +609,8 @@ public long getReceiveTimeOut () {
*
* @param timeout
*/
public void setSendTimeOut (long timeout) {
if (ZMQ.version_full() < ZMQ.make_version(3, 0, 0))
public void setSendTimeOut (int timeout) {
if (ZMQ.version_full() < ZMQ.make_version(2, 2, 0))
return;

setLongSockopt (SNDTIMEO, timeout);
Expand All @@ -621,10 +621,10 @@ public void setSendTimeOut (long timeout) {
*
* @return the Send Timeout.
*/
public long getSendTimeOut () {
if (ZMQ.version_full() < ZMQ.make_version(3, 0, 0))
public int getSendTimeOut () {
if (ZMQ.version_full() < ZMQ.make_version(2, 2, 0))
return -1;
return getLongSockopt (SNDTIMEO);
return (int) getLongSockopt (SNDTIMEO);
}

/**
Expand Down

0 comments on commit fe47a77

Please sign in to comment.