In embodiments of the present disclosure, there is provided a solution for establishing queues between threads in a user space. After creating a first thread on a first application and creating a second thread and a third thread on a second application, a socket connection between the first application and the second application is established in the user space of the operating system. Then, a first queue is established between the first thread and the second thread, while a second different queue is established between the first thread and the third thread. Embodiments of the present disclosure can avoid lock-based queue sharing by setting a separate queue for each pair of threads. Thus, the lockless queue mechanism according to embodiments of the present disclosure can improve the performance of the operating system significantly.

Methods and systems are provided for processing a stream of incoming messages sent from a specific input message source and validating each incoming message of that stream before sending them to a specific target system.

In one example, a zone player may include a network interface, at least one processor, a non-transitory computer-readable medium, and program instructions stored on the non-transitory computer-readable medium that may be executable by the at least one processor such that the zone player is configured to receive an instruction to change a volume setting of the zone player to a requested volume level; in response to receiving the instruction to change the volume setting of the zone player to the requested volume level, adjust the volume setting of the zone player to an adapted volume level that is lower than the requested volume level; and after adjusting the volume setting of the zone player to the adapted volume level, send an indication that the volume setting of the zone player has been adjusted to the requested volume level rather than the adapted volume level.

An information processing system, an information processing method, and an information processing apparatus. The information processing system includes at least one memory configured to store a plurality of jobs in order, by type of processing to be executed and a plurality of processors assigned to a specific type of processing to be executed, processes a job assigned to other processor stored in the memory in substitution for the other processor based on a determination that the job of the assigned type of processing is not stored in the memory, and cancels substituting of the processing of the job assigned to the other processor according to a processing status of at least one of other processors.

Disclosed herein are an apparatus and method for accelerating file I/O offload for a unikernel. The method, performed by the apparatus and server for accelerating file I/O offload for the unikernel, includes; executing, by the apparatus, an application in the unikernal and calling, by the thread of the application, a file I/O function; generating, by the unikernal, a file I/O offload request using the file I/O function; transmitting, by the unikernal, the file I/O offload request to Linux of the server; receiving, by Linux, the file offload request from the thread of the unikernel and processing, by Linux, the file I/O offload request; transmitting, by Linux, a file FO offload result for the file I/O I/O offload request to the unikernel; and delivering the file I/O offload result to the thread of the application.

Technologies for generating triggered conditional events operations include a host fabric interface (HFI) of a compute device configured to receive an operation execution command message associated with a triggered operation that has been fired, process the received operation execution command message to extract and store argument information from the received operation execution command, and increment an event counter associated with the fired triggered operation. The HFI is further configured to perform a triggered compare-and-generate event (TCAGE) operation as a function of the extracted argument information, determine whether to generate a triggering event, generate the triggering event as a function of the performed TCAGE operation, insert the generated triggered event into a triggered operation queue, and update the value of the event counter. Other embodiments are described herein.

A system and method (referred to as a systems) builds alert packages that deliver messages to end-users analyzes inbound message data and identifies inbound event data objects. The systems store the inbound event data objects that are removed based on assigned priority values from a first multielement data structure. The systems process the inbound event data objects based on the assigned priority values through a cluster of event analyzer engines connected in parallel and identify the inbound event data objects associated with pre-designated notification alerts through a cluster of event analyzer engines connected in parallel. The systems store the inbound event data objects associated with the pre-designated notification alerts within a another instance of the multielement data structure. The system creates alert packages through a cluster of alert builder engines and enables and disable the processors that make up the event analyzer and alert builder engines.

In certain embodiments, a method includes starting an application as a first process within a user space of an operating system. The application instantiates a data storage system associated with the operating system. The method also includes starting a block device service as a second process within the user space of the operating system, the block device service being configured to manage a persistent storage device of the computing device. In addition, the method includes receiving, by a kernel of the operating system, a system call request from the application to communicate with the block device service, the system call request is generated by the application using the data storage system and comprises an access request to access the persistent storage device. The method further includes providing the application, in response to the system call request, access to the block device service through the IPC channel.

Example implementations described herein involve a system that manages a dispatch of data within an Internet of Things (IoT) system that can involve a first process for intaking new data and conducting one of dispatching the new data or queuing the new data; a second process executed at lower priority than the first process involving determining if queued data exceeds a retry count; forwarding the queued data to a third process if the retry count does not exceed the threshold; and popping the queued data into an error process if the queued data exceeds the retry count; and the third process executed after receiving the queued data from the second process, involving attempting to dispatch the queued data.

In an embodiment, a method is provided. In an embodiment, the method provides determining that a message has been placed in a send buffer; and transferring the message to an application on a second virtual machine by bypassing use of an operating system to process the message by directly placing the message in an application memory space from which the application can retrieve the message.