Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 202 for isInitialized (0.1 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-lifecycle.go

    			t.missedImmediateTasks.Add(1)
    		}
    	}
    }
    
    var globalTransitionState *transitionState
    
    // newTransitionState returns a transitionState object ready to be initialized
    // via its Init method.
    func newTransitionState(ctx context.Context) *transitionState {
    	return &transitionState{
    		transitionCh: make(chan transitionTask, 100000),
    		ctx:          ctx,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  2. cmd/test-utils_test.go

    	if z, ok := objLayer.(*erasureServerPools); ok {
    		formattedDisks = z.serverPools[0].GetDisks(0)()
    	}
    
    	// Success.
    	return objLayer, formattedDisks, nil
    }
    
    // removeRoots - Cleans up initialized directories during tests.
    func removeRoots(roots []string) {
    	for _, root := range roots {
    		os.RemoveAll(root)
    	}
    }
    
    // creates a bucket for the tests and returns the bucket name.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  3. guava/src/com/google/common/collect/AbstractMapBasedMultimap.java

        }
    
        @Override
        public void remove() {
          valueIterator.remove();
          /*
           * requireNonNull is safe because we've already initialized `collection`. If we hadn't, then
           * valueIterator.remove() would have failed.
           */
          if (requireNonNull(collection).isEmpty()) {
            keyIterator.remove();
          }
          totalSize--;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 48.4K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

                    }
                });
            });
    
            httpClient = closeableHttpClient;
            if (logger.isInfoEnabled()) {
                logger.info("HTTP client initialized successfully: userAgent={}, maxTotal={}, defaultMaxPerRoute={}", userAgent,
                        maxTotalConnections, maxConnectionsPerRoute);
            }
        }
    
        /**
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Nov 23 12:19:14 GMT 2025
    - 53.7K bytes
    - Click Count (0)
  5. cmd/metrics-v2.go

    	HistogramBucketLabel string            `json:"HistogramBucketLabel"`
    	Histogram            map[string]uint64 `json:"Histogram"`
    }
    
    // MetricsGroupV2 are a group of metrics that are initialized together.
    type MetricsGroupV2 struct {
    	metricsCache     *cachevalue.Cache[[]MetricV2] `msg:"-"`
    	cacheInterval    time.Duration
    	metricsGroupOpts MetricsGroupOpts
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  6. doc/go_mem.html

    func main() {
    	go setup()
    	for g == nil {
    	}
    	print(g.msg)
    }
    </pre>
    
    <p>
    Even if <code>main</code> observes <code>g != nil</code> and exits its loop,
    there is no guarantee that it will observe the initialized
    value for <code>g.msg</code>.
    </p>
    
    <p>
    In all these examples, the solution is the same:
    use explicit synchronization.
    </p>
    
    <h2 id="badcompiler">Incorrect compilation</h2>
    
    <p>
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb/SmbTransportImpl.java

                    this.out.close();
                    this.in.close();
                    this.socket.close();
                    log.trace("Socket closed");
                } else {
                    log.trace("Not yet initialized");
                }
            } catch (final Exception e) {
                log.debug("Exception in disconnect", e);
            } finally {
                this.socket = null;
                this.digest = null;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 69.8K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool.go

    	}
    
    	z.decommissionCancelers = make([]context.CancelFunc, len(z.serverPools))
    
    	// Initialize the pool meta, but set it to not save.
    	// When z.Init below has loaded the poolmeta will be initialized,
    	// and allowed to save.
    	z.poolMeta = newPoolMeta(z, poolMeta{})
    	z.poolMeta.dontSave = true
    
    	bootstrapTrace("newSharedLock", func() {
    		globalLeaderLock = newSharedLock(GlobalContext, z, "leader.lock")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/SmbSessionImpl.java

                if (witnessServer != null) {
                    witnessClient = new WitnessClient(witnessServer, getContext());
                    witnessEnabled = true;
    
                    log.info("Initialized witness support with server: {}", witnessServer);
                }
            } catch (Exception e) {
                log.warn("Failed to initialize witness support", e);
            }
        }
    
        /**
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 68.9K bytes
    - Click Count (0)
  10. cmd/object-api-multipart_test.go

    	_, err = obj.NewMultipartUpload(context.Background(), bucket, object, opts)
    	if err == nil {
    		t.Fatalf("%s: Expected to fail since the NewMultipartUpload is initialized on a non-existent bucket.", instanceType)
    	}
    	if errMsg != err.Error() {
    		t.Errorf("%s, Expected to fail with Error \"%s\", but instead found \"%s\".", instanceType, errMsg, err.Error())
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
Back to Top