Lines Matching refs:r

135 	int r = 0;  in bio_bufferevent_read()  local
151 r = evbuffer_remove(input, out, outlen); in bio_bufferevent_read()
154 return r; in bio_bufferevent_read()
391 int r; in start_reading() local
392 r = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read); in start_reading()
393 if (r == 0 && bev_ssl->read_blocked_on_write) in start_reading()
394 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
396 return r; in start_reading()
406 int r = 0; in start_writing() local
414 r = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in start_writing()
415 if (!r && bev_ssl->write_blocked_on_read) in start_writing()
416 r = bufferevent_add_event_(&bev->ev_read, in start_writing()
419 return r; in start_writing()
472 int r = 0; in clear_rbow() local
477 r = start_reading(bev_ssl); in clear_rbow()
478 return r; in clear_rbow()
486 int r = 0; in clear_wbor() local
491 r = start_writing(bev_ssl); in clear_wbor()
492 return r; in clear_wbor()
568 unsigned long r = num_r - bev_ssl->counts.n_read; in decrement_buckets() local
571 if (r) in decrement_buckets()
572 bufferevent_decrement_read_buckets_(&bev_ssl->bev, r); in decrement_buckets()
588 int r, n, i, n_used = 0, atmost; in do_read() local
607 r = SSL_read(bev_ssl->ssl, space[i].iov_base, space[i].iov_len); in do_read()
608 if (r>0) { in do_read()
614 space[i].iov_len = r; in do_read()
617 int err = SSL_get_error(bev_ssl->ssl, r); in do_read()
634 conn_closed(bev_ssl, BEV_EVENT_READING, err, r); in do_read()
656 int i, r, n, n_written = 0; in do_write() local
684 r = SSL_write(bev_ssl->ssl, space[i].iov_base, in do_write()
686 if (r > 0) { in do_write()
691 n_written += r; in do_write()
695 int err = SSL_get_error(bev_ssl->ssl, r); in do_write()
714 conn_closed(bev_ssl, BEV_EVENT_WRITING, err, r); in do_write()
787 int r; in consider_reading() local
792 r = do_write(bev_ssl, WRITE_FRAME); in consider_reading()
793 if (r & (OP_BLOCKED|OP_ERR)) in consider_reading()
802 r = do_read(bev_ssl, n_to_read); in consider_reading()
803 all_result_flags |= r; in consider_reading()
805 if (r & (OP_BLOCKED|OP_ERR)) in consider_reading()
857 int r; in consider_writing() local
863 r = do_read(bev_ssl, 1024); /* XXXX 1024 is a hack */ in consider_writing()
864 if (r & OP_MADE_PROGRESS) { in consider_writing()
869 if (r & (OP_ERR|OP_BLOCKED)) in consider_writing()
887 r = do_write(bev_ssl, n_to_write); in consider_writing()
888 if (r & (OP_BLOCKED|OP_ERR)) in consider_writing()
1021 int r; in do_handshake() local
1031 r = SSL_do_handshake(bev_ssl->ssl); in do_handshake()
1036 if (r==1) { in do_handshake()
1047 int err = SSL_get_error(bev_ssl->ssl, r); in do_handshake()
1057 conn_closed(bev_ssl, BEV_EVENT_READING, err, r); in do_handshake()
1140 int r = 0; in be_openssl_outbuf_cb() local
1145 r = bufferevent_add_event_(&bev_ssl->bev.bev.ev_write, in be_openssl_outbuf_cb()
1152 (void)r; in be_openssl_outbuf_cb()