Parent: [dcd91e] (diff)

Child: [a42160] (diff)

Download this file

device.hxx    142 lines (120 with data), 4.9 kB

  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
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
/* Copyright (C) 2014 J.F.Dockes
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the
* Free Software Foundation, Inc.,
* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#ifndef _DEVICE_H_X_INCLUDED_
#define _DEVICE_H_X_INCLUDED_
#include <pthread.h> // for pthread_cond_t
#include <upnp/upnp.h> // for Upnp_EventType, etc
#include <functional> // for function
#include <string> // for string
#include <unordered_map> // for unordered_map, etc
#include <vector> // for vector
#include "libupnpp/ptmutex.hxx" // for PTMutexInit
#include "libupnpp/soaphelp.hxx" // for SoapOutgoing, SoapIncoming
namespace UPnPP { class LibUPnP; }
namespace UPnPProvider { class UpnpService; }
namespace UPnPProvider {
typedef std::function<int (const UPnPP::SoapIncoming&, UPnPP::SoapOutgoing&)>
soapfun;
// Definition of a virtual directory entry: data and mime type
struct VDirContent {
VDirContent(const std::string& ct, const std::string& mt)
: content(ct), mimetype(mt) {}
std::string content;
std::string mimetype;
};
/** Define an interface to link libupnp operations to a device implementation
*/
class UpnpDevice {
public:
/** Construct device object. Do not start it (this is done by the
* eventloop() call when everything is set up).
* @param deviceId uuid for device: "uuid:UUIDvalue"
* @param files list of path/content pairs to be added to the
* virtual directory root. The file paths must match the SCDPURL
* values for the services in the description.xml document.
* The file paths should include a sub-directory component.
* The list must include the description document, but this will not
* be directly served out. Instead a version modified by libupnp
* (with URLBase added) will be served from '/'.
*/
UpnpDevice(const std::string& deviceId,
const std::unordered_map<std::string, VDirContent>& files);
~UpnpDevice();
void addService(UpnpService *, const std::string& serviceId);
/**
* Add mapping from service+action-name to handler function.
*/
void addActionMapping(const UpnpService*,
const std::string& actName, soapfun);
/**
* Main routine. To be called by main() when done with initialization.
*
* This loop mostly polls getEventData and generates an UPnP event if
* there is anything to broadcast. The UPnP action calls happen in
* other threads with which we synchronize, currently using a global lock.
*/
void eventloop();
/**
* To be called from a service action callback to wake up the
* event loop early if something needs to be broadcast without
* waiting for the normal delay.
*
* Will only do something if the previous event is not too recent.
*/
void loopWakeup(); // To trigger an early event
/**
* To be called to get the event loop to return
*/
void shouldExit();
/** Check status */
bool ok();
private:
class Internal;
Internal *m;
class InternalStatic;
static InternalStatic *o;
};
/**
* Upnp service implementation class. This does not do much useful beyond
* encapsulating the service actions and event callback. In most cases, the
* services will need full access to the device state anyway.
*/
class UpnpService {
public:
UpnpService(const std::string& stp,const std::string& sid, UpnpDevice *dev);
virtual ~UpnpService();
/**
* Poll to retrieve evented data changed since last call.
*
* To be implemented by the derived class.
* Called by the library when a control point subscribes, to
* retrieve eventable data.
* Return name/value pairs for changed variables in the data arrays.
*/
virtual bool getEventData(bool all, std::vector<std::string>& names,
std::vector<std::string>& values);
virtual const std::string& getServiceType() const;
virtual const std::string& getServiceId() const;
protected:
const std::string m_serviceType;
const std::string m_serviceId;
private:
class Internal;
Internal *m;
};
} // End namespace UPnPProvider
#endif /* _DEVICE_H_X_INCLUDED_ */