A session change over system monitors nodes to determine whether they are operational, and transfers user equipment from one node to another when nodes are not operational. The session change over system receives one or more health check messages from one or more foreign nodes which communicate with user equipment. The session change over system inspects each health check message to determine whether a foreign node is not operational. The session change over system identifies user equipment in communication with the foreign node at a time before the foreign node was not operational. The session change over system communicates with the identified user equipment in place of the foreign node.

An I/O server service interacts with multiple containerized controller services each implementing the same control routine to control the same portion of the same plant. The I/O server service may provide the same controller inputs to each of the containerized controller services (e.g., representing measurements obtained by field devices and transmitted by the field devices to the I/O server service). Each containerized controller service executes the same control routine to generate a set of controller outputs. The I/O server service receives each set of controller outputs and forwards an “active” set to the appropriate field devices. The I/O server service and other services, such as an orchestrator service, may continuously evaluate performance and resource utilization in the control system, and may dynamically activate and deactivate controller services as appropriate. The I/O server service may interact with other containerized services, such as containerized historian services or workstation services, to facilitate control in the plant.

The disclosed embodiments provide a system for managing a stream-processing application. During operation, the system allocates a first host for an active instance of the stream-processing application that maintains a state during processing of one or more input streams. Next, the system allocates a second host for a first backup instance that recreates the state on the active instance by consuming changes to the state replicated from the active instance without consuming the input stream(s). During a failure on the first host, the system moves the active instance to the first host by stopping the first backup instance on the second host. Finally, the system launches the active instance on the second host to resume processing of the input stream(s) by the active instance using the recreated state from the first backup instance.

The disclosed embodiments provide a system for managing a stream-processing application. During operation, the system allocates a first host for an active instance of the stream-processing application that maintains a state during processing of one or more input streams. Next, the system allocates a second host for a first backup instance that recreates the state on the active instance by consuming changes to the state replicated from the active instance without consuming the input stream(s). During a failure on the first host, the system moves the active instance to the first host by stopping the first backup instance on the second host. Finally, the system launches the active instance on the second host to resume processing of the input stream(s) by the active instance using the recreated state from the first backup instance.

This application provides a data transmission method and system, an apparatus, and belongs to the field of communications technologies. The method is applied to a terminal, a wireless link is established between the terminal and an access control point device, a transmission control protocol (TCP) connection is established between the terminal and a server, and the wireless link is used to bear the TCP connection. The method includes: determining, by the terminal, link state information of the wireless link by using a link layer, and sending the link state information from the link layer to a transport layer. The method also includes: sending, by the terminal to the server by using the transport layer, a link notification corresponding to the link state information. In this application, data transmission efficiency can be improved.

This application provides a data transmission method and system, an apparatus, and belongs to the field of communications technologies. The method is applied to a terminal, a wireless link is established between the terminal and an access control point device, a transmission control protocol (TCP) connection is established between the terminal and a server, and the wireless link is used to bear the TCP connection. The method includes: determining, by the terminal, link state information of the wireless link by using a link layer, and sending the link state information from the link layer to a transport layer. The method also includes: sending, by the terminal to the server by using the transport layer, a link notification corresponding to the link state information. In this application, data transmission efficiency can be improved.

A communications method includes determining a session management function entity based on at least one of a data network name, slice information, and an application function service identifier, and sending a first message to the session management function entity, where the first message is used to subscribe to a terminal event, the first message includes service description information, and the service description information is used to indicate a service corresponding to the terminal event.

A computer-implemented method and distributed system for maintaining consistency of client applications on a plurality of server nodes may comprise providing a first and second versions of a distributed coordination engine (DConE). The first version of the DConE may receive proposals, reach agreements thereon and generate a first ordering of agreements that specifies an order in which the client applications are to execute the agreed-upon proposals and correspondingly update their respective states. A ChangeVersion proposal may then be processed by the first version of the DConE, whereupon the first version of the DConE may stop reaching any further agreements. A second version of the DConE may then take over reaching agreements on the proposals and generate a second ordering of agreements, beginning with the agreed-upon ChangeVersion proposal. Any agreed-upon proposal, received from the first version of the DConE after the agreed-upon ChangeVersion proposal, may be sent back to the second version of the DConE to enable the second version of the DConE to reach agreement thereon.

Various embodiments are provided for decentralized distributed deep learning by one or more processors in a computing system. Asynchronous distributed training of one or more machine learning models may be performed by generating a list of neighbor nodes for each node in a plurality of nodes and creating a first thread for continuous communication according to a weight management operation and a second thread for continuous computation of a gradient for each node. One or more variables are shared between the first thread and the second thread.

Disclosed is a vehicle-mounted relay device that relays data flowing through a vehicle-mounted network mounted in a vehicle, including a control unit that controls processing relating to relaying of the data, wherein the control unit derives a threshold relating to a state of the vehicle-mounted network, and determines, based on the derived threshold, whether or not there is an abnormality in the vehicle-mounted network.