- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 127 for Continue (0.2 sec)
-
cmd/common-main.go
if file.Mode().IsRegular() || file.Name() == "CAs" || strings.HasPrefix(file.Name(), "..") { continue } if file.Mode()&os.ModeSymlink == os.ModeSymlink { file, err = Stat(filepath.Join(root.Name(), file.Name())) if err != nil { // not accessible ignore continue } if !file.IsDir() { continue } } var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/peer-s3-client.go
for idx, buckets := range nodeBuckets { if buckets == nil { continue } if !slices.Contains(sys.peerClients[idx].GetPools(), poolIdx) { continue } for _, bi := range buckets { _, ok := resultMap[bi.Name] if ok { // Skip it, this bucket is found in another pool continue } bucketsMap[bi.Name]++ if bucketsMap[bi.Name] >= quorum {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/batch-expire.go
continue // including latest version in toDel suffices, skipping other versions } versionsCount++ } else { continue } if versionsCount <= matchedFilter.Purge.RetainVersions { continue // retain versions } toDel = append(toDel, expireObjInfo{ ObjectInfo: result, }) } // Send any remaining objects downstream if len(toDel) > 0 { select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
internal/grid/connection.go
atomic.StoreInt64(&c.LastPong, time.Now().Unix()) continue } case toSend = <-c.outQueue: if len(toSend) == 0 { continue } } if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 && len(c.outQueue) > 0 { queue = append(queue, toSend) queueSize += len(toSend) continue } c.connChange.L.Lock() for { state := c.State()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/grid/muxclient.go
errState = true continue case <-m.outBlock: } msg := message{ Op: OpMuxClientMsg, MuxID: m.MuxID, Seq: 1, Payload: req, } msg.setZeroPayloadFlag() err := m.send(msg) PutByteBuffer(req) if err != nil { m.addErrorNonBlockingClose(internalResp, err) errState = true continue } msg.Seq++ } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/api-response.go
// values to client. toRemove = append(toRemove, k) continue } // https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) { toRemove = append(toRemove, k) continue } } for _, k := range toRemove { delete(m, k)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
cmd/handler-utils.go
xhost, err := xnet.ParseHost(host) if err != nil { return "", err } for _, domain := range domains { if xhost.Name == minioReservedBucket+"."+domain { continue } if !strings.HasSuffix(xhost.Name, "."+domain) { continue } bucket := strings.TrimSuffix(xhost.Name, "."+domain) return SlashSeparator + pathJoin(bucket, path), nil } return path, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
cmd/object-handlers.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
// not the MD5 of the part content does not change that. var completeETags []etag.ETag for _, part := range complMultipartUpload.Parts { ETag, err := etag.Parse(part.ETag) if err != nil { continue } completeETags = append(completeETags, ETag) } multipartETag := etag.Multipart(completeETags...) opts.UserDefined["etag"] = multipartETag.String()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/http/listener.go
opts.Trace(fmt.Sprint("listenCfg.Listen: ", e)) } listenErrs[i] = e continue } if opts.Trace != nil { opts.Trace(fmt.Sprint("adding listener to ", l.Addr())) } listeners = append(listeners, l) } if len(listeners) == 0 { // No listeners initialized, no need to continue return } listener = &httpListener{ listeners: listeners,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0)