testme

ydb-platform · Feb 4, 2025 · c77a034 · c77a034
1 parent a6640cf
commit c77a034
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 6 deletions.
diff --git a/cloud/filestore/apps/client/lib/create_session.cpp b/cloud/filestore/apps/client/lib/create_session.cpp
@@ -50,7 +50,7 @@ class TCreateSessionCommand final
         request->MutableHeaders()->SetClientId(ClientId);
         request->MutableHeaders()->SetSessionSeqNo(SeqNo);
 
-        TCallContextPtr ctx = MakeIntrusive<TCallContext>();
+        TCallContextPtr ctx = MakeIntrusive<TCallContext>(FileSystemId);
         auto response = WaitFor(Client->CreateSession(ctx, std::move(request)));
         CheckResponse(response);
         Print(response, JsonOutput);

diff --git a/cloud/filestore/apps/client/lib/destroy_session.cpp b/cloud/filestore/apps/client/lib/destroy_session.cpp
@@ -50,7 +50,7 @@ class TDestroySessionCommand final
         request->MutableHeaders()->SetClientId(ClientId);
         request->MutableHeaders()->SetSessionSeqNo(SeqNo);
 
-        TCallContextPtr ctx = MakeIntrusive<TCallContext>();
+        TCallContextPtr ctx = MakeIntrusive<TCallContext>(FileSystemId);
         auto response = WaitFor(Client->DestroySession(ctx, std::move(request)));
         CheckResponse(response);
         Print(response, JsonOutput);

diff --git a/cloud/filestore/apps/client/lib/forced_compaction.cpp b/cloud/filestore/apps/client/lib/forced_compaction.cpp
@@ -38,7 +38,7 @@ class TForcedCompactionCommand final
         STORAGE_DEBUG("Sending ExecuteAction request");
         const auto requestId = GetRequestId(*request);
         auto result = WaitFor(Client->ExecuteAction(
-            MakeIntrusive<TCallContext>(requestId),
+            MakeIntrusive<TCallContext>(FileSystemId, requestId),
             std::move(request)));
 
         STORAGE_DEBUG("Received ExecuteAction response");

diff --git a/cloud/filestore/libs/diagnostics/profile_log.cpp b/cloud/filestore/libs/diagnostics/profile_log.cpp
@@ -76,15 +76,17 @@ void TProfileLog::Stop()
 
 void TProfileLog::Write(TRecord record)
 {
-    // TODO(proller): Remove debug after bug fix 
-    //STORAGE_VERIFY_DEBUG_C(record.FileSystemId.empty(), "", "", "Missing filesystem id in profile log");
     static bool reported = false;
     if (!reported && record.FileSystemId.empty()) {
         reported = true;
+DUMP("profile log write without fs", record.Request.ShortDebugString().Quote());
         Cerr << "Profile log record without filesystem id. Trace:\n";
         PrintBackTrace();
     }
 
+    // TODO(proller): Remove debug after bug fix 
+    STORAGE_VERIFY_DEBUG_C(!record.FileSystemId.empty(), "", record.FileSystemId, "Missing filesystem id in profile log");
+
     Records.Enqueue(std::move(record));
 }
 

diff --git a/cloud/filestore/tools/testing/loadtest/lib/request_data.cpp b/cloud/filestore/tools/testing/loadtest/lib/request_data.cpp
@@ -597,6 +597,7 @@ class TDataRequestGenerator final
     TIntrusivePtr<TCallContext> CreateCallContext()
     {
         return MakeIntrusive<TCallContext>(
+            FileSystemId,
             LastRequestId.fetch_add(1, std::memory_order_relaxed));
     }
 

diff --git a/cloud/filestore/tools/testing/loadtest/lib/request_index.cpp b/cloud/filestore/tools/testing/loadtest/lib/request_index.cpp
@@ -653,7 +653,7 @@ class TIndexRequestGenerator final
 
     TIntrusivePtr<TCallContext> CreateCallContext()
     {
-        return MakeIntrusive<TCallContext>(AtomicIncrement(LastRequestId));
+        return MakeIntrusive<TCallContext>(FileSystemId, AtomicIncrement(LastRequestId));
     }
 };
-Original file line number
+Diff line change
@@ Expand Up / @@ -653,7 +653,7 @@ class TIndexRequestGenerator final @@
         TIntrusivePtr<TCallContext> CreateCallContext()
         {
-            return MakeIntrusive<TCallContext>(AtomicIncrement(LastRequestId));
+            return MakeIntrusive<TCallContext>(FileSystemId, AtomicIncrement(LastRequestId));
         }
     };
@@ Expand Down @@