share queue test

chaoqin-li1123 · chaoqin-li1123 · commit 065da3f7a93e · 2021-11-15T03:11:31.000Z
Signed-off-by: chaoqin-li1123 &lt;chaoqinli@google.com&gt;
diff --git a/test/wasm_test.cc b/test/wasm_test.cc
@@ -182,13 +182,15 @@ TEST_P(WasmTest, SharedQueueProducerConsumer) {
   EXPECT_EQ(root_context2->lookupSharedQueue(vm_id_, queue_name, &token2), WasmResult::Ok);
   EXPECT_EQ(token1, token2);
   for (int i = 0; i < 5; i++) {
-    root_context1->enqueueSharedQueue(token1, std::to_string(i));
+    EXPECT_EQ(root_context1->enqueueSharedQueue(token1, std::to_string(i)), WasmResult::Ok);
   }
   std::string data;
   for (int i = 0; i < 5; i++) {
-    root_context1->dequeueSharedQueue(token1, &data);
+    EXPECT_EQ(root_context2->dequeueSharedQueue(token1, &data), WasmResult::Ok);
     EXPECT_EQ(data, std::to_string(i));
   }
+  EXPECT_EQ(root_context2->dequeueSharedQueue(token1, &data), WasmResult::Empty);
+  EXPECT_EQ(root_context2->dequeueSharedQueue(10086, &data), WasmResult::NotFound);
 }
 
 } // namespace proxy_wasm

Original file line number	Diff line number	Diff line change
`@@ -182,13 +182,15 @@ TEST_P(WasmTest, SharedQueueProducerConsumer) {`
`182`	`182`	`EXPECT_EQ(root_context2->lookupSharedQueue(vm_id_, queue_name, &token2), WasmResult::Ok);`
`183`	`183`	`EXPECT_EQ(token1, token2);`
`184`	`184`	`for (int i = 0; i < 5; i++) {`
`185`		`- root_context1->enqueueSharedQueue(token1, std::to_string(i));`
	`185`	`+ EXPECT_EQ(root_context1->enqueueSharedQueue(token1, std::to_string(i)), WasmResult::Ok);`
`186`	`186`	`}`
`187`	`187`	`std::string data;`
`188`	`188`	`for (int i = 0; i < 5; i++) {`
`189`		`- root_context1->dequeueSharedQueue(token1, &data);`
	`189`	`+ EXPECT_EQ(root_context2->dequeueSharedQueue(token1, &data), WasmResult::Ok);`
`190`	`190`	`EXPECT_EQ(data, std::to_string(i));`
`191`	`191`	`}`
	`192`	`+ EXPECT_EQ(root_context2->dequeueSharedQueue(token1, &data), WasmResult::Empty);`
	`193`	`+ EXPECT_EQ(root_context2->dequeueSharedQueue(10086, &data), WasmResult::NotFound);`
`192`	`194`	`}`
`193`	`195`
`194`	`196`	`} // namespace proxy_wasm`