diff options
| -rw-r--r-- | src/core/lib/iomgr/tcp_cfstream_sync.h | 2 | ||||
| -rw-r--r-- | src/core/lib/iomgr/tcp_cfstream_sync.mm | 12 |
2 files changed, 10 insertions, 4 deletions
diff --git a/src/core/lib/iomgr/tcp_cfstream_sync.h b/src/core/lib/iomgr/tcp_cfstream_sync.h index 06e225485f..ef9d41de26 100644 --- a/src/core/lib/iomgr/tcp_cfstream_sync.h +++ b/src/core/lib/iomgr/tcp_cfstream_sync.h @@ -33,7 +33,7 @@ class CFStreamSync final { public: static CFStreamSync* CreateStreamSync(CFReadStreamRef read_stream, CFWriteStreamRef write_stream); - ~CFStreamSync() {} + ~CFStreamSync(); CFStreamSync(const CFReadStreamRef& ref) = delete; CFStreamSync(CFReadStreamRef&& ref) = delete; CFStreamSync& operator=(const CFStreamSync& rhs) = delete; diff --git a/src/core/lib/iomgr/tcp_cfstream_sync.mm b/src/core/lib/iomgr/tcp_cfstream_sync.mm index e2b10f927b..0c371ea238 100644 --- a/src/core/lib/iomgr/tcp_cfstream_sync.mm +++ b/src/core/lib/iomgr/tcp_cfstream_sync.mm @@ -123,6 +123,12 @@ CFStreamSync::CFStreamSync(CFReadStreamRef read_stream, CFWriteStreamRef write_s CFWriteStreamScheduleWithRunLoop(write_stream, CFRunLoopGetMain(), kCFRunLoopCommonModes); } +CFStreamSync::~CFStreamSync() { + open_event_.DestroyEvent(); + read_event_.DestroyEvent(); + write_event_.DestroyEvent(); +} + void CFStreamSync::NotifyOnOpen(grpc_closure* closure) { open_event_.NotifyOn(closure); } void CFStreamSync::NotifyOnRead(grpc_closure* closure) { read_event_.NotifyOn(closure); } @@ -130,9 +136,9 @@ void CFStreamSync::NotifyOnRead(grpc_closure* closure) { read_event_.NotifyOn(cl void CFStreamSync::NotifyOnWrite(grpc_closure* closure) { write_event_.NotifyOn(closure); } void CFStreamSync::Shutdown(grpc_error* error) { - open_event_.SetShutdown(error); - read_event_.SetShutdown(error); - write_event_.SetShutdown(error); + open_event_.SetShutdown(GRPC_ERROR_REF(error)); + read_event_.SetShutdown(GRPC_ERROR_REF(error)); + write_event_.SetShutdown(GRPC_ERROR_REF(error)); GRPC_ERROR_UNREF(error); } |