Patent application number | Description | Published |
20080298355 | Out of band messages - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A building block layer is coupled to the application programming interface. A channel layer is coupled to the building block layer. A transport protocol stack is coupled to the channel layer for implementing properties specified by the channel layer. The transport protocol stack has a concurrent stack consisting of an out of band thread pool and a regular thread pool. The regular thread pool forms one thread for every messages from a sender. The out of band thread pool to form one thread for messages marked as out of band from the sender. Messages processed with the thread from the out of band thread pool are processed before messages processed with the regular thread pool. | 12-04-2008 |
20080298357 | Logical addresses - A method and apparatus for processing message is described. In one embodiment, a channel layer is configured to form a logical address upon a creation of a channel of a group communication protocol, to store an association of the logical address with a message received with a sender's address in a cache of a member of the group, and to dissolve the logical address when the channel is to be closed or disconnected. | 12-04-2008 |
20080298363 | Message handling multiplexer - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A multiplexer receives messages from different servers. A service name is coupled to each message with the corresponding destination service. A single shared channel is formed. The messages are processed over the single shared channel. | 12-04-2008 |
20080298364 | Flush support for virtual synchrony - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. The application programming interface provides for a flush protocol to force members of a group to send all of their pending messages prior to a predetermined event, and to perform a message exchange phase as part of the flush protocol to allow all members of the group to see a same set of messages in a same view prior to installing a new view. | 12-04-2008 |
20080298395 | Channel bundling - A method and apparatus for processing message is described. In one embodiment, a channel layer is configured to form a channel with a corresponding process. The channel is associated with a group. A plurality of sockets is formed in a transport layer of a group communication protocol. Traffic of messages to and from the processes is distributed across the plurality of sockets in the transport layer. | 12-04-2008 |
20080301244 | Concurrent stack - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A building block layer is coupled to the application programming interface. A channel layer is coupled to the building block layer. A transport protocol stack is coupled to the channel layer for implementing properties specified by the channel layer. The transport protocol stack has a concurrent stack consisting of an out of band thread pool and a regular thread pool. The transport protocol layer is to process messages from each sender in parallel with the corresponding channel for each sender. | 12-04-2008 |
20080301706 | Flow control protocol - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A message credit account of a sender is maintained. The message credit account of the sender is debited when a message is received from the sender to a receiver. The message credit account of the sender is credited when a replenishment message is sent to the sender in response to the receiver processing the received message. The sender is prevented from sending any messages to the receiver when a balance in the message credit account of the sender becomes negative. | 12-04-2008 |
20080301709 | Queuing for thread pools using number of bytes - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A building block layer is coupled to the application programming interface. A channel layer is coupled to the building block layer. A transport protocol stack is coupled to the channel layer for implementing properties specified by the channel layer. The transport protocol stack has a concurrent stack consisting of an out of band thread pool and a regular thread pool. The transport protocol layer is to process messages from each sender in parallel with the corresponding channel for each sender. | 12-04-2008 |
20090063420 | Grid based file system - A method and apparatus for interfacing a drive with a tree-structured cluster as a library for a data grid storage system is described. In one embodiment, the tree-structured cluster of cache nodes is provided for storing data. The cluster is mounted as a drive or file system based on data stored in the cache nodes transparent to anyone using the drive or file system. A file system interface interfaces with the tree-structure cluster of cache nodes to presents data stored in the cache nodes. | 03-05-2009 |
20090219945 | Combined join and state transfer - A method and apparatus for processing messages is described. In one embodiment, an application programming interface provides for a flush protocol to force members of a group to send all of their pending messages prior to a predetermined event. A client sends a request to a coordinator of the group to join the group and to transfer a state of the group to the client. The application programming interface performs a single flush operation on the group in response to the request. | 09-03-2009 |
20090290586 | Shared Transport - A method and apparatus for processing message is described. In one embodiment, messages are received over a plurality of channels from a plurality of applications in a virtual machine. An identifier is coupled to each message. The identifier refers to the application originating the corresponding message. A shared transport is formed and associated with the channels. The messages are processed with the shared transport with the identifier. | 11-26-2009 |
20110080921 | LOGICAL ADDRESSES - A method and apparatus for processing message includes forming a logical address upon a creation of a channel of a group communication protocol at a logical address generator of a server. The logical address includes a unique identifier (UUID) associated with a logical name. The UUID created upon connecting the channel, and deleted upon disconnecting the channel. A mapping between UUIDs and physical addresses of members of the group is stored in a cache of a member of the group. | 04-07-2011 |
20110082908 | DYNAMIC CACHING OF NODES - A replication count of a data element of a node of a cache cluster is defined. The data element has a key-value pair where the node is selected based on a hash of the key and a size of the cache cluster. The data element is replicated to at least one other node of the cache cluster based on the replication count. | 04-07-2011 |
20120066313 | CONCURRENT DELIVERY FOR MESSAGES FROM A SAME SENDER - An apparatus and a method for processing messages. A transport protocol stack receives messages from senders. The transport protocol stack comprises a concurrent stack having an out of band thread pool and a non-out of band thread pool. A channel is formed with a thread from the non-out of band thread pool of the concurrent stack for each sender. Non-out of band messages are processed in parallel for each scope of an application with a non-out of band thread. Non-out of band messages pertains to processes of the application from a same sender. Processes from a scope of the application are unrelated to processes from another scope of the application. Non-out of band messages within a same scope are processed in a predefined order. | 03-15-2012 |
20120221636 | METHOD AND APPARATUS FOR USING A SHARED DATA STORE FOR PEER DISCOVERY - After acquiring a network address, a computing device accesses a shared data store and writes the network address to the shared data store. The computing device additionally reads a plurality of network addresses from the shared data store, wherein the plurality of network addresses are for a plurality of nodes that are members of a peer-to-peer system. The computing device then joins the peer-to-peer system based on communicating with the plurality of nodes using the plurality of network addresses. | 08-30-2012 |
20140105220 | MESSAGE HANDLING MULTIPLEXER - A method and apparatus for processing message is described. In one embodiment, an application programming interface is configured for receiving and sending messages. A multiplexer receives messages from different servers. A service name is coupled to each message with the corresponding destination service. A single shared channel is formed. The messages are processed over the single shared channel. | 04-17-2014 |
20150019812 | REPLICATION BETWEEN SITES USING KEYS ASSOCIATED WITH MODIFIED DATA - Systems and methods are disclosed for replicating data stored in an in-memory data cache to a remote site. An example system includes an in-memory data cache and an in-memory keys cache. The system also includes a key insert module that detects a modification to the in-memory data cache, identifies one or more keys of the plurality of keys based on the modification, and inserts the identified one or more keys into the in-memory keys cache. The system further includes an update module that retrieves from the in-memory keys cache a set of keys, retrieves from the in-memory data cache modified data associated with the set of keys, and transmits to a remote site a modification list including the set of keys and the modified data associated with the set of keys. | 01-15-2015 |