Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 181 for listeners (0.18 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.ProtocolException
    import java.net.Proxy
    
    /**
     * Listener for metrics events. Extend this class to monitor the quantity, size, and duration of
     * your application's HTTP calls.
     *
     * All start/connect/acquire events will eventually receive a matching end/release event, either
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  2. cmd/mrf.go

    		localDrive.Delete(GlobalContext, minioMetaBucket, pathJoin(healMRFDir, "list.bin"), DeleteOptions{})
    		break
    	}
    }
    
    var healSleeper = newDynamicSleeper(5, time.Second, false)
    
    // healRoutine listens to new disks reconnection events and
    // issues healing requests for queued objects belonging to the
    // corresponding erasure set
    func (m *mrfState) healRoutine(z *erasureServerPools) {
    	for {
    		select {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

       * [requestBodyOpen], [responseBodyOpen], and [expectMoreExchanges].
       *
       * This will release the connection if it is still held.
       *
       * It will also notify the listener that the call completed; either successfully or
       * unsuccessfully.
       *
       * If the call was canceled or timed out, this will wrap [e] in an exception that provides that
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users_test.go

    	err := s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    	if err != nil {
    		c.Fatalf("Unable to set user: %v", err)
    	}
    
    	// 2. Check new user appears in listing
    	usersMap, err := s.adm.ListUsers(ctx)
    	if err != nil {
    		c.Fatalf("error listing: %v", err)
    	}
    	v, ok := usersMap[accessKey]
    	if !ok {
    		c.Fatalf("user not listed: %s", accessKey)
    	}
    	c.Assert(v.Status, madmin.AccountEnabled)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/behind-a-proxy.md

    proxy["Proxy on http://0.0.0.0:9999/api/v1/app"]
    server["Server on http://127.0.0.1:8000/app"]
    
    browser --> proxy
    proxy --> server
    ```
    
    /// tip
    
    The IP `0.0.0.0` is commonly used to mean that the program listens on all the IPs available in that machine/server.
    
    ///
    
    The docs UI would also need the OpenAPI schema to declare that this API `server` is located at `/api/v1` (behind the proxy). For example:
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 19:34:08 UTC 2025
    - 16K bytes
    - Viewed (0)
  6. src/test/java/jcifs/http/NetworkExplorerTest.java

                }
    
                @Override
                public boolean isReady() {
                    return true;
                }
    
                @Override
                public void setWriteListener(WriteListener listener) {
                }
            };
    
            lenient().when(response.getWriter()).thenReturn(printWriter);
            lenient().when(response.getOutputStream()).thenReturn(servletOutputStream);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  7. CHANGELOG.md

     *  New: `EventListener.retryDecision()` is called each time a request fails with an `IOException`.
        It notifies your listener if OkHttp will retry.
    
     *  New: `EventListener.followUpDecision()` is called each time a response is received. It notifies
        your listener if OkHttp has decided to make a follow-up request. Some common follow-ups are
        authentication challenges and redirects.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 19:32:33 UTC 2025
    - 31.6K bytes
    - Viewed (1)
  8. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java

            } finally {
                // MNG-4543
                cleanupTemporaryFiles(temporaryFiles);
    
                // Remove every checksum listener
                for (String id : CHECKSUM_IDS) {
                    TransferListener checksumListener = checksums.get(id);
                    if (checksumListener != null) {
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Sat Apr 05 11:52:05 UTC 2025
    - 29.9K bytes
    - Viewed (0)
  9. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/internal/http2/Http2Connection$Builder;-><init>(ZLokhttp3/internal/concurrent/TaskRunner;)V
    HSPLokhttp3/internal/http2/Http2Connection$Listener$Companion$REFUSE_INCOMING_STREAMS$1;-><init>()V
    HSPLokhttp3/internal/http2/Http2Connection$Listener;-><clinit>()V
    HSPLokhttp3/internal/http2/Http2Connection$Listener;-><init>()V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users.go

    }
    
    // ListUsers - GET /minio/admin/v3/list-users
    func (a adminAPIHandlers) ListUsers(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, cred := validateAdminReq(ctx, w, r, policy.ListUsersAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	password := cred.SecretKey
    
    	allCredentials, err := globalIAMSys.ListUsers(ctx)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
Back to top