Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 187 for Pending (0.05 sec)

  1. src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java

        }
    
        /**
         * Get number of pending operations
         *
         * @return number of pending operations
         */
        public long getRequestsPending() {
            return pendingOperations.size();
        }
    
        /**
         * Get pending operations list
         *
         * @return list of pending operations
         */
        public List<CommonServerMessageBlock> getPendingOperations() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  2. cmd/bucket-stats.go

    	// in Queue stats for bucket - from qCache
    	QStat InQueueMetric `json:"queued"`
    	// Deprecated fields
    	// Pending size in bytes
    	PendingSize int64 `json:"pendingReplicationSize"`
    	// Failed size in bytes
    	FailedSize int64 `json:"failedReplicationSize"`
    	// Total number of pending operations including metadata updates
    	PendingCount int64 `json:"pendingReplicationCount"`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java

         * Last fragment flag - indicates last fragment of a multi-fragment message
         */
        int DCERPC_LAST_FRAG = 0x02; /* Last fragment */
        /**
         * Pending cancel flag - indicates cancel was pending at sender
         */
        int DCERPC_PENDING_CANCEL = 0x04; /* Cancel was pending at sender */
        /**
         * Reserved flag for future use
         */
        int DCERPC_RESERVED_1 = 0x08;
        /**
         * Supports concurrent multiplexing flag
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  4. src/main/java/jcifs/dcerpc/DcerpcConstants.java

         * Last fragment flag - indicates last fragment of a multi-fragment message
         */
        int DCERPC_LAST_FRAG = 0x02; /* Last fragment */
        /**
         * Pending cancel flag - indicates cancel was pending at sender
         */
        int DCERPC_PENDING_CANCEL = 0x04; /* Cancel was pending at sender */
        /**
         * Reserved flag for future use
         */
        int DCERPC_RESERVED_1 = 0x08;
        /**
         * Supports concurrent multiplexing flag.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils.go

    }
    
    // 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 {
    			fmt.Fprintf(b, "%s=%s;", k.Arn, replication.Pending.String())
    		}
    	}
    	return b.String()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  6. docs/bucket/replication/DESIGN.md

    ### Replication of object version and metadata
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

        private void redistributePendingOperations(ChannelInfo failedChannel) {
            // Get pending operations from failed channel
            List<CommonServerMessageBlock> pendingOps = failedChannel.getPendingOperations();
    
            if (pendingOps.isEmpty()) {
                return;
            }
    
            log.info("Redistributing {} pending operations from failed channel", pendingOps.size());
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

            ChannelInfo leastLoadedChannel = null;
            long minPending = Long.MAX_VALUE;
            for (ChannelInfo channel : channels) {
                long pending = channel.getRequestsPending();
                if (pending < minPending) {
                    minPending = pending;
                    leastLoadedChannel = channel;
                }
            }
            return leastLoadedChannel != null ? leastLoadedChannel : channels.iterator().next();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

        }
    
        @Test
        void testLeastLoadedStrategy() {
            loadBalancer.setStrategy(LoadBalancingStrategy.LEAST_LOADED);
    
            // Add pending operations to channel1 to make it more loaded
            channel1.addPendingOperation(mockMessage);
    
            when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom_test.go

    		},
    		{
    			meta:           nmeta2,
    			pools:          pools,
    			name:           "Correct-Decom-Pending",
    			expectedErr:    false,
    			expectedUpdate: false,
    		},
    		{
    			meta:           nmeta2,
    			pools:          reducedPools,
    			name:           "Invalid-Decom-Pending-Pool-Removal",
    			expectedErr:    false,
    			expectedUpdate: true,
    		},
    		{
    			meta:           nmeta1,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.8K bytes
    - Viewed (0)
Back to top