example

Question

example

Closed this issue 7 years ago · 8 comments

Hi,

I try to use TokenBucket to limit the output rate of an UDP send... and I fail
Could you give us an example of how to use that class?
If I want to limit at X Mbps an UDP flow @ MTU octets per packet, how can I do?

thanks

Answer 1 · 2017-12-17T12:08:34.000Z

Consume one token per byte. Set max rate to number of bytes per second.

Answer 2 · 2017-12-20T08:47:21.000Z

Hi, thanks for answer
but what about burst size?

Answer 3 · 2017-12-20T09:39:41.000Z

Set it to at least your max rate. Higher if you want to allow higher temporary bursts.

…

On Wed, Dec 20, 2017, 09:47 michel ***@***.***> wrote: Hi, thanks for answer but what about burst size? — You are receiving this because you modified the open/close state. Reply to this email directly, view it on GitHub <#4 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AAK3a_T-5kjp8BeoZmrjtmlhXkuGPgYMks5tCMmagaJpZM4Q6zzq> .

Answer 4 · 2017-12-20T10:12:20.000Z

I tried this:

rate = 12500 (ko/s)
bs = 12500 (ko)
TokenBuket t(rate, bs);

if (t.consume(bs)) {
  //send bs octets
} else {
  sleep_for(1ms);
}

And I have ~ 700Mo/s with local loop
I missed something ... and I don't find
sorry for repeating the same question... thx for your help ;)

Answer 5 · 2017-12-20T10:15:51.000Z

I assume you are reusing the token bucket instance? It has state that needs to be preserved between consecutive consume calls.

…

On Wed, Dec 20, 2017, 11:12 michel ***@***.***> wrote: I tried this: rate = 12500 (ko/s) bs = 12500 (ko) TokenBuket t(rate, bs); if (t.consume(bs)) { //send bs octets } else { sleep_for(1ms); } And I have ~ 700Mo/s with local loop I missed something ... and I don't find sorry for repeating the same question... thx for your help ;) — You are receiving this because you modified the open/close state. Reply to this email directly, view it on GitHub <#4 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AAK3a1E7HBLGSy7rYqmyVg8PUH9CuQnvks5tCN2EgaJpZM4Q6zzq> .

Answer 6 · 2017-12-20T10:39:11.000Z

... and it works better with one instance :D

I get an average rate 30% over limit choosen
The µs resolution make the object difficult to use with octect/s directly, would switch to ns make it easier?

Answer 7 · 2017-12-20T10:51:37.000Z

No, but it should be quite easy for you to modify. I will accept a merge request. You can also make it sleep the exact amount needed, or return it from the consume call. The overhead is probably due to Ethernet + IP + UDP headers. You will need to take that into account. Depends on how you measure.

…

On Wed, Dec 20, 2017 at 4:39 AM michel ***@***.***> wrote: ... and it works better with one instance :D I get an average rate 30% over limit choosen The µs resolution make the object difficult to use with octect/s directly, would switch to ns make it easier? — You are receiving this because you modified the open/close state. Reply to this email directly, view it on GitHub <#4 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AAK3a90E0s1XnNP2AF8q5kMAcGuHwXeuks5tCOPQgaJpZM4Q6zzq> .

Answer 8 · 2017-12-21T06:45:49.000Z

my mistake... with a correct measure, it's ok
thanks a lot for help!