Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 491 for ccancel (0.05 seconds)

  1. guava/src/com/google/common/util/concurrent/AbstractService.java

       * State#RUNNING}. Services that need to cancel startup work can override {@link #doCancelStart}.
       */
      @ForOverride
      protected abstract void doStop();
    
      /**
       * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link
       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.7K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb2/Smb2ConstantsTest.java

            }
    
            @Test
            @DisplayName("Multi-channel capability should be 0x8")
            void testGlobalCapMultiChannel() {
                assertEquals(0x8, Smb2Constants.SMB2_GLOBAL_CAP_MULTI_CHANNEL, "Multi-channel capability must be 0x8");
            }
    
            @Test
            @DisplayName("Persistent handles capability should be 0x10")
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  3. cmd/signature-v4-utils_test.go

    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestCheckValid(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  4. docs/pt/docs/help-fastapi.md

    ### Peça para encerrar { #ask-to-close }
    
    Se a pessoa responder, há uma grande chance de você ter resolvido o problema, parabéns, **você é um(a) herói(na)**! 🦸
    
    * Agora, se isso resolveu o problema, você pode pedir para:
    
        * No GitHub Discussions: marcar o comentário como a **resposta**.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  5. docs/sts/tls.md

    *Applications that use direct S3 API will work fine, however interactive users uploading content using (when POSTing to the presigned URL an app generates) a popup becomes visible on browser to provide client certs, you would have to manually cancel and continue. This may be annoying to use but there is no workaround for now.*
    
    ## Explore Further
    
    - [MinIO Admin Complete Guide](https://docs.min.io/community/minio-object-store/reference/minio-mc-admin.html)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 6K bytes
    - Click Count (1)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Play it back.
        connect(peer, PushObserver.CANCEL, Http2Connection.Listener.REFUSE_INCOMING_STREAMS)
    
        // Verify the peer received what was expected.
        val rstStream = peer.takeFrame()
        assertThat(rstStream.type).isEqualTo(Http2.TYPE_RST_STREAM)
        assertThat(rstStream.streamId).isEqualTo(2)
        assertThat(rstStream.errorCode).isEqualTo(ErrorCode.CANCEL)
      }
    
      /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  7. docs/changelogs/changelog_3x.md

     *  **Canceling batches of calls is now the application's responsibility.**
        The API to cancel calls by tag has been removed and replaced with a more
        general mechanism. The dispatcher now exposes all in-flight calls via its
        `runningCalls()` and `queuedCalls()` methods. You can write code that
        selects calls by tag, host, or whatever, and invokes `Call.cancel()` on the
        ones that are no longer necessary.
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  8. .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"
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Dec 22 07:15:16 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  9. .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. 😎
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu Aug 03 15:59:41 GMT 2023
    - 5.8K bytes
    - Click Count (0)
  10. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/260137033
              @Override
              protected void finalize() {
                future.cancel(false);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 17:02:07 GMT 2025
    - 7.9K bytes
    - Click Count (0)
Back to Top