Lines Matching refs:Connection
89 struct Connection {
92 /* WANT_READ if SSL connection needs more input; or WANT_WRITE if it
97 SSL connection. */
210 struct Connection *connection;
212 connection = (struct Connection*)user_data;
213 connection->want_io = IO_NONE;
215 rv = SSL_write(connection->ssl, data, length);
217 int err = SSL_get_error(connection->ssl, rv);
219 connection->want_io = (err == SSL_ERROR_WANT_READ ?
242 struct Connection *connection;
244 connection = (struct Connection*)user_data;
245 connection->want_io = IO_NONE;
247 rv = SSL_read(connection->ssl, buf, length);
249 int err = SSL_get_error(connection->ssl, rv);
251 connection->want_io = (err == SSL_ERROR_WANT_READ ?
562 * Update |pollfd| based on the state of |connection|.
564 static void ctl_poll(struct pollfd *pollfd, struct Connection *connection)
567 if(spdylay_session_want_read(connection->session) ||
568 connection->want_io == WANT_READ) {
571 if(spdylay_session_want_write(connection->session) ||
572 connection->want_io == WANT_WRITE) {
578 * Submits the request |req| to the connection |connection|. This
580 * internal queue in |connection->session|.
582 static void submit_request(struct Connection *connection, struct Request *req)
598 rv = spdylay_submit_request(connection->session, pri, nv, NULL, req);
607 static void exec_io(struct Connection *connection)
610 rv = spdylay_session_recv(connection->session);
614 rv = spdylay_session_send(connection->session);
648 struct Connection connection;
658 /* Establish connection and setup SSL */
675 connection.ssl = ssl;
676 connection.want_io = IO_NONE;
683 rv = spdylay_session_client_new(&connection.session, spdy_proto_version,
684 &callbacks, &connection);
690 submit_request(&connection, &req);
693 ctl_poll(pollfds, &connection);
696 while(spdylay_session_want_read(connection.session) ||
697 spdylay_session_want_write(connection.session)) {
703 exec_io(&connection);
706 die("Connection error");
708 ctl_poll(pollfds, &connection);
712 spdylay_session_del(connection.session);
