Revision 9f09d1ae ml.c

View differences:

ml.c
663 663 
// process a single recv data message
664 664 
void recv_data_msg(struct msg_header *msg_h, char *msgbuf, int bufsize)
665 665 
{
666 
	debug("ML: received packet of size %d with rconID:%d lconID:%d\n",bufsize,msg_h->remote_con_id,msg_h->local_con_id);
666 
	debug("ML: received packet of size %d with rconID:%d lconID:%d type:%d offset:%d\n",bufsize,msg_h->remote_con_id,msg_h->local_con_id,msg_h->msg_type,msg_h->offset);
667 667 

  		




  668
  668
  
    
	int recv_id, free_recv_id = -1;


  		




  669
  669
  
    

  		




  ......




  706
  706
  
    
		memset(recvdatabuf[recv_id]->recvbuf, 0, msg_h->msg_length);


  		




  707
  707
  
    
		debug(" new @ id:%d\n",recv_id);


  		




  708
  708
  
    
	} else {	//message structure already exists, no need to create new


  		




  709
  
  
    
		debug(" found @ id:%d\n",recv_id);


  		




  
  709
  
    
		debug(" found @ id:%d (arrived before this packet: bytes:%d fragments%d\n",recv_id, recvdatabuf[recv_id]->arrivedBytes, recvdatabuf[recv_id]->recvFragments);


  		




  710
  710
  
    
	}


  		




  711
  711
  
    

  		




  712
  712
  
    
	if (msg_h->offset == 0)


  		












Also available in:  Unified diff