A method including processing a stream of data in a sequence of tasks. The processing including receiving a first block of data of the stream of data, determining features associated with the first block of data, selecting, based on the features, one of a first a task to process the first block of data or a second task to process the first block of data and if the second task is selected, shift an output of the second task in time to align the output of the second task with a predicted output of the first task processing a second block of data of the stream of data.

A technique for generating component usage statistics involves associating components with blocks of a stream-enabled application. When the streaming application is executed, block requests may be logged by Block ID in a log. The frequency of component use may be estimated by analyzing the block request log with the block associations.

A technique for generating component usage statistics involves associating components with blocks of a stream-enabled application. When the streaming application is executed, block requests may be logged by Block ID in a log. The frequency of component use may be estimated by analyzing the block request log with the block associations.

Methods and apparatuses for providing a dynamically scalable ADNA Manager with decentralized atomic decision making are described. The decentralized atomic decision making may be performed using atomic deterministic next action (ADNA) task blocks that execute one or more workflow rules and then invoke one or more ADNAs within a pool of ADNAs. The ADNA Manager may identify a first ADNA task block, determine a set of input parameters for the first ADNA task block, detect that a first input parameter of the set of input parameters does not satisfy a qualification rule for the first ADNA task block, identify an exception ADNA task block in response to detection that the first input parameter does not satisfy the qualification rule, store breadcrumb information for the first ADNA task block within a persistence layer prior to the exception ADNA task block being invoked, and invoke the exception ADNA task block.

In example implementations, an apparatus is provided. The apparatus includes a context switch block, a processor performance state block, and a task execution block. The context switch block is to perform a context switch. The processor performance state block is to load a processor with a processor performance state stored in a context information associated with a task. The task execution block is to execute the task with the processor operating at the processor performance state loaded from the context information.

Techniques are disclosed for reducing or eliminating loop overhead caused by function calls in processors that form part of a pipeline architecture. The processors in the pipeline process data blocks in an iterative fashion, with each processor in the pipeline completing one of several iterations associated with a processing loop for a commonly-executed function. The described techniques leverage the use of message passing for pipelined processors to enable an upstream processor to signal to a downstream processor when processing has been completed, and thus a data block is ready for further processing in accordance with the next loop processing iteration. The described techniques facilitate a zero loop overhead architecture, enable continuous data block processing, and allow the processing pipeline to function indefinitely within the main body of the processing loop associated with the commonly-executed function where efficiency is greatest.

An information processing device connectable to a plurality of storage devices includes a power source circuit configured to supply power from a backup power source to each of the plurality of storage devices in response to a power loss event, and a processor. The processor is configured to transmit, to each of the storage devices, a first instruction to save user data that have been transmitted to the storage device and have not been written in a non-volatile manner, in response to the power loss event, and transmit, to at least one of the storage devices, a second instruction to save updated address translation information that corresponds to the user data and has not been reflected in an address translation table, upon receiving a response indicating completion of saving the user data from each of the storage devices.

An information processing device connectable to a plurality of storage devices includes a power source circuit configured to supply power from a backup power source to each of the plurality of storage devices in response to a power loss event, and a processor. The processor is configured to transmit, to each of the storage devices, a first instruction to save user data that have been transmitted to the storage device and have not been written in a non-volatile manner, in response to the power loss event, and transmit, to at least one of the storage devices, a second instruction to save updated address translation information that corresponds to the user data and has not been reflected in an address translation table, upon receiving a response indicating completion of saving the user data from each of the storage devices.

Embodiments of this disclosure disclose a block processing method, a node, and a system, to improve the speed of block generation and the performance of transaction processing. One method includes: a first node being a leader node, and a second node being a follower node, packaging, by the first node, first transaction information in a transaction queue of the first node into a candidate block, and broadcasting the candidate block through the blockchain; performing, by the first node, verification on the first transaction information in the candidate block to generate a first verification result, and executing the first transaction information in the candidate block to generate a first transaction execution result; broadcasting, by the first node, a first node processing result comprising the first verification result and the first transaction execution result through the blockchain; receiving, by the first node, a second node processing result broadcast by the second node through the blockchain, the second node processing result comprising: a second verification result generated by the second node by performing verification on the first transaction information in the candidate block, and a second transaction execution result generated by executing the first transaction information in the candidate block by the second node; and performing, by the first node, consensus on the candidate block according to the first node processing result and the second node processing result, saving, by the first node, the candidate block in response to a consensus on the candidate block being reached successfully, and saving, by the first node, the first transaction execution result in response to the first transaction information being executed successfully.

An information management system for detecting not only a set of management target data which has been changed but also another set of management target data which is affected by that change among a plurality of sets of management target data. The present system includes a dependency manager for managing the association of one set of management target data with another set of management target data which depends on the former set of management target data; and an inspector for detecting a set of management target data which is affected by a change in another set of management target data.