cshared: test: Fix failing cshared tests

Signed-off-by: Hiroshi Hatake <[email protected]>

cshared_test.go

@@ -40,6 +40,13 @@ func TestInputCallbackCtrlC(t *testing.T) {
 
 	ptr := unsafe.Pointer(nil)
 
+	// prepare channel for input explicitly.
+	err := prepareInputCollector()
+	if err != nil {
+		t.Fail()
+		return
+	}
+
 	go func() {
 		FLBPluginInputCallback(&ptr, nil)
 		cdone <- true
@@ -86,6 +93,12 @@ func TestInputCallbackDangle(t *testing.T) {
 	cdone := make(chan bool)
 	ptr := unsafe.Pointer(nil)
 
+	// prepare channel for input explicitly.
+	err := prepareInputCollector()
+	if err != nil {
+		t.Fail()
+	}
+
 	go func() {
 		t := time.NewTicker(collectInterval)
 		defer t.Stop()
@@ -156,6 +169,13 @@ func TestInputCallbackInfinite(t *testing.T) {
 	cshutdown := make(chan bool)
 	ptr := unsafe.Pointer(nil)
 
+	// prepare channel for input explicitly.
+	err := prepareInputCollector()
+	if err != nil {
+		t.Fail()
+		return
+	}
+
 	go func() {
 		t := time.NewTicker(collectInterval)
 		defer t.Stop()
@@ -237,6 +257,13 @@ func TestInputCallbackLatency(t *testing.T) {
 	cstarted := make(chan bool)
 	cmsg := make(chan []byte)
 
+	// prepare channel for input explicitly.
+	err := prepareInputCollector()
+	if err != nil {
+		t.Fail()
+		return
+	}
+
 	go func() {
 		t := time.NewTicker(collectInterval)
 		defer t.Stop()
@@ -363,6 +390,12 @@ func TestInputCallbackInfiniteConcurrent(t *testing.T) {
 
 	concurrentWait.Add(64)
 
+	// prepare channel for input explicitly.
+	err := prepareInputCollector()
+	if err != nil {
+		t.Fail()
+	}
+
 	go func(cstarted chan bool) {
 		ticker := time.NewTicker(time.Second * 1)
 		defer ticker.Stop()