- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 126 for end (5.9 sec)
-
src/bufio/scan.go
if s.err != nil { // Shut it down. s.start = 0 s.end = 0 return false } // Must read more data. // First, shift data to beginning of buffer if there's lots of empty space // or space is needed. if s.start > 0 && (s.end == len(s.buf) || s.start > len(s.buf)/2) { copy(s.buf, s.buf[s.start:s.end]) s.end -= s.start s.start = 0 } // Is the buffer full? If so, resize.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
// CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct { *io.PipeReader wait func() } // CloseWithError close with supplied error the reader end
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
internal/s3select/genmessage.go
buf.WriteString("Stats") fmt.Println(buf.Bytes()) } // End Message // =========== // Header specification // -------------------- // End messages contain two headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-end.png // // Payload specification // --------------------- // End messages have no payload. func genEndMessage() { buf := new(bytes.Buffer)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0) -
src/archive/zip/reader.go
// if (data size / 30) >= end.directoryRecords. if end.directorySize < uint64(size) && (uint64(size)-end.directorySize)/30 >= end.directoryRecords { r.File = make([]*File, 0, end.directoryRecords) } r.Comment = end.comment rs := io.NewSectionReader(rdr, 0, size) if _, err = rs.Seek(r.baseOffset+int64(end.directoryOffset), io.SeekStart); err != nil { return err }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
cmd/copy-part-range.go
if err != nil { return nil, err } if hrange.IsSuffixLength || hrange.Start < 0 || hrange.End < 0 { return nil, errInvalidRange } return hrange, nil } // checkCopyPartRangeWithSize adds more check to the range string in case of // copy object part. This API requires having specific start and end range values // e.g. 'bytes=3-10'. Other use cases will be rejected.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 2.5K bytes - Viewed (0) -
operator/cmd/mesh/operator-common.go
watchedNamespaces: {{.WatchedNamespaces}} hub: {{.Hub}} tag: {{.Tag}} {{- if .ImagePullSecrets }} imagePullSecrets: {{- range .ImagePullSecrets }} - {{ . }} {{- end }} {{- end }} revision: {{if .Revision }} {{.Revision}} {{else}} "" {{end}} ` tv := struct { IstioNamespace string WatchedNamespaces string Hub string Tag string ImagePullSecrets []string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Dec 17 02:25:04 GMT 2022 - 3.8K bytes - Viewed (0) -
cmd/metacache_gen.go
return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "end": z.ended, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ended") return } case "st": z.started, err = dc.ReadTime() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 08 18:26:08 GMT 2021 - 10K bytes - Viewed (0) -
internal/s3select/select.go
return 0, 0, err } if s.End == nil && s.Start == nil { // Not valid, but should be caught above. return 0, -1, nil } if s.End == nil { start := int64(*s.Start) if start < 0 { return 0, 0, errors.New("ScanRange: Start after EOF") } return start, -1, nil } if s.Start == nil { // Suffix length end := int64(*s.End) if end < 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/leak-detect_test.go
"sort" "strings" "time" ) const ( // deadline (in seconds) up to which the go routine leak detection has to be retried. leakDetectDeadline = 5 // pause time (in milliseconds) between each snapshot at the end of the go routine leak detection. leakDetectPauseTimeMs = 50 ) // LeakDetect - type with methods for go routine leak detection. type LeakDetect struct { relevantRoutines map[string]bool }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
src/archive/zip/zip_test.go
_, err := f.Write(chunk[:frag]) if err != nil { t.Fatal("write chunk:", err) } } end := []byte("END\n") _, err = f.Write(end) if err != nil { t.Fatal("write end:", err) } if err := w.Close(); err != nil { t.Fatal(err) } // read back zip file and check that we get to the end of it r, err := NewReader(buf, buf.Size()) if err != nil { t.Fatal("reader:", err) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 19.5K bytes - Viewed (0)