# US 8,788,644 B2 · Tracking data processing in an application carried out on a distributed computing system > Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt - Number: US 8,788,644 B2 - Document ID: US8788644B2 - Status: Granted - Kind: B2 - Application number: 12/129,284 - Filed: 2008-05-29 - Published: 2009-12-03 - Granted: 2014-07-22 - Earliest claimed: 2008-05-29 - Assignees: International Business Machines Corporation - Applicants: Michael J. Branson; Zachary A. Garbow; John M. Santosuosso - Inventors: Michael J. Branson; Zachary A. Garbow; John M. Santosuosso - Web page: https://patentgrep.com/patent/US8788644B2 ## CPC - G06F 16/24532: {of parallel queries} - G06F 9/5038: {considering the execution order of a plurality of tasks, e.g. taking priority or time dependency constraints into consideration (scheduling strategies G06F9/4881 and subgroups)} - G06F 9/5066: {Algorithms for mapping a plurality of inter-dependent sub-tasks onto a plurality of physical CPUs (mappping at compile time, see G06F8/451)} - H04L 67/1097: for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS] - G06F 2209/506: Constraint - H04L 69/329: in the application layer [OSI layer 7] - Y10S 707/99932: Access augmentation or optimizing - G06F: ELECTRIC DIGITAL DATA PROCESSING (computer systems based on specific computational models G06N) - H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M) - Y10S: TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS ## Abstract Methods, systems, and products are disclosed for tracking data processing in an application carried out on a distributed computing system, the distributed computing system including a plurality of computing nodes connected through a data communications network, the application carried out by a plurality of pluggable processing components installed on the plurality of computing nodes, the pluggable processing components including a pluggable processing provider component and a pluggable processing consumer component, that include: identifying, by the provider component, data satisfying predetermined processing criteria, the criteria specifying that the data is relevant to processing provided by the consumer component; passing, by the provider component, the data to the next pluggable processing component in the application for processing, including maintaining access to the data; receiving, by the consumer component, the data during execution of the application; and sending, by the consumer component, a receipt indicating that the consumer component received the data. ## Claims ### Claim 1 A method of tracking data processing in an application carried out on a distributed computing system, the distributed computing system comprising a plurality of computing nodes connected for data communications through a data communications network, the application carried out by a plurality of pluggable processing components installed on the plurality of computing nodes, the pluggable processing components including a pluggable processing provider component and a pluggable processing consumer component, the method comprising: identifying, by the pluggable processing provider component, data satisfying predetermined processing criteria, the predetermined processing criteria specifying that the data is relevant to processing provided by the pluggable processing consumer component; passing, by the pluggable processing provider component, the data to the next pluggable processing component in the application for processing, including maintaining access to the data; receiving, by the pluggable processing consumer component, the data during execution of the application; and sending, by the pluggable processing consumer component, a receipt indicating that the pluggable processing consumer component received the data. ### Claim 2 (depends on 1) The method of claim 1 further comprising: receiving, by the pluggable processing provider component from the pluggable processing consumer component, the receipt indicating that the pluggable processing consumer component received the data; and administering, by the pluggable processing provider component, the data in response to receiving the receipt. ### Claim 3 (depends on 1) The method of claim 1 further comprising: receiving, by a system administrative component from the pluggable processing consumer component, the receipt indicating that the pluggable processing consumer component received the data; sending, by the system administrative component to the pluggable processing provider component, the receipt indicating that the pluggable processing consumer component received the data; receiving, by the pluggable processing provider component from the system administrative component, the receipt indicating that the pluggable processing consumer component received the data; and administering, by the pluggable processing provider component, the data in response to receiving the receipt. ### Claim 4 (depends on 1) The method of claim 1 further comprising: determining, by the pluggable processing provider component, that the pluggable processing provider component did not receive the receipt within a predefined time period; and performing, by the pluggable processing provider component, one or more corrective actions in response to not receiving the receipt within a predefined time period. ### Claim 5 (depends on 1) The method of claim 1 wherein maintaining access to the data further comprises storing the data in computer memory of the pluggable processing provider component. ### Claim 6 (depends on 1) The method of claim 1 wherein maintaining access to the data further comprises storing information used by the pluggable processing provider component to recreate the data. ### Claim 7 A distributed computing system capable of tracking data processing in an application carried out on the distributed computing system, the distributed computing system comprising a plurality of computing nodes connected for data communications through a data communications network, the application carried out by a plurality of pluggable processing components installed on the plurality of computing nodes, the pluggable processing components including a pluggable processing provider component and a pluggable processing consumer component, the distributed computing system comprising one or more computer processors and computer memory operatively coupled to the computer processors, the computer memory for the distributed computing system having disposed within it computer program instructions capable of: identifying, by the pluggable processing provider component, data satisfying predetermined processing criteria, the predetermined processing criteria specifying that the data is relevant to processing provided by the pluggable processing consumer component; passing, by the pluggable processing provider component, the data to the next pluggable processing component in the application for processing, including maintaining access to the data; receiving, by the pluggable processing consumer component, the data during execution of the application; and sending, by the pluggable processing consumer component, a receipt indicating that the pluggable processing consumer component received the data. ### Claim 8 (depends on 7) The distributed computing system of claim 7 wherein the computer memory for the distributed computing system has disposed within it computer program instructions capable of: receiving, by the pluggable processing provider component from the pluggable processing consumer component, the receipt indicating that the pluggable processing consumer component received the data; and administering, by the pluggable processing provider component, the data in response to receiving the receipt. ### Claim 9 (depends on 7) The distributed computing system of claim 7 wherein the computer memory for the distributed computing system has disposed within it computer program instructions capable of: receiving, by a system administrative component from the pluggable processing consumer component, the receipt indicating that the pluggable processing consumer component received the data; sending, by the system administrative component to the pluggable processing provider component, the receipt indicating that the pluggable processing consumer component received the data; receiving, by the pluggable processing provider component from the system administrative component, the receipt indicating that the pluggable processing consumer component received the data; and administering, by the pluggable processing provider component, the data in response to receiving the receipt. ### Claim 10 (depends on 7) The distributed computing system of claim 7 wherein the computer memory for the distributed computing system has disposed within it computer program instructions capable of: determining, by the pluggable processing provider component, that the pluggable processing provider component did not receive the receipt within a predefined time period; and performing, by the pluggable processing provider component, one or more corrective actions in response to not receiving the receipt within a predefined time period. ### Claim 11 (depends on 7) The distributed computing system of claim 7 wherein maintaining access to the data further comprises storing the data in computer memory of the pluggable processing provider component. ### Claim 12 (depends on 7) The distributed computing system of claim 7 wherein maintaining access to the data further comprises storing information used by the pluggable processing provider component to recreate the data. ### Claim 13 A computer program product for tracking data processing in an application carried out on a distributed computing system, the distributed computing system comprising a plurality of computing nodes connected for data communications through a data communications network, the application carried out by a plurality of pluggable processing components installed on the plurality of computing nodes, the pluggable processing components including a pluggable processing provider component and a pluggable processing consumer component, the computer program product disposed upon a non-transitory computer readable medium, the computer program product comprising computer program instructions capable of: identifying, by the pluggable processing provider component, data satisfying predetermined processing criteria, the predetermined processing criteria specifying that the data is relevant to processing provided by the pluggable processing consumer component; passing, by the pluggable processing provider component, the data to the next pluggable processing component in the application for processing, including maintaining access to the data; receiving, by the pluggable processing consumer component, the data during execution of the application; and sending, by the pluggable processing consumer component, a receipt indicating that the pluggable processing consumer component received the data. ### Claim 14 (depends on 13) The computer program product of claim 13 further comprising computer program instructions capable of: receiving, by the pluggable processing provider component from the pluggable processing consumer component, the receipt indicating that the pluggable processing consumer component received the data; and administering, by the pluggable processing provider component, the data in response to receiving the receipt. ### Claim 15 (depends on 13) The computer program product of claim 13 further comprising computer program instructions capable of: receiving, by a system administrative component from the pluggable processing consumer component, the receipt indicating that the pluggable processing consumer component received the data; sending, by the system administrative component to the pluggable processing provider component, the receipt indicating that the pluggable processing consumer component received the data; receiving, by the pluggable processing provider component from the system administrative component, the receipt indicating that the pluggable processing consumer component received the data; and administering, by the pluggable processing provider component, the data in response to receiving the receipt. ### Claim 16 (depends on 13) The computer program product of claim 13 further comprising computer program instructions capable of: determining, by the pluggable processing provider component, that the pluggable processing provider component did not receive the receipt within a predefined time period; and performing, by the pluggable processing provider component, one or more corrective actions in response to not receiving the receipt within a predefined time period. ### Claim 17 (depends on 13) The computer program product of claim 13 wherein maintaining access to the data further comprises storing the data in computer memory of the pluggable processing provider component. ### Claim 18 (depends on 13) The computer program product of claim 13 wherein maintaining access to the data further comprises storing information used by the pluggable processing provider component to recreate the data.