diff options
Diffstat (limited to 'src/globster/hub/hub.go')
| -rw-r--r-- | src/globster/hub/hub.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/globster/hub/hub.go b/src/globster/hub/hub.go index fb7b377..5bf7f79 100644 --- a/src/globster/hub/hub.go +++ b/src/globster/hub/hub.go @@ -3,20 +3,20 @@ package hub import ( "globster/adc" "go.blicky.net/tanja" - "time" "net" + "time" ) // TODO: Do the connect() and write()s in a separate goroutine. type hub struct { - name string - ses *tanja.Session - conn net.Conn + name string + ses *tanja.Session + conn net.Conn } func newHub(node *tanja.Node, name string) *hub { - s := &hub{name:name, ses:node.Session()} + s := &hub{name: name, ses: node.Session()} s.ses.RegRPC(s, func(s string) tanja.Tuple { if s[0] != 'T' { @@ -45,7 +45,7 @@ func (s *hub) Tconnect(addr string) { s.ses.Send(false, "hub", s.name, "Disconnected", e.Error()) } else { s.ses.Send(false, "hub", s.name, "Connected", s.conn.RemoteAddr().String()) - adc.NewWriter(s.conn).Write(&adc.Message{Header:adc.SUP.SetType('I')}) + adc.NewWriter(s.conn).Write(&adc.Message{Header: adc.SUP.SetType('I')}) } } |