@Test public void testStandardCase() throws Exception { DIRClient client = new DIRClient(testEnv.getDirClient(), servers, 10, 2); AddressMappingSet result = client.xtreemfs_address_mappings_get(null, RPCAuthentication.authNone, RPCAuthentication.userService, "*"); assertEquals(0, result.getMappingsCount()); }
public AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader, final UserCredentials userCreds, final String uuid) throws IOException, InterruptedException { return xtreemfs_address_mappings_get(server, authHeader, userCreds, uuid, maxRetries); }
DIRClient implements TimeServerClient { public AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader, final UserCredentials userCreds, final String uuid) throws IOException, InterruptedException { return xtreemfs_address_mappings_get(server, authHeader, userCreds, uuid, maxRetries); } }
DIRClient implements TimeServerClient { public AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader, final UserCredentials userCreds, final String uuid) throws IOException, InterruptedException { return xtreemfs_address_mappings_get(server, authHeader, userCreds, uuid, maxRetries); } DIRClient(DIRServiceClient rpcClient, InetSocketAddress[] servers, int maxRetries, int retryWaitMs); }
DIRClient implements TimeServerClient { public AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader, final UserCredentials userCreds, final String uuid) throws IOException, InterruptedException { return xtreemfs_address_mappings_get(server, authHeader, userCreds, uuid, maxRetries); } DIRClient(DIRServiceClient rpcClient, InetSocketAddress[] servers, int maxRetries, int retryWaitMs); AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); void xtreemfs_address_mappings_remove(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); void xtreemfs_address_mappings_remove(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final List<AddressMapping> mappings); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final List<AddressMapping> mappings, int maxRetries); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final AddressMappingSet input); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final AddressMappingSet input, int maxRetries); void xtreemfs_service_deregister(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); void xtreemfs_service_deregister(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); void xtreemfs_service_offline(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name); void xtreemfs_service_offline(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name, int maxRetries); ServiceSet xtreemfs_service_get_by_name(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name); ServiceSet xtreemfs_service_get_by_name(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name, int maxRetries); ServiceSet xtreemfs_service_get_by_uuid(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); ServiceSet xtreemfs_service_get_by_uuid(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); ServiceSet xtreemfs_service_get_by_type(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final ServiceType type); ServiceSet xtreemfs_service_get_by_type(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final ServiceType type, int maxRetries); serviceRegisterResponse xtreemfs_service_register(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Service service); serviceRegisterResponse xtreemfs_service_register(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Service service, int maxRetries); Configuration xtreemfs_configuration_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); Configuration xtreemfs_configuration_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); configurationSetResponse xtreemfs_configuration_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Configuration config); configurationSetResponse xtreemfs_configuration_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Configuration config, int maxRetries); @Override long xtreemfs_global_time_get(InetSocketAddress server); long xtreemfs_global_time_get(); boolean clientIsAlive(); }
DIRClient implements TimeServerClient { public AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader, final UserCredentials userCreds, final String uuid) throws IOException, InterruptedException { return xtreemfs_address_mappings_get(server, authHeader, userCreds, uuid, maxRetries); } DIRClient(DIRServiceClient rpcClient, InetSocketAddress[] servers, int maxRetries, int retryWaitMs); AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); AddressMappingSet xtreemfs_address_mappings_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); void xtreemfs_address_mappings_remove(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); void xtreemfs_address_mappings_remove(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final List<AddressMapping> mappings); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final List<AddressMapping> mappings, int maxRetries); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final AddressMappingSet input); addressMappingSetResponse xtreemfs_address_mappings_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final AddressMappingSet input, int maxRetries); void xtreemfs_service_deregister(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); void xtreemfs_service_deregister(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); void xtreemfs_service_offline(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name); void xtreemfs_service_offline(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name, int maxRetries); ServiceSet xtreemfs_service_get_by_name(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name); ServiceSet xtreemfs_service_get_by_name(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String name, int maxRetries); ServiceSet xtreemfs_service_get_by_uuid(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); ServiceSet xtreemfs_service_get_by_uuid(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); ServiceSet xtreemfs_service_get_by_type(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final ServiceType type); ServiceSet xtreemfs_service_get_by_type(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final ServiceType type, int maxRetries); serviceRegisterResponse xtreemfs_service_register(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Service service); serviceRegisterResponse xtreemfs_service_register(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Service service, int maxRetries); Configuration xtreemfs_configuration_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid); Configuration xtreemfs_configuration_get(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final String uuid, int maxRetries); configurationSetResponse xtreemfs_configuration_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Configuration config); configurationSetResponse xtreemfs_configuration_set(InetSocketAddress server, final Auth authHeader,
            final UserCredentials userCreds, final Configuration config, int maxRetries); @Override long xtreemfs_global_time_get(InetSocketAddress server); long xtreemfs_global_time_get(); boolean clientIsAlive();  }