hostname *string
motd *string
passwords *string
- clients map[*Client]bool
+ clients map[*Client]struct{}
clientAliveness map[*Client]*ClientAlivenessState
rooms map[string]*Room
roomSinks map[*Room]chan ClientEvent
func NewDaemon(version string, hostname, motd, passwords *string, logSink chan<- LogEvent, stateSink chan<- StateEvent) *Daemon {
daemon := Daemon{
- version: version,
- hostname: hostname,
- motd: motd,
+ version: version,
+ hostname: hostname,
+ motd: motd,
passwords: passwords,
}
- daemon.clients = make(map[*Client]bool)
+ daemon.clients = make(map[*Client]struct{})
daemon.clientAliveness = make(map[*Client]*ClientAlivenessState)
daemon.rooms = make(map[string]*Room)
daemon.roomSinks = make(map[*Room]chan ClientEvent)
}
func (daemon *Daemon) Processor(events <-chan ClientEvent) {
+ var now time.Time
for event := range events {
- now := time.Now()
+ now = time.Now()
client := event.client
// Check for clients aliveness
switch event.eventType {
case EventNew:
- daemon.clients[client] = true
+ daemon.clients[client] = struct{}{}
daemon.clientAliveness[client] = &ClientAlivenessState{
- pingSent: false,
+ pingSent: false,
timestamp: now,
}
case EventDel:
mode := os.O_CREATE | os.O_WRONLY | os.O_APPEND
perm := os.FileMode(0660)
var format string
+ var logfile string
+ var fd *os.File
+ var err error
for event := range events {
- logfile := path.Join(logdir, event.where)
- fd, err := os.OpenFile(logfile, mode, perm)
+ logfile = path.Join(logdir, event.where)
+ fd, err = os.OpenFile(logfile, mode, perm)
if err != nil {
log.Println("Can not open logfile", logfile, err)
continue
// Room states shows that either topic or key has been changed
// Each room's state is written to separate file in statedir
func StateKeeper(statedir string, events <-chan StateEvent) {
+ var fn string
+ var data string
+ var err error
for event := range events {
- fn := path.Join(statedir, event.where)
- data := event.topic + "\n" + event.key + "\n"
- err := ioutil.WriteFile(fn, []byte(data), os.FileMode(0660))
+ fn = path.Join(statedir, event.where)
+ data = event.topic + "\n" + event.key + "\n"
+ err = ioutil.WriteFile(fn, []byte(data), os.FileMode(0660))
if err != nil {
log.Printf("Can not write statefile %s: %v", fn, err)
}