Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 661 for curLeft (0.08 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

          )
        }
        val result = proxies[nextProxyIndex++]
        resetNextInetSocketAddress(result)
        return result
      }
    
      /** Prepares the socket addresses to attempt for the current proxy or host. */
      @Throws(IOException::class)
      private fun resetNextInetSocketAddress(proxy: Proxy) {
        // Clear the addresses. Necessary if getAllByName() below throws!
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/opensearch/config/bsentity/dbmeta/RelatedContentDbm.java

            return _instance;
        }
    
        // ===================================================================================
        //                                                                       Current DBDef
        //                                                                       =============
        @Override
        public String getProjectName() {
            return null;
        }
    
        @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/TableCollectors.java

            insertionOrder.add(cell);
            table.put(row, column, cell);
          } else {
            oldCell.merge(value, merger);
          }
        }
    
        /*
         * While the current implementation returns `this`, that's not something we mean to guarantee.
         * Anyway, the purpose of this method is to implement a BinaryOperator combiner for a Collector,
         * so its return value will get used naturally.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 16:07:06 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  4. cmd/mrf.go

    	defer m.wg.Done()
    
    	if atomic.LoadInt32(&m.closing) == 1 {
    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    	}
    }
    
    // Do not accept new MRF operations anymore and start to save
    // the current heal status in one available disk
    func (m *mrfState) shutdown() {
    	atomic.StoreInt32(&m.closing, 1)
    	m.wg.Wait()
    	close(m.opCh)
    	atomic.StoreInt32(&m.closed, 1)
    
    	if len(m.opCh) > 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. internal/lru/lru.go

    	c.mu.Lock()
    	defer c.mu.Unlock()
    	now := time.Now()
    
    	// Check for existing item
    	if ent, ok := c.items[key]; ok {
    		c.evictList.MoveToFront(ent)
    		c.removeFromBucket(ent) // remove the entry from its current bucket as expiresAt is renewed
    		ent.Value = value
    		ent.ExpiresAt = now.Add(c.ttl)
    		c.addToBucket(ent)
    		return false
    	}
    
    	// Add new item
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/config/bsentity/dbmeta/RequestHeaderDbm.java

            return _instance;
        }
    
        // ===================================================================================
        //                                                                       Current DBDef
        //                                                                       =============
        @Override
        public String getProjectName() {
            return null;
        }
    
        @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/exception/SsoProcessExceptionTest.java

            StackTraceElement[] stackTrace = exception.getStackTrace();
            assertTrue(stackTrace.length > 0);
    
            // Verify that the current test method appears in the stack trace
            boolean foundTestMethod = false;
            for (StackTraceElement element : stackTrace) {
                if (element.getMethodName().equals("test_stackTrace_isPresent")) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  8. cmd/lock-rest-server.go

    	"github.com/minio/minio/internal/grid"
    	"github.com/minio/minio/internal/logger"
    )
    
    // To abstract a node over network.
    type lockRESTServer struct {
    	ll *localLocker
    }
    
    // RefreshHandler - refresh the current lock
    func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	// Add a timeout similar to what we expect upstream.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 31 19:54:34 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  9. migrator/migrator.go

    				alterColumn = true
    			}
    		}
    	}
    
    	// check nullable
    	if nullable, ok := columnType.Nullable(); ok && nullable == field.NotNull {
    		// not primary key & current database is non-nullable(to be nullable)
    		if !field.PrimaryKey && !nullable {
    			alterColumn = true
    		}
    	}
    
    	// check default value
    	if !field.PrimaryKey {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Jun 06 02:35:01 UTC 2025
    - 29.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java

            });
        }
    
        /**
         * Sets up search paging data for rendering the scheduled job list.
         *
         * @param data the render data to populate
         * @param form the search form containing current search criteria
         */
        protected void searchPaging(final RenderData data, final SearchForm form) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 22.2K bytes
    - Viewed (0)
Back to top