Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 220 for processors (0.36 sec)

  1. docs/pt/docs/features.md

    * Suporte a **WebSocket**.
    * Suporte a **GraphQL**.
    * Tarefas em processo _background_.
    * Eventos na inicialização e encerramento.
    * Cliente de testes construído sobre HTTPX.
    * Respostas em **CORS**, GZip, Static Files, Streaming.
    * Suporte a **Session e Cookie**.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/sso/spnego/SpnegoAuthenticator.java

                throw new SsoLoginException("Failed to initialize SPNEGO.", e);
            }
        }
    
        /**
         * Attempts to obtain login credentials using SPNEGO authentication.
         *
         * This method processes the HTTP request to extract and validate SPNEGO
         * authentication tokens. It handles the SPNEGO handshake process and
         * extracts the user principal from successful authentication.
         *
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  3. cmd/update.go

    	if err != nil {
    		return t, fmt.Errorf("Unable to get ModTime of %s. %w", absPath, err)
    	}
    
    	// Return the ModTime
    	return fi.ModTime().UTC(), nil
    }
    
    // GetCurrentReleaseTime - returns this process's release time.  If it
    // is official minio version, parsed version is returned else minio
    // binary's mod time is returned.
    func GetCurrentReleaseTime() (releaseTime time.Time, err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  4. cmd/bucket-replication-metrics.go

    	}
    }
    
    // incrementBytes add bytes reported for a bucket/target.
    func (m *rateMeasurement) incrementBytes(bytes uint64) {
    	atomic.AddUint64(&m.bytesSinceLastWindow, bytes)
    }
    
    // updateExponentialMovingAverage processes the measurements captured so far.
    func (m *rateMeasurement) updateExponentialMovingAverage(endTime time.Time) {
    	// Calculate aggregate avg bandwidth and exp window avg
    	m.lock.Lock()
    	defer func() {
    		m.startTime = endTime
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/SearchHelper.java

            }
    
        }
    
        /**
         * Internal search method that executes the actual search query.
         *
         * This method performs the search using the rank fusion processor and may retry
         * with OR operator if the hit count is below the configured minimum threshold.
         *
         * @param query The search query string
         * @param params The search request parameters
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/job/SuggestJobTest.java

                    // Create a mock JavaPropertiesResult
                    java.util.Properties props = new java.util.Properties();
                    props.setProperty("job.max.crawler.processes", "5");
                    props.setProperty("java.command.path", "java");
    
                    org.dbflute.helper.jprop.JavaPropertiesReader reader =
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

    ) : WebSocket,
      WebSocketReader.FrameCallback,
      Lockable {
      private val key: String
    
      /** Non-null for client web sockets. These can be canceled. */
      internal var call: Call? = null
    
      /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */
      private var writerTask: Task? = null
    
      /** Null until this web socket is connected. Only accessed by the reader thread. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  8. docs/LICENSE

      d. Nothing in this Public License constitutes or may be interpreted
         as a limitation upon, or waiver of, any privileges and immunities
         that apply to the Licensor or You, including from the legal
         processes of any jurisdiction or authority.
    
    
    =======================================================================
    
    Creative Commons is not a party to its public
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 10 16:50:06 UTC 2021
    - 18.2K bytes
    - Viewed (0)
  9. src/cmd/cgo/doc.go

    is okay, because cmd/link also processes the cgo_import_static directive and
    knows that _cgo_gcc_Cfunc_sin is expected to be supplied by a host
    object file, so cmd/link does not treat the missing symbol as an error when
    creating go.o. Indeed, the definition for _cgo_gcc_Cfunc_sin will be
    provided to the host linker by foo2.cgo.o, which in turn will need the
    symbol 'sin'. cmd/link also processes the cgo_ldflag directives, so that it
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Dec 11 23:57:34 UTC 2024
    - 44K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

        @SuppressWarnings("nullness")
        ListenableFuture<List<V>> nonNull = nullable;
        return nonNull;
      }
    
      /**
       * Creates a {@link FutureCombiner} that processes the completed futures whether or not they're
       * successful.
       *
       * <p>Any failures from the input futures will not be propagated to the returned future.
       *
       * @since 20.0
       */
      @SafeVarargs
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
Back to top