mirror of
https://github.com/zeromq/libzmq.git
synced 2025-03-19 18:03:50 +00:00
parent
7852a6ce98
commit
d7e51cdfed
@ -166,8 +166,9 @@ void zmq::pgm_receiver_t::in_event ()
|
|||||||
// If active_tsi is not null, there is a pending restart_input.
|
// If active_tsi is not null, there is a pending restart_input.
|
||||||
// Keep the internal state as is so that restart_input would process the right data
|
// Keep the internal state as is so that restart_input would process the right data
|
||||||
if (active_tsi) {
|
if (active_tsi) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Read data from the underlying pgm_socket.
|
// Read data from the underlying pgm_socket.
|
||||||
const pgm_tsi_t *tsi = NULL;
|
const pgm_tsi_t *tsi = NULL;
|
||||||
|
|
||||||
@ -181,8 +182,7 @@ void zmq::pgm_receiver_t::in_event ()
|
|||||||
while (true) {
|
while (true) {
|
||||||
// Get new batch of data.
|
// Get new batch of data.
|
||||||
// Note the workaround made not to break strict-aliasing rules.
|
// Note the workaround made not to break strict-aliasing rules.
|
||||||
|
insize = 0;
|
||||||
insize = 0;
|
|
||||||
void *tmp = NULL;
|
void *tmp = NULL;
|
||||||
ssize_t received = pgm_socket.receive (&tmp, &tsi);
|
ssize_t received = pgm_socket.receive (&tmp, &tsi);
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user