TestIPCServerResponder.java 文件源码

@Override
public Writable call(RPC.RpcKind rpcKind, String protocol, Writable param,
    long receiveTime) throws IOException {
  if (sleep) {
    try {
      Thread.sleep(RANDOM.nextInt(20)); // sleep a bit
    } catch (InterruptedException e) {}
  }
  return param;
}