Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 88 for isConnected (0.05 seconds)

  1. android/guava/src/com/google/common/collect/ImmutableRangeMap.java

          for (int i = 0; i < entries.size(); i++) {
            Range<K> range = entries.get(i).getKey();
            if (i > 0) {
              Range<K> prevRange = entries.get(i - 1).getKey();
              if (range.isConnected(prevRange) && !range.intersection(prevRange).isEmpty()) {
                throw new IllegalArgumentException(
                    "Overlapping ranges: range " + prevRange + " overlaps with entry " + range);
              }
            }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb/DirFileEntryEnumIterator2.java

        protected void doCloseInternal() throws CIFSException {
            try {
                @SuppressWarnings("resource")
                final SmbTreeHandleImpl th = getTreeHandle();
                if (this.fileId != null && th.isConnected()) {
                    th.send(new Smb2CloseRequest(th.getConfig(), this.fileId));
                }
            } finally {
                this.fileId = null;
            }
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/RegularContiguousSet.java

      RegularContiguousSet(Range<C> range, DiscreteDomain<C> domain) {
        super(domain);
        this.range = range;
      }
    
      private ContiguousSet<C> intersectionInCurrentDomain(Range<C> other) {
        return range.isConnected(other)
            ? ContiguousSet.create(range.intersection(other), domain)
            : new EmptyContiguousSet<C>(domain);
      }
    
      @Override
      ContiguousSet<C> headSetImpl(C toElement, boolean inclusive) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/RegularContiguousSet.java

      RegularContiguousSet(Range<C> range, DiscreteDomain<C> domain) {
        super(domain);
        this.range = range;
      }
    
      private ContiguousSet<C> intersectionInCurrentDomain(Range<C> other) {
        return range.isConnected(other)
            ? ContiguousSet.create(range.intersection(other), domain)
            : new EmptyContiguousSet<C>(domain);
      }
    
      @Override
      ContiguousSet<C> headSetImpl(C toElement, boolean inclusive) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbFileHandleImpl.java

         * {@inheritDoc}
         *
         * @see jcifs.SmbFileHandle#isValid()
         */
        @Override
        public boolean isValid() {
            return this.open && this.tree_num == this.tree.getTreeId() && this.tree.isConnected();
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbFileHandle#close(long)
         */
        @Override
        public synchronized void close(final long lastWriteTime) throws CIFSException {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 9.4K bytes
    - Click Count (1)
  6. src/test/java/jcifs/smb/SmbFileInputStreamTest.java

            when(mockTree.getReceiveBufferSize()).thenReturn(0x10000);
            when(mockTree.getMaximumBufferSize()).thenReturn(0x10000);
            when(mockTree.getConfig()).thenReturn(mockConfig);
            when(mockTree.isConnected()).thenReturn(true);
            when(mockTree.getTreeId()).thenReturn(1L);
    
            when(mockFile.getType()).thenReturn(SmbConstants.TYPE_FILESYSTEM);
        }
    
        @Nested
        @DisplayName("Happy path")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/DirFileEntryEnumIterator2Test.java

        @Mock
        private CIFSContext cifsContext;
    
        @BeforeEach
        void setup() {
            // Tree handle lifecycle and config
            lenient().when(tree.acquire()).thenReturn(tree);
            lenient().when(tree.isConnected()).thenReturn(true);
    
            // CIFS context returns same config to build responses during initResponse
            lenient().when(cifsContext.getConfig()).thenReturn(config);
        }
    
        @AfterEach
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 13.7K bytes
    - Click Count (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

                    ftpClient.disconnect();
                } catch (final IOException e) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Failed to disconnect FTP client: connected={}", ftpClient.isConnected(), e);
                    }
                }
            }
            if (logger.isDebugEnabled()) {
                logger.debug("FTP client closed");
            }
        }
    
        /*
         * (non-Javadoc)
         *
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 40K bytes
    - Click Count (0)
  9. docs/bucket/notifications/README.md

      go func() {
       for {
        // Reconnect if the connection is lost.
        if stanConnection == nil || stanConnection.NatsConn() == nil ||  !stanConnection.NatsConn().IsConnected() {
         stanConnection, _ = stan.Connect("test-cluster", "test-client", stan.NatsURL("nats://yourusername:yoursecret@0.0.0.0:4222"), stan.SetConnectionLostHandler(func(c stan.Conn, _ error) {
          if c.NatsConn() != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  10. docs/smb3-features/06-witness-protocol-design.md

                }
            }, 30, TimeUnit.SECONDS);
        }
        
        private boolean testWitnessService() {
            // Simple connectivity test
            return client != null && client.isConnected();
        }
        
        private void reregisterNotifications() {
            // Re-register all previous registrations
            // Implementation would store registration details for recovery
        }
    }
    ```
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 42K bytes
    - Click Count (0)
Back to Top