Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 79 for availability (0.07 seconds)

  1. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

        /** The HTTP client used for API communication. */
        protected CloseableHttpClient httpClient;
    
        /** Cached availability status of the LLM provider. */
        protected volatile Boolean cachedAvailability = null;
    
        /** The scheduled task for periodic availability checks. */
        protected TimeoutTask availabilityCheckTask;
    
        /** Semaphore for limiting concurrent LLM requests. Initialized lazily in init(). */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 72K bytes
    - Click Count (0)
  3. 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: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  4. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  5. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/util/ports/DefaultPortDetector.java

    import java.net.ServerSocket;
    
    public class DefaultPortDetector implements PortDetector {
        /**
         * Checks to see if a specific port is available.
         *
         * @param port the port to check for availability
         * @return true if the port is available, false otherwise
         */
        public boolean isAvailable(int port) {
            try {
                ServerSocket ss = new ServerSocket(port);
                try {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 1.3K bytes
    - Click Count (0)
  6. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  7. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  8. docs/distributed/README.md

    If one or more drives are offline at the start of a PutObject or NewMultipartUpload operation the object will have additional data protection bits added automatically to provide additional safety for these objects.
    
    ### High availability
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  9. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/docker/DockerSupportService.java

                availability.path,
                availability.version == null ? "" : " v" + availability.version,
                tasks.size() > 1 ? "s" : "",
                String.join("\n", tasks),
                availability.lastCommand.exitCode,
                availability.lastCommand.stderr.trim()
            );
            throwDockerRequiredException(message);
        }
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 14.8K bytes
    - Click Count (0)
  10. 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: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.7K bytes
    - Click Count (0)
Back to Top