Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for cancelling (0.94 sec)

  1. chainable_api.go

    //
    // Offset conditions can be cancelled by using `Offset(-1)`.
    //
    //	// select the third user
    //	db.Offset(2).First(&user)
    //	// select the first user by cancelling an earlier chained offset
    //	db.Offset(5).Offset(-1).First(&user)
    func (db *DB) Offset(offset int) (tx *DB) {
    	tx = db.getInstance()
    	tx.Statement.AddClause(clause.Limit{Offset: offset})
    	return
    }
    
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Wed Jun 12 09:47:34 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    	// Currently, using cancellation from that context causes test failures. To remove this WithoutCancel,
    	// any wait.Interrupted errors need to be filtered from result and bypass the reasonCache - cancelling
    	// the context for SyncPod is a known and deliberate error, not a generic error.
    	// Use WithoutCancel instead of a new context.TODO() to propagate trace context
    	// Call the container runtime's SyncPod callback
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. internal/grid/stream.go

    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. internal/grid/muxserver.go

    	for {
    		select {
    		case <-m.ctx.Done():
    			return
    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    			if last > 4*m.clientPingInterval {
    				gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last))
    				m.close()
    				return
    			}
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  5. src/os/exec/exec.go

    			// (Perhaps c.Wait hadn't been called, or perhaps it happened to race with
    			// c.ctx being canceled.) Don't inject a needless error.
    		} else {
    			err = wrappedError{
    				prefix: "exec: canceling Cmd",
    				err:    interruptErr,
    			}
    		}
    	}
    	if c.WaitDelay == 0 {
    		resultc <- ctxResult{err: err}
    		return
    	}
    
    	timer := time.NewTimer(c.WaitDelay)
    	select {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  6. src/os/exec/exec_test.go

    			// Panic instead of calling t.Fatal so that we get a goroutine dump.
    			// We want to know exactly what the os/exec goroutines got stuck on.
    			debug.SetTraceback("system")
    			panic("canceling context did not stop program")
    		}
    
    		// Back off exponentially (up to 1-second sleeps) to give the OS time to
    		// terminate the process.
    		delay *= 2
    		if delay > 1*time.Second {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. src/net/http/serve_test.go

    			if err != nil {
    				t.Errorf("Proxy copy error: %v", err)
    				return
    			}
    			t.Cleanup(func() { bresp.Body.Close() })
    
    			// Try to cause a race. Canceling the client request will cause the client
    			// transport to close req2.Body. Returning from the server handler will
    			// cause the server to close req.Body. Since they are the same underlying
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
Back to top