bev_ssl 360 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c put_error(struct bufferevent_openssl *bev_ssl, unsigned long err) bev_ssl 362 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->n_errors == NUM_ERRORS) bev_ssl 369 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->errors[bev_ssl->n_errors++] = (ev_uint32_t) err; bev_ssl 376 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c start_reading(struct bufferevent_openssl *bev_ssl) bev_ssl 378 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 379 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_unsuspend_read(bev_ssl->underlying, bev_ssl 383 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 386 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r == 0 && bev_ssl->read_blocked_on_write) bev_ssl 397 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c start_writing(struct bufferevent_openssl *bev_ssl) bev_ssl 400 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 403 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 405 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!r && bev_ssl->write_blocked_on_read) bev_ssl 413 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_reading(struct bufferevent_openssl *bev_ssl) bev_ssl 415 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->write_blocked_on_read) bev_ssl 417 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 418 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_suspend_read(bev_ssl->underlying, bev_ssl 421 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 427 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_writing(struct bufferevent_openssl *bev_ssl) bev_ssl 429 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->read_blocked_on_write) bev_ssl 431 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 434 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 440 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c set_rbow(struct bufferevent_openssl *bev_ssl) bev_ssl 442 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) bev_ssl 443 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_reading(bev_ssl); bev_ssl 444 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->read_blocked_on_write = 1; bev_ssl 445 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return start_writing(bev_ssl); bev_ssl 449 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c set_wbor(struct bufferevent_openssl *bev_ssl) bev_ssl 451 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) bev_ssl 452 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_writing(bev_ssl); bev_ssl 453 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->write_blocked_on_read = 1; bev_ssl 454 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return start_reading(bev_ssl); bev_ssl 458 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c clear_rbow(struct bufferevent_openssl *bev_ssl) bev_ssl 460 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 462 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->read_blocked_on_write = 0; bev_ssl 464 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_writing(bev_ssl); bev_ssl 466 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = start_reading(bev_ssl); bev_ssl 472 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c clear_wbor(struct bufferevent_openssl *bev_ssl) bev_ssl 474 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 476 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->write_blocked_on_read = 0; bev_ssl 478 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_reading(bev_ssl); bev_ssl 480 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = start_writing(bev_ssl); bev_ssl 485 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(struct bufferevent_openssl *bev_ssl, int errcode, int ret) bev_ssl 494 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (SSL_get_shutdown(bev_ssl->ssl) & SSL_RECEIVED_SHUTDOWN) bev_ssl 522 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c put_error(bev_ssl, err); bev_ssl 525 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (dirty_shutdown && bev_ssl->allow_dirty_shutdown) bev_ssl 528 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_reading(bev_ssl); bev_ssl 529 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_writing(bev_ssl); bev_ssl 531 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, event); bev_ssl 535 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c init_bio_counts(struct bufferevent_openssl *bev_ssl) bev_ssl 537 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->counts.n_written = bev_ssl 538 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BIO_number_written(SSL_get_wbio(bev_ssl->ssl)); bev_ssl 539 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->counts.n_read = bev_ssl 540 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BIO_number_read(SSL_get_rbio(bev_ssl->ssl)); bev_ssl 544 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c decrement_buckets(struct bufferevent_openssl *bev_ssl) bev_ssl 546 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c unsigned long num_w = BIO_number_written(SSL_get_wbio(bev_ssl->ssl)); bev_ssl 547 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c unsigned long num_r = BIO_number_read(SSL_get_rbio(bev_ssl->ssl)); bev_ssl 549 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c unsigned long w = num_w - bev_ssl->counts.n_written; bev_ssl 550 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c unsigned long r = num_r - bev_ssl->counts.n_read; bev_ssl 552 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decrement_write_buckets(&bev_ssl->bev, w); bev_ssl 554 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decrement_read_buckets(&bev_ssl->bev, r); bev_ssl 555 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->counts.n_written = num_w; bev_ssl 556 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->counts.n_read = num_r; bev_ssl 566 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c do_read(struct bufferevent_openssl *bev_ssl, int n_to_read) { bev_ssl 568 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 574 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended) bev_ssl 577 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c atmost = _bufferevent_get_read_max(&bev_ssl->bev); bev_ssl 586 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended) bev_ssl 588 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = SSL_read(bev_ssl->ssl, space[i].iov_base, space[i].iov_len); bev_ssl 591 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->read_blocked_on_write) bev_ssl 592 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (clear_rbow(bev_ssl) < 0) bev_ssl 596 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c decrement_buckets(bev_ssl); bev_ssl 598 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int err = SSL_get_error(bev_ssl->ssl, r); bev_ssl 603 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->read_blocked_on_write) bev_ssl 604 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (clear_rbow(bev_ssl) < 0) bev_ssl 610 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->read_blocked_on_write) bev_ssl 611 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (set_rbow(bev_ssl) < 0) bev_ssl 615 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(bev_ssl, err, r); bev_ssl 625 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) bev_ssl 635 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c do_write(struct bufferevent_openssl *bev_ssl, int atmost) bev_ssl 638 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 643 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->last_write > 0) bev_ssl 644 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c atmost = bev_ssl->last_write; bev_ssl 646 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c atmost = _bufferevent_get_write_max(&bev_ssl->bev); bev_ssl 655 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.write_suspended) bev_ssl 664 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = SSL_write(bev_ssl->ssl, space[i].iov_base, bev_ssl 668 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->write_blocked_on_read) bev_ssl 669 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (clear_wbor(bev_ssl) < 0) bev_ssl 672 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->last_write = -1; bev_ssl 673 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c decrement_buckets(bev_ssl); bev_ssl 675 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int err = SSL_get_error(bev_ssl->ssl, r); bev_ssl 680 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->write_blocked_on_read) bev_ssl 681 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (clear_wbor(bev_ssl) < 0) bev_ssl 683 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->last_write = space[i].iov_len; bev_ssl 688 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->write_blocked_on_read) bev_ssl 689 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (set_wbor(bev_ssl) < 0) bev_ssl 691 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->last_write = space[i].iov_len; bev_ssl 694 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(bev_ssl, err, r); bev_ssl 695 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->last_write = -1; bev_ssl 704 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) bev_ssl 766 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_reading(struct bufferevent_openssl *bev_ssl) bev_ssl 772 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c while (bev_ssl->write_blocked_on_read) { bev_ssl 773 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_write(bev_ssl, WRITE_FRAME); bev_ssl 777 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->write_blocked_on_read) bev_ssl 780 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c n_to_read = bytes_to_read(bev_ssl); bev_ssl 783 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_read(bev_ssl, n_to_read); bev_ssl 789 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended) bev_ssl 800 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c n_to_read = SSL_pending(bev_ssl->ssl); bev_ssl 816 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!n_to_read && bev_ssl->underlying) bev_ssl 817 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c n_to_read = bytes_to_read(bev_ssl); bev_ssl 821 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 829 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) { bev_ssl 831 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended || bev_ssl 832 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c !(bev_ssl->bev.bev.enabled & EV_READ)) { bev_ssl 833 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev_ssl->bev.bev.ev_read); bev_ssl 839 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_writing(struct bufferevent_openssl *bev_ssl) bev_ssl 842 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *output = bev_ssl->bev.bev.output; bev_ssl 846 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c while (bev_ssl->read_blocked_on_write) { bev_ssl 847 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_read(bev_ssl, 1024); /* XXXX 1024 is a hack */ bev_ssl 849 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 859 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->read_blocked_on_write) bev_ssl 861 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 862 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c target = bev_ssl->underlying->output; bev_ssl 863 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c wm = &bev_ssl->underlying->wm_write; bev_ssl 865 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c while ((bev_ssl->bev.bev.enabled & EV_WRITE) && bev_ssl 866 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c (! bev_ssl->bev.write_suspended) && bev_ssl 874 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_write(bev_ssl, n_to_write); bev_ssl 879 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) { bev_ssl 881 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev_ssl->bev.bev.ev_write); bev_ssl 882 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c } else if (bev_ssl->bev.write_suspended || bev_ssl 883 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c !(bev_ssl->bev.bev.enabled & EV_WRITE)) { bev_ssl 885 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev_ssl->bev.bev.ev_write); bev_ssl 893 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ctx; bev_ssl 894 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_reading(bev_ssl); bev_ssl 900 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ctx; bev_ssl 901 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_writing(bev_ssl); bev_ssl 907 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ctx; bev_ssl 911 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->allow_dirty_shutdown) bev_ssl 926 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, event); bev_ssl 932 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ptr; bev_ssl 933 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_incref_and_lock(&bev_ssl->bev.bev); bev_ssl 935 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, bev_ssl 938 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_reading(bev_ssl); bev_ssl 940 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decref_and_unlock(&bev_ssl->bev.bev); bev_ssl 946 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ptr; bev_ssl 947 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_incref_and_lock(&bev_ssl->bev.bev); bev_ssl 949 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, bev_ssl 952 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_writing(bev_ssl); bev_ssl 954 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decref_and_unlock(&bev_ssl->bev.bev); bev_ssl 958 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c set_open_callbacks(struct bufferevent_openssl *bev_ssl, evutil_socket_t fd) bev_ssl 960 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 961 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_setcb(bev_ssl->underlying, bev_ssl 963 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl); bev_ssl 966 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 968 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (fd < 0 && bev_ssl->fd_is_set) bev_ssl 970 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->fd_is_set) { bev_ssl 977 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c EV_READ|EV_PERSIST, be_openssl_readeventcb, bev_ssl); bev_ssl 979 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c EV_WRITE|EV_PERSIST, be_openssl_writeeventcb, bev_ssl); bev_ssl 985 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->fd_is_set = 1; bev_ssl 992 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c do_handshake(struct bufferevent_openssl *bev_ssl) bev_ssl 996 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c switch (bev_ssl->state) { bev_ssl 1003 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = SSL_do_handshake(bev_ssl->ssl); bev_ssl 1006 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c decrement_buckets(bev_ssl); bev_ssl 1010 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->state = BUFFEREVENT_SSL_OPEN; bev_ssl 1011 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c set_open_callbacks(bev_ssl, -1); /* XXXX handle failure */ bev_ssl 1013 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_enable(&bev_ssl->bev.bev, bev_ssl->bev.bev.enabled); bev_ssl 1014 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, bev_ssl 1018 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int err = SSL_get_error(bev_ssl->ssl, r); bev_ssl 1022 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) { bev_ssl 1023 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_reading(bev_ssl); bev_ssl 1024 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return start_writing(bev_ssl); bev_ssl 1028 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) { bev_ssl 1029 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_writing(bev_ssl); bev_ssl 1030 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return start_reading(bev_ssl); bev_ssl 1034 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(bev_ssl, err, r); bev_ssl 1043 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ctx; bev_ssl 1044 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c do_handshake(bev_ssl);/* XXX handle failure */ bev_ssl 1050 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = ptr; bev_ssl 1052 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_incref_and_lock(&bev_ssl->bev.bev); bev_ssl 1054 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, BEV_EVENT_TIMEOUT); bev_ssl 1056 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c do_handshake(bev_ssl);/* XXX handle failure */ bev_ssl 1057 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decref_and_unlock(&bev_ssl->bev.bev); bev_ssl 1061 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c set_handshake_callbacks(struct bufferevent_openssl *bev_ssl, evutil_socket_t fd) bev_ssl 1063 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 1064 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_setcb(bev_ssl->underlying, bev_ssl 1067 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl); bev_ssl 1068 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return do_handshake(bev_ssl); bev_ssl 1070 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev_ssl 1072 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (fd < 0 && bev_ssl->fd_is_set) bev_ssl 1074 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->fd_is_set) { bev_ssl 1079 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c EV_READ|EV_PERSIST, be_openssl_handshakeeventcb, bev_ssl); bev_ssl 1081 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c EV_WRITE|EV_PERSIST, be_openssl_handshakeeventcb, bev_ssl); bev_ssl 1085 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->fd_is_set = 1; bev_ssl 1094 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev_ssl 1095 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl) bev_ssl 1097 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (SSL_renegotiate(bev_ssl->ssl) < 0) bev_ssl 1099 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->state = BUFFEREVENT_SSL_CONNECTING; bev_ssl 1100 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (set_handshake_callbacks(bev_ssl, -1) < 0) bev_ssl 1102 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) bev_ssl 1103 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return do_handshake(bev_ssl); bev_ssl 1111 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = arg; bev_ssl 1115 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (cbinfo->n_added && bev_ssl->state == BUFFEREVENT_SSL_OPEN) { bev_ssl 1117 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev_ssl->bev.bev.ev_write, bev_ssl 1118 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c &bev_ssl->bev.bev.timeout_write); bev_ssl 1119 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_writing(bev_ssl); bev_ssl 1129 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev_ssl 1132 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->state != BUFFEREVENT_SSL_OPEN) bev_ssl 1136 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r1 = start_reading(bev_ssl); bev_ssl 1138 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r2 = start_writing(bev_ssl); bev_ssl 1140 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 1147 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_reading(bev_ssl); bev_ssl 1149 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c consider_writing(bev_ssl); bev_ssl 1157 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev_ssl 1158 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->state != BUFFEREVENT_SSL_OPEN) bev_ssl 1162 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_reading(bev_ssl); bev_ssl 1164 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c stop_writing(bev_ssl); bev_ssl 1166 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 1178 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev_ssl 1180 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 1187 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) { bev_ssl 1188 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 1189 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (BEV_UPCAST(bev_ssl->underlying)->refcnt < 2) { bev_ssl 1193 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_free(bev_ssl->underlying); bev_ssl 1194 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->underlying = NULL; bev_ssl 1198 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BIO *bio = SSL_get_wbio(bev_ssl->ssl); bev_ssl 1204 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c SSL_free(bev_ssl->ssl); bev_ssl 1206 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) { bev_ssl 1207 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying->errorcb == be_openssl_eventcb) bev_ssl 1208 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_setcb(bev_ssl->underlying, bev_ssl 1210 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_unsuspend_read(bev_ssl->underlying, bev_ssl 1219 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev_ssl 1221 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) bev_ssl 1245 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev_ssl 1248 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) bev_ssl 1253 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c SSL_set_bio(bev_ssl->ssl, bio, bio); bev_ssl 1254 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->fd_is_set = 1; bev_ssl 1256 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->state == BUFFEREVENT_SSL_OPEN) bev_ssl 1257 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return set_open_callbacks(bev_ssl, data->fd); bev_ssl 1259 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return set_handshake_callbacks(bev_ssl, data->fd); bev_ssl 1262 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->underlying) bev_ssl 1264 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->fd_is_set) bev_ssl 1269 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl->underlying) bev_ssl 1271 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c data->ptr = bev_ssl->underlying; bev_ssl 1282 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bufev); bev_ssl 1283 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!bev_ssl) bev_ssl 1285 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return bev_ssl->ssl; bev_ssl 1296 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = NULL; bev_ssl 1303 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!(bev_ssl = mm_calloc(1, sizeof(struct bufferevent_openssl)))) bev_ssl 1306 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_p = &bev_ssl->bev; bev_ssl 1316 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->underlying = underlying; bev_ssl 1317 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->ssl = ssl; bev_ssl 1319 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->outbuf_cb = evbuffer_add_cb(bev_p->bev.output, bev_ssl 1320 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_outbuf_cb, bev_ssl); bev_ssl 1323 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_enable_locking(&bev_ssl->bev.bev, NULL); bev_ssl 1326 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_init_generic_timeout_cbs(&bev_ssl->bev.bev); bev_ssl 1330 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->state = state; bev_ssl 1331 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->last_write = -1; bev_ssl 1333 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c init_bio_counts(bev_ssl); bev_ssl 1337 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c SSL_set_accept_state(bev_ssl->ssl); bev_ssl 1338 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (set_handshake_callbacks(bev_ssl, fd) < 0) bev_ssl 1342 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c SSL_set_connect_state(bev_ssl->ssl); bev_ssl 1343 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (set_handshake_callbacks(bev_ssl, fd) < 0) bev_ssl 1347 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (set_open_callbacks(bev_ssl, fd) < 0) bev_ssl 1361 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->bev.bev.enabled = EV_READ|EV_WRITE; bev_ssl 1362 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->fd_is_set) { bev_ssl 1364 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event_add(&bev_ssl->bev.bev.ev_read, NULL) < 0) bev_ssl 1366 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event_add(&bev_ssl->bev.bev.ev_write, NULL) < 0) bev_ssl 1371 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return &bev_ssl->bev.bev; bev_ssl 1373 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl) bev_ssl 1374 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_free(&bev_ssl->bev.bev); bev_ssl 1446 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl; bev_ssl 1448 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl = upcast(bev); bev_ssl 1449 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl && bev_ssl->n_errors) { bev_ssl 1450 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c err = bev_ssl->errors[--bev_ssl->n_errors];