Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 93 for pin1 (0.02 seconds)

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

  1. docs/changelogs/changelog_4x.md

        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 Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Click Count (0)
  2. internal/grid/grid.go

    	biggerBufMin = 32 << 10
    
    	// This is the maximum size of bigger buffers.
    	biggerBufMax = maxBufferSize
    
    	// If there is a queue, merge up to this many messages.
    	maxMergeMessages = 50
    
    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    	// Deadline for single (non-streaming) requests to complete.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7K bytes
    - Click Count (0)
  3. api/go1.8.txt

    pkg database/sql/driver, type NamedValue struct, Ordinal int
    pkg database/sql/driver, type NamedValue struct, Value Value
    pkg database/sql/driver, type Pinger interface { Ping }
    pkg database/sql/driver, type Pinger interface, Ping(context.Context) error
    pkg database/sql/driver, type QueryerContext interface { QueryContext }
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Dec 21 05:25:57 GMT 2016
    - 16.3K bytes
    - Click Count (0)
  4. src/main/java/jcifs/smb/MultiChannelManager.java

                for (ChannelInfo channel : channelGroup.getChannels()) {
                    try {
                        // Simplified health check - in real implementation would ping the channel
                        boolean isHealthy = checkChannelHealth(channel);
                        channel.setHealthy(isHealthy);
    
                        if (!isHealthy) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

      /**
       * Returns true if the host and port are unchanged from when this was created. This is used to
       * detect if followups need to do a full connection-finding process including DNS resolution, and
       * certificate pin checks.
       */
      fun sameHostAndPort(url: HttpUrl): Boolean
    
      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue May 27 14:58:02 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

          errorCode: ErrorCode,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_RST_STREAM
          this.streamId = streamId
          this.errorCode = errorCode
        }
    
        override fun ping(
          ack: Boolean,
          payload1: Int,
          payload2: Int,
        ) {
          check(type == -1)
          type = Http2.TYPE_PING
          this.ack = ack
          this.payload1 = payload1
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  7. internal/grid/muxserver.go

    	if m.outBlock == nil {
    		// Closed
    		return
    	}
    	select {
    	case m.outBlock <- struct{}{}:
    	default:
    		gridLogIf(m.ctx, errors.New("output unblocked overflow"))
    	}
    }
    
    func (m *muxServer) ping(seq uint32) pongMsg {
    	if !m.checkSeq(seq) {
    		msg := fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq)
    		return pongMsg{Err: &msg}
    	}
    	select {
    	case <-m.ctx.Done():
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  8. docs/contribute/concurrency.md

    #### Do-stuff-later pool
    
    Sometimes there's an action required like calling the application layer or responding to a ping, and the thread discovering the action is not the thread that should do the work. We enqueue a runnable on this executor and it gets handled by one of the executor's threads.
    
    ### Locks
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  9. src/main/config/openapi/openapi-user.yaml

              
      /health:
        get:
          tags:
            - monitor
          summary: Check a server status
          description: Returns status
          operationId: ping
          responses:
            '200':
              description: Successful operation
              content:
                application/json:
                  schema:
                    type: object
                    properties:
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu May 09 06:31:27 GMT 2024
    - 21.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

          if (delegate == null) {
            return;
          }
    
          /*
           * If we're about to complete the TimeoutFuture, we want to release our reference to it.
           * Otherwise, we'll pin it (and its result) in memory until the timeout task is GCed. (The
           * need to clear our reference to the TimeoutFuture is the reason we use a *static* nested
           * class with a manual reference back to the "containing" class.)
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
Back to Top