Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for getCount (0.13 sec)

  1. src/test/java/jcifs/internal/smb2/io/Smb2WriteResponseTest.java

                assertEquals(1024, response.getCount());
                assertEquals(512, response.getRemaining());
    
                // Second read - should update values
                byte[] buffer2 = createValidWriteResponse(2048, 1024);
                response.readBytesWireFormat(buffer2, 0);
                assertEquals(2048, response.getCount());
                assertEquals(1024, response.getRemaining());
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbFileOutputStream.java

                        wr.setOffset(this.fp);
                        wr.setData(b, off, w);
    
                        final Smb2WriteResponse resp = th.send(wr, RequestParam.NO_RETRY);
                        final long cnt = resp.getCount();
                        this.fp += cnt;
                        len -= cnt;
                        off += cnt;
                    } else if (this.useNTSmbs) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/cache/CacheEvictionTest.java

        assertThat(removalListener.getCount()).isEqualTo(1);
    
        // 2 will be cached
        assertThat(cache.getUnchecked(2)).isEqualTo(2);
        assertThat(cache.asMap().keySet()).containsExactly(2);
    
        CacheTesting.processPendingNotifications(cache);
        CacheTesting.checkValidState(cache);
        assertThat(removalListener.getCount()).isEqualTo(1);
    
        // 4 will be cached
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 15K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/ImmutableMultiset.java

        public boolean contains(@Nullable Object o) {
          if (o instanceof Entry) {
            Entry<?> entry = (Entry<?>) o;
            if (entry.getCount() <= 0) {
              return false;
            }
            int count = count(entry.getElement());
            return count == entry.getCount();
          }
          return false;
        }
    
        @Override
        public int hashCode() {
          return ImmutableMultiset.this.hashCode();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  5. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                crawler1.awaitTermination();
                crawler2.awaitTermination();
    
                assertEquals(maxCount, dataService.getCount(sessionId1));
                assertEquals(maxCount, dataService.getCount(sessionId2));
    
                UrlQueue urlQueue;
                while ((urlQueue = urlQueueService.poll(sessionId1)) != null) {
                    assertTrue(urlQueue.getUrl().startsWith(url1));
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        assertEquals("Eviction notifications must be received", 10, removalListener.getCount());
    
        CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
        // ensure that no new notifications are sent
        assertEquals("Eviction notifications must be received", 10, removalListener.getCount());
      }
    
      public void testExpiringGet_expireAfterWrite() {
        FakeTicker ticker = new FakeTicker();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                crawler1.awaitTermination();
                crawler2.awaitTermination();
    
                assertEquals(maxCount, dataService.getCount(sessionId1));
                assertEquals(maxCount, dataService.getCount(sessionId2));
    
                UrlQueue urlQueue;
                while ((urlQueue = urlQueueService.poll(sessionId1)) != null) {
                    assertTrue(urlQueue.getUrl().startsWith(url1));
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/google/MultisetNavigationTester.java

      // Needed to stop Eclipse whining
      private void resetWithHole() {
        List<E> container = new ArrayList<>();
        container.addAll(nCopies(a.getCount(), a.getElement()));
        container.addAll(nCopies(c.getCount(), c.getElement()));
        super.resetContainer(getSubjectGenerator().create(container.toArray()));
        sortedMultiset = (SortedMultiset<E>) getMultiset();
      }
    
      @CollectionSize.Require(ZERO)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 20:14:36 UTC 2024
    - 26K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          for (int j = 0; j < numListeners; j++) {
            list.add(listener, directExecutor());
            returnValue += listenerLatch.getCount();
          }
          list.execute();
          returnValue += listenerLatch.getCount();
        }
        return returnValue;
      }
    
      @Benchmark
      int executeThenAdd_singleThreaded(int reps) {
        int returnValue = 0;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbFileOutputStreamTest.java

            when(mockTreeHandle.send(any(Smb2WriteRequest.class), any())).thenReturn(mockWriteResponse);
            when(mockWriteResponse.getCount()).thenReturn(1);
    
            outputStream = new SmbFileOutputStream(mockFile, mockTreeHandle, mockFileHandle,
                    SmbConstants.O_CREAT | SmbConstants.O_WRONLY | SmbConstants.O_TRUNC, SmbConstants.FILE_WRITE_DATA,
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
Back to top