139 } |
139 } |
140 (pThis->mOpenMonitor)->notify(); |
140 (pThis->mOpenMonitor)->notify(); |
141 |
141 |
142 |
142 |
143 int rt = -1; |
143 int rt = -1; |
144 char * addr = new char[MAX_SIZE]; |
144 //char * addr = new char[MAX_SIZE]; |
145 |
145 |
146 if (rt < 0 && pThis->mKeepRunning) |
146 if (rt < 0 && pThis->mKeepRunning) |
147 { |
147 { |
148 char *buf = new char[BUFFER_SIZE]; |
148 char *buf = new char[BUFFER_SIZE]; |
149 // wchar_t * sender = new wchar_t[256]; |
149 // wchar_t * sender = new wchar_t[256]; |
150 char * sender = new char[256]; |
150 //char * sender = new char[256]; |
151 while (match == false) |
151 while (match == false) |
152 { |
152 { |
153 rt = recvfrom(pThis->mListenDatagram, buf, BUFFER_SIZE, 0, |
153 rt = recvfrom(pThis->mListenDatagram, buf, BUFFER_SIZE, 0, |
154 (sockaddr*) &sender_addr, &size); |
154 (sockaddr*) &sender_addr, &size); |
155 |
155 delete[] buf; |
156 strcpy(sender,inet_ntoa(sender_addr.sin_addr)); |
156 //strcpy(sender,inet_ntoa(sender_addr.sin_addr));// Do we need this? |
|
157 //delete[] sender; |
157 ILOG2(ESOCKET, "pThis->mListenDatagram = %d, port = %d",pThis-> mListenDatagram,pThis->mPort); |
158 ILOG2(ESOCKET, "pThis->mListenDatagram = %d, port = %d",pThis-> mListenDatagram,pThis->mPort); |
158 |
159 |
159 // validate the filter |
160 // validate the filter |
160 /*if(strcmp((const char *)pThis->mFilter.c_str(),(const char *) NULL)== 0) |
161 /*if(strcmp((const char *)pThis->mFilter.c_str(),(const char *) NULL)== 0) |
161 { |
162 { |