| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/ |
| H A D | TestRpcCall.java | 37 int rpcVersion = RpcCall.RPC_VERSION; in testConstructor()
41 RpcCall call = new RpcCall(0, RpcMessage.Type.RPC_CALL, rpcVersion, program, in testConstructor()
56 new RpcCall(0, RpcMessage.Type.RPC_CALL, invalidRpcVersion, 2, 3, 4, null, null); in testInvalidRpcVersion()
62 new RpcCall(0, invalidMessageType, RpcCall.RPC_VERSION, 2, 3, 4, null, null); in testInvalidRpcMessageType()
|
| H A D | TestFrameDecoder.java | 71 RpcCall rpcCall = (RpcCall) info.header(); in handleInternal()
92 protected boolean isIdempotent(RpcCall call) { in isIdempotent()
246 RpcCall.getInstance(0, 100000, 2, procedure, new CredentialsNone(), in createPortmapXDRheader()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/ |
| H A D | RpcCall.java | 28 public class RpcCall extends RpcMessage { class
30 private static final Log LOG = LogFactory.getLog(RpcCall.class);
32 public static RpcCall read(XDR xdr) { in read()
33 return new RpcCall(xdr.readInt(), RpcMessage.Type.fromValue(xdr.readInt()), in read()
39 public static RpcCall getInstance(int xid, int program, int version, in getInstance()
41 return new RpcCall(xid, RpcMessage.Type.RPC_CALL, 2, program, version, in getInstance()
52 protected RpcCall(int xid, RpcMessage.Type messageType, int rpcVersion, in RpcCall() method in RpcCall
|
| H A D | RpcProgram.java | 147 RpcCall call = (RpcCall) info.header(); in messageReceived()
193 private void sendAcceptedReply(RpcCall call, SocketAddress remoteAddress, in sendAcceptedReply()
210 protected static void sendRejectedReply(RpcCall call, in sendRejectedReply()
230 protected abstract boolean isIdempotent(RpcCall call); in isIdempotent()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/security/ |
| H A D | SecurityHandler.java | 24 import org.apache.hadoop.oncrpc.RpcCall;
32 public abstract boolean shouldSilentlyDrop(RpcCall request); in shouldSilentlyDrop()
34 public abstract Verifier getVerifer(RpcCall request) throws IOException; in getVerifer()
45 public XDR unwrap(RpcCall request, byte[] data ) throws IOException { in unwrap()
50 public byte[] wrap(RpcCall request, XDR response) throws IOException { in wrap()
|
| H A D | SysSecurityHandler.java | 21 import org.apache.hadoop.oncrpc.RpcCall;
43 public boolean shouldSilentlyDrop(RpcCall request) { in shouldSilentlyDrop()
48 public VerifierNone getVerifer(RpcCall request) { in getVerifer()
|
| /dports/devel/grpc/grpc-1.42.0/test/core/transport/binder/ |
| H A D | wire_writer_test.cc | 36 TEST(WireWriterTest, RpcCall) { in TEST() argument
66 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
101 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
114 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
127 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
168 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
202 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
241 EXPECT_TRUE(wire_writer.RpcCall(tx).ok()); in TEST()
|
| /dports/irc/quassel/quassel-0.14-rc2/src/common/ |
| H A D | internalpeer.cpp | 33 qRegisterMetaType<Protocol::RpcCall>(); in InternalPeer()
123 selectOverload<const Protocol::RpcCall&>(&InternalPeer::dispatchMessage), in setPeer()
125 selectOverload<const Protocol::RpcCall&>(&InternalPeer::handleMessage)); in setPeer()
154 void InternalPeer::dispatch(const RpcCall& msg) in dispatch()
174 void InternalPeer::handleMessage(const Protocol::RpcCall& msg) in handleMessage()
|
| H A D | internalpeer.h | 59 void dispatch(const Protocol::RpcCall& msg) override;
80 void dispatchMessage(const Protocol::RpcCall& msg);
88 void handleMessage(const Protocol::RpcCall& msg);
|
| H A D | protocol.h | 208 struct RpcCall : public SignalProxyMessage struct
210 RpcCall() = default;
211 RpcCall(QByteArray signalName, QVariantList params) in RpcCall() argument
270 Q_DECLARE_METATYPE(Protocol::RpcCall)
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/common/ |
| H A D | internalpeer.cpp | 33 qRegisterMetaType<Protocol::RpcCall>(); in InternalPeer()
123 selectOverload<const Protocol::RpcCall&>(&InternalPeer::dispatchMessage), in setPeer()
125 selectOverload<const Protocol::RpcCall&>(&InternalPeer::handleMessage)); in setPeer()
154 void InternalPeer::dispatch(const RpcCall& msg) in dispatch()
174 void InternalPeer::handleMessage(const Protocol::RpcCall& msg) in handleMessage()
|
| H A D | internalpeer.h | 59 void dispatch(const Protocol::RpcCall& msg) override;
80 void dispatchMessage(const Protocol::RpcCall& msg);
88 void handleMessage(const Protocol::RpcCall& msg);
|
| H A D | protocol.h | 208 struct RpcCall : public SignalProxyMessage struct
210 RpcCall() = default;
211 RpcCall(QByteArray signalName, QVariantList params) in RpcCall() function
270 Q_DECLARE_METATYPE(Protocol::RpcCall)
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/ |
| H A D | PortmapRequest.java | 20 import org.apache.hadoop.oncrpc.RpcCall;
38 RpcCall call = RpcCall.getInstance( in create()
|
| /dports/astro/kstars/kstars-3.5.6/kstars/ekos/guide/externalguide/ |
| H A D | phd2.h | 254 struct RpcCall struct
258 RpcCall() = default; argument
259 …RpcCall(const QJsonObject &call_, PHD2ResultType resultType_) : call(call_), resultType(resultType… in RpcCall() function
261 QVector<RpcCall> rpcRequestQueue;
|
| /dports/irc/quassel/quassel-0.14-rc2/src/test/util/ |
| H A D | mockedpeer.cpp | 36 Protocol::RpcCall,
59 void operator()(const Protocol::RpcCall& rpcCall) const in PrintTo()
104 void MockedPeer::dispatch(const Protocol::RpcCall& msg) in dispatch()
217 bool operator()(const Protocol::RpcCall& rpcCall) const in operator ()()
282 Matcher<const ProtocolMessage&> RpcCall(Matcher<QByteArray> signalName, Matcher<QVariantList> param… in RpcCall() function
|
| H A D | mockedpeer.h | 71 void dispatch(const Protocol::RpcCall&) override;
92 TEST_UTIL_EXPORT ::testing::Matcher<const ProtocolMessage&> RpcCall(
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/test/util/ |
| H A D | mockedpeer.cpp | 36 Protocol::RpcCall,
59 void operator()(const Protocol::RpcCall& rpcCall) const in PrintTo()
104 void MockedPeer::dispatch(const Protocol::RpcCall& msg) in dispatch()
217 bool operator()(const Protocol::RpcCall& rpcCall) const in operator ()()
282 Matcher<const ProtocolMessage&> RpcCall(Matcher<QByteArray> signalName, Matcher<QVariantList> param… in RpcCall() function
|
| H A D | mockedpeer.h | 71 void dispatch(const Protocol::RpcCall&) override;
92 TEST_UTIL_EXPORT ::testing::Matcher<const ProtocolMessage&> RpcCall(
|
| /dports/editors/xi-core/xi-editor-0.3.0/rust/rpc/tests/ |
| H A D | integration.rs | 23 use xi_rpc::{Handler, ReadError, RemoteError, RpcCall, RpcCtx, RpcLoop};
30 type Notification = RpcCall;
31 type Request = RpcCall;
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/transport/binder/wire_format/ |
| H A D | wire_writer.h | 34 virtual absl::Status RpcCall(const Transaction& call) = 0;
42 absl::Status RpcCall(const Transaction& tx) override;
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/binder/wire_format/ |
| H A D | wire_writer.h | 34 virtual absl::Status RpcCall(const Transaction& call) = 0;
42 absl::Status RpcCall(const Transaction& tx) override;
|
| /dports/irc/quassel/quassel-0.14-rc2/src/common/protocols/legacy/ |
| H A D | legacypeer.h | 34 RpcCall, enumerator
60 void dispatch(const Protocol::RpcCall& msg) override;
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/common/protocols/legacy/ |
| H A D | legacypeer.h | 34 RpcCall, enumerator
60 void dispatch(const Protocol::RpcCall& msg) override;
|
| /dports/irc/quassel-core/quassel-0.14-rc2/tests/common/ |
| H A D | signalproxytest.cpp | 100 …EXPECT_CALL(*_clientPeer, Dispatches(RpcCall(Eq(SIGNAL(sendData(int,QString))), ElementsAre(42, "H… in TEST_F()
101 …EXPECT_CALL(*_clientPeer, Dispatches(RpcCall(Eq(SIGNAL(sendExtraData(int,QString))), ElementsAre(4… in TEST_F()
102 …EXPECT_CALL(*_serverPeer, Dispatches(RpcCall(Eq("2sendData(int,QString)"), ElementsAre(23, "World"… in TEST_F()
103 …EXPECT_CALL(*_serverPeer, Dispatches(RpcCall(Eq("2sendToFunctor(int,QString)"), ElementsAre(17, "H… in TEST_F()
318 …EXPECT_CALL(*_serverPeer, Dispatches(RpcCall(Eq("__objectRenamed__"), ElementsAre("SyncObj", "Bar"… in TEST_F()
|