- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 377 for timeouts (0.07 sec)
-
src/main/java/jcifs/internal/smb1/trans/TransCallNamedPipe.java
super(config, SMB_COM_TRANSACTION, TRANS_CALL_NAMED_PIPE); this.name = pipeName; this.pipeData = data; this.pipeDataOff = off; this.pipeDataLen = len; this.timeout = 0xFFFFFFFF; this.maxParameterCount = 0; this.maxDataCount = 0xFFFF; this.maxSetupCount = (byte) 0x00; this.setupCount = 2; } @Override
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 3.1K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
package deadlineconn import ( "net" "time" ) const updateInterval = 250 * time.Millisecond // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. readSetAt time.Time writeDeadline time.Duration // sets the write deadline on a connection.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 17:40:11 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/kms/kes.go
} } list := make([]madmin.KMSAPI, 0, len(APIs)) for _, api := range APIs { list = append(list, madmin.KMSAPI{ Method: api.Method, Path: api.Path, MaxBody: api.MaxBody, Timeout: int64(api.Timeout.Truncate(time.Second).Seconds()), }) } return list, nil } // Stat returns the current KES status containing a // list of KES endpoints and the default key ID.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
return applyTransformation(input.get()); } @Override public O get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return applyTransformation(input.get(timeout, unit)); } private O applyTransformation(I input) throws ExecutionException { try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/net/NetShareEnum.java
this.name = new String("\\PIPE\\LANMAN"); this.maxParameterCount = 8; // maxDataCount = 4096; why was this set? this.maxSetupCount = (byte) 0x00; this.setupCount = 0; this.timeout = 5000; } @Override protected int writeSetupWireFormat ( byte[] dst, int dstIndex ) { return 0; } @Override
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransPeekNamedPipe.java
private int fid; TransPeekNamedPipe( String pipeName, int fid ) { name = pipeName; this.fid = fid; command = SMB_COM_TRANSACTION; subCommand = TRANS_PEEK_NAMED_PIPE; timeout = 0xFFFFFFFF; maxParameterCount = 6; maxDataCount = 1; maxSetupCount = (byte)0x00; setupCount = 2; } int writeSetupWireFormat( byte[] dst, int dstIndex ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2.1K bytes - Viewed (0) -
.github/workflows/mint/minio-pools.yaml
MINIO_ROOT_PASSWORD: "minio123" MINIO_KMS_SECRET_KEY: "my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw=" healthcheck: test: ["CMD", "mc", "ready", "local"] interval: 5s timeout: 5s retries: 5 # starts 4 docker containers running minio server instances. # using nginx reverse proxy, load balancing, you can access # it through port 9000. services: minio1: <<: *minio-common
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Nov 03 21:18:18 UTC 2023 - 2.3K bytes - Viewed (0) -
internal/http/dial_dnscache.go
if lookupHost == nil { lookupHost = net.DefaultResolver.LookupHost } if baseDialCtx == nil { // This is same as which `http.DefaultTransport` uses. baseDialCtx = (&net.Dialer{ Timeout: 30 * time.Second, KeepAlive: 30 * time.Second, }).DialContext } return func(ctx context.Context, network, addr string) (conn net.Conn, err error) { host, port, err := net.SplitHostPort(addr)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 03 19:30:51 UTC 2023 - 2.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
resultFuture = buildChainingFuture(inputFuture); listener = new MockFutureListener(resultFuture); } public void testFutureGetBeforeCallback() throws Exception { // Verify that get throws a timeout exception before the callback is called. assertThrows(TimeoutException.class, () -> resultFuture.get(1L, MILLISECONDS)); } public void testFutureGetThrowsWrappedException() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NetShareEnum.java
name = new String( "\\PIPE\\LANMAN" ); maxParameterCount = 8; // maxDataCount = 4096; why was this set? maxSetupCount = (byte)0x00; setupCount = 0; timeout = 5000; } int writeSetupWireFormat( byte[] dst, int dstIndex ) { return 0; } int writeParametersWireFormat( byte[] dst, int dstIndex ) { int start = dstIndex; byte[] descr;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2.5K bytes - Viewed (0)