Lightweight polling technique

• US 8,972,558 B1
• Filed: 08/14/2012
• Issued: 03/03/2015
• Est. Priority Date: 08/14/2012
• Status: Active Grant

• Current Assignee: Time Warner Cable Enterprises LLC (Charter Communications Incorporated)
• Original Assignee: Time Warner Cable Enterprises LLC (Charter Communications Incorporated)
• Inventors: Horton, Gary
• Primary Examiner(s): JACOBS, LASHONDA T
• Application Number:
  US13/585,651
• Time in Patent Office: 931 Days
• Field of Search: 709/203, 709/217, 709/219, 709/223, 709/224
• US Class Current: 709/223
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 67/141 Setup of application sessions admission control or resource allocation in data switching networks H04L47/70
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

At a network layer of a physical server, during a time when updated information about a topic is unavailable, a first polling request for information about the topic is obtained from a client. The first polling request is directed to a particular port. The first polling request is responded to with a connection refused message, from the network layer of the physical server. In response to updated information about the topic becoming available, a topic server is launched on the physical server and the particular port is opened. A second polling request for information about the topic, directed to the particular port, is obtained from the client. The second polling request is responded to, from the topic server on the physical server, with a message to the client including the updated information about the topic.

Claims

1. A method comprising the steps of:

obtaining, at a network layer of a physical server, from a client, during a time when updated information about a topic is unavailable, a first polling request for information about said topic, said first polling request being directed to a particular port;

responding to said first polling request, from said network layer of said physical server, with a connection refused message;

in response to updated information about said topic becoming available, launching a topic server on said physical server and opening said particular port;

obtaining, at said particular port on said topic server on said physical server, a second polling request for information about said topic, from said client, said second polling request being directed to said particular port; and

responding to said second polling request, from said topic server on said physical server, with a message to said client including said updated information about said topic.

2. The method of claim 1, wherein said second polling request is obtained during a first predetermined time after said updated information about said topic is available.

3. The method of claim 2, further comprising closing said particular port after a second predetermined time has elapsed.

4. The method of claim 3, further comprising, as part of an initial registration process, advising said client of said particular port.

5. The method of claim 4, further comprising, as part of said initial registration process, advising said client of a polling time interval.

6. The method of claim 5, wherein, in said step of advising said client of said polling time interval, said polling time interval is no greater than said second predetermined time.

7. The method of claim 5, further comprising obtaining a registration request from said client, wherein said advising of said client is in response to said registration request.

8. The method of claim 7, further comprising:

establishing interconnections with a plurality of content providers; and

monitoring for updated content from said content providers;

wherein said launching of said topic server and said opening of said particular port are in response to said updated content being available from a corresponding one of said content providers.

9. The method of claim 1, further comprising providing a system, wherein the system comprises distinct software modules, each of the distinct software modules being embodied on a non-transitory computer-readable storage medium, and wherein the distinct software modules comprise a network layer module, a topic server module, and a content listener module;

wherein;

said obtaining of said first polling request is carried out by said network layer module executing on at least one hardware processor;

said responding to said first polling request is carried out by said network layer module executing on said at least one hardware processor;

said launching of said topic server is carried out by said content listener module and said topic server module executing on said at least one hardware processor;

said obtaining of said second polling request is carried out by said network layer module and said topic server module executing on said at least one hardware processor; and

said responding to said second polling request is carried out by said topic server module executing on said at least one hardware processor.

10. A computer program product comprising a non-transitory computer readable storage medium having computer readable program code embodied therewith, said computer readable program code comprising:

computer readable program code configured to obtain, at a network layer of a physical server, from a client, during a time when updated information about a topic is unavailable, a first polling request for information about said topic, said first polling request being directed to a particular port;

computer readable program code configured to respond to said first polling request, from said network layer of said physical server, with a connection refused message;

computer readable program code configured to, in response to updated information about said topic becoming available, launch a topic server on said physical server and opening said particular port;

computer readable program code configured to obtain, at said particular port on said topic server on said physical server, a second polling request for information about said topic, from said client, said second polling request being directed to said particular port; and

