C / C++ / MFC

int on = 1, optlen = sizeof(on);
m_udpSocket.SetSockOpt(SO_BROADCAST,&on,optlen);

<br />
if (Connect(host, 9000) == SOCKET_ERROR)<br />
{<br />
AfxMessageBox("Error Connecting");<br />
errorCode = GetLastError();<br />
}<br />
if (Send(command, command.GetLength()) == SOCKET_ERROR)<br />
{<br />
AfxMessageBox("Error Sending Packet");<br />
errorCode = GetLastError();<br />
}<br />

ResetEvent(AddedToQueue_A)
WaitForSingleObject(AddedToQueue_A,INFINITE);

while(threadNeedstorun){<br />
       if(queueSize>0){<br />
       //Service Queue<br />
       }<br />
       // Block <br />
       WaitForSingleObject(AddedtoQueue_A,INFINITE)<br />
       // Awake <br />
  }<br />
<br />
here is the snippet of my Enqueue operation <br />
<br />
    if(queueSize<MAX_QUE_SIZE){<br />
<br />
       array[(head+queueSize)%MAX_QUE_SIZE]=newVal;<br />
       queueSize++;<br />
<br />
      SetEvent(AddedtoQueue_A) <br />
    }<br />

void DecrementElementsInA()
{
  EnterCriticalSection(CS_A);
  --queueSize;
  if(queueSize==0){
    ResetEvent(AddedtoQueue_A);
  }
  LeaveCriticalSection(CS_A);
}

IncrementElementsInA()
{
  EnterCriticalSection(CS_A);
  ++queueSize;
  if(queueSize>0){
    SetEvent(AddedtoQueue_A);
  }
  LeaveCriticalSection(CS_A);
}

CLogViewFrame *pLogViewFrame = dynamic_cast<CLogViewFrame *>(pObject);
ASSERT (pLogViewFrame);