Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 212 for Ensure (0.99 sec)

  1. src/test/java/jcifs/internal/fscc/FsctlPipeWaitRequestTest.java

            int[] offsets = { 0, 1, 10, 50, 100 };
    
            for (int offset : offsets) {
                byte[] buffer = new byte[200];
                // Fill buffer with pattern to ensure proper writing
                for (int i = 0; i < buffer.length; i++) {
                    buffer[i] = (byte) 0xFF;
                }
    
                int bytesEncoded = request.encode(buffer, offset);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java

         *
         * @return true if the stream is open, false otherwise
         */
        public boolean isOpen() {
            return file.isOpen();
        }
    
        void ensureOpen() throws IOException {
            // ensure file is open
            if (!file.isOpen()) {
                file.open(openFlags, access | SmbConstants.FILE_WRITE_DATA, SmbFile.ATTR_NORMAL, 0);
                if (append) {
                    fp = file.length();
                }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb1/net/SmbShareInfoTest.java

            // Verify that SmbShareInfo properly implements FileEntry interface
            SmbShareInfo info = new SmbShareInfo(TEST_NET_NAME, TEST_TYPE, TEST_REMARK);
    
            // Cast to FileEntry to ensure interface is properly implemented
            jcifs.smb.FileEntry fileEntry = info;
    
            // Verify all FileEntry methods work
            assertEquals(TEST_NET_NAME, fileEntry.getName());
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java

            }
    
            /**
             * Establishes a connection to the storage service.
             * This method creates a MinIO client using environment variables for configuration.
             * This method is synchronized to ensure thread-safe connection initialization.
             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:52:56 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/create/CreateContextRequestTest.java

            }
    
            @Test
            @DisplayName("Should align to 8-byte boundary")
            void testPaddingAlignment() {
                // Test various name lengths to ensure proper padding
                for (int nameLen = 1; nameLen <= 32; nameLen++) {
                    byte[] name = new byte[nameLen];
                    Arrays.fill(name, (byte) 'A');
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbFileInputStream.java

            if (len <= 0) {
                return 0;
            }
            final long start = this.fp;
    
            if (this.tmp == null) {
                throw new IOException("Bad file descriptor");
            }
            // ensure file is open
            try (SmbFileHandleImpl fd = ensureOpen(); SmbTreeHandleImpl th = fd.getTree()) {
    
                if (log.isTraceEnabled()) {
                    log.trace("read: fid=" + fd + ",off=" + off + ",len=" + len);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                /* Yes, there is the potential to drop packets
                 * because we might close the socket during a
                 * request. However the chances are slim and the
                 * retry code should ensure the overall request
                 * is serviced. The alternative complicates things
                 * more than I think is worth it.
                 */
    
                if (socket != null) {
                    socket.close();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

            if (len <= 0) {
                return 0;
            }
            final long start = fp;
    
            if (tmp == null) {
                throw new IOException("Bad file descriptor");
            }
            // ensure file is open
            file.open(openFlags, access, SmbFile.ATTR_NORMAL, 0);
    
            /*
             * Read AndX Request / Response
             */
    
            if (LogStream.level >= 4) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

        }
    
        /**
         * Starts a new process with the given session ID, command list, buffer size, and output callback.
         * This method is synchronized to ensure thread safety when managing processes.
         *
         * @param sessionId unique identifier for the process session
         * @param cmdList list of command and arguments to execute
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 06:54:47 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  10. src/main/java/jcifs/util/SimpleCircuitBreaker.java

                    }
                }
            }
        }
    
        /**
         * Get current state
         *
         * @return current state
         */
        public State getState() {
            evaluateState(); // Ensure state is current
            return state.get();
        }
    
        /**
         * Reset the circuit breaker
         */
        public void reset() {
            state.set(State.CLOSED);
            consecutiveFailures.set(0);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 11.3K bytes
    - Viewed (0)
Back to top