Lines Matching refs:connection
82 /* WANT_READ if SSL/TLS connection needs more input; or WANT_WRITE
87 SSL/TSL connection. */
164 struct Connection *connection;
169 connection = (struct Connection *)user_data;
170 connection->want_io = IO_NONE;
172 rv = SSL_write(connection->ssl, data, (int)length);
174 int err = SSL_get_error(connection->ssl, rv);
176 connection->want_io =
194 struct Connection *connection;
199 connection = (struct Connection *)user_data;
200 connection->want_io = IO_NONE;
202 rv = SSL_read(connection->ssl, buf, (int)length);
204 int err = SSL_get_error(connection->ssl, rv);
206 connection->want_io =
461 * Update |pollfd| based on the state of |connection|.
463 static void ctl_poll(struct pollfd *pollfd, struct Connection *connection) {
465 if (nghttp2_session_want_read(connection->session) ||
466 connection->want_io == WANT_READ) {
469 if (nghttp2_session_want_write(connection->session) ||
470 connection->want_io == WANT_WRITE) {
476 * Submits the request |req| to the connection |connection|. This
478 * internal queue in |connection->session|.
480 static void submit_request(struct Connection *connection, struct Request *req) {
490 stream_id = nghttp2_submit_request(connection->session, NULL, nva,
504 static void exec_io(struct Connection *connection) {
506 rv = nghttp2_session_recv(connection->session);
510 rv = nghttp2_session_send(connection->session);
539 struct Connection connection;
546 /* Establish connection and setup SSL */
564 connection.ssl = ssl;
565 connection.want_io = IO_NONE;
581 rv = nghttp2_session_client_new(&connection.session, callbacks, &connection);
589 rv = nghttp2_submit_settings(connection.session, NGHTTP2_FLAG_NONE, NULL, 0);
596 submit_request(&connection, &req);
599 ctl_poll(pollfds, &connection);
602 while (nghttp2_session_want_read(connection.session) ||
603 nghttp2_session_want_write(connection.session)) {
609 exec_io(&connection);
614 ctl_poll(pollfds, &connection);
618 nghttp2_session_del(connection.session);