- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for channel (0.06 sec)
-
cmd/bucket-replication.go
configFile := path.Join(bucketMetaPrefix, bucket, replicationDir, resyncFileName) return saveConfig(ctx, objectAPI, configFile, buf) } // getReplicationDiff returns un-replicated objects in a channel. // If a non-nil channel is returned it must be consumed fully or // the provided context must be canceled.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
cmd/admin-handlers.go
} // Start profiling on remote servers. for _, profiler := range profiles { // Limit start time to max 10s. ctx, cancel := context.WithTimeout(ctx, 10*time.Second) globalNotificationSys.StartProfiling(ctx, profiler) // StartProfiling blocks, so we can cancel now. cancel() // Start profiling locally as well. prof, err := startProfiler(profiler) if err == nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.4.md
- [Other notable changes](#other-notable-changes-6) - [v1.4.3](#v143) - [Downloads](#downloads) - [Changelog since v1.4.2-beta.1](#changelog-since-v142-beta1) - [Other notable changes](#other-notable-changes-7) - [v1.4.2](#v142) - [Downloads](#downloads-1) - [Changelog since v1.4.2-beta.1](#changelog-since-v142-beta1-1) - [Other notable changes](#other-notable-changes-8)
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K bytes - Viewed (0) -
cmd/metrics-v2.go
wg.Add(2) go publish(ReportMetrics(GlobalContext, c.metricsGroups)) go publish(globalNotificationSys.GetClusterMetrics(GlobalContext)) wg.Wait() } // ReportMetrics reports serialized metrics to the channel passed for the metrics generated. func ReportMetrics(ctx context.Context, metricsGroups []*MetricsGroupV2) <-chan MetricV2 { ch := make(chan MetricV2) go func() { defer xioutil.SafeClose(ch)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0) -
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) -
okhttp/src/androidMain/assets/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 Dec 31 14:50:53 UTC 2024 - 129.6K bytes - Viewed (2) -
CHANGELOG/CHANGELOG-1.5.md
- [Other notable changes](#other-notable-changes) - [v1.5.7](#v157) - [Downloads for v1.5.7](#downloads-for-v157) - [Client Binaries](#client-binaries-1) - [Server Binaries](#server-binaries-1) - [Node Binaries](#node-binaries-1) - [Changelog since v1.5.6](#changelog-since-v156) - [Other notable changes](#other-notable-changes-1) - [v1.5.6](#v156)
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 136.4K bytes - Viewed (0) -
cmd/sts-handlers_test.go
} } // SetUpLDAP - expects to setup an LDAP test server using the test LDAP // container and canned data from https://github.com/minio/minio-ldap-testing func (s *TestSuiteIAM) SetUpLDAP(c *check, serverAddr string) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout) defer cancel() configCmds := []string{ "identity_ldap", fmt.Sprintf("server_addr=%s", serverAddr),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 100.2K bytes - Viewed (1) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
callB.cancel() return MockResponse(body = (nextResponse++).toString()) } } callA.enqueue(callback) callB.enqueue(callback) assertThat(server.takeRequest().url.encodedPath).isEqualTo("/a") callback.await(requestA.url).assertBody("A") // At this point we know the callback is ready, and that it will receive a cancel failure. callback
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
all would change to dull reality--the grass would be only rustling in the wind, and the pool rippling to the waving of the reeds--the rattling teacups would change to tinkling sheep- bells, and the Queen's shrill cries to the voice of the shepherd boy--and the sneeze of the baby, the shriek of the Gryphon, and all thy other queer noises, would change (she knew) to the
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 145.2K bytes - Viewed (0)