Lines Matching refs:recv_buf
275 ctx->recv_buf.buf = wreq->tmp_buf; in websocket_connect()
276 ctx->recv_buf.size = wreq->tmp_buf_len; in websocket_connect()
319 req.recv_buf = wreq->tmp_buf; in websocket_connect()
390 ctx->recv_buf.count = 0; in websocket_connect()
790 if (parsed_count >= ctx->recv_buf.count) { in websocket_parse()
794 data = ctx->recv_buf.buf[parsed_count++]; in websocket_parse()
868 size_t remaining_in_recv_buf = ctx->recv_buf.count - parsed_count; in websocket_parse()
878 memcpy(&payload->buf[payload->count], &ctx->recv_buf.buf[parsed_count], in websocket_parse()
978 if (ctx->recv_buf.count == 0) { in websocket_recv_msg()
980 size_t input_len = MIN(ctx->recv_buf.size, in websocket_recv_msg()
984 memcpy(ctx->recv_buf.buf, in websocket_recv_msg()
997 ret = zsock_recv(ctx->real_sock, ctx->recv_buf.buf, in websocket_recv_msg()
998 ctx->recv_buf.size, ZSOCK_MSG_DONTWAIT); in websocket_recv_msg()
1018 ctx->recv_buf.count = ret; in websocket_recv_msg()
1038 size_t left = ctx->recv_buf.count - parsed_count; in websocket_recv_msg()
1041 memmove(ctx->recv_buf.buf, &ctx->recv_buf.buf[parsed_count], left); in websocket_recv_msg()
1043 ctx->recv_buf.count = left; in websocket_recv_msg()
1047 ctx->recv_buf.count -= parsed_count; in websocket_recv_msg()
1164 int websocket_register(int sock, uint8_t *recv_buf, size_t recv_buf_len) in websocket_register() argument
1185 ctx->recv_buf.buf = recv_buf; in websocket_register()
1186 ctx->recv_buf.size = recv_buf_len; in websocket_register()
1201 ctx->recv_buf.count = 0; in websocket_register()