Lines Matching refs:pp
48 long Curl_pp_state_timeout(struct pingpong *pp)
50 struct connectdata *conn = pp->conn;
55 data->set.server_response_timeout: pp->response_time;
58 remaining time, or use pp->response because SERVER_RESPONSE_TIMEOUT is
65 Curl_tvdiff(Curl_tvnow(), pp->response); /* spent time */
85 CURLcode Curl_pp_multi_statemach(struct pingpong *pp)
87 struct connectdata *conn = pp->conn;
92 long timeout_ms = Curl_pp_state_timeout(pp);
99 rc = Curl_socket_ready(pp->sendleft?CURL_SOCKET_BAD:sock, /* reading */
100 pp->sendleft?sock:CURL_SOCKET_BAD, /* writing */
108 result = pp->statemach_act(conn);
120 CURLcode Curl_pp_easy_statemach(struct pingpong *pp)
122 struct connectdata *conn = pp->conn;
126 long timeout_ms = Curl_pp_state_timeout(pp);
139 rc = Curl_socket_ready(pp->sendleft?CURL_SOCKET_BAD:sock, /* reading */
140 pp->sendleft?sock:CURL_SOCKET_BAD, /* writing */
155 result = pp->statemach_act(conn);
161 void Curl_pp_init(struct pingpong *pp)
163 struct connectdata *conn = pp->conn;
164 pp->nread_resp = 0;
165 pp->linestart_resp = conn->data->state.buffer;
166 pp->pending_resp = TRUE;
167 pp->response = Curl_tvnow(); /* start response time-out now! */
185 CURLcode Curl_pp_vsendf(struct pingpong *pp,
196 struct connectdata *conn = pp->conn;
210 Curl_pp_init(pp);
238 pp->sendthis = malloc(write_len);
239 if(pp->sendthis) {
240 memcpy(pp->sendthis, sptr, write_len);
241 pp->sendsize = pp->sendleft = write_len;
249 pp->response = Curl_tvnow();
268 CURLcode Curl_pp_sendf(struct pingpong *pp,
275 res = Curl_pp_vsendf(pp, fmt, ap);
288 struct pingpong *pp,
296 struct connectdata *conn = pp->conn;
304 ptr=buf + pp->nread_resp;
307 perline = (ssize_t)(ptr-pp->linestart_resp);
311 while((pp->nread_resp<BUFSIZE) && (keepon && !result)) {
313 if(pp->cache) {
322 DEBUGASSERT((ptr+pp->cache_size) <= (buf+BUFSIZE+1));
323 memcpy(ptr, pp->cache, pp->cache_size);
324 gotbytes = (ssize_t)pp->cache_size;
325 free(pp->cache); /* free the cache */
326 pp->cache = NULL; /* clear the pointer */
327 pp->cache_size = 0; /* zero the size just in case */
335 DEBUGASSERT((ptr+BUFSIZE-pp->nread_resp) <= (buf+BUFSIZE+1));
336 res = Curl_read(conn, sockfd, ptr, BUFSIZE-pp->nread_resp,
373 pp->nread_resp += gotbytes;
386 pp->linestart_resp, (size_t)perline, conn);
394 pp->linestart_resp, perline);
398 if(pp->endofresp(pp, code)) {
404 for(meow=pp->linestart_resp, n=0; meow<ptr; meow++, n++)
408 pp->linestart_resp = ptr+1; /* advance pointer */
411 *size = pp->nread_resp; /* size of the response */
412 pp->nread_resp = 0; /* restart */
416 pp->linestart_resp = ptr+1;
442 else if(pp->nread_resp > BUFSIZE/2) {
454 pp->cache_size = clipamount;
455 pp->cache = malloc(pp->cache_size);
456 if(pp->cache)
457 memcpy(pp->cache, pp->linestart_resp, pp->cache_size);
464 pp->nread_resp = 0; /* start over from scratch in the buffer */
465 ptr = pp->linestart_resp = buf;
473 pp->pending_resp = FALSE;
478 int Curl_pp_getsock(struct pingpong *pp,
482 struct connectdata *conn = pp->conn;
489 if(pp->sendleft) {
498 CURLcode Curl_pp_flushsend(struct pingpong *pp)
501 struct connectdata *conn = pp->conn;
506 result = Curl_write(conn, sock, pp->sendthis + pp->sendsize -
507 pp->sendleft, pp->sendleft, &written);
511 if(written != (ssize_t)pp->sendleft) {
513 pp->sendleft -= written;
516 free(pp->sendthis);
517 pp->sendthis=NULL;
518 pp->sendleft = pp->sendsize = 0;
519 pp->response = Curl_tvnow();
524 CURLcode Curl_pp_disconnect(struct pingpong *pp)
526 if(pp->cache) {
527 free(pp->cache);
528 pp->cache = NULL;