← Back to branch summary

~ricmm/+junk/unity-lens_music-sc

« back to all changes in this revision

Viewing changes to src/player.vala

  • Committer: Ricardo Mendoza
  • Date: 2012-09-05 14:20:15 UTC
  • Revision ID: ricardo.mendoza@canonical.com-20120905142015-prem6hiyfshwgm8q
Initial commit

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/player.vala
 
1
/*
 
2
 * Copyright (C) 2012 Canonical Ltd
 
3
 *
 
4
 * This program is free software: you can redistribute it and/or modify
 
5
 * it under the terms of the GNU General Public License version 3 as
 
6
 * published by the Free Software Foundation.
 
7
 *
 
8
 * This program is distributed in the hope that it will be useful,
 
9
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
 * GNU General Public License for more details.
 
12
 *
 
13
 * You should have received a copy of the GNU General Public License
 
14
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
15
 *
 
16
 * Authored by Pawel Stolowski <pawel.stolowski@canonical.com>
 
17
 */
 
18
 
 
19
using Gst;
 
20
 
 
21
namespace PreviewPlayer
 
22
{
 
23
  errordomain PreviewPlayerError
 
24
  {
 
25
    GST_INIT_FAILED
 
26
  }
 
27
 
 
28
  public class PreviewPlayer
 
29
  {
 
30
    // Track states; keep in sync with libunity - TrackState enum
 
31
    private enum TrackState
 
32
    {
 
33
      STOPPED,
 
34
      PLAYING,
 
35
      PAUSED
 
36
    }
 
37
 
 
38
    private static uint64 GST_STATE_QUERY_TIMEOUT = 1000000;
 
39
 
 
40
    // gstreamer - playbin plugin flags; run 'gst-inspect-0.10 playbin2' for more flags & description
 
41
    private static int GST_PLAYBIN_AUDIO = 0x02;
 
42
    private static int GST_PLAYBIN_SOFT_VOLUME = 0x10;
 
43
 
 
44
    private Gst.Pipeline gst_pipeline;
 
45
    private Gst.Element gst_playbin;
 
46
    private Gst.Element gst_sink;
 
47
    private Gst.Bus gst_bus;
 
48
    private uint timer_id;
 
49
    private string uri;
 
50
        
 
51
    public signal void progress (string uri, uint32 state, double value);
 
52
 
 
53
    public PreviewPlayer () throws PreviewPlayerError
 
54
    {
 
55
      timer_id = 0;
 
56
      init_gst ();
 
57
    }
 
58
 
 
59
    internal void init_gst () throws PreviewPlayerError
 
60
    {
 
61
      gst_pipeline = new Gst.Pipeline ("preview-player-pipeline");
 
62
      gst_playbin = Gst.ElementFactory.make ("playbin2", "playbin2");
 
63
      gst_sink = Gst.ElementFactory.make ("pulsesink", "sink");
 
64
      if (gst_sink == null)
 
65
      {
 
66
        gst_sink = Gst.ElementFactory.make ("alsasink", "sink");
 
67
        if (gst_sink == null)
 
68
        {
 
69
          throw new PreviewPlayerError.GST_INIT_FAILED ("Can't create backend sink");
 
70
        }
 
71
      }
 
72
      
 
73
      gst_playbin.set_property ("audio-sink", gst_sink);
 
74
      gst_playbin.set_property ("flags", GST_PLAYBIN_AUDIO | GST_PLAYBIN_SOFT_VOLUME);
 
75
      
 
76
      gst_pipeline.add (gst_playbin);
 
77
 
 
78
      gst_bus = gst_pipeline.get_bus ();
 
79
      gst_bus.add_watch_full (GLib.Priority.DEFAULT, gst_bus_message_cb);
 
80
    }
 
81
 
 
82
    internal bool gst_bus_message_cb (Gst.Bus bus, Gst.Message message)
 
83
    {
 
84
      if (message.type == Gst.MessageType.EOS)
 
85
      {
 
86
        gst_pipeline.set_state (Gst.State.READY);
 
87
        progress (uri, TrackState.PLAYING, 1.0f);
 
88
      }
 
89
      return true;
 
90
    }
 
91
 
 
92
    private bool progress_report_cb ()
 
93
    {
 
94
      Gst.State current_state;
 
95
      Gst.State pending_state;
 
96
 
 
97
      var status = gst_pipeline.get_state (out current_state, out pending_state, GST_STATE_QUERY_TIMEOUT);
 
98
      
 
99
      if (status != Gst.StateChangeReturn.FAILURE)
 
100
      {
 
101
        if (current_state == Gst.State.PLAYING || pending_state == Gst.State.PLAYING)
 
102
        {
 
103
          progress (uri, TrackState.PLAYING, gst_progress ());
 
104
          return true;
 
105
        }
 
106
        if (current_state == Gst.State.PAUSED || pending_state == Gst.State.PAUSED)
 
107
        {
 
108
          return true;
 
109
        }
 
110
        progress (uri, TrackState.STOPPED, 0.0f);             
 
111
      }
 
112
      
 
113
      return false;
 
114
    }
 
115
 
 
116
    private double gst_progress ()
 
117
    {
 
118
      int64 pos;
 
119
      int64 dur;
 
120
 
 
121
      var fmt = Gst.Format.TIME;
 
122
      if (gst_pipeline.query_position (ref fmt, out pos))
 
123
      {
 
124
        if (gst_pipeline.query_duration (ref fmt, out dur))
 
125
        {
 
126
          if (dur > 0)
 
127
          {
 
128
            return pos / (double)dur;
 
129
          }
 
130
        }
 
131
      }
 
132
      return 0.0f;
 
133
    }
 
134
 
 
135
    private bool is_playing ()
 
136
    {
 
137
      Gst.State current_state;
 
138
      Gst.State pending_state;
 
139
 
 
140
      var status = gst_pipeline.get_state (out current_state, out pending_state, GST_STATE_QUERY_TIMEOUT);
 
141
      return status != Gst.StateChangeReturn.FAILURE && (current_state == Gst.State.PLAYING || pending_state == Gst.State.PLAYING);
 
142
    }
 
143
 
 
144
    public void play (string uri)
 
145
    {
 
146
      // resume playback for same uri
 
147
      if (uri == this.uri)
 
148
      {
 
149
        Gst.State current_state;
 
150
        Gst.State pending_state;
 
151
      
 
152
        var status = gst_pipeline.get_state (out current_state, out pending_state, GST_STATE_QUERY_TIMEOUT);
 
153
        if (status != Gst.StateChangeReturn.FAILURE)
 
154
        {
 
155
          if (current_state == Gst.State.PAUSED || pending_state == Gst.State.PAUSED)
 
156
          {
 
157
            gst_pipeline.set_state (Gst.State.PLAYING);
 
158
            progress (uri, TrackState.PLAYING, gst_progress ());
 
159
            return;
 
160
          }
 
161
        }
 
162
      }
 
163
 
 
164
      // start new playback
 
165
      if (timer_id > 0)
 
166
      {
 
167
        GLib.Source.remove(timer_id);
 
168
      }
 
169
      this.uri = uri;
 
170
      gst_pipeline.set_state (Gst.State.NULL);
 
171
      gst_playbin.set_property ("uri", uri);
 
172
      gst_pipeline.set_state (Gst.State.PLAYING);
 
173
      
 
174
      timer_id = GLib.Timeout.add_seconds (1, progress_report_cb);
 
175
    }
 
176
 
 
177
    public void stop ()
 
178
    {
 
179
      Gst.State current_state;
 
180
      Gst.State pending_state;
 
181
 
 
182
      var status = gst_pipeline.get_state (out current_state, out pending_state, GST_STATE_QUERY_TIMEOUT);
 
183
      if (status != Gst.StateChangeReturn.FAILURE)
 
184
      {
 
185
        if (current_state == Gst.State.PAUSED || current_state == Gst.State.PLAYING ||
 
186
            pending_state == Gst.State.PAUSED || pending_state == Gst.State.PLAYING)
 
187
        {
 
188
          gst_pipeline.set_state (Gst.State.READY);
 
189
          progress (uri, TrackState.STOPPED, 0.0f);
 
190
        }
 
191
      }
 
192
    }
 
193
 
 
194
    public void pause ()
 
195
    {
 
196
      if (is_playing())
 
197
      {
 
198
        gst_pipeline.set_state (Gst.State.PAUSED);
 
199
        progress (uri, TrackState.PAUSED, gst_progress ());
 
200
      }
 
201
    }
 
202
 
 
203
    public void resume ()
 
204
    {
 
205
      Gst.State current_state;
 
206
      Gst.State pending_state;
 
207
      
 
208
      var status = gst_pipeline.get_state (out current_state, out pending_state, GST_STATE_QUERY_TIMEOUT);
 
209
      if (status != Gst.StateChangeReturn.FAILURE)
 
210
      {
 
211
        if (current_state == Gst.State.PAUSED || pending_state == Gst.State.PAUSED)
 
212
        {
 
213
          gst_pipeline.set_state (Gst.State.PLAYING);
 
214
          progress (uri, TrackState.PLAYING, gst_progress ());
 
215
        }
 
216
      }
 
217
    }
 
218
    
 
219
    public void pause_resume()
 
220
    {
 
221
      Gst.State current_state;
 
222
      Gst.State pending_state;
 
223
      
 
224
      var status = gst_pipeline.get_state (out current_state, out pending_state, GST_STATE_QUERY_TIMEOUT);
 
225
      
 
226
      if (status != Gst.StateChangeReturn.FAILURE)
 
227
      {
 
228
        TrackState track_state = TrackState.STOPPED;
 
229
        Gst.State gst_state = Gst.State.NULL;
 
230
        
 
231
        if (current_state == Gst.State.PLAYING || pending_state == Gst.State.PLAYING)
 
232
        {
 
233
          track_state = TrackState.PAUSED;
 
234
          gst_state = Gst.State.PAUSED;
 
235
          gst_pipeline.set_state (Gst.State.PAUSED);
 
236
        }
 
237
        else if (current_state == Gst.State.PAUSED || pending_state == Gst.State.PAUSED)
 
238
        {
 
239
          track_state = TrackState.PLAYING;
 
240
          gst_state = Gst.State.PLAYING;
 
241
        }
 
242
 
 
243
        if (gst_state != Gst.State.NULL)
 
244
        {
 
245
          gst_pipeline.set_state (gst_state);
 
246
          progress (uri, track_state, gst_progress ());
 
247
        }
 
248
      }
 
249
    }
 
250
     
 
251
    public HashTable<string, Variant> get_video_file_props (string uri)
 
252
    {
 
253
      var props = new HashTable<string, Variant> (str_hash, str_equal);
 
254
 
 
255
      try
 
256
      {
 
257
        var discoverer = new Gst.Discoverer (2 * 1000000000); //2 seconds
 
258
        var discoverer_info = discoverer.discover_uri (uri);
 
259
        var video_streams = discoverer_info.get_video_streams ();
 
260
 
 
261
        // note: the container may have multiple video and audio streams, we just get properties of the first one
 
262
        if (video_streams != null && video_streams.length () > 0)
 
263
        {
 
264
          var vstream = video_streams.nth_data (0);
 
265
          props.insert ("width", new GLib.Variant.uint32 (vstream.get_width ()));
 
266
          props.insert ("height", new GLib.Variant.uint32 (vstream.get_height ()));
 
267
          props.insert ("codec", new GLib.Variant.string (Gst.pb_utils_get_codec_description (vstream.get_caps ())));
 
268
        }
 
269
      }
 
270
      catch (GLib.Error e)
 
271
      {
 
272
        stderr.printf ("Failed to get video file properties for '%s': '%s'\n", uri, e.message);
 
273
      }
 
274
 
 
275
      return props;
 
276
    }
 
277
  }
 
278
}
 
 
b'\\ No newline at end of file'