@Test(expected=RpcAuthException.class) public void testBadAuthType() throws Exception { _xdr.beginEncoding(); _xdr.xdrEncodeInt(2); _xdr.xdrEncodeInt(127); _xdr.xdrEncodeInt(1); _xdr.xdrEncodeInt(0); _xdr.xdrEncodeInt(100); _xdr.endEncoding(); _xdr.beginDecoding(); _call.accept(); }
public void accept() throws IOException { _rpcvers = _xdr.xdrDecodeInt(); if (_rpcvers != RPCVERS) { throw new RpcMismatchReply(_rpcvers, 2); } _prog = _xdr.xdrDecodeInt(); _version = _xdr.xdrDecodeInt(); _proc = _xdr.xdrDecodeInt(); _cred = RpcCredential.decode(_xdr, _transport); }
RpcCall { public void accept() throws IOException { _rpcvers = _xdr.xdrDecodeInt(); if (_rpcvers != RPCVERS) { throw new RpcMismatchReply(_rpcvers, 2); } _prog = _xdr.xdrDecodeInt(); _version = _xdr.xdrDecodeInt(); _proc = _xdr.xdrDecodeInt(); _cred = RpcCredential.decode(_xdr, _transport); } }
RpcCall { public void accept() throws IOException { _rpcvers = _xdr.xdrDecodeInt(); if (_rpcvers != RPCVERS) { throw new RpcMismatchReply(_rpcvers, 2); } _prog = _xdr.xdrDecodeInt(); _version = _xdr.xdrDecodeInt(); _proc = _xdr.xdrDecodeInt(); _cred = RpcCredential.decode(_xdr, _transport); } RpcCall(int prog, int ver, RpcAuth cred, RpcTransport transport);  RpcCall(int prog, int ver, RpcAuth cred, Xdr xdr, RpcTransport transport);  RpcCall(int xid, Xdr xdr, RpcTransport transport);  RpcCall(int xid, int prog, int ver, int proc, RpcAuth cred, Xdr xdr, RpcTransport transport); }
RpcCall { public void accept() throws IOException { _rpcvers = _xdr.xdrDecodeInt(); if (_rpcvers != RPCVERS) { throw new RpcMismatchReply(_rpcvers, 2); } _prog = _xdr.xdrDecodeInt(); _version = _xdr.xdrDecodeInt(); _proc = _xdr.xdrDecodeInt(); _cred = RpcCredential.decode(_xdr, _transport); } RpcCall(int prog, int ver, RpcAuth cred, RpcTransport transport);  RpcCall(int prog, int ver, RpcAuth cred, Xdr xdr, RpcTransport transport);  RpcCall(int xid, Xdr xdr, RpcTransport transport);  RpcCall(int xid, int prog, int ver, int proc, RpcAuth cred, Xdr xdr, RpcTransport transport); void accept(); int getProgram(); int getProgramVersion(); int getProcedure(); RpcAuth getCredential(); RpcTransport getTransport(); int getXid(); Xdr getXdr(); @Override String toString(); void reject(int status, XdrAble reason); void reply(XdrAble reply); void acceptedReply(int state, XdrAble reply); void retrieveCall(XdrAble args); void failProgramMismatch(int min, int max); void failProgramUnavailable(); void failProcedureUnavailable(); void failRpcGarbage(); void failRpcSystem(); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback, long timeoutValue, TimeUnit timeoutUnits, RpcAuth auth); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback, long timeoutValue, TimeUnit timeoutUnits); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback, RpcAuth auth); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback); CompletableFuture<T> call(int procedure, XdrAble args, final Class<T> type, final RpcAuth auth); CompletableFuture<T> call(int procedure, XdrAble args, final Class<T> type); void call(int procedure, XdrAble args, XdrAble result, long timeoutValue, TimeUnit timeoutUnits, RpcAuth auth); void call(int procedure, XdrAble args, XdrAble result, long timeoutValue, TimeUnit timeoutUnits); void call(int procedure, XdrAble args, XdrAble result, RpcAuth auth); void call(int procedure, XdrAble args, XdrAble result); void registerSendListener(CompletionHandler<Integer, InetSocketAddress> listener); void registerSendOnceListener(CompletionHandler<Integer, InetSocketAddress> listener); }
RpcCall { public void accept() throws IOException { _rpcvers = _xdr.xdrDecodeInt(); if (_rpcvers != RPCVERS) { throw new RpcMismatchReply(_rpcvers, 2); } _prog = _xdr.xdrDecodeInt(); _version = _xdr.xdrDecodeInt(); _proc = _xdr.xdrDecodeInt(); _cred = RpcCredential.decode(_xdr, _transport); } RpcCall(int prog, int ver, RpcAuth cred, RpcTransport transport);  RpcCall(int prog, int ver, RpcAuth cred, Xdr xdr, RpcTransport transport);  RpcCall(int xid, Xdr xdr, RpcTransport transport);  RpcCall(int xid, int prog, int ver, int proc, RpcAuth cred, Xdr xdr, RpcTransport transport); void accept(); int getProgram(); int getProgramVersion(); int getProcedure(); RpcAuth getCredential(); RpcTransport getTransport(); int getXid(); Xdr getXdr(); @Override String toString(); void reject(int status, XdrAble reason); void reply(XdrAble reply); void acceptedReply(int state, XdrAble reply); void retrieveCall(XdrAble args); void failProgramMismatch(int min, int max); void failProgramUnavailable(); void failProcedureUnavailable(); void failRpcGarbage(); void failRpcSystem(); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback, long timeoutValue, TimeUnit timeoutUnits, RpcAuth auth); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback, long timeoutValue, TimeUnit timeoutUnits); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback, RpcAuth auth); void call(int procedure, XdrAble args, CompletionHandler<RpcReply, RpcTransport> callback); CompletableFuture<T> call(int procedure, XdrAble args, final Class<T> type, final RpcAuth auth); CompletableFuture<T> call(int procedure, XdrAble args, final Class<T> type); void call(int procedure, XdrAble args, XdrAble result, long timeoutValue, TimeUnit timeoutUnits, RpcAuth auth); void call(int procedure, XdrAble args, XdrAble result, long timeoutValue, TimeUnit timeoutUnits); void call(int procedure, XdrAble args, XdrAble result, RpcAuth auth); void call(int procedure, XdrAble args, XdrAble result); void registerSendListener(CompletionHandler<Integer, InetSocketAddress> listener); void registerSendOnceListener(CompletionHandler<Integer, InetSocketAddress> listener);  }