MCPcopy Create free account
hub / github.com/apache/mesos / TEST

Function TEST

src/tests/log_tests.cpp:84–129  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

82
83
84TEST(NetworkTest, Watch)
85{
86 UPID pid1 = ProcessBase().self();
87 UPID pid2 = ProcessBase().self();
88
89 Network network;
90
91 // Test the default parameter.
92 Future<size_t> future = network.watch(1u);
93 AWAIT_READY(future);
94 EXPECT_EQ(0u, future.get());
95
96 future = network.watch(2u, Network::NOT_EQUAL_TO);
97 AWAIT_READY(future);
98 EXPECT_EQ(0u, future.get());
99
100 future = network.watch(0u, Network::GREATER_THAN_OR_EQUAL_TO);
101 AWAIT_READY(future);
102 EXPECT_EQ(0u, future.get());
103
104 future = network.watch(1u, Network::LESS_THAN);
105 AWAIT_READY(future);
106 EXPECT_EQ(0u, future.get());
107
108 network.add(pid1);
109
110 future = network.watch(1u, Network::EQUAL_TO);
111 AWAIT_READY(future);
112 EXPECT_EQ(1u, future.get());
113
114 future = network.watch(1u, Network::GREATER_THAN);
115 ASSERT_TRUE(future.isPending());
116
117 network.add(pid2);
118
119 AWAIT_READY(future);
120 EXPECT_EQ(2u, future.get());
121
122 future = network.watch(1u, Network::LESS_THAN_OR_EQUAL_TO);
123 ASSERT_TRUE(future.isPending());
124
125 network.remove(pid2);
126
127 AWAIT_READY(future);
128 EXPECT_EQ(1u, future.get());
129}
130
131
132template <typename T>

Callers

nothing calls this directly

Calls 7

ProcessBaseClass · 0.50
selfMethod · 0.45
watchMethod · 0.45
getMethod · 0.45
addMethod · 0.45
isPendingMethod · 0.45
removeMethod · 0.45

Tested by

no test coverage detected