wvsync/wvsynclister.cc

   1 /*
   2  * Worldvisions Weaver Software:
   3  *   Copyright (C) 1997-2004 Net Integration Technologies, Inc.
   4  *
   5  * See wvsynclister.h for details.
   6  *
   7  */
   8
   9 #include "wvsynclister.h"
  10 #include "wvsyncobj.h"
  11 #include "wvsyncprotocol.h"
  12
  13 WvSyncLister::WvSyncLister(WvSyncProtocol &_prot)
  14 : prot(_prot), log("Lister", WvLog::Debug1), err(log.split(WvLog::Error))
  15 {
  16     donetbl.zap();
  17 }
  18
  19
  20 void WvSyncLister::run()
  21 {
  22     WvSyncObj *newobj = NULL;
  23
  24     while (prot.isok())
  25     {
  26         if (prot.want_more() && prot.num_in_flight() < WVSYNC_MAX_IN_FLIGHT)
  27         {
  28             // sync the thing we found before we sent the yourturn
  29             WvSyncObj *oldobj = NULL;
  30             if (newobj)
  31                 oldobj = newobj;
  32
  33             newobj = next();
  34
  35             if (oldobj && isdone(oldobj->name) == false)
  36                 prot.do_ihave(oldobj);
  37
  38             if (newobj)
  39             {
  40                 // might not be my turn anymore!
  41                 if (prot.want_more())
  42                 {
  43                     if (isdone(newobj->name) == false)
  44                     {
  45                         prot.do_ihave(newobj);
  46                         newobj = NULL;
  47                     }
  48                 }
  49             }
  50             else
  51             {
  52                 if (prot.want_more())
  53                     prot.do_yourturn();
  54
  55                 prot.do_done();
  56             }
  57         }
  58
  59         if (prot.isreadable())
  60             prot.callback();
  61     }
  62 }
  63
  64
  65 void WvSyncLister::do_chdir(WvStringParm dir)
  66 {
  67     prot.do_chdir(dir);
  68     cleardone();
  69 }
  70
  71 void WvSyncLister::markdone(WvStringParm name)
  72 {
  73     donetbl.add(new WvString(name), true);
  74 }
  75
  76 bool WvSyncLister::isdone(WvStringParm name)
  77 {
  78     return donetbl[name];
  79 }
  80
  81 void WvSyncLister::cleardone()
  82 {
  83     donetbl.zap();
  84 }