| /thrift-3.4.0/lib/c_glib/src/thrift/c_glib/protocol/ |
| D | thrift_multiplexed_protocol.c | 48 gchar *service_name = NULL; in thrift_multiplexed_protocol_write_message_begin() local
53 if( (message_type == T_CALL || message_type == T_ONEWAY) && self->service_name != NULL) { in thrift_multiplexed_protocol_write_message_begin()
54 …service_name = g_strdup_printf("%s%s%s", self->service_name, THRIFT_MULTIPLEXED_PROTOCOL_DEFAULT_S… in thrift_multiplexed_protocol_write_message_begin()
56 service_name = g_strdup(name); in thrift_multiplexed_protocol_write_message_begin()
60 …ret = thrift_protocol_decorator_write_message_begin(protocol, service_name, message_type, seqid, e… in thrift_multiplexed_protocol_write_message_begin()
62 g_free(service_name); in thrift_multiplexed_protocol_write_message_begin()
79 g_free(self->service_name); in thrift_multiplexed_protocol_set_property()
80 self->service_name = g_value_dup_string (value); in thrift_multiplexed_protocol_set_property()
101 g_value_set_string (value, self->service_name); in thrift_multiplexed_protocol_get_property()
115 protocol->service_name = NULL; in thrift_multiplexed_protocol_init()
[all …]
|
| D | thrift_multiplexed_protocol.h | 58 gchar *service_name; member
|
| /thrift-3.4.0/lib/rb/lib/thrift/ |
| D | multiplexed_processor.rb | 28 def register_processor(service_name, processor) argument
29 @actual_processors[service_name] = processor
36 service_name, method = name.split(':')
37 … processor(service_name).process(StoredMessageProtocol.new(iprot, [method, type, seqid]), oprot)
42 def processor(service_name) argument
43 if @actual_processors.has_key?(service_name)
44 @actual_processors[service_name]
46 …raise Thrift::Exception.new("Service name not found: #{service_name}. Did you forget to call #{sel…
|
| /thrift-3.4.0/lib/rs/src/protocol/ |
| D | multiplexed.rs | 60 service_name: String, field
72 pub fn new(service_name: &str, wrapped: P) -> TMultiplexedOutputProtocol<P> { in new()
74 service_name: service_name.to_owned(), in new()
90 name: format!("{}:{}", self.service_name, identifier.name), in write_message_begin()
|
| /thrift-3.4.0/lib/rb/lib/thrift/protocol/ |
| D | multiplexed_protocol.rb | 26 def initialize(protocol, service_name) argument
28 @service_name = service_name
|
| /thrift-3.4.0/lib/erl/src/ |
| D | thrift_multiplexed_protocol.erl | 41 service_name::nonempty_string()}).
50 service_name = ServiceName},
65 service_name = ServiceName},
|
| D | thrift_client_util.erl | 25 -type service_name() :: nonempty_string(). type
27 -type multiplexed_service_map() :: [{ServiceName::service_name(), ServiceModule::service_module()}].
100 ServiceThriftClientList :: [{ServiceName::service_name(), ThriftClient::term()}].
|
| /thrift-3.4.0/compiler/cpp/src/thrift/generate/ |
| D | t_gv_generator.cc | 298 string service_name = get_service_name(tservice); in generate_service() local
299 f_out_ << "subgraph cluster_" << service_name << " {" << endl; in generate_service()
302 f_out_ << "label = \"" << escape_string(service_name) << " service\";" << endl; in generate_service()
311 f_out_ << "function_" << service_name << fn_name; in generate_service()
314 print_type((*fn_iter)->get_returntype(), "function_" + service_name + fn_name + ":return_type"); in generate_service()
327 "function_" + service_name + fn_name + ":param_" + (*arg_iter)->get_name()); in generate_service()
337 edges.push_back("function_" + service_name + fn_name + " -> " in generate_service()
|
| D | t_go_generator.h | 324 const std::string& service_name) const;
|
| D | t_go_generator.cc | 222 …ublicize(const std::string& value, bool is_args_or_result, const std::string& service_name) const { in publicize()
264 prefix += publicize(service_name); in publicize()
|
| /thrift-3.4.0/lib/nodejs/lib/thrift/ |
| D | ohos_connection.js | 131 var service_name = self.seqId2Service[header.rseqid];
132 if (service_name) {
133 client = self.client[service_name];
|
| D | ws_connection.js | 148 var service_name = this.seqId2Service[header.rseqid];
149 if (service_name) {
150 client = this.client[service_name];
|
| D | xhr_connection.js | 162 var service_name = this.seqId2Service[header.rseqid];
163 if (service_name) {
164 client = this.client[service_name];
|
| D | http_connection.js | 128 var service_name = self.seqId2Service[header.rseqid];
129 if (service_name) {
130 client = self.client[service_name];
|
| D | connection.js | 121 var service_name = self.seqId2Service[header.rseqid];
122 if (service_name) {
123 client = self.client[service_name];
131 if (service_name) {
|
| /thrift-3.4.0/compiler/cpp/test/keyword-samples/ |
| D | service2_return.thrift | 22 service service_name {
|
| D | service3_return.thrift | 22 service service_name {
|
| D | service4_return.thrift | 24 service service_name {
|
| /thrift-3.4.0/lib/rs/src/server/ |
| D | multiplexed.rs | 78 service_name: S, in register()
84 let name = service_name.into(); in register()
|
| /thrift-3.4.0/test/rs/src/bin/ |
| D | test_client.rs | 170 service_name: &str, in build()
194 service_name, in build()
205 service_name, in build()
|
