summaryrefslogtreecommitdiffhomepage
path: root/test
diff options
context:
space:
mode:
authorZyad A. Ali <zyad.ali.me@gmail.com>2021-05-30 18:03:39 +0200
committerZyad A. Ali <zyad.ali.me@gmail.com>2021-07-13 22:12:02 +0200
commitc8851be593a7f0a8c22f53e44d2d46d71c3c142d (patch)
tree3dd312a2c1d356db3f7bd090140b2df3351fe1f4 /test
parent44c8766d2e8086c1f67f8c59391ddae60ac11299 (diff)
Add initial test cases for msgget(2).
Updates #135
Diffstat (limited to 'test')
-rw-r--r--test/syscalls/BUILD4
-rw-r--r--test/syscalls/linux/BUILD12
-rw-r--r--test/syscalls/linux/msgqueue.cc96
3 files changed, 112 insertions, 0 deletions
diff --git a/test/syscalls/BUILD b/test/syscalls/BUILD
index de08091af..bcf4c41a8 100644
--- a/test/syscalls/BUILD
+++ b/test/syscalls/BUILD
@@ -331,6 +331,10 @@ syscall_test(
)
syscall_test(
+ test = "//test/syscalls/linux:msgqueue_test",
+)
+
+syscall_test(
size = "medium",
test = "//test/syscalls/linux:msync_test",
)
diff --git a/test/syscalls/linux/BUILD b/test/syscalls/linux/BUILD
index 5ca655803..773688f44 100644
--- a/test/syscalls/linux/BUILD
+++ b/test/syscalls/linux/BUILD
@@ -4171,6 +4171,18 @@ cc_binary(
)
cc_binary(
+ name = "msgqueue_test",
+ testonly = 1,
+ srcs = ["msgqueue.cc"],
+ linkstatic = 1,
+ deps = [
+ "//test/util:temp_path",
+ "//test/util:test_main",
+ "//test/util:test_util",
+ ],
+)
+
+cc_binary(
name = "fadvise64_test",
testonly = 1,
srcs = ["fadvise64.cc"],
diff --git a/test/syscalls/linux/msgqueue.cc b/test/syscalls/linux/msgqueue.cc
new file mode 100644
index 000000000..ba61bba34
--- /dev/null
+++ b/test/syscalls/linux/msgqueue.cc
@@ -0,0 +1,96 @@
+// Copyright 2021 The gVisor Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include <sys/ipc.h>
+#include <sys/msg.h>
+#include <sys/types.h>
+
+#include "test/util/temp_path.h"
+#include "test/util/test_util.h"
+
+namespace gvisor {
+namespace testing {
+namespace {
+
+// Queue is a RAII class used to automatically clean message queues.
+class Queue {
+ public:
+ explicit Queue(int id) : id_(id) {}
+
+ ~Queue() {
+ if (id_ >= 0) {
+ EXPECT_THAT(msgctl(id_, IPC_RMID, nullptr), SyscallSucceeds());
+ }
+ }
+
+ int release() {
+ int old = id_;
+ id_ = -1;
+ return old;
+ }
+
+ int get() { return id_; }
+
+ private:
+ int id_ = -1;
+};
+
+// Test simple creation and retrieval for msgget(2).
+TEST(MsgqueueTest, MsgGet) {
+ // Don't run test until syscall is implemented.
+ GTEST_SKIP();
+
+ const TempPath keyfile = ASSERT_NO_ERRNO_AND_VALUE(TempPath::CreateFile());
+ const key_t key = ftok(keyfile.path().c_str(), 1);
+ ASSERT_THAT(key, SyscallSucceeds());
+
+ Queue queue(msgget(key, IPC_CREAT));
+ ASSERT_THAT(queue.get(), SyscallSucceeds());
+ EXPECT_THAT(msgget(key, 0), SyscallSucceedsWithValue(queue.get()));
+}
+
+// Test simple failure scenarios for msgget(2).
+TEST(MsgqueueTest, MsgGetFail) {
+ // Don't run test until syscall is implemented.
+ GTEST_SKIP();
+
+ const TempPath keyfile = ASSERT_NO_ERRNO_AND_VALUE(TempPath::CreateFile());
+ const key_t key = ftok(keyfile.path().c_str(), 1);
+ ASSERT_THAT(key, SyscallSucceeds());
+
+ EXPECT_THAT(msgget(key, 0), SyscallFailsWithErrno(ENOENT));
+
+ Queue queue(msgget(key, IPC_CREAT));
+ ASSERT_THAT(queue.get(), SyscallSucceeds());
+
+ EXPECT_THAT(msgget(key, IPC_CREAT | IPC_EXCL), SyscallFailsWithErrno(EEXIST));
+}
+
+// Test using msgget(2) with IPC_PRIVATE option.
+TEST(MsgqueueTest, MsgGetIpcPrivate) {
+ // Don't run test until syscall is implemented.
+ GTEST_SKIP();
+
+ Queue queue1(msgget(IPC_PRIVATE, 0));
+ ASSERT_THAT(queue1.get(), SyscallSucceeds());
+
+ Queue queue2(msgget(IPC_PRIVATE, 0));
+ ASSERT_THAT(queue2.get(), SyscallSucceeds());
+
+ EXPECT_NE(queue1.get(), queue2.get());
+}
+
+} // namespace
+} // namespace testing
+} // namespace gvisor