This commit is contained in:
Erik 2015-04-15 09:48:03 -04:00
parent 4be6b58150
commit 269bb5a943
2 changed files with 8 additions and 12 deletions

View File

@ -35,7 +35,7 @@ private struct SocketAck: Hashable, Equatable {
self.ack = ack self.ack = ack
} }
init(ack:Int, callback:AckCallback?) { init(ack:Int, callback:AckCallback) {
self.ack = ack self.ack = ack
self.callback = callback self.callback = callback
} }
@ -65,6 +65,10 @@ struct SocketAckMap {
} }
mutating func timeoutAck(ack:Int) { mutating func timeoutAck(ack:Int) {
self.acks.remove(SocketAck(ack: ack))?.callback(["NO ACK"]) let callback = self.acks.remove(SocketAck(ack: ack))
dispatch_async(dispatch_get_main_queue()) {
callback?.callback(["NO ACK"])
}
} }
} }

View File

@ -77,22 +77,14 @@ final class SocketPacket: Printable {
} }
func addData(data:NSData) -> Bool { func addData(data:NSData) -> Bool {
func checkDoEvent() -> Bool { if self.placeholders == self.currentPlace {
if self.placeholders == self.currentPlace {
return true
} else {
return false
}
}
if checkDoEvent() {
return true return true
} }
self.binary.append(data) self.binary.append(data)
self.currentPlace++ self.currentPlace++
if checkDoEvent() { if self.placeholders == self.currentPlace {
self.currentPlace = 0 self.currentPlace = 0
return true return true
} else { } else {