diff --git a/common/collect/timed_queue.go b/common/collect/timed_queue.go index 375316f04..52d865c94 100644 --- a/common/collect/timed_queue.go +++ b/common/collect/timed_queue.go @@ -72,7 +72,7 @@ func (queue *TimedQueue) RemovedEntries() <-chan interface{} { func (queue *TimedQueue) cleanup(tick <-chan time.Time) { for now := range tick { - nowSec := now.UTC().Unix() + nowSec := now.Unix() for { queue.access.RLock() queueLen := queue.queue.Len() diff --git a/common/collect/timed_queue_test.go b/common/collect/timed_queue_test.go index fb3c5f99e..162e0b6dd 100644 --- a/common/collect/timed_queue_test.go +++ b/common/collect/timed_queue_test.go @@ -12,7 +12,7 @@ func TestTimedQueue(t *testing.T) { removed := make(map[string]bool) - nowSec := time.Now().UTC().Unix() + nowSec := time.Now().Unix() q := NewTimedQueue(2) go func() { @@ -51,7 +51,7 @@ func TestTimedQueue(t *testing.T) { <-tick assert.Bool(removed["Values"]).IsFalse() - q.Add("Value1", time.Now().UTC().Unix()+10) + q.Add("Value1", time.Now().Unix()+10) <-tick v1, ok = removed["Value1"] diff --git a/proxy/vmess/protocol/user/userset.go b/proxy/vmess/protocol/user/userset.go index 81f186e7e..1ca661d52 100644 --- a/proxy/vmess/protocol/user/userset.go +++ b/proxy/vmess/protocol/user/userset.go @@ -63,10 +63,10 @@ func (us *TimedUserSet) generateNewHashes(lastSec, nowSec int64, idx int, id *co } func (us *TimedUserSet) updateUserHash(tick <-chan time.Time) { - lastSec := time.Now().UTC().Unix() - cacheDurationSec + lastSec := time.Now().Unix() - cacheDurationSec for now := range tick { - nowSec := now.UTC().Unix() + cacheDurationSec + nowSec := now.Unix() + cacheDurationSec for idx, id := range us.validUserIds { us.generateNewHashes(lastSec, nowSec, idx, id) } @@ -79,7 +79,7 @@ func (us *TimedUserSet) AddUser(user config.User) error { idx := len(us.validUserIds) us.validUserIds = append(us.validUserIds, id) - nowSec := time.Now().UTC().Unix() + nowSec := time.Now().Unix() lastSec := nowSec - cacheDurationSec us.generateNewHashes(lastSec, nowSec+cacheDurationSec, idx, id) diff --git a/proxy/vmess/protocol/vmess.go b/proxy/vmess/protocol/vmess.go index e1964f4da..0c01ab775 100644 --- a/proxy/vmess/protocol/vmess.go +++ b/proxy/vmess/protocol/vmess.go @@ -166,7 +166,7 @@ func (request *VMessRequest) ToBytes(idHash user.CounterHash, randomRangeInt64 u buffer = alloc.NewSmallBuffer().Clear() } - counter := randomRangeInt64(time.Now().UTC().Unix(), 30) + counter := randomRangeInt64(time.Now().Unix(), 30) hash := idHash.Hash(request.UserId.Bytes[:], counter) buffer.Append(hash)