pool/pool.go

@@ -1180,6 +1180,22 @@ func (c *clientWrapper) close() error {
 }
 
 func (c *clientStatusMonitor) handleError(ctx context.Context, st apistatus.Status, err error) error {
+	if stErr := apistatus.ErrFromStatus(st); stErr != nil {
+		switch stErr.(type) {
+		case *apistatus.ServerInternal,
+			*apistatus.WrongMagicNumber,
+			*apistatus.SignatureVerification,
+			*apistatus.NodeUnderMaintenance:
+			c.incErrorRate()
+		}
+
+		if err == nil {
+			err = stErr
+		}
+
+		return err
+	}
+
 	if err != nil {
 		if needCountError(ctx, err) {
 			c.incErrorRate()
@@ -1188,16 +1204,7 @@ func (c *clientStatusMonitor) handleError(ctx context.Context, st apistatus.Stat
 		return err
 	}
 
-	err = apistatus.ErrFromStatus(st)
-	switch err.(type) {
-	case *apistatus.ServerInternal,
-		*apistatus.WrongMagicNumber,
-		*apistatus.SignatureVerification,
-		*apistatus.NodeUnderMaintenance:
-		c.incErrorRate()
-	}
-
-	return err
+	return nil
 }
 
 func needCountError(ctx context.Context, err error) bool {

pool/pool_test.go

@@ -609,6 +609,23 @@ func TestHandleError(t *testing.T) {
 			expectedError: true,
 			countError:    false,
 		},
+		{
+			ctx:           ctx,
+			status:        new(apistatus.ObjectNotFound),
+			err:           &apistatus.ObjectNotFound{},
+			expectedError: true,
+			countError:    false,
+		},
+		{
+			ctx:           ctx,
+			status:        nil,
+			err:           &apistatus.EACLNotFound{},
+			expectedError: true,
+			// we expect error be counted because status is nil
+			// currently we assume that DisableFrostFSErrorResolution be always false for pool
+			// and status be checked first in handleError
+			countError: true,
+		},
 		{
 			ctx:           ctx,
 			status:        new(apistatus.ServerInternal),

pool/tree/pool.go

@@ -836,6 +836,11 @@ LOOP:
 				if startI != indexI || startJ != indexJ {
 					p.setStartIndices(indexI, indexJ)
 				}
+
+				if err != nil {
+					err = fmt.Errorf("address %s: %w", p.innerPools[indexI].clients[indexJ].endpoint(), err)
+				}
+
 				return err
 			}