[ViewVC] Diff of: cvs/gvpe/src/connection.C

Comparing gvpe/src/connection.C (file contents):
Revision 1.24 by pcg, Wed Oct 22 01:05:23 2003 UTC vs.
Revision 1.28 by pcg, Tue Jan 27 05:56:35 2004 UTC

 /*
     connection.C -- manage a single connection
-    Copyright (C) 2003 Marc Lehmann <pcg@goof.com>
+    Copyright (C) 2003-2004 Marc Lehmann <pcg@goof.com>
     This program is free software; you can redistribute it and/or modify
     it under the terms of the GNU General Public License as published by
     the Free Software Foundation; either version 2 of the License, or
     (at your option) any later version.
 extern "C" {
 # include "lzf/lzf.h"
 }
+#include <cassert>
 #include <list>
 #include <openssl/rand.h>
 #include <openssl/evp.h>
 #include <openssl/rsa.h>
 } rsa_cache;
 void rsa_cache::cleaner_cb (time_watcher &w)
 {
-  if (empty ())
+  if (!empty ())
-    w.at = TSTAMP_CANCEL;
-  else
     {
-      w.at = NOW + RSA_TTL;
+      w.start (NOW + RSA_TTL);
       for (iterator i = begin (); i != end (); )
         if (i->expire <= NOW)
           i = erase (i);
         else
 }
 #define MAXVPNDATA (MAX_MTU - 6 - 6)
 #define DATAHDR (sizeof (u32) + RAND_SIZE)
-struct vpndata_packet:vpn_packet
+struct vpndata_packet : vpn_packet
   {
     u8 data[MAXVPNDATA + DATAHDR]; // seqno
     void setup (connection *conn, int dst, u8 *d, u32 len, u32 seqno);
     tap_packet *unpack (connection *conn, u32 &seqno);
 struct auth_req_packet : config_packet
 {
   char magic[8];
   u8 initiate; // false if this is just an automatic reply
-  u8 protocols; // supported protocols (will get patches on forward)
+  u8 protocols; // supported protocols (will be patched on forward)
   u8 pad2, pad3;
   rsaid id;
   rsaencrdata encr;
   auth_req_packet (int dst, bool initiate_, u8 protocols_)
     }
   else
     {
       retry_cnt = 0;
       establish_connection.start (NOW + 5);
-      keepalive.reset ();
+      keepalive.stop ();
-      rekey.reset ();
+      rekey.stop ();
     }
 }
 void
 connection::reset_si ()
 }
 void
 connection::establish_connection_cb (time_watcher &w)
 {
-  if (ictx || conf == THISNODE
+  if (!ictx
+      && conf != THISNODE
-      || connectmode == conf_node::C_NEVER
+      && connectmode != conf_node::C_NEVER
-      || connectmode == conf_node::C_DISABLED)
+      && connectmode != conf_node::C_DISABLED
-    w.at = TSTAMP_CANCEL;
+      && NOW > w.at)
-  else if (w.at <= NOW)
     {
       double retry_int = double (retry_cnt & 3 ? (retry_cnt & 3) : 1 << (retry_cnt >> 2)) * 0.6;
       if (retry_int < 3600 * 8)
         retry_cnt++;
-      w.at = NOW + retry_int;
+      w.start (NOW + retry_int);
       reset_si ();
       if (si.prot && !si.host)
         vpn->send_connect_request (conf->id);
   si.host= 0;
   last_activity = 0;
   retry_cnt = 0;
-  rekey.reset ();
+  rekey.stop ();
-  keepalive.reset ();
+  keepalive.stop ();
-  establish_connection.reset ();
+  establish_connection.stop ();
 }
 void
 connection::shutdown ()
 {
 }
 void
 connection::rekey_cb (time_watcher &w)
 {
-  w.at = TSTAMP_CANCEL;
   reset_connection ();
   establish_connection ();
 }
 void
 {
   if (ictx && octx)
     send_vpn_packet (pkt, si, tos);
   else
     {
-      vpn_queue.put (new vpn_packet (*pkt));
+      vpn_queue.put ((vpn_packet *)new data_packet (*(data_packet *)pkt));
       establish_connection ();
     }
 }
                   crypto_ctx *cctx = new crypto_ctx (chg, 0);
                   if (!p->hmac_chk (cctx))
                     {
                       slog (L_ERR, _("%s(%s): hmac authentication error on auth response, received invalid packet\n"
-                                     "could be an attack, or just corruption or an synchronization error"),
+                                     "could be an attack, or just corruption or a synchronization error"),
                             conf->nodename, (const char *)rsi);
                       break;
                     }
                   else
                     {
           {
             vpndata_packet *p = (vpndata_packet *)pkt;
             if (!p->hmac_chk (ictx))
               slog (L_ERR, _("%s(%s): hmac authentication error, received invalid packet\n"
-                             "could be an attack, or just corruption or an synchronization error"),
+                             "could be an attack, or just corruption or a synchronization error"),
                     conf->nodename, (const char *)rsi);
             else
               {
                 u32 seqno;
                 tap_packet *d = p->unpack (this, seqno);
     {
       reset_connection ();
       establish_connection ();
     }
   else if (NOW < last_activity + ::conf.keepalive)
-    w.at = last_activity + ::conf.keepalive;
+    w.start (last_activity + ::conf.keepalive);
   else if (conf->connectmode != conf_node::C_ONDEMAND
            || THISNODE->connectmode != conf_node::C_ONDEMAND)
     {
       send_ping (si);
-      w.at = NOW + 5;
+      w.start (NOW + 5);
     }
   else if (NOW < last_activity + ::conf.keepalive + 10)
     // hold ondemand connections implicitly a few seconds longer
     // should delete octx, though, or something like that ;)
-    w.at = last_activity + ::conf.keepalive + 10;
+    w.start (last_activity + ::conf.keepalive + 10);
   else
     reset_connection ();
 }
 void connection::send_connect_request (int id)

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing gvpe/src/connection.C (file contents): Revision 1.24 by pcg, Wed Oct 22 01:05:23 2003 UTC vs. Revision 1.28 by pcg, Tue Jan 27 05:56:35 2004 UTC

Diff Legend

Comparing gvpe/src/connection.C (file contents):
Revision 1.24 by pcg, Wed Oct 22 01:05:23 2003 UTC vs.
Revision 1.28 by pcg, Tue Jan 27 05:56:35 2004 UTC