Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for traceCh (0.11 sec)

  1. cmd/admin-handlers.go

    		if peer == nil {
    			continue
    		}
    		peer.Trace(ctx, traceCh, traceOpts)
    	}
    
    	keepAliveTicker := time.NewTicker(time.Second)
    	defer keepAliveTicker.Stop()
    
    	for {
    		select {
    		case entry := <-traceCh:
    			if _, err := w.Write(entry); err != nil {
    				return
    			}
    			grid.PutByteBuffer(entry)
    			if len(traceCh) == 0 {
    				// Flush if nothing is queued
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    			defer wg.Done()
    			for roi := range workers[idx] {
    				select {
    				case <-ctx.Done():
    					return
    				case <-s.resyncCancelCh:
    				default:
    				}
    				traceFn := s.trace(tgt.ResetID, fmt.Sprintf("%s/%s (%s)", opts.bucket, roi.Name, roi.VersionID))
    				if roi.DeleteMarker || !roi.VersionPurgeStatus.Empty() {
    					versionID := ""
    					dmVersionID := ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. fastapi/routing.py

                name=name,
                callbacks=callbacks,
                openapi_extra=openapi_extra,
                generate_unique_id_function=generate_unique_id_function,
            )
    
        def trace(
            self,
            path: Annotated[
                str,
                Doc(
                    """
                    The URL path to be used for this *path operation*.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:44:57 UTC 2024
    - 172.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
        if (!done) {
          StringBuilder builder = new StringBuilder();
          for (StackTraceElement trace : thread.getStackTrace()) {
            builder.append("\tat ").append(trace).append('\n');
          }
          fail(builder.toString());
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
        if (!done) {
          StringBuilder builder = new StringBuilder();
          for (StackTraceElement trace : thread.getStackTrace()) {
            builder.append("\tat ").append(trace).append('\n');
          }
          fail(builder.toString());
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  6. cmd/testdata/decryptObjectInfo.json.zst

    ncryption-S3-Sealed-Key":"IAAfAMMpsuoBm5H6WEV1/GXN62X/H4i6iAH9a8e5GDStp3Hl/9w==","X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm":"DAREv2-HMAC-SHA256","content-type":"application/octet-stream"}},{"Bucket":"buck1","Name":"go_113/src/cmd/trace/trace.go","UserDef":{"X-Minio-Internal-Server-Side-Encryption-Iv":"J7O5iC5KY88NYSySviPG=","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id":"my-minio-key","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Sealed-Key":"IAAfAIYvSkUNNt0olfz1/E3QbYuW...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 29 16:34:20 UTC 2020
    - 164K bytes
    - Viewed (0)
  7. fastapi/applications.py

            """
            Add a *path operation* using an HTTP TRACE operation.
    
            ## Example
    
            ```python
            from fastapi import FastAPI
    
            app = FastAPI()
    
            @app.put("/items/{item_id}")
            def trace_item(item_id: str):
                return None
            ```
            """
            return self.router.trace(
                path,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:52:31 UTC 2024
    - 172.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  9. okhttp-android/src/main/baseline-prof.txt

    HSPLandroidx/startup/AppInitializer;->doInitialize(Ljava/lang/Class;Ljava/util/Set;)Ljava/lang/Object;
    HSPLandroidx/startup/InitializationProvider;-><init>()V
    HSPLandroidx/startup/InitializationProvider;->onCreate()Z
    HSPLandroidx/tracing/Trace;->isEnabled()Z
    HSPLkotlin/Result$Failure;-><init>(Ljava/lang/Throwable;)V
    HSPLkotlin/Result;->exceptionOrNull-impl(Ljava/lang/Object;)Ljava/lang/Throwable;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CacheTest.kt

      }
    
      @Test
      fun requestMethodDeleteIsNotCached() {
        testRequestMethod("DELETE", false)
      }
    
      @Test
      fun requestMethodTraceIsNotCached() {
        testRequestMethod("TRACE", false)
      }
    
      private fun testRequestMethod(
        requestMethod: String,
        expectCached: Boolean,
        withOverride: Boolean = false,
      ) {
        // 1. Seed the cache (potentially).
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
Back to top