Lines Matching refs:stream_id
43 unsigned int stream_id; /* http2 protocol stream id */ member
159 unsigned int stream_id, in http2_stream_node_search() argument
171 if (search_node->stream_id == stream_id) { in http2_stream_node_search()
177 h2_debug("stream node not exist, stream_id = %d", stream_id); in http2_stream_node_search()
181 static void on_stream_header(int32_t stream_id, int cat, const uint8_t *name, in on_stream_header() argument
192 http2_stream_node_search(g_stream_handle, stream_id, &node); in on_stream_header()
242 g_stream_handle->cbs->on_stream_header_cb(stream_id, channel_id, cat, in on_stream_header()
248 static void on_stream_chunk_recv(int32_t stream_id, const uint8_t *data, in on_stream_chunk_recv() argument
258 http2_stream_node_search(g_stream_handle, stream_id, &node); in on_stream_chunk_recv()
266 stream_id, channel_id, data, len, flags, user_data); in on_stream_chunk_recv()
270 static void on_stream_close(int32_t stream_id, uint32_t error_code) in on_stream_close() argument
279 http2_stream_node_search(g_stream_handle, stream_id, &node); in on_stream_close()
285 g_stream_handle->cbs->on_stream_close_cb(stream_id, channel_id, in on_stream_close()
290 static void on_stream_frame_send(int32_t stream_id, int type, uint8_t flags) in on_stream_frame_send() argument
299 http2_stream_node_search(g_stream_handle, stream_id, &node); in on_stream_frame_send()
305 g_stream_handle->cbs->on_stream_frame_send_cb(stream_id, channel_id, in on_stream_frame_send()
310 static void on_stream_frame_recv(int32_t stream_id, int type, uint8_t flags) in on_stream_frame_recv() argument
318 http2_stream_node_search(g_stream_handle, stream_id, &node); in on_stream_frame_recv()
325 g_stream_handle->cbs->on_stream_frame_recv_cb(stream_id, channel_id, in on_stream_frame_recv()
439 node->stream_id = id; in http2_stream_node_insert()
468 if (id == search_node->stream_id) { in http2_stream_node_remove()
637 h2_data.stream_id = 0; in IOT_HTTP2_Stream_Open()
641 http2_stream_node_insert(handle, h2_data.stream_id, info->user_data, in IOT_HTTP2_Stream_Open()
665 http2_stream_node_remove(handle, node->stream_id); in IOT_HTTP2_Stream_Open()
673 http2_stream_node_remove(handle, node->stream_id); in IOT_HTTP2_Stream_Open()
765 return h2_data.stream_id; in IOT_HTTP2_Stream_Send_Message()
853 http2_stream_node_insert(handle, h2_data.stream_id, info->user_data, in IOT_HTTP2_Stream_Send()
873 info->h2_stream_id = h2_data.stream_id; in IOT_HTTP2_Stream_Send()
881 h2_data.stream_id = info->h2_stream_id; in IOT_HTTP2_Stream_Send()
901 http2_stream_node_search(handle, h2_data.stream_id, &node); in IOT_HTTP2_Stream_Send()
912 h2_data.stream_id); in IOT_HTTP2_Stream_Send()
914 http2_stream_node_remove(handle, node->stream_id); in IOT_HTTP2_Stream_Send()
976 h2_data.stream_id = 0; in IOT_HTTP2_Stream_Query()
980 http2_stream_node_insert(handle, h2_data.stream_id, info->user_data, in IOT_HTTP2_Stream_Query()
1004 http2_stream_node_remove(handle, node->stream_id); in IOT_HTTP2_Stream_Query()
1021 char *stream_id = info->channel_id; in IOT_HTTP2_FS_Close() local
1022 int len = strlen(stream_id); in IOT_HTTP2_FS_Close()
1070 h2_data.stream_id = 0; in IOT_HTTP2_FS_Close()
1077 http2_stream_node_insert(handle, h2_data.stream_id, info->user_data, in IOT_HTTP2_FS_Close()
1109 if (info->h2_stream_id == node->stream_id) { in IOT_HTTP2_FS_Close()
1111 node->stream_id); in IOT_HTTP2_FS_Close()
1118 if ((node->channel_id != NULL) && (stream_id != NULL) && in IOT_HTTP2_FS_Close()
1120 !strncmp(node->channel_id, stream_id, len))) { in IOT_HTTP2_FS_Close()
1142 char *stream_id = info->channel_id; in IOT_HTTP2_Stream_Close() local
1143 int len = strlen(stream_id); in IOT_HTTP2_Stream_Close()
1168 h2_data.stream_id = 0; in IOT_HTTP2_Stream_Close()
1187 if (info->h2_stream_id == node->stream_id) { in IOT_HTTP2_Stream_Close()
1189 node->stream_id); in IOT_HTTP2_Stream_Close()
1196 if ((node->channel_id != NULL) && (stream_id != NULL) && in IOT_HTTP2_Stream_Close()
1198 !strncmp(node->channel_id, stream_id, len))) { in IOT_HTTP2_Stream_Close()