|
|
|
@ -132,7 +132,7 @@ static void CallReadCb(CFStreamEndpoint* ep, grpc_error* error) { |
|
|
|
|
grpc_closure* cb = ep->read_cb; |
|
|
|
|
ep->read_cb = nullptr; |
|
|
|
|
ep->read_slices = nullptr; |
|
|
|
|
ExecCtx::Run(DEBUG_LOCATION, cb, error); |
|
|
|
|
grpc_core::ExecCtx::Run(DEBUG_LOCATION, cb, error); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void CallWriteCb(CFStreamEndpoint* ep, grpc_error* error) { |
|
|
|
@ -145,7 +145,7 @@ static void CallWriteCb(CFStreamEndpoint* ep, grpc_error* error) { |
|
|
|
|
grpc_closure* cb = ep->write_cb; |
|
|
|
|
ep->write_cb = nullptr; |
|
|
|
|
ep->write_slices = nullptr; |
|
|
|
|
ExecCtx::Run(DEBUG_LOCATION, cb, error); |
|
|
|
|
grpc_core::ExecCtx::Run(DEBUG_LOCATION, cb, error); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void ReadAction(void* arg, grpc_error* error) { |
|
|
|
|