Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 125 for decision (0.04 sec)

  1. cmd/bucket-replication-utils_test.go

    }{
    	{ // 1.
    		name: "empty string",
    		dsc:  "",
    		expDsc: ReplicateDecision{
    			targetsMap: map[string]replicateTargetDecision{},
    		},
    		expErr: nil,
    	},
    
    	{ // 2.
    		name:   "replicate decision for one target",
    		dsc:    "arn:minio:replication::id:bucket=true;false;arn:minio:replication::id:bucket;id",
    		expErr: nil,
    		expDsc: ReplicateDecision{
    			targetsMap: map[string]replicateTargetDecision{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    		}
    	}
    	return b.String()
    }
    
    // ResyncDecision is a struct representing a map with target's individual resync decisions
    type ResyncDecision struct {
    	targets map[string]ResyncTargetDecision
    }
    
    // Empty returns true if no targets with resync decision present
    func (r ResyncDecision) Empty() bool {
    	return r.targets == nil
    }
    
    func (r ResyncDecision) mustResync() bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     * object). So it is important to not call {@link #dispatch} while holding any locks. This is why
     * {@link #enqueue} and {@link #dispatch} are 2 different methods. It is expected that the decision
     * to run a particular event is made during the state change, but the decision to actually invoke
     * the listeners can be delayed slightly so that locks can be dropped. Also, because {@link
     * #dispatch} is expected to be called concurrently, it is idempotent.
     */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  4. cmd/api-datatypes.go

    	// VersionPurgeStatuses holds the internal
    	VersionPurgeStatuses string `xml:"VersionPurgeStatuses"`
    	// ReplicateDecisionStr stringified representation of replication decision
    	ReplicateDecisionStr string `xml:"-"`
    }
    
    // createBucketLocationConfiguration container for bucket configuration request from client.
    // Used for parsing the location from the request body for Makebucket.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 3K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/SmbFilenameFilterTest.java

            verifyNoInteractions(mockDir);
        }
    
        /**
         * Interaction with dependency: implementation can use directory's methods to make decisions.
         * Tests a filter that uses directory path information.
         */
        @Test
        @DisplayName("filter can use SmbFile directory for decision logic")
        void filterCanUseSmbFileForDecision() throws Exception {
            // Stub the getPath method to return a specific value
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/Kerb5AuthenticatorTest.java

            assertTrue(ex.getMessage().contains("Server does not support NTLM authentication"));
    
            // Verify the decision consulted the configuration
            // getConfig() is called twice: once in Kerb5Authenticator and once in NtlmPasswordAuthenticator
            verify(tc, times(2)).getConfig();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

              }
    
              // We have a task to execute when we complete the loop.
              else -> {
                readyTask = candidate
              }
            }
          }
    
          // Implement the decision.
          when {
            // We have a task ready to go. Get ready.
            readyTask != null -> {
              beforeRun(readyTask)
    
              // Also start another thread if there's more work or scheduling to do.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/ComparisonChain.java

       * href="https://docs.oracle.com/javase/tutorial/collections/interfaces/order.html">mutually
       * comparable</a>. If you pass objects that are not mutually comparable, this method may throw an
       * exception. (The reason for this decision is lost to time, but the reason <i>might</i> be that
       * we wanted to support legacy classes that implement the raw type {@code Comparable} (instead of
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

     * and the last 7 bits from this byte.
     *
     * The end of the range is not encoded, but can be inferred by looking at the start of the range
     * that follows.
     *
     * b1
     * --
     *
     * This is either a mapping decision or the length of the mapped output, according to this table:
     *
     * ```
     *  0..63 : Length of the UTF-16 sequence that this range maps to. The offset is b2b3.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. cmd/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	_, isEncrypted := crypto.IsEncrypted(mi.UserDefined)
    
    	// Read compression metadata preserved in the init multipart for the decision.
    	_, isCompressed := mi.UserDefined[ReservedMetadataPrefix+"compression"]
    	// Compress only if the compression is enabled during initial multipart.
    	var idxCb func() []byte
    	if isCompressed {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
Back to top