Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 647 for timeIt (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/AutobahnTester.kt

              response: Response?,
            ) {
              t.printStackTrace(System.out)
              latch.countDown()
            }
          },
        )
    
        check(latch.await(30, TimeUnit.SECONDS)) { "Timed out waiting for test $number to finish." }
        val endNanos = System.nanoTime()
        val tookMs = TimeUnit.NANOSECONDS.toMillis(endNanos - startNanos.get())
        println("Took ${tookMs}ms")
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java

         *
         * @param error the error to check
         * @return true if error might be recoverable, false otherwise
         */
        private boolean isRecoverableError(Exception error) {
            // Timeout errors are often recoverable
            if (error instanceof SocketTimeoutException) {
                return true;
            }
    
            // Some socket errors might be recoverable
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  3. src/test/java/jcifs/dcerpc/msrpc/lsarpcTest.java

            verify(mockDeferredNdrBuffer, times(9)).enc_ndr_long(anyInt()); // 3 enc_ndr_long for each of 3 unicode strings
            verify(mockDeferredNdrBuffer, times(3)).enc_ndr_long(0);
            verify(mockDeferredNdrBuffer, times(3)).advance(anyInt());
            verify(mockDeferredNdrBuffer, times(4)).derive(anyInt()); // 3 for strings + 1 for guid
            verify(mockDeferredNdrBuffer, times(18)).enc_ndr_short(0); // 5+6+7 shorts with value 0
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 60.8K bytes
    - Click Count (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

      }
    
      private fun logWithTime(message: String) {
        val startNs = startNs
        val timeMs =
          if (startNs == null) {
            // Event occurred before start, for an example an early cancel.
            0L
          } else {
            TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs)
          }
    
        logger.invoke("[$timeMs ms] $message")
      }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb/SmbTransportInternalTest.java

            assertTrue(transport.isSMB2());
            assertFalse(transport.isSMB2());
            verify(transport, times(2)).isSMB2();
    
            doThrow(new SmbException("query failed")).when(transport).isSMB2();
            assertThrows(SmbException.class, () -> transport.isSMB2());
            verify(transport, times(3)).isSMB2();
        }
    
        // Inflight requests count including edge values
        @ParameterizedTest
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb1/smb1/AllocInfoTest.java

            assertEquals(400L, mockAllocInfo.getFree(), "free space should match stubbed value");
            verify(mockAllocInfo, times(1)).getCapacity();
            verify(mockAllocInfo, times(1)).getFree();
        }
    
        /**
         * Parameterised test of capacity values, including edge cases such as
         * zero and negative capacities.
         */
        @ParameterizedTest
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb1/smb1/TransWaitNamedPipeTest.java

            // SubCommand should be TRANS_WAIT_NAMED_PIPE (0x53)
            assertEquals(SmbComTransaction.TRANS_WAIT_NAMED_PIPE, pipe.subCommand);
    
            // Timeout is set to 0xFFFFFFFF (-1 when cast to int)
            assertEquals(0xFFFFFFFF, pipe.timeout);
    
            // Max parameter and data counts should be 0
            assertEquals(0, pipe.maxParameterCount);
            assertEquals(0, pipe.maxDataCount);
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

    import okhttp3.internal.http2.ErrorCode
    import okhttp3.testing.Flaky
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junitpioneer.jupiter.RetryingTest
    import org.opentest4j.TestAbortedException
    
    /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java

            }
        }
    
        @Override
        public ByteBuffer receive(int timeout) throws IOException {
            if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {
                throw new IOException("Connection not established");
            }
    
            try {
                socket.setSoTimeout(timeout);
    
                // First, read the header to determine message size
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  10. tests/test_tutorial/test_custom_request_and_route/test_tutorial003.py

        assert response.json() == {"message": "Not timed"}
        assert "X-Response-Time" not in response.headers
    
    
    def test_get_timed(client: TestClient):
        response = client.get("/timed")
        assert response.json() == {"message": "It's the time of my life"}
        assert "X-Response-Time" in response.headers
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 894 bytes
    - Click Count (0)
Back to Top