Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for Ling (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. src/main/java/org/codelibs/fess/api/BaseApiManager.java

                return FormatType.FAVORITE;
            }
            if (FormatType.FAVORITES.name().equals(type)) {
                return FormatType.FAVORITES;
            }
            if (FormatType.PING.name().equals(type)) {
                return FormatType.PING;
            }
            if (FormatType.SCROLL.name().equals(type)) {
                return FormatType.SCROLL;
            }
            if (FormatType.SUGGEST.name().equals(type)) {
    Registered: 2024-10-31 13:40
    - Last Modified: 2024-02-22 01:53
    - 4.3K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top