Methods and systems for bandwidth adaptive N-to-N communication in a distributed system

• US 8,732,242 B2
• Filed: 02/09/2012
• Issued: 05/20/2014
• Est. Priority Date: 05/04/2006
• Status: Active Grant

• Current Assignee: GOTO Group Incorporated (LogMeIn, Inc.)
• Original Assignee: Citrix Online LLC (Cloud Software Group)
• Inventors: Alexandrov, Albert, Saavedra, Rafael, Chalmers, Robert, Srinivasan, Kavitha
• Primary Examiner(s): Avellino, Joseph E
• Assistant Examiner(s): BARON, JAMES T
• Application Number:
  US13/369,985
• Publication Number:
  US 20120143955A1
• Time in Patent Office: 831 Days
• Field of Search: 709204-206, 709246-247
• US Class Current: 709/204
• CPC Class Codes: H04L 12/1886 with traffic restrictions for efficiency improvement, e.g. involving subnets or subdomains
• CPC Class Codes: H04L 65/1101 Session protocols
• CPC Class Codes: H04L 65/4038 with floor control
• CPC Class Codes: H04L 65/611 for multicast or broadcast systems for broadcast or conference H04L12/18; arrangements for broadcast or distribution combined with broadcast H04H20/00; arrangements for broadcast applications with a direct linkage to broadcast information or to broadcast space-time H04H60/00; selective distribution of broadcast services, e.g. multimedia broadcast multicast service [MBMS], H04W4/06
• CPC Class Codes: H04L 67/563 Data redirection of data network streams
• CPC Class Codes: H04L 67/63 Routing a service request depending on the request content or context

Abstract

Methods and systems for bandwidth adaptive computing device to computing device communication are described. Bandwidth adaptive communication includes receiving a communication from a first participant, storing the payload data of the communication in a channel memory element associated with the first participant, and transmitting the payload data to a second participant.

Claims

1. A method for bandwidth adaptive communication among a plurality of participants in a distributed system, the method comprising:

receiving, at a server, a communication from a first participant computing device, the communication including metadata and payload data;

storing the payload data in a channel memory element of the server, the channel memory element comprising a plurality of memory locations, one of the plurality of memory locations selected using the metadata and associated with the first participant computing device;

comparing contents of the channel memory element to a first record, residing at the server, of a copy of the channel memory element locally maintained by a second participant computing device, the first record being associated with the second participant computing device, wherein the first record is different from the one of the plurality of memory locations selected using the metadata and associated with the first participant computing device;

transmitting the payload data to the second participant computing device and updating the first record, residing at the server, upon a determination that the comparing between the contents of the channel memory element and the first record, residing at the server, of the copy of the channel memory element locally maintained by the second participant computing device reveals an update to the payload data stored in the selected one of the plurality of memory locations;

comparing contents of the channel memory element to a second record, residing at the server, of a copy of the channel memory element locally maintained by a third participant computing device, the second record being associated with the third participant computing device, wherein the second record is different from the one of the plurality of memory locations selected using the metadata and associated with the first participant computing device; and

transmitting the payload data to the third participant computing device and updating the second record, residing at the server, upon a determination that the comparing between the contents of the channel memory element and the second record, residing at the server, of the copy of the channel memory element locally maintained by the third participant computing device reveals an update to the payload data stored in the selected one of the plurality of memory locations;

wherein, during a given time period, the payload data is equivalent to the first record more often than the payload data is equivalent to the second record.

4. The method of claim 1 wherein a received communication comprises an identifier of the first participant computing device and the payload data.

5. The method of claim 1, wherein a received communication represents a state of the first participant computing device and comprises metadata and payload data.

6. The method of claim 1, wherein the storing step comprises storing the payload data in one of a plurality of array locations, the one of the plurality of array locations selected using the metadata and associated with the first participant computing device.

7. The method of claim 6, wherein the transmitting to the second participant computing device step comprises transmitting the array to the second participant computing device.

8. The method of claim 1, wherein the transmitting to the second participant computing device step comprises transmitting the payload data to the second participant computing device in response to information identifying the first participant computing device payload data most-recently received from the first participant computing device.

