GitHub/ergo
3
0
Fork 0
mirror of https://github.com/ergochat/ergo.git synced 2024-11-10 22:19:31 +01:00
Code Issues Projects Releases Wiki Activity

eliminate quitMutex

Browse Source
This commit is contained in:
Shivaram Lingamneni 2017-10-10 20:49:29 -04:00
parent b0649cb5d3
commit 545e8d71db
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
irc/client.go
View File

@ -70,7 +70,6 @@ type Client struct {
proxiedIP string // actual remote IP if using the PROXY protocol
quitMessage string
quitMessageSent bool
quitMutex sync.Mutex
quitTimer *time.Timer
rawHostname string
realname string
@ -505,19 +504,25 @@ func (client *Client) RplISupport() {
// Quit sends the given quit message to the client (but does not destroy them).
func (client *Client) Quit(message string) {
client.quitMutex.Lock()
defer client.quitMutex.Unlock()
if !client.quitMessageSent {
quitMsg := ircmsg.MakeMessage(nil, client.nickMaskString, "QUIT", message)
quitLine, _ := quitMsg.Line()
errorMsg := ircmsg.MakeMessage(nil, "", "ERROR", message)
errorLine, _ := errorMsg.Line()
client.socket.SetFinalData(quitLine + errorLine)
client.stateMutex.Lock()
alreadyQuit := client.quitMessageSent
if !alreadyQuit {
client.quitMessageSent = true
client.quitMessage = message
}
client.stateMutex.Unlock()
if alreadyQuit {
return
}
quitMsg := ircmsg.MakeMessage(nil, client.nickMaskString, "QUIT", message)
quitLine, _ := quitMsg.Line()
errorMsg := ircmsg.MakeMessage(nil, "", "ERROR", message)
errorLine, _ := errorMsg.Line()
client.socket.SetFinalData(quitLine + errorLine)
}
// destroy gets rid of a client, removes them from server lists etc.