Revision 08a4230a ml.c

View differences:

ml.c
339 339 
					info("ML: sending message failed (to:%s conID:%d lconID:%d msgsize:%d offset:%d)\n", conid_to_string(con_id), ntohl(msg_h.remote_con_id), ntohl(msg_h.local_con_id), msg_len, offset);
340 340 
					offset = msg_len; // exit the while
341 341 
					break;
342 
                                case THROTTLE:
343 
                                    //    debug("THROTTLE on output");
344 
					offset = msg_len; // exit the while
345 
					break;
342 346 
				case OK:
343 347 
					//update
344 348 
					offset += pkt_len;
......
1328 1332 
	return create_socket(port, ipaddr);
1329 1333 
}
1330 1334 

  		




  
  1335
  
    
void mlSetThrottle(int bucketsize, int drainrate) {


  		




  
  1336
  
    
        setOutputRateParams(bucketsize, drainrate);


  		




  
  1337
  
    
}


  		




  
  1338
  
    
     


  		




  
  1339
  
    

  		




  1331
  1340
  
    
/* register callbacks  */


  		




  1332
  1341
  
    
void mlRegisterGetRecvPktInf(get_recv_pkt_inf_cb recv_pkt_inf_cb){


  		




  1333
  1342
  
    

  		












Also available in:  Unified diff