Merge pull request #25 from calyptia/no-buffered

Remove buffered channels
chronosphereio · Dec 14, 2022 · dc2e246 · dc2e246
2 parents 93cc63c + 5b088d5
commit dc2e246
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cshared.go b/cshared.go
@@ -126,7 +126,7 @@ func FLBPluginInputCallback(data *unsafe.Pointer, csize *C.size_t) int {
 	var err error
 	once.Do(func() {
 		runCtx, runCancel = context.WithCancel(context.Background())
-		theChannel = make(chan Message, 1)
+		theChannel = make(chan Message)
 		go func() {
 			err = theInput.Collect(runCtx, theChannel)
 		}()
@@ -185,7 +185,7 @@ func FLBPluginFlush(data unsafe.Pointer, clength C.int, ctag *C.char) int {
 	var err error
 	once.Do(func() {
 		runCtx, runCancel = context.WithCancel(context.Background())
-		theChannel = make(chan Message, 1)
+		theChannel = make(chan Message)
 		go func() {
 			err = theOutput.Flush(runCtx, theChannel)
 		}()

diff --git a/testdata/Dockerfile b/testdata/Dockerfile
@@ -26,7 +26,7 @@ RUN dpkg -i external/*.deb
 RUN go build -trimpath -buildmode c-shared -o ./bin/go-test-input-plugin.so ./testdata/input/input.go
 RUN go build -trimpath -buildmode c-shared -o ./bin/go-test-output-plugin.so ./testdata/output/output.go
 
-FROM ghcr.io/calyptia/enterprise/advanced:main
+FROM ghcr.io/calyptia/internal/core:main
 
 COPY --from=builder /fluent-bit-go/bin/go-test-input-plugin.so /fluent-bit/etc/
 COPY --from=builder /fluent-bit-go/bin/go-test-output-plugin.so /fluent-bit/etc/