Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 170 for PENDING (0.14 sec)

  1. docs/smb3-features/03-multi-channel-design.md

        
        private void redistributePendingOperations(ChannelInfo failedChannel) {
            // Get pending operations from failed channel
            List<SMBMessage> 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: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java

                }
            }
            return target;
        }
    
        /**
         * Commits any remaining documents in the cache to the index.
         * This method ensures all pending documents are processed.
         */
        @Override
        public void commit() {
            synchronized (docList) {
                if (!docList.isEmpty()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  3. cmd/site-replication-metrics.go

    			srs.Latency.update(st.TransferSize, st.TransferDuration)
    			srs.updateXferRate(st.TransferSize, st.TransferDuration)
    		}
    	case st.Failed:
    		srs.Failed.addsize(st.TransferSize, st.Err)
    	case st.Pending:
    	}
    	sr.M[dID] = srs
    }
    
    func (sr *SRStats) get() map[string]SRMetric {
    	epMap := globalBucketTargetSys.healthStats()
    
    	sr.lock.RLock()
    	defer sr.lock.RUnlock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/ShareEnumIteratorTest.java

            if (useFilter) {
                verify(filter, times(1)).accept(any());
            }
        }
    
        @Test
        @DisplayName("close() clears pending element and hasNext() becomes false")
        void closeClearsNext() throws Exception {
            SmbFile parent = newParent();
            List<FileEntry> entries = Collections.singletonList(entry("one", SmbConstants.TYPE_SHARE));
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  5. cmd/xl-storage-format_test.go

    	fi := FileInfo{
    		Volume:           "volume",
    		Name:             "object-name",
    		VersionID:        "756100c6-b393-4981-928a-d49bbc164741",
    		IsLatest:         true,
    		Deleted:          false,
    		TransitionStatus: "PENDING",
    		DataDir:          "bffea160-ca7f-465f-98bc-9b4f1c3ba1ef",
    		XLV1:             false,
    		ModTime:          time.Now(),
    		Size:             1234456,
    		Mode:             0,
    		Metadata: map[string]string{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  6. docs/bigdata/README.md

    fs.s3a.secret.key=minio123
    fs.s3a.path.style.access=true
    fs.s3a.block.size=512M
    fs.s3a.buffer.dir=${hadoop.tmp.dir}/s3a
    fs.s3a.committer.magic.enabled=false
    fs.s3a.committer.name=directory
    fs.s3a.committer.staging.abort.pending.uploads=true
    fs.s3a.committer.staging.conflict-mode=append
    fs.s3a.committer.staging.tmp.path=/tmp/staging
    fs.s3a.committer.staging.unique-filenames=true
    fs.s3a.connection.establish.timeout=5000
    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/lease/DirectoryCacheEntry.java

         * @return the last access time
         */
        public long getLastAccessTime() {
            return lastAccessTime;
        }
    
        /**
         * Checks if the cache has pending changes
         * @return true if cache has changes
         */
        public boolean hasChanges() {
            return hasChanges;
        }
    
        /**
         * Get and increment inconsistency count
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/util/transport/Transport.java

         * 2 - run connected
         * 3 - connected
         * 4 - error
         */
        int state = 0;
    
        String name = "Transport" + id++;
        Thread thread;
        TransportException te;
    
        /**
         * Map of pending requests to their corresponding responses.
         */
        protected HashMap response_map = new HashMap(4);
    
        /**
         * Creates a key for the specified request for response matching.
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb1/trans2/Trans2QueryPathInformationResponseTest.java

            }
    
            // Mock number of links (4 bytes)
            buffer[16] = 0x01;
            buffer[17] = 0x00;
            buffer[18] = 0x00;
            buffer[19] = 0x00;
    
            // Mock delete pending and directory flags
            buffer[20] = 0x00;
            buffer[21] = 0x00;
    
            return buffer;
        }
    
        private byte[] createMockFileInternalInfoBuffer() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java

                    throw new DictionaryException("Failed to write: " + line, e);
                }
            }
    
            /**
             * Commits the changes to the dictionary file.
             * If there is a pending new item, it is written to the file.
             *
             * @return The committed item, or null if no item was committed.
             * @throws DictionaryException if an I/O error occurs.
             */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 12.6K bytes
    - Viewed (0)
Back to top