International Business Machines Corporation

Other

Cornell G Wright, Jr

Michael A Paolini

Michael Wayne Brown

Newton James Smith, Jr

Foluso Olaiya Okunseinde

Michael E Aho

Nir Naaman

Gidon Gershinsky

Gordon G Stewart

John J Duigenan

Hilary A Pike

Kenneth Wayne Borgendale

Eliezer Dekel

Alexander Krits

Kulvir Singh Bhogal

Robert Charles Paulsen, Jr

Paul D Lewis

Ramanujam Ravisankar

Herman Rodriguez

Scott Lee Winters

David Jaramillo

Jerry Walter Malcolm

Steven Edward Atkin

Avraham Harpaz

Amir Farrokh Sanjar

Ricardo M Matinata

Kenneth Walter Christopher, Jr

Richard Dale Wahl

Mary M Snow

A method includes issuing a request, from an application of a contributing client device to a stream administration server, to contribute messages from the application to a feed adapter within a data communication environment via a message stream which bypasses the stream administration server. The feed adapter is coupled to a feed source via a feed adapter input stream and to at least one subscribing device via a feed adapter output stream. The feed source is separate from the contributing client device. The feed adapter input stream is separate from the message stream. The method includes receiving, in response to the request and an authentication of the contributing client device. A set of constraints on messages is to be transmitted from the contributing client device to the feed adapter.

Computer data communications in a high speed, low latency data communications environment

Executing an accelerator application program in a hybrid computing environment with a host computer having a host computer architecture; an accelerator having an accelerator architecture, the accelerator architecture optimized, with respect to the host computer architecture, for speed of execution of a particular class of computing functions; the host computer and the accelerator adapted to one another for data communications by a system level message passing module, where executing an accelerator application program on an accelerator includes receiving, from a host application program on the host computer, operating information for an accelerator application program; designating a directory as a CWD for the accelerator application program, separate from any other CWDs of any other applications running on the accelerator; assigning, to the CWD, a name that is unique with respect to names of other CWDs of other applications in the computing environment; and starting the accelerator application program on the accelerator.

Executing an accelerator application program in a hybrid computing environment

Methods, apparatus, and products are disclosed for synchronizing an active feed adapter and a backup feed adapter in a high speed, low latency data communications environment that include brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter, the active message stream capable of communicating active application messages; brokering, by the server, establishment of a backup message stream to the client device from a backup feed adapter, the backup message stream capable of communicating backup application messages; receiving an active feed adapter state in backup messaging middleware of the backup adapter from active messaging middleware of the active adapter; determining, by the backup feed adapter, whether a backup feed adapter state is synchronized with the active feed adapter state; and administering, by the backup feed adapter, operation of the backup adapter in dependence upon the determining.

Synchronizing an active feed adapter and a backup feed adapter in a high speed, low latency data communications environment

A method includes receiving active application messages that are part of an active message stream in a subscribing client device from an active feed adapter. Each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number. The method includes receiving, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages in the subscribing client device from the backup feed adapter. Each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number. The method includes administering, by the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number.

Reliable messaging using redundant message streams in a high speed, low latency data communications environment

Methods, systems, and products are disclosed for referencing message elements in an application message in a messaging environment that include: establishing a message model on a computer, the message model comprising message element specifications that each specify a message element for storing data in the application messages, each message element specification comprising element characteristics; creating, by a messaging module on the computer in dependence upon the message model, a message element designator map that maps a separate message element designator to each message element specified by the message model; receiving, in the messaging module from a requesting module, a request for an element designator for a specific message element identified by the element characteristics for the specific message element; and providing, by the messaging module to the requesting module, the requested element designator in dependence upon the message element designator map and the element characteristics for the specific message element.

Referencing message elements in an application message in a messaging environment

A secondary player receives a wireless broadcast of an electronic work from a primary player. Responsive to a playback of the electronic work from the secondary player, the secondary player requires a recipient of the electronic work to rate the electronic work. Responsive to the recipient rating the electronic work or an automatic rating selection made based on the recipient's preferences, the options available to the recipient may be dynamically adjusted.

