- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 194 for channel2 (0.08 seconds)
-
src/main/java/jcifs/ntlmssp/Type3Message.java
AvPairs.replace(serverAvPairs, new AvTimestamp(ts)); if (targetName != null) { AvPairs.replace(serverAvPairs, new AvTargetName(targetName)); } // possibly add channel bindings AvPairs.replace(serverAvPairs, new AvPair(0xa, new byte[16])); AvPairs.replace(serverAvPairs, new AvSingleHost(tc.getConfig())); return AvPairs.encode(serverAvPairs); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 32.7K bytes - Click Count (0) -
cmd/iam-object-store.go
func listIAMConfigItems(ctx context.Context, objAPI ObjectLayer, pathPrefix string) <-chan itemOrErr[string] { ch := make(chan itemOrErr[string]) go func() { defer xioutil.SafeClose(ch) // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan itemOrErr[ObjectInfo]) if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil { select {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 26.6K bytes - Click Count (0) -
doc/godebug.md
use and validate the CRT parameters in the encoded private key. This behavior can be controlled with the `x509rsacrt` setting. Using `x509rsacrt=0` restores the Go 1.23 behavior. ### Go 1.23 Go 1.23 changed the channels created by package time to be unbuffered (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop) and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Mar 20 15:49:10 GMT 2026 - 26K bytes - Click Count (0) -
internal/grid/grid_test.go
st.Results(func(b []byte) error { close(nowBlocking) // Block until test is done. <-stopBlocking return nil }) }() <-nowBlocking // Wait for the receiver channel to fill. for len(st.responses) != cap(st.responses) { time.Sleep(time.Millisecond) } cancel() <-serverCanceled local.debugMsg(debugIsOutgoingClosed, st.muxID, func(closed bool) { if !closed {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
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) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 34.5K bytes - Click Count (0) -
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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Jun 25 15:08:54 GMT 2025 - 37.3K bytes - Click Count (0) -
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) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0) -
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
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 309.7K bytes - Click Count (1) -
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.Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Mon Mar 30 18:31:38 GMT 2026 - 746.5K bytes - Click Count (3) -
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))
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Mon Jun 14 22:06:39 GMT 2021 - 271.5K bytes - Click Count (0)