Lines Matching refs:tcp_byte_count
1182 c->tcp_byte_count = 0;
1530 c->tcp_byte_count = 0;
1542 c->tcp_byte_count = 0;
1573 c->tcp_byte_count = 0;
1796 if(c->tcp_byte_count < current_read_size) {
1799 c->buffer, c->tcp_byte_count),
1801 c->tcp_byte_count)) <= 0) {
1830 c->tcp_byte_count += r;
1832 if(c->tcp_byte_count != current_read_size) return 1;
1864 } else if(c->tcp_byte_count < current_read_size) {
1867 c->buffer, c->tcp_byte_count),
1869 c->tcp_byte_count)) <= 0) {
1898 c->tcp_byte_count += r;
1900 if(c->tcp_byte_count != current_read_size) return 1;
1922 c->tcp_byte_count = 0;
1925 if(c->tcp_byte_count < sizeof(uint16_t)) {
1929 c->tcp_byte_count), (int)(sizeof(uint16_t) -
1930 c->tcp_byte_count))) <= 0) {
1958 c->tcp_byte_count += r;
1959 if(c->tcp_byte_count < sizeof(uint16_t))
1972 sldns_buffer_skip(c->buffer, (ssize_t)(c->tcp_byte_count-sizeof(uint16_t)));
2034 if((c->tcp_write_and_read?c->tcp_write_byte_count:c->tcp_byte_count) < sizeof(uint16_t)) {
2064 r = SSL_write(c->ssl, (void*)(buf+c->tcp_byte_count),
2067 - c->tcp_byte_count));
2070 (void*)(((uint8_t*)&len)+c->tcp_byte_count),
2071 (int)(sizeof(uint16_t)-c->tcp_byte_count));
2104 c->tcp_byte_count += r;
2105 if(c->tcp_byte_count < sizeof(uint16_t))
2107 sldns_buffer_set_position(c->buffer, c->tcp_byte_count -
2220 if(c->tcp_byte_count < current_read_size) {
2222 c->tcp_byte_count),
2223 current_read_size-c->tcp_byte_count, MSG_DONTWAIT);
2231 c->tcp_byte_count += r;
2233 if(c->tcp_byte_count != current_read_size) return 1;
2265 } else if(c->tcp_byte_count < current_read_size) {
2267 c->tcp_byte_count),
2268 current_read_size-c->tcp_byte_count, MSG_DONTWAIT);
2276 c->tcp_byte_count += r;
2278 if(c->tcp_byte_count != current_read_size) return 1;
2300 c->tcp_byte_count = 0;
2304 if(c->tcp_byte_count < sizeof(uint16_t)) {
2306 r = recv(fd,(void*)sldns_buffer_at(c->buffer,c->tcp_byte_count),
2307 sizeof(uint16_t)-c->tcp_byte_count, MSG_DONTWAIT);
2316 c->tcp_byte_count += r;
2317 if(c->tcp_byte_count != sizeof(uint16_t))
2450 …if(((!c->tcp_write_and_read && c->tcp_byte_count == 0) || (c->tcp_write_and_read && c->tcp_write_b…
2513 iov[0].iov_base = (uint8_t*)&len + c->tcp_byte_count;
2514 iov[0].iov_len = sizeof(uint16_t) - c->tcp_byte_count;
2582 c->tcp_byte_count += r;
2583 if(c->tcp_byte_count < sizeof(uint16_t))
2585 sldns_buffer_set_position(buffer, c->tcp_byte_count -
2596 if((c->tcp_write_and_read?c->tcp_write_byte_count:c->tcp_byte_count) < sizeof(uint16_t)) {
2606 iov[0].iov_base = (uint8_t*)&len + c->tcp_byte_count;
2607 iov[0].iov_len = sizeof(uint16_t) - c->tcp_byte_count;
2618 r = send(fd, (void*)(((uint8_t*)&len)+c->tcp_byte_count),
2619 sizeof(uint16_t)-c->tcp_byte_count, 0);
2667 c->tcp_byte_count += r;
2668 if(c->tcp_byte_count < sizeof(uint16_t))
2670 sldns_buffer_set_position(buffer, c->tcp_byte_count -
3049 c->tcp_byte_count = (size_t)atoi(line+16);
3051 c->tcp_byte_count = 0;
3080 if(line[0] == 0 && c->tcp_byte_count == 0) {
3105 c->tcp_byte_count = (size_t)strtol(line, &end, 16);
3112 if(c->tcp_byte_count == 0) {
3132 if(c->tcp_byte_count <= got_now) {
3144 if(remainbufferlen+got_now >= c->tcp_byte_count ||
3155 c->tcp_byte_count -= got_now;
3175 …tp_stored %d, buffer pos %d, buffer limit %d", (int)got_now, (int)c->tcp_byte_count, (int)c->http_…
3176 if(c->tcp_byte_count <= got_now) {
3183 sldns_buffer_skip(c->buffer, (ssize_t)c->tcp_byte_count);
3215 c->tcp_byte_count -= got_now;
3221 if(remainbufferlen >= c->tcp_byte_count ||
3856 c->tcp_byte_count = 0;
3960 c->tcp_byte_count = 0;
4024 c->tcp_byte_count = 0;
4100 c->tcp_byte_count = 0;
4199 c->tcp_byte_count = 0;
4312 c->tcp_byte_count = 0;
4412 c->tcp_byte_count = 0;
4480 c->tcp_byte_count = 0;
4550 c->tcp_byte_count = 0;
4613 c->tcp_byte_count = 0;