Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 587 for dong (0.02 sec)

  1. cmd/admin-handlers.go

    		hostMap = make(map[string]struct{}, len(hosts))
    		for _, k := range hosts {
    			if k != "" {
    				hostMap[k] = struct{}{}
    			}
    		}
    	}
    	dID := r.Form.Get("by-depID")
    	done := ctx.Done()
    	ticker := time.NewTicker(interval)
    	defer ticker.Stop()
    	w.Header().Set(xhttp.ContentType, string(mimeJSON))
    
    	enc := json.NewEncoder(w)
    	for n > 0 {
    		var m madmin.RealtimeMetrics
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  2. internal/lru/lru.go

    	if res.ttl != noEvictionTTL {
    		go func(done <-chan struct{}) {
    			ticker := time.NewTicker(res.ttl / numBuckets)
    			defer ticker.Stop()
    			for {
    				select {
    				case <-done:
    					return
    				case <-ticker.C:
    					res.deleteExpired()
    				}
    			}
    		}(res.done)
    	}
    	return &res
    }
    
    // Purge clears the cache completely.
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/HashBiMap.java

        }
      }
    
      /**
       * An {@code Entry} implementation that attempts to follow its key around the map -- that is, if
       * the key is moved, deleted, or reinserted, it will account for that -- while not doing any extra
       * work if the key has not moved. One quirk: The {@link #getValue()} method can return {@code
       * null} even for a map which supposedly does not contain null elements, if the key is not present
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

          return;
        }
        long timeoutSeconds = timeoutSeconds();
        long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds);
        do {
          System.runFinalization();
          if (predicate.isDone()) {
            return;
          }
          CountDownLatch done = new CountDownLatch(1);
          createUnreachableLatchFinalizer(done);
          await(done);
          if (predicate.isDone()) {
            return;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java

            }
    
            /*
             * The message provided to batch has a batchLimit that is
             * higher than the current batchLevel so we will now encode
             * that chained message. Before doing so we must increment
             * the batchLevel of the andx message in case it itself is an
             * andx message and needs to perform the same check as above.
             */
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  6. src/main/assemblies/files/fess

      ls=`ls -ld "$SCRIPT"`
      # Drop everything prior to ->
      link=`expr "$ls" : '.*-> \(.*\)$'`
      if expr "$link" : '/.*' > /dev/null; then
        SCRIPT="$link"
      else
        SCRIPT=`dirname "$SCRIPT"`/"$link"
      fi
    done
    
    # determine fess home
    FESS_HOME=`dirname "$SCRIPT"`/..
    
    # make FESS_HOME absolute
    FESS_HOME=`cd "$FESS_HOME"; pwd`
    
    
    # If an include wasn't specified in the environment, then search for one...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  7. cmd/metacache-stream.go

    // readAll will return all remaining objects on the dst channel and close it when done.
    // The context allows the operation to be canceled.
    func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error {
    	r.checkInit()
    	if r.err != nil {
    		return r.err
    	}
    	defer xioutil.SafeClose(dst)
    	if r.current.name != "" {
    		select {
    		case <-ctx.Done():
    			r.err = ctx.Err()
    			return ctx.Err()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java

                                        message);
                            }
                        } else {
                            done = true;
                        }
                    } else {
                        done = true;
                    }
                }
            } while (!done);
    
            ProjectRelocation rel = new ProjectRelocation();
            rel.project = project;
            rel.pomArtifact = pomArtifact;
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Mar 26 10:49:22 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerStatus.java

    /**
     * Enum representing the status of a crawler.
     * It can be INITIALIZING, RUNNING, or DONE.
     */
    public enum CrawlerStatus {
        /**
         * The crawler is initializing.
         */
        INITIALIZING,
    
        /**
         * The crawler is currently running.
         */
        RUNNING,
    
        /**
         * The crawler has completed its task.
         */
        DONE;
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 997 bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

            crawlerContext.setStatus(CrawlerStatus.RUNNING);
            assertEquals(CrawlerStatus.RUNNING, crawlerContext.getStatus());
    
            crawlerContext.setStatus(CrawlerStatus.DONE);
            assertEquals(CrawlerStatus.DONE, crawlerContext.getStatus());
    
            crawlerContext.setStatus(null);
            assertNull(crawlerContext.getStatus());
        }
    
        /**
         * Test urlFilter getter and setter
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
Back to top