git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@1377
48e7efb5-ca39-0410-a469-
dd3cf9ba447f
XBT_IN;
if (data->in.size!=data->in.pos) {
XBT_IN;
if (data->in.size!=data->in.pos) {
- WARN1("Socket closed, but %d bytes were unread",data->in.size - data->in.pos);
+ WARN3("Socket closed, but %d bytes were unread (size=%d,pos=%d)",
+ data->in.size - data->in.pos,data->in.size, data->in.pos);
}
if (data->out.size!=data->out.pos) {
}
if (data->out.size!=data->out.pos) {
data->in.pos=0;
} else {
memcpy((char*)&nextsize,data->in.data,4);
data->in.pos=0;
} else {
memcpy((char*)&nextsize,data->in.data,4);
- data->in.size = (int)ntohl(nextsize)+4;
+ data->in.size = nextsize+4;
- VERB3("Got the chunk (size=%d+4 for the size ifself)='%.*s'",data->in.size-4,
- data->in.size,data->in.data);
+ VERB3("Got the chunk (size=%d+4 for the size ifself)='%.*s'",
+ data->in.size-4, data->in.size,data->in.data);
if (XBT_LOG_ISENABLED(trp_buf,xbt_log_priority_debug))
hexa_print("chunck received",data->in.data,data->in.size);
}
if (XBT_LOG_ISENABLED(trp_buf,xbt_log_priority_debug))
hexa_print("chunck received",data->in.data,data->in.size);
}
XBT_IN;
DEBUG0("Flush");
if (XBT_LOG_ISENABLED(trp_buf,xbt_log_priority_debug))
XBT_IN;
DEBUG0("Flush");
if (XBT_LOG_ISENABLED(trp_buf,xbt_log_priority_debug))
- hexa_print("chunck to send",data->out.data,data->out.size);
+ hexa_print("chunck to send ",data->out.data,data->out.size);
if ((data->out.size - data->out.pos) == (gras_if_RL()?0:4) ) { /* 4 first bytes=size in SG mode*/
DEBUG2("Nothing to flush (size=%d; pos=%d)",data->out.size,data->out.pos);
return no_error;
if ((data->out.size - data->out.pos) == (gras_if_RL()?0:4) ) { /* 4 first bytes=size in SG mode*/
DEBUG2("Nothing to flush (size=%d; pos=%d)",data->out.size,data->out.pos);
return no_error;
TRY(super->chunk_send(sock, data->out.data, data->out.size));
VERB1("Chunk sent (size=%d)",data->out.size);
if (XBT_LOG_ISENABLED(trp_buf,xbt_log_priority_debug))
TRY(super->chunk_send(sock, data->out.data, data->out.size));
VERB1("Chunk sent (size=%d)",data->out.size);
if (XBT_LOG_ISENABLED(trp_buf,xbt_log_priority_debug))
- hexa_print("chunck sent",data->out.data,data->out.size);
- data->out.size = 0;
+ hexa_print("chunck sent ",data->out.data,data->out.size);
+ data->out.size = gras_if_RL()?0:4;