초록 ▼

A method is disclosed for transferring data from a data source to a service broker. The method includes providing a data source and a service broker; providing a moderator for receiving the data transferred by the data source; providing a data store for storing data received by the moderator; and pr

A method is disclosed for transferring data from a data source to a service broker. The method includes providing a data source and a service broker; providing a moderator for receiving the data transferred by the data source; providing a data store for storing data received by the moderator; and providing a communications module for transferring data from the data store. Data is transferred from the data source to the moderator and stored by the moderator in the data store. The polling frequency is adaptively determined and the communications module is polled for the data on the data store and the data is forwarded to the service broker, whereby data is transferred between the data source and the service broker.

대표청구항 ▼

A method is disclosed for transferring data from a data source to a service broker. The method includes providing a data source and a service broker; providing a moderator for receiving the data transferred by the data source; providing a data store for storing data received by the moderator; and pr

A method is disclosed for transferring data from a data source to a service broker. The method includes providing a data source and a service broker; providing a moderator for receiving the data transferred by the data source; providing a data store for storing data received by the moderator; and providing a communications module for transferring data from the data store. Data is transferred from the data source to the moderator and stored by the moderator in the data store. The polling frequency is adaptively determined and the communications module is polled for the data on the data store and the data is forwarded to the service broker, whereby data is transferred between the data source and the service broker. ein the free list stores available cell buffers; and updating the free list to reflect usage of the next available cell buffer. 7. The method of claim 1, wherein queuing the cell in the next available cell buffer further comprises updating cell buffer context information that includes a next cell pointer and a copy count, wherein the copy count identifies a number of destinations that have yet to read the cell from a corresponding cell buffer of the root queue. 8. The method of claim 7 further comprises: providing the cell from the root queue to an egress connection associated with a selected leaf queue of the leaf queues; decrementing the copy count; updating a head pointer of the selected leaf queue; and when the copy count reaches a terminal count value, dequeuing the cell buffer from the root queue. 9. The method of claim 8, wherein updating the head pointer of the selected leaf queue further comprises: determining if the head pointer of the selected leaf queue indicates, based on present state of the root queue, that the selected leaf queue is empty; and when the selected leaf queue is empty, adding identity of the selected leaf queue to the segment queue. 10. The method of claim 1, wherein at least one of the leaf queues associated with the multicast transmission supports a test access connection (TAC), wherein the test access connection provides cells to a destination end system (DES). 11. A method for managing per connection queuing of a plurality of multicast transmissions, comprising: a) receiving cells via ingress connections of the plurality of multicast transmissions, wherein each of the plurality of multicast transmissions includes an ingress connection and a plurality of egress connections; b) queuing the cells in a plurality of root queues, wherein each of the plurality of root queues is associated with a corresponding one of the plurality of multicast transmissions; c) when a selected cell of the cells is queued in a selected root queue of the plurality of root queues corresponding to a selected multicast transmission of the plurality of multicast transmissions, determining whether a selected segment queue of a plurality of segment queues is non-empty, wherein each of the plurality of segment queues is associated with a corresponding one of the plurality of multicast transmissions, wherein the selected segment queue corresponds to the selected multicast transmission, wherein the selected segment queue stores indications of empty leaf queues corresponding to the selected multicast transmission, wherein leaf queues corresponding to the selected multicast transmission control transmission of cells on egress connections for the selected multicast transmission; and d) when the selected segment queue is non-empty, appending entries in the selected segment queue to an update queue as a segment, wherein the update queue is used to activate the empty leaf queues, wherein activating the empty leaf queues includes updating a leaf head pointer in each of the empty leaf queues to reflect presence of the selected cell in the selected root queue. 12. The method of claim 11 further comprises: determining when a leaf queue of the plurality of leaf queues is empty; and when the leaf queue is empty, adding identify of the leaf queue to a corresponding one of the segment queues. 13. The method of claim 11, wherein step (d) further comprises: determining if a number of empty leaf queues identified in the selected segment queue is less than a predetermined number; when the number of empty leaf queues identified in the selected segment queue is not less than the predetermined number, appending entries in the selected segment queue to the update queue as a segment; and when the number of empty leaf queues identified in the selected segment queue is less than the predetermined number, activating the empty leaf queues as the selected cell is queued in the selected root queue. 14. The method of clai