diff options
author | Craig Tiller <craig.tiller@gmail.com> | 2016-07-01 11:35:06 -0700 |
---|---|---|
committer | Craig Tiller <craig.tiller@gmail.com> | 2016-07-01 11:35:06 -0700 |
commit | bf6fd294d26e8a504d45f1f96ac1eb909bc367f4 (patch) | |
tree | 65d3db6273351a30ba8c3187caa298a3c8cbf8e0 | |
parent | b19ca30b43401cf5b550ba91498e6daced1dde6b (diff) |
Add a minimal (but correct) implementation of workqueue to Windows
-rw-r--r-- | src/core/lib/iomgr/workqueue_windows.c | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/src/core/lib/iomgr/workqueue_windows.c b/src/core/lib/iomgr/workqueue_windows.c index 275f040b1c..6dde80b0b2 100644 --- a/src/core/lib/iomgr/workqueue_windows.c +++ b/src/core/lib/iomgr/workqueue_windows.c @@ -37,4 +37,28 @@ #include "src/core/lib/iomgr/workqueue.h" +grpc_error *grpc_workqueue_create(grpc_exec_ctx *exec_ctx, grpc_workqueue **workqueue) { + return GRPC_ERROR_NONE; +} + +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) { +} +void grpc_workqueue_unref(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue, + 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_enqueue(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue, grpc_closure *closure, grpc_error *error) { + grpc_exec_ctx_sched(exec_ctx, closure, error, NULL); +} + #endif /* GPR_WINDOWS */ |