ippServerQueues.h

Go to the documentation of this file.

// 
// DISCLAIMER: 
//  This software was produced by the National Institute of Standards 
//  and Technology (NIST), an agency of the U.S. government, and by statute is 
//  not subject to copyright in the United States.  Recipients of this 
//  software assume all responsibility associated with its operation,
//  modification,maintenance, and subsequent redistribution. 
//
//  See NIST Administration Manual 4.09.07 b and Appendix I. 
#ifndef __ippServerQueues_H
#define __ippServerQueues_H

#include "ippdme/ippdme.h"

#include "ippdme/Response/ippResponse.h"


#include <queue>


class IPPDME_EXT_CLASS ippServerQueues
{
private:

  std::vector<int> _tagList;               //<! List of tag numbers in use
  std::queue<std::string> _fastQueue;      //<! Event commands go here
  std::queue<std::string> _slowQueue;      //<! Command commands go here
  std::queue<std::string> _responseQueue;  //<! All responses go here
  
public:

  ippServerQueues();

  virtual ~ippServerQueues();

  void addTag(int tag_num);

  void delTag(int tag_num);

  bool tagInList(int tag_num) const;

  
  // Put an event on the event queue ( fast queue ) 
  void EnqueueEvent(const char * a_string);

  // Put a command on the command queue (slow queue)
  void EnqueueCommand(const char * a_string);

  // Put a response on the response queue
  void EnqueueResponse(const char * a_string);

  // Remove an event from the event queue ( fast queue )
  std::string DequeueEvent();
  
  // Remove a command from the command queue ( slow queue)
  std::string DequeueCommand();

  // Remove a response from the response queue 
  std::string DequeueResponse();

  // Check for data on a queue
  bool EventQueueHasData()const { return !_fastQueue.empty(); }
  bool CommandQueueHasData()const { return !_slowQueue.empty(); }
  bool ResponseQueueHasData()const { return !_responseQueue.empty(); }
  

  // Clear all queues in the case of an abort or a mid session client disconnect
  void ClearAllQueues();
private:
  ippServerQueues(const ippServerQueues&);
  void operator=(const ippServerQueues&);
};

#endif /* #ifndef __ippServerQueues_H */

---