1. wxWindow::IsTopLevel() added and documented

[wxWidgets.git] / src / common / sckint.cpp

diff --git a/src/common/sckint.cpp b/src/common/sckint.cpp
index 925ffebf7a2d79463f63c8e4d7cb97f619e51b9a..8531c9b3a929b054c038023f924010e2a5816d2f 100644 (file)
--- a/src/common/sckint.cpp
+++ b/src/common/sckint.cpp
@@ -100,7 +100,9 @@ void SocketWaiter::ProcessReadEvent()
   int ret;
   char c;
 
   int ret;
   char c;
 

+  m_internal->AcquireFD();

   ret = recv(m_fd, &c, 1, MSG_PEEK);
   ret = recv(m_fd, &c, 1, MSG_PEEK);

+  m_internal->ReleaseFD();

   
   // We are a server => emit a EVT_ACCEPT event.
   if (ret == -1 && m_socket->GetType() == wxSocketBase::SOCK_SERVER) {
   
   // We are a server => emit a EVT_ACCEPT event.
   if (ret == -1 && m_socket->GetType() == wxSocketBase::SOCK_SERVER) {


@@ -114,6 +116,7 @@ void SocketWaiter::ProcessReadEvent()
     m_socket->OnRequest(wxSocketBase::EVT_READ);
   } else {
     m_socket->OnRequest(wxSocketBase::EVT_LOST);
     m_socket->OnRequest(wxSocketBase::EVT_READ);
   } else {
     m_socket->OnRequest(wxSocketBase::EVT_LOST);

+    m_internal->ReleaseData();  // In that case, we mustn't forget to unlock the mutex.

     Exit(NULL);
   }
 }
     Exit(NULL);
   }
 }


@@ -141,6 +144,8 @@ void *SocketWaiter::Entry()
     FD_ZERO(&sockrd_set);
     FD_ZERO(&sockwr_set);
 
     FD_ZERO(&sockrd_set);
     FD_ZERO(&sockwr_set);
 

+    m_internal->AcquireData();
+

     if ((m_socket->NeededReq() & READ_MASK) != 0)
       FD_SET(m_fd, &sockrd_set);
     if ((m_socket->NeededReq() & WRITE_MASK) != 0)
     if ((m_socket->NeededReq() & READ_MASK) != 0)
       FD_SET(m_fd, &sockrd_set);
     if ((m_socket->NeededReq() & WRITE_MASK) != 0)


@@ -156,20 +161,20 @@ void *SocketWaiter::Entry()
     if (FD_ISSET(m_fd, &sockwr_set))
       ProcessWriteEvent();
 
     if (FD_ISSET(m_fd, &sockwr_set))
       ProcessWriteEvent();
 

+    m_internal->ReleaseData();
+

 #if wxUSE_THREADS
 #ifdef Yield
 #undef Yield
 #endif
 #endif
 
 #if wxUSE_THREADS
 #ifdef Yield
 #undef Yield
 #endif
 #endif
 

-    if (ret == 0)
-      // If nothing happened, we wait for 100 ms.
-      wxUsleep(10);
+   // We wait for 100 ms to prevent the CPU from burning.
+   wxUsleep(100);

 
     // Check whether we should exit.
 
     // Check whether we should exit.

-    if (TestDestroy()) {
+    if (TestDestroy())

       return NULL;
       return NULL;

-    }

   }
   return NULL;
 }
   }
   return NULL;
 }


@@ -180,7 +185,10 @@ void *SocketWaiter::Entry()
 
 SocketRequester::SocketRequester(wxSocketBase *socket,
                                 wxSocketInternal *internal)
 
 SocketRequester::SocketRequester(wxSocketBase *socket,
                                 wxSocketInternal *internal)

-  : wxThread(),
+  :
+#if wxUSE_THREADS
+    wxThread(),
+#endif

     m_socket(socket), m_internal(internal), m_fd(internal->GetFD())
 {
 }
     m_socket(socket), m_internal(internal), m_fd(internal->GetFD())
 {
 }


@@ -199,12 +207,12 @@ bool SocketRequester::WaitFor(wxSocketBase::wxRequestNotify req, int millisec)
   tv.tv_sec = millisec / 1000;
   tv.tv_usec = (millisec % 1000) * 1000;
 
   tv.tv_sec = millisec / 1000;
   tv.tv_usec = (millisec % 1000) * 1000;
 

-  if ((req & READ_MASK) != 0)  
-    FD_ZERO(&sockrd_set);
+  FD_ZERO(&sockrd_set);

   FD_ZERO(&sockwr_set);
   FD_ZERO(&sockwr_set);

