Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 61 for shifting (0.69 sec)

  1. cmd/object-api-interface.go

    type BucketOptions struct {
    	Deleted    bool // true only when site replication is enabled
    	Cached     bool // true only when we are requesting a cached response instead of hitting the disk for example ListBuckets() call.
    	NoMetadata bool
    }
    
    // SetReplicaStatus sets replica status and timestamp for delete operations in ObjectOptions
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/MultiChannelManager.java

                        totalRequests, totalChannelsCreated);
            }
        }
    
        /**
         * Cleanup and shutdown the multi-channel manager.
         */
        public void shutdown() {
            log.info("Shutting down MultiChannelManager");
    
            // Close all channels
            for (String sessionId : new ArrayList<>(sessionChannels.keySet())) {
                removeChannels(sessionId);
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

            if (ref == null || ref.get() == null) {
                fileCache.remove(path);
            }
        }
    
        /**
         * Shutdown the lease manager
         */
        public void shutdown() {
            log.info("Shutting down lease manager");
    
            // Stop cleanup executor
            if (cleanupExecutor != null) {
                cleanupExecutor.shutdown();
                try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  4. src/test/java/jcifs/dcerpc/rpcTest.java

                // When: Trying to encode (may throw exception due to deferred buffer)
                // Then: Should at least call the basic encoding methods before hitting deferred
                assertThrows(Exception.class, () -> {
                    unicodeString.encode(mockNdrBuffer);
                }, "Should encounter issue with deferred buffer access");
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  5. docs/smb3-features/05-rdma-smb-direct-design.md

        
        @Override
        public void shutdown() {
            if (endpointGroup != null) {
                try {
                    endpointGroup.close();
                } catch (Exception e) {
                    log.error("Error shutting down DiSNI", e);
                }
            }
            initialized = false;
        }
    }
    
    class DisniRdmaConnection extends RdmaConnection {
        private final RdmaActiveEndpoint endpoint;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

            }
            if (ComponentUtil.hasIngestFactory()) {
                ingestFactory = ComponentUtil.getIngestFactory();
            }
        }
    
        /**
         * Destroys the IndexUpdater when the container is shutting down.
         * Stops all crawler instances if crawling is still in progress.
         */
        @PreDestroy
        public void destroy() {
            if (!finishCrawling) {
                if (logger.isInfoEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 32.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                }
            }
            return true;
        }
    
        @Override
        public void commit() {
            try {
                if (logger.isDebugEnabled()) {
                    logger.debug("Shutting down thread executor.");
                }
                executor.shutdown();
                executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *   }
     * }
     * }
     *
     * <p>This class uses the ServiceManager's methods to start all of its services, to respond to
     * service failure and to ensure that when the JVM is shutting down all the services are stopped.
     *
     * @author Luke Sandberg
     * @since 14.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class ServiceManager implements ServiceManagerBridge {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  9. cmd/object-api-utils_test.go

    	testCases := []struct {
    		objectName string
    		shouldPass bool
    	}{
    		// cases which should pass the test.
    		// passing in valid object name.
    		{"object", true},
    		{"The Shining Script <v1>.pdf", true},
    		{"Cost Benefit Analysis (2009-2010).pptx", true},
    		{"117Gn8rfHL2ACARPAhaFd0AGzic9pUbIA/5OCn5A", true},
    		{"SHØRT", true},
    		{"f*le", true},
    		{"contains-^-caret", true},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     *     return Scheduler.newFixedRateSchedule(0, 1, TimeUnit.SECONDS);
     *   }
     * }
     * }
     *
     * <p>This class uses the life cycle methods to read in a list of starting URIs and save the set of
     * outstanding URIs when shutting down. Also, it takes advantage of the scheduling functionality to
     * rate limit the number of queries we perform.
     *
     * @author Luke Sandberg
     * @since 11.0
     */
    @GwtIncompatible
    @J2ktIncompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
Back to top