Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 115 for connect0 (1.22 sec)

  1. src/main/java/jcifs/smb1/smb1/SmbFile.java

        boolean hasNextAddress() {
            return addressIndex < addresses.length;
        }
    
        void connect0() throws SmbException {
            try {
                connect();
            } catch (final SmbException se) {
                throw se;
            } catch (final IOException ioe) {
                throw new SmbException("Failed to connect to server", ioe);
            }
        }
    
        void doConnect() throws IOException {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/smb1/SmbFileTest.java

                SmbFile share = new SmbFile("smb1://server/share/");
                // To test this properly, we would need to mock connect0() and the tree object.
                // This is a limitation of unit testing such a coupled class.
                // We expect an SmbException because it will try to connect.
                assertThrows(SmbException.class, () -> share.getType());
            }
    
            @Test
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

            if (file.type != SmbFile.TYPE_NAMED_PIPE) {
                file.open(openFlags, access, SmbFile.ATTR_NORMAL, 0);
                this.openFlags &= ~(SmbFile.O_CREAT | SmbFile.O_TRUNC);
            } else {
                file.connect0();
            }
            readSize = Math.min(file.tree.session.transport.rcv_buf_size - 70, file.tree.session.transport.server.maxBufferSize - 70);
        }
    
        /**
         * Converts an SmbException to an IOException.
         *
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  4. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/gcs/HandlerTest.java

            try {
                conn.connect();
                fail("Should throw IOException when project ID is not set");
            } catch (IOException e) {
                assertTrue(e.getMessage().contains("GCS_PROJECT_ID is blank"));
            }
        }
    
        /**
         * Test thread-safety of connect() method.
         * Multiple threads should be able to call connect() concurrently without issues.
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb1/smb1/SmbTreeTest.java

        void testTreeConnectAndDisconnect() throws Exception {
            SmbTree tree = new SmbTree(session, "testShare", "testService");
    
            // Mock transport.connect() to succeed
            doNothing().when(transport).connect();
    
            // Setup response for tree connect
            doAnswer(invocation -> {
                ServerMessageBlock request = invocation.getArgument(0);
                ServerMessageBlock response = invocation.getArgument(1);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java

             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
                if (connected) {
                    return;
                }
                final String projectId = System.getenv("GCS_PROJECT_ID");
                final String endpoint = System.getenv("GCS_ENDPOINT");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java

             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
                if (connected) {
                    return;
                }
                final String endpoint = System.getenv().get("S3_ENDPOINT");
                final String accessKey = System.getenv().get("S3_ACCESS_KEY");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 07:57:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java

             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
                if (connected) {
                    return;
                }
                final String endpoint = System.getenv().get("STORAGE_ENDPOINT");
                final String accessKey = System.getenv().get("STORAGE_ACCESS_KEY");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:52:56 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/TreeConnectResponse.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal;
    
    /**
     * Interface for SMB Tree Connect response messages.
     * Handles the server's response to a tree connect request, providing tree ID,
     * service type, and DFS information for the connected share.
     *
     * @author mbechler
     */
    public interface TreeConnectResponse extends CommonServerMessageBlockResponse {
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  10. 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: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 12.1K bytes
    - Viewed (0)
Back to top