- Sort Score
- Result 10 results
- Languages All
Results 611 - 620 of 859 for err (0.02 sec)
-
internal/disk/directio_unix.go
} // DisableDirectIO - disables directio mode. func DisableDirectIO(f *os.File) error { fd := f.Fd() flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0) if err != nil { return err } flag &= ^(syscall.O_DIRECT) _, err = unix.FcntlInt(fd, unix.F_SETFL, flag) return err } // AlignedBlock - pass through to directio implementation. func AlignedBlock(blockSize int) []byte {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Jun 17 14:31:36 UTC 2023 - 1.6K bytes - Viewed (0) -
internal/once/init.go
return l.do(f) } return nil } func (l *Init) do(f func() error) error { l.m.Lock() defer l.m.Unlock() if atomic.LoadUint32(&l.done) == 0 { if err := f(); err != nil { return err } // Mark as done only when f() is successful atomic.StoreUint32(&l.done, 1) } return nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 09 04:20:31 UTC 2023 - 2.1K bytes - Viewed (0) -
internal/dsync/drwmutex.go
return } var locked bool var err error if isReadLock { if locked, err = c.RLock(netLockCtx, args); err != nil { log("dsync: Unable to call RLock failed with %s for %#v at %s\n", err, args, c) } } else { if locked, err = c.Lock(netLockCtx, args); err != nil { log("dsync: Unable to call Lock failed with %s for %#v at %s\n", err, args, c) } } if locked {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
internal/logger/utils.go
return } if color.IsTerminal() { ansiEscape("8") } } // logIgnoreError if true,the error will ignore. func logIgnoreError(err error) bool { return err == nil || errors.Is(err, context.Canceled) || errors.Is(err, http.ErrServerClosed) || err.Error() == "drive not found"
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 04 23:10:08 UTC 2022 - 1.7K bytes - Viewed (0) -
internal/lock/lock.go
// closes the underlying fd only when the refs // reach zero. func (r *RLockedFile) Close() (err error) { r.mutex.Lock() defer r.mutex.Unlock() if r.refs == 0 { return os.ErrInvalid } r.refs-- if r.refs == 0 { err = r.File.Close() } return err } // Provides a new initialized read locked struct from *os.File
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.5K bytes - Viewed (0) -
tests/multi_primary_keys_test.go
DB.Migrator().DropTable(&Label{}, &Book{}) if err := DB.AutoMigrate(&Label{}, &Book{}); err != nil { t.Fatalf("failed to migrate, got %v", err) } book := Book{ Name: "my book", Labels: []Label{ {Name: "region", Value: "emea"}, }, } DB.Create(&book) var result Book if err := DB.Preload("Labels").First(&result, book.ID).Error; err != nil {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Thu Jan 06 07:02:53 UTC 2022 - 12.8K bytes - Viewed (0) -
internal/http/check_port_others.go
func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{} ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.5K bytes - Viewed (0) -
tests/tracer_test.go
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Tue Oct 18 09:28:06 UTC 2022 - 830 bytes - Viewed (0) -
internal/config/callhome/callhome.go
func LookupConfig(kvs config.KVS) (cfg Config, err error) { if err = config.CheckValidKeys(config.CallhomeSubSys, kvs, DefaultKVS); err != nil { return cfg, err } cfg.Enable = env.Get(config.EnvMinIOCallhomeEnable, kvs.GetWithDefault(Enable, DefaultKVS)) == config.EnableOn cfg.Frequency, err = time.ParseDuration(env.Get(config.EnvMinIOCallhomeFrequency,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/bucket/lifecycle/prefix.go
set bool Unused struct{} // Needed for GOB compatibility } // UnmarshalXML - decodes XML data. func (p *Prefix) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) { var s string if err = d.DecodeElement(&s, &start); err != nil { return err } *p = Prefix{string: s, set: true} return nil } // MarshalXML - decodes XML data. func (p Prefix) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 15 14:45:25 UTC 2023 - 1.5K bytes - Viewed (0)