From 76012e39e9201b9dfcbbad546c7c2b38512903cb Mon Sep 17 00:00:00 2001
From: Mikhail Osipov <mike.osipov@gmail.com>
Date: Wed, 11 Mar 2020 10:49:15 +0300
Subject: auto dial, tunnel limit

---
 pkg/server/socket/loop.go | 46 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 46 insertions(+)
 create mode 100644 pkg/server/socket/loop.go

(limited to 'pkg/server/socket/loop.go')

diff --git a/pkg/server/socket/loop.go b/pkg/server/socket/loop.go
new file mode 100644
index 0000000..88e9491
--- /dev/null
+++ b/pkg/server/socket/loop.go
@@ -0,0 +1,46 @@
+package socket
+
+import (
+	"tunnel/pkg/server/env"
+	"tunnel/pkg/server/queue"
+)
+
+type loopSocket struct{}
+
+type loopChannel struct {
+	c chan queue.Q
+	q chan error
+}
+
+func (c *loopChannel) Send(wq queue.Q) error {
+	c.c <- wq
+	return <-c.q
+}
+
+func (c *loopChannel) Recv(rq queue.Q) error {
+	defer close(c.q)
+	return queue.Copy(rq, <-c.c)
+}
+
+func (c *loopChannel) String() string {
+	return "loop"
+}
+
+func (c *loopChannel) Close() error {
+	return nil
+}
+
+func (s *loopSocket) Open(env.Env) (Channel, error) {
+	return &loopChannel{make(chan queue.Q), make(chan error)}, nil
+}
+
+func (s *loopSocket) String() string {
+	return "loop"
+}
+
+func (s *loopSocket) Close() {
+}
+
+func newLoopSocket() (S, error) {
+	return &loopSocket{}, nil
+}
-- 
cgit v1.2.3-70-g09d2