public Nfs3WriteResponse wrapped_sendWrite(NfsWriteRequest request) throws IOException {
        // for async write, all the writes and commit should be sent to
        // the same NFS server
        String ip = request.isSync() ? _rpcWrapper.chooseIP(request.getIpKey()) : _server;
        NfsResponseHandler<Nfs3WriteResponse> responseHandler = new NfsResponseHandler<Nfs3WriteResponse>() {

            /* (non-Javadoc)
             * @see com.emc.ecs.nfsclient.rpc.RpcResponseHandler#makeNewResponse()
             */
            protected Nfs3WriteResponse makeNewResponse() {
                return new Nfs3WriteResponse();
            }

        };
        _rpcWrapper.callRpcWrapped(request, responseHandler, ip);
        return responseHandler.getResponse();
    }
public Nfs3WriteResponse wrapped_sendWrite ( NfsWriteRequest request ) throws IOException { String ip = request . isSync ( ) ? _rpcWrapper . chooseIP ( request . getIpKey ( ) ) : _server ; NfsResponseHandler < Nfs3WriteResponse > responseHandler = new NfsResponseHandler < Nfs3WriteResponse > ( ) { protected Nfs3WriteResponse makeNewResponse ( ) { return new Nfs3WriteResponse ( ) ; } } ; _rpcWrapper . callRpcWrapped ( request , responseHandler , ip ) ; return responseHandler . getResponse ( ) ; }
/* (non-Javadoc)
@see com.emc.ecs.nfsclient.nfs.Nfs#wrapped_sendWrite(com.emc.ecs.nfsclient.nfs.NfsWriteRequest)