Multitask subscription data retrieval system

• US 4,815,030 A
• Filed: 09/03/1986
• Issued: 03/21/1989
• Est. Priority Date: 09/03/1986
• Status: Expired due to Term

• Current Assignee: Research Investment Network Incorporated
• Original Assignee: Wang Laboratories Incorporated
• Inventors: Cross, Charley B., Moy, Diana Y.
• Primary Examiner(s): Heckler, Thomas M.
• Assistant Examiner(s): Mills, John G.
• Application Number:
  US06/903,495
• Time in Patent Office: 930 Days
• Field of Search: 364/200, 364/900
• US Class Current: 455/3.04
• 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
• CPC Class Codes: G06F 9/4843 by program, e.g. task dispatcher, supervisor, operating system
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 12/1804 for stock exchange and similar applications

Abstract

A multitask multiuser system provides for efficient transfer of data from a remote data base to individual subscribers and has particular utility in the distribution of stock market data. A primary provider distributes the incoming data directly to user tasks or to an inquiry provider or a monitor provider. The inquiry provider responds to specific inquiries by users for information in the data base. The monitor provider maintains lists of information which are being monitored by the host computer for individual users. The inquiry provider and the monitor provider do not repeat requests to the remote data base where a similar request is already pending from another user. Data transfer paths between tasks are estabilished by a code module which may be linked to any of the tasks. The transfer paths are established using information from a configuration list and they are monitored by the operating system through a wait list established for each user task. Providers in the system may establish subscriber lists through the code module.

Claims

1. In a multitask electronic data processing shstem having means for receiving from a remote data base of different types in response to nonmonitoring requests for data and specific monitoring requests for data, the specific monitoring requests requiring the remote data base to monitor data base sources with respect to specific identifiers, a method performed by the electronic data processing system for distributing the data to plural user tasks subscribing to the data comprising:

in a first provider task dividing a data stream of plural data types from the remote data base into plural data streams according to the data types;

transferring from the first provider task at least one selected data stream in response to nonmonitoring requests directly to user tasks subscribing to the data streams and transferring at least one selected data stream in response to specific monitoring requests to at least a second provider task; and

in a second provider task, dividing the data stream in response to specific monitoring requests into further data streams and transferring the further data streams to user tasks requesting the data streams.

2. A method as claimed in claim 1 further comprising the step of decoding the data a stream in the second provider task.

3. A method as claimed in claim 1 further comprising, before transferring data to user tasks and by means of a common code module linked to each user task, the step of establishing data transfer paths between the provider tasks and the user tasks, each data transfer path being specific to a type of data transferred to a single user task.

4. A method as claimed in claim 3 further comprising, by means of a wait list established in an operating system, the step of monitoring provider task mailboxes with respect to each type of data to identify request from user tasks and of monitoring user task mailboxes with respect to each type of data to identify data being transferred to the user tasks.

5. A method as claimed in claim 4 further comprising, in establishing data paths, the step of generating a configuration list for each of the provider tasks and the user tasks from a configuration file, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data.

6. A method as claimed in claim 3 further comprising the step of generating in at least the first provider task, a subscribers list for identifying, relative to each type of data, the tasks which are to receive that type of data.

7. A method as claimed in claim 1 further comprising, by means of a wait list established in an operating system, the step of monitoring provider task mailboxes with respect to each type of data to identify requests from user tasks and of monitoring user task mailboxes with respect to each type of data to identify data being transferred to the user tasks.

8. A method as claimed in claim 1 further comprising establishing data transfer paths between the provider tasks and the user tasks, each data transfer path being specific to a type of data transferred to a single user task.

9. A method as claimed in claim 8 further comprising, in establishing data paths, the step of generating a configuration list for each of the provider tasks and the user tasks from a configuration file, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data.

10. A method as claimed in claim 1 wherein the second provider task receives specific data requests from the user tasks and compiles information correlating user tasks with specific data requests, the data being compiled by generating a user tree and a data-type tree, each user node of the user tree pointing to a list of data types requested by that user and each node of the data-type tree pointing to the users which have requested that type of data.

11. A method as claimed in claim 1 wherein the data comprises stock market information.

12. A method as claimed in claim 11 further comprising transferring stock quotation requests from the user tasks to the first provider task, providing each such request with a sequence number in the first provider task and transferring the request to the remote data base, the first provider task maintaining a record of users requesting the data with respect to sequence numbers and, by means of sequence numbers returned with the data, confirming receipt of data responses to the requests and forwarding the received data to the users which made the quotation requests.

13. In a multitask electronic data processing system having means for receiving from a remote data base data of different types, a method of distributing the data from a provider task to plural user tasks subscribing t the data, the method performed by the electronic data processing system comprising:

by means of a common code module linked to each user task, establishing data paths between the provider task and the user tasks, each data path being specific to a type of data transferred to a single user; and

by means of the provider task, dividing a data stream from the remote data base into plural data streams according to the data type and transferring the plural data steams to the user tasks through the established data paths.

14. A method as claimed in claim 13 further comprising the step of monitoring, by means of a wait list established through the common code module in an operating system, a user task mailbox with respect to each type of data to notify the user task of data being transferred to the user task.

15. A method as claimed in claim 14 further comprising, in establishing data paths, the step of generating a configuration list for each user task from a configuration file, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data.

