Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for channel (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top