Apparatus and method for active and passive data gathering using stochastic model in control network

• US 9,477,736 B2
• Filed: 04/04/2014
• Issued: 10/25/2016
• Est. Priority Date: 10/31/2013
• Status: Active Grant

• Current Assignee: Samsung SDS (China) Co., Ltd. (Samsung Group)
• Original Assignee: Samsung SDS (China) Co., Ltd. (Samsung Group)
• Inventors: Kwon, Soonmok, Yun, Yongkeun, Yoo, Dongho
• Primary Examiner(s): Lee, Wilson
• Application Number:
  US14/245,612
• Publication Number:
  US 20150120657A1
• Time in Patent Office: 935 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor

Abstract

There is provided an apparatus and method for active and passive data gathering using a stochastic model in a control network. An active and passive synchronizer performs a first gathering operation in which a data request frame is transmitted via the control network and data on the local devices is gathered and a second gathering operation in which data on the local devices is gathered by reading a communication frame among the local devices, and determines a first gathering operation schedule for each data stored in a cache unit based on an expected delay time estimated using a stochastic model for the second gathering operation process when the first gathering operation is not performed on each data that is gathered through the first gathering operation and the second gathering operation and is stored in the cache unit and waiting is performed until the data is updated through the second gathering operation.

Claims

1. A data gathering apparatus, comprising:

a cache unit configured to store data, gathered from local devices connected via a control network, and constituting cached data items;

an active and passive synchronizer, comprising at least one hardware processor, configured;

to perform a first gathering operation in which;

a data request frame is transmitted via the control network, and data on the local devices is gathered and stored as cached data items;

to perform a second gathering operation in which data on the local devices is gathered and stored as cached data items by reading a communication frame communicated over the control network; and

to determine a first gathering operation schedule for each of the cached data items based on an expected delay time, estimated using a stochastic model for the second gathering operation process, in case that waiting is performed until the each of the cached data items is updated through the second gathering operation without performing the first gathering operation; and

an active and passive medium access unit having a receiver and a transmitter, configured to deliver data obtained from a frame received via the control network to the active and passive synchronizer and to transmit a frame for gathering data on the local devices of the control network in response to a request of the active and passive synchronizer.

2. The apparatus according to claim 1, further comprising a synchronization statistics manager configured to measure a statistical moment of a time interval in which data is updated through the second gathering operation and measure a time at which data is most recently updated through the first gathering operation and the second gathering operation.

3. The apparatus according to claim 1, further comprising a service interface unit configured to:

when a request message, including a data identifier list, is received from an external system connected via a communication network, read data corresponding to the data identifiers from the cache unit,

put the data in a response message, and

transmit the message to the external system in response to the request message received from the external system.

4. The apparatus according to claim 1, wherein the active and passive medium access unit performs frame transmission for gathering data requested from the active and passive synchronizer when the number of frames transmitted in a time slot of a time point at which a frame transmission request for data gathering is received from the active and passive synchronizer is within an active synchronization quota that is the maximum number of times frame transmission can be performed for the first gathering operation by the active and passive medium access unit.

5. The apparatus according to claim 4, wherein the active and passive medium access unit is further configured to respond to a request, from the active and passive synchronizer to transmit a data request frame, for gathering data from the local devices, by:

storing the frame in its own buffer, and then

batch-transmitting the stored frame at a start point of a time slot subsequent to a time slot of a time at which the data request frame is received.

6. The apparatus according to claim 1, wherein the active and passive synchronizer calculates the expected delay time by:

adding together;

an expected passive synchronization cycle, and

a last passive synchronization update time; and

then

subtracting a last update time;

wherein;

the expected passive synchronization cycle is a predicted estimator of a cycle by which data is updated through the second gathering operation using a stochastic model,

the last passive synchronization update time is a time at which data is most recently updated through the second gathering operation, and

the last update time is a time at which data is most recently updated through at least one of the first gathering operation and the second gathering operation.

7. The apparatus according to claim 6, wherein the active and passive synchronizer is further configured to:

set a probability distribution of a time interval, in which data stored in the cache unit is updated through the second gathering operation, based on a communication characteristic of an internal system of the control network,

receive statistical moment data provided from the synchronization statistics manager, and

