Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 249 for isSynchronized (0.08 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

         * This method delegates to {@link FileInputStream#mark(int)}.
         *
         * @param readlimit the maximum limit of bytes that can be read before the mark position becomes invalid
         */
        @Override
        public synchronized void mark(final int readlimit) {
            fileInputStream.mark(readlimit);
        }
    
        /**
         * Tests if this input stream supports the mark and reset methods.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  2. compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java

            }
        }
    
        public void markForDeletion(File toDelete) {
            filesToDelete.add(toDelete);
            warnAboutCleanup = true;
        }
    
        public synchronized File createTempDir() {
            try {
                Thread.sleep(20);
            } catch (InterruptedException e) {
                // ignore
            }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/SmbCircuitBreaker.java

                }
            }
    
            public synchronized void recordSuccess(long responseTimeMs) {
                getCurrentBucket().recordSuccess(responseTimeMs);
            }
    
            public synchronized void recordFailure() {
                getCurrentBucket().recordFailure();
            }
    
            public synchronized WindowMetrics getMetrics() {
                long now = System.currentTimeMillis();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          synchronized (future) {
            if (future.waitersField == expect) {
              future.waitersField = update;
              return true;
            }
            return false;
          }
        }
    
        @Override
        boolean casListeners(
            AbstractFutureState<?> future, @Nullable Listener expect, Listener update) {
          synchronized (future) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // Lock while we check state. We must maintain the lock while adding the new pair so that
        // another thread can't run the list out from under us. We only add to the list if we have not
        // yet started execution.
        synchronized (this) {
          if (!executed) {
            runnables = new RunnableExecutorPair(runnable, executor, runnables);
            return;
          }
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          synchronized (future) {
            if (future.waitersField == expect) {
              future.waitersField = update;
              return true;
            }
            return false;
          }
        }
    
        @Override
        boolean casListeners(
            AbstractFutureState<?> future, @Nullable Listener expect, Listener update) {
          synchronized (future) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbSession.java

        }
    
        synchronized SmbTransport transport() {
            if (transport == null) {
                transport = SmbTransport.getSmbTransport(address, port, localAddr, localPort, null);
            }
            return transport;
        }
    
        void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException {
            synchronized (transport()) {
                if (response != null) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/netbios/Lmhosts.java

         *
         * @param host the hostname to resolve
         * @return the resolved NbtAddress or null if not found
         */
    
        public synchronized static NbtAddress getByName(final String host) {
            return getByName(new Name(host, 0x20, null));
        }
    
        synchronized static NbtAddress getByName(final Name name) {
            NbtAddress result = null;
    
            try {
                if (FILENAME != null) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/netbios/NbtAddress.java

                }
            }
            obj = getCachedAddress(name);
            if (obj == null) {
                synchronized (LOOKUP_TABLE) {
                    LOOKUP_TABLE.put(name, name);
                }
            }
    
            return obj;
        }
    
        private static void updateLookupTable(final Name name) {
            synchronized (LOOKUP_TABLE) {
                LOOKUP_TABLE.remove(name);
                LOOKUP_TABLE.notifyAll();
            }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/DfsImpl.java

         *
         * @see jcifs.DfsResolver#isTrustedDomain(jcifs.CIFSContext, java.lang.String)
         */
        @Override
        public boolean isTrustedDomain(final CIFSContext tf, String domain) throws SmbAuthException {
            synchronized (this.domainsLock) {
                final Map<String, Map<String, CacheEntry<DfsReferralDataInternal>>> domains = getTrustedDomains(tf);
                if (domains == null) {
                    return false;
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 29.7K bytes
    - Viewed (0)
Back to top