专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

31. 发明申请

US20140075071A1 SYSTEM AND METHOD FOR SUPPORTING MESSAGE PRE-PROCESSING IN A DISTRIBUTED DATA GRID CLUSTER 有权
标题翻译：在分布式数据网格集群中支持消息预处理的系统和方法
公开(公告)号：US20140075071A1
公开(公告)日：2014-03-13
申请号：US14020422
申请日：2013-09-06
申请人： Oracle International Corporation
发明人： Mark Falco , Alex Gleyzer
IPC分类号： G06F13/20
CPC分类号： G06F13/20 , G06F9/546 , G06F13/42 , G06F2209/547 , H04L67/1097
摘要： A system and method can support message pre-processing in a distributed data grid. The system can associate a message bus with a service thread on a cluster member in the distributed data grid. Furthermore, the system can receive one or more incoming messages at the message bus using an input/output (I/O) thread, and pre-process said one or more incoming messages on the I/O thread before each said incoming message is delivered to a service thread in the distributed data grid. Additionally, the system can take advantage of a pool of input/output (I/O) threads to deserialize inbound messages before they are delivered to the addressed service, and can relieve the bottleneck that is caused by performing all message deserialization in a single threaded fashion before the message type can be identified and offloaded to the thread-pool within the distributed data grid.
摘要翻译：系统和方法可以支持分布式数据网格中的消息预处理。系统可以将消息总线与分布式数据网格中的集群成员上的服务线程相关联。此外，系统可以使用输入/输出（I / O）线程在消息总线处接收一个或多个输入消息，并且在每个所述传入消息被递送之前在I / O线程上预处理所述一个或多个输入消息到分布式数据网格中的服务线程。此外，系统可以利用输入/输出（I / O）线程池对入站消息进行反序列化，然后将其传递到寻址服务，并可以减轻在单个线程中执行所有消息反序列化所引起的瓶颈消息类型之前的时间可以被识别并被分配到分布式数据网格内的线程池中。

32. 发明授权

US10798146B2 System and method for universal timeout in a distributed computing environment 有权
公开(公告)号：US10798146B2
公开(公告)日：2020-10-06
申请号：US15200897
申请日：2016-07-01
申请人： Oracle International Corporation
发明人： Mark Falco
IPC分类号： H04L12/24 , H04L12/26 , H04L29/08 , G06F9/48
摘要： A system and method for supporting universal timeout in a distributed computing environment. The universal timeout feature can enforce a defined timeout for a block (or group of blocks) or code executing on a thread regardless of the number of network hops required to effectuate the code. The universal timeout feature allows a thread to express a timeout which is respected across the platform thereby improving timeout functionality compared to prior timeout implementations which pass a timeout between functions. Universal timeout may be implemented using a try-with-resources paradigm where the timeout period is treated as a resource.

33. 发明授权

US10706021B2 System and method for supporting persistence partition discovery in a distributed data grid 有权
公开(公告)号：US10706021B2
公开(公告)日：2020-07-07
申请号：US14271142
申请日：2014-05-06
申请人： Oracle International Corporation
发明人： Robert H. Lee , Jason John Howes , Mark Falco , Gene Gleyzer
IPC分类号： G06F16/182 , G06F16/27 , G06F16/11 , G06F16/21 , G06F9/50 , G06F11/14 , G06F11/16 , G06F16/18
摘要： A system and method can support persistence in a distributed data grid. A plurality of members in the distributed data grid can persist a plurality of partitions associated with one or more cache services in persistent storage. Furthermore, a coordinator, which may be a member in the distributed data grid, can synchronize a view of partition ownership among the plurality of members in the distributed data grid, and form a distributed consensus on which partition can be recovered from which member in the distributed data grid.

34. 发明授权

US09990239B2 System and method for supporting cooperative notification offloading in a distributed data grid 有权
公开(公告)号：US09990239B2
公开(公告)日：2018-06-05
申请号：US14856367
申请日：2015-09-16
申请人： Oracle International Corporation
发明人： Mark Falco
IPC分类号： G06F9/54
CPC分类号： G06F9/542
摘要： A system and method for cooperative notification offloading supports thread notification offloading in a multi-threaded messaging system such as a distributed data grid. Pending notifiers are maintained in a collection of pending notifiers. A signaling thread processes a first notifier in the collection of pending notifiers to wake a first thread. The first awoken thread processes additional notifiers in the collection of pending notifiers to wake additional threads. The additional awoken threads can process additional notifiers in a cycle until all pending notifiers in the collection are processed. Such cooperative notification offloading of notifier processing from the signaling thread improves performance of the signaling thread with respect to other tasks thereby improving performance of the signaling thread and the distributed data grid.

