Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 413 for Unit (0.06 sec)

  1. src/main/java/org/codelibs/fess/sso/saml/SamlAuthenticator.java

        protected static final String SAML_PREFIX = "saml.";
    
        protected static final String SAML_STATE = "SAML_STATE";
    
        private Map<String, Object> defaultSettings;
    
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            ComponentUtil.getSsoManager().register(this);
    
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    		// these could be stale buckets lying around, queue a heal
    		// of such a bucket. This is needed here as we identify such
    		// buckets here while listing buckets. As part of regular
    		// globalBucketMetadataSys.Init() call would get a valid
    		// buckets only and not the quourum lost ones like this, so
    		// explicit call
    		for bktName, count := range bucketsMap {
    			if count < quorum {
    				// Queue a bucket heal task
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. cmd/signature-v4-utils_test.go

    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    		t.Fatalf("unable initialize config file, %s", err)
    	}
    
    	initAllSubsystems(ctx)
    	initConfigSubsystem(ctx, objLayer)
    
    	globalIAMSys.Init(ctx, objLayer, globalEtcdClient, 2*time.Second)
    
    	req, err := newTestRequest(http.MethodGet, "http://example.com:9000/bucket/object", 0, nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 05 21:26:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	mu        sync.Mutex
    	init      sync.Once
    	lastMinuteLatency
    }
    
    func (e *lockedLastMinuteLatency) add(value time.Duration) {
    	e.addSize(value, 0)
    }
    
    // addSize will add a duration and size.
    func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) {
    	// alloc on every call, so we have a clean entry to swap in.
    	t := time.Now().Unix()
    	e.init.Do(func() {
    		e.cached.Store(&AccElem{})
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. doc/go_mem.html

    </p>
    
    <h2 id="synchronization">Synchronization</h2>
    
    <h3 id="init">Initialization</h3>
    
    <p>
    Program initialization runs in a single goroutine,
    but that goroutine may create other goroutines,
    which run concurrently.
    </p>
    
    <p class="rule">
    If a package <code>p</code> imports package <code>q</code>, the completion of
    <code>q</code>'s <code>init</code> functions happens before the start of any of <code>p</code>'s.
    </p>
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. internal/grid/handlers.go

    }
    
    const (
    	lockPrefix      = "lockR"
    	storagePrefix   = "storageR"
    	bootstrapPrefix = "bootstrap"
    	peerPrefix      = "peer"
    	peerPrefixS3    = "peerS3"
    	healPrefix      = "heal"
    )
    
    func init() {
    	// Static check if we exceed 255 handler ids.
    	// Extend the type to uint16 when hit.
    	if uint32(handlerLast) > 255 {
    		panic(fmt.Sprintf("out of handler IDs. %d > %d", handlerLast, 255))
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

        private List<Crawler> crawlerList;
    
        private IngestFactory ingestFactory = null;
    
        public IndexUpdater() {
            // nothing
        }
    
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            if (ComponentUtil.hasIngestFactory()) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  8. cmd/object-multipart-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	_, isEncrypted := crypto.IsEncrypted(mi.UserDefined)
    
    	// Read compression metadata preserved in the init multipart for the decision.
    	_, isCompressed := mi.UserDefined[ReservedMetadataPrefix+"compression"]
    	// Compress only if the compression is enabled during initial multipart.
    	var idxCb func() []byte
    	if isCompressed {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

        protected long thumbnailTaskQueueTimeout = 10 * 1000L;
    
        protected long noImageExpired = 24 * 60 * 60 * 1000L; // 24 hours
    
        protected int splitHashSize = 10;
    
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            final String thumbnailPath = System.getProperty(Constants.FESS_THUMBNAIL_PATH);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  10. internal/s3select/select.go

    	lz4Type    CompressionType = "LZ4"
    	s2Type     CompressionType = "S2"
    	snappyType CompressionType = "SNAPPY"
    )
    
    const (
    	maxRecordSize = 1 << 20 // 1 MiB
    )
    
    var parquetSupport bool
    
    func init() {
    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = sync.Pool{
    	New: func() interface{} {
    		// make a buffer with a reasonable capacity.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top