computer readable program code configured to respond to said second polling request, from said topic server on said physical server, with a message to said client including said updated information about said topic.

11. The computer program product of claim 10, wherein said second polling request is obtained during a first predetermined time after said updated information about said topic is available.

12. The computer program product of claim 11, further comprising computer readable program code configured to close said particular port after a second predetermined time has elapsed.

13. The computer program product of claim 12, further comprising computer readable program code configured to, as part of an initial registration process, advise said client of said particular port.

14. The computer program product of claim 13, further comprising computer readable program code configured to, as part of said initial registration process, advise said client of a polling time interval.

15. The computer program product of claim 14, wherein, in said computer readable program code configured to advise said client of said polling time interval, said polling time interval is no greater than said second predetermined time.

16. The computer program product of claim 14, further comprising computer readable program code configured to obtain a registration request from said client, wherein said advising of said client is in response to said registration request.

17. The computer program product of claim 16, further comprising:

computer readable program code configured to establish interconnections with a plurality of content providers; and

computer readable program code configured to monitor for updated content from said content providers;

wherein said launching of said topic server and said opening of said particular port are in response to said updated content being available from a corresponding one of said content providers.

18. An apparatus comprising:

a memory; and

at least one processor, coupled to said memory, and operative to;

obtain, at a network layer of a physical server, from a client, during a time when updated information about a topic is unavailable, a first polling request for information about said topic, said first polling request being directed to a particular port;

respond to said first polling request, from said network layer of said physical server, with a connection refused message;

in response to updated information about said topic becoming available, launch a topic server on said physical server and opening said particular port;

obtain, at said particular port on said topic server on said physical server, a second polling request for information about said topic, from said client, said second polling request being directed to said particular port; and

respond to said second polling request, from said topic server on said physical server, with a message to said client including said updated information about said topic.

19. The apparatus of claim 18, wherein said second polling request is obtained during a first predetermined time after said updated information about said topic is available.

20. The apparatus of claim 19, wherein said at least one processor is further operative to close said particular port after a second predetermined time has elapsed.

21. The apparatus of claim 20, wherein said at least one processor is further operative to, as part of an initial registration process, advise said client of said particular port.

22. The apparatus of claim 21, wherein said at least one processor is further operative to, as part of said initial registration process, advise said client of a polling time interval.

23. The apparatus of claim 22, wherein said polling time interval, said polling time interval is no greater than said second predetermined time.

24. The apparatus of claim 22, wherein said at least one processor is further operative to obtain a registration request from said client, wherein said advising of said client is in response to said registration request.

25. The apparatus of claim 24, wherein said at least one processor is further operative:

to establish interconnections with a plurality of content providers; and

to monitor for updated content from said content providers;

wherein said launching of said topic server and said opening of said particular port are in response to said updated content being available from a corresponding one of said content providers.

26. The apparatus of claim 18, further comprising a plurality of distinct software modules, each of the distinct software modules being embodied on a non-transitory computer-readable storage medium, and wherein the distinct software modules comprise a network layer module, a topic server module, and a content listener module;

wherein;

said at least one processor is operative to obtain said first polling request by executing said network layer module;

said at least one processor is operative to respond to said first polling request by executing said network layer module;

said at least one processor is operative to launch said topic server by executing said content listener module and said topic server module;

said at least one processor is operative to obtain said second polling request by executing said network layer module and said topic server module; and

said at least one processor is operative to respond to said second polling request by executing said topic server module.

27. An apparatus comprising:

means for obtaining, at a network layer of a physical server, from a client, during a time when updated information about a topic is unavailable, a first polling request for information about said topic, said first polling request being directed to a particular port;

means for responding to said first polling request, from said network layer of said physical server, with a connection refused message;

means for, in response to updated information about said topic becoming available, launching a topic server on said physical server and opening said particular port;

means for obtaining, at said particular port on said topic server on said physical server, a second polling request for information about said topic, from said client, said second polling request being directed to said particular port; and

means for responding to said second polling request, from said topic server on said physical server, with a message to said client including said updated information about said topic.