We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a00dc50 commit 9c2ac6fCopy full SHA for 9c2ac6f
rpc/subscription.go
@@ -17,7 +17,6 @@
17
package rpc
18
19
import (
20
- "bufio"
21
"container/list"
22
"context"
23
crand "crypto/rand"
@@ -51,10 +50,14 @@ func NewID() ID {
51
50
52
// randomIDGenerator returns a function generates a random IDs.
53
func randomIDGenerator() func() ID {
54
- seed, err := binary.ReadVarint(bufio.NewReader(crand.Reader))
55
- if err != nil {
+ var buf = make([]byte, 8)
+ var seed int64
+ if _, err := crand.Read(buf); err == nil {
56
+ seed = int64(binary.BigEndian.Uint64(buf))
57
+ } else {
58
seed = int64(time.Now().Nanosecond())
59
}
60
+
61
var (
62
mu sync.Mutex
63
rng = rand.New(rand.NewSource(seed))
0 commit comments