Responding to recipient rated wirelessly broadcast electronic works

Methods, apparatus, and products are disclosed for computer data communications in a high speed, low latency data communications environment that include: brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter; receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware, whether contents of the message satisfy the constraints; and administering the message, by the messaging middleware, in dependence upon whether the message satisfies the constraints.

A second player detects a first player locally broadcasting an electronic work. The second player accepts a distribution cookie from the first player at the second player with the broadcast of the electronic work. The second player updates the distribution cookie with tracking information about the broadcast of the electronic work to the second player. The second player updates the distribution cookie with a plurality of electronic work ratings of a plurality of electronic works by a recipient at the second player. The second player, responsive to detecting a network connection provides the distribution cookie to a tracking server enabled to analyze the distribution cookie.

Tracking locally broadcast electronic works

Methods, apparatus, and products are disclosed for reliable messaging using redundant message streams in a high speed, low latency data communications environment that include brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter, the active message stream capable of communicating active application messages; brokering, by the server, establishment of a backup message stream to the subscribing client device from a backup feed adapter, the backup message stream capable of communicating backup application messages representing duplicates of the active messages; receiving the active messages in messaging middleware of the subscribing client device; receiving, in response to a failover, the backup messages in the messaging middleware; and administering, by the messaging middleware, the backup messages in dependence upon an active stream source identifier, an active stream source sequence number, a backup stream source identifier, and a backup stream source sequence number.

A method, system, and program for responding to recipient ratings of wirelessly broadcast electronic works are provided. A secondary player receives a wireless broadcast of an electronic work from a primary player. Next, responsive to a playback of the electronic work from the secondary player, the secondary player requires a recipient of the electronic work to rate the electronic work. Then, responsive to the recipient rating the electronic work or an automatic rating selection made based on the recipient's preferences, the options available to the recipient may be dynamically adjusted. First, responsive to the recipient rating the electronic work with a favorable rating, the secondary player triggers a purchase offer for the electronic work when the secondary player is connected to a network providing access to a purchase server. Second, responsive to the recipient rating the electronic work, the secondary player transfers the rating to the primary player, such that the primary player is enabled to dynamically adjust a next electronic work selection for broadcast based on the rating for the previously broadcast electronic work.

A method, system, and program for tracking locally broadcast electronic works are provided. According to one aspect of the invention, a sending player locally broadcasts an electronic work. In particular, the local broadcast may be a wireless broadcast creating an ad-hoc radio system. At least one recipient player receives the localized broadcast of the electronic work and accepts a distribution cookie for tracking distribution of the electronic work. The at least one recipient player updates the distribution cookie with tracking information about the broadcast of the electronic work, including ratings by users at the second player and purchase of the broadcast electronic work. Each of the at least one recipient players may in turn become a sending player that broadcasts the electronic work to other recipient players and requires the other recipient players to accept a copy of the distribution cookie updated by the second player. Then, responsive to detecting a network connection to a statistics server, the at least one recipient player provides the distribution cookie to the statistics server, such that localized broadcast distribution of the electronic work is tracked.

Executing a service program for an accelerator application program in a hybrid computing environment that includes a host computer and an accelerator, the host computer and the accelerator adapted to one another for data communications by a system level message passing module; where the service program includes a host portion and an accelerator portion and executing a service program for an accelerator includes receiving, from the host portion, operating information for the accelerator portion; starting the accelerator portion on the accelerator; providing, to the accelerator portion, operating information for the accelerator application program; establishing direct data communications between the host portion and the accelerator portion; and, responsive to an instruction communicated directly from the host portion, executing the accelerator application program.

Message passing module in hybrid computing system starting and sending operation information to service program for accelerator to execute application program

Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message; determining, by the transport engine, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label; providing, by the transport engine, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and administering the application message, by the messaging middleware, in dependence upon the collision indicator.

Growing community of inventors

Austin, TX, United States of America

Cornell G Wright, Jr