Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 408 of 408 for iterable (0.04 sec)

  1. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

         */
        private void removeIdleConnections() {
            long now = System.currentTimeMillis();
            List<SmbTransportImpl> idle = new ArrayList<>();
    
            // Iterate through connections without synchronization - ConcurrentLinkedQueue is thread-safe
            for (SmbTransportImpl transport : connections) {
                try {
                    // Check if connection has been idle too long
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/net/InetAddresses.java

        if (IPV4_DELIMITER_MATCHER.countIn(ipString) + 1 != IPV4_PART_COUNT) {
          return null; // Wrong number of parts
        }
    
        byte[] bytes = new byte[IPV4_PART_COUNT];
        int start = 0;
        // Iterate through the parts of the ip string.
        // Invariant: start is always the beginning of an octet.
        for (int i = 0; i < IPV4_PART_COUNT; i++) {
          int end = ipString.indexOf(IPV4_DELIMITER, start);
          if (end == -1) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

            fireEvent(ResolutionListener.TEST_ARTIFACT, listeners, node);
    
            Object key = node.getKey();
    
            // TODO Does this check need to happen here? Had to add the same call
            // below when we iterate on child nodes -- will that suffice?
            if (managedVersions.containsKey(key)) {
                manageArtifact(node, managedVersions, listeners);
            }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 36.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/SearchHelper.java

                }
            }
            return documentItems;
        }
    
        /**
         * Performs a scroll search for processing large result sets efficiently.
         *
         * This method uses OpenSearch scroll API to iterate through large numbers of
         * documents without loading them all into memory at once.
         *
         * @param params The search request parameters
         * @param cursor Function to process each document in the result set
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

       * to do so leaks open files!
       */
      @Synchronized
      @Throws(IOException::class)
      fun snapshots(): MutableIterator<Snapshot> {
        initialize()
        return object : MutableIterator<Snapshot> {
          /** Iterate a copy of the entries to defend against concurrent modification errors. */
          private val delegate = ArrayList(lruEntries.values).iterator()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          ArrayList<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get());
          LockGraphNode node = lock.getLockGraphNode();
          // Iterate in reverse because locks are usually locked/unlocked in a
          // LIFO order.
          for (int i = acquiredLockList.size() - 1; i >= 0; i--) {
            if (acquiredLockList.get(i) == node) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 15:05:43 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    	// initialize a new mux router.
    	// goriilla/mux is the library used to register all the routes and handle them.
    	muxRouter := mux.NewRouter().SkipClean(true).UseEncodedPath()
    	if len(apiFunctions) > 0 {
    		// Iterate the list of API functions requested for and register them in mux HTTP handler.
    		registerAPIFunctions(muxRouter, objLayer, apiFunctions...)
    		muxRouter.Use(globalMiddlewares...)
    		return muxRouter
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    and-butter--'
    
      `But what did the Dormouse say?' one of the jury asked.
    
      `That I can't remember,' said the Hatter.
    
      `You MUST remember,' remarked the King, `or I'll have you
    executed.'
    
      The miserable Hatter dropped his teacup and bread-and-butter,
    and went down on one knee.  `I'm a poor man, your Majesty,' he
    began.
    
      `You're a very poor speaker,' said the King.
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 145.2K bytes
    - Viewed (0)
Back to top