e2m/goircd
4
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Unnecessary message broadcasting goroutines

Browse Source
This commit is contained in:
Sergey Matveev 2014-05-18 15:26:50 +04:00
parent cda982f7e9
commit 216a9dc05e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
room.go
View File

@ -87,7 +87,7 @@ func (room *Room) Processor(events chan ClientEvent) {
room.members[client] = true room.members[client] = true
log.Println(client, "joined", room.name) log.Println(client, "joined", room.name)
room.SendTopic(client) room.SendTopic(client)
go room.Broadcast(fmt.Sprintf(":%s JOIN %s", client, room.name)) room.Broadcast(fmt.Sprintf(":%s JOIN %s", client, room.name))
room.log_sink <- LogEvent{room.name, client.nickname, "joined", true} room.log_sink <- LogEvent{room.name, client.nickname, "joined", true}
nicknames := []string{} nicknames := []string{}
for member := range room.members { for member := range room.members {
@ -163,7 +163,7 @@ func (room *Room) Processor(events chan ClientEvent) {
room.StateSave() room.StateSave()
case EVENT_MSG: case EVENT_MSG:
sep := strings.Index(event.text, " ") sep := strings.Index(event.text, " ")
go room.Broadcast(fmt.Sprintf(":%s %s %s :%s", client, event.text[:sep], room.name, event.text[sep+1:]), client) room.Broadcast(fmt.Sprintf(":%s %s %s :%s", client, event.text[:sep], room.name, event.text[sep+1:]), client)
room.log_sink <- LogEvent{room.name, client.nickname, event.text[sep+1:], false} room.log_sink <- LogEvent{room.name, client.nickname, event.text[sep+1:], false}
} }
} }