fix socket busy loop; del locked readall; refactor.

lichao

2021-04-26 1b167ec5ad101ac44451381e26cc73ab5d67d2a1

 src/sendq.h

@@ -29,10 +29,7 @@
#include <string>
#include <unordered_map>

namespace bhome_shm
{
class ShmMsgQueue;
} // namespace bhome_shm

class SendQ
{
@@ -65,7 +62,7 @@
   {
      AppendData(addr, Data(std::move(content)), DefaultExpire(), onExpire);
   }
   bool TrySend(bhome_shm::ShmMsgQueue &mq);
   bool TrySend(ShmMsgQueue &mq);
   // bool empty() const { return store_.empty(); }

private:
@@ -88,8 +85,8 @@
   typedef std::list<Array> ArrayList;
   typedef std::unordered_map<Remote, ArrayList> Store;

   int DoSend1Remote(bhome_shm::ShmMsgQueue &mq, const Remote remote, Array &arr);
   int DoSend1Remote(bhome_shm::ShmMsgQueue &mq, const Remote remote, ArrayList &arr);
   int DoSend1Remote(ShmMsgQueue &mq, const Remote remote, Array &arr);
   int DoSend1Remote(ShmMsgQueue &mq, const Remote remote, ArrayList &arr);

   std::mutex mutex_in_;
   std::mutex mutex_out_;