void SocketManager::Close(ConnectionID connectionID) {
{
- std::unique_lock<std::mutex> ulock(m_eventQueueMutex);
+ std::lock_guard<std::mutex> ulock(m_eventQueueMutex);
m_closeQueue.push(connectionID);
}
NotifyMe();
buffer.connectionID = connectionID;
buffer.rawBuffer = rawBuffer;
{
- std::unique_lock<std::mutex> ulock(m_eventQueueMutex);
+ std::lock_guard<std::mutex> ulock(m_eventQueueMutex);
m_writeBufferQueue.push(buffer);
}
NotifyMe();
data.connectionID = connectionID;
data.sendMsgData = sendMsgData;
{
- std::unique_lock<std::mutex> ulock(m_eventQueueMutex);
+ std::lock_guard<std::mutex> ulock(m_eventQueueMutex);
m_writeDataQueue.push(data);
}
NotifyMe();
WriteBuffer buffer;
WriteData data;
{
- std::unique_lock<std::mutex> ulock(m_eventQueueMutex);
+ std::lock_guard<std::mutex> ulock(m_eventQueueMutex);
while (!m_writeBufferQueue.empty()) {
buffer = m_writeBufferQueue.front();
m_writeBufferQueue.pop();
while (1) {
ConnectionID connection;
{
- std::unique_lock<std::mutex> ulock(m_eventQueueMutex);
+ std::lock_guard<std::mutex> ulock(m_eventQueueMutex);
if (m_closeQueue.empty())
return;
connection = m_closeQueue.front();