- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 190 for Lock (0.17 sec)
-
internal/grid/muxclient.go
if m.cancelFn != nil { m.cancelFn(context.Canceled) } // Wait for senders to release. m.respMu.Lock() } defer m.respMu.Unlock() m.closeLocked() } func (m *muxClient) closeLocked() { if m.closed { return } // We hold the lock, so nobody can modify m.respWait while we're closing. if m.respWait != nil { xioutil.SafeClose(m.respWait) m.respWait = nil }
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) -
internal/ioutil/append-file_windows.go
import ( "io" "os" "github.com/minio/minio/internal/lock" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := lock.Open(src, os.O_RDONLY, 0o666) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.2K bytes - Viewed (0) -
cmd/bucket-targets.go
func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock() defer sys.hMutex.Unlock() if h, ok := sys.hc[ep.Host]; ok { h.Online = false sys.hc[ep.Host] = h } } func (sys *BucketTargetSys) initHC(ep *url.URL) { sys.hMutex.Lock() sys.hc[ep.Host] = epHealth{ Endpoint: ep.Host, Scheme: ep.Scheme, Online: true, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/tier.go
} func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.success++ t.requestsCount[tier] = stat } func (t *tierMetrics) logFailure(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.failure++ t.requestsCount[tier] = stat }
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) -
cmd/metrics-resource.go
} sfx += v } return string(name) + "_" + sfx } func updateResourceMetrics(subSys MetricSubsystem, name MetricName, val float64, labels map[string]string, isCumulative bool) { resourceMetricsMapMu.Lock() defer resourceMetricsMapMu.Unlock() subsysMetrics, found := resourceMetricsMap[subSys] if !found { subsysMetrics = ResourceMetrics{} } key := getResourceKey(name, labels)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/api-router.go
} func setHTTPServer(h *xhttp.Server) { globalObjLayerMutex.Lock() globalHTTPServer = h globalObjLayerMutex.Unlock() } func newConsoleServerFn() *consoleapi.Server { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalConsoleSrv } func setConsoleSrv(srv *consoleapi.Server) { globalObjLayerMutex.Lock() globalConsoleSrv = srv globalObjLayerMutex.Unlock() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return err } // if no update is needed return right away. if !update { z.poolMetaMutex.Lock() z.poolMeta = meta z.poolMetaMutex.Unlock() } else { newMeta := newPoolMeta(z, meta) if err = newMeta.save(ctx, z.serverPools); err != nil { return err } z.poolMetaMutex.Lock() z.poolMeta = newMeta z.poolMetaMutex.Unlock() } pools := meta.returnResumablePools()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/config.go
if err != nil { return err } bootstrapTraceMsg("lookup the configuration") // Override any values from ENVs. lookupConfigs(srvCfg, objAPI) // hold the mutex lock before a new config is assigned. globalServerConfigMu.Lock() globalServerConfig = srvCfg globalServerConfigMu.Unlock() return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0) -
cmd/untar.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/dsync/dsync.go
package dsync // Dsync represents dsync client object which is initialized with // authenticated clients, used to initiate lock REST calls. type Dsync struct { // List of rest client objects, one per lock server. GetLockers func() ([]NetLocker, string) // Timeouts to apply. Timeouts Timeouts
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 01 19:14:28 GMT 2022 - 1K bytes - Viewed (0)