| /thrift-3.4.0/lib/nodejs/lib/thrift/ |
| D | binary.js | 33 exports.readI16 = function(buff, off) { argument
35 var v = buff[off + 1];
36 v += buff[off] << 8;
37 if (buff[off] & 128) {
43 exports.readI32 = function(buff, off) { argument
45 var v = buff[off + 3];
46 v += buff[off + 2] << 8;
47 v += buff[off + 1] << 16;
48 v += buff[off] * POW_24;
49 if (buff[off] & 0x80) {
[all …]
|
| D | compact_protocol.js | 370 var buff = new Buffer(8);
373 buff[7] = (v < 0 ? 0x80 : 0x00);
411 buff[6] = (e << 4) & 0xf0;
412 buff[7] |= (e >> 4) & 0x7f;
414 buff[0] = m & 0xff;
416 buff[1] = m & 0xff;
418 buff[2] = m & 0xff;
420 buff[3] = m & 0xff;
422 buff[4] = m & 0xff;
424 buff[5] = m & 0xff;
[all …]
|
| D | binary_protocol.js | 271 var buff = this.trans.read(8);
272 return new Int64(buff);
|
| /thrift-3.4.0/lib/swift/Sources/ |
| D | TBinaryProtocol.swift | 187 var buff = Data() in read() variable
189 buff = try self.transport.readAll(size: 1) in read()
191 return buff[0] in read()
195 var buff = Data() in read() variable
197 buff = try self.transport.readAll(size: 1) in read()
199 return buff.withUnsafeBytes { pntr in in read()
205 var buff = Data() in read() variable
207 buff = try self.transport.readAll(size: 2) in read()
209 var ret = Int16(buff[0] & 0xff) << 8 in read()
210 ret |= Int16(buff[1] & 0xff) in read()
[all …]
|
| D | TTransport.swift | 42 var buff = Data() in read() variable
47 buff.append(chunk) in read()
52 return buff in read()
|
| D | TCompactProtocol.swift | 349 var buff: UInt8 = 0 in read() variable
351 buff = try self.transport.readAll(size: 1)[0] in read()
353 return buff in read()
357 var buff = Data() in read() variable
359 buff = try self.transport.readAll(size: 1) in read()
361 return buff.withUnsafeBytes { pntr in in read()
382 var buff = Data() in read() variable
384 buff = try self.transport.readAll(size: 8) in read()
386 let i64: UInt64 = buff.withUnsafeBytes { $0.load(as: UInt64.self) } in read()
568 let buff = Data(bytes: &value, count: MemoryLayout<Int8>.size(ofValue: value)) in write() variable
[all …]
|
| D | TFramedTransport.swift | 75 let buff = writeBuffer in flush() variable
78 let frameSize = encodeFrameSize(size: UInt32(buff.count)) in flush()
81 try transport.write(data: buff) in flush()
|
| D | TSocketTransport.swift | 190 var buff = Array<UInt8>.init(repeating: 0, count: size) in read() variable
191 let readBytes = Sys.read(socketDescriptor, &buff, size) in read()
193 return Data(buff[0..<readBytes]) in read()
|
| /thrift-3.4.0/lib/lua/ |
| D | TBinaryProtocol.lua | 100 local buff = libluabpack.bpack('c', byte)
101 self.trans:write(buff)
105 local buff = libluabpack.bpack('s', i16)
106 self.trans:write(buff)
110 local buff = libluabpack.bpack('i', i32)
111 self.trans:write(buff)
115 local buff = libluabpack.bpack('l', i64)
116 self.trans:write(buff)
120 local buff = libluabpack.bpack('d', dub)
121 self.trans:write(buff)
[all …]
|
| D | TCompactProtocol.lua | 188 local buff = libluabpack.bpack('c', byte)
189 self.trans:write(buff)
205 local buff = libluabpack.bpack('d', dub)
206 self.trans:write(buff)
367 local buff = self.trans:readAll(1)
368 local val = libluabpack.bunpack('c', buff)
373 local buff = self.trans:readAll(1)
374 local val = libluabpack.bunpack('C', buff)
394 local buff = self.trans:readAll(8)
395 local val = libluabpack.bunpack('d', buff)
|
| D | TJsonProtocol.lua | 180 local buff = libluabpack.bpack('c', outCh)
181 self.trans:write(buff)
183 buff = libluabpack.bpack('c', outCh)
184 self.trans:write(buff)
202 local buff = libluabpack.bpack('c', outCh)
203 self.trans:write(buff)
381 local buff = libluabpack.bpack('c', byte)
382 local val = libluabpack.bunpack('c', buff)
387 local buff = libluabpack.bpack('s', i16)
388 local val = libluabpack.bunpack('s', buff)
[all …]
|
| /thrift-3.4.0/lib/py/test/ |
| D | thrift_TZlibTransport.py | 49 buff = TTransport.TMemoryBuffer()
50 trans = TTransport.TBufferedTransportFactory().getTransport(buff)
56 value = buff.getvalue()
59 buff = TTransport.TMemoryBuffer(value)
60 trans = TTransport.TBufferedTransportFactory().getTransport(buff)
72 buff = TTransport.TMemoryBuffer()
73 trans = TTransport.TBufferedTransportFactory().getTransport(buff)
82 value = buff.getvalue()
85 buff = TTransport.TMemoryBuffer(value)
86 trans = TTransport.TBufferedTransportFactory().getTransport(buff)
|
| D | thrift_json.py | 52 buff = TTransport.TMemoryBuffer()
53 transport = TTransport.TBufferedTransportFactory().getTransport(buff)
73 value = buff.getvalue()
81 buff = TTransport.TMemoryBuffer(read_data.encode('utf-8'))
82 transport = TTransport.TBufferedTransportFactory().getTransport(buff)
|
| /thrift-3.4.0/lib/py/src/protocol/ |
| D | TBinaryProtocol.py | 110 buff = pack("!b", byte)
111 self.trans.write(buff)
114 buff = pack("!h", i16)
115 self.trans.write(buff)
118 buff = pack("!i", i32)
119 self.trans.write(buff)
122 buff = pack("!q", i64)
123 self.trans.write(buff)
126 buff = pack("!d", dub)
127 self.trans.write(buff)
[all …]
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/ |
| D | TestStructOrder.java | 59 byte[] buff = new byte[1024]; in readAllBytes()
61 while ((bytesRead = is.read(buff, 0, buff.length)) != -1) { in readAllBytes()
62 os.write(buff, 0, bytesRead); in readAllBytes()
|
| /thrift-3.4.0/lib/py/src/transport/ |
| D | TSocket.py | 153 buff = self.handle.recv(sz)
163 buff = ''
168 if len(buff) == 0:
171 return buff
173 def write(self, buff): argument
178 have = len(buff)
181 plus = self.handle.send(buff)
186 buff = buff[plus:]
|
| D | TTransport.py | 59 buff = b''
65 buff += chunk
70 return buff
287 buff = self.__trans.readAll(4)
288 sz, = unpack('!i', buff)
|
| /thrift-3.4.0/lib/javame/src/org/apache/thrift/transport/ |
| D | TFramedTransport.java | 99 byte[] buff = new byte[size]; in readFrame()
100 transport_.readAll(buff, 0, size); in readFrame()
101 readBuffer_ = new ByteArrayInputStream(buff); in readFrame()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TSaslTransport.java | 406 byte[] buff = new byte[dataLength]; in readFrame()
408 underlyingTransport.readAll(buff, 0, dataLength); in readFrame()
410 buff = sasl.unwrap(buff, 0, buff.length); in readFrame()
411 LOGGER.debug("data length after unwrap: {}", buff.length); in readFrame()
413 readBuffer.reset(buff); in readFrame()
|
| /thrift-3.4.0/lib/nodejs/test/ |
| D | deep-constructor.test.js | 26 let buff;
28 buff = msg;
33 return buff;
45 let buff;
47 buff = msg;
54 return buff;
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/layered/ |
| D | TFramedTransport.java | 152 byte[] buff = new byte[size]; in readFrame()
153 getInnerTransport().readAll(buff, 0, size); in readFrame()
154 readBuffer_.reset(buff); in readFrame()
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | THttpServer.cpp | 156 char buff[128]; in getTimeRFC1123() local
162 sprintf(buff, in getTimeRFC1123()
171 return std::string(buff); in getTimeRFC1123()
|
| /thrift-3.4.0/lib/dart/lib/src/protocol/ |
| D | t_compact_protocol.dart | 417 Uint8List buff = Uint8List(length);
418 transport.readAll(buff, 0, length);
419 return _utf8Codec.decode(buff);
427 Uint8List buff = Uint8List(length);
428 transport.readAll(buff, 0, length);
429 return buff;
|
| /thrift-3.4.0/lib/swift/ |
| D | README.md | 174 let otrans = TMemoryBufferTransport(flushHandler: { trans, buff in
175 let array = buff.withUnsafeBytes {
176 Array<UInt8>(UnsafeBufferPointer(start: $0, count: buff.count))
|
| /thrift-3.4.0/lib/delphi/src/ |
| D | Thrift.Transport.pas | 1415 buff : TBytes;
1438 SetLength( buff, size );
1439 InnerTransport.ReadAll( buff, 0, size );
1443 if Length(buff) > 0
1444 then FReadBuffer.Write( Pointer(@buff[0])^, size );
|