calculate the expected passive synchronization cycle after an estimator of a factor of a cumulative distribution function of the set probability distribution is set using the received statistical moment data.

8. The apparatus according to claim 1, wherein the active and passive synchronizer is further configured to:

search the cache unit for data having the greatest expected delay time,

receive data related to the searched data from the active and passive medium access unit, and

update data stored in the cache unit.

9. The apparatus according to claim 1, wherein, the active and passive synchronizer is further configured to:

receive data, from the active and passive medium access unit, related to active synchronization target data, when an expected delay time of active synchronization target data is greater than a preset reference delay time, and

update data stored in the cache unit.

10. The apparatus according to claim 9, wherein the active and passive synchronizer is further configured to change the reference delay time according to the following Equation:

11. A data gathering method that is performed in a data gathering apparatus for gathering data from local devices connected via a control network, the method comprising:

(a) performing a first gathering operation comprising;

transmitting a data request frame, from a transmitter, via the control network,

gathering first data about the local devices, and

storing data items, corresponding to the first gathered data, in a cache memory;

(b) performing a second gathering operation comprising;

gathering second data about the local devices by reading a communication frame communicated among the local devices, and

storing data items, corresponding to the second gathered data, in the cache memory; and

(c) determining a first gathering operation schedule for each of the cached data items, based on an expected delay time, estimated using a stochastic model for the second gathering operation process, in case that waiting is performed until the each of the cached data items is updated through the second gathering operation without performing the first gathering operation.

12. The method according to claim 11, further comprising (d) measuring a statistical moment of a time interval in which data is updated through the second gathering operation and measuring a time at which data is most recently updated through the first gathering operation and the second gathering operation.

13. The method according to claim 11, wherein:

in the operation of (a), frame transmission for the data gathering is performed when the number of frames transmitted, in a time slot of a point in time at which frame transmission for the data gathering is requested, is within an active synchronization quota, and the active synchronization quota is the maximum number of times frame transmission can be performed for the second gathering operation.

14. The method according to claim 11, wherein operation (c) further comprises calculating the expected delay time by:

adding together;

an expected passive synchronization cycle, and

a last passive synchronization update time; and

then

subtracting a last update time;

wherein;

the expected passive synchronization cycle is a predicted estimator of a cycle by which data is updated through the second gathering operation using a stochastic model,

the last passive synchronization time is a time at which data is most recently updated through the second gathering operation, and

the last update time is a time at which data is most recently updated through at least one of the first gathering operation and the second gathering operation.

15. The method according to claim 14, wherein operation (c) includes:

(c1) setting a probability distribution of a time interval in which data stored in the cache memory is updated through the second gathering operation based on a communication characteristic of an internal system of the control network; and

(c2) calculating the expected passive synchronization cycle after an estimator of a factor of a cumulative distribution function of the set probability distribution is set using statistical moment data calculated based on a time interval in which data is updated through the second gathering operation.

16. The method according to claim 11, wherein, operation (c) includes:

(c3) searching the cache memory for data having the greatest expected delay time; and

(c4) gathering, from a local device, data related to the searched data, and updating the data stored in the cache memory.

17. The method according to claim 11, wherein, in operation (c), when an expected delay time of active synchronization target data is greater than a preset reference delay time:

data is gathered from a local device related to the active synchronization target data and

the data stored in the cache memory is updated.

18. The method according to claim 17, wherein, in operation (c), the reference delay time is changed according to the following Equation:

19. A non-transitory computer readable recording medium storing a program configured to enable a computer, during execution, to perform operations comprising:

(a) performing a first gathering operation comprising;

transmitting a data request frame, from a transmitter, via the control network,

gathering first data about the local devices, and

storing data items, corresponding to the first gathered data, in a cache memory;

(b) performing a second gathering operation comprising;

gathering second data about the local devices by reading a communication frame communicated among the local devices, and

storing data items, corresponding to the second gathered data, in the cache memory; and

(c) determining a first gathering operation schedule for each of the cached data items, based on an expected delay time, estimated using a stochastic model for the second gathering operation process, wherein;

the expected delay time includes a time when the first gathering operation is not performed on each of the cached data items, and

waiting is performed until the each of the cached data items is updated through the second gathering operation.