summaryrefslogtreecommitdiff
path: root/src/threadpoolwork-inl.h
diff options
context:
space:
mode:
authorSam Roberts <vieuxtech@gmail.com>2019-05-22 09:42:25 -0700
committerSam Roberts <vieuxtech@gmail.com>2019-05-23 08:51:33 -0700
commit6ded4f2bad519d2c201c855b9ba87095bc29d71b (patch)
tree509c246445663d1100422911b4a0c786c16e1da8 /src/threadpoolwork-inl.h
parentcb1687241671732e91959c67202efa73139bd1e8 (diff)
downloadandroid-node-v8-6ded4f2bad519d2c201c855b9ba87095bc29d71b.tar.gz
android-node-v8-6ded4f2bad519d2c201c855b9ba87095bc29d71b.tar.bz2
android-node-v8-6ded4f2bad519d2c201c855b9ba87095bc29d71b.zip
src: move ThreadPoolWork inlines into a -inl.h
The presence of the inline definitions in node_internals.h can cause all files that include node_internals.h to depend on util-inl.h, even if they never use ThreadPoolWork. Whether this happens depends on the toolchain, gcc will strip unused definitions, clang won't. PR-URL: https://github.com/nodejs/node/pull/27755 Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Rich Trott <rtrott@gmail.com> Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: James M Snell <jasnell@gmail.com>
Diffstat (limited to 'src/threadpoolwork-inl.h')
-rw-r--r--src/threadpoolwork-inl.h57
1 files changed, 57 insertions, 0 deletions
diff --git a/src/threadpoolwork-inl.h b/src/threadpoolwork-inl.h
new file mode 100644
index 0000000000..8bba988b18
--- /dev/null
+++ b/src/threadpoolwork-inl.h
@@ -0,0 +1,57 @@
+// Copyright Joyent, Inc. and other Node contributors.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a
+// copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to permit
+// persons to whom the Software is furnished to do so, subject to the
+// following conditions:
+//
+// The above copyright notice and this permission notice shall be included
+// in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
+// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
+// USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+#ifndef SRC_THREADPOOLWORK_INL_H_
+#define SRC_THREADPOOLWORK_INL_H_
+
+#if defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS
+
+#include "util-inl.h"
+#include "node_internals.h"
+
+namespace node {
+
+void ThreadPoolWork::ScheduleWork() {
+ env_->IncreaseWaitingRequestCounter();
+ int status = uv_queue_work(
+ env_->event_loop(),
+ &work_req_,
+ [](uv_work_t* req) {
+ ThreadPoolWork* self = ContainerOf(&ThreadPoolWork::work_req_, req);
+ self->DoThreadPoolWork();
+ },
+ [](uv_work_t* req, int status) {
+ ThreadPoolWork* self = ContainerOf(&ThreadPoolWork::work_req_, req);
+ self->env_->DecreaseWaitingRequestCounter();
+ self->AfterThreadPoolWork(status);
+ });
+ CHECK_EQ(status, 0);
+}
+
+int ThreadPoolWork::CancelWork() {
+ return uv_cancel(reinterpret_cast<uv_req_t*>(&work_req_));
+}
+
+} // namespace node
+
+#endif // defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS
+
+#endif // SRC_THREADPOOLWORK_INL_H_