Lines Matching defs:connection
86 struct Connection {
88 /* WANT_READ if SSL connection needs more input; or WANT_WRITE if it
93 SSL connection. */
207 struct Connection *connection;
209 connection = (struct Connection*)user_data;
210 connection->want_io = IO_NONE;
212 rv = write(connection->fd,
224 connection->want_io = WANT_WRITE;
248 struct Connection *connection;
250 connection = (struct Connection*)user_data;
251 connection->want_io = IO_NONE;
253 rv = read(connection->fd,
265 connection->want_io = WANT_READ;
526 * Update |pollfd| based on the state of |connection|.
528 static void ctl_poll(struct pollfd *pollfd, struct Connection *connection)
531 if(spdylay_session_want_read(connection->session) ||
532 connection->want_io == WANT_READ) {
535 if(spdylay_session_want_write(connection->session) ||
536 connection->want_io == WANT_WRITE) {
542 * Submits the request |req| to the connection |connection|. This
544 * internal queue in |connection->session|.
546 static void submit_request(struct Connection *connection, struct Request *req)
562 rv = spdylay_submit_request(connection->session, pri, nv, NULL, req);
571 static void exec_io(struct Connection *connection)
574 rv = spdylay_session_recv(connection->session);
578 rv = spdylay_session_send(connection->session);
610 struct Connection connection;
620 /* Establish connection and setup SSL */
625 connection.fd = fd;
626 connection.want_io = IO_NONE;
633 connection.session, spdy_proto_version,
634 &callbacks, &connection);
640 submit_request(&connection, &req);
643 ctl_poll(pollfds, &connection);
646 while(spdylay_session_want_read(connection.session) ||
647 spdylay_session_want_write(connection.session)) {
653 exec_io(&connection);
656 die("Connection error");
658 ctl_poll(pollfds, &connection);
662 spdylay_session_del(connection.session);
