Ignore camera errors while stopping the pipeline.
[harmattan/cameraplus] / lib / qtcamdevice_p.h
1 // -*- c++ -*-
2
3 /*!
4  * This file is part of CameraPlus.
5  *
6  * Copyright (C) 2012 Mohammed Sameer <msameer@foolab.org>
7  *
8  * This library is free software; you can redistribute it and/or
9  * modify it under the terms of the GNU Lesser General Public
10  * License as published by the Free Software Foundation; either
11  * version 2.1 of the License, or (at your option) any later version.
12  *
13  * This library is distributed in the hope that it will be useful,
14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
16  * Lesser General Public License for more details.
17  *
18  * You should have received a copy of the GNU Lesser General Public
19  * License along with this library; if not, write to the Free Software
20  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
21  */
22
23 #ifndef QT_CAM_DEVICE_P_H
24 #define QT_CAM_DEVICE_P_H
25
26 #include <QDebug>
27 #include <gst/gst.h>
28 #include "qtcamconfig.h"
29 #include "qtcamviewfinder.h"
30 #include "qtcamdevice.h"
31 #include "qtcammode.h"
32
33 class QtCamGStreamerMessageListener;
34 class QtCamMode;
35 class QtCamImageMode;
36 class QtCamVideoMode;
37
38 class QtCamDevicePrivate {
39 public:
40   QtCamDevicePrivate() :
41     cameraBin(0),
42     videoSource(0),
43     wrapperVideoSource(0),
44     image(0),
45     video(0),
46     active(0),
47     viewfinder(0),
48     conf(0),
49     error(false),
50     notifications(0),
51     stopping(false) {
52
53   }
54
55   GstElement *createAndAddElement(const QString& elementName, const char *prop, const char *name) {
56     GstElement *elem = gst_element_factory_make(elementName.toAscii(), name);
57     if (!elem) {
58       qWarning() << "Failed to create" << elementName;
59       return 0;
60     }
61
62     g_object_set(cameraBin, prop, elem, NULL);
63
64     return elem;
65   }
66
67   void createAndAddVideoSource() {
68     // TODO: rework this function
69     GstElement *src, *wrapper;
70     QString wrapperSrc = conf->wrapperVideoSource();
71     QString prop = conf->wrapperVideoSourceProperty();
72
73     if (!prop.isEmpty() && !wrapperSrc.isEmpty()) {
74       wrapper = gst_element_factory_make(wrapperSrc.toAscii(), "QCameraWrapperVideoSrc");
75       if (!wrapper) {
76         qCritical() << "Failed to create wrapper source" << wrapperSrc;
77         return;
78       }
79     }
80
81     src = gst_element_factory_make(conf->videoSource().toAscii(),
82                                                "QtCameraVideoSrc");
83     if (!src) {
84       qCritical() << "Failed to create video source";
85       if (wrapper) {
86         gst_object_unref(wrapper);
87       }
88       return;
89     }
90
91     if (wrapper) {
92       g_object_set(wrapper, prop.toAscii(), src, NULL);
93       g_object_set(cameraBin, "camera-source", wrapper, NULL);
94     }
95
96     videoSource = src;
97     wrapperVideoSource = wrapper;
98
99     if (!id.isValid() || id.isNull()) {
100       return;
101     }
102
103     if (conf->deviceScannerType() == SCANNER_TYPE_ENUM) {
104       int dev = id.toInt();
105       g_object_set(src, conf->deviceScannerProperty().toAscii().data(), dev, NULL);
106     }
107     else {
108       QString dev = id.toString();
109       g_object_set(src, conf->deviceScannerProperty().toAscii().data(),
110                    dev.toAscii().data(), NULL);
111     }
112   }
113
114   bool setViewfinderSink() {
115     GstElement *sink;
116     g_object_get(cameraBin, "viewfinder-sink", &sink, NULL);
117
118     if (sink) {
119       gst_object_unref(sink);
120       return true;
121     }
122
123     sink = viewfinder->sinkElement();
124     if (!sink) {
125       qCritical() << "Failed to create GStreamer sink element";
126       return false;
127     }
128
129     g_object_set(cameraBin, "viewfinder-sink", sink, NULL);
130
131     return true;
132   }
133
134   void _d_error(const QString& message, int code, const QString& debug) {
135     if (stopping) {
136       // TODO: is it wise to ignore errors while stopping??
137       return;
138     }
139
140     error = true;
141
142     QMetaObject::invokeMethod(q_ptr, "error", Q_ARG(QString, message),
143                               Q_ARG(int, code), Q_ARG(QString, debug));
144
145     if (active) {
146       QMetaObject::invokeMethod(active, "canCaptureChanged", Qt::QueuedConnection);
147     }
148   }
149
150   void _d_stopped() {
151     QMetaObject::invokeMethod(q_ptr, "stopped");
152   }
153
154   void _d_stopping() {
155     if (active) {
156       QMetaObject::invokeMethod(active, "canCaptureChanged", Qt::QueuedConnection);
157     }
158
159     QMetaObject::invokeMethod(q_ptr, "stopping", Qt::QueuedConnection);
160     QMetaObject::invokeMethod(q_ptr, "runningStateChanged", Qt::QueuedConnection,
161                               Q_ARG(bool, false));
162   }
163
164   void _d_started() {
165     if (active) {
166       QMetaObject::invokeMethod(active, "canCaptureChanged", Qt::QueuedConnection);
167     }
168
169     QMetaObject::invokeMethod(q_ptr, "started", Qt::QueuedConnection);
170     QMetaObject::invokeMethod(q_ptr, "runningStateChanged", Qt::QueuedConnection,
171                               Q_ARG(bool, true));
172   }
173
174   void setAudioCaptureCaps() {
175     QString captureCaps = conf->audioCaptureCaps();
176     if (!captureCaps.isEmpty()) {
177       GstCaps *caps = gst_caps_from_string(captureCaps.toAscii().data());
178       if (caps) {
179         g_object_set(cameraBin, "audio-capture-caps", caps, NULL);
180         gst_caps_unref(caps);
181       }
182     }
183   }
184
185   bool isWrapperReady() {
186     if (!wrapperVideoSource) {
187       return false;
188     }
189
190     gboolean ready = FALSE;
191     g_object_get(wrapperVideoSource, "ready-for-capture", &ready, NULL);
192
193     return ready == TRUE;
194   }
195
196   static void on_ready_for_capture_changed(GObject *obj, GParamSpec *pspec,
197                                            QtCamDevicePrivate *d)  {
198     Q_UNUSED(obj);
199     Q_UNUSED(pspec);
200
201     if (!d->active) {
202       return;
203     }
204
205     QMetaObject::invokeMethod(d->active, "canCaptureChanged", Qt::QueuedConnection);
206   }
207
208   static void on_idle_changed(GObject *obj, GParamSpec *pspec, QtCamDevicePrivate *d) {
209     Q_UNUSED(obj);
210     Q_UNUSED(pspec);
211
212     QMetaObject::invokeMethod(d->q_ptr, "idleStateChanged", Qt::QueuedConnection,
213                               Q_ARG(bool, d->q_ptr->isIdle()));
214   }
215
216 #if 0
217   void resetCapabilities() {
218     g_object_set(cameraBin, "zoom", 1.0, NULL);
219     g_object_set(videoSource, "flash-mode", 0, NULL);
220
221     // TODO: should scene mode be manual or automatic ?
222     g_object_set(videoSource, "scene-mode", 0, NULL);
223   }
224 #endif
225
226   QString name;
227   QVariant id;
228
229   QtCamDevice *q_ptr;
230
231   GstElement *cameraBin;
232   GstElement *videoSource;
233   GstElement *wrapperVideoSource;
234
235   QtCamImageMode *image;
236   QtCamVideoMode *video;
237   QtCamMode *active;
238
239   QtCamViewfinder *viewfinder;
240   QtCamConfig *conf;
241   QtCamGStreamerMessageListener *listener;
242   bool error;
243   QtCamNotifications *notifications;
244   bool stopping;
245 };
246
247 #endif /* QT_CAM_DEVICE_P_H */