Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 67 for Availability (0.16 seconds)

  1. src/main/java/jcifs/util/SmbCircuitBreaker.java

            if (total == 0) {
                return 100.0;
            }
            return (totalSuccesses.get() * 100.0) / total;
        }
    
        /**
         * Calculate availability
         *
         * @return availability as percentage (0-100)
         */
        private double calculateAvailability() {
            long total = totalRequests.get();
            if (total == 0) {
                return 100.0;
            }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  2. internal/config/storageclass/storage-class.go

    //
    // Default is "availability" optimized, unless this is configured.
    func (sCfg *Config) CapacityOptimized() bool {
    	ConfigLock.RLock()
    	defer ConfigLock.RUnlock()
    	if !sCfg.initialized {
    		return false
    	}
    	return sCfg.Optimize == "capacity"
    }
    
    // AvailabilityOptimized - returns true if the storage-class is availability
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  3. internal/bucket/bandwidth/reader.go

    			tokens = b
    		}
    	} else { // all tokens go towards payload
    		need = int(math.Min(float64(b), float64(need)))
    		tokens = need
    	}
    	// reduce tokens requested according to availability
    	av := int(r.throttle.Tokens())
    	if av < tokens && av > 0 {
    		tokens = av
    		need = int(math.Min(float64(tokens), float64(need)))
    	}
    	err = r.throttle.WaitN(r.ctx, tokens)
    	if err != nil {
    		return n, err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  4. internal/http/check_port_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"fmt"
    	"net"
    	"runtime"
    	"strconv"
    	"testing"
    )
    
    // Tests for port availability logic written for server startup sequence.
    func TestCheckPortAvailability(t *testing.T) {
    	if runtime.GOOS != "linux" {
    		t.Skip()
    	}
    
    	l, err := net.Listen("tcp", "localhost:0") // ask kernel for a free port.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  5. internal/http/check_port_linux.go

    	lc := &net.ListenConfig{
    		Control: func(network, address string, c syscall.RawConn) error {
    			c.Control(func(fdPtr uintptr) {
    				if opts.Interface != "" {
    					// When interface is specified look for specifically port availability on
    					// the specified interface if any.
    					_ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    				}
    			})
    			return nil
    		},
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/container/CrawlerContainer.java

    import org.codelibs.core.lang.StringUtil;
    
    /**
     * The CrawlerContainer interface provides methods for managing components
     * within a crawler container. It includes methods to retrieve components,
     * check availability, and destroy the container. Additionally, it provides
     * a default method to initialize the container with specific protocol handlers.
     *
     */
    public interface CrawlerContainer {
    
        /**
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Mar 15 06:52:00 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/service/GroupService.java

                return g;
            });
        }
    
        /**
         * Stores a group by inserting or updating it in both LDAP and the database.
         * Uses refresh policy to ensure immediate availability of the stored data.
         *
         * @param group the group entity to store
         */
        public void store(final Group group) {
            ComponentUtil.getLdapManager().insert(group);
    
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/pager/WebConfigPager.java

         * Search criteria: interval time.
         */
        public String intervalTime;
    
        /**
         * Search criteria: boost value.
         */
        public String boost;
    
        /**
         * Search criteria: availability status.
         */
        public String available;
    
        /**
         * Search criteria: sort order.
         */
        public String sortOrder;
    
        /**
         * Search criteria: creator user.
         */
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponse.java

        /**
         * Share capability indicating DFS support.
         */
        public static final int SMB2_SHARE_CAP_DFS = 0x8;
    
        /**
         * Share capability indicating continuous availability support.
         */
        public static final int SMB2_SHARE_CAP_CONTINUOUS_AVAILABILITY = 0x10;
    
        /**
         * Share capability indicating scale-out support.
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  10. Dockerfile.release

    ENV MINIO_ACCESS_KEY_FILE=access_key \
        MINIO_SECRET_KEY_FILE=secret_key \
        MINIO_ROOT_USER_FILE=access_key \
        MINIO_ROOT_PASSWORD_FILE=secret_key \
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 3K bytes
    - Click Count (0)
Back to Top