RESOURCE SERVER PROVIDING A RAPIDLY CHANGING RESOURCE

• US 20160006673A1
• Filed: 07/02/2015
• Published: 01/07/2016
• Est. Priority Date: 07/03/2014
• Status: Active Grant

• Current Assignee: SAS Institute Incorporated
• Original Assignee: SAS Institute Incorporated
• Inventors: Baulier, Gerald Donald, Thomas, Michael
• Granted Patent: US 9,369,406 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 3/0608 Saving storage space on storage systems
• CPC Class Codes: G06F 3/0619 in relation to data integrity, e.g. data losses, bit errors
• CPC Class Codes: G06F 3/0661 Format or protocol conversion arrangements
• CPC Class Codes: G06F 3/067 Distributed or networked storage systems, e.g. storage area networks [SAN], network attached storage [NAS]
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals
• CPC Class Codes: G06F 9/544 Buffers; Shared memory; Pipes
• CPC Class Codes: H04L 41/509 wherein the managed service relates to media content delivery, e.g. audio, video or TV
• CPC Class Codes: H04L 47/70 Admission control; Resource allocation
• CPC Class Codes: H04L 47/827 Aggregation of resource allocation or reservation requests
• CPC Class Codes: H04L 67/5682 Policies or rules for updating, deleting or replacing the stored data
• CPC Class Codes: H04L 69/03 Protocol definition or specification protocol conformance testing H04L1/244

Abstract

A computer-readable medium is provided that causes a computing device to serve data resources. A nozzle is instantiated for a resource based on a media type associated with both the nozzle and the resource and starts a subscriber thread and a rendering thread. The subscriber thread receives a block of streamed data from a publishing device, stores the block in a queue, and receives a request to drain the queue. The block includes a unique identifier of an event associated with the media type. The rendering thread reads the block from the queue, renders the block, and stores the rendered block in a pre-allocated block of memory based on the unique identifier. A reference to the pre-allocated block of memory is stored in a tree map based on the unique identifier. The instantiated nozzle sends the rendered block to a requesting event client system.

Claims

1. A non-transitory computer-readable medium having stored thereon computer-readable instructions that when executed by a computing device cause the computing device to:

instantiate a nozzle for a resource based on a media type associated with both the nozzle and the resource;

start, by the instantiated nozzle, a subscriber thread and a rendering thread;

receive, by the started subscriber thread, a block of streamed data from a publishing device, wherein the block includes a unique identifier of an event associated with the media type;

store, by the started subscriber thread, the received block in a queue;

receive, by the started subscriber thread, a request to drain the queue;

read, by the started rendering thread, the received block from the queue;

render, by the started rendering thread, the read, received block;

store, by the started rendering thread, the rendered block in a pre-allocated block of memory based on the unique identifier, wherein a reference to the pre-allocated block of memory is stored in a tree map based on the unique identifier;

receive, by the instantiated nozzle, a request for an update for the resource based on the unique identifier;

select, by the instantiated nozzle, the stored, rendered block from the tree map using the unique identifier;

read, by the instantiated nozzle, the selected block from the pre-allocated block of memory; and

send the read block to a requesting event client system.

2. The non-transitory computer-readable medium of claim 1, wherein the started subscriber thread further stores the received block in the queue in association with a change index value.

3. The non-transitory computer-readable medium of claim 2, wherein after storing the received block in the queue and before receiving the request to drain the queue, the computer-readable instructions further cause the computing device to increment, by the started subscriber thread, the change index value.

4. The non-transitory computer-readable medium of claim 2, wherein the change index value stored in the queue is further stored in the tree map in association with the pre-allocated block of memory and the unique identifier.

5. The non-transitory computer-readable medium of claim 4, wherein the change index value stored in the tree map in association with the pre-allocated block of memory and the unique identifier is updated, by the started rendering thread, on a subsequent execution of storing the rendered block in the pre-allocated block of memory based on the unique identifier.

6. The non-transitory computer-readable medium of claim 4, wherein the request includes the unique identifier.

7. The non-transitory computer-readable medium of claim 6, wherein the request further includes a value of a last change index.

8. The non-transitory computer-readable medium of claim 7, wherein the selecting the stored, rendered block from the tree map further use the value of the last change index and the change index value stored in the tree map.

9. The non-transitory computer-readable medium of claim 8, wherein the stored, rendered block is selected from the tree map when the last change index is less than the change index value stored in the tree map.

10. The non-transitory computer-readable medium of claim 1, wherein rendering the read, received block comprises converting the streamed data from a publishing device format to a requesting event client system format.

11. The non-transitory computer-readable medium of claim 1, wherein the received block is stored in a write-only queue and the received block is read from a read-only queue, and wherein the computer-readable instructions further cause the computing device to toggle, by the started subscriber thread, the write-only queue with the read-only queue in response to receiving the request to drain the queue.

12. The non-transitory computer-readable medium of claim 11, wherein the reference to the pre-allocated block of memory is stored in a write-only tree map and the stored, rendered block is selected from a read-only tree map, and wherein the computer-readable instructions further cause the computing device to toggle, by the started rendering thread, the write-only tree map with the read-only tree map.

13. The non-transitory computer-readable medium of claim 1, wherein the reference to the pre-allocated block of memory is stored in a write-only tree map and the stored, rendered block is selected from a read-only tree map, and wherein the computer-readable instructions further cause the computing device to toggle, by the started rendering thread, the write-only tree map with the read-only tree map.

14. The non-transitory computer-readable medium of claim 13, wherein the computer-readable instructions further cause the computing device to send, by the started rendering thread, the request to drain the queue after toggling the write-only tree map with the read-only tree map.

15. The non-transitory computer-readable medium of claim 13, wherein toggling the write-only tree map with the read-only tree map occurs after rendering and storing each block stored in the read-only queue.