-
-  FD_SET(m_fd, &sockrd_set);
-  FD_SET(m_fd, &sockwr_set);
+  if ((req & READ_MASK) != 0)  
+    FD_SET(m_fd, &sockrd_set);
+  if ((req & WRITE_MASK) != 0)
+    FD_SET(m_fd, &sockwr_set);

   
   m_internal->AcquireFD();
   ret = select(m_fd+1, &sockrd_set, &sockwr_set, NULL, &tv);
   
   m_internal->AcquireFD();
   ret = select(m_fd+1, &sockrd_set, &sockwr_set, NULL, &tv);


@@ -242,6 +250,9 @@ void SocketRequester::ProcessReadEvent(SockRequest *req)
     req->size -= len;
     req->io_nbytes += len;
     req->buffer += len;
     req->size -= len;
     req->io_nbytes += len;
     req->buffer += len;

+
+    if (len == 0)
+      m_internal->EndRequest(req); 

     return;
   }
   // The End.
     return;
   }
   // The End.


@@ -332,21 +343,17 @@ void *SocketRequester::Entry()
 wxSocketInternal::wxSocketInternal(wxSocketBase *socket)
 {
   m_socket = socket;
 wxSocketInternal::wxSocketInternal(wxSocketBase *socket)
 {
   m_socket = socket;

-#if wxUSE_THREADS

   m_thread_requester = NULL;
   m_thread_waiter = NULL;
   m_invalid_requester = TRUE;
   m_thread_requester = NULL;
   m_thread_waiter = NULL;
   m_invalid_requester = TRUE;

-#endif

 }
 
 wxSocketInternal::~wxSocketInternal()
 {
 }
 
 wxSocketInternal::~wxSocketInternal()
 {

-#if wxUSE_THREADS

   StopRequester();
   wxASSERT(m_thread_requester == NULL);
   StopWaiter();
   wxASSERT(m_thread_waiter == NULL);
   StopRequester();
   wxASSERT(m_thread_requester == NULL);
   StopWaiter();
   wxASSERT(m_thread_waiter == NULL);

-#endif

 }
 
 // ----------------------------------------------------------------------
 }
 
 // ----------------------------------------------------------------------


@@ -358,10 +365,12 @@ SockRequest *wxSocketInternal::WaitForReq()
 #if wxUSE_THREADS
   wxNode *node;
 
 #if wxUSE_THREADS
   wxNode *node;
 

+  // First try.

   node = m_requests.First();
   if (node == NULL) {
     m_socket_cond.Wait(m_request_locker, 10, 0);
 
   node = m_requests.First();
   if (node == NULL) {
     m_socket_cond.Wait(m_request_locker, 10, 0);
 

+    // Second try, if it is unsuccessul we give up.

     node = m_requests.First();
     if (node == NULL)
       return NULL;
     node = m_requests.First();
     if (node == NULL)
       return NULL;


@@ -387,6 +396,20 @@ void wxSocketInternal::EndRequest(SockRequest *req)
     delete node;
 }
 
     delete node;
 }
 

+void wxSocketInternal::AcquireData()
+{
+#if wxUSE_THREADS
+  m_socket_locker.Lock();
+#endif
+}
+
+void wxSocketInternal::ReleaseData()
+{
+#if wxUSE_THREADS
+  m_socket_locker.Unlock();
+#endif
+}
+

 void wxSocketInternal::AcquireFD()
 {
 #if wxUSE_THREADS
 void wxSocketInternal::AcquireFD()
 {
 #if wxUSE_THREADS


@@ -406,14 +429,17 @@ void wxSocketInternal::ResumeRequester()
 #if wxUSE_THREADS
   wxThreadError err;
 
 #if wxUSE_THREADS
   wxThreadError err;
 

-  wxASSERT(m_thread_requester == NULL || m_invalid_requester);
+  wxASSERT(m_invalid_requester);

 
   m_end_requester.Lock();
 
   m_end_requester.Lock();

-  if (m_invalid_requester) {
-    if (m_thread_requester != NULL)
-      delete m_thread_requester;
-    m_invalid_requester = FALSE;
+
+  if (m_thread_requester != NULL) {
+    m_thread_requester->Delete(); // We must join it.
+    delete m_thread_requester;

   }
   }

+
+  m_invalid_requester = FALSE;
+

   m_end_requester.Unlock();
 
   m_thread_requester = new SocketRequester(m_socket, this);
   m_end_requester.Unlock();
 
   m_thread_requester = new SocketRequester(m_socket, this);


@@ -423,7 +449,11 @@ void wxSocketInternal::ResumeRequester()
 
   err = m_thread_requester->Run();
   wxASSERT(err == wxTHREAD_NO_ERROR);
 
   err = m_thread_requester->Run();
   wxASSERT(err == wxTHREAD_NO_ERROR);

-
+#else
+  if (!m_invalid_requester) 
+    return;
+  m_thread_requester = new SocketRequester(m_socket, this);
+  m_invalid_requester = FALSE;

 #endif
 }
 
 #endif
 }
 


