- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for Ling (0.07 sec)
-
guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
like that!' He got behind Alice as he spoke. `A cat may look at a king,' said Alice. `I've read that in some book, but I don't remember where.' `Well, it must be removed,' said the King very decidedly, and he called the Queen, who was passing at the moment, `My dear! I wish you would have this cat removed!' The Queen had only one way of settling all difficulties, great
Registered: 2024-11-01 12:43 - Last Modified: 2012-10-29 21:35 - 145.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.sendFrame().ping(false, 2, 3) peer.acceptFrame() // PING peer.play() // Play it back. connect(peer) // Verify the peer received what was expected. val ping = peer.takeFrame() assertThat(ping.type).isEqualTo(Http2.TYPE_PING) assertThat(ping.streamId).isEqualTo(0) assertThat(ping.payload1).isEqualTo(2) assertThat(ping.payload2).isEqualTo(3)
Registered: 2024-11-01 11:42 - Last Modified: 2024-04-20 17:03 - 75.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java
} } resultBuf.append("Status of ").append(ping.getClusterName()).append(" is changed to ").append(ping.getClusterStatus()) .append('.'); } else if (status == 0) { resultBuf.append(ping.getClusterName()).append(" is alive."); } else { resultBuf.append(ping.getClusterName()).append(" is not available."); }
Registered: 2024-10-31 13:40 - Last Modified: 2024-02-22 01:37 - 4.1K bytes - Viewed (0) -
internal/s3select/jstream/decoder_test.go
var ( counter int mv *MetaValue body = `{ "bio": "bada bing bada boom", "id": 1, "name": "Charles" } { "bio": "bada bing bada boom", "id": 2, "name": "Charles" } { "bio": "bada bing bada boom", "id": 3, "name": "Charles" } { "bio": "bada bing bada boom", "id": 4, "name": "Charles" } { "bio": "bada bing bada boom", "id": 5, "name": "Charles" } ` ) decoder := NewDecoder(mkReader(body), 0)
Registered: 2024-11-03 19:28 - Last Modified: 2024-09-23 19:35 - 6.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1000L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. taskFaker.advanceUntil(ns(1500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong. } @Test
Registered: 2024-11-01 11:42 - Last Modified: 2024-04-11 01:59 - 18.5K bytes - Viewed (0) -
internal/ringbuffer/README.md
# Blocking vs Non-blocking The default behavior of the ring buffer is non-blocking, meaning that reads and writes will return immediately with an error if the operation cannot be completed. If you want to block when reading or writing, you must enable it: ```go rb := ringbuffer.New(1024).SetBlocking(true) ``` Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe).
Registered: 2024-11-03 19:28 - Last Modified: 2024-05-15 00:11 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/BaseApiManager.java
Registered: 2024-10-31 13:40 - Last Modified: 2024-02-22 01:53 - 4.3K bytes - Viewed (0) -
cmd/consolelogger.go
console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w), logBuf: ring.New(defaultLogBufferCount), } }
Registered: 2024-11-03 19:28 - Last Modified: 2024-05-24 23:05 - 5.5K bytes - Viewed (0) -
prepare_stmt.go
if err == nil { return stmt.QueryRowContext(ctx, args...) } return &sql.Row{} } func (db *PreparedStmtDB) Ping() error { conn, err := db.GetDBConn() if err != nil { return err } return conn.Ping() } type PreparedStmtTX struct { Tx PreparedStmtDB *PreparedStmtDB } func (db *PreparedStmtTX) GetDBConn() (*sql.DB, error) {
Registered: 2024-11-03 09:35 - Last Modified: 2024-08-22 11:02 - 6.6K bytes - Viewed (0) -
internal/event/target/redis.go
return false, err } return target.isActive() } func (target *RedisTarget) isActive() (bool, error) { conn := target.pool.Get() defer conn.Close() _, pingErr := conn.Do("PING") if pingErr != nil { if xnet.IsConnRefusedErr(pingErr) { return false, store.ErrNotConnected } return false, pingErr } return true, nil }
Registered: 2024-11-03 19:28 - Last Modified: 2024-09-06 23:06 - 9.1K bytes - Viewed (0)