Home
last modified time | relevance | path

Searched full:this (Results 1 – 25 of 1548) sorted by relevance

12345678910>>...62

/thrift-3.4.0/lib/nodejs/lib/thrift/
Dbuffered_transport.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
27 this.defaultReadBufferSize = 1024;
28 this.writeBufferSize = 512; // Soft Limit
29 this.inBuf = new Buffer(this.defaultReadBufferSize);
30 this.readCursor = 0;
31 this.writeCursor = 0; // for input buffer
32 this.outBuffers = [];
33 this.outCount = 0;
[all …]
Dconnection.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
36 var self = this;
37 EventEmitter.call(this);
39 this.seqId2Service = {};
40 this.connection = stream;
41 this.ssl = (stream.encrypted);
42 this.options = options || {};
43 this.transport = this.options.transport || TBufferedTransport;
[all …]
Dbinary_protocol.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
41 this.trans = trans;
42 this.strictRead = (strictRead !== undefined ? strictRead : false);
43 this.strictWrite = (strictWrite !== undefined ? strictWrite : true);
44 this._seqid = null;
48 return this.trans.flush();
52 if (this.strictWrite) {
53 this.writeI32(VERSION_1 | type);
[all …]
Dws_transport.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
36 this.__reset(url);
41 this.url = url; //Where to connect
42 this.socket = null; //The web socket
43 this.callbacks = []; //Pending callbacks
44 this.send_pending = []; //Buffers/Callback pairs waiting to be sent
45 this.send_buf = ''; //Outbound data, immutable until sent
46 this.recv_buf = ''; //Inbound data
[all …]
Dframed_transport.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
27 this.inBuf = buffer || new Buffer(0);
28 this.outBuffers = [];
29 this.outCount = 0;
30 this.readPos = 0;
31 this.onFlush = callback;
79 this._seqid = seqid;
83 if (this.readPos + len > this.inBuf.length) {
[all …]
Dws_connection.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
78 EventEmitter.call(this);
81 this.options = options || {};
82 this.host = host;
83 this.port = port;
84 this.secure = this.options.secure || false;
85 this.transport = this.options.transport || TBufferedTransport;
86 this.protocol = this.options.protocol || TJSONProtocol;
[all …]
Dheader_protocol.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
31 Error.call(this);
33 Error.captureStackTrace(this, this.constructor);
35 this.name = this.constructor.name;
36 this.message = message;
61 this.trans = trans;
62 this.setProtocol();
69 this.trans.writeHeaders();
[all …]
Djson_protocol.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
43 this.tstack = [];
44 this.tpos = [];
45 this.trans = trans;
93 this.writeToTransportIfStackIsFlushable();
94 return this.trans.flush();
98 if (this.tstack.length === 1) {
99 this.trans.write(this.tstack.pop());
[all …]
Dheader_transport.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
26 Error.call(this);
28 Error.captureStackTrace(this, this.constructor);
30 this.name = this.constructor.name;
31 this.message = message;
57 this.outputBuffer = null;
58 var _this = this;
59 this.transport = new TBufferedTransport(null, function(output) {
[all …]
Dxhr_connection.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
34 * host and port of the page from which this javascript is served.
43 this.options = options || {};
44 this.wpos = 0;
45 this.rpos = 0;
46 this.useCORS = (options && options.useCORS);
47 this.send_buf = '';
48 this.recv_buf = '';
[all …]
/thrift-3.4.0/lib/php/lib/Protocol/
DTJSONProtocol.php6 * distributed with this work for additional information
7 * regarding copyright ownership. The ASF licenses this file
9 * "License"); you may not use this file except in compliance
166 array_push($this->contextStack_, $this->context_);
167 $this->context_ = $c;
172 $this->context_ = array_pop($this->contextStack_);
178 $this->context_ = new BaseContext();
179 $this->reader_ = new LookaheadReader($this);
184 $this->contextStack_ = array();
185 $this->context_ = new BaseContext();
[all …]
DTSimpleJSONProtocol.php6 * distributed with this work for additional information
7 * regarding copyright ownership. The ASF licenses this file
9 * "License"); you may not use this file except in compliance
59 $this->writeContextStack_[] = $this->writeContext_;
60 $this->writeContext_ = $c;
68 $this->writeContext_ = array_pop($this->writeContextStack_);
76 if ($this->writeContext_->isMapKey()) {
86 $this->writeContext_->write();
88 $this->trans_->write(json_encode((string)$b));
93 $isMapKey = $this->writeContext_->isMapKey();
[all …]
DTCompactProtocol.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
133 $out = $this->getVarint($data);
135 $this->trans_->write($out, $result);
146 $x = $this->trans_->readAll(1);
168 $this->writeUByte(TCompactProtocol::PROTOCOL_ID) +
169 $this->writeUByte(TCompactProtocol::VERSION |
171 $this->writeVarint($seqid) +
172 $this->writeString($name);
[all …]
DTProtocolDecorator.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
49 * @param TProtocol $protocol All operations will be forward to this instance. Must be non-null.
54 $this->concreteProtocol_ = $protocol;
62 * @param int $seqid The sequence id of this message
66 return $this->concreteProtocol_->writeMessageBegin($name, $type, $seqid);
74 return $this->concreteProtocol_->writeMessageEnd();
87 return $this->concreteProtocol_->writeStructBegin($name);
98 return $this->concreteProtocol_->writeStructEnd();
[all …]
/thrift-3.4.0/lib/php/test/Protocol/
DTJSONProtocolTest.php6 * distributed with this work for additional information
7 * regarding copyright ownership. The ASF licenses this file
9 * "License"); you may not use this file except in compliance
34 * This test suite depends on running the compiler against the
59 $this->transport = new TMemoryBuffer();
60 $this->protocol = new TJSONProtocol($this->transport);
61 $this->transport->open();
70 $args->write($this->protocol);
72 $actual = $this->transport->read(Fixtures::$bufsize);
75 $this->assertEquals($expected, $actual);
[all …]
DTSimpleJSONProtocolTest.php6 * distributed with this work for additional information
7 * regarding copyright ownership. The ASF licenses this file
9 * "License"); you may not use this file except in compliance
34 * This test suite depends on running the compiler against the
60 $this->transport = new TMemoryBuffer();
61 $this->protocol = new TSimpleJSONProtocol($this->transport);
62 $this->transport->open();
71 $args->write($this->protocol);
73 $actual = $this->transport->read(Fixtures::$bufsize);
76 $this->assertEquals($expected, $actual);
[all …]
/thrift-3.4.0/lib/php/lib/Transport/
DTSocket.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
60 * Combined with sendTimeoutUsec this is used for send timeouts.
69 * Combined with sendTimeoutSec this is used for send timeouts.
78 * Combined with recvTimeoutUsec this is used for recv timeouts.
87 * Combined with recvTimeoutSec this is used for recv timeouts.
128 $this->host_ = $host;
129 $this->port_ = $port;
130 $this->persist_ = $persist;
[all …]
DTBufferedTransport.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
77 $this->transport_ = $transport;
78 $this->rBufSize_ = $rBufSize;
79 $this->wBufSize_ = $wBufSize;
84 return $this->transport_->isOpen();
94 $this->transport_->open();
99 $this->transport_->close();
104 if (TStringFuncFactory::create()->strlen($this->rBuf_) === 0) {
[all …]
DTHttpClient.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
112 $this->scheme_ = $scheme;
113 $this->host_ = $host;
114 $this->port_ = $port;
115 $this->uri_ = $uri;
116 $this->buf_ = '';
117 $this->handle_ = null;
118 $this->timeout_ = null;
[all …]
DTFramedTransport.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
77 $this->transport_ = $transport;
78 $this->read_ = $read;
79 $this->write_ = $write;
84 return $this->transport_->isOpen();
89 $this->transport_->open();
94 $this->transport_->close();
105 if (!$this->read_) {
[all …]
/thrift-3.4.0/lib/js/src/
Dthrift.js4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
32 * This library creates one global object: Thrift
33 * Code in this library must never create additional global identifiers,
145 this.message = message;
155 return this.message;
196 this.message = message;
197 this.code = typeof code === 'number' ? code : 0;
219 this.message = ret.value;
[all …]
/thrift-3.4.0/lib/dart/test/serializer/
Dserializer_test_data.dart4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
51 int get i => this._i;
54 this._i = i;
55 this.__isset_i = true;
58 bool isSetI() => this.__isset_i;
61 this.__isset_i = false;
65 double get d => this._d;
68 this._d = d;
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/protocol/
DTVirtualProtocol.h4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
34 * This class provides default implementations of the non-virtual TProtocol
39 * You probably don't want to use this class directly. Use TVirtualProtocol
49 "this protocol does not support reading (yet)."); in readMessageBegin()
54 "this protocol does not support reading (yet)."); in readMessageEnd()
60 "this protocol does not support reading (yet)."); in readStructBegin()
65 "this protocol does not support reading (yet)."); in readStructEnd()
73 "this protocol does not support reading (yet)."); in readFieldBegin()
[all …]
/thrift-3.4.0/lib/php/lib/Protocol/JSON/
DPairContext.php5 * distributed with this work for additional information
6 * regarding copyright ownership. The ASF licenses this file
8 * "License"); you may not use this file except in compliance
35 $this->p_ = $p;
40 if ($this->first_) {
41 $this->first_ = false;
42 $this->colon_ = true;
44 … $this->p_->getTransport()->write($this->colon_ ? TJSONProtocol::COLON : TJSONProtocol::COMMA);
45 $this->colon_ = !$this->colon_;
51 if ($this->first_) {
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/partial/
DThriftMetadata.java4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
7 * "License"); you may not use this file except in compliance
45 * <p>This class is mainly used by {@code TDeserializer}.
61 this.id = id; in FieldTypeEnum()
62 this.name = name; in FieldTypeEnum()
93 // Placeholder to attach additional data. This class or its descendents
94 // do not try to access or interpret this field.
98 this.parent = parent; in ThriftObject()
99 this.fieldId = fieldId; in ThriftObject()
[all …]

12345678910>>...62