Streaming data on data processes

• US 10,033,781 B2
• Filed: 04/13/2017
• Issued: 07/24/2018
• Est. Priority Date: 11/09/2012
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Dettori, Paolo, Nogima, Julio, Schaffa, Frank A.
• Primary Examiner(s): Eskandarnia, Arvin
• Application Number:
  US15/487,039
• Publication Number:
  US 20170339201A1
• Time in Patent Office: 467 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 processing media content, comprising:

receiving specified media content at one or more processing units;

using a set of services operating on the one or more processing units to process the specified media content by having each of the services in the set of services process increments of the specified media content, the processing of the increments of the specified media content characterized by,

using an orchestration engine to orchestrate an exchange of the increments of the specified media content among the set of services in a defined sequence by

sending a set of communications between the orchestration engine and the set of services to orchestrate said exchange of the increments of the specified media content among the services in the set of services, and

wherein the set of services simultaneously process different ones of the increments of the specified media content to reduce a time needed to process all the increments of the specified media content, and

implementing an interface for the communications between the orchestration engine and the set of services; and

sending a notification message at defined times to the orchestration engine, the notification message indicating that each of the services in the set of services has completed processing all the increments of the specified media content.

2. The method according to claim 1, wherein:

said interface is a first interface; and

the method further comprises implementing a second interface for the exchange of the media content among the services in the set of services.

3. The method according to claim 2, wherein the first and second interfaces are separate interfaces.

4. The method according to claim 2, wherein the first and second interfaces are implemented by the services in the set of services.

5. The method according to claim 2, wherein the first and second interfaces are implemented by a mediation layer.

6. The method according to claim 1, wherein the communications between the orchestration engine and the services in the set of services include the orchestration engine sending a request to a first of the services in the set of services to produce the specified media content.

7. The method according to claim 6, wherein the using the orchestration engine to orchestrate the exchange of the increments of the specified media content among the services in the set of services includes the orchestration engine invoking a second of the services in the set of services to transform the specified media content.

8. The method according to claim 7, wherein the using of the orchestration engine to orchestrate the exchange of the increments of the specified media content among the services in the set of services further includes the orchestration engine calling a third of the services in the set of services and informing the third of the services in the set of services that one or more increments of the specified media content is available to the third of the services from the second of the services.

9. The method according to claim 6, wherein the communications between the orchestration engine and the services in the set of services further includes the first of the services in the set of services informing the orchestration engine of a specified port at which the specified media content produced by the first of the services in the set of services will be available.

10. The method according to claim 9, wherein the communications between the orchestration engine and the services in the set of services further includes the orchestration engine informing a second of the services in the set of services of the specified port of the first of the services in the set of services at which the specified media content produced by the first of the services in the set of services is available.

11. A system for servicing media content, comprising:

one or more processing units configured for;

using a set of services operating on the one or more processing units to process the specified media content by having each of the services in the set of services process increments of the specified media content, the processing of the increments of the specified media content characterized by,

using an orchestration engine to orchestrate an exchange of the increments of the specified media content among the set of services in a defined sequence by

sending a set of communications between the orchestration engine and the set of services to orchestrate said exchange of the increments of the specified media content among the services in the set of services, and

wherein the set of services simultaneously process different ones of the increments of the specified media content to reduce a time needed to process all the increments of the specified media content, and

implementing an interface for the communications between the orchestration engine and the set of services; and

sending a notification message at defined times to the orchestration engine, the notification message indicating that each of the services in the set of services has completed processing all the increments of the specified media content.

12. The system according to claim 11, wherein:

said interface is a first interface; and

the one or more processing units are further configured for implementing a second interface for the exchange of the specified media content among the services in the set of services.

13. The system according to claim 12, wherein the first and second interfaces are separate interfaces.

14. The system according to claim 12, wherein the first and second interfaces are implemented by the services in the set of services.

15. The system according to claim 12, wherein the first and second interfaces are implemented by a mediation layer.

16. An article of manufacture comprising:

at least one tangible computer readable device having computer readable instructions tangibly embodied therein to use a set of services to process specified media content by having each of the services in the set of services process increments of the specified media content, the computer readable instructions, when executing, performing the following;

using an orchestration engine to orchestrate an exchange of the increments of the specified media content among the set of services in a defined sequence by

sending a set of communications between the orchestration engine and the set of services to orchestrate said exchange of the increments of the specified media content among the services in the set of services, and

wherein the set of services simultaneously process different ones of the increments of the specified media content to reduce a time needed to process all the increments of the specified media content, and

implementing an interface for the communications between the orchestration engine and the set of services; and

sending a notification message at defined times to the orchestration engine, the notification message indicating that each of the services in the set of services has completed processing all the increments of the specified media content.

17. The article of manufacture according to claim 16, wherein:

said interface is a first interface; and

the computer readable instructions, when executed implements a second interface for the exchange of the specified media content among the services in the set of services.

18. The article of manufacture according to claim 17, wherein the first and second interfaces are separate interfaces.

19. The article of manufacture according to claim 17, wherein the first and second interfaces are implemented by the services in the set of services.

20. The article of manufacture according to claim 17, wherein the first and second interfaces are implemented by a mediation layer.