Imported Upstream version 0.3
[anytun.git] / src / seqWindow.h
1 /*
2  *  anytun
3  *
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.
12  *
13  *
14  *  Copyright (C) 2007-2008 Othmar Gsenger, Erwin Nindl, 
15  *                          Christian Pointner <satp@wirdorange.org>
16  *
17  *  This file is part of Anytun.
18  *
19  *  Anytun is free software: you can redistribute it and/or modify
20  *  it under the terms of the GNU General Public License version 3 as
21  *  published by the Free Software Foundation.
22  *
23  *  Anytun is distributed in the hope that it will be useful,
24  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
25  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
26  *  GNU General Public License for more details.
27  *
28  *  You should have received a copy of the GNU General Public License
29  *  along with anytun.  If not, see <http://www.gnu.org/licenses/>.
30  */
31
32 #ifndef _SEQ_WINDOW_H_
33 #define _SEQ_WINDOW_H_
34
35 #include <map>
36 #include <deque>
37 #include <boost/archive/text_oarchive.hpp>
38 #include <boost/archive/text_iarchive.hpp>
39 #include "threadUtils.hpp"
40 #include "datatypes.h"
41
42 class SeqWindow;
43
44 class SeqWindowElement {
45 public:
46   SeqWindowElement();
47   ~SeqWindowElement();
48
49   void init(window_size_t w, seq_nr_t m);
50
51   seq_nr_t max_;
52   window_size_t pos_;
53   u_int8_t* window_;
54 };
55
56 class SeqWindow
57 {
58 public:
59   typedef std::map<sender_id_t, SeqWindowElement> SenderMap;
60
61   SeqWindow(window_size_t w);
62   ~SeqWindow();
63
64   bool checkAndAdd(sender_id_t sender, seq_nr_t seq_nr);
65   void clear(sender_id_t sender);
66   void clear();
67
68 private:
69   window_size_t window_size_;
70   Mutex mutex_;
71   SenderMap sender_;
72
73   SeqWindow(const SeqWindow &s);
74   void operator=(const SeqWindow &s);
75
76         friend class boost::serialization::access;
77         template<class Archive>
78         void serialize(Archive & ar, const unsigned int version)
79         {
80                 Lock lock(mutex_);
81                 //unsigned int serial = (unsigned int) window_size_;
82                 //window_size_t serial = (window_size_t) window_size_;
83         ar & window_size_;
84         //TODO: Do not sync complete Sender Map!
85         // ar & sender_;
86   }
87  
88
89 };
90
91 #endif