src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java [297:315]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        ReplicatedWriteClient client = new ReplicatedWriteClient(
            server.server, networkTimeoutMillis, serverConnectionRefresher, finishUploadAck, usePooledConnection, user, appId, appAttempt, shuffleWriteConfig);
        client.connect();

        // use synchronize to make sure writes on clients array element visible to other threads
        // see http://www.cs.umd.edu/~pugh/java/memoryModel/jsr-133-faq.html
        synchronized (clients) {
            clients[server.index] = client;
        }
    }

    private void closeClient(ReplicatedWriteClient client) {
        try {
            if (client != null) {
                logger.debug(String.format("Closing client: %s", client));
                client.close();
            }
        } catch (Throwable ex) {
            logger.warn("Failed to close client", ex);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java [164:181]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        ReplicatedWriteClient client = new ReplicatedWriteClient(
            server.server, networkTimeoutMillis, serverConnectionRefresher, finishUploadAck, usePooledConnection, user, appId, appAttempt, shuffleWriteConfig);
        client.connect();
        // use synchronize to make sure writes on clients array element visible to other threads
        // see http://www.cs.umd.edu/~pugh/java/memoryModel/jsr-133-faq.html
        synchronized (clients) {
            clients[server.index] = client;
        }
    }

    private void closeClient(ReplicatedWriteClient client) {
        try {
            if (client != null) {
                logger.debug(String.format("Closing client: %s", client));
                client.close();
            }
        } catch (Throwable ex) {
            logger.warn("Failed to close client", ex);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -