| … | |
… | |
| 47 | #include <arpa/inet.h> |
47 | #include <arpa/inet.h> |
| 48 | |
48 | |
| 49 | #include <loader.h> |
49 | #include <loader.h> |
| 50 | |
50 | |
| 51 | #define MAX_QUEUE_DEPTH 500 //TODO |
51 | #define MAX_QUEUE_DEPTH 500 //TODO |
| 52 | #define MAX_QUEUE_BACKLOG 2 //TODO |
52 | #define MAX_QUEUE_BACKLOG 5. //TODO |
| 53 | |
53 | |
| 54 | void |
54 | void |
| 55 | client::reset_state () |
55 | client::reset_state () |
| 56 | { |
56 | { |
| 57 | if (!pl) |
57 | if (!pl) |
| … | |
… | |
| 77 | reset_state (); |
77 | reset_state (); |
| 78 | send_packet_printf ("drawinfo %d too many commands in queue, ignoring.", NDI_RED); |
78 | send_packet_printf ("drawinfo %d too many commands in queue, ignoring.", NDI_RED); |
| 79 | } |
79 | } |
| 80 | else |
80 | else |
| 81 | cmd_queue.push_back (command ( |
81 | cmd_queue.push_back (command ( |
| 82 | stamp, handler, (char *)salloc (datalen, data), datalen |
82 | stamp, handler, (char *)salloc (datalen + 1, data), datalen |
| 83 | )); |
83 | )); |
| 84 | } |
84 | } |
| 85 | |
85 | |
| 86 | bool |
86 | bool |
| 87 | client::handle_command () |
87 | client::handle_command () |
