diff options
Diffstat (limited to 'ot_http.c')
-rw-r--r-- | ot_http.c | 6 |
1 files changed, 0 insertions, 6 deletions
@@ -144,8 +144,6 @@ ssize_t http_sendiovecdata( const int64 sock, struct ot_workstruct *ws, int iove | |||
144 | cookie->flag &= ~STRUCT_HTTP_FLAG_WAITINGFORTASK; | 144 | cookie->flag &= ~STRUCT_HTTP_FLAG_WAITINGFORTASK; |
145 | } | 145 | } |
146 | 146 | ||
147 | fprintf(stderr, "http_sendiovecdata sending %d iovec entries found cookie->batch == %p\n", iovec_entries, cookie->batch); | ||
148 | |||
149 | if( iovec_entries ) { | 147 | if( iovec_entries ) { |
150 | 148 | ||
151 | if( cookie->flag & STRUCT_HTTP_FLAG_GZIP ) | 149 | if( cookie->flag & STRUCT_HTTP_FLAG_GZIP ) |
@@ -184,7 +182,6 @@ fprintf(stderr, "http_sendiovecdata sending %d iovec entries found cookie->batch | |||
184 | for( i=0; i<iovec_entries; ++i ) { | 182 | for( i=0; i<iovec_entries; ++i ) { |
185 | /* If the current batch's limit is reached, try to reallocate a new batch to work on */ | 183 | /* If the current batch's limit is reached, try to reallocate a new batch to work on */ |
186 | if( current->bytesleft > OT_BATCH_LIMIT ) { | 184 | if( current->bytesleft > OT_BATCH_LIMIT ) { |
187 | fprintf(stderr, "http_sendiovecdata found batch above limit: %llu\n", current->bytesleft); | ||
188 | io_batch * new_batch = realloc( cookie->batch, (cookie->batches + 1) * sizeof(io_batch) ); | 185 | io_batch * new_batch = realloc( cookie->batch, (cookie->batches + 1) * sizeof(io_batch) ); |
189 | if( new_batch ) { | 186 | if( new_batch ) { |
190 | cookie->batch = new_batch; | 187 | cookie->batch = new_batch; |
@@ -192,7 +189,6 @@ fprintf(stderr, "http_sendiovecdata found batch above limit: %llu\n", current->b | |||
192 | iob_init_autofree(current ,0); | 189 | iob_init_autofree(current ,0); |
193 | } | 190 | } |
194 | } | 191 | } |
195 | fprintf(stderr, "http_sendiovecdata calling iob_addbuf_free with %zd\n", iovector[i].iov_len); | ||
196 | iob_addbuf_free( current, iovector[i].iov_base, iovector[i].iov_len ); | 192 | iob_addbuf_free( current, iovector[i].iov_base, iovector[i].iov_len ); |
197 | } | 193 | } |
198 | free( iovector ); | 194 | free( iovector ); |
@@ -201,7 +197,6 @@ fprintf(stderr, "http_sendiovecdata calling iob_addbuf_free with %zd\n", iovecto | |||
201 | } | 197 | } |
202 | 198 | ||
203 | if ((cookie->flag & STRUCT_HTTP_FLAG_CHUNKED_IN_TRANSFER) && cookie->batch && !is_partial) { | 199 | if ((cookie->flag & STRUCT_HTTP_FLAG_CHUNKED_IN_TRANSFER) && cookie->batch && !is_partial) { |
204 | fprintf(stderr, "http_sendiovecdata adds a terminating 0 size buffer to batch\n"); | ||
205 | current = cookie->batch + cookie->batches - 1; | 200 | current = cookie->batch + cookie->batches - 1; |
206 | iob_addbuf(current, "0\r\n\r\n", 5); | 201 | iob_addbuf(current, "0\r\n\r\n", 5); |
207 | cookie->flag &= ~STRUCT_HTTP_FLAG_CHUNKED_IN_TRANSFER; | 202 | cookie->flag &= ~STRUCT_HTTP_FLAG_CHUNKED_IN_TRANSFER; |
@@ -210,7 +205,6 @@ fprintf(stderr, "http_sendiovecdata adds a terminating 0 size buffer to batch\n" | |||
210 | /* writeable sockets timeout after 10 minutes */ | 205 | /* writeable sockets timeout after 10 minutes */ |
211 | taia_now( &t ); taia_addsec( &t, &t, OT_CLIENT_TIMEOUT_SEND ); | 206 | taia_now( &t ); taia_addsec( &t, &t, OT_CLIENT_TIMEOUT_SEND ); |
212 | io_timeout( sock, t ); | 207 | io_timeout( sock, t ); |
213 | fprintf (stderr, "http_sendiovecdata marks socket %lld as wantwrite\n", sock); | ||
214 | io_wantwrite( sock ); | 208 | io_wantwrite( sock ); |
215 | return 0; | 209 | return 0; |
216 | } | 210 | } |