nsqd:It is more efficient to deal with the case where the sequence is…

… used up here
nsqio · Apr 26, 2023 · 34f2e70 · 34f2e70
1 parent cfbd287
commit 34f2e70
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/nsqd/guid.go b/nsqd/guid.go
@@ -63,7 +63,10 @@ func (f *guidFactory) NewGUID() (guid, error) {
 		f.sequence = (f.sequence + 1) & sequenceMask
 		if f.sequence == 0 {
 			f.Unlock()
-			return 0, ErrSequenceExpired
+			//wait for next millisecond
+			for ts <= f.lastTimestamp {
+				ts = time.Now().UnixNano() >> 20
+			}
 		}
 	} else {
 		f.sequence = 0