Home
last modified time | relevance | path

Searched refs:response_queue (Results 1 - 8 of 8) sorted by relevance

/third_party/skia/third_party/externals/microhttpd/src/microspdy/
H A Dsession.c424 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; in SPDYF_handler_write_syn_reply() local
425 struct SPDYF_Stream *stream = response_queue->stream; in SPDYF_handler_write_syn_reply()
435 memcpy(&control_frame, response_queue->control_frame, sizeof(control_frame)); in SPDYF_handler_write_syn_reply()
438 response_queue->data, in SPDYF_handler_write_syn_reply()
439 response_queue->data_size, in SPDYF_handler_write_syn_reply()
457 SPDYF_ASSERT(used_data == response_queue->data_size, "not everything was used by zlib"); in SPDYF_handler_write_syn_reply()
519 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; in SPDYF_handler_write_goaway() local
526 memcpy(&control_frame, response_queue->control_frame, sizeof(control_frame)); in SPDYF_handler_write_goaway()
555 memcpy(session->write_buffer + session->write_buffer_offset, response_queue->data, 4); in SPDYF_handler_write_goaway()
558 //free(response_queue in SPDYF_handler_write_goaway()
572 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; SPDYF_handler_write_data() local
744 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; SPDYF_handler_write_rst_stream() local
789 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; SPDYF_handler_write_window_update() local
987 struct SPDYF_Response_Queue *response_queue; SPDYF_session_write() local
1578 struct SPDYF_Response_Queue *response_queue; SPDYF_session_destroy() local
[all...]
H A Dstream.c126 SPDYF_stream_set_flags_on_write(struct SPDYF_Response_Queue *response_queue) in SPDYF_stream_set_flags_on_write() argument
128 struct SPDYF_Stream * stream = response_queue->stream; in SPDYF_stream_set_flags_on_write()
130 if(NULL != response_queue->data_frame) in SPDYF_stream_set_flags_on_write()
132 stream->is_out_closed = (bool)(response_queue->data_frame->flags & SPDY_DATA_FLAG_FIN); in SPDYF_stream_set_flags_on_write()
134 else if(NULL != response_queue->control_frame) in SPDYF_stream_set_flags_on_write()
136 switch(response_queue->control_frame->type) in SPDYF_stream_set_flags_on_write()
139 stream->is_out_closed = (bool)(response_queue->control_frame->flags & SPDY_SYN_REPLY_FLAG_FIN); in SPDYF_stream_set_flags_on_write()
H A Dapplicationlayer.c203 * @param response_queue the object which is being handled
213 struct SPDYF_Response_Queue *response_queue, in spdy_handler_response_queue_result()
219 SPDYF_ASSERT( ( (NULL == response_queue->data_frame) && in spdy_handler_response_queue_result()
220 (NULL != response_queue->control_frame) ) || in spdy_handler_response_queue_result()
221 ( (NULL != response_queue->data_frame) && in spdy_handler_response_queue_result()
222 (NULL == response_queue->control_frame) ), in spdy_handler_response_queue_result()
225 streamopened = !response_queue->stream->is_out_closed; in spdy_handler_response_queue_result()
227 response_queue->rrcb(response_queue->rrcb_cls, response_queue in spdy_handler_response_queue_result()
212 spdy_handler_response_queue_result(void * cls, struct SPDYF_Response_Queue *response_queue, enum SPDY_RESPONSE_RESULT status) spdy_handler_response_queue_result() argument
[all...]
H A Dstructures.c435 SPDYF_response_queue_destroy(struct SPDYF_Response_Queue *response_queue) in SPDYF_response_queue_destroy() argument
439 if(!response_queue->is_data in SPDYF_response_queue_destroy()
440 && (SPDY_CONTROL_FRAME_TYPES_RST_STREAM == response_queue->control_frame->type in SPDYF_response_queue_destroy()
441 || SPDY_CONTROL_FRAME_TYPES_GOAWAY == response_queue->control_frame->type)) in SPDYF_response_queue_destroy()
443 free(response_queue->data); in SPDYF_response_queue_destroy()
445 if(response_queue->is_data) in SPDYF_response_queue_destroy()
446 free(response_queue->data_frame); in SPDYF_response_queue_destroy()
448 free(response_queue->control_frame); in SPDYF_response_queue_destroy()
450 free(response_queue); in SPDYF_response_queue_destroy()
H A Dstream.h60 * @param response_queue sent for this stream
63 SPDYF_stream_set_flags_on_write(struct SPDYF_Response_Queue *response_queue);
H A Dstructures.h361 * @param response_queue the SPDYF_Response_Queue structure which will
371 struct SPDYF_Response_Queue *response_queue,
1194 * @param response_queue to destroy
1197 SPDYF_response_queue_destroy(struct SPDYF_Response_Queue *response_queue);
/third_party/python/Lib/idlelib/
H A Drun.py165 rpc.response_queue.put((seq, ret))
179 rpc.response_queue.put((seq, None))
H A Drpc.py125 response_queue = queue.Queue(0) variable
409 taken from response_queue and sent across the link with the associated
413 sequence number in the response_queue.
423 qmsg = response_queue.get(0)

Completed in 6 milliseconds