16. A method as claimed in claim 15 wherein each configuration list indicates whether the task is a provider of data to other tasks, the method further comprising the step of limiting provider specific routines of the common code module to provider tasks.

17. A method as claimed in claim 15 further comprising the step of monitoring, by means of a wait list established through the common code module in an operating system, a mailbox to a provider task with respect to each type of data to notify the provider task of data being transferred to the provider task.

18. A method as claimed in claim 17 further comprising the step of generating a configuration list for each provider task from a configuration file, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred.

19. A method as claimed in claim 17 further comprising the step of generating in at least the provider task, a subscribers list for identifying, relative to each type of data, the tasks which are to receive that type of data.

20. A method as claimed in Claim 14 further comprising the step of monitoring, by means of a wait list established through the common code module in an operating system, a mailbox to a provider task with respect to each type of data to notify the provider task of data being transferred to the provider task.

21. A method as claimed in claim 13 further comprising the step of generating in the provider task, a subscribers list for identifying, relative to each type of data, the tasks which are to receive that type of data.

22. A method as claimed in claim 13, further comprising, in establishing data paths, the step of generating a configuration list for each user task from a configuration file, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data.

23. A method as claimed in claim 13 wherein the data comprises stock market information.

36. A method as claimed in claim 13 wherein the data paths are established by routines of the common code module based on system configuration information available to the common code module routine, the routine being called by a user task without regard for the provider task architecture.

37. A method as claimed in claim 36 wherein the configuration information is available through a configuration list which includes the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data.

38. A method as claimed in claim 14 further comprising the step of including in the wait list events specified by the user other than data transfers from a provider task.

39. A method as claimed in claim 13 wherein data streams of a first type are transferred to specific user tasks depending on the content of the data streams, and data streams of a second type are transferred to all user tasks from a list of user tasks.

24. In a multitask electronic data processing system having means or receiving from a remote data base data of different types, a method of distributing the data from a provider task to plural user tasks subscribing to the data, the method performed by the electronic data processing system comprising:

in response to calls from the user tasks, establishing data paths between the provider task and the user tasks, each data path being specific to a type of data transferred to a single user; and

by means of the provider task, dividing a data stream from the remote data base into plural data streams according to the data type and transferring the plural data streams to the user tasks through the established data paths.

25. A method as claimed in claim 24 further comprising in establishing data paths, the step of generating a configuration list for each of the provider tasks and the user tasks from a configuration file, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data.

26. A method as claimed in claim 25 further comprising the step of monitoring, by means of a wait list established in an operating system, mailboxes with respect to each type of data to the provider tasks to identify requests from user tasks and to user tasks to identify data being transferred to the user tasks.

27. A method as claimed in claim 24 further comprising, by means of a wait list established in an operating system, the step of monitoring provider task mailboxes with respect to each type of data to identify requests from user tasks and of monitoring user task mailboxes with respect to each type of data of identify data being transferred to the user tasks.

28. A method as claimed in claim 24 wherein the data comprises stock market information.

29. In a multitask electronic data processing system having means for receiving from a remote data base data, a method performed by the electronic data processing system of distributing the data to plural user tasks comprising in a provider task:

receiving specific data requests from the user task and compiling information correlating user tasks with specific data requests;

for each data request, determining whether a like request is pending for another task;

only if a like request is not pending, transferring to the remote data base the specific data request;

receiving specific data from the remote data base;

determining from the compiled information all user tasks which have requested the received specific data; and

transferring the specific data to user tasks which have requested the data.

30. A method as claimed in claim 29 wherein the information is compiled by generating a user tree and a symbol tree, each user node of the user tree pointing to a list of symbols identifying data requested by that user and each node of the symbol tree pointing to the users which have requested the data represented by the symbol.

31. A method as claimed in claim 30 wherein each node of the user tree includes a listing of services to which that user has subscribed.

32. A method as claimed in claim 30 wherein each node of the symbol tree includes a listing of services through which users have made requests for the data identified by the symbol.

33. A method as claimed in claim 29 wherein the data comprises stock market information.

34. In a multitask electronic processing system having means for receiving data of different types, a method of distributing the data from provider tasks to plural user tasks subscribing to the data, the method performed by the electronic data processing system comprising:

by means of a common code module linked to each user task, establishing data paths between the provider tasks and the user tasks, each data path being specific to a type of data being transferred to a single user, the data paths being established by each user task using a configuration list for each user task, each configuration list including the name of a provider task mailbox to which requests for data of each type are to be transferred and an indication of whether the task has access to a particular type of data;

by means of a wait list established in an operating system, monitoring provider task mailboxes with respect to each type of data to identify requests from user tast and monitoring user tasks mailboxes with respect to each type of data to identify data being transferred to the user tasks;

receiving in a monitor provider task specific data requests from the user tasks and compiling information corelating user tasks with specific data requests, determining whether a like request is pending for another task, and only if a like request is not pending transferring through a primary provider task to the remote data base the specific data request;

in the primary provider task, dividing a data stream of plural data types from the remote data base into plural data streams according to the data types;

transferring selected data streams in response to nonmonitoring requests directly to user tasks subscribing to the data streams and transferring at least one selected data stream in response to specific monitoring requests to the monitor provider task; and

in the monitor provider task, dividing the data stream in response to specific monitoring requests into further data streams and transferring the further data streams to user tasks requesting the data streams.

35. A method as claimed in claim 34 wherein the data comprises stock market information.