Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 170 for sendMsg (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/prepare-storage.go

    // https://github.com/minio/minio/issues/5667
    var errErasureV3ThisEmpty = fmt.Errorf("Erasure format version 3 has This field empty")
    
    // isServerResolvable - checks if the endpoint is resolvable
    // by sending a naked HTTP request with liveness checks.
    func isServerResolvable(endpoint Endpoint, timeout time.Duration) error {
    	serverURL := &url.URL{
    		Scheme: endpoint.Scheme,
    		Host:   endpoint.Host,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheStrategy.kt

          return receivedAge + responseDuration + residentDuration
        }
    
        /**
         * Returns true if the request contains conditions that save the server from sending a response
         * that the client has locally. When a request is enqueued with its own conditions, the built-in
         * response cache won't be used.
         */
        private fun hasConditions(request: Request): Boolean =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      /**
       * Returns a request that creates a TLS tunnel via an HTTP proxy. Everything in the tunnel request
       * is sent unencrypted to the proxy server, so tunnels include only the minimum set of headers.
       * This avoids sending potentially sensitive data like HTTP cookies to the proxy unencrypted.
       *
       * In order to support preemptive authentication we pass a fake "Auth Failed" response to the
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  4. cmd/event-notification.go

    	defer evnot.Unlock()
    
    	targetIDSet := event.NewTargetIDSet()
    	for k := range evnot.targetList.TargetMap() {
    		targetIDSet[k] = struct{}{}
    	}
    	evnot.targetList.Remove(targetIDSet)
    }
    
    // Send - sends the event to all registered notification targets
    func (evnot *EventNotifier) Send(args eventArgs) {
    	evnot.RLock()
    	targetIDSet := evnot.bucketRulesMap[args.BucketName].Match(args.EventName, args.Object.Name)
    	evnot.RUnlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        taskFaker.runTasks()
        client.listener.assertFailure(IOException::class.java, "source is closed")
      }
    
      @Test
      fun closeMessageAndConnectionCloseThrowingDoesNotMaskOriginal() {
        // So when the client sends close it throws an IOException.
        server.source.close()
        client.webSocket!!.close(1000, "Bye!")
        taskFaker.runTasks()
        client.webSocket!!.finishReader()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  6. docs/en/docs/advanced/security/http-basic-auth.md

    That tells the browser to show the integrated prompt for a username and password.
    
    Then, when you type that username and password, the browser sends them in the header automatically.
    
    ## Simple HTTP Basic Auth { #simple-http-basic-auth }
    
    * Import `HTTPBasic` and `HTTPBasicCredentials`.
    * Create a "`security` scheme" using `HTTPBasic`.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5K bytes
    - Click Count (0)
  7. docs/en/docs/tutorial/cors.md

    Then, the browser will send an HTTP `OPTIONS` request to the `:80`-backend, and if the backend sends the appropriate headers authorizing the communication from this different origin (`http://localhost:8080`) then the `:8080`-browser will let the JavaScript in the frontend send its request to the `:80`-backend.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5.2K bytes
    - Click Count (0)
  8. docs/sts/tls.md

    Now, the STS certificate-based authentication happens in 4 steps:
    
    - Client sends HTTP `POST` request over a TLS connection hitting the MinIO TLS STS API.
    - MinIO verifies that the client certificate is valid.
    - MinIO tries to find a policy that matches the `CN` of the client certificate.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 6K bytes
    - Click Count (1)
  9. src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java

            // Execute
            String result = pingSearchEngineJob.execute();
    
            // Assert
            assertEquals("Status of test-cluster is changed to RED.", result);
            // Note: Notification sending is tested but we don't verify the mock since it uses complex callback mechanism
        }
    
        // Test state change with empty notification addresses
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18.9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java

                if (aggregations != null) {
                    builder.facetResponse(new FacetResponse(aggregations));
                }
    
            });
            return builder.build();
        }
    
        /**
         * Sends a search request to OpenSearch with the specified parameters.
         *
         * @param query the search query string
         * @param params the search request parameters
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 09:24:04 GMT 2025
    - 12.6K bytes
    - Click Count (0)
Back to Top