Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 248 for sena (0.02 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        taskFaker.runTasks()
        assertThat(client.closed).isTrue()
        server.listener.assertExhausted() // Client should not have sent second close.
        client.listener.assertExhausted() // Server should not have sent second close.
      }
    
      @Test
      fun serverCloseBreaksReadMessageLoop() {
        server.webSocket!!.send("Hello!")
        server.webSocket!!.close(1000, "Bye!")
        assertThat(client.processNextFrame()).isTrue()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java

            // Verify interactions
            verify(tree, times(1)).send(isA(Trans2FindFirst2.class), any(Trans2FindFirst2Response.class));
            // Verify that Trans2FindNext2 was sent twice for fetching more entries
            verify(tree, times(2)).send(isA(Trans2FindNext2.class), any(Trans2FindFirst2Response.class));
    
            // Close should have sent FindClose2 exactly once
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      }
    
      // Writer methods to enqueue frames. They'll be sent asynchronously by the writer thread.
    
      override fun send(text: String): Boolean = send(text.encodeUtf8(), OPCODE_TEXT)
    
      override fun send(bytes: ByteString): Boolean = send(bytes, OPCODE_BINARY)
    
      @Synchronized private fun send(
        data: ByteString,
        formatOpcode: Int,
      ): Boolean {
        // Don't send new frames after we've failed or enqueued a close frame.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbFileOutputStreamTest.java

            byte[] data = "Appended".getBytes();
    
            // When
            outputStream.write(data);
    
            // Then - verify write request was sent
            verify(mockTreeHandle, atLeastOnce()).send(any(Smb2WriteRequest.class), any());
        }
    
        @Test
        void testMultipleWrites() throws IOException, CIFSException {
            // Given
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/rdma/SmbDirectNegotiateRequest.java

        }
    
        /**
         * Get the preferred size for send operations
         *
         * @return preferred send size in bytes
         */
        public int getPreferredSendSize() {
            return preferredSendSize;
        }
    
        /**
         * Set the preferred size for send operations
         *
         * @param preferredSendSize preferred send size in bytes
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

            exchange.finishRequest()
          }
        } catch (e: IOException) {
          if (e is ConnectionShutdownException) {
            throw e // No request was sent so there's no response to read.
          }
          if (!exchange.hasFailure) {
            throw e // Don't attempt to read the response; we failed to send the request.
          }
          sendRequestException = e
        }
    
        try {
          if (responseBuilder == null) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  7. docs/en/docs/tutorial/body.md

    # Request Body { #request-body }
    
    When you need to send data from a client (let's say, a browser) to your API, you send it as a **request body**.
    
    A **request** body is data sent by the client to your API. A **response** body is the data your API sends to the client.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:58:56 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

            // Note: This IOCTL must be sent on an existing session
            // The actual sending would need integration with the session's transport
            // For now, we're preparing the request structure correctly
    
            // TODO: Integration point - send request through session.send()
            // Smb2IoctlResponse response = (Smb2IoctlResponse) session.send(request);
            // if (response.isSuccess()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/rdma/RdmaStatistics.java

            rdmaWrites.incrementAndGet();
            bytesTransferred.addAndGet(bytes);
            totalWriteTime.addAndGet(durationNanos);
        }
    
        /**
         * Record an RDMA send operation
         *
         * @param bytes number of bytes sent
         * @param durationNanos operation duration in nanoseconds
         */
        public void recordRdmaSend(int bytes, long durationNanos) {
            rdmaSends.incrementAndGet();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  10. docs/metrics/v3.md

    | `minio_notification_current_send_in_progress` | Number of concurrent async Send calls active to all targets. <br><br>Type: counter                    | `server` |
    | `minio_notification_events_errors_total`      | Total number of events that failed to send to the targets. <br><br>Type: counter                      | `server` |
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 45.2K bytes
    - Viewed (0)
Back to top