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

Comparing gvpe/src/connection.C (file contents):
Revision 1.59 by pcg, Mon Dec 5 12:58:09 2005 UTC vs.
Revision 1.60 by pcg, Sat Nov 10 05:14:22 2007 UTC

   rsachallenge chg;
 };
 struct rsa_cache : list<rsa_entry>
 {
-  void cleaner_cb (time_watcher &w); time_watcher cleaner;
+  void cleaner_cb (ev::timer &w, int revents); ev::timer cleaner;
   bool find (const rsaid &id, rsachallenge &chg)
   {
     for (iterator i = begin (); i != end (); ++i)
       {
-        if (!memcmp (&id, &i->id, sizeof id) && i->expire > NOW)
+        if (!memcmp (&id, &i->id, sizeof id) && i->expire > ev::ev_now ())
           {
             memcpy (&chg, &i->chg, sizeof chg);
             erase (i);
             return true;
           }
       }
-    if (cleaner.at < NOW)
+    if (!cleaner.is_active ())
-      cleaner.start (NOW + RSA_TTL);
+      cleaner.again ();
     return false;
   }
   void gen (rsaid &id, rsachallenge &chg)
     rsa_entry e;
     RAND_bytes ((unsigned char *)&id,  sizeof id);
     RAND_bytes ((unsigned char *)&chg, sizeof chg);
-    e.expire = NOW + RSA_TTL;
+    e.expire = ev::ev_now () + RSA_TTL;
     e.id = id;
     memcpy (&e.chg, &chg, sizeof chg);
     push_back (e);
-    if (cleaner.at < NOW)
+    if (!cleaner.is_active ())
-      cleaner.start (NOW + RSA_TTL);
+      cleaner.again ();
   }
   rsa_cache ()
   : cleaner (this, &rsa_cache::cleaner_cb)
-  { }
+  {
+    cleaner.set (RSA_TTL, RSA_TTL);
+  }
 } rsa_cache;
-void rsa_cache::cleaner_cb (time_watcher &w)
+void rsa_cache::cleaner_cb (ev::timer &w, int revents)
 {
-  if (!empty ())
+  if (empty ())
+    w.stop ();
+  else
     {
-      w.start (NOW + RSA_TTL);
       for (iterator i = begin (); i != end (); )
-        if (i->expire <= NOW)
+        if (i->expire <= ev::ev_now ())
           i = erase (i);
         else
           ++i;
     }
 }
   iterator i;
   for (i = begin (); i != end (); )
     if (i->host == host)
       break;
-    else if (i->last < NOW - NRL_EXPIRE)
+    else if (i->last < ev::ev_now () - NRL_EXPIRE)
       i = erase (i);
     else
       i++;
   if (i == end ())
       net_rateinfo ri;
       ri.host = host;
       ri.pcnt = 1.;
       ri.diff = NRL_MAXDIF;
-      ri.last = NOW;
+      ri.last = ev::ev_now ();
       push_front (ri);
       return true;
     }
     {
       net_rateinfo ri (*i);
       erase (i);
       ri.pcnt = ri.pcnt * NRL_ALPHA;
-      ri.diff = ri.diff * NRL_ALPHA + (NOW - ri.last);
+      ri.diff = ri.diff * NRL_ALPHA + (ev::ev_now () - ri.last);
-      ri.last = NOW;
+      ri.last = ev::ev_now ();
       double dif = ri.diff / ri.pcnt;
       bool send = dif > NRL_CUTOFF;
   if (ictx && octx)
     {
       connectmode = conf->connectmode;
       // make sure rekeying timeouts are slightly asymmetric
-      rekey.start (NOW + ::conf.rekey
+      ev::tstamp rekey_interval = ::conf.rekey + (conf->id > THISNODE->id ? 10 : 0);
-                   + (conf->id > THISNODE->id ? 10 : 0));
+      rekey.start (rekey_interval, rekey_interval);
-      keepalive.start (NOW + ::conf.keepalive);
+      keepalive.start (::conf.keepalive);
       // send queued packets
       if (ictx && octx)
         {
           while (tap_packet *p = (tap_packet *)data_queue.get ())
         }
     }
   else
     {
       retry_cnt = 0;
-      establish_connection.start (NOW + 5);
+      establish_connection.start (5);
       keepalive.stop ();
       rekey.stop ();
     }
 }
   delete r;
 }
 void
