aboutsummaryrefslogtreecommitdiffstats
path: root/whisper/common_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'whisper/common_test.go')
-rw-r--r--whisper/common_test.go40
1 files changed, 0 insertions, 40 deletions
diff --git a/whisper/common_test.go b/whisper/common_test.go
deleted file mode 100644
index a5df762e1..000000000
--- a/whisper/common_test.go
+++ /dev/null
@@ -1,40 +0,0 @@
-// Contains some common utility functions for testing.
-
-package whisper
-
-import (
- "bytes"
- "io/ioutil"
-
- "github.com/ethereum/go-ethereum/p2p"
-)
-
-// bufMsgPipe creates a buffered message pipe between two endpoints.
-func bufMsgPipe() (*p2p.MsgPipeRW, *p2p.MsgPipeRW) {
- A, midA := p2p.MsgPipe()
- midB, B := p2p.MsgPipe()
-
- go copyMsgPipe(midA, midB)
- go copyMsgPipe(midB, midA)
-
- return A, B
-}
-
-// copyMsgPipe copies messages from the src pipe to the dest.
-func copyMsgPipe(dst, src *p2p.MsgPipeRW) {
- defer dst.Close()
- for {
- msg, err := src.ReadMsg()
- if err != nil {
- return
- }
- data, err := ioutil.ReadAll(msg.Payload)
- if err != nil {
- return
- }
- msg.Payload = bytes.NewReader(data)
- if err := dst.WriteMsg(msg); err != nil {
- return
- }
- }
-}