Test adding multiple backends on different hosts.
| 29 | |
| 30 | /// Test adding multiple backends on different hosts. |
| 31 | TEST(ExecutorGroupTest, AddExecutors) { |
| 32 | ExecutorGroup group1("group1"); |
| 33 | ASSERT_EQ(0, group1.GetPerExecutorMemLimitForAdmission()); |
| 34 | |
| 35 | int64_t mem_limit_admission1 = 100L * MEGABYTE; |
| 36 | BackendDescriptorPB exec1 = MakeBackendDescriptor(1, group1, /* port_offset=*/0, |
| 37 | mem_limit_admission1); |
| 38 | group1.AddExecutor(exec1); |
| 39 | |
| 40 | int64_t mem_limit_admission2 = 120L * MEGABYTE; |
| 41 | BackendDescriptorPB exec2 = MakeBackendDescriptor(2, group1, /* port_offset=*/0, |
| 42 | mem_limit_admission2); |
| 43 | group1.AddExecutor(exec2); |
| 44 | |
| 45 | ASSERT_EQ(mem_limit_admission1, group1.GetPerExecutorMemLimitForAdmission()); |
| 46 | ASSERT_EQ(2, group1.NumExecutors()); |
| 47 | IpAddr backend_ip; |
| 48 | ASSERT_TRUE(group1.LookUpExecutorIp("host_1", &backend_ip)); |
| 49 | EXPECT_EQ("10.0.0.1", backend_ip); |
| 50 | ASSERT_TRUE(group1.LookUpExecutorIp("host_2", &backend_ip)); |
| 51 | EXPECT_EQ("10.0.0.2", backend_ip); |
| 52 | |
| 53 | AssertLookupById(exec1, exec2, group1); |
| 54 | } |
| 55 | |
| 56 | /// Test adding multiple backends on the same host. |
| 57 | TEST(ExecutorGroupTest, MultipleExecutorsOnSameHost) { |
nothing calls this directly
no test coverage detected