35. 发明授权

US09787561B2 System and method for supporting a selection service in a server environment 有权
公开(公告)号：US09787561B2
公开(公告)日：2017-10-10
申请号：US13671433
申请日：2012-11-07
申请人： Oracle International Corporation
发明人： Mark Falco , Ballav Bihani
IPC分类号： G06F15/173 , H04L12/26 , G06F17/30 , H04L29/08 , G06F11/16 , G06F11/20 , H04L12/24
CPC分类号： H04L43/0811 , G06F11/16 , G06F11/2041 , G06F11/2048 , G06F11/2097 , G06F17/30067 , G06F17/30371 , G06F2201/82 , H04L41/0668 , H04L67/1095
摘要： A system and method can support socket programming in a server environment, such as a distributed data grid. The server environment can include a selection service that operates to register a plurality of sockets, wherein each socket is associated with a handler in a plurality of handlers. Furthermore, the selection service can listen for one or more incoming connection requests on the plurality of sockets, and invoke a pluggable callback provided by a handler associated with a registered socket in the plurality of sockets, when registered socket receives an incoming connection request.

36. 发明授权

US09672038B2 System and method for supporting a scalable concurrent queue in a distributed data grid 有权
公开(公告)号：US09672038B2
公开(公告)日：2017-06-06
申请号：US14856106
申请日：2015-09-16
申请人： Oracle International Corporation
发明人： Mark Falco
IPC分类号： G06F9/30 , G06F9/54
CPC分类号： G06F9/3009 , G06F9/546 , G06F2209/548
摘要： A scalable concurrent queue includes a central queue associated with multiple temporary queues for holding batches of nodes from multiple producers. When a producer thread or service performs an insertion operation on the scalable concurrent queue, the producer inserts one or more nodes into a batch in one of the multiple temporary queues associated with the central queue. Subsequently, the producer (or another producer) inserts the batch held in the temporary queue into the central queue. Contention between the multiple producers is reduced by providing multiple temporary queues into which the producers may insert nodes, and also by inserting nodes in the central queue in batches rather than one node at a time. The scalable concurrent queue scales to serve large number of producers with reduced contention thereby improving performance in a distributed data grid.

37. 发明授权

US09535863B2 System and method for supporting message pre-processing in a distributed data grid cluster 有权
标题翻译：在分布式数据网格集群中支持消息预处理的系统和方法
公开(公告)号：US09535863B2
公开(公告)日：2017-01-03
申请号：US14020422
申请日：2013-09-06
申请人： Oracle International Corporation
发明人： Mark Falco , Alex Gleyzer
IPC分类号： G06F13/20 , G06F13/42 , H04L29/08 , G06F9/54
CPC分类号： G06F13/20 , G06F9/546 , G06F13/42 , G06F2209/547 , H04L67/1097
摘要： A system and method can support message pre-processing in a distributed data grid. The system can associate a message bus with a service thread on a cluster member in the distributed data grid. Furthermore, the system can receive one or more incoming messages at the message bus using an input/output (I/O) thread, and pre-process said one or more incoming messages on the I/O thread before each said incoming message is delivered to a service thread in the distributed data grid. Additionally, the system can take advantage of a pool of input/output (I/O) threads to deserialize inbound messages before they are delivered to the addressed service, and can relieve the bottleneck that is caused by performing all message deserialization in a single threaded fashion before the message type can be identified and offloaded to the thread-pool within the distributed data grid.
摘要翻译：系统和方法可以支持分布式数据网格中的消息预处理。系统可以将消息总线与分布式数据网格中的集群成员上的服务线程相关联。此外，系统可以使用输入/输出（I / O）线程在消息总线处接收一个或多个输入消息，并且在每个所述传入消息被递送之前在I / O线程上预处理所述一个或多个输入消息到分布式数据网格中的服务线程。此外，系统可以利用输入/输出（I / O）线程池对入站消息进行反序列化，然后将其传递到寻址服务，并可以减轻在单个线程中执行所有消息反序列化所引起的瓶颈消息类型之前的时间可以被识别并被分配到分布式数据网格内的线程池中。

38. 发明申请

