~ubuntu-branches/ubuntu/lucid/anytun/lucid

« back to all changes in this revision

Viewing changes to src/syncOnConnect.hpp

  • Committer: Bazaar Package Importer
  • Author(s): Michael Prokop
  • Date: 2009-12-14 02:08:25 UTC
  • Revision ID: james.westby@ubuntu.com-20091214020825-ntyi58y4wvsaglhi
Tags: upstream-0.3.2
ImportĀ upstreamĀ versionĀ 0.3.2

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
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-2009 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 as published by
 
21
 *  the Free Software Foundation, either version 3 of the License, or
 
22
 *  any later version.
 
23
 *
 
24
 *  Anytun is distributed in the hope that it will be useful,
 
25
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 
26
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
27
 *  GNU General Public License for more details.
 
28
 *
 
29
 *  You should have received a copy of the GNU General Public License
 
30
 *  along with anytun.  If not, see <http://www.gnu.org/licenses/>.
 
31
 */
 
32
 
 
33
#ifndef ANYTUN_syncOnConnect_hpp_INCLUDED
 
34
#define ANYTUN_syncOnConnect_hpp_INCLUDED
 
35
 
 
36
// TODO required headers
 
37
 
 
38
void syncOnConnect(SyncTcpConnection * connptr)
 
39
{
 
40
  //TODO Locking here   
 
41
  ConnectionList & cl_(gConnectionList);
 
42
  ConnectionMap::iterator cit = cl_.getBeginUnlocked();
 
43
  for (;cit!=cl_.getEndUnlocked();++cit)
 
44
  {
 
45
    std::ostringstream sout;
 
46
    boost::archive::text_oarchive oa(sout);
 
47
    const SyncCommand scom(cl_,cit->first);
 
48
    oa << scom;
 
49
    std::stringstream lengthout;
 
50
    lengthout << std::setw(5) << std::setfill('0') << sout.str().size()<< ' ';
 
51
    connptr->Send(lengthout.str());
 
52
    connptr->Send(sout.str());
 
53
  }
 
54
  //TODO Locking here   
 
55
        network_address_type_t types[] = {ipv4,ipv6,ethernet};
 
56
        for (int types_idx=0; types_idx<3; types_idx++)
 
57
        {
 
58
                network_address_type_t type = types[types_idx];
 
59
                RoutingMap::iterator it = gRoutingTable.getBeginUnlocked(type);
 
60
                for (;it!=gRoutingTable.getEndUnlocked(type);++it)
 
61
                {
 
62
                        NetworkPrefix tmp(it->first);
 
63
                        std::ostringstream sout;
 
64
                        boost::archive::text_oarchive oa(sout);
 
65
                        const SyncCommand scom(tmp);
 
66
                        oa << scom;
 
67
                        std::stringstream lengthout;
 
68
                        lengthout << std::setw(5) << std::setfill('0') << sout.str().size()<< ' ';
 
69
                        connptr->Send(lengthout.str());
 
70
                        connptr->Send(sout.str());
 
71
                }
 
72
        }
 
73
}
 
74
 
 
75
#endif