| /thrift-3.4.0/lib/swift/Tests/ThriftTests/ |
| D | TMultiplexedProcessorTests.swift | 36 func process(on inProtocol: TProtocol, outProtocol: TProtocol) throws { in process() function
60 XCTAssertThrowsError(try sut.process(on: proto, outProtocol: proto)) { error in in testExceptionMessageThrowsError()
72 XCTAssertThrowsError(try sut.process(on: proto, outProtocol: proto)) { error in in testReplyMessageThrowsError()
84 XCTAssertThrowsError(try sut.process(on: proto, outProtocol: proto)) { error in in testMissingDefaultProcessorThrowsError()
98 try sut.process(on: proto, outProtocol: proto) in testUsesDefaultProcessorForNonMultiplexedMessage()
108 try sut.process(on: proto, outProtocol: proto) in testUsesProcessorForMultiplexedMessage()
115 XCTAssertThrowsError(try sut.process(on: proto, outProtocol: proto)) { error in in testMissingProcessorForMultiplexedMessageThrowsError()
130 try sut.process(on: proto, outProtocol: proto) in testCallMessageDoesNotThrowError()
139 try sut.process(on: proto, outProtocol: proto) in testOneWayMessageDoesNotThrowError()
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/ |
| D | TestMultiplexedProcessor.java | 49 assertThrows(TException.class, () -> mp.process(iprot, oprot)); in testWrongMessageType()
56 assertThrows(TException.class, () -> mp.process(iprot, oprot)); in testNoSuchService()
61 public void process(TProtocol in, TProtocol out) throws TException { in process() method in TestMultiplexedProcessor.StubProcessor
74 mp.process(iprot, oprot); in testExistingService()
82 mp.process(iprot, oprot); in testDefaultService()
|
| /thrift-3.4.0/lib/cpp/src/thrift/async/ |
| D | TAsyncProcessor.h | 42 virtual void process(std::function<void(bool success)> _return,
46 void process(std::function<void(bool success)> _return, in process() function
48 return process(_return, io, io); in process()
|
| D | TAsyncProtocolProcessor.cpp | 29 void TAsyncProtocolProcessor::process(std::function<void(bool healthy)> _return, in process() function in apache::thrift::async::TAsyncProtocolProcessor
35 ->process(std::bind(&TAsyncProtocolProcessor::finish, in process()
|
| D | TEvhttpServer.cpp | 104 static_cast<TEvhttpServer*>(self)->process(req); in request()
110 void TEvhttpServer::process(struct evhttp_request* req) { in process() function in apache::thrift::async::TEvhttpServer
112 return processor_->process(std::bind(&TEvhttpServer::complete, in process()
|
| /thrift-3.4.0/lib/c_glib/src/thrift/c_glib/processor/ |
| D | thrift_processor.c | 30 THRIFT_PROCESSOR_GET_CLASS (processor)->process (processor, in, out, error); in G_DEFINE_ABSTRACT_TYPE()
38 cls->process = thrift_processor_process; in thrift_processor_class_init()
|
| /thrift-3.4.0/lib/d/src/thrift/protocol/ |
| D | processor.d | 40 bool process(TProtocol iprot, TProtocol oprot,
48 final bool process(TProtocol prot, Variant connectionContext = Variant()) {
49 return process(prot, prot, connectionContext);
|
| /thrift-3.4.0/lib/nodejs/test/ |
| D | helpers.js | 35 module.exports.ecmaMode = process.argv.includes("--es6") ? "es6" : "es5";
36 module.exports.genPath = process.argv.includes("--es6")
|
| D | client.js | 58 .parse(process.argv);
109 process.exit(0);
170 process.exit(0);
|
| /thrift-3.4.0/lib/py/src/ |
| D | TMultiplexedProcessor.py | 46 def process(self, iprot, oprot): member in TMultiplexedProcessor
56 return self.defaultProcessor.process(
73 return self.services[serviceName].process(
|
| /thrift-3.4.0/lib/swift/Sources/ |
| D | TMultiplexedProcessor.swift | 59 public func process(on inProtocol: TProtocol, outProtocol: TProtocol) throws { in process() function
67 try processor.process(on: storedMessage, outProtocol: outProtocol) in process()
70 try processor.process(on: inProtocol, outProtocol: outProtocol) in process()
|
| D | TProcessor.swift | 21 func process(on inProtocol: TProtocol, outProtocol: TProtocol) throws function
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | TMultiplexedProcessor.java | 98 public void process(TProtocol iprot, TProtocol oprot) throws TException { in process() method in TMultiplexedProcessor
116 defaultProcessor.process(new StoredMessageProtocol(iprot, message), oprot); in process()
147 actualProcessor.process(new StoredMessageProtocol(iprot, standardMessage), oprot); in process()
|
| D | TBaseProcessor.java | 26 public void process(TProtocol in, TProtocol out) throws TException { in process() method in TBaseProcessor
40 fn.process(msg.seqid, in, out, iface); in process()
|
| D | TAsyncProcessor.java | 32 void process(final AsyncFrameBuffer fb) throws TException; in process() method
|
| /thrift-3.4.0/lib/perl/lib/Thrift/ |
| D | MultiplexedProcessor.pm | 89 sub process { subroutine
110 return $self->{defaultProcessor}->process(
128 return $processor->process(
|
| /thrift-3.4.0/lib/rb/lib/thrift/server/ |
| D | mongrel_http_server.rb | 32 def process(request, response) method in Thrift.MongrelHTTPServer.Handler
38 @processor.process protocol, protocol
|
| /thrift-3.4.0/lib/rb/lib/thrift/ |
| D | multiplexed_processor.rb | 32 def process(iprot, oprot) method in Thrift.MultiplexedProcessor
37 … processor(service_name).process(StoredMessageProtocol.new(iprot, [method, type, seqid]), oprot)
|
| /thrift-3.4.0/lib/nodets/test/ |
| D | client.ts | 35 .parse(process.argv);
59 process.exit(0);
|
| /thrift-3.4.0/lib/php/lib/ |
| D | TMultiplexedProcessor.php | 86 public function process(TProtocol $input, TProtocol $output) function in Thrift\\TMultiplexedProcessor
113 return $processor->process(
|
| /thrift-3.4.0/lib/nodejs/lib/thrift/ |
| D | multiplexed_processor.js | 31 MultiplexedProcessor.prototype.process = function(inp, out) { method in MultiplexedProcessor
62 this.services[sname].process(inpProxy, out);
|
| /thrift-3.4.0/lib/rs/src/server/ |
| D | multiplexed.rs | 131 (*arc).process(&mut proxy_i_prot, o_prot) in process_message()
139 fn process( in process() method
224 p.process(&mut i, &mut o).unwrap(); // at this point an error should be written out in should_write_error_if_no_separator_found_and_no_default_processor_exists()
249 p.process(&mut i, &mut o).unwrap(); // at this point an error should be written out in should_write_error_if_separator_exists_and_no_processor_found()
269 fn process( in process() method
311 p.process(&mut i, &mut o).unwrap(); in should_route_call_to_correct_processor()
344 p.process(&mut i, &mut o).unwrap(); in should_route_call_to_correct_processor_if_no_separator_exists_and_default_processor_set()
|
| /thrift-3.4.0/lib/perl/t/ |
| D | processor.t | 60 my $result = $processor->process($input_protocol, $output_protocol);
61 print "process resulted in $result\n";
62 $result = $processor->process($input_protocol, $output_protocol);
63 print "process resulted in $result\n";
|
| /thrift-3.4.0/lib/cpp/src/thrift/ |
| D | TProcessor.h | 144 virtual bool process(std::shared_ptr<protocol::TProtocol> in,
148 bool process(std::shared_ptr<apache::thrift::protocol::TProtocol> io, void* connectionContext) { in process() function
149 return process(io, io, connectionContext); in process()
|
| /thrift-3.4.0/lib/cpp/src/thrift/processor/ |
| D | TMultiplexedProcessor.h | 150 bool process(std::shared_ptr<protocol::TProtocol> in, in process() function
184 ->process(std::shared_ptr<protocol::TProtocol>( in process()
198 ->process(std::shared_ptr<protocol::TProtocol>( in process()
|
