- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 283 for Lock (0.03 sec)
-
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHook.java
processDBFluteSystem(); } protected void processDBFluteSystem() { DBFluteSystem.unlock(); DBFluteSystem.setFinalTimeZoneProvider(createFinalTimeZoneProvider()); DBFluteSystem.lock(); } protected DfFinalTimeZoneProvider createFinalTimeZoneProvider() { return new DfFinalTimeZoneProvider() { protected final TimeZone provided = FessUserTimeZoneProcessProvider.centralTimeZone;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/erasure-common.go
// unformatted or simply not accessible for some reason. // // - Do not consume disks which are being healed // // - Future: skip busy disks return } mu.Lock() newDisks = append(newDisks, disks[i]) mu.Unlock() }() } wg.Wait() return newDisks } func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) { disks := er.getOnlineDisks()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 2.3K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
i.Buckets[bucket] = st } // ImportBucketMetadataHandler - imports all bucket metadata from a zipped file and overwrite bucket metadata config // There are some caveats regarding the following: // 1. object lock config - object lock should have been specified at time of bucket creation. Only default retention settings are imported here.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 33.2K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
if clnt.gridConn.State() != grid.StateConnected { mu.Lock() offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected)) mu.Unlock() return } ctx, cancel := context.WithTimeout(ctx, 2*time.Second) defer cancel() err := clnt.Verify(ctx, srcCfg) mu.Lock() if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/lock/lock_windows_test.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package lock import ( "strings" "testing" ) func TestFixLongPath(t *testing.T) { // 248 is long enough to trigger the longer-than-248 checks in // fixLongPath, but short enough not to make a path component
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Oct 18 18:08:15 UTC 2023 - 2.2K bytes - Viewed (0) -
cmd/auth-handler.go
if cred.AccessKey == "" { return ErrAccessDenied } conditions := getConditionValues(r, "", cred) conditions["object-lock-mode"] = []string{string(retMode)} conditions["object-lock-retain-until-date"] = []string{retDate.UTC().Format(time.RFC3339)} if retDays > 0 { conditions["object-lock-remaining-retention-days"] = []string{strconv.Itoa(retDays)} } if retMode == objectlock.RetGovernance && byPassSet {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/erasure-object.go
nsUnlocker() } }() // Acquire lock if !opts.NoLock { lock := er.NewNSLock(bucket, object) lkctx, err := lock.GetRLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() // Release lock when the metadata is verified, and reader // is ready to be read. // // This is possible to be lock free because
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 78.5K bytes - Viewed (0) -
cmd/batch-rotate.go
versionSuspended := globalBucketVersioningSys.PrefixSuspended(srcBucket, srcObject) lock := api.NewNSLock(r.Bucket, objInfo.Name) lkctx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lock.Unlock(lkctx) opts := ObjectOptions{ VersionID: objInfo.VersionID, Versioned: versioned,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 14.7K bytes - Viewed (0) -
internal/config/lambda/target/lazyinit.go
m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f) } return nil } func (l *lazyInit) doSlow(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 Mar 07 16:12:41 UTC 2023 - 1.3K bytes - Viewed (0) -
cmd/batch-handlers.go
if ri == nil { return } ri.mu.Lock() defer ri.mu.Unlock() if success { ri.Bucket = bucket ri.Object = info.Name } ri.countItem(info.Size, info.DeleteMarker, success, attempt) } func (ri *batchJobInfo) trackCurrentBucketBatch(bucket string, batch []ObjectInfo) { if ri == nil { return } ri.mu.Lock() defer ri.mu.Unlock() ri.Bucket = bucket
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 18 15:32:09 UTC 2024 - 62.2K bytes - Viewed (0)