default config for client1 with crypto
[anytun.git] / syncQueue.cpp
bloba24a4f56c79114a8f92535e6a7c34f3878367f80
1 /*
2 * anytun
4 * The secure anycast tunneling protocol (satp) defines a protocol used
5 * for communication between any combination of unicast and anycast
6 * tunnel endpoints. It has less protocol overhead than IPSec in Tunnel
7 * mode and allows tunneling of every ETHER TYPE protocol (e.g.
8 * ethernet, ip, arp ...). satp directly includes cryptography and
9 * message authentication based on the methodes used by SRTP. It is
10 * intended to deliver a generic, scaleable and secure solution for
11 * tunneling and relaying of packets of any protocol.
14 * Copyright (C) 2007 anytun.org <satp@wirdorange.org>
16 * This program is free software; you can redistribute it and/or modify
17 * it under the terms of the GNU General Public License version 2
18 * as published by the Free Software Foundation.
20 * This program is distributed in the hope that it will be useful,
21 * but WITHOUT ANY WARRANTY; without even the implied warranty of
22 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
23 * GNU General Public License for more details.
25 * You should have received a copy of the GNU General Public License
26 * along with this program (see the file COPYING included with this
27 * distribution); if not, write to the Free Software Foundation, Inc.,
28 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
31 #include "threadUtils.hpp"
32 #include "datatypes.h"
34 #include <sstream>
35 #include <iostream>
36 #include <string>
38 #include <boost/archive/text_oarchive.hpp>
39 #include <boost/archive/text_iarchive.hpp>
42 #include "syncQueue.h"
43 void SyncQueue::push(const SyncCommand & scom )
45 std::ostringstream sout;
46 boost::archive::text_oarchive oa(sout);
47 oa << scom;
49 Lock lock(mutex_);
50 std::stringstream lengthout;
51 lengthout << std::setw(5) << std::setfill('0') << sout.str().size()<< ' ';
52 queue_.push(lengthout.str()+sout.str());
55 void SyncQueue::push(const std::string & str )
57 Lock lock(mutex_);
58 queue_.push(str);
61 std::string SyncQueue::pop()
63 Lock lock(mutex_);
64 std::string tmp = queue_.front();
65 queue_.pop();
66 return tmp;
69 bool SyncQueue::empty()
71 Lock lock(mutex_);
72 return queue_.empty();