International Business Machines Corporation

Kenneth S Sabir

Yoonho Park

David Lowe

Philip S P Chan

Mark Carl Hampton

Eric Martinez De Morentin

Matthew James Ponsford

Richard Bremner

Samuel Joseph Tannous

Stephen J Garward

Responsive to a client request, a processing thread for handling the client request is assigned. Responsive to the client request, a server request is sent to a stream server configured to interact with a plurality of stream processing nodes. The processing thread is maintained in an idle state pending a write response message from the stream server. The processing thread is returned to an active state responsive to receiving the write response message including a stream processing result from the stream server. A client response including the stream processing result is sent to the client.

Stream processing using a client-server architecture

An invention for generating an alternative representation of virtual content in a virtual universe is provided. In one embodiment, there is an alternative representation tool, including a visual component configured to determine a visual capacity of a user of a virtual universe. The alternative representation tool further includes an alternative component configured to provide an alternative representation of a virtual content renderable in the virtual universe based on the visual capacity of the user of the virtual universe.

Alternative representations of virtual content in a virtual universe

A method of responding to requests using stream processing includes, responsive to a client request, assigning a processing thread for handling the client request. A return connection is established within the processing thread. A server request derived from the client request is sent to a stream server configured to interact with a plurality of stream processing nodes. The server request includes a thread identifier specifying the processing thread. The processing thread for handling the client request is maintained in an idle state pending a write response message from the stream server. Responsive to receiving the write response message comprising a stream processing result and the thread identifier from the stream server, the processing thread specified by the thread identifier is returned to an active state using a processor. A client response comprising the stream processing result is returned to the client over the return connection.

Embodiments of the present invention address deficiencies of the art in respect to virtual world navigation and provide a method, system and computer program product for applying temporal rankings to elements in a virtual world. In an embodiment of the invention, a method for temporally ranking locations in a virtual world can be provided. The method can include timing a duration of visit for different locations in a virtual world, computing a temporal score for the different locations, and displaying a ranking of the locations by temporal score. For instance, computing a temporal score for the different locations can include computing a sum of durations for each of the different locations, or computing an average of durations for each of the different locations, to name two examples. Optionally, computing a temporal score for the different locations also can include filtering the durations according to a date or time range.

Temporal ranking in virtual worlds

A system for responding to requests using stream processing comprises a computer readable storage medium having computer readable program code embodied therewith and a processor coupled to the computer readable storage medium. Responsive to a client request, a processing thread is assigned for handling the client request. A return connection is established within the processing thread. A server request derived from the client request to a stream server configured to interact with a plurality of stream processing nodes is sent, and the server request comprises a thread identifier specifying the processing thread. The processing thread for handling the client request is maintained in an idle state pending a write response message from the stream server. Responsive to receiving the write response message comprising a stream processing result and the thread identifier from the stream server, the processing thread is returned to an active state.

A method for responding to requests using stream processing includes, responsive to a server request received from a server, a stream processing request being sent to a first stream processing node. Responsive to a create response message received from a second stream processing node, a stream processing result is correlated with the server request. A write response message including the stream processing result is sent to the server. The stream processing request is derived from the server request and includes a request identifier associated with the server request. The create response message includes the stream processing result and the request identifier.

A computer hardware system configured to respond to requests using stream processing includes a HTTP stream server including at least one processor. The at least one processor is configured to initiate and/or perform the following. Responsive to a server request received from a server, a stream processing request is sent to a first stream processing node. Responsive to a create response message received from a second stream processing node, a stream processing result is correlated with the server request. A write response message including the stream processing result is sent to the server. The stream processing request is derived from the server request and includes a request identifier associated with the server request. The create response message includes the stream processing result and the request identifier.

A method of load balancing can include segmenting data from a plurality of servers into usage patterns determined from accesses to the data. Items of the data can be cached in one or more servers of the plurality of servers according to the usage patterns. Each of the plurality of servers can be designated to cache items of the data of a particular usage pattern. A reference to an item of the data cached in one of the plurality of servers can be updated to specify the server of the plurality of servers within which the item is cached.

Load balancing based upon data usage

A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes in a hierarchical genome having a plurality of levels, wherein each of said processing nodes is configured to transmit and receive a stream of data. The method may further include restricting a subset of the plurality of processing nodes from differentiating into a role within each level of the hierarchical genome. The method may also include identifying a failure at one of the processing nodes and replacing the failed node with one of the processing nodes from the restricted subset.

System and method for stream processing utilizing multipotent morphogenic stem cells

A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data. The method may further include adding one or more new processing nodes to the computing system. The method may also include determining a source node based upon, at least in part, an activation level being above or below a particular threshold. The method may additionally include, for each of the one or more added processing nodes, automatically determining an appropriate role, based upon, at least in part, a neighboring processing node.

System and method for stream processing

A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data. The method may further include restricting a subset of the plurality of processing nodes from differentiating into a role. The method may also include identifying a failure at one of the processing nodes and replacing the failed node with one of the processing nodes from the restricted subset.

System and method for stream processing utilizing totipotent morphogenic stem cells

A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data. The method may also include providing a genome including a hierarchical set of tasks that represent a hierarchical functional decomposition of one or more problem scenarios. The method may further include identifying, at each of the processing nodes, one or more tasks for a first genome level. The method may additionally include differentiating, at one or more of the plurality of processing nodes, into one or more tasks, based upon, at least in part, the first genome level. The method may further include grouping a plurality of the processing nodes together to achieve a power level. The method may also include activating a second genome level once the power level has been reached. The method may further include repeating until one or more of the nodes differentiates into a further genome level.

System and method for hierarchical stream processing

A system for responding to requests using stream processing can include a processor configured to initiate executable operations including receiving a server request from a server, wherein the server is configured to generate the server request responsive to a client request, generating a request identifier associated with the server request, and, responsive to the server request, sending a stream processing request derived from the server request to a first stream processing node. The stream processing request can include the request identifier. Responsive to receiving a create response message including a stream processing result and the request identifier from a second stream processing node, the stream processing result can be correlated with the server request. A write response message specifying the stream processing result can be sent to the server.

Growing community of inventors

Marrickville, Australia

Kenneth S Sabir