Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 285 for poolId (0.08 sec)

  1. docs/pt/docs/tutorial/request-files.md

    {* ../../docs_src/request_files/tutorial001_an_py39.py hl[14] *}
    
    Utilizar `UploadFile` tem várias vantagens sobre `bytes`:
    
    * Você não precisa utilizar o `File()` no valor padrão do parâmetro.
    * Ele utiliza um arquivo "spooled":
        * Um arquivo armazenado na memória até um limite máximo de tamanho, e após passar esse limite, ele será armazenado no disco.
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Nov 12 16:23:57 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. internal/grid/grid.go

    	// Used if no deadline is provided on context.
    	defaultSingleRequestTimeout = time.Minute
    )
    
    var internalByteBuffer = bpool.Pool[*[]byte]{
    	New: func() *[]byte {
    		m := make([]byte, 0, defaultBufferSize)
    		return &m
    	},
    }
    
    var internal32KByteBuffer = bpool.Pool[*[]byte]{
    	New: func() *[]byte {
    		m := make([]byte, 0, biggerBufMin)
    		return &m
    	},
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7K bytes
    - Viewed (0)
  3. src/test/java/jcifs/CIFSContextTest.java

            SmbTransportPool mockPool = mock(SmbTransportPool.class);
            when(mockContext.getTransportPool()).thenReturn(mockPool);
    
            // When
            SmbTransportPool pool = mockContext.getTransportPool();
    
            // Then
            assertEquals(mockPool, pool);
            verify(mockContext).getTransportPool();
        }
    
        @Test
        @DisplayName("Should get DfsResolver")
        void testGetDfs() {
            // Given
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

         * the interrupting thread doesn't interrupt the _next_ thing to run on this thread.
         *
         * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread
         * pool thread, the thread pool will reset it for us. Otherwise, the interrupted bit may have
         * been intended for something else, so don't clear it.
         */
        boolean restoreInterruptedBit = false;
        int spinCount = 0;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt

          .build()
        assertThat(original.interceptors.size).isEqualTo(0)
        assertThat(original.networkInterceptors.size).isEqualTo(0)
      }
    
      /**
       * When copying the client, stateful things like the connection pool are shared across all
       * clients.
       */
      @Test fun cloneSharesStatefulInstances() {
        val client = clientTestRule.newClient()
    
        // Values should be non-null.
        val a = client.newBuilder().build()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 13.4K bytes
    - Viewed (1)
  6. scripts/docs.py

            if (lang.is_dir() and lang.name in SUPPORTED_LANGS)
        ]
        cpu_count = os.cpu_count() or 1
        process_pool_size = cpu_count * 4
        typer.echo(f"Using process pool size: {process_pool_size}")
        with Pool(process_pool_size) as p:
            p.map(build_lang, langs)
    
    
    @app.command()
    def update_languages() -> None:
        """
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Dec 21 17:40:17 UTC 2025
    - 16.9K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

            append(buf, "committed", () -> mem.getNonHeapCommitted().getBytes());
            buf.append('}');
            buf.append("},");
            final List<BufferPool> bufferPools = jvmStats.getBufferPools();
            buf.append("\"pools\":{");
            buf.append(bufferPools.stream().map(p -> {
                final StringBuilder b = new StringBuilder();
                b.append('"').append(StringEscapeUtils.escapeJson(p.getName())).append("\":{");
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  8. cmd/storage-interface.go

    	WriteAll(ctx context.Context, volume string, path string, b []byte) (err error)
    
    	// Read all.
    	ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error)
    	GetDiskLoc() (poolIdx, setIdx, diskIdx int) // Retrieve location indexes.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTreeHandleInternal.java

     * SMB tree connections and their lifecycle.
     *
     * @author mbechler
     */
    public interface SmbTreeHandleInternal extends SmbTreeHandle {
    
        /**
         * Releases this tree handle back to the pool for reuse
         */
        void release();
    
        /**
         * Ensures that DFS referrals have been resolved for this tree
         * @throws SmbException if an SMB-specific error occurs
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  10. cmd/naughty-disk_test.go

    	defer d.mu.Unlock()
    	d.callNR++
    	if err, ok := d.errors[d.callNR]; ok {
    		return err
    	}
    	if d.defaultErr != nil {
    		return d.defaultErr
    	}
    	return nil
    }
    
    func (d *naughtyDisk) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return -1, -1, -1
    }
    
    func (d *naughtyDisk) GetDiskID() (string, error) {
    	return d.disk.GetDiskID()
    }
    
    func (d *naughtyDisk) SetDiskID(id string) {
    	d.disk.SetDiskID(id)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
Back to top