Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 110 for ReadLine (0.06 sec)

  1. cmd/common-main.go

    type bgCtx struct {
    	parent context.Context
    }
    
    func (a bgCtx) Done() <-chan struct{} {
    	return nil
    }
    
    func (a bgCtx) Err() error {
    	return nil
    }
    
    func (a bgCtx) Deadline() (deadline time.Time, ok bool) {
    	return time.Time{}, false
    }
    
    func (a bgCtx) Value(key any) any {
    	return a.parent.Value(key)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  2. internal/rest/client.go

    	req, err := c.newRequest(ctx, httpMethod, u, body)
    	if err != nil {
    		return nil, &NetworkError{Err: err}
    	}
    	if length > 0 {
    		req.ContentLength = length
    	}
    
    	_, expectTimeouts := ctx.Deadline()
    
    	req, update := setupReqStatsUpdate(req)
    	defer update()
    
    	resp, err := c.httpClient.Do(req)
    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, expectTimeouts) {
    			if !c.NoMetrics {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        // Call 1: set a deadline on the response body.
        val request1 = Request.Builder().url(server.url("/")).build()
        val response1 = client.newCall(request1).execute()
        val body1 = response1.body.source()
        assertThat(body1.readUtf8()).isEqualTo("abc")
        body1.timeout().deadline(5, TimeUnit.SECONDS)
    
        // Call 2: check for the absence of a deadline on the request body.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 147.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       Future} is "completed" even if it is cancelled while its underlying work continues on a
     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       Future} is "completed" even if it is cancelled while its underlying work continues on a
     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      // * We want to behave reasonably for timeouts of 0
      // * We are more responsive to completion than timeouts. This is because parkNanos depends on
      //   system scheduling and as such we could either miss our deadline, or unpark() could be delayed
      //   so that it looks like we timed out even though we didn't. For comparison FutureTask respects
      //   completion preferably and AQS is non-deterministic (depends on where in the queue the waiter
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  7. api/go1.txt

    pkg bufio, method (*Reader) Read([]uint8) (int, error)
    pkg bufio, method (*Reader) ReadByte() (uint8, error)
    pkg bufio, method (*Reader) ReadBytes(uint8) ([]uint8, error)
    pkg bufio, method (*Reader) ReadLine() ([]uint8, bool, error)
    pkg bufio, method (*Reader) ReadRune() (int32, int, error)
    pkg bufio, method (*Reader) ReadSlice(uint8) ([]uint8, error)
    pkg bufio, method (*Reader) ReadString(uint8) (string, error)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      // * We want to behave reasonably for timeouts of 0
      // * We are more responsive to completion than timeouts. This is because parkNanos depends on
      //   system scheduling and as such we could either miss our deadline, or unpark() could be delayed
      //   so that it looks like we timed out even though we didn't. For comparison FutureTask respects
      //   completion preferably and AQS is non-deterministic (depends on where in the queue the waiter
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  9. finisher_api.go

    		opt *sql.TxOptions
    		err error
    	)
    
    	if len(opts) > 0 {
    		opt = opts[0]
    	}
    
    	ctx := tx.Statement.Context
    	if db.DefaultTransactionTimeout > 0 {
    		if _, ok := ctx.Deadline(); !ok {
    			ctx, _ = context.WithTimeout(ctx, db.DefaultTransactionTimeout)
    		}
    	}
    
    	switch beginner := tx.Statement.ConnPool.(type) {
    	case TxBeginner:
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Sep 19 01:49:06 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.7.md

    * Fix incorrect conflict errors applying strategic merge patches to resources. ([#43871](https://github.com/kubernetes/kubernetes/pull/43871), [@liggitt](https://github.com/liggitt))
    
    * Fix init container status reporting when active deadline is exceeded. ([#46305](https://github.com/kubernetes/kubernetes/pull/46305), [@sjenning](https://github.com/sjenning))
    
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 308.7K bytes
    - Viewed (1)
Back to top