Data flow processing method and apparatus for data flow system

    公开(公告)号:US10608946B2

    公开(公告)日:2020-03-31

    申请号:US15410629

    申请日:2017-01-19

    摘要: The present application discloses a data flow processing method and apparatus for a data flow system. A specific implementation of the method includes: acquiring a to-be-processed data flow, and determining, according to a data flow processing instruction, at least one data flow processing node corresponding to the to-be-processed data flow and a passing order in which the to-be-processed data flow passes through the at least one data flow processing node; and connecting together the at least one data flow processing node according to the passing order to obtain a data flow processing channel, and importing the to-be-processed data flow to the data flow processing channel for data processing. This implementation improves the utilization of data flow processing nodes and the data flow processing efficiency.

    Data transmission method and system for transmitting data between processes using shared memory block indexes

    公开(公告)号:US10423542B2

    公开(公告)日:2019-09-24

    申请号:US15281261

    申请日:2016-09-30

    摘要: A method and a system for transmitting data are disclosed. A method embodiment comprises: acquiring a most recent shared memory block index of a shared memory segment by a data receiver, the shared memory segment being used by a data transmitter and the data receiver to transmit data; deciding whether the most recent shared memory block index is consistent with a shared memory block index corresponding to data recently read by the data receiver; and determining, according to the decision, whether to read the data in the shared memory block corresponding to the most recent shared memory block index, where the determining includes reading the data in the shared memory block corresponding to the most recent shared memory block index when the decision indicates that the most recent shared memory block index is inconsistent with the shared memory block index corresponding to the data recently read by the data receiver.

    Monitoring method and apparatus
    3.
    发明授权

    公开(公告)号:US10343630B2

    公开(公告)日:2019-07-09

    申请号:US15410451

    申请日:2017-01-19

    摘要: The present application discloses a monitoring method and apparatus. A specific implementation of the method comprises: reading information about monitoring data acquisition methods of monitored objects, the monitoring data acquisition method comprising an active acquisition method and a passive acquisition method; executing following steps for each of the monitored objects having the active acquisition method as the monitoring data acquisition method: generating a monitoring data acquisition task of the monitored object; determining a monitoring data acquisition frequency of the monitored object; and adding the monitoring data acquisition task to to-be-executed monitoring data acquisition task sets in a defined period corresponding to the monitoring data acquisition frequency; executing, in successive defined periods, monitoring data acquisition tasks in the corresponding to-be-executed monitoring data acquisition task sets; and parsing acquired monitoring data of the monitored objects to generate a monitoring result. The implementation solves the problem of high system resource occupation and waste of system resources during the monitoring process.

    Data transmission method and system

    公开(公告)号:US10152277B2

    公开(公告)日:2018-12-11

    申请号:US15281268

    申请日:2016-09-30

    IPC分类号: G06F3/06 H04L12/801 G05D1/02

    摘要: The present application discloses a data transmission method and system. A specific embodiment of the method includes: receiving a data transmission-instruction by a data sender, wherein the data transmission-instruction includes a thematic name indicative of a type of to-be-transmitted data required by a data receiver; creating a shared memory segment corresponding to the thematic name. It makes possible for the data sender and the data receiver to run in a separate memory space. When data is needed to be transmitted, a corresponding shared memory segment may be created for data transmission in accordance with any transmitting requirement, and the shared memory segment may be released when the transmission is done or appears abnormal. On one hand, it reduces the redundant operations of the data transmission system during data transmission, and improves the data transmission performance; on the other hand, the data transmitting procedure between the data sender and the data receiver, and other operations executed by the data sender or the data receiver are independent of each other, which improves the stability of the data transmission system.

    Method and apparatus for monitoring a message transmission frequency in a robot operating system

    公开(公告)号:US10127092B1

    公开(公告)日:2018-11-13

    申请号:US16039144

    申请日:2018-07-18

    IPC分类号: G06F9/54 G06F11/30

    摘要: This disclosure discloses a method and apparatus for monitoring a message transmission frequency in a robot operating system. A specific implementation of the method includes: writing to-be-transmitted messages, into a pre-allocated memory; obtaining time points when the to-be-transmitted messages are written into the memory, and recording the time points in a preset time point list; determining a message transmission frequency within a preset time interval based on the time points in the time point list; and comparing the message transmission frequency with a preset message transmission frequency threshold, and generating monitoring information based on a comparing result. This implementation monitors the message transmission frequency of a process to thereby avoid information codes related to monitoring of each application from being added to the application so as to reduce the program debuging cost, and improve the monitoring efficiency.

    REMOTE CONTROL METHOD, ELECTRONIC DEVICE, CAB, CLOUD SERVER AND AUTONOMOUS VEHICLE

    公开(公告)号:US20210341917A1

    公开(公告)日:2021-11-04

    申请号:US17373859

    申请日:2021-07-13

    IPC分类号: G05D1/00 G05D1/02

    摘要: A remote control method, an electronic device, a cab, a cloud server and an autonomous vehicle are provided. The method includes: receiving first remote control request information sent by a cloud, the first remote control request information is sent by the cloud after receiving second remote control request information sent by the vehicle to the cloud; sending a control parameter synchronization signal of a cab to the cloud such that the cloud sends the control parameter synchronization signal to the vehicle, so that the vehicle synchronizes the control parameter with the cab; sending verification information for taking over vehicle control to the cloud to enable the cloud to switch on a control channel between the vehicle and the cab; and sending a control signal by the cab against the vehicle and receiving a response signal from the vehicle against the control signal through the control channel.

    Method and apparatus for transmitting a message

    公开(公告)号:US10817439B2

    公开(公告)日:2020-10-27

    申请号:US15410680

    申请日:2017-01-19

    摘要: The present application discloses a method and an apparatus for transmitting a message. The method of an embodiment comprises: dividing a shared memory area allocated by an operating system into a plurality of memory blocks for storing messages having different priorities; dividing each memory block in the plurality of memory blocks into at least one memory unit having a successive serial number; determining, from the plurality of memory blocks according to a priority of a to-be-transmitted message, a target memory block for storing the to-be-transmitted message; and writing the to-be-transmitted message into a memory unit of the target memory block. This embodiment implements message transmission based on priorities of the messages, and improves the control security of an intelligent control system.

    Method and device for establishing communication connection

    公开(公告)号:US10609133B2

    公开(公告)日:2020-03-31

    申请号:US15410188

    申请日:2017-01-19

    IPC分类号: H04L29/08 H04L12/24 H04L12/26

    摘要: The present application discloses a method and device for establishing communication connection. An embodiment of the method includes: selecting a predetermined number of servers from a server cluster to form a backup server cluster, the server cluster including at least one server adapted to implement a given service; obtaining communication information of each backup server in the backup server cluster, and selecting a backup server from the backup server cluster as a master server based on the communication information of the backup server; and sending the communication information of the master server to controlled equipment controlled by the server cluster to establish communication connection between the master server and the controlled equipment. The embodiment solves a problem of reliability raised when main server abnormally quits or restarts during the operation of a system.