ngcdcsPUBLISHER.hpp

Go to the documentation of this file.

#ifndef ngcdcsPUBLISHER_H
#define ngcdcsPUBLISHER_H
 
 
#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif
 
#include <ngc/core/ngcdcsEXP.hpp>
 
/*
 * Publishing methods
 */
#define ngcdcsPUB_POSTPONE  0x1   //< postpone until completion  
#define ngcdcsPUB_KEEP      0x2   //< keep in list

class ngcdcsPUBLISHER
{
public:
  int verboseLevel;

  int logLevel;

  ngcdcsPUBLISHER &operator=(const ngcdcsPUBLISHER &other) {
    ngcbLIST *l;
    verboseLevel = other.verboseLevel;
    logLevel = other.logLevel;
    for (l=other.list_.First();l!=NULL;l=l->next) 
      {
      ngcdcs_exp_topic *topic = static_cast<ngcdcs_exp_topic *>(l->item);
      if (topic != NULL) list_.Add(new ngcdcs_exp_topic(*topic));
      }
    return (*this);
  }

  ngcdcsPUBLISHER(const ngcdcsPUBLISHER &other) {
    ngcbLIST *l; 
    verboseLevel = other.verboseLevel;
    logLevel = other.logLevel;
    for (l=other.list_.First();l!=NULL;l=l->next) 
      {
      ngcdcs_exp_topic *topic = static_cast<ngcdcs_exp_topic *>(l->item);
      if (topic != NULL) list_.Add(new ngcdcs_exp_topic(*topic));
      }
  }

  ngcdcsPUBLISHER() {verboseLevel = 0; logLevel = 0;}

  virtual ~ngcdcsPUBLISHER() {Clear();}

  void Clear() {
    ngcbLIST *l; 
    for (l=list_.First();l!=NULL;l=l->next) 
      {
      ngcdcs_exp_topic *topic = static_cast<ngcdcs_exp_topic *>(l->item);
      if (topic != NULL) delete topic;
      }
    list_.Clear();
  }

  void Remove(const char *id) {
    ngcbLIST *l = list_.First();
    while (l != NULL) 
      {
      if (l->item != NULL)
    {
    ngcdcs_exp_topic *topic = static_cast<ngcdcs_exp_topic *>(l->item);
    l = l->next;
    if (strcmp(topic->id, id) == 0)
      {
      list_.Remove(topic); delete topic;
      }
    }
      else
    {
    l = l->next;
    }
      }
  }
  
  void Remove(int id) {
    char s[64];
    sprintf(s, "%d", id);
    Remove(s);
  }
  
  void Push(const ngcdcs_exp_topic &topic) {
    if (strcmp(topic.status, "Active") == 0)
      {
      /*
       * Add the topic to the list
       */
      list_.Add(new ngcdcs_exp_topic(topic));
    
      if (!(topic.method & ngcdcsPUB_POSTPONE))
    {
    /*
     * Publish immediately
     */
    PublishList_(topic.id, topic.status);
    }
      }
    else if (strlen(topic.fileName) > 0)
      {
      /*
       * Add the topic to the list and publish
       */
      list_.Add(new ngcdcs_exp_topic(topic));
      PublishList_(topic.id, topic.status);
      Clear();
      }
    else if (strlen(topic.status) > 0)
      {
      /*
       * Update status and publish the list again
       */
      PublishList_(topic.id, topic.status);
      Clear();
      }
    else
      {
      /*
       * No file, no status - we do nothing
       */
      }
  }
 
protected:
  
  virtual void Publish(const ngcdcs_exp_topic &topic) {
    if (verboseLevel > 0)
      {
      fprintf(stdout, "data: %s,%s,%s:%s\n", topic.id, topic.status,
          topic.host, topic.fileName);
      }
  }
 
private:
  ngcbLIST list_;
  
  void PublishList_(const char *id, const char *status) {
    ngcbLIST *l;
    for (l = list_.First(); l != NULL; l = l->next) 
      {
      if (l->item != NULL)
    {
    ngcdcs_exp_topic *topic = static_cast<ngcdcs_exp_topic *>(l->item);
    if (strcmp(topic->id, id) == 0)
      {
      /*
       * Exposure id matches. We update the status and publish
       */
      strcpy(topic->status, status);
      Publish(*topic);
      }
    }
      }
  }
};
 
#endif