16. The non-transitory computer-readable medium of claim 1, wherein the computer-readable instructions further cause the computing device to:

receive, by the started subscriber thread, a second block of streamed data, wherein the second block includes a second unique identifier of the event associated with the media type, wherein the second unique identifier is different from the unique identifier; and

store, by the started subscriber thread, the received second block in the queue before receiving, by the started subscriber thread, the request to drain the queue.

17. The non-transitory computer-readable medium of claim 16, wherein the computer-readable instructions further cause the computing device to:

read, by the started rendering thread, the received second block from the queue;

render, by the started rendering thread, the read, received second block; and

store, by the started rendering thread, the rendered second block in a second pre-allocated block of memory based on the second unique identifier, wherein a second reference to the second pre-allocated block of memory is stored in the tree map based on the second unique identifier before receiving, by the instantiated nozzle, the request for the update.

18. The non-transitory computer-readable medium of claim 17, wherein the computer-readable instructions further cause the computing device to:

select, by the instantiated nozzle, the stored, rendered second block from the tree map using the second unique identifier;

read, by the instantiated nozzle, the selected second block from the second pre-allocated block of memory; and

send the read second block to the requesting event client system.

19. The non-transitory computer-readable medium of claim 17, wherein the computer-readable instructions further cause the computing device to:

select, by the instantiated nozzle, the stored, rendered second block from the tree map using the second unique identifier;

read, by the instantiated nozzle, the selected second block from the second pre-allocated block of memory; and

compress, by the instantiated nozzle, the read block and the read second block in a single block;

wherein the compressed single block is sent to the requesting event client system as the read block.

20. The non-transitory computer-readable medium of claim 19, wherein a second request for a second update for the resource is received from a second requesting event client system, and the computer-readable instructions further cause the computing device to select and send the compressed single block to the second requesting event client system.

21. The non-transitory computer-readable medium of claim 1, wherein the computer-readable instructions further cause the computing device to:

receive, by the started subscriber thread, an additional block of streamed data, wherein the additional block includes the unique identifier of the event associated with the media type; and

store, by the started subscriber thread, the received additional block in the queue before receiving, by the started subscriber thread, the request to drain the queue.

22. The non-transitory computer-readable medium of claim 21, wherein the computer-readable instructions further cause the computing device to:

read, by the started rendering thread, the received additional block from the queue;

render, by the started rendering thread, the read, received additional block; and

store, by the started rendering thread, the rendered additional block in the pre-allocated block of memory based on the unique identifier, before receiving, by the instantiated nozzle, the request for the update.

23. The non-transitory computer-readable medium of claim 1, wherein the computer-readable instructions further cause the computing device to start a requestor thread, wherein the read block is sent to the requesting event client system by the started requestor thread.

24. The non-transitory computer-readable medium of claim 23, wherein after receiving the request for the update the started requestor thread is acquired from a pool of started requestor threads.

25. The non-transitory computer-readable medium of claim 23, wherein the stored, rendered block is selected from the tree map by the started requestor thread and the selected block is read from the pre-allocated block of memory by the started requestor thread.

26. The non-transitory computer-readable medium of claim 1, wherein the read block is sent to the requesting event client system when a location of the event is within a clipping region defined in the request for the update for the resource.

27. The non-transitory computer-readable medium of claim 1, wherein the block of streamed data is received from an event stream processing device that receives and processes data from an event publishing device.

28. The non-transitory computer-readable medium of claim 1, wherein the block of streamed data is received directly from an event publishing device.

29. A computing device comprising:

a processor; and

a computer-readable medium operably coupled to the processor, the computer-readable medium having computer-readable instructions stored thereon that, when executed by the processor, cause the computing device to

instantiate a nozzle for a resource based on a media type associated with both the nozzle and the resource;

start, by the instantiated nozzle, a subscriber thread and a rendering thread;

receive, by the started subscriber thread, a block of streamed data from a publishing device, wherein the block includes a unique identifier of an event associated with the media type;

store, by the started subscriber thread, the received block in a queue;

receive, by the started subscriber thread, a request to drain the queue;

read, by the started rendering thread, the received block from the queue;

render, by the started rendering thread, the read, received block;

store, by the started rendering thread, the rendered block in a pre-allocated block of memory based on the unique identifier, wherein a reference to the pre-allocated block of memory is stored in a tree map based on the unique identifier;

receive, by the instantiated nozzle, a request for an update for the resource based on the unique identifier;

select, by the instantiated nozzle, the stored, rendered block from the tree map using the unique identifier;

read, by the instantiated nozzle, the selected block from the pre-allocated block of memory; and

send the read block to a requesting event client system.

30. A method of serving data resources from a publishing system to a client system, the method comprising:

instantiating, by a computing device, a nozzle for a resource based on a media type associated with both the nozzle and the resource;

starting, by the instantiated nozzle, a subscriber thread and a rendering thread;

receiving, by the started subscriber thread, a block of streamed data from a publishing device, wherein the block includes a unique identifier of an event associated with the media type;

storing, by the started subscriber thread, the received block in a queue;

receiving, by the started subscriber thread, a request to drain the queue;

reading, by the started rendering thread, the received block from the queue;

rendering, by the started rendering thread, the read, received block;

storing, by the started rendering thread, the rendered block in a pre-allocated block of memory based on the unique identifier, wherein a reference to the pre-allocated block of memory is stored in a tree map based on the unique identifier;

receiving, by the instantiated nozzle, a request for an update for the resource based on the unique identifier;

selecting, by the instantiated nozzle, the stored, rendered block from the tree map using the unique identifier;

reading, by the instantiated nozzle, the selected block from the pre-allocated block of memory; and

sending the read block to a requesting event client system.