diff options
Diffstat (limited to 'src/microspdy/stream.c')
-rw-r--r-- | src/microspdy/stream.c | 19 |
1 files changed, 18 insertions, 1 deletions
diff --git a/src/microspdy/stream.c b/src/microspdy/stream.c index 97fdd6c8..336672ac 100644 --- a/src/microspdy/stream.c +++ b/src/microspdy/stream.c | |||
@@ -122,7 +122,7 @@ SPDYF_stream_destroy(struct SPDYF_Stream *stream) | |||
122 | 122 | ||
123 | 123 | ||
124 | void | 124 | void |
125 | SPDYF_stream_set_flags(struct SPDYF_Response_Queue *response_queue) | 125 | SPDYF_stream_set_flags_on_write(struct SPDYF_Response_Queue *response_queue) |
126 | { | 126 | { |
127 | struct SPDYF_Stream * stream = response_queue->stream; | 127 | struct SPDYF_Stream * stream = response_queue->stream; |
128 | 128 | ||
@@ -149,3 +149,20 @@ SPDYF_stream_set_flags(struct SPDYF_Response_Queue *response_queue) | |||
149 | } | 149 | } |
150 | } | 150 | } |
151 | } | 151 | } |
152 | |||
153 | |||
154 | //TODO add function *on_read | ||
155 | |||
156 | |||
157 | struct SPDYF_Stream * | ||
158 | SPDYF_stream_find(uint32_t stream_id, struct SPDY_Session * session) | ||
159 | { | ||
160 | struct SPDYF_Stream * stream = session->streams_head; | ||
161 | |||
162 | while(NULL != stream && stream_id != stream->stream_id) | ||
163 | { | ||
164 | stream = stream->next; | ||
165 | } | ||
166 | |||
167 | return stream; | ||
168 | } | ||