Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 432 for ccancel (2.27 sec)

  1. cmd/utils.go

    		CurvePreferences: crypto.TLSCurveIDs(),
    		TCPOptions:       globalTCPOptions,
    		EnableHTTP2:      false,
    	}
    
    	if clientCert != "" && clientKey != "" {
    		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    		defer cancel()
    		transport, err := s.NewHTTPTransportWithClientCerts(ctx, clientCert, clientKey)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  2. .teamcity/src/main/kotlin/configurations/PerformanceTestsPass.kt

                    param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                    param("performance.db.username", "tcagent")
                    param("env.PERFORMANCE_CHANNEL", performanceTestSpec.channel())
                }
    
                features {
                    publishBuildStatusToGithub(model)
                }
    
                val performanceResultsDir = "perf-results"
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 12 09:12:03 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  3. .github/DISCUSSION_TEMPLATE/questions.yml

            By asking questions in a structured way (following this) it will be much easier to help you.
    
            And there's a high chance that you will find the solution along the way and you won't even have to submit it and wait for an answer. 😎
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Thu Aug 03 15:59:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  4. src/test/java/jcifs/dcerpc/DcerpcMessageTest.java

                when(mockBuffer.dec_ndr_short()).thenReturn(100) // length
                        .thenReturn(0) // auth_value length
                        .thenReturn(0) // context id
                        .thenReturn(0); // cancel count
    
                message.decode(mockBuffer);
    
                assertEquals(DcerpcConstants.RPC_PT_RESPONSE, message.ptype);
                assertEquals(100, message.alloc_hint);
            }
    
            @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  5. CONTRIBUTING.md

    ```
    
    ### Test MinIO server changes
    
    After your code changes, make sure
    
    - To add test cases for the new code. If you have questions about how to do it, please ask on our [Slack](https://slack.min.io) channel.
    - To run `make verifiers`
    - To squash your commits into a single commit. `git rebase -i`. It's okay to force update your pull request.
    - To run `make test` and `make build` completes.
    
    ### Commit changes
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait.
      })
      private void waitForInterrupt(Thread currentThread) {
        /*
         * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
         * Wait for the interrupting thread to set DONE. (See interruptTask().) We want to wait so that
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  7. docs/smb3-features/05-rdma-smb-direct-design.md

                EnumSet.of(RdmaAccess.LOCAL_WRITE, RdmaAccess.REMOTE_WRITE));
            
            try {
                // Create SMB2 Read request with RDMA read channel info
                request.addRdmaChannelInfo(readRegion.getRemoteKey(), 
                                         readRegion.getAddress(),
                                         readRegion.getSize());
                
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        consumer.accept(new ValueAndCloser<C>(closingFuture));
      }
    
      /**
       * Attempts to cancel execution of this step. This attempt will fail if the step has already
       * completed, has already been cancelled, or could not be cancelled for some other reason. If
       * successful, and this step has not started when {@code cancel} is called, this step should never
       * run.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  9. cmd/notification.go

    		if client == nil {
    			continue
    		}
    		ng.Go(ctx, func() error {
    			// Give 15 seconds to each remote call.
    			// Errors are logged but not returned.
    			ctx, cancel := context.WithTimeout(ctx, 15*time.Second)
    			defer cancel()
    			data, err := client.DownloadProfileData(ctx)
    			if err != nil {
    				reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", client.host.String())
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  10. docs/pt/docs/async.md

    Ainda, em ambas as situações, as chances são que o **FastAPI** [ainda será mais rápido](index.md#performance){.internal-link target=_blank} do que (ou ao menos comparável a) seu framework anterior.
    
    ### Dependências
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 23.6K bytes
    - Viewed (0)
Back to top