wvprint/wvprintconfwatcher.cc

   1
   2
   3
   4 #include "wvlog.h"
   5 #include "uniconf.h"
   6 #include "wvprint.h"
   7 #include "wvcupsmanager.h"
   8
   9 #include "wvprintconfwatcher.h"
  10
  11 #include "wvprintuniconfkeys.h"
  12
  13
  14
  15 WvPrintConfWatcher::WvPrintConfWatcher(WvLog &_log, const UniConf &_cfg)
  16     : log(_log), cfg(_cfg), queues(16), cups(NULL)
  17 {
  18     /* needed for editing of the 'WvPrint/aliases' on the commandline */
  19     watches.add(cfg[WVPRINT_ALIASES_KEYS],
  20                 UniConfCallback(this, &WvPrintConfWatcher::addalias_callback), true);
  21
  22     /* handle all the queues thru UniCallbacks */
  23     watches.add(cfg[WVPRINT_QUEUES_KEYS],
  24                 UniConfCallback(this, &WvPrintConfWatcher::addqueue_callback), true);
  25 }
  26
  27
  28 void WvPrintConfWatcher::addalias_callback(const UniConf &_cfg, const UniConfKey &_key)
  29 {
  30     /* if the user has invoked this callback .. not when we're doing a config
  31      * aliases.  Also, don't let them delete the lp alias */
  32 //    if (!need_alias_config)
  33 //      return;
  34
  35     WvString queuename = _cfg[_key].getme("");
  36     if (!!queuename && queues[queuename])
  37     {
  38         //configure_aliases();
  39     }
  40     else
  41     {
  42         _cfg[_key].remove();
  43     }
  44 }
  45
  46
  47 void WvPrintConfWatcher::addqueue_callback(const UniConf &_cfg, const UniConfKey &_key)
  48 {
  49     log(WvLog::Debug1, "addqueue_callback. Key = %s\n", _key);
  50
  51     if (!!_key.printable())
  52     {
  53         WvStringList subkeys;
  54         subkeys.split(_key, "/");
  55         if (subkeys.count() == 1)
  56         {
  57             _add_queue(*subkeys.first());
  58         }
  59         else
  60         {
  61             _update_queue(*subkeys.first());
  62         }
  63     }
  64 }
  65
  66
  67 void WvPrintConfWatcher::init_config()
  68 {
  69     log(WvLog::Debug1, "init_config()\n");
  70     if(!queues.isempty())
  71     {
  72         log(WvLog::Warning, "queues is not empty. Emptying\n");
  73         queues.zap();
  74     }
  75
  76     UniConf::Iter cfgit(cfg[WVPRINT_QUEUES_KEYS]);
  77
  78     /* Iterate over all queues .. starts only the real ones */
  79     for (cfgit.rewind(); cfgit.next(); )
  80     {
  81         WvString queuename(cfgit().key().printable());
  82         log(WvLog::Debug1, "adding a queue\n");
  83         _add_queue(queuename);
  84     }
  85 }
  86
  87 WvString WvPrintConfWatcher::get_printer_state(WvStringParm queuename)
  88 {
  89     WvString state = "";
  90     PrintQueueName *qn = queues[queuename];
  91     if (qn)
  92     {
  93         state = qn->queue->get_state();
  94     }
  95     return state;
  96 }
  97
  98
  99 int WvPrintConfWatcher::count_jobs(WvStringParm queuename)
 100 {
 101     int count = 0;
 102     PrintQueueName *qn = queues[queuename];
 103     if (qn)
 104     {
 105         count = qn->queue->job_count();
 106     }
 107     return count;
 108 }
 109
 110
 111 bool WvPrintConfWatcher::job_exists(WvStringParm queuename, int job_num)
 112 {
 113     bool found = false;
 114     PrintQueueName *qn = queues[queuename];
 115     if (qn)
 116     {
 117         found = qn->queue->job_exists(queuename, job_num);
 118     }
 119     return found;
 120 }
 121
 122
 123 bool WvPrintConfWatcher::cancel_job(WvStringParm queuename, int job_num)
 124 {
 125     PrintQueueName *qn = queues[queuename];
 126     if (qn)
 127     {
 128         return qn->queue->cancel(job_num);
 129     }
 130     return false;
 131 }
 132
 133
 134
 135 void WvPrintConfWatcher::_add_queue(WvStringParm name)
 136 {
 137     PrintQueue *queue = PrintQueue::new_queue(name, cfg, log);
 138
 139     if (queue)
 140     {
 141         queue->set_cups_manager(cups);
 142         queues.add(new PrintQueueName(queue->name, queue), true);
 143         log(WvLog::Debug, "Added new queue %s.\n", name);
 144         queue->enable();
 145     }
 146     else
 147     {
 148         log(WvLog::Error, "Could not add new queue %s; disabling.\n", name);
 149     }
 150 }
 151
 152
 153 void WvPrintConfWatcher::_update_queue(WvStringParm queuename)
 154 {
 155     PrintQueue *queue = queues[queuename]->queue;
 156
 157     // FIXME: looks like this can happen to often. Perhaps should we add the queue
 158     // to a list and reconfig every once and while
 159     if (cups)
 160     {
 161         queue->reconfig();
 162     }
 163 }
 164
 165
 166 void WvPrintConfWatcher::_remove_queue(WvStringParm queuename)
 167 {
 168     /* Clean up both queue and uniconf */
 169     PrintQueueName *q = queues[queuename];
 170
 171     if (q)
 172     {
 173         log(WvLog::Debug, "Removing queue %s\n", queuename);
 174         queues.remove(q);
 175     }
 176     else
 177     {
 178         log(WvLog::Debug, "Could not find queue %s\n", queuename);
 179     }
 180 }