… | |
… | |
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 () |