- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 283 for Lock (0.06 sec)
-
cmd/ilm-config.go
} func (c *ilmConfig) getTransitionWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.TransitionWorkers } func (c *ilmConfig) update(cfg ilm.Config) { c.mu.Lock() defer c.mu.Unlock() c.cfg = cfg
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Mar 05 02:50:24 UTC 2024 - 1.3K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
type Target struct { status int32 totalMessages int64 failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
ci/official/pycpp.sh
PROFILE_JSON_PATH="$PROFILE_JSON_PATH/profile.json.gz" else PROFILE_JSON_PATH="$TFCI_OUTPUT_DIR/profile.json.gz" fi # TODO(b/361369076) Remove the following block after TF NumPy 1 is dropped # Move hermetic requirement lock files for NumPy 1 to the root if [[ "$TFCI_WHL_NUMPY_VERSION" == 1 ]]; then cp ./ci/official/requirements_updater/numpy1_requirements/*.txt . fi if [[ $TFCI_PYCPP_SWAP_TO_BUILD_ENABLE == 1 ]]; then
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Wed Oct 23 18:48:35 UTC 2024 - 1.9K bytes - Viewed (0) -
cmd/data-scanner-metric.go
if c != nil { c2 := c.clone() c = &c2 } p.cycleInfoMu.Lock() p.cycleInfo = c p.cycleInfoMu.Unlock() } // getCycle returns the current cycle metrics. // If not nil, the returned value can safely be modified. func (p *scannerMetrics) getCycle() *currentScannerCycle { p.cycleInfoMu.Lock() defer p.cycleInfoMu.Unlock() if p.cycleInfo == nil { return nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
return } if lockEnabled { lock, _, _, _, err := clnt.GetObjectLockConfig(ctx, clnt.Bucket) if err != nil { writeErrorResponse(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationValidationError, err), r.URL) return } if lock != objectlock.Enabled {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/signals.go
func handleSignals() { // Custom exit function exit := func(success bool) { if globalLoggerOutput != nil { globalLoggerOutput.Close() } // If global profiler is set stop before we exit. globalProfilerMu.Lock() defer globalProfilerMu.Unlock() for _, p := range globalProfiler { p.Stop() } if success { os.Exit(0) } os.Exit(1) } stopProcess := func() bool {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/webapp/WEB-INF/orig/view/login/index.jsp
</c:set> <la:password property="password" class="form-control" placeholder="${ph_password}" /> <div class="input-group-append"> <span class="input-group-text"> <em class="fa fa-lock fa-fw"> </span> </div> </div> <div class="text-center"> <button type="submit" name="login" class="btn btn-primary btn-block" value="<la:message key="labels.login"/>">
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 3K bytes - Viewed (0) -
cmd/bucket-metadata.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/policy" "github.com/minio/sio" ) const ( legacyBucketObjectLockEnabledConfigFile = "object-lock-enabled.json" legacyBucketObjectLockEnabledConfig = `{"x-amz-bucket-object-lock-enabled":true}` bucketMetadataFile = ".metadata.bin" bucketMetadataFormat = 1 bucketMetadataVersion = 1 ) var (
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 18.2K bytes - Viewed (0) -
cmd/metacache-walk.go
} } if contextCanceled(ctx) { return ctx.Err() } if opts.Limit > 0 && objsReturned >= opts.Limit { return nil } if s.walkMu != nil { s.walkMu.Lock() } entries, err := s.ListDir(ctx, "", opts.Bucket, current, -1) if s.walkMu != nil { s.walkMu.Unlock() } if err != nil { // Folder could have gone away in-between
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
docs/site-replication/README.md
- Creation of STS credentials - Creation and deletion of service accounts (except those owned by the root user) - Changes to Bucket features such as: - Bucket Policies - Bucket Tags - Bucket Object-Lock configurations (including retention and legal hold configuration) - Bucket Encryption configuration > NOTE: Bucket versioning is automatically enabled for all new and existing buckets on all replicated sites.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 26 21:30:28 UTC 2024 - 3.4K bytes - Viewed (0)