aboutsummaryrefslogtreecommitdiff
path: root/middleware/dnstap/out/tcp_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/dnstap/out/tcp_test.go')
-rw-r--r--middleware/dnstap/out/tcp_test.go66
1 files changed, 0 insertions, 66 deletions
diff --git a/middleware/dnstap/out/tcp_test.go b/middleware/dnstap/out/tcp_test.go
deleted file mode 100644
index 113603cd4..000000000
--- a/middleware/dnstap/out/tcp_test.go
+++ /dev/null
@@ -1,66 +0,0 @@
-package out
-
-import (
- "net"
- "testing"
-)
-
-func sendOneTCP(tcp *TCP) error {
- if _, err := tcp.Write([]byte("frame")); err != nil {
- return err
- }
- if err := tcp.Flush(); err != nil {
- return err
- }
- return nil
-}
-func TestTCP(t *testing.T) {
- tcp := NewTCP("localhost:14000")
-
- if err := sendOneTCP(tcp); err == nil {
- t.Fatal("Not listening but no error.")
- return
- }
-
- l, err := net.Listen("tcp", "localhost:14000")
- if err != nil {
- t.Fatal(err)
- return
- }
-
- wait := make(chan bool)
- go func() {
- acceptOne(t, l)
- wait <- true
- }()
-
- if err := sendOneTCP(tcp); err != nil {
- t.Fatalf("send one: %s", err)
- return
- }
-
- <-wait
-
- // TODO: When the server isn't responding according to the framestream protocol
- // the thread is blocked.
- /*
- if err := sendOneTCP(tcp); err == nil {
- panic("must fail")
- }
- */
-
- go func() {
- acceptOne(t, l)
- wait <- true
- }()
-
- if err := sendOneTCP(tcp); err != nil {
- t.Fatalf("send one: %s", err)
- return
- }
-
- <-wait
- if err := l.Close(); err != nil {
- t.Error(err)
- }
-}