Update SessionManagerProcessor.cpp

vesoft-inc · Dec 8, 2023 · a202ca3 · a202ca3
1 parent a4be856
commit a202ca3
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/meta/processors/session/SessionManagerProcessor.cpp b/src/meta/processors/session/SessionManagerProcessor.cpp
@@ -8,7 +8,7 @@
 namespace nebula {
 namespace meta {
 
-void CreateSessionprocessor::process(const cpp2::CreateSessionReq &req) {
+void CreateSessionProcessor::process(const cpp2::CreateSessionReq &req) {
   auto user = req.get_user();
   cpp2::Session session;
   // The sessionId is generated by microsecond timestamp
@@ -53,7 +53,7 @@ void CreateSessionprocessor::process(const cpp2::CreateSessionReq &req) {
   kvstore_->asyncAtomicOp(kDefaultSpaceId, kDefaultPartId, std::move(getAtomicOp), std::move(cb));
 }
 
-void UpdateSessionsprocessor::process(const cpp2::UpdateSessionsReq &req) {
+void UpdateSessionsProcessor::process(const cpp2::UpdateSessionsReq &req) {
   // AtomicOp for update
   auto getAtomicOp = [this, req]() mutable {
     kvstore::MergeableAtomicOpResult atomicOp;
@@ -174,7 +174,7 @@ void GetSessionProcessor::process(const cpp2::GetSessionReq &req) {
   onFinished();
 }
 
-void RemoveSessionprocessor::process(const cpp2::RemoveSessionReq &req) {
+void RemoveSessionProcessor::process(const cpp2::RemoveSessionReq &req) {
   std::vector<SessionID> killedSessions;
   auto sessionIds = req.get_session_ids();
 
@@ -232,7 +232,7 @@ void RemoveSessionprocessor::process(const cpp2::RemoveSessionReq &req) {
   onFinished();
 }
 
-void KillQueryprocessor::process(const cpp2::KillQueryReq &req) {
+void KillQueryProcessor::process(const cpp2::KillQueryReq &req) {
   auto &killQueries = req.get_kill_queries();
   auto getAtomicOp = [this, killQueries] {
     kvstore::MergeableAtomicOpResult atomicOp;