@@ -75,6 +75,7 @@ func (st *StatsConn) ListDir(ctx context.Context, dirPath string, full bool) ([]
75
75
}
76
76
defer st .readSem .Release (1 )
77
77
topoStatsConnReadWaitTimings .Record (statsKey , startTime )
78
+ startTime = time .Now () // reset
78
79
defer topoStatsConnTimings .Record (statsKey , startTime )
79
80
res , err := st .conn .ListDir (ctx , dirPath , full )
80
81
if err != nil {
@@ -125,6 +126,7 @@ func (st *StatsConn) Get(ctx context.Context, filePath string) ([]byte, Version,
125
126
}
126
127
defer st .readSem .Release (1 )
127
128
topoStatsConnReadWaitTimings .Record (statsKey , startTime )
129
+ startTime = time .Now () // reset
128
130
defer topoStatsConnTimings .Record (statsKey , startTime )
129
131
bytes , version , err := st .conn .Get (ctx , filePath )
130
132
if err != nil {
@@ -143,6 +145,7 @@ func (st *StatsConn) List(ctx context.Context, filePathPrefix string) ([]KVInfo,
143
145
}
144
146
defer st .readSem .Release (1 )
145
147
topoStatsConnReadWaitTimings .Record (statsKey , startTime )
148
+ startTime = time .Now () // reset
146
149
defer topoStatsConnTimings .Record (statsKey , startTime )
147
150
bytes , err := st .conn .List (ctx , filePathPrefix )
148
151
if err != nil {
0 commit comments