change flag name from Controller::FLAGS_ADDED_CONCURRENCY to FLAGS_CONCURRENCY_LIMITER_REQUESTED

src/brpc/controller.h

@@ -115,8 +115,8 @@ friend void policy::ProcessThriftRequest(InputMessageBase*);
     // << Flags >>
     static const uint32_t FLAGS_IGNORE_EOVERCROWDED = 1;
     static const uint32_t FLAGS_SECURITY_MODE = (1 << 1);
-    // Incremented Server._concurrency
-    static const uint32_t FLAGS_ADDED_CONCURRENCY = (1 << 2);
+    // Called Server._cl->OnRequested()
+    static const uint32_t FLAGS_CONCURRENCY_LIMITER_REQUESTED = (1 << 2);
     static const uint32_t FLAGS_READ_PROGRESSIVELY = (1 << 3);
     static const uint32_t FLAGS_PROGRESSIVE_READER = (1 << 4);
     static const uint32_t FLAGS_BACKUP_REQUEST = (1 << 5);

src/brpc/details/server_private_accessor.h

@@ -41,14 +41,14 @@ public:
     // Returns true if the `max_concurrency' limit is not reached.
     bool AddConcurrency(Controller* c) {
         if (NULL != _server->_cl) {
-            c->add_flag(Controller::FLAGS_ADDED_CONCURRENCY);
+            c->add_flag(Controller::FLAGS_CONCURRENCY_LIMITER_REQUESTED);
             return _server->_cl->OnRequested();
         } 
         return true;
     }
 
     void RemoveConcurrency(const Controller* c) {
-        if (c->has_flag(Controller::FLAGS_ADDED_CONCURRENCY)){
+        if (c->has_flag(Controller::FLAGS_CONCURRENCY_LIMITER_REQUESTED)){
             CHECK(_server->_cl != NULL);
             _server->_cl->OnResponded(c->ErrorCode(), c->latency_us());
         }