From a82c423725474270db27232cda4e4e2cd772a60d Mon Sep 17 00:00:00 2001
From: kpl <kevin@larke.org>
Date: Tue, 12 Jan 2021 17:05:34 -0500
Subject: [PATCH] cwWebSock.cpp: replace use of MpScNbQueue until MpScQueue can
 be debugged.

---
 cwWebSock.cpp | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/cwWebSock.cpp b/cwWebSock.cpp
index c6207e8..16ddfd7 100644
--- a/cwWebSock.cpp
+++ b/cwWebSock.cpp
@@ -3,9 +3,8 @@
 #include "cwCommonImpl.h"
 #include "cwMem.h"
 #include "cwFileSys.h"
-#include "cwMutex.h"
 #include "cwWebSock.h"
-#include "cwMpScQueue.h"
+#include "cwMpScNbQueue.h"
 
 #include <libwebsockets.h>
 
@@ -36,7 +35,7 @@ namespace cw
       unsigned               _nextSessionId = 0;       // Next session id.
       unsigned               _connSessionN  = 0;       // Count of connected sessions.
       struct lws_http_mount* _mount         = nullptr; //
-      MpScQueue<msg_t>*    _q; // Thread safe, non-blocking, protocol independent msg queue.
+      MpScNbQueue<msg_t>*    _q; // Thread safe, non-blocking, protocol independent msg queue.
 
       lws_pollfd* _pollfdA;     // socket handle array used by poll()
       int         _pollfdMaxN;
@@ -445,7 +444,7 @@ cw::rc_t cw::websock::create(
   info.mounts    = p->_mount;
   info.protocols = p->_protocolA;
 
-  p->_q = new MpScQueue<msg_t>();
+  p->_q = new MpScNbQueue<msg_t>();
   p->_cbFunc = cbFunc;
   p->_cbArg  = cbArg;