- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 303 for isSynchronized (0.07 seconds)
-
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 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 29 23:40:28 GMT 2021 - 1.8K bytes - Click Count (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...Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 6.7K bytes - Click Count (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 neededCreated: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 5.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/CacheReferencesTest.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 5.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Sets.java
* @return a synchronized view of the specified navigable set. * @since 13.0 */ @GwtIncompatible // NavigableSet @J2ktIncompatible // Synchronized public static <E extends @Nullable Object> NavigableSet<E> synchronizedNavigableSet( NavigableSet<E> navigableSet) { return Synchronized.navigableSet(navigableSet); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 81.6K bytes - Click Count (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; }Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Dec 11 08:38:29 GMT 2025 - 9.6K bytes - Click Count (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; }Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Dec 11 07:57:44 GMT 2025 - 9.5K bytes - Click Count (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();Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 14.2K bytes - Click Count (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")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 17.5K bytes - Click Count (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();
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 15.3K bytes - Click Count (0)