Method CommitExWithContext

xenomint/state.go:608–650

CommitExWithContext commits the current transaction and returns all the pooled queries with context.

(
	ctx context.Context)

// CommitExWithContext commits the current transaction and returns all the pooled queries
// with context.
func (s *State) CommitExWithContext(
	ctx context.Context) (failed []*types.Request, queries []*QueryTracker, err error,
) {
	var (
		start = time.Now()

		lockAcquired, committed, poolCleaned, lockReleased time.Duration
	)

	defer func() {
		var fields = log.Fields{}
		fields["1#lockAcquired"] = float64(lockAcquired.Nanoseconds()) / 1000
		if committed > 0 {
			fields["2#committed"] = float64((committed - lockAcquired).Nanoseconds()) / 1000
		}
		if poolCleaned > 0 {
			fields["3#poolCleaned"] = float64((poolCleaned - committed).Nanoseconds()) / 1000
		}
		if lockReleased > 0 {
			fields["4#lockReleased"] = float64((lockReleased - poolCleaned).Nanoseconds()) / 1000
		}
		log.WithFields(fields).Debug("Commit duration stat (us)")
	}()

	s.Lock()
	lockAcquired = time.Since(start)
	defer func() {
		s.Unlock()
		lockReleased = time.Since(start)
	}()
	// Always try to commit before the block is produced
	s.flushHandler()
	committed = time.Since(start)
	// Return pooled items and reset
	failed = s.pool.failedList()
	queries = s.pool.queries
	for _, v := range s.pool.reads {
		queries = append(queries, v)
	}
	s.pool = newPool()
	poolCleaned = time.Since(start)
	return
}

func (s *State) flushHandler() {
	s.commitHandler()