1*ec63e07aSXin Li // Copyright 2020 Google LLC
2*ec63e07aSXin Li //
3*ec63e07aSXin Li // Licensed under the Apache License, Version 2.0 (the "License");
4*ec63e07aSXin Li // you may not use this file except in compliance with the License.
5*ec63e07aSXin Li // You may obtain a copy of the License at
6*ec63e07aSXin Li //
7*ec63e07aSXin Li // https://www.apache.org/licenses/LICENSE-2.0
8*ec63e07aSXin Li //
9*ec63e07aSXin Li // Unless required by applicable law or agreed to in writing, software
10*ec63e07aSXin Li // distributed under the License is distributed on an "AS IS" BASIS,
11*ec63e07aSXin Li // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12*ec63e07aSXin Li // See the License for the specific language governing permissions and
13*ec63e07aSXin Li // limitations under the License.
14*ec63e07aSXin Li
15*ec63e07aSXin Li #include <linux/futex.h>
16*ec63e07aSXin Li #include <syscall.h>
17*ec63e07aSXin Li #include <uv.h>
18*ec63e07aSXin Li
19*ec63e07aSXin Li #include "gtest/gtest.h"
20*ec63e07aSXin Li #include "absl/flags/flag.h"
21*ec63e07aSXin Li #include "sandboxed_api/util/status_matchers.h"
22*ec63e07aSXin Li #include "uv_sapi.sapi.h" // NOLINT(build/include)
23*ec63e07aSXin Li
24*ec63e07aSXin Li namespace {
25*ec63e07aSXin Li
26*ec63e07aSXin Li class UVTestLoopSapiSandbox : public uv::UVSandbox {
27*ec63e07aSXin Li private:
ModifyPolicy(sandbox2::PolicyBuilder *)28*ec63e07aSXin Li std::unique_ptr<sandbox2::Policy> ModifyPolicy(
29*ec63e07aSXin Li sandbox2::PolicyBuilder*) override {
30*ec63e07aSXin Li return sandbox2::PolicyBuilder()
31*ec63e07aSXin Li .AllowDynamicStartup()
32*ec63e07aSXin Li .AllowExit()
33*ec63e07aSXin Li .AllowFutexOp(FUTEX_WAKE_PRIVATE)
34*ec63e07aSXin Li .AllowSyscalls({__NR_epoll_create1, __NR_eventfd2, __NR_pipe2})
35*ec63e07aSXin Li .AllowWrite()
36*ec63e07aSXin Li .BuildOrDie();
37*ec63e07aSXin Li }
38*ec63e07aSXin Li };
39*ec63e07aSXin Li
40*ec63e07aSXin Li class UVTestLoop : public ::testing::Test {
41*ec63e07aSXin Li protected:
SetUp()42*ec63e07aSXin Li void SetUp() override {
43*ec63e07aSXin Li sandbox_ = std::make_unique<UVTestLoopSapiSandbox>();
44*ec63e07aSXin Li ASSERT_THAT(sandbox_->Init(), sapi::IsOk());
45*ec63e07aSXin Li api_ = std::make_unique<uv::UVApi>(sandbox_.get());
46*ec63e07aSXin Li }
47*ec63e07aSXin Li
48*ec63e07aSXin Li // Check sapi_uv_loop_init
UVLoopInit(sapi::v::Ptr * loop)49*ec63e07aSXin Li void UVLoopInit(sapi::v::Ptr* loop) {
50*ec63e07aSXin Li SAPI_ASSERT_OK_AND_ASSIGN(int error_code, api_->sapi_uv_loop_init(loop));
51*ec63e07aSXin Li ASSERT_EQ(error_code, 0);
52*ec63e07aSXin Li }
53*ec63e07aSXin Li
54*ec63e07aSXin Li // Check sapi_uv_run
UVRun(sapi::v::Ptr * loop)55*ec63e07aSXin Li void UVRun(sapi::v::Ptr* loop) {
56*ec63e07aSXin Li SAPI_ASSERT_OK_AND_ASSIGN(int error_code,
57*ec63e07aSXin Li api_->sapi_uv_run(loop, UV_RUN_DEFAULT));
58*ec63e07aSXin Li ASSERT_EQ(error_code, 0);
59*ec63e07aSXin Li }
60*ec63e07aSXin Li
61*ec63e07aSXin Li // Check sapi_uv_loop_close
UVLoopClose(sapi::v::Ptr * loop)62*ec63e07aSXin Li void UVLoopClose(sapi::v::Ptr* loop) {
63*ec63e07aSXin Li SAPI_ASSERT_OK_AND_ASSIGN(int error_code, api_->sapi_uv_loop_close(loop));
64*ec63e07aSXin Li ASSERT_EQ(error_code, 0);
65*ec63e07aSXin Li }
66*ec63e07aSXin Li
67*ec63e07aSXin Li // Check sapi_uv_default_loop, set loop to default loop
UVDefaultLoop(sapi::v::Ptr * loop)68*ec63e07aSXin Li void UVDefaultLoop(sapi::v::Ptr* loop) {
69*ec63e07aSXin Li SAPI_ASSERT_OK_AND_ASSIGN(void* loop_voidptr, api_->sapi_uv_default_loop());
70*ec63e07aSXin Li loop->SetRemote(loop_voidptr);
71*ec63e07aSXin Li }
72*ec63e07aSXin Li
73*ec63e07aSXin Li std::unique_ptr<UVTestLoopSapiSandbox> sandbox_;
74*ec63e07aSXin Li std::unique_ptr<uv::UVApi> api_;
75*ec63e07aSXin Li };
76*ec63e07aSXin Li
TEST_F(UVTestLoop,InitLoop)77*ec63e07aSXin Li TEST_F(UVTestLoop, InitLoop) {
78*ec63e07aSXin Li // Allocate memory for loop
79*ec63e07aSXin Li void* loop_voidptr;
80*ec63e07aSXin Li ASSERT_THAT(
81*ec63e07aSXin Li sandbox_->rpc_channel()->Allocate(sizeof(uv_loop_t), &loop_voidptr),
82*ec63e07aSXin Li sapi::IsOk());
83*ec63e07aSXin Li sapi::v::RemotePtr loop(loop_voidptr);
84*ec63e07aSXin Li
85*ec63e07aSXin Li // Initialize, run and close the manually initialized loop
86*ec63e07aSXin Li UVLoopInit(loop.PtrBoth());
87*ec63e07aSXin Li UVRun(loop.PtrNone());
88*ec63e07aSXin Li UVLoopClose(loop.PtrNone());
89*ec63e07aSXin Li
90*ec63e07aSXin Li // Free loop memory
91*ec63e07aSXin Li ASSERT_THAT(sandbox_->rpc_channel()->Free(loop_voidptr), sapi::IsOk());
92*ec63e07aSXin Li }
93*ec63e07aSXin Li
TEST_F(UVTestLoop,DefaultLoop)94*ec63e07aSXin Li TEST_F(UVTestLoop, DefaultLoop) {
95*ec63e07aSXin Li sapi::v::RemotePtr loop(nullptr);
96*ec63e07aSXin Li
97*ec63e07aSXin Li // Run the default loop
98*ec63e07aSXin Li UVDefaultLoop(&loop);
99*ec63e07aSXin Li UVRun(loop.PtrNone());
100*ec63e07aSXin Li
101*ec63e07aSXin Li // Close the default loop
102*ec63e07aSXin Li UVDefaultLoop(&loop);
103*ec63e07aSXin Li UVLoopClose(loop.PtrNone());
104*ec63e07aSXin Li }
105*ec63e07aSXin Li
106*ec63e07aSXin Li } // namespace
107