| 64 | } |
| 65 | |
| 66 | Stream::~Stream() { |
| 67 | // Clear pending buffer |
| 68 | if (_pending_buf != NULL) { |
| 69 | delete _pending_buf; |
| 70 | _pending_buf = NULL; |
| 71 | } |
| 72 | CHECK(_host_socket == NULL); |
| 73 | bthread_mutex_destroy(&_connect_mutex); |
| 74 | bthread_mutex_destroy(&_congestion_control_mutex); |
| 75 | bthread_id_list_destroy(&_writable_wait_list); |
| 76 | } |
| 77 | |
| 78 | int Stream::Create(const StreamOptions &options, |
| 79 | const StreamSettings *remote_settings, |
nothing calls this directly
no test coverage detected