Add upstreamConn.register
git-svn-id: file:///srv/svn/repo/suika/trunk@44 f0ae65fe-ee39-954e-97ec-027ff2717ef4
This commit is contained in:
parent
16dd0965fb
commit
6f89a1e0f5
@ -106,6 +106,8 @@ func (s *Server) Run() {
|
||||
return
|
||||
}
|
||||
|
||||
conn.register()
|
||||
|
||||
u.lock.Lock()
|
||||
u.upstreamConns = append(u.upstreamConns, conn)
|
||||
u.lock.Unlock()
|
||||
|
@ -317,9 +317,7 @@ func (c *upstreamConn) handleMessage(msg *irc.Message) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (c *upstreamConn) readMessages() error {
|
||||
defer c.Close()
|
||||
|
||||
func (c *upstreamConn) register() {
|
||||
c.nick = c.upstream.Nick
|
||||
c.messages <- &irc.Message{
|
||||
Command: "NICK",
|
||||
@ -329,6 +327,10 @@ func (c *upstreamConn) readMessages() error {
|
||||
Command: "USER",
|
||||
Params: []string{c.upstream.Username, "0", "*", c.upstream.Realname},
|
||||
}
|
||||
}
|
||||
|
||||
func (c *upstreamConn) readMessages() error {
|
||||
defer c.Close()
|
||||
|
||||
for {
|
||||
msg, err := c.irc.ReadMessage()
|
||||
|
Loading…
x
Reference in New Issue
Block a user