9. The method of claim 1, wherein the transmitting to the second participant computing device step comprises transmitting the payload data to the second participant computing device in response to a request from the second participant computing device.

10. The method of claim 1, wherein the transmitting to the second participant computing device step comprises transmitting the payload data to the second participant computing device in response to a request from the second participant computing device, the request identifying the first participant computing device payload data most-recently stored by the second participant computing device.

11. The method of claim 1, wherein, during the given time period, the payload data is equivalent to the first record more often than the payload data is equivalent to the second record due to the second participant computing device communicating via a connection which permits the second participant computing device to receive more data from the server during the given time period than the third participant computing device.

2. A non-transitory computer-readable medium for bandwidth adaptive communication among a plurality of participants in a distributed system, the computer-readable medium comprising instructions which, when executed by one or more computers, cause the one or more computers to implement a method, the method comprising:

receiving, at a server, a communication from a first participant computing device, the communication including metadata and payload data;

storing the payload data in a channel memory element of the server, the channel memory element comprising a plurality of memory locations, one of the plurality of memory locations selected using the metadata and associated with the first participant computing device;

comparing contents of the channel memory element to a first record, residing at the server, of a copy of the channel memory element locally maintained by a second participant computing device, the first record being associated with the second participant computing device, wherein the first record is different from the one of the plurality of memory locations selected using the metadata and associated with the first participant computing device;

transmitting the payload data to the second participant computing device and updating the first record, residing at the server, upon a determination that the comparing between the contents of the channel memory element and the first record, residing at the server, of the copy of the channel memory element locally maintained by the second participant computing device reveals an update to the payload data stored in the selected one of the plurality of memory locations;

comparing contents of the channel memory element to a second record, residing at the server, of a copy of the channel memory element locally maintained by a third participant computing device, the second record being associated with the third participant computing device, wherein the second record is different from the one of the plurality of memory locations selected using the metadata and associated with the first participant computing device; and

transmitting the payload data to the third participant computing device and updating the second record, residing at the server, upon a determination that the comparing between the contents of the channel memory element and the second record, residing at the server, of the copy of the channel memory element locally maintained by the third participant computing device reveals an update to the payload data stored in the selected one of the plurality of memory locations;

wherein, during a given time period, the payload data is equivalent to the first record more often than the payload data is equivalent to the second record.

3. A system for bandwidth adaptive communication among a plurality of participants, the system comprising:

one or more processors; and

a memory comprising instructions which, when executed by one or more processors, cause the one or more processors to implement a method, the method comprising;

receiving, at a server, a communication from a first participant computing device, the communication including metadata and payload data;

storing the payload data in a channel memory element of the server, the channel memory element comprising a plurality of memory locations, one of the plurality of memory locations selected using the metadata and associated with the first participant computing device;

comparing contents of the channel memory element to a first record, residing at the server, of a copy of the channel memory element locally maintained by a second participant computing device, the first record being associated with the second participant computing device, wherein the first record is different from the one of the plurality of memory locations selected using the metadata and associated with the first participant computing device;

transmitting the payload data to the second participant computing device and updating the first record, residing at the server, upon a determination that the comparing between the contents of the channel memory element and the first record, residing at the server, of the copy of the channel memory element locally maintained by the second participant computing device reveals an update to the payload data stored in the selected one of the plurality of memory locations;

comparing contents of the channel memory element to a second record, residing at the server, of a copy of the channel memory element locally maintained by a third participant computing device, the second record being associated with the third participant computing device, wherein the second record is different from the one of the plurality of memory locations selected using the metadata and associated with the first participant computing device; and

transmitting the payload data to the third participant computing device and updating the second record, residing at the server, upon a determination that the comparing between the contents of the channel memory element and the second record, residing at the server, of the copy of the channel memory element locally maintained by the third participant computing device reveals an update to the payload data stored in the selected one of the plurality of memory locations;

wherein, during a given time period, the payload data is equivalent to the first record more often than the payload data is equivalent to the second record.