fix up

Signed-off-by: SamYuan1990 <[email protected]>

src/brpc/policy/constant_concurrency_limiter.cpp

@@ -37,7 +37,7 @@ int ConstantConcurrencyLimiter::MaxConcurrency() {
 
 ConstantConcurrencyLimiter*
 ConstantConcurrencyLimiter::New(const AdaptiveMaxConcurrency& amc) const {
-    CHECK_EQ(amc.type(), AdaptiveMaxConcurrency.CONSTANT);
+    CHECK_EQ(amc.type(), AdaptiveMaxConcurrency::CONSTANT);
     return new ConstantConcurrencyLimiter(static_cast<int>(amc));
 }
 

src/brpc/server.cpp

@@ -738,7 +738,7 @@ static int get_port_from_fd(int fd) {
 
 bool Server::CreateConcurrencyLimiter(const AdaptiveMaxConcurrency& amc,
                                       ConcurrencyLimiter** out) {
-    if (amc.type() == AdaptiveMaxConcurrency.UNLIMITED) {
+    if (amc.type() == AdaptiveMaxConcurrency::UNLIMITED) {
         *out = NULL;
         return true;
     }
@@ -1086,7 +1086,7 @@ int Server::StartInternal(const butil::EndPoint& endpoint,
             it->second.status->SetConcurrencyLimiter(NULL);
         } else {
             const AdaptiveMaxConcurrency* amc = &it->second.max_concurrency;
-            if (amc->type() == AdaptiveMaxConcurrency.UNLIMITED) {
+            if (amc->type() == AdaptiveMaxConcurrency::UNLIMITED) {
                 amc = &_options.method_max_concurrency;
             }
             ConcurrencyLimiter* cl = NULL;

src/brpc/server.h

@@ -716,7 +716,7 @@ friend class Controller;
     int SetServiceMaxConcurrency(T* service) {
         if (NULL != service) {
             const AdaptiveMaxConcurrency* amc = &service->_max_concurrency;
-            if (amc->type() == AdaptiveMaxConcurrency.UNLIMITED) {
+            if (amc->type() == AdaptiveMaxConcurrency::UNLIMITED) {
                 amc = &_options.method_max_concurrency;
             }
             ConcurrencyLimiter* cl = NULL;

test/brpc_adaptive_class_unittest.cpp

@@ -31,13 +31,13 @@ const std::string kPooled = "PoOled";
 TEST(AdaptiveMaxConcurrencyTest, ShouldConvertCorrectly) {
     brpc::AdaptiveMaxConcurrency amc(0);
 
-    EXPECT_EQ(brpc::AdaptiveMaxConcurrency.UNLIMITED, amc.type());
-    EXPECT_EQ(brpc::AdaptiveMaxConcurrency.UNLIMITED, amc.value());
+    EXPECT_EQ(brpc::AdaptiveMaxConcurrency::UNLIMITED, amc.type());
+    EXPECT_EQ(brpc::AdaptiveMaxConcurrency::UNLIMITED, amc.value());
     EXPECT_EQ(0, int(amc));
-    EXPECT_TRUE(amc == brpc::AdaptiveMaxConcurrency.UNLIMITED);
+    EXPECT_TRUE(amc == brpc::AdaptiveMaxConcurrency::UNLIMITED);
 
     amc = 10;
-    EXPECT_EQ(brpc::AdaptiveMaxConcurrency.CONSTANT, amc.type());
+    EXPECT_EQ(brpc::AdaptiveMaxConcurrency::CONSTANT, amc.type());
     EXPECT_EQ("10", amc.value());
     EXPECT_EQ(10, int(amc));
     EXPECT_EQ(amc, "10");