- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 1,328 for Time (0.02 sec)
-
src/main/java/org/codelibs/fess/opensearch/user/bsentity/BsRole.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.opensearch.user.bsentity; import java.time.LocalDateTime; import java.util.HashMap; import java.util.Map; import org.codelibs.fess.opensearch.user.allcommon.EsAbstractEntity; import org.codelibs.fess.opensearch.user.bsentity.dbmeta.RoleDbm; /**
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 3.9K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/SlackClient.java
public synchronized void awaitAccessToken(Timeout timeout) throws InterruptedIOException { while (session == null) { timeout.waitUntilNotified(this); } } /** Starts a real time messaging session. */ public void startRtm() throws IOException { String accessToken; synchronized (this) { accessToken = session.access_token; }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jan 12 03:31:36 UTC 2019 - 3.4K bytes - Viewed (0) -
okhttp/api/jvm/okhttp.api
public final fun callTimeout (Ljava/time/Duration;)Lokhttp3/OkHttpClient$Builder; public final fun callTimeout-LRDsOJo (J)Lokhttp3/OkHttpClient$Builder; public final fun certificatePinner (Lokhttp3/CertificatePinner;)Lokhttp3/OkHttpClient$Builder; public final fun connectTimeout (JLjava/util/concurrent/TimeUnit;)Lokhttp3/OkHttpClient$Builder; public final fun connectTimeout (Ljava/time/Duration;)Lokhttp3/OkHttpClient$Builder;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 69.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
) : EventListener() { val eventSequence: Deque<CallEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableListOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */ private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 9.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaStatistics.java
} return totalReceiveTime.get() / (double) receives / 1000.0; // Convert to microseconds } /** * Calculate total throughput in MB/s based on total time * * @param totalTimeSeconds total elapsed time in seconds * @return throughput in MB/s */ public double getThroughputMBps(double totalTimeSeconds) { if (totalTimeSeconds <= 0.0) { return 0.0;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 10.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/com/SmbComNegotiateResponseTest.java
buffer[bufferIndex++] = (byte) 0x80; buffer[bufferIndex++] = 0; buffer[bufferIndex++] = 0; buffer[bufferIndex++] = 0; // serverTime long time = new Date().getTime(); SMBUtil.writeTime(time, buffer, bufferIndex); bufferIndex += 8; // serverTimeZone buffer[bufferIndex++] = (byte) 0x80; buffer[bufferIndex++] = (byte) 0xFF; // encryptionKeyLength
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EmptyImmutableListMultimap.java
super(ImmutableMap.<Object, ImmutableList<Object>>of(), 0); } /* * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most * of common.collect a second time with the results of the first compilation on the classpath. Or * just back this out once we stop doing that (which we'll do after our internal GWT setup * changes). */ @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Aug 06 14:59:07 UTC 2025 - 1.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
cancel() mu.Unlock() return } }(resultIndex, erObj) } } updateCloser := make(chan chan struct{}) go func() { updateTicker := time.NewTicker(30 * time.Second) defer updateTicker.Stop() var lastUpdate time.Time // We need to merge since we will get the same buckets from each pool. // Therefore to get the exact bucket sizes we must merge before we can convert.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/bsentity/BsUserInfo.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.opensearch.log.bsentity; import java.time.LocalDateTime; import java.util.HashMap; import java.util.Map; import org.codelibs.fess.opensearch.log.allcommon.EsAbstractEntity; import org.codelibs.fess.opensearch.log.bsentity.dbmeta.UserInfoDbm; /**
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 4.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheControlTest.kt
*/ package okhttp3 import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isFalse import assertk.assertions.isTrue import kotlin.test.Test import kotlin.time.Duration.Companion.seconds class CacheControlTest { @Test @Throws(Exception::class) fun emptyBuilderIsEmpty() { val cacheControl = CacheControl.Builder().build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2.7K bytes - Viewed (0)