mirror/ezbookkeeping
1
0
Fork 0
mirror of https://github.com/mayswind/ezbookkeeping.git synced 2026-05-21 02:04:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

add more log in unit test

Browse Source
This commit is contained in:
MaysWind
2023-08-21 01:41:03 +08:00
parent 2aa6df48c6
commit 09f6dd8d82
1 changed files with 24 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/uuid/internal_generator_test.go
+12
View File
@@ -120,6 +120,8 @@ func TestGenerateUuid_10000TimesConcurrent(t *testing.T) {
} }
if uuidInfo.SequentialId == 0 { if uuidInfo.SequentialId == 0 {
fmt.Printf("routine#%d generate uuid %d\n", currentRoutineIndex, uuid)
if existedRoutineIndex, exists := generatedIds.Load(uuid); exists { if existedRoutineIndex, exists := generatedIds.Load(uuid); exists {
mutex.Lock() mutex.Lock()
assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuid, uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex)) assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuid, uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex))
@@ -168,6 +170,8 @@ func TestGenerateUuid_1000000TimesConcurrent(t *testing.T) {
} }
if uuidInfo.SequentialId == 0 { if uuidInfo.SequentialId == 0 {
fmt.Printf("routine#%d generate uuid %d\n", currentRoutineIndex, uuid)
if existedRoutineIndex, exists := generatedIds.Load(uuid); exists { if existedRoutineIndex, exists := generatedIds.Load(uuid); exists {
mutex.Lock() mutex.Lock()
assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuid, uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex)) assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuid, uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex))
@@ -297,6 +301,9 @@ func TestGenerateUuids_20000TimesConcurrent(t *testing.T) {
} }
} }
if uuidInfo.SequentialId == 0 {
fmt.Printf("routine#%d generate uuid %d\n", currentRoutineIndex, uuids[i])
if existedRoutineIndex, exists := generatedIds.Load(uuids[i]); exists { if existedRoutineIndex, exists := generatedIds.Load(uuids[i]); exists {
mutex.Lock() mutex.Lock()
assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuids[i], uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex)) assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuids[i], uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex))
@@ -306,6 +313,7 @@ func TestGenerateUuids_20000TimesConcurrent(t *testing.T) {
generatedIds.Store(uuids[i], currentRoutineIndex) generatedIds.Store(uuids[i], currentRoutineIndex)
} }
} }
}
waitGroup.Done() waitGroup.Done()
}(routineIndex) }(routineIndex)
@@ -346,6 +354,9 @@ func TestGenerateUuids_1000000TimesConcurrent(t *testing.T) {
} }
} }
if uuidInfo.SequentialId == 0 {
fmt.Printf("routine#%d generate uuid %d\n", currentRoutineIndex, uuids[i])
if existedRoutineIndex, exists := generatedIds.Load(uuids[i]); exists { if existedRoutineIndex, exists := generatedIds.Load(uuids[i]); exists {
mutex.Lock() mutex.Lock()
assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuids[i], uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex)) assert.Fail(t, fmt.Sprintf("uuid \"%d\" conflicts, unix time is %d, seq id is %d, existed routine index is %d, current routine index is %d", uuids[i], uuidInfo.UnixTime, uuidInfo.SequentialId, existedRoutineIndex, currentRoutineIndex))
@@ -355,6 +366,7 @@ func TestGenerateUuids_1000000TimesConcurrent(t *testing.T) {
generatedIds.Store(uuids[i], currentRoutineIndex) generatedIds.Store(uuids[i], currentRoutineIndex)
} }
} }
}
waitGroup.Done() waitGroup.Done()
}(routineIndex) }(routineIndex)