METHOD AND PORTABLE DEVICE FOR MANAGING MEMORY IN A DATA STREAM MANAGEMENT SYSTEM

• US 20120254575A1
• Filed: 03/15/2012
• Published: 10/04/2012
• Est. Priority Date: 03/28/2011
• Status: Active Grant

• Current Assignee: Samsung Electronics Co. Ltd.
• Original Assignee: Samsung Electronics Co. Ltd.
• Inventors: Ryu, Seung-woo, Hong, Seok-jin, Kwon, Keun-joo
• Granted Patent: US 9,298,644 B2
• Time in Patent Office: Days
• US Class Current: 711/165
• CPC Class Codes: G06F 12/08 in hierarchically structured memory systems, e.g. virtual memory systems
• CPC Class Codes: G06F 12/121 using replacement algorithms
• CPC Class Codes: G06F 12/123 with age lists, e.g. queue, most recently used [MRU] list or least recently used [LRU] list
• CPC Class Codes: G06F 12/126 with special data handling, e.g. priority of data or instructions, handling errors or pinning
• CPC Class Codes: G16H 40/40 for the management of medical equipment or devices, e.g. scheduling maintenance or upgrades

Abstract

Provided are method and device for managing a memory in a data stream management system (DSMS) of a portable device. The method includes moving data of a selected memory region that has a low priority to a secondary storage and storing a received data stream in the selected memory region.

Claims

1. A method of managing a memory in a data stream management system (DSMS) of a portable device, the method comprising:

calculating values of a scoring function for a plurality of memory regions of a first memory area based on priorities of the plurality of memory regions;

comparing the values of the scoring function of the plurality of memory regions and selecting a memory region that has a lowest priority;

moving data of the selected memory region to a second memory area; and

storing a received data stream in the selected memory region.

2. The method of claim 1, wherein the calculating of the values of the scoring function for each memory region comprises calculating the values of the scoring function by adding values together that are obtained by multiplying values of components that are to be considered by weights of the respective components.

3. The method of claim 2, wherein the components used to calculate the value of each scoring function comprise at least one of an expected time when at least one second data stream corresponding to a memory region is to be received, a data receiving state of a sensor for transmitting a second data stream to the portable device, a size of the corresponding memory region, and the number of second data streams corresponding to the memory region.

4. The method of claim 3, further comprising determining a time when the second data stream is to be received next based on at least one of periodic information that is inserted into a line of syntax in order to generate the second data stream by a user of the DSMS, periodic information that is determined using times when the second data stream is received previously, and periodic information that is included as tag information in the second data stream,

wherein the calculating of the value of the scoring function comprises lowering a priority of a memory region by increasing a weight, in response to a second data stream not being received during a predetermined amount of time.

5. The method of claim 3, wherein the calculating of the value of the scoring function comprises lowering a priority of a memory region by increasing a weight corresponding to a receiving state of data, in response to a second data stream not being received at an input expected time.

6. The method of claim 3, wherein the calculating of the value of the scoring function comprises lowering a priority of a memory region by increasing a weight corresponding to a size of the corresponding memory region, in response to a size of a memory to be used for calculation of the first data stream being similar to a size of the memory region.

7. The method of claim 3, wherein the calculating of the value of the scoring function comprises increasing a priority of a memory region by reducing a weight corresponding to the number, in response to the amount of second data streams to be received by the corresponding memory region increasing.

8. The method of claim 1, wherein the memory region comprises a synopsis which is a memory region corresponding to an operator of a data stream, or comprises a store which is a memory region shared by a plurality of operators.

9. A portable device for managing a memory in a data stream management system (DSMS), the portable device comprising:

a plurality of memory regions of a first memory area configured to store data streams;

a calculator configured to calculate values of a scoring function for the plurality of memory regions based on the priorities of the plurality of memory regions, to compare the values of the scoring function of each of the memory regions to select a memory region that has a lowest priority;

a second memory area configured to store data of the selected memory region; and

a controller configured to move the data of the selected memory region to the second memory area.

10. The portable device of claim 9, wherein the calculator is configured to calculate the values of the scoring function for each memory region by adding values together that are obtained by multiplying values of components that are to be considered by weights of the respective components.

11. The portable device of claim 10, wherein the components used to calculate the value of each scoring function comprise at least one of an expected time when at least one second data stream corresponding to a memory region is to be received, a data receiving state of a sensor for transmitting a second data stream to the portable device, a size of the corresponding memory region, and the number of second data streams corresponding to the memory region.

12. The portable device of claim 11, further comprising a stream periodic manager for determining a time when the second data stream is to be received next based on at least one of periodic information that is inserted into a line of syntax in order to generate the second data stream by a user of the DSMS, periodic information that is determined using times when the second data stream is received previously, and periodic information that is included as tag information in the second data stream,

wherein the calculator is configured to lower a priority of a memory region by increasing a corresponding weight, in response to a second data stream not being received during a predetermined amount of time.

13. The portable device of claim 11, wherein the calculator is configured to lower a priority of a memory region by increasing a weight corresponding to a receiving state of data, in response to a second data stream not being received at an input expected time.

14. The portable device of claim 11, wherein the calculator is configured to lower a priority of a memory region by increasing a weight corresponding to a size of the corresponding memory region, in response to a size of a memory to be used for calculation of the first data stream being similar to a size of the memory region.

15. The portable device of claim 11, wherein the calculator is configured to increase a priority of a memory region by reducing a weight corresponding to the number.

16. The portable device of claim 9, wherein the memory region comprises a synopsis which is a memory region corresponding to an operator of a data stream, or comprises a store which is a memory region shared by a plurality of operators.

17. A computer-readable storage medium having stored therein program instructions to cause a processor to implement a method of managing a memory in a DSMS of a portable device, the method comprising:

calculating values of a scoring function for a plurality of memory regions of a first memory area based on priorities of the plurality of memory regions;

comparing the values of the scoring function of the plurality of memory regions and selecting a memory region that has a lowest priority;

moving data of the selected memory region to a second memory area; and

storing a received data stream in the selected memory region.