Data processing system using stream stores
First Claim
1. A computer method of processing the logging data acquired from a sonde transiting an oil well borehole comprising the steps of:
- acquiring data from a transducer in the sonde indicative of a geological property of the formation surrounding the borehole;
writing the geological data to a geological data memory store as a stream of sequential data items, said geological data memory store being operable for receiving and storing only the geological data stream;
performing a first process including the substeps(a) sequentially reading a geological data item of interest from the geological data store,(b) determining a first reference value using said geological data item of interest,(c) writing the first reference value to a first reference value memory store in a stream of sequential data items, said first reference value memory store being operable for receiving and storing only the first reference value stream, and(d) repeating substeps (a)-(c) with another geological data item read in sequential order;
performing a second process including the substeps(a) sequentially reading a geological data item of interest from the geological data store,(b) determining a second reference value using said geological data item of interest,(c) writing the second reference value to a second reference memory store in a stream of sequential data items, said second reference memory store being operable for receiving and storing only the second reference value stream, and(d) repeating substeps (a)-(c) with another geological data item read in sequential order;
the first and second processes being concurrent processes with the rate of performing one process not altering the determination of the reference value in the other process.
0 Assignments
0 Petitions
Accused Products
Abstract
A system and method for data processing in which data processing tasks are arranged as separate processes, each of which can be executed by a dedicated central processing unit or by one or more shared processing units. All communication between processes takes place via streams of data items. Each stream receives data items from a single source, for example from an input to the processing system or from one of the processes. Every data item appended to a stream is associated with a unique index value--even if physical memory locations are re-used, index values never are. A process can request a data item in terms of the stream where it is stored and the index value associated with it. Within constraints imposed by physical storage capacity, any index value can be included in a request. If the data item is not yet available, execution of the process is suspended until the data item becomes available. A data item can be requested with a limit on the time that elapses before the attempt is aborted; also a request can be made for the data item most recently appended to a stream instead of in terms of a specific index value. This architecture facilitates data processing involving both time-independent and time-dependent processes.
26 Citations
27 Claims
-
1. A computer method of processing the logging data acquired from a sonde transiting an oil well borehole comprising the steps of:
-
acquiring data from a transducer in the sonde indicative of a geological property of the formation surrounding the borehole; writing the geological data to a geological data memory store as a stream of sequential data items, said geological data memory store being operable for receiving and storing only the geological data stream; performing a first process including the substeps (a) sequentially reading a geological data item of interest from the geological data store, (b) determining a first reference value using said geological data item of interest, (c) writing the first reference value to a first reference value memory store in a stream of sequential data items, said first reference value memory store being operable for receiving and storing only the first reference value stream, and (d) repeating substeps (a)-(c) with another geological data item read in sequential order; performing a second process including the substeps (a) sequentially reading a geological data item of interest from the geological data store, (b) determining a second reference value using said geological data item of interest, (c) writing the second reference value to a second reference memory store in a stream of sequential data items, said second reference memory store being operable for receiving and storing only the second reference value stream, and (d) repeating substeps (a)-(c) with another geological data item read in sequential order; the first and second processes being concurrent processes with the rate of performing one process not altering the determination of the reference value in the other process. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
-
-
13. A computer-implemented method of processing the logging data acquired from a sonde transisting an oil well borehole comprising the steps of:
-
acquiring data from a transducer in the sonde indicative of a geological property of the formation surrounding the borehole; writing the geological data to a geological data memory store as a stream of sequential data items, said geological data memory store being operable for receiving and storing only the geological data stream; performing a first process in a time period including the substeps (a) sequentially locating the memory location for a geological data item of interest in the geological data store, (b) reading any geological data item written to said memory location within said time period, (c) repeating substeps (a)-(b) for another memory location for another geological data item in sequential order; performing a second process including the substeps (a) sequentially reading a geological data item of interest from the geological data store, (b) determining a reference value using said geological data item of interest, (c) writing the reference value to a reference memory store in a stream of sequential data items, said reference memory store being operable for receiving and storing only the reference value stream, and (d) repeating substeps (a)-(c) with another geological data item in sequential order; the first and second processes being concurrent processes with the rate of performing one process not altering the determination of the reference value in the second process. - View Dependent Claims (14, 15)
-
-
16. A computer-implemented method of processing data acquired from a sensor comprising the steps of:
-
acquiring data from a sensor; writing the sensor data to a sensor data memory store as a stream of sequential data items, said sensor data memory store being operable for receiving and storing only the sensor data stream; performing a first process including the substeps (a) sequentially reading a sensor data item of interest from the sensor data store, (b) determining a first reference value using said a sensor data item of interest, (c) writing the first reference value to a first reference value memory store in a stream of sequential data items, said first reference value memory store being operable for receiving and storing only the first reference value stream, and (d) repeating substeps (a)-(c) with another sensor data item in sequential order; performing a second process including the substeps (a) sequentially reading a sensor data item of interest from the sensor data store, (b) determining a second reference value using said sensor data item of interest, (c) writing the second reference value to a second reference memory store in a stream of sequential data items, said second reference memory store being operable for receiving and storing only the second reference value stream, and (d) repeating substeps (a)-(c) with another sensor data item in sequential order; the first and second processes being concurrent processes with the rate of performing one process not altering the determination of the reference value in the other process. - View Dependent Claims (17, 18, 19, 20, 21, 22, 23, 24)
-
-
25. A computer-implemented method of processing data acquired from a sensor comprising the steps of:
-
acquiring data from a sensor; writing the sensor data to a sensor data memory store as a stream of sequential data items, said sensor data memory store being operable for receiving and storing only the sensor data stream; performing a first process in a time period including the substeps (a) sequentially locating the memory location for a sensor data item of interest in the sensor data store, (b) reading any sensor data item written to said memory location within said time period, (c) repeating substeps (a)-(b) with another memory location for a sensor data item in sequential order; performing a second process including the substeps (a) sequentially reading a sensor data item of interest from the sensor data store, (b) determining a reference value using said sensor data item of interest, (c) writing the reference value to a reference memory store in a stream of sequential data items, said reference memory store being operable for receiving and storing only the reference value stream, and (d) repeating substeps (a)-(c) with another sensor data item in sequential order; the first and second processes being concurrent processes with the rate of performing one process not altering the determination of the reference value in the second process. - View Dependent Claims (26, 27)
-
Specification