Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(828)

Unified Diff: mojo/public/cpp/system/wait_set.h

Issue 2109843002: Add C++ wrappers for the wait set functions. (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/public/cpp/system/tests/core_unittest.cc ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/public/cpp/system/wait_set.h
diff --git a/mojo/public/cpp/system/wait_set.h b/mojo/public/cpp/system/wait_set.h
new file mode 100644
index 0000000000000000000000000000000000000000..66ef979ea3d48a8702eec2dbf3dc5a3538080c46
--- /dev/null
+++ b/mojo/public/cpp/system/wait_set.h
@@ -0,0 +1,85 @@
+// Copyright 2016 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+// This file provides a C++ wrapping around the Mojo C API for wait sets,
+// replacing the prefix of "Mojo" with a "mojo" namespace, and using more
+// strongly-typed representations of |MojoHandle|s.
+//
+// Please see "mojo/public/c/system/wait_set.h" for complete documentation of
+// the API.
+
+#ifndef MOJO_PUBLIC_CPP_SYSTEM_WAIT_SET_H_
+#define MOJO_PUBLIC_CPP_SYSTEM_WAIT_SET_H_
+
+#include <assert.h>
+
+#include <vector>
+
+#include "mojo/public/c/system/wait_set.h"
+#include "mojo/public/cpp/system/handle.h"
+
+namespace mojo {
+
+// A strongly-typed representation of a |MojoHandle| to a wait set.
+class WaitSetHandle : public Handle {
+ public:
+ WaitSetHandle() {}
+ explicit WaitSetHandle(MojoHandle value) : Handle(value) {}
+
+ // Copying and assignment allowed.
+};
+
+static_assert(sizeof(WaitSetHandle) == sizeof(Handle),
+ "Bad size for C++ WaitSetHandle");
+
+typedef ScopedHandleBase<WaitSetHandle> ScopedWaitSetHandle;
+static_assert(sizeof(ScopedWaitSetHandle) == sizeof(WaitSetHandle),
+ "Bad size for C++ ScopedWaitSetHandle");
+
+// Creates a new wait set. See |MojoCreateWaitSet()| for complete documentation.
+inline MojoResult CreateWaitSet(const MojoCreateWaitSetOptions* options,
+ ScopedWaitSetHandle* wait_set) {
+ assert(wait_set);
+ WaitSetHandle wait_set_handle;
+ MojoResult rv = MojoCreateWaitSet(options, wait_set_handle.mutable_value());
+ // Reset even on failure (reduces the chances that a "stale"/incorrect handle
+ // will be used).
+ wait_set->reset(wait_set_handle);
+ return rv;
+}
+
+inline MojoResult WaitSetAdd(WaitSetHandle wait_set,
+ Handle handle,
+ MojoHandleSignals signals,
+ uint64_t cookie,
+ const struct MojoWaitSetAddOptions* options) {
+ return MojoWaitSetAdd(wait_set.value(), handle.value(), signals, cookie,
+ options);
+}
+
+inline MojoResult WaitSetRemove(WaitSetHandle wait_set, uint64_t cookie) {
+ return MojoWaitSetRemove(wait_set.value(), cookie);
+}
+
+inline MojoResult WaitSetWait(WaitSetHandle wait_set,
+ MojoDeadline deadline,
+ std::vector<MojoWaitSetResult>* results,
+ uint32_t* max_results) {
+ if (!results) {
+ return MojoWaitSetWait(wait_set.value(), deadline, 0u, nullptr,
+ max_results);
+ }
+
+ assert(results->capacity() <= static_cast<uint32_t>(-1));
+ uint32_t num_results = static_cast<uint32_t>(results->capacity());
+ results->resize(num_results);
+ MojoResult rv = MojoWaitSetWait(wait_set.value(), deadline, &num_results,
+ results->data(), max_results);
+ results->resize((rv == MOJO_RESULT_OK) ? num_results : 0u);
+ return rv;
+}
+
+} // namespace mojo
+
+#endif // MOJO_PUBLIC_CPP_SYSTEM_WAIT_SET_H_
« no previous file with comments | « mojo/public/cpp/system/tests/core_unittest.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698