- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,058 for readArg (0.11 sec)
-
docs/debugging/inspect/decrypt-v2.go
} if stream.Name == "inspect.zip" { if extracted { return keepFileErr{errors.New("multiple inspect.zip streams found")} } _, err := io.Copy(w, stream) if err != nil { return fmt.Errorf("reading inspect stream: %w", err) } fmt.Println(okMsg) extracted = true continue } if err := stream.Skip(); err != nil { return fmt.Errorf("stream skip: %w", err) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 21:22:47 UTC 2024 - 2.2K bytes - Viewed (0) -
src/internal/saferio/io.go
// allocating all n bytes in cases where n is incorrect. // // The error is io.EOF only if no bytes were read. // If an io.EOF happens after reading some but not all the bytes, // ReadData returns io.ErrUnexpectedEOF. func ReadData(r io.Reader, n uint64) ([]byte, error) { if int64(n) < 0 || n != uint64(int(n)) { // n is too large to fit in int, so we can't allocate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 31 00:34:05 UTC 2023 - 3.4K bytes - Viewed (0) -
src/net/http/request.go
} var textprotoReaderPool sync.Pool func newTextprotoReader(br *bufio.Reader) *textproto.Reader { if v := textprotoReaderPool.Get(); v != nil { tr := v.(*textproto.Reader) tr.R = br return tr } return textproto.NewReader(br) } func putTextprotoReader(r *textproto.Reader) { r.R = nil textprotoReaderPool.Put(r) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
src/internal/zstd/block.go
} return off, nil } panic("unreachable") } // execSeqs reads and executes the sequences. RFC 3.1.1.3.2.1.2. func (r *Reader) execSeqs(data block, off int, litbuf []byte, seqCount int) error { // Set up the initial states for the sequence code readers. rbr, err := r.makeReverseBitReader(data, len(data)-1, off) if err != nil { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 28 17:57:43 UTC 2023 - 10.2K bytes - Viewed (0) -
src/go/build/read.go
// findEmbed advances the input reader to the next //go:embed comment. // It reports whether it found a comment. // (Otherwise it found an error or EOF.) func (r *importReader) findEmbed(first bool) bool { // The import block scan stopped after a non-space character, // so the reader is not at the start of a line on the first call. // After that, each //go:embed extraction leaves the reader // at the end of a line.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 14.1K bytes - Viewed (0) -
src/io/pipe.go
func (r *PipeReader) Read(data []byte) (n int, err error) { return r.pipe.read(data) } // Close closes the reader; subsequent writes to the // write half of the pipe will return the error [ErrClosedPipe]. func (r *PipeReader) Close() error { return r.CloseWithError(nil) } // CloseWithError closes the reader; subsequent writes // to the write half of the pipe will return the error err. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/strings/strings_test.go
} } if res != s { t.Errorf("Reader(%q).ReadRune() produced %q", s, res) } } } var UnreadRuneErrorTests = []struct { name string f func(*Reader) }{ {"Read", func(r *Reader) { r.Read([]byte{0}) }}, {"ReadByte", func(r *Reader) { r.ReadByte() }}, {"UnreadRune", func(r *Reader) { r.UnreadRune() }}, {"Seek", func(r *Reader) { r.Seek(0, io.SeekCurrent) }},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 12:58:37 UTC 2024 - 53K bytes - Viewed (0) -
tools/istio-iptables/pkg/builder/iptables_builder_impl.go
if rb.cfg.TraceLogging && idx >= 0 && command != log.UndefinedCommand { match := params[:idx] // 1337 group is just a random constant to be matched on the log reader side // Size of 20 allows reading the IPv4 IP header. match = append(match, "-j", "NFLOG", "--nflog-prefix", fmt.Sprintf(`%q`, command.Identifier), "--nflog-group", "1337", "--nflog-size", "20") *ipt = append(*ipt, &Rule{ chain: chain,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 14:29:54 UTC 2024 - 8.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* to determine the charset of the response bytes. * * Otherwise the response bytes are decoded as UTF-8. */ fun charStream(): Reader = reader ?: BomAwareReader(source(), charset()).also { reader = it } /** * Returns the response as a string. * * If the response starts with a
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
src/net/http/httputil/dump.go
dump = dump[:i+4] } } return dump, nil } // delegateReader is a reader that delegates to another reader, // once it arrives on a channel. type delegateReader struct { c chan io.Reader err error // only used if r is nil and c is closed. r io.Reader // nil until received from c } func (r *delegateReader) Read(p []byte) (int, error) { if r.r == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9.3K bytes - Viewed (0)