aboutsummaryrefslogtreecommitdiffhomepage
path: root/protocol.c
diff options
context:
space:
mode:
authoreihrul <eihrul>2007-10-12 05:18:46 +0000
committereihrul <eihrul>2007-10-12 05:18:46 +0000
commit2852f791799eeeebe775f1b27af8b293eff91666 (patch)
tree9052b4a2a7791f2e5a025f3459851b04df6f8eb7 /protocol.c
parent870779bfb0bbb798aace21a76b4fd6b28eac60d1 (diff)
downloadenet-2852f791799eeeebe775f1b27af8b293eff91666.tar.gz
enet-2852f791799eeeebe775f1b27af8b293eff91666.zip
*** empty log message ***
Diffstat (limited to 'protocol.c')
-rw-r--r--protocol.c18
1 files changed, 12 insertions, 6 deletions
diff --git a/protocol.c b/protocol.c
index b950d7e..380500e 100644
--- a/protocol.c
+++ b/protocol.c
@@ -183,7 +183,11 @@ enet_protocol_remove_sent_reliable_command (ENetPeer * peer, enet_uint16 reliabl
reliableWindow = reliableSequenceNumber / ENET_PEER_RELIABLE_WINDOW_SIZE;
channel = & peer -> channels [channelID];
if (channel -> reliableWindows [reliableWindow] > 0)
- -- channel -> reliableWindows [reliableWindow];
+ {
+ -- channel -> reliableWindows [reliableWindow];
+ if (! channel -> reliableWindows [reliableWindow])
+ channel -> usedReliableWindows &= ~ (1 << reliableWindow);
+ }
commandNumber = outgoingCommand -> command.header.command & ENET_PROTOCOL_COMMAND_MASK;
@@ -292,7 +296,7 @@ enet_protocol_handle_connect (ENetHost * host, ENetProtocolHeader * header, ENet
enet_list_clear (& channel -> incomingReliableCommands);
enet_list_clear (& channel -> incomingUnreliableCommands);
- channel -> currentReliableWindow = 0;
+ channel -> usedReliableWindows = 0;
memset (channel -> reliableWindows, 0, sizeof (channel -> reliableWindows));
}
@@ -1168,9 +1172,11 @@ enet_protocol_send_reliable_outgoing_commands (ENetHost * host, ENetPeer * peer)
channel = outgoingCommand -> command.header.channelID < peer -> channelCount ? & peer -> channels [outgoingCommand -> command.header.channelID] : NULL;
reliableWindow = outgoingCommand -> reliableSequenceNumber / ENET_PEER_RELIABLE_WINDOW_SIZE;
- if (channel != NULL && outgoingCommand -> sendAttempts < 1 &&
- channel -> currentReliableWindow != reliableWindow &&
- channel -> reliableWindows [reliableWindow] > 0)
+ if (channel != NULL &&
+ outgoingCommand -> sendAttempts < 1 &&
+ ! (outgoingCommand -> reliableSequenceNumber % ENET_PEER_RELIABLE_WINDOW_SIZE) &&
+ channel -> usedReliableWindows & ((((1 << (ENET_PEER_RELIABLE_WINDOWS / 2)) - 1) << reliableWindow) |
+ (((1 << (ENET_PEER_RELIABLE_WINDOWS / 2)) - 1) >> (ENET_PEER_RELIABLE_WINDOW_SIZE - reliableWindow))))
break;
commandSize = commandSizes [outgoingCommand -> command.header.command & ENET_PROTOCOL_COMMAND_MASK];
@@ -1200,7 +1206,7 @@ enet_protocol_send_reliable_outgoing_commands (ENetHost * host, ENetPeer * peer)
if (channel != NULL && outgoingCommand -> sendAttempts < 1)
{
- if (channel -> currentReliableWindow != reliableWindow) channel -> currentReliableWindow = reliableWindow;
+ channel -> usedReliableWindows |= 1 << reliableWindow;
++ channel -> reliableWindows [reliableWindow];
}