| 65 | } |
| 66 | |
| 67 | static int receive_chunk(context_data *ctx_data, per_session_data *pss, const void *in, size_t len) |
| 68 | { |
| 69 | websocket_chunk *chunk = ctx_data->recv_buffer.Allocate(len + sizeof(websocket_chunk)); |
| 70 | if(chunk == nullptr) |
| 71 | { |
| 72 | return 1; |
| 73 | } |
| 74 | |
| 75 | chunk->size = len; |
| 76 | chunk->read = 0; |
| 77 | chunk->addr = pss->addr; |
| 78 | mem_copy(&chunk->data[0], in, len); |
| 79 | return 0; |
| 80 | } |
| 81 | |
| 82 | static void sockaddr_to_netaddr_websocket(const sockaddr *src, socklen_t src_len, NETADDR *dst) |
| 83 | { |
no test coverage detected