This commit is contained in:
@@ -49,11 +49,14 @@ func SendPacket(conn io.Writer, messageType uint16, datafn func(w io.Writer) err
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
binary.Write(conn, binary.LittleEndian, Packet{
|
||||
err = binary.Write(conn, binary.LittleEndian, Packet{
|
||||
Version: 1,
|
||||
MessageType: messageType,
|
||||
DataLength: uint16(len(data)),
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
packetsSent.Inc()
|
||||
_, err = conn.Write(data)
|
||||
return err
|
||||
|
||||
@@ -382,7 +382,7 @@ func (p *SyncedPool) OwnerChanged(id CartId, host string) error {
|
||||
}
|
||||
|
||||
func DoPing(host *RemoteHost) error {
|
||||
SendPacket(host.connection, Ping, func(w io.Writer) error {
|
||||
SendPacket(host, Ping, func(w io.Writer) error {
|
||||
return nil
|
||||
})
|
||||
_, err := host.Expect(Pong, time.Second)
|
||||
|
||||
Reference in New Issue
Block a user