Skip to content

Commit

Permalink
Merge branch 'james/proj' into james/proj3
Browse files Browse the repository at this point in the history
  • Loading branch information
James Cor committed Oct 1, 2024
2 parents c19546c + 05f30a1 commit 7f9f227
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
12 changes: 6 additions & 6 deletions server/handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -577,12 +577,6 @@ func (h *Handler) resultForDefaultIter(
}
}

pollCtx, cancelF := ctx.NewSubContext()
eg.Go(func() error {
defer pan2err()
return h.pollForClosedConnection(pollCtx, c)
})

wg := sync.WaitGroup{}
wg.Add(2)

Expand Down Expand Up @@ -614,6 +608,12 @@ func (h *Handler) resultForDefaultIter(
}
})

pollCtx, cancelF := ctx.NewSubContext()
eg.Go(func() error {
defer pan2err()
return h.pollForClosedConnection(pollCtx, c)
})

// Default waitTime is one minute if there is no timeout configured, in which case
// it will loop to iterate again unless the socket died by the OS timeout or other problems.
// If there is a timeout, it will be enforced to ensure that Vitess has a chance to
Expand Down
2 changes: 1 addition & 1 deletion sql/rowexec/rel_iters.go
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ func ProjectRow(
row sql.Row,
) (sql.Row, error) {
var fields = make(sql.Row, len(projections))
var secondPass = make([]int, 0, len(projections))
var secondPass []int
for i, expr := range projections {
// Default values that are expressions may reference other fields, thus they must evaluate after all other exprs.
// Also default expressions may not refer to other columns that come after them if they also have a default expr.
Expand Down

0 comments on commit 7f9f227

Please sign in to comment.