- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for cancelling (0.94 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)