- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 365 for timeouts (0.14 sec)
-
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
} finally { lockStateChanged(this); } } @Override public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException { aboutToAcquire(this); try { return super.tryLock(timeout, unit); } finally { lockStateChanged(this); } } @Override public void unlock() { try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
docs/orchestration/docker-compose/docker-compose.yaml
expose: - "9000" - "9001" # environment: # MINIO_ROOT_USER: minioadmin # MINIO_ROOT_PASSWORD: minioadmin 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: Wed Oct 30 21:24:58 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
(this as Object).notifyAll() } /** * Returns the recorded response triggered by `request`. Throws if the response isn't * enqueued before the timeout. */ @Synchronized fun await(url: HttpUrl): RecordedResponse { val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS while (true) { val i = responses.iterator()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NetServerEnum2.java
name = "\\PIPE\\LANMAN"; maxParameterCount = 8; maxDataCount = 16384; maxSetupCount = (byte)0x00; setupCount = 0; timeout = 5000; } void reset( int key, String lastName ) { super.reset(); this.lastName = lastName; } int writeSetupWireFormat( byte[] dst, int dstIndex ) { return 0;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 3.5K bytes - Viewed (0) -
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/grid/grid.go
} return fmt.Sprint(b) } // ConnDialer is a function that dials a connection to the given address. // There should be no retries in this function, // and should have a timeout of something like 2 seconds. // The returned net.Conn should also have quick disconnect on errors. // The net.Conn must support all features as described by the net.Conn interface.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
import okio.BufferedSink import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource @Timeout(30) @Tag("Slow") class CancelTest { @JvmField @RegisterExtension val platform = PlatformRule()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* @throws NullPointerException {@inheritDoc} */ @CanIgnoreReturnValue @Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { if (e == null) throw new NullPointerException(); final Monitor monitor = this.monitor; if (monitor.enterWhen(notFull, timeout, unit)) { try { insert(e); return true; } finally { monitor.leave(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
docs/bigdata/README.md
fs.s3a.committer.staging.conflict-mode=append fs.s3a.committer.staging.tmp.path=/tmp/staging fs.s3a.committer.staging.unique-filenames=true fs.s3a.connection.establish.timeout=5000 fs.s3a.connection.ssl.enabled=false fs.s3a.connection.timeout=200000 fs.s3a.endpoint=http://minio:9000 fs.s3a.impl=org.apache.hadoop.fs.s3a.S3AFileSystem fs.s3a.committer.threads=2048 # Number of threads writing to MinIO
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0)