255 	size_t				bytes_transmitted;  member
4200 	if (data->bytes_transmitted == 0 && data->query_needs_reset) {  in handle_tcp_reading()
4219 			if(data->bytes_transmitted < current_read_size) {  in handle_tcp_reading()
4222 						data->bytes_transmitted),  in handle_tcp_reading()
4223 					current_read_size - data->bytes_transmitted,  in handle_tcp_reading()
4226 				data->bytes_transmitted += received;  in handle_tcp_reading()
4228 				if(data->bytes_transmitted != current_read_size)  in handle_tcp_reading()
4255 			} else if(data->bytes_transmitted < current_read_size) {  in handle_tcp_reading()
4258 						data->bytes_transmitted),  in handle_tcp_reading()
4259 					current_read_size - data->bytes_transmitted,  in handle_tcp_reading()
4262 				data->bytes_transmitted += received;  in handle_tcp_reading()
4264 				if(data->bytes_transmitted != current_read_size)  in handle_tcp_reading()
4285 		data->bytes_transmitted = 0;  in handle_tcp_reading()
4291 	if (data->bytes_transmitted < sizeof(uint16_t)) {  in handle_tcp_reading()
4293 			(char*) &data->query->tcplen + data->bytes_transmitted,  in handle_tcp_reading()
4294 			sizeof(uint16_t) - data->bytes_transmitted, &received))  in handle_tcp_reading()
4296 		data->bytes_transmitted += received;  in handle_tcp_reading()
4297 		if (data->bytes_transmitted < sizeof(uint16_t)) {  in handle_tcp_reading()
4304 		assert(data->bytes_transmitted == sizeof(uint16_t));  in handle_tcp_reading()
4337 	data->bytes_transmitted += received;  in handle_tcp_reading()
4435 	data->bytes_transmitted = 0;  in handle_tcp_reading()
4471 	if (data->bytes_transmitted < sizeof(q->tcplen)) {  in handle_tcp_writing()
4476 		iov[0].iov_base = (uint8_t*)&n_tcplen + data->bytes_transmitted;  in handle_tcp_writing()
4477 		iov[0].iov_len = sizeof(n_tcplen) - data->bytes_transmitted;   in handle_tcp_writing()
4483 			     (const char *) &n_tcplen + data->bytes_transmitted,  in handle_tcp_writing()
4484 			     sizeof(n_tcplen) - data->bytes_transmitted);  in handle_tcp_writing()
4506 		data->bytes_transmitted += sent;  in handle_tcp_writing()
4507 		if (data->bytes_transmitted < sizeof(q->tcplen)) {  in handle_tcp_writing()
4545 	data->bytes_transmitted += sent;  in handle_tcp_writing()
4550 	if (data->bytes_transmitted < q->tcplen + sizeof(q->tcplen)) {  in handle_tcp_writing()
4558 	assert(data->bytes_transmitted == q->tcplen + sizeof(q->tcplen));  in handle_tcp_writing()
4573 			data->bytes_transmitted = 0;  in handle_tcp_writing()
4606 	data->bytes_transmitted = 0;  in handle_tcp_writing()
4768 	if (data->bytes_transmitted == 0 && data->query_needs_reset) {  in handle_tls_reading()
4794 			if(data->bytes_transmitted < current_read_size) {  in handle_tls_reading()
4797 						data->bytes_transmitted),  in handle_tls_reading()
4798 					current_read_size - data->bytes_transmitted,  in handle_tls_reading()
4801 				data->bytes_transmitted += received;  in handle_tls_reading()
4803 				if(data->bytes_transmitted != current_read_size)  in handle_tls_reading()
4830 			} else if(data->bytes_transmitted < current_read_size) {  in handle_tls_reading()
4833 						data->bytes_transmitted),  in handle_tls_reading()
4834 					current_read_size - data->bytes_transmitted,  in handle_tls_reading()
4837 				data->bytes_transmitted += received;  in handle_tls_reading()
4839 				if(data->bytes_transmitted != current_read_size)  in handle_tls_reading()
4858 		data->bytes_transmitted = 0;  in handle_tls_reading()
4863 	if(data->bytes_transmitted < sizeof(uint16_t)) {  in handle_tls_reading()
4865 		    (char *) &data->query->tcplen + data->bytes_transmitted,  in handle_tls_reading()
4866 		    sizeof(uint16_t) - data->bytes_transmitted, &received))  in handle_tls_reading()
4868 		data->bytes_transmitted += received;  in handle_tls_reading()
4869 		if (data->bytes_transmitted < sizeof(uint16_t)) {  in handle_tls_reading()
4877 		assert(data->bytes_transmitted == sizeof(uint16_t));  in handle_tls_reading()
4910 	data->bytes_transmitted += received;  in handle_tls_reading()
5006 	data->bytes_transmitted = 0;  in handle_tls_reading()
5047 	if (data->bytes_transmitted == 0) {  in handle_tls_writing()
5089 		if (data->bytes_transmitted == 0 && (ssize_t)sent > (ssize_t)sizeof(q->tcplen)) {  in handle_tls_writing()
5094 	data->bytes_transmitted += sent;  in handle_tls_writing()
5095 	if (data->bytes_transmitted < q->tcplen + sizeof(q->tcplen)) {  in handle_tls_writing()
5103 	assert(data->bytes_transmitted == q->tcplen + sizeof(q->tcplen));  in handle_tls_writing()
5118 			data->bytes_transmitted = 0;  in handle_tls_writing()
5141 	data->bytes_transmitted = 0;  in handle_tls_writing()
5281 	tcp_data->bytes_transmitted = 0;  in handle_tcp_accept()