Revision 08a4230a ml.c
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