diff options
author | Othmar Gsenger <otti@anytun.org> | 2008-04-12 11:38:42 +0000 |
---|---|---|
committer | Othmar Gsenger <otti@anytun.org> | 2008-04-12 11:38:42 +0000 |
commit | fffd213c8cba2135afda493d797c41c10354770e (patch) | |
tree | bb5eea1b12871d8c3fed0e687d83be3e504d11b2 /src/syncSocketHandler.cpp | |
parent | svn cleanup (diff) |
big svn cleanup
Diffstat (limited to 'src/syncSocketHandler.cpp')
-rw-r--r-- | src/syncSocketHandler.cpp | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/src/syncSocketHandler.cpp b/src/syncSocketHandler.cpp new file mode 100644 index 0000000..25f4c43 --- /dev/null +++ b/src/syncSocketHandler.cpp @@ -0,0 +1,38 @@ +//#include <sstream> +//#include <iostream> +//#include <string> +// +//#include <boost/archive/text_oarchive.hpp> +//#include <boost/archive/text_iarchive.hpp> + + +//#include "connectionParam.h" +//#include "Sockets/Utility.h" +#include "syncSocketHandler.h" +#include "syncListenSocket.h" +#include "syncSocket.h" +#include "connectionList.h" +//#include "buffer.h" +//#include "log.h" + +SyncSocketHandler::SyncSocketHandler(SyncQueue & queue) +:SocketHandler(),queue_(queue) +{ +} + +int SyncSocketHandler::Select(long sec,long usec) +{ + if(!queue_.empty()) + { + std::string sendstr = queue_.pop(); + for (socket_m::iterator it = m_sockets.begin(); it != m_sockets.end(); it++) + { + ::SOCKETS_NAMESPACE::Socket *p = (*it).second; + TcpSocket *p3 = dynamic_cast<TcpSocket *>(p); + //SyncListenSocket<SyncSocket,ConnectionList> *p4 = dynamic_cast<SyncListenSocket<SyncSocket,ConnectionList> *>(p); + if (p3) + p3->Send(sendstr); + } + } + return SocketHandler::Select(sec,usec); +} |