System and method for implementing augmented object members for remote procedure call

• US 10,536,560 B2
• Filed: 03/12/2018
• Issued: 01/14/2020
• Est. Priority Date: 09/13/2013
• Status: Active Grant

• Current Assignee: John Wason
• Original Assignee: John Wason
• Inventors: Wason, John
• Primary Examiner(s): Chan, Wing F
• Assistant Examiner(s): Ng, Billy H
• Application Number:
  US15/918,388
• Publication Number:
  US 20180270331A1
• Time in Patent Office: 673 Days
• CPC Class Codes: G06F 9/547 Remote procedure calls [RPC]; Web services
• CPC Class Codes: G06F 9/548 Object oriented; Remote method invocation [RMI] non-remote method invocation G06F9/449
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/133 Protocols for remote procedure calls [RPC]

Abstract

A communication method and system configured to facilitate integration of complex automation systems composed of disparate components that may run with different processes are distributed over a network or are embedded devices. The system/method allows for a client to rapidly access functionality exposed by a service within a client-service system employing a distributed application structure utilizing an augmented object-oriented model of multiple member types. The system/method allows interconnected nodes to communicate through message passing and remote procedure calling so as to reduce latency within a system composed of distributed resources.

Claims

1. A system for executing remote procedure calls between a client and a server comprising:

at least one client, said client comprising a machine with at least one processor and a storage device communicatively coupled to the at least one processor, the storage device storing instructions which, when executed by the at least one processor, cause the at least one processor to perform operations;

at least one server in operable communication with said client, said server comprising a machine with at least one processor and a storage device communicatively coupled to the at least one processor, the storage device storing instructions which, when executed by the at least one processor, cause the at least one processor to perform operations; and

a hierarchical communication architecture comprising;

at least one channel, said channel providing a communication bridge between at least one client node and at least one server node;

a message passing layer, said message passing layer passing messages comprising routing information and serialized data between at least one client endpoint associated with at least one client node and at least one server endpoint associated with said at least one server node for non-critical operations;

a remote procedure call layer comprising an augmented object-oriented interface overlaying said message passing layer, said remote procedure call layer further comprising an augmented object-oriented model comprising a plurality of defined member types, said defined member types comprising a function member, a property member, an event member, an object reference (objref) member, a pipe member, a callback member, a wire member, and a memory member, said remote procedure call layer comprising a client context endpoint associated with said client node and configured for identifying object references, processing transaction requests, and dispatching events received from said server node, for latency sensitive operations; and

a readonly modifier and a writeonly modifier, wherein said readonly and writeonly modifier can be applied to at least one of;

said property member, said pipe member, said wire member, and said memory member.

2. The system of claim 1 wherein said property member is configured to get a variable value or to set a variable value.

3. The system of claim 1 wherein said a wire member is configured to communicate a most recent value between said server and at least one client with a best-effort delivery.

4. The system of claim 3 further comprising:

a PeekInValue configured to read a current InValue at the client requested from the server;

a PeekOutValue configured to read a current OutValue for the client received by the server; and

a PokeOutValue configured to write said current OutValue for the client by requesting the server update said OutValue.

5. The system of claim 1 wherein said function member is configured to allow a function of zero or more parameters to be called by said at least one client with zero or one return values.

6. The system of claim 1 wherein said event member is configured to allow said server to notify said at least one client with zero or more parameters.

7. The system of claim 1 wherein said object reference (objref) member is configured to retrieve object references from said server.

8. The system of claim 1 wherein said pipe member is configured to allow said at least one client to request a pipe endpoint be created with a matching endpoint in said server in order to send/receive packets between endpoints, with at least one of:

a reliable in-order delivery; and

an unreliable best-effort delivery.

9. The system of claim 1 wherein said callback member is configured to allow said server to execute a function on said at least one client with zero or more parameters and zero or one return value.

10. The system of claim 1 wherein said memory member is configured to allow said at least one client to read or write randomly accessible memory segments comprising at least one of:

fixed numbers; and

floating point numbers.

11. The system of claim 1 further comprising providing service subscriptions between the client and server, said service subscriptions comprising at least one of:

a Serviceinfo2Subscription;

a ServiceSubscription;

a PipeSubscription; and

a WireSubscription.

12. The system of claim 1 further comprising a filter with criteria comprising:

servicetypes; and

maxconnections.

13. The system of claim 12 wherein said filter further comprises at least one of:

nodes;

transportschemes; and

predicate.