Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 3131 - 3140 of 5,478 for newE (0.03 seconds)

  1. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

      /** This method will throw an {@link UnsupportedOperationException}. */
      @CanIgnoreReturnValue // to skip a line
      @Override
      @DoNotCall("Always throws UnsupportedOperationException")
      public String readLine() {
        throw new UnsupportedOperationException("readLine is not supported");
      }
    
      @Override
      public void readFully(byte[] b) throws IOException {
        ByteStreams.readFully(this, b);
      }
    
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 12 03:49:18 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

      private static final LazyLogger log = new LazyLogger(ExecutionList.class);
    
      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
       */
      @GuardedBy("this")
      private @Nullable RunnableExecutorPair runnables;
    
      @GuardedBy("this")
      private boolean executed;
    
      /** Creates a new, empty {@link ExecutionList}. */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  3. cmd/warm-backend-azure.go

    	case conf.AccountName == "":
    		return errors.New("the account name is required")
    	case conf.AccountKey != "" && (conf.SPAuth.TenantID != "" || conf.SPAuth.ClientID != "" || conf.SPAuth.ClientSecret != ""):
    		return errors.New("multiple authentication mechanisms are provided")
    	case conf.AccountKey == "" && (conf.SPAuth.TenantID == "" || conf.SPAuth.ClientID == "" || conf.SPAuth.ClientSecret == ""):
    		return errors.New("no authentication mechanism was provided")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 31 22:10:24 GMT 2024
    - 7K bytes
    - Click Count (0)
  4. internal/event/target/nsq.go

    func (n NSQArgs) Validate() error {
    	if !n.Enable {
    		return nil
    	}
    
    	if n.NSQDAddress.IsEmpty() {
    		return errors.New("empty nsqdAddress")
    	}
    
    	if n.Topic == "" {
    		return errors.New("empty topic")
    	}
    	if n.QueueDir != "" {
    		if !filepath.IsAbs(n.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	return nil
    }
    
    // NSQTarget - NSQ target.
    type NSQTarget struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

                        + exceptionList.stream().map(e -> "; " + e.getMessage()).collect(Collectors.joining());
                throw new MultipleCrawlingAccessException(message, exceptionList.toArray(new Throwable[exceptionList.size()]));
            } finally {
                if (listener != null) {
                    listener.onRequestEnd(this, request, exceptionList);
                }
            }
        }
    
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  6. internal/http/server.go

    )
    
    // Server - extended http.Server supports multiple addresses to serve and enhanced connection handling.
    type Server struct {
    	http.Server
    	Addrs         []string      // addresses on which the server listens for new connection.
    	TCPOptions    TCPOptions    // all the configurable TCP conn specific configurable options.
    	listenerMutex sync.Mutex    // to guard 'listener' field.
    	listener      *httpListener // HTTP listener for all 'Addrs' field.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

     *
     * ```java
     * Request request = new Request.Builder()
     *     .cacheControl(new CacheControl.Builder().noCache().build())
     *     .url("http://publicobject.com/helloworld.txt")
     *     .build();
     * ```
     *
     * If it is only necessary to force a cached response to be validated by the server, use the more
     * efficient `max-age=0` directive instead:
     *
     * ```java
     * Request request = new Request.Builder()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 03 17:41:45 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  8. guava/src/com/google/common/primitives/Doubles.java

          return Math.min(Math.max(value, min), max);
        }
        throw new IllegalArgumentException(
            lenientFormat("min (%s) must be less than or equal to max (%s)", min, max));
      }
    
      /**
       * Returns the values from each provided array combined into a single array. For example, {@code
       * concat(new double[] {a, b}, new double[] {}, new double[] {c}} returns the array {@code {a, b,
       * c}}.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 22 18:14:49 GMT 2025
    - 27.6K bytes
    - Click Count (0)
  9. src/archive/tar/common.go

    var tarinsecurepath = godebug.New("tarinsecurepath")
    
    var (
    	ErrHeader          = errors.New("archive/tar: invalid tar header")
    	ErrWriteTooLong    = errors.New("archive/tar: write too long")
    	ErrFieldTooLong    = errors.New("archive/tar: header field too long")
    	ErrWriteAfterClose = errors.New("archive/tar: write after close")
    	ErrInsecurePath    = errors.New("archive/tar: insecure file path")
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 24.5K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

        protected int maxErrorCount = 2;
    
        /** List of finished crawler session IDs for cleanup */
        protected List<String> finishedSessionIdList = new ArrayList<>();
    
        /** List of document boost matchers for scoring enhancement */
        private final List<DocBoostMatcher> docBoostMatcherList = new ArrayList<>();
    
        /** List of active crawler instances */
        private List<Crawler> crawlerList;
    
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
Back to Top