US 2020/0092120 A1 · Feed Processing

Abstract

A data processing system comprising: a processing subsystem supporting a plurality of consumers, each consumer being arranged to process messages received into a corresponding receive queue; a network interface device supporting a virtual interface for each of the receive queues; and a hardware accelerator coupled to the processing subsystem by the network interface device and configured to parse one or more streams of data packets received from a network so as to, for each consumer: identify in the data packets messages having one or more of a set of characteristics associated with the consumer; and frame the identified messages in a new stream of data packets addressed to a network endpoint associated with the virtual interface of the consumer so as to cause said new stream of data packets to be delivered into the receive queue of the consumer.

Claims28

Dependent claims

A network interface device comprising:

circuitry configured to support a virtual interface for each of a plurality of receive queues associated with a plurality of consumers comprised within a processing subsystem;
and
a hardware accelerator configured to parse one or more streams of data packets received from a network so as to:
identify messages within the received data packets having one or more of a respective set of characteristics requested by a respective consumer;
duplicate the messages that have one or more of the respective set of characteristics associated with more than one consumer of the plurality of consumers so as to provide those messages to each of those consumers;
and
provide the identified messages in a stream of data packets for each consumer, such that the data packets are addressed to a network endpoint associated with the virtual interface of the respective consumer so as to cause said stream of data packets to be delivered into the receive queue of the respective consumer.

4 more elements

A method for distributing messages to consumers, the method comprising:

receiving a request, from a plurality of consumers, for messages from one or more streams of data packets received at the hardware accelerator by indicating to the hardware accelerator a respective set of characteristics identifying those messages;
and
on receiving the one or more streams of data packets from a network, the hardware accelerator parsing the streams of data packets, and:
identifying messages within the received data packets having one or more of a respective set of characteristics requested by a respective consumer;
duplicating the messages that have one or more of the respective set of characteristics associated with more than one consumer of the plurality of consumers so as to provide those messages to each of those consumers;
and
providing the identified messages in a stream of data packets for each consumer, such that the data packets are addressed to a network endpoint associated with the virtual interface of the respective consumer so as to cause said stream of data packets to be delivered into the receive queue of the respective consumer.

4 more elements

Dependencies are inferred from the claim text.

Feed Processing

Life of this patent

Feed Processing

Life of this patent

Abstract

Claims28