- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 283 for Lock (0.1 sec)
-
internal/config/identity/openid/jwt.go
pkey, err := key.DecodePublicKey() if err != nil { return err } pk.add(key.Kid, pkey) } return nil } func (pk *publicKeys) add(keyID string, key interface{}) { pk.Lock() defer pk.Unlock() pk.pkMap[keyID] = key } func (pk *publicKeys) get(kid string) interface{} { pk.RLock() defer pk.RUnlock() return pk.pkMap[kid] }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 02:46:36 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/object-api-errors.go
return "No bucket tags found for bucket: " + e.Bucket } // BucketObjectLockConfigNotFound - no bucket object lock config found type BucketObjectLockConfigNotFound GenericError func (e BucketObjectLockConfigNotFound) Error() string { return "No bucket object lock configuration found for bucket: " + e.Bucket } // BucketQuotaConfigNotFound - no bucket quota config found.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Aug 09 02:05:14 UTC 2024 - 22.1K bytes - Viewed (0) -
cmd/server-main.go
logger.FatalIf(initGlobalGrid(GlobalContext, globalEndpoints), "Unable to configure server grid RPC services") }) // Initialize lock grid bootstrapTrace("initLockGrid", func() { logger.FatalIf(initGlobalLockGrid(GlobalContext, globalEndpoints), "Unable to configure server lock grid RPC services") }) // Configure server. bootstrapTrace("configureServer", func() {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (3) -
docs/en/docs/tutorial/security/first-steps.md
You will see something like this: <img src="/img/tutorial/security/image01.png"> /// check | "Authorize button!" You already have a shiny new "Authorize" button. And your *path operation* has a little lock in the top-right corner that you can click. /// And if you click it, you have a little authorization form to type a `username` and `password` (and other optional fields): <img src="/img/tutorial/security/image02.png">
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/prepare-storage.go
return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int) printOnce[endpoint] = m if once { m[err.Error()]++ peersLogAlwaysIf(ctx, err) return
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (0) -
docs/pt/docs/deployment/docker.md
Aqui é onde geraremos o arquivo `requirements.txt` 3. Instale o Poetry nesse estágio do Docker. 4. Copie os arquivos `pyproject.toml` e `poetry.lock` para o diretório `/tmp`. Porque está usando `./poetry.lock*` (terminando com um `*`), não irá falhar se esse arquivo ainda não estiver disponível. 5. Gere o arquivo `requirements.txt`.
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Mon Aug 12 21:47:53 UTC 2024 - 37.4K bytes - Viewed (0) -
cmd/handler-api.go
return } // A valid value is available return its 90% available = (memStats.Available * 9) / 10 return } func (t *apiConfig) init(cfg api.Config, setDriveCounts []int, legacy bool) { t.mu.Lock() defer t.mu.Unlock() clusterDeadline := cfg.ClusterDeadline if clusterDeadline == 0 { clusterDeadline = 10 * time.Second } t.clusterDeadline = clusterDeadline
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
internal/event/target/amqp.go
return true } if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false } target.connMutex.Lock() defer target.connMutex.Unlock() if target.conn != nil { ch, err = target.conn.Channel() if err == nil { if target.args.PublisherConfirms {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
cmd/erasure-decode.go
br.Close() } p.readers[i] = nil // Since ReadAt returned error, trigger another read. readTriggerCh <- true return } newBufLK.Lock() newBuf[bufIdx] = p.buf[bufIdx][:n] newBufLK.Unlock() // Since ReadAt returned success, there is no need to trigger another read. readTriggerCh <- false }(readerIndex) readerIndex++ }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/bucket-stats.go
} // Clone creates a new BucketReplicationStats copy func (brs BucketReplicationStats) Clone() (c BucketReplicationStats) { // This is called only by replicationStats cache and already holds a // read lock before calling Clone() c = brs // We need to copy the map, so we do not reference the one in `brs`. c.Stats = make(map[string]*BucketReplicationStat, len(brs.Stats)) for arn, st := range brs.Stats {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 12 11:39:51 UTC 2024 - 13.4K bytes - Viewed (0)