Method and system for ensuring reliability of unicast video streaming at a video streaming platform

• US 9,912,707 B2
• Filed: 07/31/2014
• Issued: 03/06/2018
• Est. Priority Date: 07/31/2014
• Status: Active Grant

• Current Assignee: iStreamPlanet Co. LLC (Warner Bros. Discovery, Inc.)
• Original Assignee: iStreamPlanet
• Inventors: Galdy, Alessio, VanAntwerp, Mark
• Primary Examiner(s): NGUYEN, THU HA T
• Application Number:
  US14/448,996
• Publication Number:
  US 20160036693A1
• Time in Patent Office: 1,314 Days
• Field of Search: 709219, 709238, 709224, 455453, 707782
• CPC Class Codes: G06F 11/00 Error detection; Error correction; Monitoring error detection, correction or monitoring in information storage based on relative movement between record carrier and transducer G11B20/18; monitoring, i.e. supervising the progress of recording or reproducing G11B27/36; in static stores G11C29/00
• CPC Class Codes: G06F 11/1479 Generic software techniques for error detection or fault masking
• CPC Class Codes: G06F 11/20 using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements
• CPC Class Codes: G06F 9/00 Arrangements for program control, e.g. control units program control for peripheral devices G06F13/10
• CPC Class Codes: H04L 47/125 by balancing the load, e.g. traffic engineering
• CPC Class Codes: H04L 65/61 for supporting one-way streaming services, e.g. Internet radio
• CPC Class Codes: H04L 65/70 Media network packetisation
• CPC Class Codes: H04L 65/765 intermediate
• CPC Class Codes: H04L 67/1029 using data related to the state of servers by a load balancer
• CPC Class Codes: H04L 67/1034 Reaction to server failures by a load balancer
• CPC Class Codes: H04L 69/164 Adaptation or special uses of UDP protocol
• CPC Class Codes: H04L 69/40 for recovering from a failure of a protocol instance or entity, e.g. service redundancy protocols, protocol state redundancy or protocol service redirection management of faults, events, alarms or notifications in data switching networks H04L41/06
• CPC Class Codes: H04N 21/23439 for generating different versions
• CPC Class Codes: H04N 21/2402 Monitoring of the downstream path of the transmission network, e.g. bandwidth available traffic monitoring in data switching networks H04L43/00; monitoring data switching networks utilization H04L43/0876
• CPC Class Codes: H04N 21/6405 Multicasting data broadcast and multicast in packet switching networks H04L12/18
• CPC Class Codes: H04N 21/6408 Unicasting

Abstract

A method implemented in an electronic device serving as a stream distributor distributing unicast video and audio streams of a streaming platform system is disclosed. The stream distributor receives a unicast data flow containing data of a video and audio stream from a load balancer, the unicast data flow being transmitted in user datagram protocol (UDP) packets. The method includes the electronic device detecting initiation of a maintenance activity on a virtual machine or its host associated with the stream distributor. The method includes the electronic device indicating a failure mode of the stream distributor, where the failure mode indication is to cause the load balancer to switch the unicast data flow to an alternate stream distributor. The method also includes the electronic device detecting a completion of the load balancer switching the unicast data flow to the alternate stream distributor, and halting the distribution of the unicast data flow.

Claims

1. A method implemented in an electronic device serving as a stream distributor distributing unicast video and audio streams of a streaming platform system, the stream distributor receiving a unicast data flow containing data of a video and audio stream from a load balancer of the streaming platform system and distributing to one or more workers of the streaming platform system to process, the unicast data flow being transmitted in user datagram protocol (UDP) packets, the method comprising:

detecting by the stream distributor initiation of a maintenance activity on a virtual machine or its host where the virtual machine or host support execution of the stream distributor, wherein the virtual machine is a part of a cloud computing environment of the streaming platform system;

indicating to the load balancer a failure mode of the stream distributor, wherein the failure mode indication is to cause the load balancer to switch the unicast data flow from the stream distributor to an alternate stream distributor;

detecting by the stream distributor a completion of the load balancer switching the unicast data flow to the alternate stream distributor; and

halting the distribution of the unicast data flow to the one or more workers by the stream distributor.

2. The method of claim 1, further comprising:

delaying the maintenance activity for a period of time after detecting the initiation, wherein the period of time is to allow the load balancer to switch the unicast data flow to the alternate stream distributor; and

causing performance of the maintenance activity on the virtual machine or its host associated with the stream distributor after the halting the distribution of the unicast data flow to the one or more workers.

3. The method of claim 2, wherein the period of time ends upon the stream distributor no longer receiving UDP packets of the unicast data flow.

4. The method of claim 2, wherein delaying the maintenance activity comprises interactions with an application programing interface (API) of the cloud computing environment.

5. The method of claim 2, further comprising:

after completion of the maintenance activity, indicating that the stream distributor is healthy again so that the load balancer switches the unicast data flow from the alternate stream distributor back to the stream distributor.

