mirror of
https://github.com/luxfi/node.git
synced 2026-10-30 15:24:05 +00:00
The module already called itself github.com/luxfi/node while containing no node in Go: cmd/luxd was twenty-one lines that printed the size of a few types, and the Go column of the matrix measured a VM plugin. A repo that fetches the thing it claims to be has not replaced it, so the Go sources move in — 1515 files, the daemon and everything under it — and the build reaches outside this module for nothing. Rust and C++ sit beside it unchanged and are still measured against it by the differential. That is the point of one repo: the reference implementation and the two ports are the same checkout, so parity is a thing you can run rather than a thing you assert. Verified: builds, and the closure carries no lux-private — checked at build time rather than believed. The daemon starts twelve chains on a local network (P X C Q Z A B G K M F, plus D through its plugin) and reports healthy.
65 lines
1.6 KiB
Go
65 lines
1.6 KiB
Go
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package gas
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"math"
|
|
|
|
safemath "github.com/luxfi/math"
|
|
)
|
|
|
|
var ErrInsufficientCapacity = errors.New("insufficient capacity")
|
|
|
|
type State struct {
|
|
Capacity Gas `serialize:"true" json:"capacity"`
|
|
Excess Gas `serialize:"true" json:"excess"`
|
|
}
|
|
|
|
// AdvanceTime adds maxPerSecond to capacity and subtracts targetPerSecond
|
|
// from excess over the provided duration.
|
|
//
|
|
// Capacity is capped at maxCapacity.
|
|
// Excess to be removed is capped at excess.
|
|
func (s State) AdvanceTime(
|
|
maxCapacity Gas,
|
|
maxPerSecond Gas,
|
|
targetPerSecond Gas,
|
|
duration uint64,
|
|
) State {
|
|
return State{
|
|
Capacity: min(
|
|
s.Capacity.AddPerSecond(maxPerSecond, duration),
|
|
maxCapacity,
|
|
),
|
|
Excess: s.Excess.SubPerSecond(targetPerSecond, duration),
|
|
}
|
|
}
|
|
|
|
// ConsumeGas removes gas from capacity and adds gas to excess.
|
|
//
|
|
// If the capacity is insufficient, an error is returned.
|
|
// If the excess would overflow, it is capped at MaxUint64.
|
|
func (s State) ConsumeGas(gas Gas) (State, error) {
|
|
newCapacity, err := safemath.Sub(uint64(s.Capacity), uint64(gas))
|
|
if err != nil {
|
|
return State{}, fmt.Errorf("%w: capacity (%d) < gas (%d)", ErrInsufficientCapacity, s.Capacity, gas)
|
|
}
|
|
|
|
newExcess, err := safemath.Add64(uint64(s.Excess), uint64(gas))
|
|
if err != nil {
|
|
//nolint:nilerr // excess is capped at MaxUint64
|
|
return State{
|
|
Capacity: Gas(newCapacity),
|
|
Excess: math.MaxUint64,
|
|
}, nil
|
|
}
|
|
|
|
return State{
|
|
Capacity: Gas(newCapacity),
|
|
Excess: Gas(newExcess),
|
|
}, nil
|
|
}
|