Lines Matching refs:httpc
87 const struct http_conn *c = &conn->proto.httpc;
116 struct http_conn *c = &conn->proto.httpc;
161 conn->proto.httpc.settings.max_concurrent_streams =
258 struct http_conn *c = &conn->proto.httpc;
378 struct http_conn *httpc;
431 httpc = &conn->proto.httpc;
432 nghttp2_session_set_stream_user_data(httpc->h2,
447 struct http_conn *httpc = &conn->proto.httpc;
458 uint32_t max_conn = httpc->settings.max_concurrent_streams;
460 httpc->settings.max_concurrent_streams =
463 httpc->settings.enable_push =
467 httpc->settings.max_concurrent_streams));
469 httpc->settings.enable_push?"TRUE":"false"));
470 if(max_conn != httpc->settings.max_concurrent_streams) {
543 httpc->drain_total++;
620 conn->proto.httpc.drain_total++;
639 data_s->easy_conn->proto.httpc.pause_stream_id = stream_id;
647 data_s->easy_conn->proto.httpc.pause_stream_id = stream_id;
725 conn->proto.httpc.drain_total++;
987 if(!conn->proto.httpc.h2) {
991 conn->proto.httpc.inbuf = malloc(H2_BUFSIZE);
992 if(conn->proto.httpc.inbuf == NULL)
1034 rc = nghttp2_session_client_new(&conn->proto.httpc
1057 uint8_t *binsettings = conn->proto.httpc.binsettings;
1072 conn->proto.httpc.binlen = binlen;
1094 static int should_close_session(struct http_conn *httpc) {
1095 return httpc->drain_total == 0 && !nghttp2_session_want_read(httpc->h2) &&
1096 !nghttp2_session_want_write(httpc->h2);
1104 * httpc->inbuf. Then, call h2_session_send() to send pending data.
1109 struct http_conn *httpc,
1115 nread = httpc->inbuflen - httpc->nread_inbuf;
1116 inbuf = httpc->inbuf + httpc->nread_inbuf;
1118 rv = nghttp2_session_mem_recv(httpc->h2, (const uint8_t *)inbuf, nread);
1131 httpc->inbuflen = 0;
1132 httpc->nread_inbuf = 0;
1135 httpc->nread_inbuf += rv;
1139 httpc->inbuflen - httpc->nread_inbuf));
1142 rv = h2_session_send(data, httpc->h2);
1148 if(should_close_session(httpc)) {
1163 struct http_conn *httpc = &conn->proto.httpc;
1165 if(httpc->pause_stream_id == stream->stream_id) {
1166 httpc->pause_stream_id = 0;
1169 DEBUGASSERT(httpc->drain_total >= data->state.drain);
1170 httpc->drain_total -= data->state.drain;
1173 if(httpc->pause_stream_id == 0) {
1174 if(h2_process_pending_input(data, httpc, err) != 0) {
1281 struct http_conn *httpc = &conn->proto.httpc;
1287 if(should_close_session(httpc)) {
1333 if(httpc->pause_stream_id == stream->stream_id && !stream->pausedata) {
1336 httpc->pause_stream_id = 0;
1337 if(h2_process_pending_input(data, httpc, &result) != 0) {
1344 DEBUGASSERT(httpc->pause_stream_id == stream->stream_id);
1354 assert(httpc->pause_stream_id == stream->stream_id);
1355 httpc->pause_stream_id = 0;
1367 if(h2_process_pending_input(data, httpc, &result) != 0) {
1376 else if(httpc->pause_stream_id) {
1396 if(httpc->inbuflen == 0) {
1397 nread = ((Curl_recv *)httpc->recv_underlying)(
1398 conn, FIRSTSOCKET, httpc->inbuf, H2_BUFSIZE, &result);
1419 httpc->inbuflen = nread;
1420 inbuf = httpc->inbuf;
1423 nread = httpc->inbuflen - httpc->nread_inbuf;
1424 inbuf = httpc->inbuf + httpc->nread_inbuf;
1429 rv = nghttp2_session_mem_recv(httpc->h2, (const uint8_t *)inbuf, nread);
1440 httpc->inbuflen = 0;
1441 httpc->nread_inbuf = 0;
1444 httpc->nread_inbuf += rv;
1446 httpc->inbuflen - httpc->nread_inbuf));
1450 rv = h2_session_send(data, httpc->h2);
1456 if(should_close_session(httpc)) {
1468 if(httpc->pause_stream_id == stream->stream_id) {
1475 DEBUGASSERT(httpc->drain_total >= data->state.drain);
1476 httpc->drain_total -= data->state.drain;
1510 struct http_conn *httpc = &conn->proto.httpc;
1520 nghttp2_session *h2 = httpc->h2;
1545 if(should_close_session(httpc)) {
1785 if(should_close_session(httpc)) {
1814 struct http_conn *httpc = &conn->proto.httpc;
1840 httpc->inbuflen = 0;
1841 httpc->nread_inbuf = 0;
1843 httpc->pause_stream_id = 0;
1844 httpc->drain_total = 0;
1864 struct http_conn *httpc = &conn->proto.httpc;
1874 httpc->recv_underlying = (recving)conn->recv[FIRSTSOCKET];
1875 httpc->send_underlying = (sending)conn->send[FIRSTSOCKET];
1883 rv = nghttp2_session_upgrade(httpc->h2, httpc->binsettings,
1884 httpc->binlen, NULL);
1891 nghttp2_session_set_stream_user_data(httpc->h2,
1898 rv = nghttp2_submit_settings(httpc->h2, NGHTTP2_FLAG_NONE, NULL, 0);
1906 /* we are going to copy mem to httpc->inbuf. This is required since
1921 memcpy(httpc->inbuf, mem, nread);
1922 httpc->inbuflen = nread;
1924 nproc = nghttp2_session_mem_recv(httpc->h2, (const uint8_t *)httpc->inbuf,
1925 httpc->inbuflen);
1936 httpc->inbuflen = 0;
1937 httpc->nread_inbuf = 0;
1940 httpc->nread_inbuf += nproc;
1944 rv = h2_session_send(data, httpc->h2);
1952 if(should_close_session(httpc)) {
