Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 589 for umount (0.33 sec)

  1. src/test/java/jcifs/netbios/NodeStatusRequestTest.java

            src[0] = 0x00;
            src[1] = 0x01; // Transaction ID
            src[2] = 0x00; // Flags
            src[3] = 0x00; // Flags
            src[4] = 0x00;
            src[5] = 0x01; // Question count
    
            // Act
            int result = nodeStatusRequest.readWireFormat(src, 0);
    
            // Assert
            assertTrue(result >= NameServicePacket.HEADER_LENGTH);
        }
    
        @Test
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/suggest/util/SuggestUtilTest.java

            long count = client.prepareSearch(TEST_INDEX)
                    .setQuery(QueryBuilders.termQuery("field", "value1"))
                    .execute()
                    .actionGet()
                    .getHits()
                    .getTotalHits()
                    .value();
            assertEquals(0, count);
        }
    
        @Test
        public void testDeleteByQueryWithNoMatches() {
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

         * the web socket! It's possible that we're writing faster than the peer can read.
         */
        private const val MAX_QUEUE_SIZE = 16L * 1024 * 1024 // 16 MiB.
    
        /**
         * The maximum amount of time after the client calls [close] to wait for a graceful shutdown. If
         * the server doesn't respond the web socket will be canceled.
         */
        const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000
    
        /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbPipeInputStreamTest.java

            when(handle.getPipe()).thenReturn(pipe);
            when(tree.isSMB2()).thenReturn(smb2);
            return new SmbPipeInputStream(handle, tree);
        }
    
        @Test
        @DisplayName("available() on SMB2 returns peeked byte count and interacts with tree")
        void available_smb2_happyPath() throws Exception {
            // Verify SMB2 path: IOCTL peek result is returned and resources are closed
            SmbPipeInputStream stream = newStreamWithMinimalStubs(true);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

        try {
          val result = block(header)
    
          // The object processed bytes beyond its range.
          if (newLimit != -1L && byteCount > newLimit) {
            throw ProtocolException("unexpected byte count at $this")
          }
    
          return result
        } finally {
          peekedHeader = null
          limit = pushedLimit
          constructed = pushedConstructed
          if (name != null) path.removeAt(path.size - 1)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

         */
        @Override
        public void update(final List<OpenSearchAccessResult> accessResultList) {
            insertAll(accessResultList, OpType.INDEX);
        }
    
        /**
         * Gets the count of access results for a specific session.
         *
         * @param sessionId The session ID.
         * @return The number of access results for the session.
         */
        @Override
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/RobotsTxt.java

             *
             * @param pattern the path pattern
             * @return the priority length
             */
            private static int calculatePriorityLength(final String pattern) {
                // For priority, we count the pattern length, treating * as having length 0
                // and $ as having length 1
                int length = 0;
                for (int i = 0; i < pattern.length(); i++) {
                    final char c = pattern.charAt(i);
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 18.5K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/suggest/entity/SuggestItemTest.java

            assertTrue(dest.contains("new1"));
            assertTrue(dest.contains("new2"));
            // Should not have duplicate "existing"
            assertEquals(1, dest.stream().filter(s -> s.equals("existing")).count());
        }
    
        @Test
        public void testConcatKinds() {
            // Test static concatKinds method
            SuggestItem.Kind[] kinds1 = { SuggestItem.Kind.QUERY };
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java

            // CrawlerContext crawlerContext = (CrawlerContext) objs[0];
        }
    
        /**
         * Processes no URL in queue log events.
         *
         * @param objs the log objects (should contain UrlQueue and thread check count)
         */
        protected void processNoUrlInQueue(final Object... objs) {
            // CrawlerContext crawlerContext = (CrawlerContext) objs[0];
            final UrlQueue<?> urlQueue = (UrlQueue<?>) objs[1];
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 02:01:26 UTC 2025
    - 14K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

            this.workingDirectory = workingDirectory;
        }
    
        /**
         * Sets the maximum number of output lines to capture.
         * @param maxOutputLine The maximum output line count.
         */
        public void setMaxOutputLine(final int maxOutputLine) {
            this.maxOutputLine = maxOutputLine;
        }
    
        /**
         * Sets the command execution timeout.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 14.4K bytes
    - Viewed (0)
Back to top