Self-tuning dataflow I/O core

A computer-readable medium carrying one or more sequences of instructions for managing a plurality of data communication connections having differing data communication rates, wherein execution of the one or more sequences of instructions by one or more processors causes the one or more processors to perform the steps of:

• A) assigning said data communication connections to a plurality of buckets that have a circular order;
• B) establishing a bucket of said plurality of buckets as a current bucket;
• C) establishing a connection assigned to said current bucket as a current connection;
• D) communicating data over said current connection;
• E) in response to communicating data over said current connection, re-assigning said current connection to a different bucket of said plurality of buckets based upon where said current bucket resides in said circular order and a bandwidth estimation of said current connection;
• F) repeating steps (C), (D) and (E) for each connection assigned to said current bucket;
• G) establishing a next bucket as a new current bucket, wherein said next bucket follows said current bucket in said circular order;
• and
• H) repeating step (F) and (G) for each bucket of said plurality of buckets.

A computer system, comprising:

• a processor;
• and
• a memory coupled to said processor, said memory comprising one or more sequences of instructions for managing a plurality of data communication connections having differing data communication rates, wherein execution of the one or more sequences of instructions by said processor causes the processor to perform the steps of:
• A) assigning said data communication connections to a plurality of buckets that have a circular order;
• B) establishing a bucket of said plurality of buckets as a current bucket;
• C) establishing a connection assigned to said current bucket as a current connection;
• D) communicating data over said current connection;
• E) in response to communicating data over said current connection, re-assigning said current connection to a different bucket of said plurality of buckets based upon where said current bucket resides in said circular order and a bandwidth estimation of said current connection;
• F) repeating steps (C), (D) and (E) for each connection assigned to said current bucket;
• G) establishing a next bucket as a new current bucket, wherein said next bucket follows said current bucket in said circular order;
• and
• H) repeating step (F) and (G) for each bucket of said plurality of buckets.