Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 149 for channel2 (0.08 sec)

  1. cmd/xl-storage-disk-id-check.go

    	return p.storage.ReadParts(ctx, volume, partMetaPaths...)
    }
    
    // ReadMultiple will read multiple files and send each files as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context will return an error.
    func (p *xlStorageDiskIDCheck) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) (err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  2. cmd/object-api-utils.go

    		}
    		return actualSize, nil
    	}
    	return o.Size, nil
    }
    
    // Disabling compression for encrypted enabled requests.
    // Using compression and encryption together enables room for side channel attacks.
    // Eliminate non-compressible objects by extensions/content-types.
    func isCompressible(header http.Header, object string) bool {
    	globalCompressConfigMu.Lock()
    	cfg := globalCompressConfig
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    	scanMode              madmin.HealScanMode
    
    	weSleep    func() bool
    	shouldHeal func() bool
    
    	disks       []StorageAPI
    	disksQuorum int
    
    	// If set updates will be sent regularly to this channel.
    	// Will not be closed when returned.
    	updates    chan<- dataUsageEntry
    	lastUpdate time.Time
    
    	// updateCurrentPath should be called whenever a new path is scanned.
    	updateCurrentPath func(string)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  4. RELEASE.md

    * `tf.lite`
        * `Dequantize` op supports `TensorType_INT4`.
            * This change includes per-channel dequantization.
        * Add support for `stablehlo.composite`.
        * `EmbeddingLookup` op supports per-channel quantization and `TensorType_INT4` values.
        * `FullyConnected` op supports `TensorType_INT16` activation and `TensorType_Int4` weight per-channel quantization.
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Aug 18 20:54:38 UTC 2025
    - 740K bytes
    - Viewed (1)
  5. CHANGELOG/CHANGELOG-1.14.md

    * [Breaking change, client-go]: The WaitFor function returns, probably an ErrWaitTimeout, when the done channel is closed, even if the `WaitFunc` doesn't handle the done channel. ([#72364](https://github.com/kubernetes/kubernetes/pull/72364), [@kdada](https://github.com/kdada))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Mon Jun 14 22:06:39 UTC 2021
    - 271.5K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    		return
    	}
    	setEventStreamHeaders(w)
    
    	// Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers.
    	// Keep 100k buffered channel.
    	// If receiver cannot keep up with that we drop events.
    	traceCh := make(chan []byte, 100000)
    	peers, _ := newPeerRestClients(globalEndpoints)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    cfa
    
    // cfd : ShortDot SA
    // https://www.iana.org/domains/root/db/cfd.html
    cfd
    
    // chanel : Chanel International B.V.
    // https://www.iana.org/domains/root/db/chanel.html
    chanel
    
    // channel : Charleston Road Registry Inc.
    // https://www.iana.org/domains/root/db/channel.html
    channel
    
    // charity : Public Interest Registry
    // https://www.iana.org/domains/root/db/charity.html
    charity
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 309.7K bytes
    - Viewed (0)
  8. okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list

    cesena-forlì.it
    cesenaforli.it
    cesenaforlì.it
    cf
    cf-ipfs.com
    cfa
    cfd
    cfolks.pl
    cg
    ch
    ch.eu.org
    ch.it
    ch.trendhosting.cloud
    chambagri.fr
    championship.aero
    chanel
    channel
    channelsdvr.net
    charity
    charter.aero
    chase
    chat
    cheap
    cheap.jp
    cherkassy.ua
    cherkasy.ua
    chernigov.ua
    chernihiv.ua
    chernivtsi.ua
    chernovtsy.ua
    chiba.jp
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 22:00:49 UTC 2025
    - 129.6K bytes
    - Viewed (3)
  9. cmd/erasure-object.go

    	}
    
    	return dfi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // Send the successful but partial upload/delete, however ignore
    // if the channel is blocked by other items.
    func (er erasureObjects) addPartial(bucket, object, versionID string) {
    	globalMRFState.addPartialOp(PartialOperation{
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    	}()
    	go func() {
    		defer close(errCh)
    		// Merge all entries from all disks.
    		// We leave quorum at 1, since entries are already resolved to have the desired quorum.
    		// mergeEntryChannels will close 'merged' channel upon completion or cancellation.
    		errCh <- mergeEntryChannels(ctx, entries, merged, 1)
    	}()
    
    	return nil
    }
    
    // HealObjectFn closure function heals the object.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top