A method and an apparatus for data processing are provided. Interface circuitry connects the apparatus in a distributed system. Processing circuitry generates first hash values for a first group of virtual nodes to be added into a hash ring. The first group of virtual nodes represents a first newly added device in the distributed system. Then, the processing circuitry distributes the data in the distributed system according to the hash ring that includes the first group of virtual nodes. When the distribution of the data in the distribution system fails to satisfy a uniformity requirement, the processing circuitry identifies a specific virtual node in the first group of virtual nodes that causes the distribution to fail the uniformity requirement. Then, a hash value for a makeup virtual node to replace the specific virtual node is generated to update the distribution of the data in the distributed system.

In one aspect, machines in a managed network implements a set of rules that cause individual machines to directly interact with only a small number of machines in the network (i.e., a local neighborhood within the network), while the independent local actions of the individual machines collectively cause the individual machines to be self-organized into one or more communication orbits without any global control or coordination by a server or an administrator. The communication orbits are used for supporting network, security and system management communications in the managed network.

Provided is a method of synchronizing a plurality of user terminals based on peer-to-peer (P2P) communication, the method including occurring a first state change in a first user terminal, generating first action information corresponding to the first state change in the first user terminal, transmitting the first action information from the first user terminal to a second user terminal, receiving the first action information in the second user terminal, adding the first action information to an application ready queue in the second user terminal, detecting whether a divergence or a causality violation occurs in the second user terminal, and applying a state change based on the first action information in the second user terminal.

The present invention relates to an application that is configured to be operated in a multi-participant environment on a computer network. The application manages participants in an online session of a multi-user application so that if one of the participants exits the session, the session can continue without interruption. The application initiates an online session of the multi-user application, wherein the online session includes two or more participants comprised of network computers that are communicatively linked to a computer network. If the application detects that a first participant has disconnected from the online session, wherein the first participant is responsible for managing certain managerial functionality associated with the running of the multi-user application, then the application broadcasts a notification to existing participants of the online session over the communication network, thereby notifying the existing participants that the first participant has disconnected from the online session. The initiating application then re-assigns the functionality associated with the first participant to an existing participant of the online session. The participants can be communicating in a peer-to-peer arrangement or can be performing server duties in a client-server arrangement.

Various examples relate to a wired local area network (WLAN) including a shared transmission medium. An apparatus includes a beacon counter and an operational mode controller. The beacon counter is operably coupled to a line of a shared transmission medium of a wired local area network. The beacon counter is to count beacon signals on the line and determine a beacon count over a predetermined time period, or a beacon rate of the beacon signals. The operational mode controller is to control the apparatus to take over operation as a master node of the wired local area network based, at least in part, on a maximum bus cycle length of bus cycles on the line and responsive to the beacon count or the beacon rate.

A telematics center includes an update software distribution unit that distributes update software for updating software of an ECU to a software updating device. The software updating device includes a storage device that stores update software distributed from the telematics center and stores update information regarding influence on the operation of a vehicle in a case where the updating of the software of the ECU is not successful and an ECU software updating unit that updates the software of the ECU by using the update software stored in the storage device, and controls the operation of the ECU software updating unit on the basis of the update information stored in the storage device.

A system can include a first electrical device having a first sensor device, where the first sensor device is configured to measure a first parameter used in operating the first electrical device, where the first sensor device is further configured to detect a first condition that is unrelated to operating the first electrical device, where the first condition is created by a trigger device controlled by a user, where the first sensor device, upon detecting the first condition, broadcasts a first communication that includes a first identification of the first sensor device. The system can also include a gateway communicably coupled to the first electrical device, where the gateway receives the first communication from the first electrical device, where the gateway assigns the first electrical device to a first group based on the first identification of the first sensor device.

Examples include group leader role queries. Examples include detection of a loss of communication, via a first communication protocol, between first and second computing devices, transmission, via a second communication protocol, of a query for information about the second computing device currently having the group leader role. Examples further include a determine not to assume the group leader role with the first computing device based on receiving a response to the query via the second communication protocol from the second computing device.

Various systems and methods for implementing a software defined industrial system are described herein. For example, an orchestrated system of distributed nodes may run an application, including modules implemented on the distributed nodes. In response to a node failing, a module may be redeployed to a replacement node. In an example, self-descriptive control applications and software modules are provided in the context of orchestratable distributed systems. The self-descriptive control applications may be executed by an orchestrator or like control device and use a module manifest to generate a control system application. For example, an edge control node of the industrial system may include a system on a chip including a microcontroller (MCU) to convert IO data. The system on a chip includes a central processing unit (CPU) in an initial inactive state, which may be changed to an activated state in response an activation signal.

A system for detecting occupancy of a vehicle travelling in a direction of travel along a road. The system includes a roadside imaging device positioned on a roadside, and a first roadside light emitter, and a roadside vehicle detector. A processor is configured to receive a signal from the roadside vehicle detector, command the first roadside light emitter to emit light according to a first pattern for a first duration, command the roadside imaging device to capture images of the side of the vehicle, and compute a vehicle occupancy, in each of the captured images by determining one or more regions of interest in each of the captured images, and determining a number of visible occupants in the one or more regions of interest. The processor determines a most likely number of occupants based on each determined vehicle occupancy.