From a0c0eff723d68a5668f2a5bcfd1af77e8176d180 Mon Sep 17 00:00:00 2001
From: proller <proller@github.com>
Date: Fri, 27 Sep 2024 19:32:57 +0000
Subject: [PATCH] fix resize

---
 .../loadtest/lib/request_replay_fs.cpp        | 24 ++++++++++++++-----
 1 file changed, 18 insertions(+), 6 deletions(-)

diff --git a/cloud/filestore/tools/testing/loadtest/lib/request_replay_fs.cpp b/cloud/filestore/tools/testing/loadtest/lib/request_replay_fs.cpp
index 292f660b5c..109248430c 100644
--- a/cloud/filestore/tools/testing/loadtest/lib/request_replay_fs.cpp
+++ b/cloud/filestore/tools/testing/loadtest/lib/request_replay_fs.cpp
@@ -586,9 +586,13 @@ class TReplayRequestGeneratorFs final
                          << " fh.pos=" << fh.GetPosition());
         auto buffer = Acalloc(logRequest.GetRanges().cbegin()->GetBytes());
 
-        fh.Reserve(
-            logRequest.GetRanges().cbegin()->GetOffset() +
-            logRequest.GetRanges().cbegin()->GetBytes());
+        /*
+                if (!fh.GetLength()) {
+                    // incorrect aligned to read size, should use size from
+           nodeattr fh.Reserve( logRequest.GetRanges().cbegin()->GetOffset() +
+                        logRequest.GetRanges().cbegin()->GetBytes());
+                }
+        */
 
         TFileHandle FileHandle{fh.GetHandle()};
 
@@ -741,12 +745,15 @@ class TReplayRequestGeneratorFs final
                 TFileHandle fh(
                     fullName,
                     OpenAlways | (Spec.GetNoWrite() ? RdOnly : RdWr));
-                fh.Reserve(logRequest.GetNodeInfo().GetSize());
                 if (fh) {
                     nodeid = TFileStat{fh}.INode;
                 } else {
                     nodeid = TFileStat{fullName}.INode;
                 }
+
+                if (logRequest.GetNodeInfo().GetSize()) {
+                    fh.Reserve(logRequest.GetNodeInfo().GetSize());
+                }
             } break;
             case NProto::E_DIRECTORY_NODE: {
                 isDir = true;
@@ -915,10 +922,11 @@ class TReplayRequestGeneratorFs final
 
         TGuard<TMutex> guard(StateLock);
 
-        // TODO: by parent + name        //
+        // TODO: by ParentNodeId + NodeName        //
         // {"TimestampMcs":1726503153650998,"DurationMcs":7163,"RequestType":35,"ErrorCode":2147942422,"NodeInfo":{"NodeName":"security.capability","NewNodeName":"","NodeId":5,"Size":0}}
         // {"TimestampMcs":1726615533406265,"DurationMcs":192,"RequestType":33,"ErrorCode":2147942402,"NodeInfo":{"ParentNodeId":17033,"NodeName":"CPackSourceConfig.cmake","Flags":0,"Mode":0,"NodeId":0,"Handle":0,"Size":0}}
         // {"TimestampMcs":240399000,"DurationMcs":163,"RequestType":33,"NodeInfo":{"ParentNodeId":3,"NodeName":"branches","Flags":0,"Mode":0,"NodeId":0,"Handle":0,"Size":0}}
+        // {"TimestampMcs":1727464381415468,"DurationMcs":1982,"RequestType":33,"ErrorCode":2147942402,"NodeInfo":{"ParentNodeId":2,"NodeName":"libc.so.6","Flags":0,"Mode":0,"NodeId":0,"Handle":0,"Size":0}}
         // nfs     GetNodeAttr     0.006847s       S_OK    {parent_node_id=1,
         // node_name=freeminer, flags=0, mode=509, node_id=2, handle=0, size=0}
 
@@ -942,7 +950,11 @@ class TReplayRequestGeneratorFs final
             return MakeFuture(TCompletedRequest{
                 NProto::ACTION_GET_NODE_ATTR,
                 Started,
-                MakeError(E_CANCELLED, "cancelled")});
+                MakeError(
+                    E_NOT_FOUND,
+                    TStringBuilder{} << "Node not found "
+                                     << logRequest.GetNodeInfo().GetNodeId()
+                                     << " in " << NodesLogToLocal.size())});
         }
 
         auto fname = Spec.GetReplayRoot() + "/" + PathByNode(nodeid);