- Sort Score
- Num 10 results
- Language All
Results 261 - 270 of 592 for refer (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/once/init.go
// if it is not successful yet. func (l *Init) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.do(f) } return nil } func (l *Init) do(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 }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 09 04:20:31 GMT 2023 - 2.1K bytes - Click Count (0) -
cmd/admin-handlers-users_test.go
ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout) defer cancel() for i := range 3 { err := s.client.MakeBucket(ctx, fmt.Sprintf("bucket%d", i+1), minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket create error: %v", err) } defer func(i int) { _ = s.client.RemoveBucket(ctx, fmt.Sprintf("bucket%d", i+1)) }(i) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 50.6K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java
when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2)); ChannelInfo selected = loadBalancer.selectChannel(largeRead); // Should prefer higher bandwidth channel for large transfers assertEquals(channel2, selected); } @Test void testAdaptiveStrategyMetadataOperation() throws Exception {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.7K bytes - Click Count (0) -
internal/cachevalue/cache.go
if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 { if t.updating.TryLock() { go func() { defer t.updating.Unlock() t.update(context.Background()) }() } return *v, nil } // Get lock. Either we get it or we wait for it. t.updating.Lock() defer t.updating.Unlock() if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 12:50:46 GMT 2024 - 4.4K bytes - Click Count (0) -
internal/config/policy/opa/config.go
if a.AuthToken != "" { req.Header.Set("Authorization", a.AuthToken) } client := &http.Client{Transport: a.Transport} resp, err := client.Do(req) if err != nil { return err } defer a.CloseRespFn(resp.Body) return nil } // UnmarshalJSON - decodes JSON data. func (a *Args) UnmarshalJSON(data []byte) error { // subtype to avoid recursive call to UnmarshalJSON() type subArgs ArgsCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
guava/src/com/google/common/base/Functions.java
* {@code equals}, {@code hashCode} or {@code toString} behavior of the returned function. A * future migration to {@code java.util.function} will not preserve this behavior. * * <p>As discussed above, prefer to use the method reference {@code Object::toString} instead, * though note that it is not serializable unless you explicitly make it {@link Serializable},Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Aug 06 17:32:30 GMT 2025 - 15.4K bytes - Click Count (0) -
cmd/auth-handler_test.go
// Tests is requested authenticated function, tests replies for s3 errors. func TestIsReqAuthenticated(t *testing.T) { ctx, cancel := context.WithCancel(GlobalContext) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { t.Fatalf("unable initialize config file, %s", err) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 15.4K bytes - Click Count (0) -
internal/lsync/lrwmutex.go
const isWriteLock = false return lm.lockLoop(ctx, id, source, timeout, isWriteLock) } func (lm *LRWMutex) lock(id, source string, isWriteLock bool) (locked bool) { lm.mu.Lock() defer lm.mu.Unlock() lm.id = id lm.source = source if isWriteLock { if lm.ref == 0 && !lm.isWriteLock { lm.ref = 1 lm.isWriteLock = true locked = true } } else { if !lm.isWriteLock {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Click Count (0) -
docs/changelogs/changelog_4x.md
## Version 4.7.0 _2020-05-17_ * New: `HandshakeCertificates.Builder.addInsecureHost()` makes it easy to turn off security in private development environments that only carry test data. Prefer this over creating an all-trusting `TrustManager` because only hosts on the allowlist are insecure. From [our DevServer sample][dev_server]: ```kotlin
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Click Count (0) -
cmd/acl-handlers.go
// only responds success if the ACL is private. func (api objectAPIHandlers) PutBucketACLHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "PutBucketACL") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) vars := mux.Vars(r) bucket := vars["bucket"] objAPI := api.ObjectAPI() if objAPI == nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 8.4K bytes - Click Count (0)