- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 341 for synchronized (0.13 sec)
-
internal/disk/fdatasync_linux.go
// (st_size, as made by say ftruncate(2)), would require a metadata flush. // // The aim of fdatasync() is to reduce disk activity for applications that // do not require all metadata to be synchronized with the disk. func Fdatasync(f *os.File) error { return syscall.Fdatasync(int(f.Fd())) } // FadviseDontNeed invalidates page-cache func FadviseDontNeed(f *os.File) error {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Sep 29 23:40:28 UTC 2021 - 1.8K bytes - Viewed (0) -
impl/maven-core/src/test/remote-repo/org/apache/maven/plugins/maven-surefire-plugin/0.1/maven-surefire-plugin-0.1.jar
nothing. test false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session org.apache.maven maven-plugin-api jar 2.0 org/apache/maven/plugin/coreit/ItMojo.class package org.apache.maven.plugin.coreit; public synchronized class ItMojo extends org.apache.maven.plugin.AbstractMojo { public void ItMojo(); public void execute(); } pom.xml 4.0.0 org.apache.maven.plugins maven-surefire-plugin 0.1 maven-plugin Maven Integration Test Plugin A test plugin to assist testing...Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java
// Initialize with 0 to mark uninitialized state final AtomicLong lastTime = lastTimes.get(host, () -> new AtomicLong(0)); synchronized (lastTime) { final long lastValue = lastTime.get(); if (lastValue == 0) { // First access to this host - no delay neededRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 5.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheReferencesTest.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 5.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java
* This method creates a GCS Storage client using environment variables for configuration. * This method is synchronized to ensure thread-safe connection initialization. * * @throws IOException If the connection cannot be established */ @Override public synchronized void connect() throws IOException { if (connected) { return; }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 9.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java
* This method creates an AWS S3 client using environment variables for configuration. * This method is synchronized to ensure thread-safe connection initialization. * * @throws IOException If the connection cannot be established */ @Override public synchronized void connect() throws IOException { if (connected) { return; }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 07:57:44 UTC 2025 - 9.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Dfs.java
* @param path the path to resolve * @param auth the authentication credentials * @return a DFS referral for the resolved path * @throws SmbAuthException if authentication fails */ public synchronized DfsReferral resolve(String domain, String root, final String path, final NtlmPasswordAuthentication auth) throws SmbAuthException { DfsReferral dr = null; final long now = System.currentTimeMillis();Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 14.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
writeUtf8("\r\n") write(source, byteCount) writeUtf8("\r\n") } } @Synchronized override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. socket.sink.flush() } @Synchronized override fun close() { if (closed) return closed = true socket.sink.writeUtf8("0\r\n\r\n")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 17.5K bytes - Viewed (7) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
boolean contains = pool.contains(null); // Should handle gracefully successCount.incrementAndGet(); } catch (Exception e) { synchronized (exceptions) { exceptions.add(e); } } } long threadEnd = System.nanoTime();
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java
* This method creates a MinIO client using environment variables for configuration. * This method is synchronized to ensure thread-safe connection initialization. * * @throws IOException If the connection cannot be established */ @Override public synchronized void connect() throws IOException { if (connected) { return; }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:52:56 UTC 2025 - 11.1K bytes - Viewed (0)