6. The method of claim 1, wherein the load balancer probes the stream distributor at a predetermined interval to determine whether or not the stream distributor is in the failure mode.

7. The method of claim 6, wherein upon determining the stream distributor is in the failure mode, the load balancer switches the unicast data flow from the stream distributor to the alternate stream distributor.

8. The method of claim 1, wherein the unicast data flow forwarded by the stream distributor to the one or more workers is only a portion of a video source entering the streaming platform system for processing, wherein the portion of the video source is selected based at least partially on processing tasks executed by the one or more workers.

9. An electronic device to serve as a stream distributor distributing unicast video and audio streams of a streaming platform system, the stream distributor receiving a unicast data flow containing data of the video and audio stream from a load balancer of the streaming platform system and distributing to one or more workers of the streaming platform system to process, the unicast data flow being transmitted in user datagram protocol (UDP) packets, the electronic device comprising:

a non-transitory machine-readable storage medium to store the stream distributor; and

a processor coupled to the non-transitory machine-readable storage medium, the processor to execute the stream distributor, the stream distributor configured to detect initiation of a maintenance activity on a virtual machine or its host associated where the virtual machine or hose support execution of the stream distributor, wherein the virtual machine is a part of a cloud computing environment of the streaming platform system;

indicate to the load balancer a failure mode of the stream distributor, wherein the failure mode indication is to cause the load balancer to switch the unicast data flow from the stream distributor to an alternate stream distributor;

detect a completion of the load balancer switching the unicast data flow to the alternate stream distributor; and

halt the distribution of the unicast data flow to the one or more workers by the stream distributor.

10. The electronic device of claim 9, wherein the stream distributor is further configured to:

delay the maintenance activity for a period of time after detecting the initiation, wherein the period of time is to allow the load balancer to switch the unicast data flow to the alternate stream distributor; and

cause performance of the maintenance activity on the virtual machine or its host associated with the stream distributor after the halting the distribution of the unicast data flow to the one or more workers.

11. The electronic device of claim 10, wherein the stream distributor is further configured to:

after completion of the maintenance activity, indicate that the stream distributor is healthy again so that the load balancer switches the unicast data flow from the alternate stream distributor back to the stream distributor.

12. The electronic device of claim 9, wherein the load balancer is to probe the stream distributor at a predetermined interval to determine whether or not the stream distributor is in the failure mode.

13. The electronic device of claim 9, wherein the unicast data flow forwarded by the stream distributor to the one or more workers is only a portion of a video source entering the streaming platform system for processing, wherein the portion of the video source is selected based at least partially on processing tasks executed by the one or more workers.

14. A non-transitory machine-readable medium having instructions stored therein, which when executed by a processor, cause the processor to perform operations in an electronic device serving as a stream distributor distributing unicast video and audio streams of a streaming platform system, the stream distributor receiving a unicast data flow containing data of a video and audio stream from a load balancer of the streaming platform system and distributing to one or more workers of the streaming platform system to process, the unicast data flow being transmitted in user datagram protocol (UDP) packets, the operations comprising:

detecting by the stream distributor initiation of a maintenance activity on a virtual machine or its host where the virtual machine or host support execution of the stream distributor, wherein the virtual machine is a part of a cloud computing environment of the streaming platform system;

indicating to the load balancer a failure mode of the stream distributor, wherein the failure mode indication is to cause the load balancer to switch the unicast data flow from the stream distributor to an alternate stream distributor;

detecting by the stream distributor a completion of the load balancer switching the unicast data flow to the alternate stream distributor; and

halting the distribution of the unicast data flow to the one or more workers by the stream distributor.

15. The non-transitory machine-readable medium of claim 14, wherein the operations further comprise:

delaying the maintenance activity for a period of time after detecting the initiation, wherein the period of time is to allow the load balancer to switch the unicast data flow to the alternate stream distributor; and

causing performance of the maintenance activity on the virtual machine or its host associated with the stream distributor after the halting the distribution of the unicast data flow to the one or more workers.

16. The non-transitory machine-readable medium of claim 14, wherein delaying the maintenance activity comprises interactions with an application programing interface (API) of the cloud computing environment.

17. The non-transitory machine-readable medium of claim 14, wherein the operations further comprise:

after completion of the maintenance activity, indicating that the stream distributor is healthy again so that the load balancer switches the unicast data flow from the alternate stream distributor back to the stream distributor.

18. The non-transitory machine-readable medium of claim 14, wherein the load balancer probes the stream distributor at a predetermined interval to determine whether or not the stream distributor is in the failure mode.

19. The non-transitory machine-readable medium of claim 18, wherein upon determining the stream distributor is in the failure mode, the load balancer switches the unicast data flow from the stream distributor to the alternate stream distributor.

20. The non-transitory machine-readable medium of claim 14, wherein the unicast data flow forwarded by the stream distributor to the one or more workers is only a portion of a video source entering the streaming platform system for processing, wherein the portion of the video source is selected based at least partially on processing tasks executed by the one or more workers.