- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 109 for bagian (0.18 sec)
-
internal/dsync/drwmutex.go
wg.Wait() // Return true if releaseAll was successful, otherwise we return 'false' // to indicate we haven't sufficiently unlocked lockers to avoid deadlocks. // // Caller may use this as an indication to call again. return !checkFailedUnlocks(*locks, tolerance) } // Unlock unlocks the write lock. // // It is a run-time error if dm is not locked on entry to Unlock. func (dm *DRWMutex) Unlock(ctx context.Context) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/prepare-storage.go
if m[err.Error()] > 2 { peersLogAlwaysIf(ctx, fmt.Errorf("Following error has been printed %d times.. %w", m[err.Error()], err)) // Reduce the count to introduce further delay in printing // but let it again print after the 2th attempt m[err.Error()]-- m[err.Error()]-- } m[err.Error()]++ } }() // Cleans up tmp directory of the local disk. func bgFormatErasureCleanupTmp(diskPath string) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/install/install.go
// We had a watch error - that's no good return err case <-ctx.Done(): return ctx.Err() default: // Valid configuration; set isReady to true and wait for modifications before checking again setReady(in.isReady) cniInstalls.With(resultLabel.Value(resultSuccess)).Increment() // Pod set to "NotReady" before termination return watcher.Wait(ctx) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
cmd/object-handlers_test.go
// sets the bucket policy using the policy statement generated from `getWriteOnlyObjectStatement` so that the // unsigned request goes through and its validated again. ExecObjectLayerAPIAnonTest(t, obj, "TestAPIHeadObjectHandler", bucketName, objectName, instanceType, apiRouter, anonReq, getAnonReadOnlyObjectPolicy(bucketName, objectName))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
src/archive/tar/reader.go
} else { hdr.Typeflag = TypeReg } } // The extended headers may have updated the size. // Thus, setup the regFileReader again after merging PAX headers. if err := tr.handleRegularFile(hdr); err != nil { return nil, err } // Sparse formats rely on being able to read from the logical data
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
"ideviceinstaller", "-i", appdir, )) if out, err := cmd.CombinedOutput(); err != nil { // Sometimes, installing the app fails for some reason. // Give the device a few seconds and try again. if attempt < 5 { time.Sleep(5 * time.Second) attempt++ continue } os.Stderr.Write(out) return fmt.Errorf("ideviceinstaller -i %q: %v (%d attempts)", appdir, err, attempt) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
cmd/apierrorcode_string.go
package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[ErrNone-0] _ = x[ErrAccessDenied-1] _ = x[ErrBadDigest-2] _ = x[ErrEntityTooSmall-3] _ = x[ErrEntityTooLarge-4] _ = x[ErrPolicyTooLarge-5] _ = x[ErrIncompleteBody-6]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 21.2K bytes - Viewed (0) -
cmd/data-usage-cache.go
return cycles == 1 } return uint32(xxhash.Sum64String(string(h))>>32)%(cycles) == cycle%cycles } // addChild will add a child based on its hash. // If it already exists it will not be added again. func (e *dataUsageEntry) addChild(hash dataUsageHash) { if _, ok := e.Children[hash.Key()]; ok { return } if e.Children == nil { e.Children = make(dataUsageHashMap, 1) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/notification.go
return err }, index) } return sys.collectPeerMetrics(ctx, peerChannels, g) } // ServiceFreeze freezes all S3 API calls when 'freeze' is true, // 'freeze' is 'false' would resume all S3 API calls again. // NOTE: once a tenant is frozen either two things needs to // happen before resuming normal operations. // - Server needs to be restarted 'mc admin service restart'
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
} // This test assumes that the policy for `accessKey` allows listing on the given // bucket. It creates a session policy that restricts listing on the bucket and // then enables it again in a session policy update call. func (c *check) assertSvcAccSessionPolicyUpdate(ctx context.Context, s *TestSuiteIAM, madmClient *madmin.AdminClient, accessKey, bucket string) { c.Helper()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0)