return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx
}

// Wrapper to restClient.CallWithMethod to handle network errors, in case of network error the connection is disconnected
// and a healthcheck routine gets invoked that would reconnect.
func (client *storageRESTClient) callGet(ctx context.Context, rpcMethod string, values url.Values, body io.Reader, length int64) (io.ReadCloser, error) {

    /** The object was not found */
    int NT_STATUS_OBJECT_NAME_NOT_FOUND = 0xC0000034;
    /** The object name already exists */
    int NT_STATUS_OBJECT_NAME_COLLISION = 0xC0000035;
    /** The port is disconnected */
    int NT_STATUS_PORT_DISCONNECTED = 0xC0000037;
    /** The object path is invalid */
    int NT_STATUS_OBJECT_PATH_INVALID = 0xC0000039;
    /** The object path was not found */

            throw new IOException("Timeout waiting for RDMA send credit");
        }
    }
    
    @Override
    public void disconnect() throws IOException {
        try {
            rdmaConnection.close();
        } finally {
            bufferManager.cleanup();
            super.disconnect();
        }
    }
    
    public RdmaProvider getProvider() {
        return provider;
    }
    

                // Check if connection has been idle too long
                // Note: getLastUseTime() method would need to be added to SmbTransportImpl
                // For now, we'll use a simple disconnected check
                if (transport.isDisconnected()) {
                    idle.add(transport);
                    log.debug("Removing idle connection: {}", transport);
                }
            } catch (Exception e) {

        
        executor.submit(() -> {
            try {
                log.info("Attempting to recover channel {}", channel.getChannelId());
                
                // Disconnect existing transport
                channel.getTransport().disconnect();
                
                // Create new transport
                SmbTransport newTransport = manager.createTransport(
                    channel.getLocalInterface(),

                client.close();
            } catch (final OpenSearchException e) {
                logger.warn("Failed to close OpenSearch client: address={}", address, e);
            }
            logger.info("Disconnected from {}", address);
        }
        connected = false;
    }

    /**
     * Gets the thread pool from the underlying client.
     *
     * @return The thread pool.
     */
    @Override

     *
     * If enabled, SmbFile instances starting with their first use will hold a reference to their tree.
     * This means that trees/sessions/connections won't be idle-disconnected even if there are no other active
     * references (currently executing code, file descriptors).
     *
     * Depending on the usage scenario, this may have some benefit as there won't be any delays for restablishing these

        assertEquals(ChannelState.DISCONNECTED, channelInfo.getState());
        assertFalse(channelInfo.isPrimary());
        assertEquals(0, channelInfo.getBytesSent());
        assertEquals(0, channelInfo.getBytesReceived());
    }

    @Test
    void testStateTransitions() {
        assertEquals(ChannelState.DISCONNECTED, channelInfo.getState());
        assertFalse(channelInfo.isHealthy());

				return nil
			}
			gridConn.Store(gc)
			return gc
		},
	}
}

// Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected
// permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints()
// after verifying format.json

                                    this.transport.disconnect(true);
                                } catch (IOException e1) {
                                    log.warn("Got NT_STATUS_USER_SESSION_DELETED, disconnected transport with error", e1);
                                }
                            }