US20150169653A1 SYSTEM AND METHOD FOR SUPPORTING PERSISTENT STORE VERSIONING AND INTEGRITY IN A DISTRIBUTED DATA GRID 审中-公开
标题翻译：用于支持分布式数据网络中的持续存储版本和完整性的系统和方法
公开(公告)号：US20150169653A1
公开(公告)日：2015-06-18
申请号：US14271150
申请日：2014-05-06
申请人： Oracle International Corporation
发明人： Robert H. Lee , Jason John Howes , Mark Falco , Gene Gleyzer
IPC分类号： G06F17/30
CPC分类号： G06F17/30088 , G06F9/5027 , G06F9/5061 , G06F11/1425 , G06F11/1438 , G06F11/1448 , G06F11/1464 , G06F11/1469 , G06F11/1482 , G06F17/30309 , G06F17/30575 , G06F2201/84 , G06F2209/505
摘要： A system and method can support persistence in a distributed data grid, such as persistent store versioning and integrity. A resolver in the distributed data grid can receive a plurality of identifiers from one or more members of the distributed data grid, wherein each said identifier is associated with a persisted partition in a persistent storage for the distributed data grid. Then, the resolver can select an identifier for each partition, wherein each selected identifier is associated with a most recent valid version of a partition. Furthermore, the resolver can determine a member in the distributed data grid that is responsible for recovering said partition from a persisted partition associated with the selected identifier.
摘要翻译：系统和方法可以支持分布式数据网格中的持久性，例如持久存储版本控制和完整性。分布式数据网格中的解析器可以从分布式数据网格的一个或多个成员接收多个标识符，其中每个所述标识符与用于分布式数据网格的持久存储器中的持久化分区相关联。然后，解析器可以选择每个分区的标识符，其中每个选择的标识符与分区的最新有效版本相关联。此外，解析器可以确定负责从与所选择的标识符相关联的持久化分区中恢复所述分区的分布式数据网格中的成员。

39. 发明授权

US08935707B2 System and method for providing a messaging application program interface 有权
标题翻译：用于提供消息传递应用程序接口的系统和方法
公开(公告)号：US08935707B2
公开(公告)日：2015-01-13
申请号：US13693764
申请日：2012-12-04
申请人： Oracle International Corporation
发明人： Mark Falco , Patrik Torstensson , Gene Gleyzer , Cameron Purdy
IPC分类号： G06F3/00 , G06F13/28 , G06F9/54
CPC分类号： G06F9/546 , G06F2209/547
摘要： A system and method for providing a message bus component or version thereof (referred to herein as an implementation), and a messaging application program interface, for use in an enterprise data center, middleware machine system, or similar environment that includes a plurality of processor nodes together with a high-performance communication fabric (or communication mechanism) such as InfiniBand. In accordance with an embodiment, the messaging application program interface enables features such as asynchronous messaging, low latency, and high data throughput, and supports the use of in-memory data grid, application server, and other middleware components.
摘要翻译：一种用于提供消息总线部件或其版本（在本文中称为实现）的系统和方法以及消息应用程序接口，用于企业数据中心，中间件机器系统或包括多个处理器的类似环境节点以及InfiniBand等高性能通信结构（或通信机制）。根据实施例，消息收发应用程序接口实现诸如异步消息，低延迟和高数据吞吐量之类的特征，并且支持使用内存中数据网格，应用服务器和其他中间件组件。

40. 发明申请

US20140108681A1 SYSTEM AND METHOD FOR PROVIDING A FLEXIBLE BUFFER MANAGEMENT INTERFACE IN A DISTRIBUTED DATA GRID 有权
标题翻译：在分布式数据网络中提供灵活缓冲区管理接口的系统和方法
公开(公告)号：US20140108681A1
公开(公告)日：2014-04-17
申请号：US13671441
申请日：2012-11-07
申请人： ORACLE INTERNATIONAL CORPORATION
发明人： Charlie Helin , Mark Falco
IPC分类号： G06F5/06
CPC分类号： H04L43/0811 , G06F11/16 , G06F11/2041 , G06F11/2048 , G06F11/2097 , G06F17/30067 , G06F17/30371 , G06F2201/82 , H04L41/0668 , H04L67/1095
摘要： A system and method can provide a flexible buffer management interface in a distributed data grid. The buffer manager in the distributed data grid can receive a request from a requester for a buffer in the distributed data grid, wherein the request contains at least one parameter that provides an indication on the size of the requested buffer. Then, the buffer manager can allocate a buffer based on the indication in the request and provide the allocated buffer to the requester, wherein an actual size of the buffer is determined by the buffer manager.
摘要翻译：系统和方法可以在分布式数据网格中提供灵活的缓冲管理接口。分布式数据网格中的缓冲器管理器可以从请求者接收对分布式数据网格中的缓冲器的请求，其中该请求包含至少一个参数，该参数提供关于所请求的缓冲器的大小的指示。然后，缓冲器管理器可以基于请求中的指示来分配缓冲器，并将所分配的缓冲区提供给请求者，其中缓冲器管理器确定缓冲器的实际大小。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式