diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-23 16:06:34 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-23 16:06:34 +0300 |
| commit | 7f71e4fc69e2b27d8ff6375cc6f4be2092721186 (patch) | |
| tree | 794c0b8552dbdf90d9eb612428e1868e7b18bd08 /tmp/socket.go | |
| parent | 4bbdb1b34d9f7e71c0faf6f1943e6bb4ce303af1 (diff) | |
drop old files
Diffstat (limited to 'tmp/socket.go')
| -rw-r--r-- | tmp/socket.go | 84 |
1 files changed, 0 insertions, 84 deletions
diff --git a/tmp/socket.go b/tmp/socket.go deleted file mode 100644 index febd650..0000000 --- a/tmp/socket.go +++ /dev/null @@ -1,84 +0,0 @@ -package server - -import ( - "strconv" - "fmt" -) - -const MAXPORT = 1 << 16 - 1 - -type tcpListen struct { - addr string -} - -type tcpOut struct { - addr string -} - -func (t *tcpListen) Open() (proto, error) { - return nil, errNotImplemented -} - -func (t *tcpListen) Close() error { - return nil -} - -func (t *tcpListen) String() string { - return fmt.Sprintf("tcp <- %s", t.addr) -} - -func (t *tcpOut) Open() (proto, error) { - return nil, errNotImplemented -} - -func (t *tcpOut) Close() error { - return nil -} - -func (t *tcpOut) String() string { - return fmt.Sprintf("tcp -> %s", t.addr) -} - -func parsePort(r *request, s string) int { - port, err := strconv.Atoi(s) - if err != nil { - r.Fatalf("bad port value: %v", err) - } - if port <= 0 || port > MAXPORT { - r.Fatal("bad port value") - } - return port -} - -func addTcpListen(r *request) { - r.expect(1, 2) - - var host string - var n int - - if r.argc > 1 { - host = r.args[n] - n++ - } - - port := parsePort(r, r.args[n]) - t := &tcpListen{addr: fmt.Sprintf("%s:%d", host, port)} - - r.c.s.proto.add(t) -} - -func addTcpOut(r *request) { - r.expect(2) - - host := r.args[0] - port := parsePort(r, r.args[1]) - - t := &tcpOut{addr: fmt.Sprintf("%s:%d", host, port)} - - r.c.s.proto.add(t) -} - -func init() { - newCmd(addTcpListen, "add", "tcp", "listen") - newCmd(addTcpOut, "add", "tcp", "out") -} |
