Home
last modified time | relevance | path

Searched refs:mtype (Results 1 – 25 of 32) sorted by relevance

12

/thrift-3.4.0/lib/cpp/src/thrift/
DTDispatchProcessor.h54 protocol::TMessageType mtype; in process() local
56 inRaw->readMessageBegin(fname, mtype, seqid); in process()
63 if (mtype != protocol::T_CALL && mtype != protocol::T_ONEWAY) { in process()
64 GlobalOutput.printf("received invalid message type %d from client", mtype); in process()
74 protocol::TMessageType mtype; in processFast() local
76 in->readMessageBegin(fname, mtype, seqid); in processFast()
78 if (mtype != protocol::T_CALL && mtype != protocol::T_ONEWAY) { in processFast()
79 GlobalOutput.printf("received invalid message type %d from client", mtype); in processFast()
112 protocol::TMessageType mtype; in process() local
114 in->readMessageBegin(fname, mtype, seqid); in process()
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/async/
DTAsyncDispatchProcessor.h55 protocol::TMessageType mtype; in process() local
57 inRaw->readMessageBegin(fname, mtype, seqid); in process()
64 if (mtype != protocol::T_CALL && mtype != protocol::T_ONEWAY) { in process()
65 GlobalOutput.printf("received invalid message type %d from client", mtype); in process()
77 protocol::TMessageType mtype; in processFast() local
79 in->readMessageBegin(fname, mtype, seqid); in processFast()
81 if (mtype != protocol::T_CALL && mtype != protocol::T_ONEWAY) { in processFast()
82 GlobalOutput.printf("received invalid message type %d from client", mtype); in processFast()
116 protocol::TMessageType mtype; in process() local
118 inRaw->readMessageBegin(fname, mtype, seqid); in process()
[all …]
DTConcurrentClientSyncInfo.cpp50 ::apache::thrift::protocol::TMessageType &mtype, in getPending() argument
61 mtype = mtypePending_; in getPending()
69 ::apache::thrift::protocol::TMessageType mtype, in updatePending() argument
75 mtypePending_ = mtype; in updatePending()
DTConcurrentClientSyncInfo.h72 ::apache::thrift::protocol::TMessageType& mtype,
76 ::apache::thrift::protocol::TMessageType mtype,
/thrift-3.4.0/lib/perl/lib/Thrift/
DMultiplexedProcessor.pm38 my $mtype = shift;
43 $self->{mtype} = $mtype;
57 $$type = $self->{mtype};
100 my ($fname, $mtype, $rseqid);
101 $input->readMessageBegin(\$fname, \$mtype, \$rseqid);
103 if ($mtype ne Thrift::TMessageType::CALL && $mtype ne Thrift::TMessageType::ONEWAY) {
111 Thrift::StoredMessageProtocol->new($input, $fname, $mtype, $rseqid), $output
129 Thrift::StoredMessageProtocol->new($input, $messageName, $mtype, $rseqid), $output
/thrift-3.4.0/lib/php/lib/
DTMultiplexedProcessor.php93 $input->readMessageBegin($fname, $mtype, $rseqid);
95 if ($mtype !== TMessageType::CALL && $mtype != TMessageType::ONEWAY) {
114 new StoredMessageProtocol($input, $messageName, $mtype, $rseqid),
DStoredMessageProtocol.php39 public function __construct(TProtocol $protocol, $fname, $mtype, $rseqid) argument
43 $this->mtype_ = $mtype;
/thrift-3.4.0/lib/nodejs/lib/thrift/
Dmultiplexed_processor.js34 if (begin.mtype != Thrift.MessageType.CALL && begin.mtype != Thrift.MessageType.ONEWAY) {
57 mtype: begin.mtype,
Dconnection.js141 client['recv_' + header.fname](message, header.mtype, dummy_seqid);
360 client['recv_' + header.fname](message, header.mtype, dummy_seqid);
Dohos_connection.js149 client['recv_' + header.fname](proto, header.mtype, dummy_seqid);
Dws_connection.js164 client['recv_' + header.fname](proto, header.mtype, dummy_seqid);
/thrift-3.4.0/lib/rb/lib/thrift/
Dclient.rb54 fname, mtype, rseqid = @iprot.read_message_begin
55 [fname, mtype, rseqid]
70 def handle_exception(mtype) argument
71 if mtype == MessageTypes::EXCEPTION
/thrift-3.4.0/lib/c_glib/src/thrift/c_glib/processor/
Dthrift_dispatch_processor.c35 ThriftMessageType mtype; in G_DEFINE_ABSTRACT_TYPE() local
43 &mtype, in G_DEFINE_ABSTRACT_TYPE()
50 else if (mtype != T_CALL && mtype != T_ONEWAY) { in G_DEFINE_ABSTRACT_TYPE()
51 g_warning ("received invalid message type %d from client", mtype); in G_DEFINE_ABSTRACT_TYPE()
/thrift-3.4.0/lib/cpp/src/thrift/processor/
DPeekProcessor.cpp69 TMessageType mtype; in process() local
71 in->readMessageBegin(fname, mtype, seqid); in process()
73 if (mtype != T_CALL && mtype != T_ONEWAY) { in process()
DStatsProcessor.h48 apache::thrift::protocol::TMessageType mtype; in process() local
51 piprot_->readMessageBegin(fname, mtype, seqid); in process()
52 if (mtype != apache::thrift::protocol::T_CALL && mtype != apache::thrift::protocol::T_ONEWAY) { in process()
/thrift-3.4.0/lib/cpp/src/thrift/protocol/
DTDebugProtocol.cpp177 string mtype; in writeMessageBegin() local
180 mtype = "call"; in writeMessageBegin()
183 mtype = "reply"; in writeMessageBegin()
186 mtype = "exn"; in writeMessageBegin()
189 mtype = "oneway"; in writeMessageBegin()
193 uint32_t size = writeIndented("(" + mtype + ") " + name + "("); in writeMessageBegin()
/thrift-3.4.0/test/features/
Dstring_limit.py25 _, mtype, _ = proto.readMessageBegin()
26 assert mtype == TMessageType.REPLY
Dtheader_binary.py24 _, mtype, _ = proto.readMessageBegin()
25 assert mtype == TMessageType.REPLY
Dcontainer_limit.py29 _, mtype, _ = proto.readMessageBegin()
30 assert mtype == TMessageType.REPLY
/thrift-3.4.0/lib/c_glib/src/thrift/c_glib/protocol/
Dthrift_stored_message_protocol.c59 *message_type = self->mtype; in thrift_stored_message_protocol_read_message_begin()
80 self->mtype = g_value_get_int (value); in thrift_stored_message_protocol_set_property()
Dthrift_stored_message_protocol.h59 ThriftMessageType mtype; member
/thrift-3.4.0/lib/rb/spec/
Dclient_spec.rb84 fname, mtype, sqeid = @client.receive_message_begin()
85 expect { @client.handle_exception(mtype) }.to raise_error(StandardError)
/thrift-3.4.0/lib/nodejs/test/
Dheader.test.js52 assert.equals(result.mtype, thrift.Thrift.MessageType.CALL);
/thrift-3.4.0/lib/ts/
Dthrift.d.ts549 readMessageBegin(): { fname: string; mtype: number; rseqid: number };
/thrift-3.4.0/lib/py/src/transport/
DTTwisted.py101 (fname, mtype, rseqid) = iprot.readMessageBegin()
109 method(iprot, mtype, rseqid)

12