| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/grpc-ecosystem/grpc-opentracing/python/grpc_opentracing/ |
| H A D | _client.py | 64 rpc_info.error = code
66 span_decorator(span, rpc_info)
69 rpc_info.response = response
73 span_decorator(span, rpc_info)
116 rpc_info.response = response
130 rpc_info = RpcInfo(
143 rpc_info.error = e
156 rpc_info = RpcInfo(
175 rpc_info.error = e
190 rpc_info = RpcInfo(
[all …]
|
| H A D | _server.py | 94 rpc_info.error = servicer_context.code
132 rpc_info = RpcInfo(
147 rpc_info.error = e
154 rpc_info.response = response
156 self._span_decorator(span, rpc_info)
166 rpc_info = RpcInfo(
187 rpc_info.error = e
193 self._span_decorator(span, rpc_info)
202 rpc_info = RpcInfo(
217 rpc_info.error = e
[all …]
|
| H A D | __init__.py | 41 def __call__(self, span, rpc_info): argument
|
| /dports/devel/grpc/grpc-1.42.0/include/grpcpp/impl/codegen/ |
| H A D | interceptor_common.h | 70 auto* rpc_info = call_->client_rpc_info(); in Hijack() local
71 rpc_info->hijacked_ = true; in Hijack()
72 rpc_info->hijacked_interceptor_ = current_interceptor_index_; in Hijack()
76 rpc_info->RunInterceptor(this, current_interceptor_index_); in Hijack()
278 auto* rpc_info = call_->client_rpc_info(); in RunClientInterceptors() local
282 if (rpc_info->hijacked_) { in RunClientInterceptors()
292 auto* rpc_info = call_->server_rpc_info(); in RunServerInterceptors() local
302 auto* rpc_info = call_->client_rpc_info(); in ProceedClient() local
303 if (rpc_info->hijacked_ && !reverse_ && in ProceedClient()
317 if (rpc_info->hijacked_ && in ProceedClient()
[all …]
|
| H A D | call.h | 52 experimental::ClientRpcInfo* rpc_info) in Call() argument
57 client_rpc_info_(rpc_info) {} in Call()
60 int max_receive_message_size, experimental::ServerRpcInfo* rpc_info) in Call() argument
65 server_rpc_info_(rpc_info) {} in Call()
|
| /dports/devel/grpc130/grpc-1.30.2/include/grpcpp/impl/codegen/ |
| H A D | interceptor_common.h | 69 auto* rpc_info = call_->client_rpc_info(); in Hijack() local
70 rpc_info->hijacked_ = true; in Hijack()
71 rpc_info->hijacked_interceptor_ = current_interceptor_index_; in Hijack()
75 rpc_info->RunInterceptor(this, current_interceptor_index_); in Hijack()
288 auto* rpc_info = call_->client_rpc_info(); in RunClientInterceptors() local
292 if (rpc_info->hijacked_) { in RunClientInterceptors()
302 auto* rpc_info = call_->server_rpc_info(); in RunServerInterceptors() local
312 auto* rpc_info = call_->client_rpc_info(); in ProceedClient() local
313 if (rpc_info->hijacked_ && !reverse_ && in ProceedClient()
327 if (rpc_info->hijacked_ && in ProceedClient()
[all …]
|
| H A D | call.h | 53 experimental::ClientRpcInfo* rpc_info) in Call() argument
58 client_rpc_info_(rpc_info) {} in Call()
61 int max_receive_message_size, experimental::ServerRpcInfo* rpc_info) in Call() argument
66 server_rpc_info_(rpc_info) {} in Call()
|
| /dports/devel/grpc134/grpc-1.34.1/include/grpcpp/impl/codegen/ |
| H A D | interceptor_common.h | 69 auto* rpc_info = call_->client_rpc_info(); in Hijack() local
70 rpc_info->hijacked_ = true; in Hijack()
71 rpc_info->hijacked_interceptor_ = current_interceptor_index_; in Hijack()
75 rpc_info->RunInterceptor(this, current_interceptor_index_); in Hijack()
287 auto* rpc_info = call_->client_rpc_info(); in RunClientInterceptors() local
291 if (rpc_info->hijacked_) { in RunClientInterceptors()
301 auto* rpc_info = call_->server_rpc_info(); in RunServerInterceptors() local
311 auto* rpc_info = call_->client_rpc_info(); in ProceedClient() local
312 if (rpc_info->hijacked_ && !reverse_ && in ProceedClient()
326 if (rpc_info->hijacked_ && in ProceedClient()
[all …]
|
| H A D | call.h | 50 experimental::ClientRpcInfo* rpc_info) in Call() argument
55 client_rpc_info_(rpc_info) {} in Call()
58 int max_receive_message_size, experimental::ServerRpcInfo* rpc_info) in Call() argument
63 server_rpc_info_(rpc_info) {} in Call()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/include/grpcpp/impl/codegen/ |
| H A D | interceptor_common.h | 69 auto* rpc_info = call_->client_rpc_info(); in Hijack() local
70 rpc_info->hijacked_ = true; in Hijack()
71 rpc_info->hijacked_interceptor_ = current_interceptor_index_; in Hijack()
75 rpc_info->RunInterceptor(this, current_interceptor_index_); in Hijack()
288 auto* rpc_info = call_->client_rpc_info(); in RunClientInterceptors() local
292 if (rpc_info->hijacked_) { in RunClientInterceptors()
302 auto* rpc_info = call_->server_rpc_info(); in RunServerInterceptors() local
312 auto* rpc_info = call_->client_rpc_info(); in ProceedClient() local
313 if (rpc_info->hijacked_ && !reverse_ && in ProceedClient()
327 if (rpc_info->hijacked_ && in ProceedClient()
[all …]
|
| H A D | call.h | 53 experimental::ClientRpcInfo* rpc_info) in Call() argument
58 client_rpc_info_(rpc_info) {} in Call()
61 int max_receive_message_size, experimental::ServerRpcInfo* rpc_info) in Call() argument
66 server_rpc_info_(rpc_info) {} in Call()
|
| /dports/devel/py-grpcio-tools/grpcio-tools-1.43.0/grpc_root/include/grpcpp/impl/codegen/ |
| H A D | interceptor_common.h | 70 auto* rpc_info = call_->client_rpc_info(); in Hijack() local
71 rpc_info->hijacked_ = true; in Hijack()
72 rpc_info->hijacked_interceptor_ = current_interceptor_index_; in Hijack()
76 rpc_info->RunInterceptor(this, current_interceptor_index_); in Hijack()
278 auto* rpc_info = call_->client_rpc_info(); in RunClientInterceptors() local
282 if (rpc_info->hijacked_) { in RunClientInterceptors()
292 auto* rpc_info = call_->server_rpc_info(); in RunServerInterceptors() local
302 auto* rpc_info = call_->client_rpc_info(); in ProceedClient() local
303 if (rpc_info->hijacked_ && !reverse_ && in ProceedClient()
317 if (rpc_info->hijacked_ && in ProceedClient()
[all …]
|
| H A D | call.h | 52 experimental::ClientRpcInfo* rpc_info) in Call() argument
57 client_rpc_info_(rpc_info) {} in Call()
60 int max_receive_message_size, experimental::ServerRpcInfo* rpc_info) in Call() argument
65 server_rpc_info_(rpc_info) {} in Call()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/grpc-ecosystem/grpc-opentracing/python/examples/store/ |
| H A D | store_server.py | 71 def __call__(self, span, rpc_info): argument
72 span.set_tag('grpc.method', rpc_info.full_method)
73 span.set_tag('grpc.headers', str(rpc_info.metadata))
74 span.set_tag('grpc.deadline', str(rpc_info.timeout))
|
| H A D | store_client.py | 166 def __call__(self, span, rpc_info): argument
167 span.set_tag('grpc.method', rpc_info.full_method)
168 span.set_tag('grpc.headers', str(rpc_info.metadata))
169 span.set_tag('grpc.deadline', str(rpc_info.timeout))
|
| /dports/benchmarks/flowgrind/flowgrind-flowgrind-0.8.2/src/ |
| H A D | flowgrind.h | 215 struct rpc_info { struct
231 struct rpc_info* rpc_info; argument
|
| H A D | flowgrind.c | 503 cflow[id].endpoint[*i].rpc_info = 0; in init_flow_options()
814 struct rpc_info *flow_rpc_info= node->data; in find_daemon()
1015 cflow[id].endpoint[DESTINATION].rpc_info->server_url, in prepare_flow()
1120 cflow[id].endpoint[SOURCE].rpc_info->server_url, in prepare_flow()
1567 cflow[id].endpoint[*i].rpc_info->server_url, in close_all_flows()
2199 struct rpc_info *flow_rpc_info; in add_flow_endpoint_by_url()
2200 flow_rpc_info = malloc((sizeof(struct rpc_info))); in add_flow_endpoint_by_url()
2207 memset(flow_rpc_info, 0, sizeof(struct rpc_info)); in add_flow_endpoint_by_url()
2234 struct rpc_info *flow_rpc_info= node->data; in set_rpc_info()
3047 if (!cflow[id].endpoint[*i].rpc_info) { in parse_cmdline()
[all …]
|
| /dports/security/softether5/SoftEtherVPN-5.02.5180/developer_tools/vpnserver-jsonrpc-codegen/CodeGen/ |
| H A D | CodeGen.cs | 1614 RpcInfo rpc_info; field in VPNServer_JSONRPC_CodeGen.CodeGen.JSonOutputContractResolver
1618 this.rpc_info = info; in JSonOutputContractResolver()
1632 RpcInfo rpc_info; field in VPNServer_JSONRPC_CodeGen.CodeGen.JSonInputConverter
1636 this.rpc_info = info; in JSonInputConverter()
1656 if (rpc_info.Name == "SetHubLog") all = true; in WriteJson()
1662 if (rpc_info.InputParamMembers.Contains(p2.Name) == false) a.Add(p2); in WriteJson()
1664 if (rpc_info.InputParamMembers.Contains(p1.Name) == false) a.Add(p1); in WriteJson()
1685 RpcInfo rpc_info; field in VPNServer_JSONRPC_CodeGen.CodeGen.JSonInputContractResolver
1689 this.rpc_info = info; in JSonInputContractResolver()
1695 ret.Converter = new JSonInputConverter(this.rpc_info); in CreateProperty()
|
| /dports/net/freerdp/freerdp-2.5.0/libfreerdp/core/gateway/ |
| H A D | rpc.h | 279 rpcrt_optional_data_t rpc_info; member
285 rpcrt_optional_data_t rpc_info; member
|
| /dports/security/snort/snort-2.9.18/src/dynamic-preprocessors/dcerpc2/includes/ |
| H A D | dcerpc.h | 512 DceRpcCoOptData rpc_info; member
|