|
|
|
@ -37,7 +37,8 @@ |
|
|
|
|
|
|
|
|
|
#include "src/core/lib/iomgr/workqueue.h" |
|
|
|
|
|
|
|
|
|
grpc_error *grpc_workqueue_create(grpc_exec_ctx *exec_ctx, grpc_workqueue **workqueue) { |
|
|
|
|
grpc_error *grpc_workqueue_create(grpc_exec_ctx *exec_ctx, |
|
|
|
|
grpc_workqueue **workqueue) { |
|
|
|
|
return GRPC_ERROR_NONE; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -45,19 +46,20 @@ void grpc_workqueue_flush(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue) {} |
|
|
|
|
|
|
|
|
|
#ifdef GRPC_WORKQUEUE_REFCOUNT_DEBUG |
|
|
|
|
void grpc_workqueue_ref(grpc_workqueue *workqueue, const char *file, int line, |
|
|
|
|
const char *reason) { |
|
|
|
|
} |
|
|
|
|
const char *reason) {} |
|
|
|
|
void grpc_workqueue_unref(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue, |
|
|
|
|
const char *file, int line, const char *reason) { |
|
|
|
|
} |
|
|
|
|
const char *file, int line, const char *reason) {} |
|
|
|
|
#else |
|
|
|
|
void grpc_workqueue_ref(grpc_workqueue *workqueue) {} |
|
|
|
|
void grpc_workqueue_unref(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue) {} |
|
|
|
|
#endif |
|
|
|
|
|
|
|
|
|
void grpc_workqueue_add_to_pollset(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue, grpc_pollset *pollset) {} |
|
|
|
|
void grpc_workqueue_add_to_pollset(grpc_exec_ctx *exec_ctx, |
|
|
|
|
grpc_workqueue *workqueue, |
|
|
|
|
grpc_pollset *pollset) {} |
|
|
|
|
|
|
|
|
|
void grpc_workqueue_enqueue(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue, grpc_closure *closure, grpc_error *error) { |
|
|
|
|
void grpc_workqueue_enqueue(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue, |
|
|
|
|
grpc_closure *closure, grpc_error *error) { |
|
|
|
|
grpc_exec_ctx_sched(exec_ctx, closure, error, NULL); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|