Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 597 for serving (0.08 sec)

  1. src/main/java/jcifs/smb1/netbios/NbtSocket.java

    import java.net.InetAddress;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.IOException;
    
    /**
    Do not use this class. Writing to the OutputStream of this type of socket
    requires leaving a 4 byte prefix for the NBT header. IOW you must call
    write( buf, 4, len ). Calling write( buf, 0, len ) will generate an error.
     */
    
    public class NbtSocket extends Socket {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 4.8K bytes
    - Viewed (0)
  2. internal/config/identity/tls/config.go

    	if dur < minExpiry || dur > maxExpiry {
    		return 0, auth.ErrInvalidDuration
    	}
    	return dur, nil
    }
    
    // Lookup returns a new Config by merging the given K/V config
    // system with environment variables.
    func Lookup(kvs config.KVS) (Config, error) {
    	if err := config.CheckValidKeys(config.IdentityTLSSubSys, kvs, DefaultKVS); err != nil {
    		return Config{}, err
    	}
    	cfg := Config{}
    	var err error
    	v := env.Get(EnvIdentityTLSEnabled, "")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  3. src/main/assemblies/files/fess.in.sh

    #!/bin/sh
    
    FESS_CLASSPATH=$FESS_HOME/lib/classes
    
    # JAVA_OPTS is not a built-in JVM mechanism but some people think it is so we
    # warn them that we are not observing the value of $JAVA_OPTS
    if [ ! -z "$JAVA_OPTS" ]; then
      echo -n "warning: ignoring JAVA_OPTS=$JAVA_OPTS; "
      echo "pass JVM parameters via FESS_JAVA_OPTS"
    fi
    
    if [ "x$FESS_MIN_MEM" = "x" ]; then
        FESS_MIN_MEM=256m
    fi
    if [ "x$FESS_MAX_MEM" = "x" ]; then
        FESS_MAX_MEM=2g
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. common-protos/k8s.io/api/admissionregistration/v1/generated.proto

      // Required
      optional string name = 2;
    
      // `path` is an optional URL path which will be sent in any request to
      // this service.
      // +optional
      optional string path = 3;
    
      // If specified, the port on the service that hosting webhook.
      // Default to 443 for backward compatibility.
      // `port` should be a valid port number (1-65535, inclusive).
      // +optional
      optional int32 port = 4;
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  5. docs/bucket/lifecycle/DESIGN.md

    lifecycle transition rules and becomes eligible for tiering. MinIO scanner (which runs at one minute intervals, each time scanning one sixteenth of the namespace), picks up the object for tiering. The data is moved to the remote tier in entirety, leaving only the object metadata on MinIO.
    
    The data on the backend is stored under the `bucket/prefix` specified in the tier configuration with a custom name derived from a randomly generated uuid - e.g. `0b/c4/0bc4fab7-2daf-4d2f-8e39-5c6c6fb7e2d3`....
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbWatchHandleImpl.java

                    resp = new NtTransNotifyChangeResponse(th.getConfig());
                }
    
                if ( log.isTraceEnabled() ) {
                    log.trace("Sending NtTransNotifyChange for " + this.handle);
                }
                try {
                    resp = th.send(req, resp, RequestParam.NO_TIMEOUT, RequestParam.NO_RETRY);
                }
                catch ( SmbException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.5K bytes
    - Viewed (0)
  7. doc/go_mem.html

    observing the write to <code>done</code>
    implies observing the write to <code>a</code>, so this program could
    print an empty string too.
    Worse, there is no guarantee that the write to <code>done</code> will ever
    be observed by <code>main</code>, since there are no synchronization
    events between the two threads.  The loop in <code>main</code> is not
    guaranteed to finish.
    </p>
    
    <p>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

         * @param host an IP address or hostname.
         * @param port the IP port associated with the service.
         * @param maxAge time in seconds that this alternative is considered fresh.
         */
        fun alternateService(
          streamId: Int,
          origin: String,
          protocol: ByteString,
          host: String,
          port: Int,
          maxAge: Long,
        )
      }
    
      companion object {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        assertEquals(1, service.startUpCalled);
        assertEquals(Service.State.FAILED, service.state());
        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
      public void testStop_withoutStart() {
        TestService service = new TestService();
        service.stopAsync().awaitTerminated();
        assertEquals(0, service.startUpCalled);
        assertEquals(0, service.shutDownCalled);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      public ServiceManager startAsync() {
        for (Service service : services) {
          checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this);
        }
        for (Service service : services) {
          try {
            state.tryStartTiming(service);
            service.startAsync();
          } catch (IllegalStateException e) {
            // This can happen if the service has already been started or stopped (e.g. by another
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
Back to top