SYSTEM AND METHOD FOR PARALLEL MUXING BETWEEN SERVERS IN A CLUSTER

• US 20120066400A1
• Filed: 05/17/2011
• Published: 03/15/2012
• Est. Priority Date: 09/15/2010
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Reynolds, Nathan, Otenko, Oleksandr, Dorr, Joshua
• Granted Patent: US 8,756,329 B2
• Time in Patent Office: Days
• US Class Current: 709/228
• CPC Class Codes: G06F 15/17318 Parallel communications techniques, e.g. gather, scatter, reduce, roadcast, multicast, all to all
• CPC Class Codes: G06F 16/20 of structured data, e.g. relational data
• CPC Class Codes: G06F 16/2358 Change logging, detection, and notification replication G06F16/27
• CPC Class Codes: G06F 16/252 between a Database Management System and a front-end application
• CPC Class Codes: G06F 16/278 Data partitioning, e.g. horizontal or vertical partitioning
• CPC Class Codes: G06F 9/45504 Abstract machines for programme code execution, e.g. Java virtual machine [JVM], interpreters, emulators
• CPC Class Codes: H04L 41/042 comprising distributed management centres cooperatively managing the network
• CPC Class Codes: H04L 41/0686 Additional information in the notification, e.g. enhancement of specific meta-data
• CPC Class Codes: H04L 49/358 Infiniband Switches
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/1001 for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/1004 Server selection for load balancing
• CPC Class Codes: H04L 67/1027 Persistence of sessions during load balancing
• CPC Class Codes: H04L 67/1034 Reaction to server failures by a load balancer
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/14 Session management for real-time applications in data packet communications networks H04L65/1066
• CPC Class Codes: H04L 67/142 Managing session states for stateless protocols; Signalling session states; State transitions; Keeping-state mechanisms
• CPC Class Codes: H04L 67/146 Markers for unambiguous identification of a particular session, e.g. session cookie or URL-encoding
• CPC Class Codes: H04L 69/14 Multichannel or multilink protocols
• CPC Class Codes: Y10T 409/308904 : Multiple row dividing head
• CPC Class Codes: Y10T 409/309072 : including cutter limited to rotary motion
• CPC Class Codes: Y10T 409/309128 : with means to adjust work support vertically
• CPC Class Codes: Y10T 409/309352 : Cutter spindle or spindle support
• CPC Class Codes: Y10T 409/309408 : with cutter holder

Abstract

Systems and methods are provided for providing parallel muxing between servers in a cluster. One such system can include a cluster of one or more high performance computing systems, each including one or more processors and a high performance memory. The cluster communicates over an InfiniBand network. The system can also include a middleware environment, executing on the cluster, that includes one or more application server instances. The system can further include a plurality of muxers, wherein each application server instance includes at least one muxer. Each muxer can receive information from a plurality of threads to transmit to a different muxer on a different application server instance over the Infiniband network using a plurality of parallel channels.

Claims

1. A system for providing parallel muxing between servers in a cluster, comprising:

a cluster of one or more high performance computing systems, each including one or more processors and a high performance memory, and wherein the cluster communicates over an InfiniBand network;

a middleware environment, executing on the cluster, that includes one or more application server instances; and

a plurality of muxers, wherein each application server instance includes at least one muxer, and wherein each muxer receives information from a plurality of threads to transmit to a different muxer on a different application server instance over the Infiniband network using a plurality of parallel channels.

2. The system of claim 1 wherein a user can configure how many parallel channels are included in the plurality of parallel channels.

3. The system of claim 1 wherein the information includes session data.

4. The system of claim 1 wherein each muxer is a New I/O (NIO) muxer.

5. The system of claim 1 wherein an RMI stub is created for each of the plurality of parallel channels.

6. A method for providing parallel muxing between servers in a cluster, comprising:

providing a cluster of one or more high performance computing systems, each including one or more processors and a high performance memory, and wherein the cluster communicates over an InfiniBand network;

providing a middleware environment, executing on the cluster, that includes one or more application server instances; and

providing a plurality of muxers, wherein each application server instance includes at least one muxer;

receiving, by a first muxer at a first application server instance, information from a plurality of threads to transmit to a second muxer at a second application server instance;

transmitting the information to the second muxer over the Infiniband network using a plurality of parallel channels.

7. The method of claim 6 further comprising configuring how many parallel channels are included in the plurality of parallel channels, based on input from a user.

8. The method of claim 6 wherein the information includes session data.

9. The method of claim 6 wherein each muxer is a New I/O (NIO) muxer.

10. The method of claim 6 further comprising creating an RMI stub for each of the plurality of parallel channels.

11. A non-transitory computer readable storage medium, including instructions stored there on which, when executed by a computer, cause the computer to perform the steps of:

providing a cluster of one or more high performance computing systems, each including one or more processors and a high performance memory, and wherein the cluster communicates over an InfiniBand network;

providing a middleware environment, executing on the cluster, that includes one or more application server instances; and

providing a plurality of muxers, wherein each application server instance includes at least one muxer;

receiving, by a first muxer at a first application server instance, information from a plurality of threads to transmit to a second muxer at a second application server instance;

transmitting the information to the second muxer over the Infiniband network using a plurality of parallel channels.

12. The non-transitory computer readable storage medium of claim 11 further comprising configuring how many parallel channels are included in the plurality of parallel channels, based on input from a user.

13. The non-transitory computer readable storage medium of claim 11 wherein the information includes session data.

14. The non-transitory computer readable storage medium of claim 11 wherein each muxer is a New I/O (NIO) muxer.

15. The non-transitory computer readable storage medium of claim 11 further comprising creating an RMI stub for each of the plurality of parallel channels.