- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for buffer_end (0.95 sec)
-
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/kryo/StringDeduplicatingKryoBackedEncoder.java
output.writeString(key); } else { output.writeInt(index); } } /** * Returns the total number of bytes written by this encoder, some of which may still be buffered. */ public long getWritePosition() { return output.total(); } @Override public void flush() { output.flush(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 3.7K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
return n, err } if sock.pd.pollable() { if err := sock.pd.waitRead(sock.isFile); err != nil { return n, err } } } } // splicePump moves all the buffered data from a pipe to a socket. // // Invariant: when entering splicePump, there are exactly inPipe // bytes of data in the pipe, from a previous call to spliceDrain. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/log/uds.go
} if resp.StatusCode != http.StatusOK { return fmt.Errorf("uds server returns non-ok status %v: %v", u.url, resp.Status) } return nil } // Write implements zapcore.Core. Log messages will be temporarily buffered and sent to // UDS server asyncrhonously. func (u *udsCore) Write(entry zapcore.Entry, fields []zapcore.Field) error { buffer, err := u.enc.EncodeEntry(entry, fields) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 16 00:20:01 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/kryo/KryoBackedCodecTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
stream.close() } then: 1 * dispatch.onOutput({ it instanceof ReadStdInEvent }) >> { instant.requested } } def "read bytes continues to return buffered content when stream is closed"() { def dispatch = Mock(OutputEventListener) def stream = new StdInStream(dispatch) def text = "some text" def bytes = text.bytes when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
src/mime/quotedprintable/writer.go
} w.line[w.i] = '=' w.line[w.i+1] = upperhex[b>>4] w.line[w.i+2] = upperhex[b&0x0f] w.i += 3 return nil } const upperhex = "0123456789ABCDEF" // checkLastByte encodes the last buffered byte if it is a space or a tab. func (w *Writer) checkLastByte() error { if w.i == 0 { return nil } b := w.line[w.i-1] if isWhitespace(b) { w.i-- if err := w.encode(b); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 3.2K bytes - Viewed (0) -
src/time/sleep.go
// (Code may of course still want to call Stop to stop the timer for other reasons.) // // Before Go 1.23, the channel associated with a Timer was // asynchronous (buffered, capacity 1), which meant that // stale time values could be received even after [Timer.Stop] // or [Timer.Reset] returned. // As of Go 1.23, the channel is synchronous (unbuffered, capacity 0),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/kryo/StringDeduplicatingKryoBackedDecoder.java
} catch (KryoException e) { throw maybeEndOfStream(e); } } /** * Returns the total number of bytes consumed by this decoder. Some additional bytes may also be buffered by this decoder but have not been consumed. */ public long getReadPosition() { return input.total() + extraSkipped; } @Override public void close() throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 6.2K bytes - Viewed (0) -
tests/fuzz/oss_fuzz_build.sh
printf "package main\nimport _ \"github.com/AdamKorcz/go-118-fuzz-build/testing\"\n" > register.go go mod tidy # Find all native fuzzers and compile them # shellcheck disable=SC2016 grep --line-buffered --include '*_test.go' -Pr 'func Fuzz.*\(.* \*testing\.F' | sed -E 's/(func Fuzz(.*)\(.*)/\2/' | xargs -I{} sh -c ' fname="$(dirname $(echo "{}" | cut -d: -f1))" func="Fuzz$(echo "{}" | cut -d: -f2)" set -x
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 15:50:05 UTC 2024 - 6.5K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/kryo/KryoBackedDecoder.java
} return value; } /** * Returns the total number of bytes consumed by this decoder. Some additional bytes may also be buffered by this decoder but have not been consumed. */ public long getReadPosition() { return input.total() + extraSkipped; } @Override public void close() throws IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 7.3K bytes - Viewed (0)