Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 104 for King (0.08 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          awaitingPong = true
        }
    
        if (failedPing != -1) {
          failWebSocket(
            e =
              SocketTimeoutException(
                "sent ping but didn't receive pong within " +
                  "${pingIntervalMillis}ms (after ${failedPing - 1} successful ping/pongs)",
              ),
            isWriter = true,
          )
          return
        }
    
        try {
          writer.writePing(ByteString.EMPTY)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. gorm.go

    		ConnPool: db.ConnPool,
    		Context:  context.Background(),
    		Clauses:  map[string]clause.Clause{},
    	}
    
    	if err == nil && !config.DisableAutomaticPing {
    		if pinger, ok := db.ConnPool.(interface{ Ping() error }); ok {
    			err = pinger.Ping()
    		}
    	}
    
    	if err != nil {
    		config.Logger.Error(context.Background(), "failed to initialize database, got error %v", err)
    	}
    
    	return
    }
    
    // Session create new db session
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

        }
      }
    
      @Test fun emptyPingCallsCallback() {
        data.write("8900".decodeHex()) // Empty ping
        clientReader.processNextFrame()
        callback.assertPing(EMPTY)
      }
    
      @Test fun pingCallsCallback() {
        data.write("890548656c6c6f".decodeHex()) // Ping with "Hello"
        clientReader.processNextFrame()
        callback.assertPing("Hello".encodeUtf8())
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  4. CONTRIBUTING.md

    for MinIO?
    
    ``MinIO`` is fully conformant with Golang style. Refer: [Effective Go](https://github.com/golang/go/wiki/CodeReviewComments) article from Golang project. If you observe offending code, please feel free to send a pull request or ping us on [Slack](https://slack.min.io)....
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

            sink.writeInt(settings[i])
          }
          sink.flush()
        }
      }
    
      /**
       * Send a connection-level ping to the peer. `ack` indicates this is a reply. The data in
       * `payload1` and `payload2` opaque binary, and there are no rules on the content.
       */
      @Throws(IOException::class)
      fun ping(
        ack: Boolean,
        payload1: Int,
        payload2: Int,
      ) {
        this.withLock {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/AppendableWriterTest.java

        writer.write("Hi");
        writer.close();
    
        assertThrows(IOException.class, () -> writer.write(" Greg"));
    
        assertThrows(IOException.class, () -> writer.flush());
    
        // close()ing already closed writer is allowed
        writer.close();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  7. docs/en/docs/tutorial/handling-errors.md

    The benefit of raising an exception over `return`ing a value will be more evident in the section about Dependencies and Security.
    
    In this example, when the client requests an item by an ID that doesn't exist, raise an exception with a status code of `404`:
    
    ```Python hl_lines="11"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  8. cmd/listen-notification-handlers.go

    		if peer == nil {
    			continue
    		}
    		peer.Listen(ctx, mergeCh, values)
    	}
    
    	var (
    		emptyEventTicker <-chan time.Time
    		keepAliveTicker  <-chan time.Time
    	)
    
    	if p := values.Get("ping"); p != "" {
    		pingInterval, err := strconv.Atoi(p)
    		if err != nil {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL)
    			return
    		}
    		if pingInterval < 1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt

        assertThat(frameLog(true, 0, 0, TYPE_SETTINGS, 0x1))
          .isEqualTo("<< 0x00000000     0 SETTINGS      ACK")
        assertThat(frameLog(true, 0, 8, TYPE_PING, 0x1))
          .isEqualTo("<< 0x00000000     8 PING          ACK")
        assertThat(frameLog(true, 3, 0, TYPE_HEADERS, 0x1))
          .isEqualTo("<< 0x00000003     0 HEADERS       END_STREAM")
        assertThat(frameLog(true, 3, 0, TYPE_DATA, 0x1))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  10. RELEASE.md

    Suryamurthy, Wei Wang, Wen-Heng (Jack) Chung, wenxizhu, William D. Irons,
    winstonq, wyzhao, Xiaoming (Jason) Cui, Xinan Jiang, Xinping Wang, Yann-Yy,
    Yasir Modak, Yong Tang, Yongfeng Gu, Yuchen Ying, Yuxin Wu, zyeric, 王振华 (Zhenhua
    Wang)
    
    # Release 2.0.0
    
    ## Major Features and Improvements
    
    TensorFlow 2.0 focuses on **simplicity** and **ease of use**, featuring updates
    like:
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Oct 22 14:33:53 UTC 2024
    - 735.3K bytes
    - Viewed (0)
Back to top