Open Lighting Architecture  0.9.4
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
StreamingClient.h
Go to the documentation of this file.
1 /*
2  * This library is free software; you can redistribute it and/or
3  * modify it under the terms of the GNU Lesser General Public
4  * License as published by the Free Software Foundation; either
5  * version 2.1 of the License, or (at your option) any later version.
6  *
7  * This library is distributed in the hope that it will be useful,
8  * but WITHOUT ANY WARRANTY; without even the implied warranty of
9  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
10  * Lesser General Public License for more details.
11  *
12  * You should have received a copy of the GNU Lesser General Public
13  * License along with this library; if not, write to the Free Software
14  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
15  *
16  * StreamingClient.h
17  * Interface to the Streaming Client class.
18  * Copyright (C) 2005 Simon Newton
19  */
25 #ifndef INCLUDE_OLA_CLIENT_STREAMINGCLIENT_H_
26 #define INCLUDE_OLA_CLIENT_STREAMINGCLIENT_H_
27 
28 #include <ola/Constants.h>
29 #include <ola/DmxBuffer.h>
30 #include <ola/base/Macro.h>
32 
33 namespace ola {
34 
35 namespace io { class SelectServer; }
36 namespace network { class TCPSocket; }
37 namespace proto { class OlaServerService_Stub; }
38 namespace rpc {
39 class RpcChannel;
40 class RpcSession;
41 }
42 
43 namespace client {
44 
50  public:
54  class SendArgs {
55  public:
61  uint8_t priority;
62 
63  SendArgs() : priority(ola::dmx::SOURCE_PRIORITY_DEFAULT) {}
64  };
65 
66  virtual ~StreamingClientInterface() {}
67 
68  virtual bool Setup() = 0;
69 
70  virtual void Stop() = 0;
71 
72  virtual bool SendDmx(unsigned int universe, const DmxBuffer &data) = 0;
73 
74  virtual bool SendDMX(unsigned int universe,
75  const DmxBuffer &data,
76  const SendArgs &args) = 0;
77 };
78 
90  public:
94  class Options {
95  public:
101 
107 
111  uint16_t server_port;
112  };
113 
120  explicit StreamingClient(bool auto_start = true);
121 
126  explicit StreamingClient(const Options &options);
127 
133 
139  bool Setup();
140 
146  void Stop();
147 
155  bool SendDmx(unsigned int universe, const DmxBuffer &data);
156 
163  bool SendDMX(unsigned int universe,
164  const DmxBuffer &data,
165  const SendArgs &args);
166 
167  void ChannelClosed(ola::rpc::RpcSession *session);
168 
169  private:
170  bool m_auto_start;
171  uint16_t m_server_port;
172  ola::network::TCPSocket *m_socket;
173  ola::io::SelectServer *m_ss;
174  class ola::rpc::RpcChannel *m_channel;
175  class ola::proto::OlaServerService_Stub *m_stub;
176  bool m_socket_closed;
177 
178  bool Send(unsigned int universe, uint8_t priority, const DmxBuffer &data);
179 
181 };
182 } // namespace client
183 } // namespace ola
184 #endif // INCLUDE_OLA_CLIENT_STREAMINGCLIENT_H_