connect.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

package main

import (
	"net"

	"github.com/anon55555/mt"
)

func connect(conn net.Conn, cc *clientConn) *serverConn {
	sc := &serverConn{
		Peer: mt.Connect(conn),
		clt:  cc,
	}
	sc.log("-->", "connect")
	cc.srv = sc

	go handleSrv(sc)
	return sc
}

func connectContent(conn net.Conn, name, userName string) *contentConn {
	cc := &contentConn{
		Peer:     mt.Connect(conn),
		doneCh:   make(chan struct{}),
		name:     name,
		userName: userName,
	}

	go handleContent(cc)
	return cc
}