Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private void Coreloop()
- {
- while (m_IsSending)
- {
- if (m_SendingQueue.HasPackets())
- {
- SendingData sendableData = m_SendingQueue.SendingQueue.Dequeue();
- switch (sendableData.Type)
- {
- case PacketType.SendToOne:
- sendableData.Receiver.BeginSend(sendableData.Buffer.ToArray(), 0,
- sendableData.Buffer.ToArray().Length,
- SocketFlags.None,
- new AsyncCallback(SendCallBack), null);
- break;
- case PacketType.SendToAll:
- foreach (Client c in m_Server.ConnectedClients.Values)
- {
- c.Socket.BeginSend(sendableData.Buffer.ToArray(), 0,
- sendableData.Buffer.ToArray().Length,
- SocketFlags.None,
- new AsyncCallback(SendCallBack), null);
- }
- break;
- case PacketType.SendToAllExcept:
- foreach (Client c in m_Server.ConnectedClients.Values)
- {
- if (c.Socket != sendableData.Receiver)
- {
- c.Socket.BeginSend(sendableData.Buffer.ToArray(), 0,
- sendableData.Buffer.ToArray().Length,
- SocketFlags.None,
- new AsyncCallback(SendCallBack), null);
- }
- }
- break;
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement