VerifyWS.h

Go to the documentation of this file.

 
//
// Created by tony on 18/03/22.
//
 
#ifndef _WINDOWSLIDER_VERIFYWS_H_
#define _WINDOWSLIDER_VERIFYWS_H_
#include <WindowSlider/AbstractWS.h>
#include <JoinProcessor/CellJoinJP.h>
#include <Utils/AbstractC20Thread.h>
namespace INTELLI {
class VerifyWS : public AbstractWS, public AbstractC20Thread {
 protected:
  TuplePtrQueue TuplePtrQueueLocalS;
  TuplePtrQueue TuplePtrQueueLocalR;
 
  size_t joinResults;
  virtual void inlineMain();
  void deliverTupleS(TuplePtr ts);
  void deliverTupleR(TuplePtr tr);
  void expireS(size_t cond);
  void expireR(size_t cond);
 public:
  void reset() {
    AbstractWS::reset();
    joinResults = 0;
  }
  VerifyWS() {
    reset();
    nameTag = "VerifyJoin";
  }
  ~VerifyWS() {
 
  }
  VerifyWS(size_t sLen, size_t rLen);
  void initJoinProcessors();
  void terminateJoinProcessors();
  void waitAckFromJoinProcessors();
  //get the join result
  size_t getJoinResult();
};
}
#endif //ALIANCEDB_INCLUDE_WINDOWSLIDER_VERIFYWS_H_