TheArchive/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-07-31 16:23:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

auth getstatus max 1/s

Browse Source
This commit is contained in:
Fran Bull 2025-02-27 05:44:19 -08:00
parent ae30f58b46
commit 69f76641ac
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
tsconsensus/authorization.go
View File

@ -9,6 +9,7 @@ import (
"net/netip"
"slices"
"sync"
"time"
"tailscale.com/ipn"
"tailscale.com/ipn/ipnstate"
@ -23,9 +24,13 @@ type statusGetter interface {
type tailscaleStatusGetter struct {
ts *tsnet.Server
mu sync.Mutex // protects the following
lastStatus *ipnstate.Status
lastStatusTime time.Time
}
func (sg tailscaleStatusGetter) getStatus(ctx context.Context) (*ipnstate.Status, error) {
func (sg *tailscaleStatusGetter) fetchStatus(ctx context.Context) (*ipnstate.Status, error) {
lc, err := sg.ts.LocalClient()
if err != nil {
return nil, err
@ -33,6 +38,21 @@ func (sg tailscaleStatusGetter) getStatus(ctx context.Context) (*ipnstate.Status
return lc.Status(ctx)
}
func (sg *tailscaleStatusGetter) getStatus(ctx context.Context) (*ipnstate.Status, error) {
sg.mu.Lock()
defer sg.mu.Unlock()
if sg.lastStatus != nil && time.Since(sg.lastStatusTime) < 1*time.Second {
return sg.lastStatus, nil
}
status, err := sg.fetchStatus(ctx)
if err != nil {
return nil, err
}
sg.lastStatus = status
sg.lastStatusTime = time.Now()
return status, nil
}
type authorization struct {
sg statusGetter
tag string
@ -43,7 +63,7 @@ type authorization struct {
func newAuthorization(ts *tsnet.Server, tag string) *authorization {
return &authorization{
sg: tailscaleStatusGetter{
sg: &tailscaleStatusGetter{
ts: ts,
},
tag: tag,