| /dports/net/p5-Net-RabbitMQ/Net--RabbitMQ-0.2.8/ |
| H A D | amqp_api.c | 22 #define RPC_REPLY(replytype) \ macro
36 return RPC_REPLY(amqp_channel_open_ok_t); in amqp_channel_open()
169 return RPC_REPLY(amqp_queue_declare_ok_t); in amqp_queue_declare()
185 return RPC_REPLY(amqp_queue_bind_ok_t); in amqp_queue_bind()
201 return RPC_REPLY(amqp_queue_unbind_ok_t); in amqp_queue_unbind()
218 return RPC_REPLY(amqp_basic_consume_ok_t); in amqp_basic_consume()
260 return RPC_REPLY(amqp_queue_purge_ok_t); in amqp_queue_purge()
324 return RPC_REPLY(amqp_tx_select_ok_t); in amqp_tx_select()
336 return RPC_REPLY(amqp_tx_commit_ok_t); in amqp_tx_commit()
348 return RPC_REPLY(amqp_tx_rollback_ok_t); in amqp_tx_rollback()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/ |
| H A D | RpcMessage.java | 28 RPC_REPLY; enumConstant
46 if (messageType != Type.RPC_CALL && messageType != Type.RPC_REPLY) { in RpcMessage()
|
| H A D | RpcReply.java | 48 super(xid, RpcMessage.Type.RPC_REPLY); in RpcReply()
60 Preconditions.checkState(messageType == RpcMessage.Type.RPC_REPLY); in read()
|
| /dports/misc/rump/buildrump.sh-b914579/src/sys/lib/libsa/ |
| H A D | rpcv2.h | 54 #define RPC_REPLY 1 macro
|
| H A D | rpc.c | 263 if (x != RPC_REPLY) { in recvrpc()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/ |
| H A D | TestRpcMessage.java | 52 msg.validateMessageType(RpcMessage.Type.RPC_REPLY);
|
| H A D | TestRpcReply.java | 51 Assert.assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType()); in testRpcReply()
|
| H A D | TestRpcDeniedReply.java | 46 Assert.assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType()); in testConstructor()
|
| H A D | TestRpcAcceptedReply.java | 53 assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType()); in testConstructor()
|
| H A D | TestRpcCall.java | 61 …RpcMessage.Type invalidMessageType = RpcMessage.Type.RPC_REPLY; // Message typ is not RpcMessage.R… in testInvalidRpcMessageType()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/include/linux/sunrpc/ |
| H A D | msg_prot.h | 41 RPC_REPLY = 1 enumerator
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/include/linux/sunrpc/ |
| H A D | msg_prot.h | 41 RPC_REPLY = 1 enumerator
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/include/linux/sunrpc/ |
| H A D | msg_prot.h | 41 RPC_REPLY = 1 enumerator
|
| /dports/misc/rump/buildrump.sh-b914579/src/sys/nfs/ |
| H A D | rpcv2.h | 66 #define RPC_REPLY 1 macro
|
| H A D | krpc_subr.c | 202 if (reply->rp_direction != txdr_unsigned(RPC_REPLY)) in krpccheck()
|
| /dports/net/ryu/ryu-4.26/ryu/lib/netconf/ |
| H A D | constants.py | 89 RPC_REPLY = 'rpc-reply' variable
|
| /dports/misc/rump/buildrump.sh-b914579/src/sys/fs/nfs/common/ |
| H A D | rpcv2.h | 167 #define RPC_REPLY 1 macro
|
| /dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rpc.h | 24 #define RPC_REPLY 1 macro
|
| H A D | packet-rpc.c | 84 { RPC_REPLY, "Reply" },
2278 case RPC_REPLY:
2548 case RPC_REPLY:
3026 case RPC_REPLY:
3303 case RPC_REPLY:
3738 if ((ulMsgType == RPC_REPLY) &&
|
| /dports/net/wireshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rpc.h | 24 #define RPC_REPLY 1
|
| H A D | packet-rpc.c | 84 { RPC_REPLY, "Reply" },
2278 case RPC_REPLY:
2548 case RPC_REPLY:
3026 case RPC_REPLY:
3303 case RPC_REPLY:
3738 if ((ulMsgType == RPC_REPLY) &&
|
| /dports/net/tshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rpc.h | 24 #define RPC_REPLY 1 macro
|
| H A D | packet-rpc.c | 84 { RPC_REPLY, "Reply" },
2278 case RPC_REPLY: in dissect_rpc_message()
2548 case RPC_REPLY: in dissect_rpc_message()
3026 case RPC_REPLY: in dissect_rpc_message()
3303 case RPC_REPLY: in dissect_rpc_fragment()
3738 if ((ulMsgType == RPC_REPLY) && in find_rpc_over_tcp_reply_start()
|
| /dports/net/tshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rpc.h | 24 #define RPC_REPLY 1 macro
|
| H A D | packet-rpc.c | 84 { RPC_REPLY, "Reply" },
2278 case RPC_REPLY: in dissect_rpc_message()
2548 case RPC_REPLY: in dissect_rpc_message()
3026 case RPC_REPLY: in dissect_rpc_message()
3303 case RPC_REPLY: in dissect_rpc_fragment()
3738 if ((ulMsgType == RPC_REPLY) && in find_rpc_over_tcp_reply_start()
|