Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 171 for sendMsg (0.19 seconds)

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

  1. docs/changelogs/changelog_4x.md

     *  Fix: Include the header `Accept: text/event-stream` for SSE calls. This header is not added if
        the request already contains an `Accept` header.
    
     *  Fix: Don't crash with a `NullPointerException` if a server sends a close while we're sending a
        ping. OkHttp had a race condition bug.
    
    
    ## Version 4.6.0
    
    _2020-04-28_
    
     *  Fix: Follow HTTP 307 and 308 redirects on methods other than GET and POST. We're reluctant to
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Click Count (0)
  2. CONTRIBUTING.md

    For change proposals, see [Proposing Changes To Go](https://go.dev/s/proposal-process).
    
    ## Contributing code
    
    Please read the [Contribution Guidelines](https://golang.org/doc/contribute.html) before sending patches.
    
    Unless otherwise noted, the Go source files are distributed under
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Mar 29 22:00:27 GMT 2023
    - 1.3K bytes
    - Click Count (0)
  3. samples/guide/src/main/java/okhttp3/recipes/LoggingInterceptors.java

        @Override public Response intercept(Chain chain) throws IOException {
          long t1 = System.nanoTime();
          Request request = chain.request();
          logger.info(String.format("Sending request %s on %s%n%s",
              request.url(), chain.connection(), request.headers()));
          Response response = chain.proceed(request);
    
          long t2 = System.nanoTime();
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jan 01 15:55:32 GMT 2016
    - 2K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb2/rdma/RdmaStatistics.java

         *
         * @return average send latency
         */
        public double getAverageSendLatencyMicros() {
            long sends = rdmaSends.get();
            if (sends == 0) {
                return 0.0;
            }
            return totalSendTime.get() / (double) sends / 1000.0; // Convert to microseconds
        }
    
        /**
         * Calculate average receive latency in microseconds
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 10.7K bytes
    - Click Count (0)
  5. cmd/peer-rest-server.go

    	}
    	var buf bytes.Buffer
    	enc := json.NewEncoder(&buf)
    	for {
    		select {
    		case entry, ok := <-ch:
    			if !ok {
    				return grid.NewRemoteErrString("console log channel closed")
    			}
    			if !entry.SendLog("", madmin.LogMask(mask)) {
    				continue
    			}
    			buf.Reset()
    			if err := enc.Encode(entry); err != nil {
    				return grid.NewRemoteErr(err)
    			}
    			out <- grid.NewBytesWithCopyOf(buf.Bytes())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  6. api/go1.3.txt

    pkg syscall (darwin-386), func Mprotect([]uint8, int) error
    pkg syscall (darwin-386), func Munlock([]uint8) error
    pkg syscall (darwin-386), func Munlockall() error
    pkg syscall (darwin-386), func SendmsgN(int, []uint8, []uint8, Sockaddr, int) (int, error)
    pkg syscall (darwin-386-cgo), func FcntlFlock(uintptr, int, *Flock_t) error
    pkg syscall (darwin-386-cgo), func Mlock([]uint8) error
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * [Call.request] is a redirect to a different address.
       */
      open fun connectionReleased(
        call: Call,
        connection: Connection,
      ) {
      }
    
      /**
       * Invoked just prior to sending request headers.
       *
       * The connection is implicit, and will generally relate to the last [connectionAcquired] event.
       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response to the
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  8. docs/en/docs/advanced/response-cookies.md

    So, you will have to make sure your data is of the correct type. E.g. it is compatible with JSON, if you are returning a `JSONResponse`.
    
    And also that you are not sending any data that should have been filtered by a `response_model`.
    
    ///
    
    ### More info { #more-info }
    
    /// note | Technical Details
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 2.2K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt

              .build(),
          )
        call1.execute().use { response -> response.body.string() }
    
        listener.shouldClose = true
        // Large headers are a likely reason the servers would cut off the connection before it completes sending
        // request headers.
        // 431 "Request Header Fields Too Large"
        val largeHeaders =
          Headers
            .Builder()
            .apply {
              repeat(32) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  10. docs/contribute/concurrency.md

    Consider an application streaming a video over http/2. Perhaps the user pauses the video and the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending more data on this stream. When the user unpauses her video the buffer drains, the read is acknowledged, and the server proceeds to stream data.
    
    #### Shared reader thread
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
Back to Top