- for (exp_sofar=0; exp_sofar < exp_size; exp_sofar += chunk_size) {
- chunk_size = exp_sofar + msg_size > exp_size ?
- exp_size - exp_sofar : msg_size;
- CDEBUG6(gras_trp_meas,"Recvd %ld of %lu (msg_size=%ld) from %s:%d, receiving %lu",
- exp_sofar,exp_size,msg_size,
- gras_socket_peer_name(peer), gras_socket_peer_port(peer),
- chunk_size);
- (peer->plugin->raw_recv)(peer,chunk,chunk_size);
+ for (got_sofar=0; got_sofar < msg_amount; got_sofar ++) {
+ CDEBUG5(gras_trp_meas,"Recvd %ld msgs of %lu (size of each: %ld) from %s:%d",
+ got_sofar,msg_amount,msg_size,
+ gras_socket_peer_name(peer), gras_socket_peer_port(peer));
+ (peer->plugin->raw_recv)(peer,chunk,msg_size);