Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PendingStatus (0.08 sec)

  1. src/test/java/jcifs/smb/NtStatusTest.java

        @DisplayName("Should handle pending status")
        void testPendingStatus() {
            // Given
            int pendingStatus = NtStatus.NT_STATUS_PENDING;
    
            // When/Then
            assertEquals((int) 0x00000103L, pendingStatus);
            // Pending status is informational (not error)
            assertTrue((pendingStatus & (int) 0xC0000000L) != (int) 0xC0000000L);
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    	if d.targetsMap == nil {
    		d.targetsMap = make(map[string]replicateTargetDecision)
    	}
    	d.targetsMap[t.Arn] = t
    }
    
    // PendingStatus returns a stringified representation of internal replication status with all targets marked as `PENDING`
    func (d ReplicateDecision) PendingStatus() string {
    	b := new(bytes.Buffer)
    	for _, k := range d.targetsMap {
    		if k.Replicate {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	}
    	switch o.VersionID {
    	case "":
    		o.DeleteReplication.ReplicationStatusInternal = dsc.PendingStatus()
    		o.DeleteReplication.Targets = replicationStatusesMap(o.DeleteReplication.ReplicationStatusInternal)
    	default:
    		o.DeleteReplication.VersionPurgeStatusInternal = dsc.PendingStatus()
    		o.DeleteReplication.PurgeTargets = versionPurgeStatusesMap(o.DeleteReplication.VersionPurgeStatusInternal)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    	}
    	if dsc := mustReplicate(ctx, dstBucket, dstObject, srcInfo.getMustReplicateOptions(op, dstOpts)); dsc.ReplicateAny() {
    		srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    		srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    	}
    	// Store the preserved compression metadata.
    	maps.Copy(srcInfo.UserDefined, compressMetadata)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    			if dsc.ReplicateAny() {
    				if object.VersionID != "" {
    					object.VersionPurgeStatus = replication.VersionPurgePending
    					object.VersionPurgeStatuses = dsc.PendingStatus()
    				} else {
    					object.DeleteMarkerReplicationStatus = dsc.PendingStatus()
    				}
    				object.ReplicateDecisionStr = dsc.String()
    			}
    		}
    		if object.VersionID != "" && hasLockEnabled {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  6. cmd/object-multipart-handlers.go

    		metadata[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    		metadata[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    	}
    
    	// We need to preserve the encryption headers set in EncryptRequest,
    	// so we do not want to override them, copy them instead.
    	maps.Copy(metadata, encMetadata)
    
    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