mirror of
https://github.com/zeromq/libzmq.git
synced 2025-03-09 07:16:04 +00:00
Test cases were failing on bind
This commit is contained in:
parent
c1f76e433f
commit
8ba097f3da
@ -53,7 +53,7 @@ int main (void)
|
|||||||
val = 0;
|
val = 0;
|
||||||
rc = zmq_setsockopt(to, ZMQ_LINGER, &val, sizeof(val));
|
rc = zmq_setsockopt(to, ZMQ_LINGER, &val, sizeof(val));
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
rc = zmq_bind(to, "tcp://*:5555");
|
rc = zmq_bind(to, "tcp://*:6555");
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
|
|
||||||
// Create a socket pushing to two endpoints - only 1 message should arrive.
|
// Create a socket pushing to two endpoints - only 1 message should arrive.
|
||||||
|
@ -42,7 +42,7 @@ int tcp_client ()
|
|||||||
struct sockaddr_in serv_addr;
|
struct sockaddr_in serv_addr;
|
||||||
struct hostent *server;
|
struct hostent *server;
|
||||||
|
|
||||||
const int portno = 5555;
|
const int portno = 7555;
|
||||||
|
|
||||||
int sockfd = socket (AF_INET, SOCK_STREAM, 0);
|
int sockfd = socket (AF_INET, SOCK_STREAM, 0);
|
||||||
assert (sockfd >= 0);
|
assert (sockfd >= 0);
|
||||||
@ -77,7 +77,7 @@ int tcp_server ()
|
|||||||
memset (&serv_addr, 0, sizeof serv_addr);
|
memset (&serv_addr, 0, sizeof serv_addr);
|
||||||
serv_addr.sin_family = AF_INET;
|
serv_addr.sin_family = AF_INET;
|
||||||
serv_addr.sin_addr.s_addr = htonl (INADDR_ANY);
|
serv_addr.sin_addr.s_addr = htonl (INADDR_ANY);
|
||||||
serv_addr.sin_port = htons (5555);
|
serv_addr.sin_port = htons (7555);
|
||||||
|
|
||||||
rc = bind (listenfd, (struct sockaddr *) &serv_addr, sizeof serv_addr);
|
rc = bind (listenfd, (struct sockaddr *) &serv_addr, sizeof serv_addr);
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
@ -165,7 +165,7 @@ void test_zmq_connect ()
|
|||||||
rc = zmq_setsockopt (zs, ZMQ_ROUTER_RAW, &raw_sock, sizeof raw_sock);
|
rc = zmq_setsockopt (zs, ZMQ_ROUTER_RAW, &raw_sock, sizeof raw_sock);
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
|
|
||||||
rc = zmq_connect (zs, "tcp://127.0.0.1:5555");
|
rc = zmq_connect (zs, "tcp://127.0.0.1:7555");
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
|
|
||||||
int i;
|
int i;
|
||||||
@ -213,7 +213,7 @@ int main ()
|
|||||||
int raw_sock = 1;
|
int raw_sock = 1;
|
||||||
int rc = zmq_setsockopt (sb, ZMQ_ROUTER_RAW, &raw_sock, sizeof raw_sock);
|
int rc = zmq_setsockopt (sb, ZMQ_ROUTER_RAW, &raw_sock, sizeof raw_sock);
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
rc = zmq_bind (sb, "tcp://127.0.0.1:5555");
|
rc = zmq_bind (sb, "tcp://127.0.0.1:7555");
|
||||||
assert (rc == 0);
|
assert (rc == 0);
|
||||||
|
|
||||||
int sock_fd = tcp_client ();
|
int sock_fd = tcp_client ();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user