- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 88 for isConnected (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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); } @AfterEachCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 13.7K bytes - Click Count (0) -
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) -
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) -
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)