- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 597 for serving (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)