Streaming data on data processes

• US 9,667,680 B2
• Filed: 12/21/2015
• Issued: 05/30/2017
• Est. Priority Date: 11/09/2012
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Nogima, Julio, Schaffa, Frank A., Dettori, Paolo
• Primary Examiner(s): Eskandarnia, Arvin
• Application Number:
  US14/976,064
• Publication Number:
  US 20160112480A1
• Time in Patent Office: 526 Days
• CPC Class Codes: H04L 65/60 Network streaming of media packets
• CPC Class Codes: H04L 65/61 for supporting one-way streaming services, e.g. Internet radio
• CPC Class Codes: H04L 65/612 for unicast
• CPC Class Codes: H04L 65/75 Media network packet handling
• CPC Class Codes: H04L 65/762 at the source reformatting of additional data in video distribution servers H04N21/2355
• CPC Class Codes: H04L 9/40 Network security protocols

Abstract

A method, system and computer program product for servicing media content. In one embodiment, the media content is processed by having each of a group of services process increments of the media content, one increment at a time; and the order in which the services process these increments is orchestrated to process all of the media content in accordance with a defined procedure. In one embodiment, the increments of the media content are passed, one increment after another, to at least a plurality of the services in a defined order. In an embodiment, each time one of the plurality of services passes one of the increments of the media content to a subsequent one of the services in the defined order, the one of the plurality of services requests another increment of the media content from a preceding one of the services in the defined order.

Claims

1. A method of servicing media content, comprising:

receiving specified media content at one or more processing units;

using a multitude of services operating on the one or more processing units to process the media content by having each of the services process increments of the media content, one increment at a time;

executing the one or more processing units, implementing a media content servicing program, for orchestrating the order in which the services process the increments of the media content to process all of the media content in accordance with a defined procedure, including

orchestrating the exchange of the increments of the media content among the services in a defined sequence, and

using different ones of the services to process simultaneously different ones of the increments of the media content to reduce a time needed to service all of the specified media content; and

at defined times, each of a plurality of the services sending a notification message indicating that said each service has completed processing all the increments of the media content.

2. The method according to claim 1, wherein the using a multitude of services to process the media content includes:

requesting content operations from each of the multitude of services; and

each of said services, in response to the request for content operations, sending a message indicating that said each service supports processing of increments of the media content.

3. The method according to claim 1, wherein:

one of said services is a last service in said defined procedure; and

the using a multitude of services to process the media content includes, after said last service has finished processing all of the increments of the media content, said last service indicating that the defined procedure to process all of the media content is complete.

4. The method according to claim 3, wherein the using a multitude of services further includes:

said last service requesting an additional increment of the media content at multiple times; and

in response to one of the requests for an additional increment of the media content, sending to said last service a message indicating that no more data is to be processed by said last service.

5. The method according to claim 4, wherein the last service indicates that the defined procedure is complete after said last service receives said message.

6. The method according to claim 1, wherein the orchestrating the exchange of the increments of the media content among the services includes:

each of a first group of the services obtaining the increments of the media content from another one of the services; and

identifying to each service of the first group of the services the other one of the services from which said each service obtains the increments of the media content.

7. The method according to claim 1, wherein the orchestrating the exchange of the increments of the media content among the services further includes informing each service of a first group of the services of a specified port from which said each service obtains the increments of the media content.

8. The method according to claim 1, wherein the orchestrating includes passing the multitude of increments, one increment after another, to at least a plurality of the services in a defined order.

9. The method according to claim 8, wherein each time one of said plurality of services passes one of the increments of the media content to a subsequent one of the services in the defined order, said one of the plurality of services requests another one of the increments of the media content from a preceding one of the services in the defined order.

10. The method according to claim 1, wherein:

the receiving specified media content includes receiving the specified media content from a digital camera.

11. The method according to claim 1, wherein the orchestrating the order in which the services process the increments of the media content includes:

identifying ports of the one or more processing units at which the increments of the media content are available; and

one or more of the services obtaining the increments of the media content from the identified ports.

12. The method according to claim 1, wherein:

the orchestrating the exchange of the increments of the media content includes using an orchestration engine to orchestrate the increments of the media content; and

the each of a plurality of the services sending a notification message includes each of the plurality of the services sending the notification message to the orchestration engine indicating that said each service has completed processing all the increments of the media content.

13. The method according to claim 12, wherein:

the using a multitude of services to process the media content includes each of the plurality of services requesting increments of the media content from one of the other services; and

at specified times, each of the plurality of services receiving a message indicating that there is no more media content.

14. The method according to claim 13, wherein:

the each of the plurality of services sending a notification message further includes said each of the plurality of services sending the notification message when said each service receives the message indicating that there is no more media content.

15. A method of orchestrating servicing of media content, comprising:

requesting incremental media content processing from each of a multitude of services;

each of the services sending a message indicating that said each service supports incremental media content processing;

each of the services processing increments of the media content, one increment at a time;

orchestrating the order in which the services process the increments of the media content pursuant to a defined program to process all of the media content, including

each of a first plurality of the services identifying a port at which said each service makes processed media content available to another of the services, and passing the increments of the media content to said another of the services via said identified port,

each of a second plurality of the services obtaining the increments of the media content from another one of the services, and

using different ones of the services to process simultaneously different ones of the increments of the media content to reduce a time needed to service all of the specified media content; and

at defined times, each of the second plurality of the services sending a notification message indicating that said each service has completed processing all the increments of the media content.

16. The method according to claim 15, wherein one of said services, after all of the increments of the media content have been processed according to the defined program, sending a message indicating that the defined program is complete.

17. The method according to claim 15, wherein the orchestrating further includes identifying to each of the second plurality of the services the other one of the services from which said each service obtains the increments of the media content.

18. The method according to claim 15, wherein the orchestrating further includes passing the multitude of increments, one increment after another, to the second plurality of the services in a defined order.