Revision 29e79c56 net_helper-ml.c
net_helper-ml.c | ||
---|---|---|
177 | 177 |
sendingBuffer[p->bIdx] = NULL; |
178 | 178 |
// fprintf(stderr,"Net-helper: Message # %d for connection %d sent!\n ", p->bIdx,connectionID); |
179 | 179 |
// event_base_loopbreak(base); |
180 |
free(p); |
|
180 | 181 |
} |
181 | 182 |
|
182 | 183 |
/** |
... | ... | |
341 | 342 |
return -1; |
342 | 343 |
} |
343 | 344 |
else { |
344 |
// fprintf(stderr,"Net-helper: Got a connection ID to send msg %d to %s.\n ",current,node_addr(to)); |
|
345 |
// struct timeval tout = {0,500}; |
|
346 |
// event_base_once(base,0, EV_TIMEOUT, &t_out_cb, NULL, &tout); |
|
347 |
while (sendingBuffer[current] != NULL) |
|
348 |
event_base_loop(base,EVLOOP_ONCE);// EVLOOP_NONBLOCK |
|
349 |
// fprintf(stderr,"Net-helper: Back from eventlib loop with status %d.\n", ok); |
|
350 |
int size = p->mSize; |
|
351 |
free(p); |
|
352 |
return size; |
|
345 |
return p->mSize; |
|
353 | 346 |
} |
354 | 347 |
|
355 | 348 |
} |
Also available in: Unified diff