| 418 | } |
| 419 | } |
| 420 | td::Status SslStreamHelper::read_loop() { |
| 421 | if (ssl_stream_) { |
| 422 | //ssl_stream_.read_byte_flow().set_need_size(0); |
| 423 | ssl_stream_.write_byte_flow().reset_need_size(); |
| 424 | } |
| 425 | read_source_.wakeup(); |
| 426 | if (read_sink_.status().is_error()) { |
| 427 | return std::move(read_sink_.status()); |
| 428 | } |
| 429 | return Status::OK(); |
| 430 | } |
| 431 | td::Status SslStreamHelper::write_loop() { |
| 432 | write_source_.wakeup(); |
| 433 | if (write_sink_.status().is_error()) { |
nothing calls this directly
no outgoing calls
no test coverage detected