Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 213 for sendMsg (0.07 seconds)

  1. docs/changelogs/changelog_3x.md

        exception, "Expected Android API level 21+ but was 29".
    
    
    ## Version 3.14.6
    
    _2020-01-11_
    
     *  Fix: Don't crash if the connection is closed when sending a degraded ping. This fixes a
        regression that was introduced in OkHttp 3.14.5.
    
    
    ## Version 3.14.5
    
    _2020-01-03_
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  2. 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)
  3. internal/event/targetlist_test.go

    )
    
    type ExampleTarget struct {
    	id       TargetID
    	sendErr  bool
    	closeErr bool
    }
    
    func (target ExampleTarget) ID() TargetID {
    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 6K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/listen-notification-handlers.go

    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
    	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top