| /external/opencensus-java/impl/src/main/java/io/opencensus/impl/internal/ |
| D | DisruptorEventQueue.java | 106 private final RingBuffer<DisruptorEvent> ringBuffer; field in DisruptorEventQueue
113 RingBuffer<DisruptorEvent> ringBuffer, in DisruptorEventQueue() argument
116 this.ringBuffer = ringBuffer; in DisruptorEventQueue()
134 final RingBuffer<DisruptorEvent> ringBuffer = disruptor.getRingBuffer(); in create() local
140 long sequence = ringBuffer.next(); in create()
142 DisruptorEvent event = ringBuffer.get(sequence); in create()
145 ringBuffer.publish(sequence); in create()
149 return new DisruptorEventQueue(disruptor, ringBuffer, enqueuer); in create()
|
| /external/brotli/java/org/brotli/dec/ |
| D | Decode.java | 726 if (s.ringBuffer.length != 0) { in maybeReallocateRingBuffer()
727 System.arraycopy(s.ringBuffer, 0, newBuffer, 0, s.ringBufferSize); in maybeReallocateRingBuffer()
729 s.ringBuffer = newBuffer; in maybeReallocateRingBuffer()
896 final byte[] ringBuffer = s.ringBuffer; in copyUncompressedData()
906 BitReader.copyBytes(s, ringBuffer, s.pos, chunkLength); in copyUncompressedData()
923 System.arraycopy(s.ringBuffer, s.ringBufferBytesWritten, s.output, in writeRingBuffer()
985 int len = Transform.transformDictionaryWord(s.ringBuffer, s.pos, dictionaryData, in doUseDictionary()
1054 s.ringBuffer, pos, s.cdChunks[s.cdBrIndex], s.cdBrOffset, s.cdBrOffset + length); in copyFromCompoundDictionary()
1091 byte[] ringBuffer = s.ringBuffer; in decompress()
1104 ringBuffer = s.ringBuffer; in decompress()
[all …]
|
| D | State.java | 12 byte[] ringBuffer; field in State
93 this.ringBuffer = new byte[0]; in State()
|
| /external/brotli/csharp/org/brotli/dec/ |
| D | Decode.cs | 141 private static int TranslateShortCodes(int code, int[] ringBuffer, int index) in TranslateShortCodes() argument
147 return ringBuffer[index] + DistanceShortCodeValueOffset[code]; in TranslateShortCodes()
478 if (state.ringBuffer != null) in MaybeReallocateRingBuffer()
480 System.Array.Copy(state.ringBuffer, 0, newBuffer, 0, state.ringBufferSize); in MaybeReallocateRingBuffer()
496 state.ringBuffer = newBuffer; in MaybeReallocateRingBuffer()
613 byte[] ringBuffer = state.ringBuffer; in CopyUncompressedData()
622 Org.Brotli.Dec.BitReader.CopyBytes(br, ringBuffer, state.pos, chunkLength); in CopyUncompressedData()
648 …System.Array.Copy(state.ringBuffer, state.bytesWritten, state.output, state.outputOffset + state.o… in WriteRingBuffer()
673 byte[] ringBuffer = state.ringBuffer; in Decompress()
688 ringBuffer = state.ringBuffer; in Decompress()
[all …]
|
| D | State.cs | 16 internal byte[] ringBuffer; field in Org.Brotli.Dec.State
|
| /external/brotli/js/ |
| D | decode.js | 698 if (s.ringBuffer.length != 0) {
699 newBuffer.set(s.ringBuffer.subarray(0, 0 + s.ringBufferSize), 0);
701 s.ringBuffer = newBuffer;
866 var /** !Int8Array */ ringBuffer = s.ringBuffer;
873 copyBytes(s, ringBuffer, s.pos, chunkLength);
891 …s.output.set(s.ringBuffer.subarray(s.ringBufferBytesWritten, s.ringBufferBytesWritten + toWrite), …
951 var /** !Int8Array */ ringBuffer = s.ringBuffer;
961 ringBuffer = s.ringBuffer;
1015 ringBuffer[s.pos] = readSymbol(s.literalTreeGroup, s.literalTreeIdx, s);
1025 var /** number */ prevByte1 = ringBuffer[(s.pos - 1) & ringBufferMask] & 0xFF;
[all …]
|
| /external/lz4/examples/ |
| D | Makefile | 43 all: printVersion doubleBuffer dictionaryRandomAccess ringBuffer ringBufferHC \
58 ringBuffer : blockStreaming_ringBuffer.c $(LZ4DIR)/liblz4.a target
90 ./ringBuffer$(EXT) $(TESTFILE)
112 ringBuffer$(EXT) ringBufferHC$(EXT) lineCompress$(EXT) frameCompress$(EXT) \
|
| D | .gitignore | 5 /ringBuffer
|
| /external/lz4/contrib/meson/meson/examples/ |
| D | meson.build | 17 'ringBuffer': 'blockStreaming_ringBuffer.c',
|
| /external/lz4/tests/ |
| D | fuzzer.c | 1072 char ringBuffer[ringBufferSize] = {0}; in FUZ_unitTests() local
1258 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
1259 …compressedSize = LZ4_compress_fast_continue(&streamingState, ringBuffer + rNext, testCompressed, (… in FUZ_unitTests()
1506 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
1508 …compressedSize = LZ4_compress_HC_continue(&sHC, ringBuffer + rNext, testCompressed, (int)messageSi… in FUZ_unitTests()
|