- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for doThing (0.17 sec)
-
cmd/admin-heal-ops.go
if globalIsDistErasure { clientToken = fmt.Sprintf("%s:%d", h.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints)) } if h.clientToken == bgHealingUUID { // For background heal do nothing, do not spawn an unnecessary goroutine. } else { // Launch top-level background heal go-routine go h.healSequenceStart(objAPI) } b, err := json.Marshal(madmin.HealStartSuccess{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
src/archive/tar/format.go
// and then updates the checksum accordingly. func (b *block) setFormat(format Format) { // Set the magic values. switch { case format.has(formatV7): // Do nothing. case format.has(FormatGNU): copy(b.toGNU().magic(), magicGNU) copy(b.toGNU().version(), versionGNU) case format.has(formatSTAR): copy(b.toSTAR().magic(), magicUSTAR)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 11.3K bytes - Viewed (0) -
src/archive/zip/struct.go
case s_IFCHR: mode |= fs.ModeDevice | fs.ModeCharDevice case s_IFDIR: mode |= fs.ModeDir case s_IFIFO: mode |= fs.ModeNamedPipe case s_IFLNK: mode |= fs.ModeSymlink case s_IFREG: // nothing to do case s_IFSOCK: mode |= fs.ModeSocket } if m&s_ISGID != 0 { mode |= fs.ModeSetgid } if m&s_ISUID != 0 { mode |= fs.ModeSetuid } if m&s_ISVTX != 0 { mode |= fs.ModeSticky
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 12.1K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if xnet.IsNetworkOrHostDown(err, false) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *ElasticsearchTarget) Close() error { close(target.quitCh) if target.client != nil { // Stops the background processes that the client is running.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/object-api-utils.go
piece[i] == '-'): // Found a non-digit character, so // this piece is not a number. isNotNumber = true case piece[i] >= '0' && piece[i] <= '9': // Nothing to do. default: // Found invalid character. return false } } allNumbers = allNumbers && !isNotNumber } // Does the bucket name look like an IP address?
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
tests/hooks_test.go
t.Errorf("invalid data after update, got %+v", product) } var result Product3 DB.First(&result, product.ID) AssertEqual(t, result, product) // Select to change Code, but nothing updated, price should not change DB.Model(&product).Select("code").Updates(Product3{Name: "L1214", Code: "L1213"}) if product.Price != 220 || product.Code != "L1213" || product.Name != "Product New3" {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sat Feb 18 01:20:29 GMT 2023 - 15.9K bytes - Viewed (0) -
src/archive/zip/reader.go
// As long as the compressed size is not also 2³²-1 (implausible) // and the header is not also 2³²-1 (equally implausible), // accept the uncompressed size 2³²-1 as valid. // If nothing else, this keeps archive/zip working with 42.zip. _ = needUSize if needCSize || needHeaderOffset { return ErrFormat } return nil } func readDataDescriptor(r io.Reader, f *File) error {
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) -
internal/event/target/amqp.go
return eErr } if err := target.send(eventData, ch, confirms); err != nil { return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *AMQPTarget) Close() error { close(target.quitCh) if target.conn != nil { return target.conn.Close() } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
for { select { case entry, ok := <-diffCh: if !ok { return } if err := enc.Encode(entry); err != nil { return } if len(diffCh) == 0 { // Flush if nothing is queued w.(http.Flusher).Flush() } case <-keepAliveTicker.C: if len(diffCh) > 0 { continue } if _, err := w.Write([]byte(" ")); err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/tier.go
newConfig, err := loadTierConfig(ctx, objAPI) config.Lock() defer config.Unlock() switch err { case nil: break case errConfigNotFound: // nothing to reload // To maintain the invariance that lastRefreshedAt records the // timestamp of last successful refresh config.lastRefreshedAt = UTCNow() return nil default: return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0)