File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed
packages/client/lib/client Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -87,6 +87,7 @@ export default class RedisCommandsQueue {
87
87
this . #maintenanceCommandTimeout = ms ;
88
88
89
89
let counter = 0 ;
90
+ const total = this . #toWrite. length ;
90
91
91
92
// Overwrite timeouts of all eligible toWrite commands
92
93
for ( const node of this . #toWrite. nodes ( ) ) {
@@ -114,7 +115,7 @@ export default class RedisCommandsQueue {
114
115
} ;
115
116
signal . addEventListener ( 'abort' , command . timeout . listener , { once : true } ) ;
116
117
} ;
117
- dbgMaintenance ( `Total of ${ counter } timeouts reset to ${ ms } ` ) ;
118
+ dbgMaintenance ( `Total of ${ counter } of ${ total } timeouts reset to ${ ms } ` ) ;
118
119
}
119
120
120
121
get isPubSubActive ( ) {
Original file line number Diff line number Diff line change @@ -182,9 +182,8 @@ export default class EnterpriseMaintenanceManager {
182
182
this . #client. _pause ( ) ;
183
183
184
184
dbgMaintenance ( "Creating new tmp client" ) ;
185
- const start = performance . now ( ) ;
185
+ let start = performance . now ( ) ;
186
186
const tmpClient = this . #client. duplicate ( {
187
- maintPushNotifications : "disabled" ,
188
187
socket : {
189
188
...this . #options. socket ,
190
189
host,
@@ -193,8 +192,9 @@ export default class EnterpriseMaintenanceManager {
193
192
} ) ;
194
193
dbgMaintenance ( `Tmp client created in ${ ( performance . now ( ) - start ) . toFixed ( 2 ) } ms` ) ;
195
194
dbgMaintenance ( `Connecting tmp client: ${ host } :${ port } ` ) ;
195
+ start = performance . now ( ) ;
196
196
await tmpClient . connect ( ) ;
197
- dbgMaintenance ( `Connected to tmp client` ) ;
197
+ dbgMaintenance ( `Connected to tmp client in ${ ( performance . now ( ) - start ) . toFixed ( 2 ) } ms ` ) ;
198
198
// 3 [EVENT] New socket connected
199
199
200
200
//TODO
You can’t perform that action at this time.
0 commit comments