@@ -433,27 +463,35 @@ void wxSocketInternal::StopRequester()
   m_end_requester.Lock();
   if (m_invalid_requester) {
     m_end_requester.Unlock();
   m_end_requester.Lock();
   if (m_invalid_requester) {
     m_end_requester.Unlock();

-    delete m_thread_requester;
-    m_thread_requester = NULL;
-    m_invalid_requester = FALSE;
+    if (m_thread_requester) {
+      m_thread_requester->Delete();
+      delete m_thread_requester;
+      m_thread_requester = NULL;
+    }
+    m_invalid_requester = TRUE;

     return;
   }
   m_end_requester.Unlock();
 
   wxASSERT(m_thread_requester != NULL);
 
     return;
   }
   m_end_requester.Unlock();
 
   wxASSERT(m_thread_requester != NULL);
 

-  m_socket_locker.Lock();
+  m_request_locker.Lock();

 
   // Send a signal to the requester.
   m_socket_cond.Signal();
 
 
   // Send a signal to the requester.
   m_socket_cond.Signal();
 

-  m_socket_locker.Unlock();
+  m_request_locker.Unlock();

 
   // Finish the destruction of the requester.
   m_thread_requester->Delete();
 
   delete m_thread_requester;
   m_thread_requester = NULL;
 
   // Finish the destruction of the requester.
   m_thread_requester->Delete();
 
   delete m_thread_requester;
   m_thread_requester = NULL;

+  m_invalid_requester = TRUE;
+#else
+  delete m_thread_requester;
+  m_thread_requester = NULL;
+  m_invalid_requester = TRUE;

 #endif
 }
 
 #endif
 }
 


@@ -467,6 +505,8 @@ void wxSocketInternal::ResumeWaiter()
 
   m_thread_waiter = new SocketWaiter(m_socket, this);
 
 
   m_thread_waiter = new SocketWaiter(m_socket, this);
 

+  m_thread_waiter->SetPriority(WXTHREAD_MIN_PRIORITY);
+

   err = m_thread_waiter->Create();
   wxASSERT(err == wxTHREAD_NO_ERROR);
 
   err = m_thread_waiter->Create();
   wxASSERT(err == wxTHREAD_NO_ERROR);
 


@@ -493,14 +533,10 @@ void wxSocketInternal::StopWaiter()
 // ----------------------------------------------------------------------
 void wxSocketInternal::QueueRequest(SockRequest *request, bool async)
 {
 // ----------------------------------------------------------------------
 void wxSocketInternal::QueueRequest(SockRequest *request, bool async)
 {

-#if wxUSE_THREADS
-/*

   if (m_invalid_requester)
     ResumeRequester();
   if (m_invalid_requester)
     ResumeRequester();

-*/
-  m_thread_requester = new SocketRequester(m_socket, this);

 
 

-/*
+#if wxUSE_THREADS

   if (async) {
 
     m_request_locker.Lock();
   if (async) {
 
     m_request_locker.Lock();


@@ -522,8 +558,8 @@ void wxSocketInternal::QueueRequest(SockRequest *request, bool async)
         }
     }
   } else {
         }
     }
   } else {

-*/

     m_request_locker.Lock();
     m_request_locker.Lock();

+#endif

 
     if ((request->type & wxSocketBase::REQ_WAIT) != 0) {
       m_thread_requester->ProcessWaitEvent(request);
 
     if ((request->type & wxSocketBase::REQ_WAIT) != 0) {
       m_thread_requester->ProcessWaitEvent(request);


@@ -542,10 +578,9 @@ void wxSocketInternal::QueueRequest(SockRequest *request, bool async)
       }
     }
     request->done = TRUE;
       }
     }
     request->done = TRUE;

+#if wxUSE_THREADS

     m_request_locker.Unlock();
     m_request_locker.Unlock();

-//  }
-  delete m_thread_requester;
-  m_thread_requester = NULL;
+  }

 #endif
 }
 
 #endif
 }