Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 351 for buffer (0.04 seconds)

  1. internal/grid/handlers.go

    	// It must keep consuming from 'in' until it returns.
    	// 'in' and 'out' are independent.
    	// The handler should never close out.
    	// Buffers received from 'in'  can be recycled with PutByteBuffer.
    	// Buffers sent on out can not be referenced once sent.
    	StreamHandlerFn func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  2. tensorflow/c/c_api_experimental.h

    //     in `input_shapes`.
    //
    // The results are returned in `output_shapes` and
    // `output_resource_shapes_and_types`. The caller is responsible for freeing the
    // memory in these buffers by calling `TF_DeleteShapeAndTypeList`.
    TF_CAPI_EXPORT extern void TFE_InferShapes(
        TFE_Op* op, TF_ShapeAndTypeList* input_shapes, TF_Tensor** input_tensors,
        TF_ShapeAndTypeList* input_tensor_as_shapes,
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Thu Apr 27 21:07:00 GMT 2023
    - 15.1K bytes
    - Click Count (0)
  3. cmd/listen-notification-handlers.go

    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/io/CharSink.java

       *
       * @throws IOException if an I/O error occurs while opening the writer
       */
      public abstract Writer openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Apr 14 16:07:06 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  5. cmd/metacache-walk.go

    			return convertAccessError(err, errVolumeAccessDenied)
    		}
    	}
    
    	// Use a small block size to start sending quickly
    	w := newMetacacheWriter(wr, 16<<10)
    	w.reuseBlocks = true // We are not sharing results, so reuse buffers.
    	defer w.Close()
    	out, err := w.stream()
    	if err != nil {
    		return err
    	}
    	defer xioutil.SafeClose(out)
    	var objsReturned int
    
    	objReturned := func(metadata []byte) {
    		if opts.Limit <= 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 26 07:06:43 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  6. ci/official/utilities/setup_macos.sh

    # limitations under the License.
    # ==============================================================================
    #
    # macOS specific setup for all TF scripts.
    #
    
    # Mac version of Core utilities differ in usage. Since our scripts are written
    # with the GNU style, we need to set GNU utilities to be default on Mac.
    if [[ -n "$(which grealpath)" ]] &&  [[ -n "$(which gstat)" ]]; then
      alias realpath=grealpath
      alias stat=gstat
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Oct 06 22:42:26 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  7. impl/maven-core/src/site/apt/configuration-management.apt

    ~~ under the License.
    
     -----
     Maven configuration management
     -----
     The Maven Team
     -----
    
    Configuration levels in maven
    
     In maven configuration control happens on four differ levels: the site level, the group level,
     the project level, and the user level. On the site level you can configure maven for all users
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 5.8K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool.go

    	// setCount * setDriveCount with each memory upto blockSizeV2.
    	buffers := bpool.NewBytePoolCap(n, blockSizeV2, blockSizeV2*2)
    	if n >= 16384 {
    		// pre-populate buffers only n >= 16384 which is (32Gi/2Mi)
    		// for all setups smaller than this avoid pre-alloc.
    		buffers.Populate()
    	}
    	globalBytePoolCap.Store(buffers)
    
    	var localDrives []StorageAPI
    	local := endpointServerPools.FirstLocal()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/hash/BloomFilter.java

       * BloomFilter} with false positive probability 3%.
       *
       * <p>Note that if the {@code Collector} receives significantly more elements than specified, the
       * resulting {@code BloomFilter} will suffer a sharp deterioration of its false positive
       * probability.
       *
       * <p>The constructed {@code BloomFilter} will be serializable if the provided {@code Funnel<T>}
       * is.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 19:23:59 GMT 2025
    - 26.9K bytes
    - Click Count (0)
  10. internal/grid/grid_test.go

    	}
    	// local to remote, unbuffered
    	t.Run("unbuffered", func(t *testing.T) {
    		testHandler(t, handlerTest, false)
    	})
    	t.Run("buffered", func(t *testing.T) {
    		testHandler(t, handlerTest2, false)
    	})
    	t.Run("buffered", func(t *testing.T) {
    		testHandler(t, handlerTest2, true)
    	})
    }
    
    // testStreamDeadline will test if server
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
Back to Top