A method for processing tasks in a distributed data processing system includes processing sets of tasks. The method includes maintaining, at a first processing node a number of counters including a working counter indicating a current time interval of the number of time intervals in the distributed data processing system, and a replication counter indicating a time interval of the number of time intervals for which at least one of (1) all tasks associated with that time interval, or (2) all corresponding results associated with that time interval, are replicated at multiple processing nodes of the number of processing nodes. The method includes providing messages from the first processing node to the other processing nodes of the number of processing nodes, the messages including the working counter and the replication counter.

A method for processing data using a distributed data processing system includes providing input data to the distributed data processing system from a distributed data processing system interface component in communication with the distributed data processing system. The distributed data processing system processes the input data to generate a response, which it provides to the distributed data processing system interface component. The distributed data processing system interface component holds the response in escrow until it receives an indication from the distributed data processing system that the response has reached a sufficient level of durability.

A method for processing state update requests in a distributed data processing system with a number of processing nodes includes maintaining a number of counters including a working counter indicating a current time interval, a replication counter indicating a time interval for which all requests associated with that time interval are replicated at multiple processing nodes of the number of processing nodes, and a persistence counter indicating a time interval of the number of time intervals for which all requests associated with that time interval are stored in persistent storage. The counters are used to manage processing of the state update requests.

A method for managing a distributed data processing system, the method implementing counters to track durability states of data units in the distributed data processing system, wherein the counters are used to manage processing of the data units in the distributed data processing system.

A method for managing data in a distributed data processing system including a number of processing nodes includes storing data units in data stores that are associated with a number of different levels of durability. The method includes maintaining indicators including a first indicator associated with a first durability level and a second indicator associated with a second durability level. The first indicator is maintained to reflect a time interval at which all sets of data units associated with the time interval are stored at the first durability level. The second indicator is maintained to reflect a timer interval at which all sets of data units associated with the time interval are stored at the second durability level. The first and second indicators are used to manage processing of the data units in the distributed data processing system.

A method for processing state update requests in a distributed data processing system includes processing a set of state update requests associated with a first time interval including maintaining a count of issued state update requests for the set of state update requests, maintaining a count of state updates performed for the first set of state update requests, and updating a state consistency indicator to indicate that state updates associated with all state update requests of the first set of state update requests have been performed in response to determining that the count of state updates performed for the first set of state update requests equals the count of issued state update requests for the first set of state update requests.

A computer system includes transactional memory to implement a nested transaction. The computer system generates a plurality of speculative identification numbers (IDs), identifies at least one of a software thread executed by a hardware processor and a memory operation performed in accordance with an application code. The computer system assigns at least one speculative cache version to a requested transaction based on a corresponding software thread. The speculative ID of the corresponding software thread identifies the speculative cache version. The computer system also identifies a nested transaction in the memory unit, assigns a cache version to the nested transaction, detects a conflict with the nested transaction, determines a conflicted nesting level of the nested transaction, and determines a cache version corresponding to the conflicted nesting level. The computer system also invalidates the cache version corresponding to the conflicted nesting level.

A digital content copyright management method includes: receiving a copyright processing request, and constructing a copyright management transaction according to the copyright processing request; and storing the copyright management transaction in a blockchain for processing, where the blockchain is stored in all blockchain apparatuses. Trusted and secure processing of the copyright management transaction can be implemented.

A digital proof of delivery for digital goods items purchased online includes methods and systems for authenticating online purchases for helping to prevent and mitigate fraud. A unique download identification (ID) is created and associated with the digital goods download and purchase. Additionally, third parties may readily be allowed to view the download status of a digital goods item by providing the unique download identification (ID) of the item, which may be useful for aiding third party fraud investigations. In response to an item of digital goods purchased by a customer for download from a merchant having reached a specific stage of downloading, but the download is not complete, download is suspended and a dialog box is sent over a network for presentation to a customer, and, in response to a confirmation received via the dialog box, the download is completed with a download ID that is unique to the completed download.

A data management system receives a status update request in which a target is specified and executes status update processing of updating a status of the target specified in the status update request. The status update processing includes transaction processing that is processing of updating first information and second information in an ACID (Atomicity, Consistency, Isolation, Durability) transactional manner. The first information is a first object group (one or more first objects) for each target. The first object is data that represents the status of the target. The second information is a second object group (one or more second objects) for each target. The transaction processing includes first processing of creating, updating, or deleting the first object corresponding to the specified target, and second processing of adding the second object including at least one of a content of the first processing and a summary of the first object to the second object group corresponding to the specified target.