mirror of
https://github.com/SoftEtherVPN/SoftEtherVPN.git
synced 2025-06-28 20:05:08 +03:00
spelling: received
This commit is contained in:
parent
5f2ac8236b
commit
e9b3ed2335
@ -892,7 +892,7 @@ void PutUDPPacketData(CONNECTION *c, void *data, UINT size)
|
|||||||
block = NewBlock(tmp, size, 0);
|
block = NewBlock(tmp, size, 0);
|
||||||
|
|
||||||
// Insert Block
|
// Insert Block
|
||||||
InsertReveicedBlockToQueue(c, block, false);
|
InsertReceivedBlockToQueue(c, block, false);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -909,7 +909,7 @@ void PutUDPPacketData(CONNECTION *c, void *data, UINT size)
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Add a block to the receive queue
|
// Add a block to the receive queue
|
||||||
void InsertReveicedBlockToQueue(CONNECTION *c, BLOCK *block, bool no_lock)
|
void InsertReceivedBlockToQueue(CONNECTION *c, BLOCK *block, bool no_lock)
|
||||||
{
|
{
|
||||||
SESSION *s;
|
SESSION *s;
|
||||||
// Validate arguments
|
// Validate arguments
|
||||||
@ -1831,7 +1831,7 @@ void ConnectionReceive(CONNECTION *c, CANCEL *c1, CANCEL *c2)
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
// Add the data block to queue
|
// Add the data block to queue
|
||||||
InsertReveicedBlockToQueue(c, b, true);
|
InsertReceivedBlockToQueue(c, b, true);
|
||||||
|
|
||||||
if ((current_packet_index % 32) == 0)
|
if ((current_packet_index % 32) == 0)
|
||||||
{
|
{
|
||||||
@ -1914,7 +1914,7 @@ void ConnectionReceive(CONNECTION *c, CANCEL *c1, CANCEL *c2)
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
// Add the data block to queue
|
// Add the data block to queue
|
||||||
InsertReveicedBlockToQueue(c, block, true);
|
InsertReceivedBlockToQueue(c, block, true);
|
||||||
|
|
||||||
if ((current_packet_index % 32) == 0)
|
if ((current_packet_index % 32) == 0)
|
||||||
{
|
{
|
||||||
@ -1979,7 +1979,7 @@ void ConnectionReceive(CONNECTION *c, CANCEL *c1, CANCEL *c2)
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
// Add the data block to queue
|
// Add the data block to queue
|
||||||
InsertReveicedBlockToQueue(c, block, true);
|
InsertReceivedBlockToQueue(c, block, true);
|
||||||
|
|
||||||
if ((current_packet_index % 32) == 0)
|
if ((current_packet_index % 32) == 0)
|
||||||
{
|
{
|
||||||
@ -2208,7 +2208,7 @@ DISCONNECT_THIS_TCP:
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
// Add the data block to queue
|
// Add the data block to queue
|
||||||
InsertReveicedBlockToQueue(c, block, true);
|
InsertReceivedBlockToQueue(c, block, true);
|
||||||
|
|
||||||
if ((current_packet_index % 32) == 0)
|
if ((current_packet_index % 32) == 0)
|
||||||
{
|
{
|
||||||
@ -2477,7 +2477,7 @@ DISCONNECT_THIS_TCP:
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
// Add the data block to queue
|
// Add the data block to queue
|
||||||
InsertReveicedBlockToQueue(c, block, true);
|
InsertReceivedBlockToQueue(c, block, true);
|
||||||
}
|
}
|
||||||
num++;
|
num++;
|
||||||
if (num >= MAX_SEND_SOCKET_QUEUE_NUM)
|
if (num >= MAX_SEND_SOCKET_QUEUE_NUM)
|
||||||
@ -2558,7 +2558,7 @@ DISCONNECT_THIS_TCP:
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
InsertReveicedBlockToQueue(c, block, true);
|
InsertReceivedBlockToQueue(c, block, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
num++;
|
num++;
|
||||||
@ -2675,7 +2675,7 @@ DISCONNECT_THIS_TCP:
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
InsertReveicedBlockToQueue(c, block, true);
|
InsertReceivedBlockToQueue(c, block, true);
|
||||||
}
|
}
|
||||||
num++;
|
num++;
|
||||||
if (num >= MAX_SEND_SOCKET_QUEUE_NUM)
|
if (num >= MAX_SEND_SOCKET_QUEUE_NUM)
|
||||||
|
@ -352,7 +352,7 @@ void SendKeepAlive(CONNECTION *c, TCPSOCK *ts);
|
|||||||
void DisconnectUDPSockets(CONNECTION *c);
|
void DisconnectUDPSockets(CONNECTION *c);
|
||||||
void PutUDPPacketData(CONNECTION *c, void *data, UINT size);
|
void PutUDPPacketData(CONNECTION *c, void *data, UINT size);
|
||||||
void SendDataWithUDP(SOCK *s, CONNECTION *c);
|
void SendDataWithUDP(SOCK *s, CONNECTION *c);
|
||||||
void InsertReveicedBlockToQueue(CONNECTION *c, BLOCK *block, bool no_lock);
|
void InsertReceivedBlockToQueue(CONNECTION *c, BLOCK *block, bool no_lock);
|
||||||
void InitTcpSockRc4Key(TCPSOCK *ts, bool server_mode);
|
void InitTcpSockRc4Key(TCPSOCK *ts, bool server_mode);
|
||||||
UINT TcpSockRecv(SESSION *s, TCPSOCK *ts, void *data, UINT size);
|
UINT TcpSockRecv(SESSION *s, TCPSOCK *ts, void *data, UINT size);
|
||||||
UINT TcpSockSend(SESSION *s, TCPSOCK *ts, void *data, UINT size);
|
UINT TcpSockSend(SESSION *s, TCPSOCK *ts, void *data, UINT size);
|
||||||
|
@ -561,7 +561,7 @@ IPC *NewIPC(CEDAR *cedar, char *client_name, char *postfix, char *hubname, char
|
|||||||
ipc->ArpTable = NewList(IPCCmpArpTable);
|
ipc->ArpTable = NewList(IPCCmpArpTable);
|
||||||
|
|
||||||
// Create an IPv4 reception queue
|
// Create an IPv4 reception queue
|
||||||
ipc->IPv4RecviedQueue = NewQueue();
|
ipc->IPv4ReceivedQueue = NewQueue();
|
||||||
|
|
||||||
return ipc;
|
return ipc;
|
||||||
|
|
||||||
@ -601,7 +601,7 @@ IPC *NewIPCBySock(CEDAR *cedar, SOCK *s, void *mac_address)
|
|||||||
ipc->ArpTable = NewList(IPCCmpArpTable);
|
ipc->ArpTable = NewList(IPCCmpArpTable);
|
||||||
|
|
||||||
// Create an IPv4 reception queue
|
// Create an IPv4 reception queue
|
||||||
ipc->IPv4RecviedQueue = NewQueue();
|
ipc->IPv4ReceivedQueue = NewQueue();
|
||||||
|
|
||||||
ipc->FlushList = NewTubeFlushList();
|
ipc->FlushList = NewTubeFlushList();
|
||||||
|
|
||||||
@ -671,7 +671,7 @@ void FreeIPC(IPC *ipc)
|
|||||||
|
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
BLOCK *b = GetNext(ipc->IPv4RecviedQueue);
|
BLOCK *b = GetNext(ipc->IPv4ReceivedQueue);
|
||||||
if (b == NULL)
|
if (b == NULL)
|
||||||
{
|
{
|
||||||
break;
|
break;
|
||||||
@ -680,7 +680,7 @@ void FreeIPC(IPC *ipc)
|
|||||||
FreeBlock(b);
|
FreeBlock(b);
|
||||||
}
|
}
|
||||||
|
|
||||||
ReleaseQueue(ipc->IPv4RecviedQueue);
|
ReleaseQueue(ipc->IPv4ReceivedQueue);
|
||||||
|
|
||||||
Free(ipc);
|
Free(ipc);
|
||||||
}
|
}
|
||||||
@ -1626,7 +1626,7 @@ void IPCProcessL3EventsEx(IPC *ipc, UINT64 now)
|
|||||||
IPCAssociateOnArpTable(ipc, &ip_src, src_mac);
|
IPCAssociateOnArpTable(ipc, &ip_src, src_mac);
|
||||||
|
|
||||||
// Place in the reception queue
|
// Place in the reception queue
|
||||||
InsertQueue(ipc->IPv4RecviedQueue, NewBlock(data, size, 0));
|
InsertQueue(ipc->IPv4ReceivedQueue, NewBlock(data, size, 0));
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@ -2086,7 +2086,7 @@ BLOCK *IPCRecvIPv4(IPC *ipc)
|
|||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
b = GetNext(ipc->IPv4RecviedQueue);
|
b = GetNext(ipc->IPv4ReceivedQueue);
|
||||||
|
|
||||||
return b;
|
return b;
|
||||||
}
|
}
|
||||||
|
@ -206,7 +206,7 @@ struct IPC
|
|||||||
UCHAR MacAddress[6]; // MAC address
|
UCHAR MacAddress[6]; // MAC address
|
||||||
UCHAR Padding[2];
|
UCHAR Padding[2];
|
||||||
LIST *ArpTable; // ARP table
|
LIST *ArpTable; // ARP table
|
||||||
QUEUE *IPv4RecviedQueue; // IPv4 reception queue
|
QUEUE *IPv4ReceivedQueue; // IPv4 reception queue
|
||||||
TUBE_FLUSH_LIST *FlushList; // Tube Flush List
|
TUBE_FLUSH_LIST *FlushList; // Tube Flush List
|
||||||
UCHAR MsChapV2_ServerResponse[20]; // Server response
|
UCHAR MsChapV2_ServerResponse[20]; // Server response
|
||||||
DHCP_CLASSLESS_ROUTE_TABLE ClasslessRoute; // Classless routing table
|
DHCP_CLASSLESS_ROUTE_TABLE ClasslessRoute; // Classless routing table
|
||||||
|
@ -313,7 +313,7 @@ bool LinkPaPutPacket(SESSION *s, void *data, UINT size)
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
InsertReveicedBlockToQueue(server_connection, block, true);
|
InsertReceivedBlockToQueue(server_connection, block, true);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user