Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 303 for isSynchronized (0.07 seconds)

  1. src/main/java/jcifs/smb/BufferCacheImpl.java

            this.bufferSize = maxSize;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.BufferCache#getBuffer()
         */
        @Override
        public byte[] getBuffer() {
            synchronized (this.cache) {
                byte[] buf;
    
                if (this.freeBuffers > 0) {
                    for (int i = 0; i < this.cache.length; i++) {
                        if (this.cache[i] != null) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  2. 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) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 20.7K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/testing/TestLogHandler.java

      @Override
      public void publish(@Nullable LogRecord record) {
        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
        }
      }
    
      @Override
      public void flush() {}
    
      @Override
      public void close() {}
    
      public void clear() {
        synchronized (lock) {
          list.clear();
        }
      }
    
      /** Returns a snapshot of the logged records. */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.8K bytes
    - Click Count (0)
  4. doc/go_mem.html

    </p>
    
    <p>
    The <i>synchronized before</i> relation is a partial order on synchronizing memory operations,
    derived from <i>W</i>.
    If a synchronizing read-like memory operation <i>r</i>
    observes a synchronizing write-like memory operation <i>w</i>
    (that is, if <i>W</i>(<i>r</i>) = <i>w</i>),
    then <i>w</i> is synchronized before <i>r</i>.
    Informally, the synchronized before relation is a subset of the implied total order
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  5. src/test/java/jcifs/BufferCacheTest.java

                this.cache = new ArrayList<>(maxBuffers);
            }
    
            @Override
            public synchronized byte[] getBuffer() {
                if (!cache.isEmpty()) {
                    return cache.remove(0);
                }
                return new byte[bufferSize];
            }
    
            @Override
            public synchronized void releaseBuffer(byte[] buf) {
                if (buf != null && cache.size() < maxBuffers) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbPipeInputStream.java

         *
         * @return the tree handle implementation
         * @throws CIFSException if a connection error occurs
         */
        protected synchronized SmbTreeHandleImpl ensureTreeConnected() throws CIFSException {
            return this.handle.ensureTreeConnected();
        }
    
        @Override
        protected synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
            return this.handle.ensureOpen();
        }
    
        /**
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

          synchronized (state) {
            if (state.seenExceptionsField == expect) {
              state.seenExceptionsField = update;
            }
          }
        }
    
        @Override
        int decrementAndGetRemainingCount(AggregateFutureState<?> state) {
          synchronized (state) {
            return --state.remainingField;
          }
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  8. 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;
                }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 29.7K bytes
    - Click Count (0)
  9. 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.
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Nov 22 13:28:22 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  10. 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
            }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 4.8K bytes
    - Click Count (0)
Back to Top