Home
last modified time | relevance | path

Searched refs:output (Results 1 – 25 of 100) sorted by relevance

1234

/thrift-3.4.0/lib/php/lib/Exception/
DTApplicationException.php52 public function read($output) argument
54 return $this->_read('TApplicationException', self::$_TSPEC, $output);
57 public function write($output) argument
60 $xfer += $output->writeStructBegin('TApplicationException');
62 $xfer += $output->writeFieldBegin('message', TType::STRING, 1);
63 $xfer += $output->writeString($message);
64 $xfer += $output->writeFieldEnd();
67 $xfer += $output->writeFieldBegin('type', TType::I32, 2);
68 $xfer += $output->writeI32($code);
69 $xfer += $output->writeFieldEnd();
[all …]
DTException.php243 private function _writeMap($var, $spec, $output) argument
259 $xfer += $output->writeMapBegin($ktype, $vtype, count($var));
262 $xfer += $output->$kwrite($key);
266 $xfer += $key->write($output);
269 $xfer += $this->_writeMap($key, $kspec, $output);
272 $xfer += $this->_writeList($key, $kspec, $output, false);
275 $xfer += $this->_writeList($key, $kspec, $output, true);
280 $xfer += $output->$vwrite($val);
284 $xfer += $val->write($output);
287 $xfer += $this->_writeMap($val, $vspec, $output);
[all …]
/thrift-3.4.0/lib/php/src/
DThrift.php271 private function _writeMap($var, $spec, $output) argument
287 $xfer += $output->writeMapBegin($ktype, $vtype, count($var));
290 $xfer += $output->$kwrite($key);
294 $xfer += $key->write($output);
297 $xfer += $this->_writeMap($key, $kspec, $output);
300 $xfer += $this->_writeList($key, $kspec, $output, false);
303 $xfer += $this->_writeList($key, $kspec, $output, true);
308 $xfer += $output->$vwrite($val);
312 $xfer += $val->write($output);
315 $xfer += $this->_writeMap($val, $vspec, $output);
[all …]
/thrift-3.4.0/lib/php/lib/Base/
DTBase.php48 abstract public function write($output); argument
241 private function _writeMap($var, $spec, $output) argument
257 $xfer += $output->writeMapBegin($ktype, $vtype, count($var));
260 $xfer += $output->$kwrite($key);
264 $xfer += $key->write($output);
267 $xfer += $this->_writeMap($key, $kspec, $output);
270 $xfer += $this->_writeList($key, $kspec, $output, false);
273 $xfer += $this->_writeList($key, $kspec, $output, true);
278 $xfer += $output->$vwrite($val);
282 $xfer += $val->write($output);
[all …]
/thrift-3.4.0/test/audit/
Dthrift_audit_test.pl140 my ($exitCode, $output) = callThriftAuditTool($arguments);
141 print $output if $gVerbose eq 1;
147 print $output;
153 print $output;
156 if(index($output,getMessageSubString("break$i")) == -1)
159 print $output;
177 my ($exitCode, $output) = callThriftAuditTool($arguments);
178 print $output if $gVerbose eq 1;
207 my $output = `$command 2>&1`;
210 return ($exitCode,$output);
/thrift-3.4.0/tutorial/dart/client/web/
Dclient.dart27 new CalculatorUI(querySelector('#output')).start();
31 final DivElement output;
33 CalculatorUI(this.output);
60 output.children.forEach((e) {
74 output.append(new HeadingElement.h3()..text = "Ping");
78 output.append(pingButton);
88 output.append(new HeadingElement.h3()..text = "Add");
94 output.append(num1);
99 output.append(op);
106 output.append(num2);
[all …]
/thrift-3.4.0/lib/perl/lib/Thrift/
DException.pm123 my $output = shift;
127 $xfer += $output->writeStructBegin('TApplicationException');
130 $xfer += $output->writeFieldBegin('message', Thrift::TType::STRING, 1);
131 $xfer += $output->writeString($self->getMessage());
132 $xfer += $output->writeFieldEnd();
136 $xfer += $output->writeFieldBegin('type', Thrift::TType::I32, 2);
137 $xfer += $output->writeI32($self->getCode());
138 $xfer += $output->writeFieldEnd();
141 $xfer += $output->writeFieldStop();
142 $xfer += $output->writeStructEnd();
DMultiplexedProcessor.pm92 my $output = shift;
111 Thrift::StoredMessageProtocol->new($input, $fname, $mtype, $rseqid), $output
129 Thrift::StoredMessageProtocol->new($input, $messageName, $mtype, $rseqid), $output
/thrift-3.4.0/lib/swift/Sources/
DTStreamTransport.swift39 public var output: OutputStream? = nil variable
43 output = outputStream
101 guard let output = output else { in write() variable
107 …bytesWritten = data.withUnsafeBytes { output.write($0.bindMemory(to: UInt8.self).baseAddress!, max… in write()
135 if output != nil { in close()
137 if let cf: CFWriteStream = output { in close()
140 output?.delegate = nil in close()
141 output?.close() in close()
142 output?.remove(from: .current, forMode: .default) in close()
143 output = nil in close()
/thrift-3.4.0/lib/cpp/src/thrift/protocol/
DTDebugProtocol.cpp342 string output = "\""; in writeString() local
346 output += "\\\\"; in writeString()
348 output += "\\\""; in writeString()
352 output += *it; in writeString()
356 output += "\\a"; in writeString()
359 output += "\\b"; in writeString()
362 output += "\\f"; in writeString()
365 output += "\\n"; in writeString()
368 output += "\\r"; in writeString()
371 output += "\\t"; in writeString()
[all …]
/thrift-3.4.0/lib/d/test/
Dtransport_test.d118 Transport output; variable
141 if (inner_.output) { in this()
142 output = new WrapperTransport(inner_.output); in this()
166 output = buf; in this()
179 output = new TSocket(sockets[1]); in this()
184 output.close(); in ~this()
204 output = writer; in this()
217 output.close(); in ~this()
267 assert(transports.output);
301 transports.output.write(wbuf[totalWritten .. totalWritten + writeSize]);
[all …]
/thrift-3.4.0/lib/nodejs/lib/thrift/
Dthrift.js124 TApplicationException.prototype.write = function(output){ argument
125 output.writeStructBegin('TApplicationException');
128 output.writeFieldBegin('message', Type.STRING, 1);
129 output.writeString(this.message);
130 output.writeFieldEnd();
134 output.writeFieldBegin('type', Type.I32, 2);
135 output.writeI32(this.code);
136 output.writeFieldEnd();
139 output.writeFieldStop();
140 output.writeStructEnd();
Dserver.js56 var output = new protocol(new transport(undefined, outputCb));
61 output = input;
62 output.trans.onFlush = outputCb;
67 processor.process(input, output);
/thrift-3.4.0/lib/dart/test/protocol/
Dt_protocol_test.dart67 var output = primitive.read();
69 expect(output, input);
79 var output = primitive.read();
81 expect(output, primitive.defaultValue);
107 var output = protocol.readStructBegin();
110 expect(output, isNotNull);
123 var output = protocol.readFieldBegin();
126 expect(output.type, input.type);
127 expect(output.id, input.id);
140 var output = protocol.readMapBegin();
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/transport/
DTestTIOStreamTransport.java36 OutputStream output = new ByteArrayOutputStream(); in testOpenClose_2streams() local
37 TTransport transport = new TIOStreamTransport(input, output); in testOpenClose_2streams()
53 OutputStream output = new ByteArrayOutputStream(); in testIOpenClose_1output() local
54 TTransport transport = new TIOStreamTransport(output); in testIOpenClose_1output()
/thrift-3.4.0/compiler/cpp/tests/ocaml/
DREADME.md5 2. Generate the OCaml output using the OCaml generator
6 3. Capture the generated output in `ostringstream`
16 rm -rf gen-ocaml; cmake --build . && ctest --output-on-failure
/thrift-3.4.0/build/
Dveralign.sh202 local output
204 output=$(jq -e ".version" "$1")
206 output=$(jq -e ".version = \"${NEWVERSION}\"" "$1" > tmp.$$.json && mv tmp.$$.json "$1")
214 output=${output%\"}
216 printf "%-60s | %5d | MATCHES: version: \"${reverse}${green}${output}${normal}\"" "$1" 1
263 local output
281 output=$(sed -i "s/${oldRegex}/${newString}/g" "$1")
284 printf "%-60s | %5d | ${red}ERROR${normal}: %s" "$1" "$count" "$output"
/thrift-3.4.0/lib/rb/lib/thrift/transport/
Dio_stream_transport.rb28 def initialize(input, output) argument
30 @output = output
/thrift-3.4.0/lib/cpp/test/
DTBufferBaseTest.cpp192 string output = buffer.getBufferAsString(); in BOOST_AUTO_TEST_CASE() local
193 BOOST_CHECK_EQUAL(data_str, output); in BOOST_AUTO_TEST_CASE()
235 string output; in BOOST_AUTO_TEST_CASE() local
250 unsigned int got = buffer.readAppendToString(output, d2[index]); in BOOST_AUTO_TEST_CASE()
256 BOOST_CHECK_EQUAL(output, data_str); in BOOST_AUTO_TEST_CASE()
386 string output = buffer.getBufferAsString(); in BOOST_AUTO_TEST_CASE() local
387 BOOST_CHECK_EQUAL(data_str.substr((1<<13)-42), output); in BOOST_AUTO_TEST_CASE()
416 string output = buffer->getBufferAsString(); in BOOST_AUTO_TEST_CASE() local
417 BOOST_CHECK_EQUAL(data_str, output); in BOOST_AUTO_TEST_CASE()
516 string output = buffer->getBufferAsString(); in BOOST_AUTO_TEST_CASE() local
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/
DTServerEventHandler.java41 ServerContext createContext(TProtocol input, TProtocol output); in createContext() argument
44 void deleteContext(ServerContext serverContext, TProtocol input, TProtocol output); in deleteContext() argument
/thrift-3.4.0/lib/netstd/Thrift/Server/
DTServerEventHandler.cs49 …Task<object> CreateContextAsync(TProtocol input, TProtocol output, CancellationToken cancellationT… in CreateContextAsync() argument
54 Task DeleteContextAsync(object serverContext, TProtocol input, TProtocol output, in DeleteContextAsync() argument
/thrift-3.4.0/lib/py/src/ext/
Dprotocol.tcc56 inline int read_buffer(PyObject* buf, char** output, int len) { in read_buffer() argument
64 return PycStringIO->cread(buf, output, len); in read_buffer()
139 inline int read_buffer(PyObject* buf, char** output, int len) {
142 *output = buf2->buf + buf2->pos;
144 *output = PyBytes_AS_STRING(buf2->buf) + buf2->pos;
262 bool ProtocolBase<Impl>::readBytes(char** output, int len) { in readBytes() argument
271 int rlen = detail::read_buffer(input_.stringiobuf.get(), output, len); in readBytes()
280 *output, rlen, len, nullptr)); in readBytes()
288 rlen = detail::read_buffer(input_.stringiobuf.get(), output, len); in readBytes()
831 PyObject* ProtocolBase<Impl>::readStruct(PyObject* output, PyObject* klass, PyObject* spec_seq) { in readStruct() argument
[all …]
/thrift-3.4.0/tutorial/js/src/
DHttpd.java119 final String output = this.thriftRequest(entityContent); in handle() local
121 System.out.println("Outgoing content: "+output); in handle()
127 writer.write(output); in handle()
200 byte[] output = new byte[outbuffer.length()]; in thriftRequest()
201 outbuffer.readAll(output, 0, output.length); in thriftRequest()
203 return new String(output,"UTF-8"); in thriftRequest()
/thrift-3.4.0/lib/php/lib/
DTMultiplexedProcessor.php86 public function process(TProtocol $input, TProtocol $output) argument
115 $output
/thrift-3.4.0/lib/js/test/src/test/
DHttpd.java124 final String output = this.thriftRequest(entityContent); in handle() local
126 System.out.println("Outgoing content: "+output); in handle()
132 writer.write(output); in handle()
224 byte[] output = new byte[outbuffer.length()]; in thriftRequest()
225 outbuffer.readAll(output, 0, output.length); in thriftRequest()
227 return new String(output,"UTF-8"); in thriftRequest()

1234