summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/impl/ndds/QueryCondition.h
blob: 367a68e67a78faa6ceb000541d5a3c2d20b2f582 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
/**
 * @author William R. Otte <wotte@dre.vanderbilt.edu>
 * @author Johnny Willemsen <jwillemsen@remedy.nl>
 *
 * $Id$
 *
 * Wrapper facade for NDDS.
 */

#ifndef CIAO_RTI_QUERYCONDITION_H
#define CIAO_RTI_QUERYCONDITION_H

#include "tao/LocalObject.h"

#include "dds4ccm/idl/dds_rtf2_dcpsEC.h"

#include "dds4ccm/idl/dds_rtf2_dcpsC.h"
#include "dds4ccm/impl/ndds/dds4ccm_ndds_impl_export.h"

#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
#include "ndds/ndds_cpp.h"
#endif

#if defined (CIAO_DDS4CCM_OPENDDS) && (CIAO_DDS4CCM_OPENDDS==1)
typedef ::DDS::QueryCondition DDSQueryCondition;
#endif

#include "tao/LocalObject.h"

namespace CIAO
{
  namespace DDS4CCM
  {
    namespace RTI
    {
      class DDS4CCM_NDDS_IMPL_Export RTI_QueryCondition_i :
        public virtual ::DDS::CCM_QueryCondition,
        public virtual ::CORBA::LocalObject
      {
      public:
        // Constructor
        RTI_QueryCondition_i (void);

        // Destructor
        virtual ~RTI_QueryCondition_i (void);

        virtual ::CORBA::Boolean
        get_trigger_value (void);

        virtual ::DDS::SampleStateMask
        get_sample_state_mask (void);

        virtual ::DDS::ViewStateMask
        get_view_state_mask (void);

        virtual ::DDS::InstanceStateMask
        get_instance_state_mask (void);

        virtual ::DDS::DataReader_ptr
        get_datareader (void);

        virtual char *
        get_query_expression (void);

        virtual ::DDS::ReturnCode_t
        get_query_parameters (
          ::DDS::StringSeq & query_parameters);

        virtual ::DDS::ReturnCode_t
        set_query_parameters (
          const ::DDS::StringSeq & query_parameters);

        DDSQueryCondition * get_impl (void);

        void set_impl (DDSQueryCondition * qc);

      private:
        DDSQueryCondition * impl_;

        DDSQueryCondition * impl ();
      };
    }
  }
}

#endif /* CIAO_RTI_QUERYCONDITION_H */