Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 39 of 39 for IsConnected (0.04 sec)

  1. src/main/java/jcifs/internal/witness/WitnessRpcClient.java

            return sb.toString();
        }
    
        /**
         * Checks if the client is connected to the witness service.
         *
         * @return true if connected
         */
        public boolean isConnected() {
            return connected && rpcHandle != null;
        }
    
        @Override
        public void close() {
            if (connected && rpcHandle != null) {
                try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  2. 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")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  3. 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
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbSessionImpl.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.Object#finalize()
         */
        @Override
        protected void finalize() throws Throwable {
            try {
                if (isConnected() && this.usageCount.get() != 0) {
                    log.warn("Session was not properly released, performing emergency cleanup: " + this);
                    // Perform emergency cleanup to prevent memory leaks
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbFile.java

        @Override
        public void connect() throws IOException {
            if (isConnected() && tree.session.transport.tconHostName == null) {
                /* Tree thinks it is connected but transport disconnected
                 * under it, reset tree to reflect the truth.
                 */
                tree.treeDisconnect(true);
            }
    
            if (isConnected()) {
                return;
            }
    
            getUncPath0();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/TreeRangeMapTest.java

              RangeMap<Integer, Integer> expected = TreeRangeMap.create();
              for (Entry<Range<Integer>, Integer> entry : rangeMap.asMapOfRanges().entrySet()) {
                if (entry.getKey().isConnected(subRange)) {
                  expected.put(entry.getKey().intersection(subRange), entry.getValue());
                }
              }
              RangeMap<Integer, Integer> subRangeMap = rangeMap.subRangeMap(subRange);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 30K bytes
    - Viewed (0)
  7. 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
        }
    }
    ```
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 42K bytes
    - Viewed (0)
  8. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbFile.java

         *
         */
        synchronized SmbTreeHandleImpl ensureTreeConnected() throws CIFSException {
            // Optimization: Check connection validity more efficiently
            if (this.treeHandle != null && this.treeHandle.isConnected()) {
                // Connection is still valid - reuse it
                return this.treeHandle.acquire();
            }
    
            // Clean up old handle if needed
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
Back to top