test

loader/register_tango.go

@@ -29,5 +29,6 @@ var pluginsMu sync.Mutex
 func registerModule(mod *moduledata) {
     pluginsMu.Lock()
     defer pluginsMu.Unlock()
+    lastmoduledatap.next = mod
     lastmoduledatap = mod
 }

loader/register_test.go

@@ -1,5 +1,3 @@
-// +build !bytedance_tango
-
 /*
  * Copyright 2023 ByteDance Inc.
  *
@@ -23,25 +21,24 @@ import (
     "sync"
 )
 
-func Test_registerModuleLockFree(t *testing.T) {
-    n, parallel := 1000, 8
-    head := moduledata{}
-    tail := &head
+func Test_registerModuleRace(t *testing.T) {
+    n, parallel := 100, 8
+    s := &moduledata{}
+    registerModule(s)
     wg := sync.WaitGroup{}
     wg.Add(parallel)
     filler := func(n int) {
         defer wg.Done()
         for i := 0; i < n; i++ {
-            m := &moduledata{}
-            registerModuleLockFree(&tail, m)
+            registerModule(&moduledata{})
         }
     }
     for i := 0; i < parallel; i++ {
         go filler(n)
     }
     wg.Wait()
     i := 0
-    for p := head.next; p != nil; p = p.next {
+    for p := s.next; p != nil; p = p.next {
         i += 1
     }
     if i != parallel * n {