renamed RemoveMessageFromSendQueueByCmdID to RemoveSendMessageFromQueueByCmdID
parent
00fb629921
commit
0b65decaa3
|
@ -55,16 +55,16 @@ func (mcClient *MinecraftClient) AddMessageToSendQueue(raw []byte, cmdID int) {
|
||||||
mcClient.SendQueueMessages = append(mcClient.SendQueueMessages, &SendQueueMessage{MessageRaw: raw, CmdID: cmdID, TrySendCount: 0, Time: time.Now()})
|
mcClient.SendQueueMessages = append(mcClient.SendQueueMessages, &SendQueueMessage{MessageRaw: raw, CmdID: cmdID, TrySendCount: 0, Time: time.Now()})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (mcClient *MinecraftClient) RemoveSendMessageFromQueueByCmdID(cmdID int) {
|
func (mcClient *MinecraftClient) RemoveMessageFromSendQueueByCmdID(cmdID int) {
|
||||||
mcClient.sendQueueMessagesMu.Lock()
|
mcClient.sendQueueMessagesMu.Lock()
|
||||||
defer mcClient.sendQueueMessagesMu.Unlock()
|
defer mcClient.sendQueueMessagesMu.Unlock()
|
||||||
|
|
||||||
for index, message := range mcClient.SendQueueMessages {
|
for index, message := range mcClient.SendQueueMessages {
|
||||||
if message.CmdID == cmdID {
|
if message.CmdID == cmdID {
|
||||||
logger.Minecraft.Debugln("RemoveSendMessageFromQueueByCmdID before", mcClient.SendQueueMessages)
|
logger.Minecraft.Debugln("RemoveMessageFromSendQueueByCmdID before", mcClient.SendQueueMessages)
|
||||||
newArr := append(mcClient.SendQueueMessages[:index], mcClient.SendQueueMessages[index+1:]...)
|
newArr := append(mcClient.SendQueueMessages[:index], mcClient.SendQueueMessages[index+1:]...)
|
||||||
mcClient.SendQueueMessages = newArr
|
mcClient.SendQueueMessages = newArr
|
||||||
logger.Minecraft.Debugln("RemoveSendMessageFromQueueByCmdID after", mcClient.SendQueueMessages)
|
logger.Minecraft.Debugln("RemoveMessageFromSendQueueByCmdID after", mcClient.SendQueueMessages)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue