diff --git a/oncrpc4j-core/src/main/java/org/dcache/oncrpc4j/rpc/RpcCall.java b/oncrpc4j-core/src/main/java/org/dcache/oncrpc4j/rpc/RpcCall.java index dd6f6d44..febe76ed 100644 --- a/oncrpc4j-core/src/main/java/org/dcache/oncrpc4j/rpc/RpcCall.java +++ b/oncrpc4j-core/src/main/java/org/dcache/oncrpc4j/rpc/RpcCall.java @@ -19,28 +19,25 @@ */ package org.dcache.oncrpc4j.rpc; +import com.google.common.base.Throwables; +import org.dcache.oncrpc4j.grizzly.GrizzlyMemoryManager; import org.dcache.oncrpc4j.xdr.Xdr; -import org.dcache.oncrpc4j.xdr.XdrVoid; -import org.dcache.oncrpc4j.xdr.XdrEncodingStream; import org.dcache.oncrpc4j.xdr.XdrAble; -import com.google.common.base.Throwables; -import java.io.EOFException; +import org.dcache.oncrpc4j.xdr.XdrEncodingStream; +import org.dcache.oncrpc4j.xdr.XdrVoid; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.io.EOFException; import java.io.IOException; import java.io.InterruptedIOException; import java.lang.reflect.InvocationTargetException; import java.net.InetSocketAddress; import java.nio.channels.CompletionHandler; -import java.util.Random; import java.util.ArrayList; import java.util.List; -import java.util.concurrent.CompletableFuture; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.Future; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; +import java.util.Random; +import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; public class RpcCall { @@ -440,21 +437,29 @@ private int callInternal(int procedure, XdrAble args, CompletionHandler