Sophie

Sophie

distrib > Fedora > 13 > i386 > media > os > by-pkgid > 8be2a15ee5eee9f246f70603486aff76 > files > 4

jgroups-manual-2.2.9.2-6.6.fc12.i686.rpm




Message bundling
================

// Version: $Id: Bundling.txt,v 1.4 2005/11/09 22:15:12 belaban Exp $
// Author: Bela Ban

Init:
-----

- set start = 0
- set wait_time = 0
- set count = 0


On Message:
-----------

- if start == 0:
  - set start = current time

- if msg.length + count >= max_bundle_size:
  - send all messages
  - set count = 0
  - set start = current time

- add message
- set count = count + msg.length

- compute new wait_time: max_bundle_time - (current time - start)
- if wait_time <= 0:
  - send all messages
  - Init()


On Timeout:
-----------

- send all messages
- Init()


New implementation (Nov 2005)
=============================
- done in TP.send(), this way message bundling and using a separate thread for sending
  messages are orthogonal issues

Variables:
----------
- queue, queue size

On send():
----------
- if msg size + queue size >= max_size:
    - cancel timer
    - bundle and send queued msgs
    - clear queue
- add msg to queue
- if timer is not running: start timer

On timer timeout:
-----------------
- bundle and send queued msgs (if any)
- clear queue