Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 341 for synchronized (0.13 sec)

  1. 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)
  2. 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)
  3. 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 needed
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/cache/CacheReferencesTest.java

      static class Key {
        private final int value;
        private WeakReference<String> toString;
    
        Key(int value) {
          this.value = value;
        }
    
        @Override
        public synchronized String toString() {
          String s;
          if (toString != null) {
            s = toString.get();
            if (s != null) {
              return s;
            }
          }
          s = Integer.toString(value);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top