Home
last modified time | relevance | path

Searched refs:frameSize (Results 1 – 11 of 11) sorted by relevance

/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/
DTNonblockingMultiFetchClient.java203 int[] frameSize = new int[numTotalServers]; in run() local
308 frameSize[index] = recvBuf[index].getInt(0); in run()
310 if (frameSize[index] <= 0) { in run()
314 frameSize[index], in run()
320 if (frameSize[index] + 4 > stats.getMaxResponseBytes()) { in run()
321 stats.setMaxResponseBytes(frameSize[index] + 4); in run()
324 if (frameSize[index] + 4 > maxRecvBufBytesPerServer) { in run()
328 frameSize[index], in run()
336 recvBuf[index] = ByteBuffer.allocate(frameSize[index] + 4); in run()
337 recvBuf[index].putInt(frameSize[index]); in run()
[all …]
/thrift-3.4.0/lib/d/src/thrift/transport/
Dframed.d230 int frameSize = bswap((cast(int[])(actualData[0..int.sizeof]))[0]); local
231 enforce(frameSize == writtenData.length);
270 size_t frameSize; local
276 frameSize += chunkSize;
277 if (frameSize > 0 && uniform(0, flushProbability, randGen) == 0) {
278 frameSizes ~= frameSize;
279 frameSize = 0;
283 if (frameSize > 0) {
284 frameSizes ~= frameSize;
285 frameSize = 0;
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/layered/
DTFramedTransport.java173 public static void encodeFrameSize(final int frameSize, final byte[] buf) { in encodeFrameSize() argument
174 buf[0] = (byte) (0xff & (frameSize >> 24)); in encodeFrameSize()
175 buf[1] = (byte) (0xff & (frameSize >> 16)); in encodeFrameSize()
176 buf[2] = (byte) (0xff & (frameSize >> 8)); in encodeFrameSize()
177 buf[3] = (byte) (0xff & (frameSize)); in encodeFrameSize()
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/
DAbstractNonblockingServer.java322 int frameSize = buffer_.getInt(0); in read() local
323 if (frameSize <= 0) { in read()
326 + frameSize in read()
333 if (frameSize > trans_.getMaxFrameSize()) { in read()
336 + frameSize in read()
345 if (readBufferBytesAllocated.get() + frameSize > MAX_READ_BUFFER_BYTES) { in read()
350 readBufferBytesAllocated.addAndGet(frameSize + 4); in read()
353 buffer_ = ByteBuffer.allocate(frameSize + 4); in read()
354 buffer_.putInt(frameSize); in read()
/thrift-3.4.0/lib/nodejs/lib/thrift/
Dheader_transport.js185 THeaderTransport.prototype.setMaxFrameSize = function(frameSize) { argument
186 this.maxFrameSize = frameSize;
229 var frameSize = readBuffer.readInt32BE(FRAME_SIZE_OFFSET);
230 if (frameSize > this.maxFrameSize) {
318 var frameSize = Buffer.alloc(4);
319 frameSize.writeInt32BE(10 + this.outCount + headerContentBuffer.length);
331 frameSize,
Dframed_transport.js51 var frameSize = binary.readI32(Buffer.from(residual.slice(0, 4)), 0);
53 if (residual.length < 4 + frameSize) {
60 var frame = Buffer.from(residual.splice(0, frameSize));
/thrift-3.4.0/lib/go/thrift/
Dheader_transport.go351 frameSize := binary.BigEndian.Uint32(buf)
352 if frameSize&VERSION_MASK == VERSION_1 {
363 if frameSize > THeaderMaxFrameSize || frameSize > uint32(t.cfg.GetMaxFrameSize()) {
375 _, err = io.CopyN(t.frameBuffer, t.reader, int64(frameSize))
386 return t.parseHeaders(ctx, frameSize)
416 func (t *THeaderTransport) parseHeaders(ctx context.Context, frameSize uint32) error {
426 frameSize -= headerMetaSize
430 if int64(frameSize) < headerLength {
/thrift-3.4.0/lib/swift/Sources/
DTFramedTransport.swift78 let frameSize = encodeFrameSize(size: UInt32(buff.count)) in flush() variable
80 try transport.write(data: frameSize) in flush()
/thrift-3.4.0/lib/d/src/thrift/server/
Dnonblocking.d1093 auto frameSize = readWant_; in workSocket() local
1098 (cast(ubyte[])((&frameSize)[0 .. 1]))[readBufferPos_ .. $]); in workSocket()
1113 if (readBufferPos_ < frameSize.sizeof) { in workSocket()
1116 readWant_ = frameSize; in workSocket()
1120 auto size = netToHost(frameSize); in workSocket()
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.cpp701 auto frameSize = (int32_t)htonl(writeBufferSize_ - 4); in transition() local
702 memcpy(writeBuffer_, &frameSize, 4); in transition()
/thrift-3.4.0/doc/specs/
Dthrift-tconfiguration.md63 …ing the remaining read byte count, the known message size should be set to frameSize + sizeof(i32).