| /external/libmicrohttpd/src/microspdy/ |
| stream.h | 60 * @param response_queue sent for this stream
63 SPDYF_stream_set_flags_on_write(struct SPDYF_Response_Queue *response_queue);
|
| stream.c | 126 SPDYF_stream_set_flags_on_write(struct SPDYF_Response_Queue *response_queue)
128 struct SPDYF_Stream * stream = response_queue->stream;
130 if(NULL != response_queue->data_frame)
132 stream->is_out_closed = (bool)(response_queue->data_frame->flags & SPDY_DATA_FLAG_FIN);
134 else if(NULL != response_queue->control_frame)
136 switch(response_queue->control_frame->type)
139 stream->is_out_closed = (bool)(response_queue->control_frame->flags & SPDY_SYN_REPLY_FLAG_FIN);
|
| session.c | 424 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; local
425 struct SPDYF_Stream *stream = response_queue->stream;
435 memcpy(&control_frame, response_queue->control_frame, sizeof(control_frame));
438 response_queue->data,
439 response_queue->data_size,
457 SPDYF_ASSERT(used_data == response_queue->data_size, "not everything was used by zlib");
519 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; local
526 memcpy(&control_frame, response_queue->control_frame, sizeof(control_frame));
555 memcpy(session->write_buffer + session->write_buffer_offset, response_queue->data, 4);
558 //free(response_queue->data)
572 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; local
744 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; local
789 struct SPDYF_Response_Queue *response_queue = session->response_queue_head; local
987 struct SPDYF_Response_Queue *response_queue; local
1578 struct SPDYF_Response_Queue *response_queue; local
[all...] |
| applicationlayer.c | 203 * @param response_queue the object which is being handled
213 struct SPDYF_Response_Queue *response_queue,
219 SPDYF_ASSERT( ( (NULL == response_queue->data_frame) &&
220 (NULL != response_queue->control_frame) ) ||
221 ( (NULL != response_queue->data_frame) &&
222 (NULL == response_queue->control_frame) ),
225 streamopened = !response_queue->stream->is_out_closed;
227 response_queue->rrcb(response_queue->rrcb_cls, response_queue->response, request, status, streamopened)
[all...] |
| structures.c | 435 SPDYF_response_queue_destroy(struct SPDYF_Response_Queue *response_queue)
439 if(!response_queue->is_data
440 && (SPDY_CONTROL_FRAME_TYPES_RST_STREAM == response_queue->control_frame->type
441 || SPDY_CONTROL_FRAME_TYPES_GOAWAY == response_queue->control_frame->type))
443 free(response_queue->data);
445 if(response_queue->is_data)
446 free(response_queue->data_frame);
448 free(response_queue->control_frame);
450 free(response_queue);
|
| structures.h | 361 * @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);
|
| /external/autotest/client/cros/cellular/mbim_compliance/ |
| mbim_channel_endpoint.py | 55 response_queue,
67 @param response_queue: A process safe queue where we enqueue
78 self._response_queue = response_queue
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/idlelib/ |
| run.py | 101 rpc.response_queue.put((seq, ret))
112 rpc.response_queue.put((seq, None))
|
| rpc.py | 121 response_queue = Queue.Queue(0) variable
401 taken from response_queue and sent across the link with the associated
405 sequence number in the response_queue.
415 qmsg = response_queue.get(0)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/idlelib/ |
| run.py | 101 rpc.response_queue.put((seq, ret))
112 rpc.response_queue.put((seq, None))
|
| rpc.py | 121 response_queue = Queue.Queue(0) variable
401 taken from response_queue and sent across the link with the associated
405 sequence number in the response_queue.
415 qmsg = response_queue.get(0)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/idlelib/ |
| run.py | 101 rpc.response_queue.put((seq, ret))
112 rpc.response_queue.put((seq, None))
|
| rpc.py | 121 response_queue = Queue.Queue(0) variable
401 taken from response_queue and sent across the link with the associated
405 sequence number in the response_queue.
415 qmsg = response_queue.get(0)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/idlelib/ |
| run.py | 101 rpc.response_queue.put((seq, ret))
112 rpc.response_queue.put((seq, None))
|
| rpc.py | 121 response_queue = Queue.Queue(0) variable
401 taken from response_queue and sent across the link with the associated
405 sequence number in the response_queue.
415 qmsg = response_queue.get(0)
|
| /external/python/cpython2/Lib/idlelib/ |
| run.py | 116 rpc.response_queue.put((seq, ret))
128 rpc.response_queue.put((seq, None))
|
| rpc.py | 121 response_queue = Queue.Queue(0) variable
398 taken from response_queue and sent across the link with the associated
402 sequence number in the response_queue.
412 qmsg = response_queue.get(0)
|
| /external/python/cpython3/Lib/idlelib/ |
| rpc.py | 122 response_queue = queue.Queue(0) variable
406 taken from response_queue and sent across the link with the associated
410 sequence number in the response_queue.
420 qmsg = response_queue.get(0)
|
| run.py | 143 rpc.response_queue.put((seq, ret))
155 rpc.response_queue.put((seq, None))
|
