Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 540 for blocks (0.13 sec)

  1. cmd/erasure-object.go

    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := er.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    **FastAPI** uses them internally to achieve this.
    
    ///
    
    ## Dependencies with `yield` and `HTTPException`
    
    You saw that you can use dependencies with `yield` and have `try` blocks that catch exceptions.
    
    The same way, you could raise an `HTTPException` or similar in the exit code, after the `yield`.
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt

          private val useCompression: Boolean = true,
          private val out: Buffer,
        ) {
          /**
           * In the scenario where the dynamic table size changes multiple times between transmission of
           * header blocks, we need to keep track of the smallest value in that interval.
           */
          private var smallestHeaderTableSizeSetting = Integer.MAX_VALUE
          private var emitDynamicTableSizeUpdate: Boolean = false
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  5. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        assertThat(first.requestLine).isEqualTo("GET / HTTP/1.1")
        val redirect = server.takeRequest()
        assertThat(redirect.requestLine).isEqualTo("GET /new-path HTTP/1.1")
      }
    
      /**
       * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock
       * response is ready.
       */
      @Test
      fun dispatchBlocksWaitingForEnqueue() {
        Thread {
          try {
            Thread.sleep(1000)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        assertThat(first.requestLine).isEqualTo("GET / HTTP/1.1")
        val redirect = server.takeRequest()
        assertThat(redirect.requestLine).isEqualTo("GET /new-path HTTP/1.1")
      }
    
      /**
       * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock
       * response is ready.
       */
      @Test
      fun dispatchBlocksWaitingForEnqueue() {
        Thread {
          try {
            Thread.sleep(1000)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  7. src/archive/tar/writer.go

    					sa.IsExtended()[0] = 1
    				}
    				return sp
    			}
    			sp2 := formatSPD(spd, blk.GNU().Sparse())
    			for len(sp2) > 0 {
    				var spHdr block
    				sp2 = formatSPD(sp2, spHdr.Sparse())
    				spb = append(spb, spHdr[:]...)
    			}
    
    			// Update size fields in the header block.
    			realSize := hdr.Size
    			hdr.Size = 0 // Encoded size; does not account for encoded sparse map
    			for _, s := range spd {
    				hdr.Size += s.Length
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  8. src/archive/tar/reader_test.go

    		// Write the initial GNU header.
    		var blk block
    		gnu := blk.toGNU()
    		sparse := gnu.sparse()
    		copy(gnu.realSize(), size)
    		sps = populateSparseMap(sparse, sps)
    		if format != FormatUnknown {
    			blk.setFormat(format)
    		}
    		out = append(out, blk[:]...)
    
    		// Write extended sparse blocks.
    		for len(sps) > 0 {
    			var blk block
    			sps = populateSparseMap(blk.toSparse(), sps)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  9. cmd/peer-rest-client.go

    		}
    	}()
    }
    
    // Trace - send http trace request to peer nodes
    func (client *peerRESTClient) Trace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) {
    	go func() {
    		for {
    			// Blocks until context is canceled or an error occurs.
    			client.doTrace(ctx, traceCh, traceOpts)
    			select {
    			case <-ctx.Done():
    				return
    			default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  10. README.md

    ## Deployment Recommendations
    
    ### Allow port access for Firewalls
    
    By default MinIO uses the port 9000 to listen for incoming connections. If your platform blocks the port by default, you may need to enable access to the port.
    
    ### ufw
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:34:11 UTC 2024
    - 18.2K bytes
    - Viewed (0)
Back to top