| /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 | 264 private static int translateShortCodes(int code, int[] ringBuffer, int index) { in translateShortCodes() argument
268 return ringBuffer[index] + DISTANCE_SHORT_CODE_VALUE_OFFSET[code]; in translateShortCodes()
543 if (s.ringBuffer.length != 0) { in maybeReallocateRingBuffer()
544 System.arraycopy(s.ringBuffer, 0, newBuffer, 0, s.ringBufferSize); in maybeReallocateRingBuffer()
546 s.ringBuffer = newBuffer; in maybeReallocateRingBuffer()
660 final byte[] ringBuffer = s.ringBuffer; in copyUncompressedData()
670 BitReader.copyBytes(s, ringBuffer, s.pos, chunkLength); in copyUncompressedData()
687 System.arraycopy(s.ringBuffer, s.ringBufferBytesWritten, s.output, in writeRingBuffer()
732 byte[] ringBuffer = s.ringBuffer; in decompress()
745 ringBuffer = s.ringBuffer; in decompress()
[all …]
|
| D | State.java | 12 byte[] ringBuffer; field in State
80 this.ringBuffer = new byte[0]; in State()
|
| /external/brotli/js/ |
| D | decode.js | 218 function translateShortCodes(code, ringBuffer, index) { argument
222 return ringBuffer[index] + DISTANCE_SHORT_CODE_VALUE_OFFSET[code];
568 if (s.ringBuffer.length != 0) {
569 newBuffer.set(s.ringBuffer.subarray(0, 0 + s.ringBufferSize), 0);
571 s.ringBuffer = newBuffer;
694 var /** !Int8Array */ ringBuffer = s.ringBuffer;
701 copyBytes(s, ringBuffer, s.pos, chunkLength);
719 …s.output.set(s.ringBuffer.subarray(s.ringBufferBytesWritten, s.ringBufferBytesWritten + toWrite), …
769 var /** !Int8Array */ ringBuffer = s.ringBuffer;
779 ringBuffer = s.ringBuffer;
[all …]
|
| D | decode.min.js | 1 …ringBuffer.length!=0){a.set(e.ringBuffer.subarray(0,0+e.ringBufferSize),0)}e.ringBuffer=a;e.ringBu…
|
| /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/lz4/examples/ |
| D | Makefile | 52 all: printVersion doubleBuffer dictionaryRandomAccess ringBuffer ringBufferHC \
67 ringBuffer : blockStreaming_ringBuffer.c $(LZ4DIR)/liblz4.a target
96 ./ringBuffer$(EXT) $(TESTFILE)
110 ringBuffer$(EXT) ringBufferHC$(EXT) lineCompress$(EXT) frameCompress$(EXT) \
|
| D | .gitignore | 5 /ringBuffer
|
| /external/lz4/tests/ |
| D | fuzzer.c | 968 char ringBuffer[ringBufferSize]; in FUZ_unitTests() local
1023 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
1024 …compressedSize = LZ4_compress_fast_continue(&streamingState, ringBuffer + rNext, testCompressed, m… in FUZ_unitTests()
1183 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
1184 …compressedSize = LZ4_compress_HC_continue(&sHC, ringBuffer + rNext, testCompressed, messageSize, t… in FUZ_unitTests()
|