Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1111 - 1120 of 1,713 for Take (0.02 sec)

  1. guava/src/com/google/common/eventbus/Subscriber.java

                bus.handleSubscriberException(e.getCause(), context(event));
              }
            });
      }
    
      /**
       * Invokes the subscriber method. This method can be overridden to make the invocation
       * synchronized.
       */
      @VisibleForTesting
      void invokeSubscriberMethod(Object event) throws InvocationTargetException {
        try {
          method.invoke(target, checkNotNull(event));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 06 00:47:57 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  2. cmd/background-heal-ops.go

    		} else {
    			workers = numHealers
    		}
    	}
    
    	if workers == 0 {
    		workers = 4
    	}
    
    	return &healRoutine{
    		tasks:   make(chan healTask),
    		workers: workers,
    	}
    }
    
    // healDiskFormat - heals format.json, return value indicates if a
    // failure error occurred.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cni/pkg/log/uds_test.go

    )
    
    func TestUDSLog(t *testing.T) {
    	// Start UDS log server
    	udsSockDir := t.TempDir()
    	udsSock := filepath.Join(udsSockDir, "cni.sock")
    	logger := NewUDSLogger(istiolog.DebugLevel)
    	stop := make(chan struct{})
    	defer close(stop)
    	assert.NoError(t, logger.StartUDSLogServer(udsSock, stop))
    
    	// Configure log to tee to UDS server
    	stdout := os.Stdout
    	r, w, _ := os.Pipe()
    	os.Stdout = w
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. schema/relationship.go

    	}
    
    	if constraint.OnUpdate != "" {
    		sql += " ON UPDATE " + constraint.OnUpdate
    	}
    
    	foreignKeys := make([]interface{}, 0, len(constraint.ForeignKeys))
    	for _, field := range constraint.ForeignKeys {
    		foreignKeys = append(foreignKeys, clause.Column{Name: field.DBName})
    	}
    
    	references := make([]interface{}, 0, len(constraint.References))
    	for _, field := range constraint.References {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  5. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java

            Iterator<TransferResourceAndSize> entries = transfers.values().iterator();
            while (entries.hasNext()) {
                TransferResourceAndSize entry = entries.next();
                // just in case, make sure 0 <= complete <= total
                long complete = Math.max(0, entry.transferredBytes);
                long total = Math.max(complete, entry.resource.getContentLength());
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/dependencies/dependencies-in-path-operation-decorators.md

    /// tip
    
    Some editors check for unused function parameters, and show them as errors.
    
    Using these `dependencies` in the *path operation decorator* you can make sure they are executed while avoiding editor/tooling errors.
    
    It might also help avoid confusion for new developers that see an unused parameter in your code and could think it's unnecessary.
    
    ///
    
    /// info
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. internal/config/subnet/config.go

    	cfg.Proxy = proxy
    
    	if transport == nil {
    		// when transport is nil, it means we are just validating the
    		// inputs not performing any network calls.
    		return cfg, nil
    	}
    
    	// Make sure to clone the transport before editing the ProxyURL
    	if proxyURL != nil {
    		ctransport := transport.(*http.Transport).Clone()
    		ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL))
    		cfg.transport = ctransport
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  9. cmd/xl-storage_test.go

    	volume := "success-vol"
    	// Setup test environment.
    	if err = xlStorage.MakeVol(context.Background(), volume); err != nil {
    		t.Fatalf("Unable to create volume, %s", err)
    	}
    
    	// Create directory to make errIsNotRegular
    	if err = os.Mkdir(slashpath.Join(path, "success-vol", "object-as-dir"), 0o777); err != nil {
    		t.Fatalf("Unable to create directory, %s", err)
    	}
    
    	testCases := []struct {
    		volume      string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  10. buildscripts/minio-iam-ldap-upgrade-import-test.sh

    #!/bin/bash
    
    # This script is used to test the migration of IAM content from old minio
    # instance to new minio instance.
    #
    # To run it locally, start the LDAP server in github.com/minio/minio-iam-testing
    # repo (e.g. make podman-run), and then run this script.
    #
    # This script assumes that LDAP server is at:
    #
    #   `localhost:1389`
    #
    # if this is not the case, set the environment variable
    # `_MINIO_LDAP_TEST_SERVER`.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 18 18:19:01 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top