diff options
| author | Samuel Stauffer <[email protected]> | 2014-03-19 14:18:21 -0700 |
|---|---|---|
| committer | Samuel Stauffer <[email protected]> | 2014-03-19 14:18:21 -0700 |
| commit | 706c1cdc687158e370b72181f3a0e88f5156309b (patch) | |
| tree | 17c4e74628a070d692655add20ee513ac5ab5a71 /conn.go | |
| parent | 67312503d2a9166d5547734d36dcd5ecc70174cf (diff) | |
Short writes don't happen without an error so don't loop
Diffstat (limited to 'conn.go')
| -rw-r--r-- | conn.go | 17 |
1 files changed, 5 insertions, 12 deletions
@@ -226,18 +226,11 @@ func (l *Conn) processMessages() { l.chanResults[messagePacket.MessageID] = messagePacket.Channel // go routine buf := messagePacket.Packet.Bytes() - for len(buf) > 0 { - n, err := l.conn.Write(buf) - if err != nil { - l.Debug.Printf("Error Sending Message: %s", err.Error()) - break - } - // nothing else to send - if n == len(buf) { - break - } - // the remaining buf content - buf = buf[n:] + + _, err := l.conn.Write(buf) + if err != nil { + l.Debug.Printf("Error Sending Message: %s", err.Error()) + break } case MessageResponse: l.Debug.Printf("Receiving message %d", messagePacket.MessageID) |