-connection::establish_connection_cb (time_watcher &w)
+connection::establish_connection_cb (ev::timer &w, int revents)
 {
   if (!ictx
       && conf != THISNODE
       && connectmode != conf_node::C_NEVER
       && connectmode != conf_node::C_DISABLED
-      && NOW > w.at)
+      && !w.is_active ())
     {
-      w.at = TSTAMP_MAX; // first disable this watcher in case of recursion
+      ev::tstamp retry_int = ev::tstamp (retry_cnt & 3
-      double retry_int = double (retry_cnt & 3
-                                 ? (retry_cnt & 3) + 1
+                                         ? (retry_cnt & 3) + 1
-                                 : 1 << (retry_cnt >> 2));
+                                         : 1 << (retry_cnt >> 2));
       reset_si ();
       bool slow = si.prot & PROT_SLOW;
       if (si.prot && !si.host)
+        {
+          /*TODO*/ /* start the timer so we don't recurse endlessly */
+          w.start (1);
-        vpn->send_connect_request (conf->id);
+          vpn->send_connect_request (conf->id);
+        }
       else
         {
           const sockinfo &dsi = forward_si (si);
           slow = slow || (dsi.prot & PROT_SLOW);
       if (retry_int < conf->max_retry)
         retry_cnt++;
       else
         retry_int = conf->max_retry;
-      w.start (NOW + retry_int);
+      w.start (retry_int);
     }
 }
 void
 connection::reset_connection ()
   reset_connection ();
 }
 void
-connection::rekey_cb (time_watcher &w)
+connection::rekey_cb (ev::timer &w, int revents)
 {
   reset_connection ();
   establish_connection ();
 }
 }
 void
 connection::recv_vpn_packet (vpn_packet *pkt, const sockinfo &rsi)
 {
-  last_activity = NOW;
+  last_activity = ev::ev_now ();
   slog (L_NOISE, "<<%d received packet type %d from %d to %d",
         conf->id, pkt->typ (), pkt->src (), pkt->dst ());
   switch (pkt->typ ())
         send_reset (rsi);
         break;
     }
 }
-void connection::keepalive_cb (time_watcher &w)
+void connection::keepalive_cb (ev::timer &w, int revents)
 {
-  if (NOW >= last_activity + ::conf.keepalive + 30)
+  if (ev::ev_now () >= last_activity + ::conf.keepalive + 30)
     {
       reset_connection ();
       establish_connection ();
     }
-  else if (NOW < last_activity + ::conf.keepalive)
+  else if (ev::ev_now () < last_activity + ::conf.keepalive)
-    w.start (last_activity + ::conf.keepalive);
+    w.start (last_activity + ::conf.keepalive - ev::now ());
   else if (conf->connectmode != conf_node::C_ONDEMAND
            || THISNODE->connectmode != conf_node::C_ONDEMAND)
     {
       send_ping (si);
-      w.start (NOW + 5);
+      w.start (5);
     }
-  else if (NOW < last_activity + ::conf.keepalive + 10)
+  else if (ev::ev_now () < last_activity + ::conf.keepalive + 10)
     // hold ondemand connections implicitly a few seconds longer
     // should delete octx, though, or something like that ;)
-    w.start (last_activity + ::conf.keepalive + 10);
+    w.start (last_activity + ::conf.keepalive + 10 - ev::now ());
   else
     reset_connection ();
 }
 void connection::send_connect_request (int id)
 const char *connection::script_node_up ()
 {
   script_init_connect_env ();
-  putenv ("STATE=up");
+  putenv ((char *)"STATE=up");
   char *filename;
   asprintf (&filename,
             "%s/%s",
             confbase,
 const char *connection::script_node_down ()
 {
   script_init_connect_env ();
-  putenv ("STATE=down");
+  putenv ((char *)"STATE=down");
   char *filename;
   asprintf (&filename,
             "%s/%s",
             confbase,

Diff Legend

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

Comparing gvpe/src/connection.C (file contents): Revision 1.59 by pcg, Mon Dec 5 12:58:09 2005 UTC vs. Revision 1.60 by pcg, Sat Nov 10 05:14:22 2007 UTC

Diff Legend

Comparing gvpe/src/connection.C (file contents):
Revision 1.59 by pcg, Mon Dec 5 12:58:09 2005 UTC vs.
Revision 1.60 by pcg, Sat Nov 10 05:14:22 2007 UTC