Lines Matching full:conn
61 struct connectdata *conn)
72 if(conn->recv_pipe && conn->recv_pipe->head) {
73 struct Curl_easy *recv_handle = conn->recv_pipe->head->ptr;
82 (curl_off_t)conn->chunk.datasize > chunk_penalty_size)
85 infof(data, "Conn: %ld (%p) Receive pipe weight: (%"
87 conn->connection_id, (void *)conn, recv_size,
88 conn->chunk.datasize, penalized?"TRUE":"FALSE");
104 struct connectdata *conn)
106 struct curl_llist_element *sendhead = conn->send_pipe->head;
110 pipeline = conn->send_pipe;
114 if(pipeline == conn->send_pipe && sendhead != conn->send_pipe->head) {
116 Curl_pipeline_leave_write(conn); /* not in use yet */
117 Curl_expire(conn->send_pipe->head->ptr, 1);
121 print_pipeline(conn);
134 struct connectdata *conn)
138 curr = conn->send_pipe->head;
141 Curl_llist_move(conn->send_pipe, curr,
142 conn->recv_pipe, conn->recv_pipe->tail);
144 if(conn->send_pipe->head) {
147 Curl_pipeline_leave_write(conn); /* not used now */
149 infof(conn->data, "%p is at send pipe head B!\n",
150 (void *)conn->send_pipe->head->ptr);
152 Curl_expire(conn->send_pipe->head->ptr, 1);
166 struct connectdata *conn)
180 if(Curl_raw_equal(site->hostname, conn->host.name) &&
181 site->port == conn->remote_port) {
183 conn->host.name, conn->remote_port);
341 struct connectdata *conn)
343 return pipe_head(data, conn->recv_pipe);
348 struct connectdata *conn)
350 return pipe_head(data, conn->send_pipe);
362 struct connectdata *conn)
364 if(conn->bits.multiplex)
368 if(!conn->writechannel_inuse && Curl_sendpipe_head(data, conn)) {
370 conn->writechannel_inuse = TRUE;
385 struct connectdata *conn)
387 if(conn->bits.multiplex)
391 if(!conn->readchannel_inuse && Curl_recvpipe_head(data, conn)) {
393 conn->readchannel_inuse = TRUE;
402 void Curl_pipeline_leave_write(struct connectdata *conn)
404 conn->writechannel_inuse = FALSE;
410 void Curl_pipeline_leave_read(struct connectdata *conn)
412 conn->readchannel_inuse = FALSE;
417 void print_pipeline(struct connectdata *conn)
421 struct Curl_easy *data = conn->data;
423 cb_ptr = conn->bundle;
428 conn = curr->ptr;
429 infof(data, "- Conn %ld (%p) send_pipe: %zu, recv_pipe: %zu\n",
430 conn->connection_id,
431 (void *)conn,
432 conn->send_pipe->size,
433 conn->recv_pipe->size);
