Attachment #358546 for bug #483318

View | Details | Raw Unified | Return to bug 483318
Collapse All | Expand All




                zmq_msg_t msg;
                zmq_msg_init (&msg);
                zmq_msg_recv (&msg, pubSocket, 0);
                int msgSize = zmq_msg_size(&msg);
                char* buffer = (char*)zmq_msg_data(&msg);

                if (buffer[0] == 0) {
                    assert(isSubscribed);
                    isSubscribed = false;
                } 
                else {
                    assert(!isSubscribed);
                    isSubscribed = true;
                }

                zmq_msg_t msg;
                zmq_msg_init (&msg);
                zmq_msg_recv (&msg, subSocket, 0);
                int msgSize = zmq_msg_size(&msg);
                char* buffer = (char*)zmq_msg_data(&msg);
        
        
                zmq_getsockopt (subSocket, ZMQ_RCVMORE, &more, &more_size);
                zmq_msg_close (&msg);
        

Return to bug 483318

Lines 40-52 Link Here

(-)zeromq-3.2.3/tests/test_disconnect_inproc.cpp (-6 / +2 lines)
40	zmq_msg_t msg;	40	zmq_msg_t msg;
41	zmq_msg_init (&msg);	41	zmq_msg_init (&msg);
42	zmq_msg_recv (&msg, pubSocket, 0);	42	zmq_msg_recv (&msg, pubSocket, 0);
43	int msgSize = zmq_msg_size(&msg);
44	char* buffer = (char*)zmq_msg_data(&msg);	43	char* buffer = (char*)zmq_msg_data(&msg);
45		44
46	if (buffer[0] == 0) {	45	if (buffer[0] == 0) {
47	assert(isSubscribed);	46	assert(isSubscribed);
48	isSubscribed = false;	47	isSubscribed = false;
49	} else {	48	}
		49	else {
50	assert(!isSubscribed);	50	assert(!isSubscribed);
51	isSubscribed = true;	51	isSubscribed = true;
52	}	52	}
Lines 64-73 Link Here
64	zmq_msg_t msg;	64	zmq_msg_t msg;
65	zmq_msg_init (&msg);	65	zmq_msg_init (&msg);
66	zmq_msg_recv (&msg, subSocket, 0);	66	zmq_msg_recv (&msg, subSocket, 0);
67	int msgSize = zmq_msg_size(&msg);
68	char* buffer = (char*)zmq_msg_data(&msg);
69
70
71	zmq_getsockopt (subSocket, ZMQ_RCVMORE, &more, &more_size);	67	zmq_getsockopt (subSocket, ZMQ_RCVMORE, &more, &more_size);
72	zmq_msg_close (&msg);	68	zmq_msg_close (&msg);
73		69