← Back to branch summary

~ubuntu-branches/ubuntu/raring/rygel/raring

« back to all changes in this revision

Viewing changes to tests/rygel-http-gst-sink.c

  • Committer: Package Import Robot
  • Author(s): Andreas Henriksson
  • Date: 2012-09-26 22:34:15 UTC
  • mfrom: (1.3.2)
  • mto: (14.1.10 sid)
  • mto: This revision was merged to the branch mainline in revision 27.
  • Revision ID: package-import@ubuntu.com-20120926223415-mem27auv86jjrj9k
Imported Upstream version 0.16.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
tests/rygel-http-gst-sink.c
1
 
/* rygel-http-gst-sink.c generated by valac 0.17.4.16-52707, the Vala compiler
 
1
/* rygel-http-gst-sink.c generated by valac 0.16.1, the Vala compiler
2
2
 * generated from rygel-http-gst-sink.vala, do not modify */
3
3
 
4
4
/*
167
167
static gboolean ___lambda4__gsource_func (gpointer self);
168
168
void rygel_http_response_push_data (RygelHTTPResponse* self, guint8* data, int data_length1);
169
169
static void rygel_http_gst_sink_finalize (GObject* obj);
170
 
static void _vala_clear_GMutex (GMutex * mutex);
171
 
static void _vala_clear_GRecMutex (GRecMutex * mutex);
172
 
static void _vala_clear_GRWLock (GRWLock * mutex);
173
 
static void _vala_clear_GCond (GCond * mutex);
174
170
 
175
171
 
176
172
static void _rygel_http_gst_sink_on_cancelled_g_cancellable_cancelled (GCancellable* _sender, gpointer self) {
177
173
#line 72 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
178
174
        rygel_http_gst_sink_on_cancelled (self);
179
 
#line 180 "rygel-http-gst-sink.c"
 
175
#line 176 "rygel-http-gst-sink.c"
180
176
}
181
177
 
182
178
 
183
179
static void _rygel_http_gst_sink_on_wrote_chunk_soup_message_wrote_chunk (SoupMessage* _sender, gpointer self) {
184
180
#line 73 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
185
181
        rygel_http_gst_sink_on_wrote_chunk (self, _sender);
186
 
#line 187 "rygel-http-gst-sink.c"
 
182
#line 183 "rygel-http-gst-sink.c"
187
183
}
188
184
 
189
185
 
240
236
        _tmp7_ = _tmp6_->seek;
241
237
#line 66 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
242
238
        if (_tmp7_ != NULL) {
243
 
#line 244 "rygel-http-gst-sink.c"
 
239
#line 240 "rygel-http-gst-sink.c"
244
240
                RygelHTTPResponse* _tmp8_;
245
241
                RygelHTTPSeek* _tmp9_;
246
242
#line 67 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
248
244
#line 67 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
249
245
                _tmp9_ = _tmp8_->seek;
250
246
#line 67 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
251
 
                if (G_TYPE_CHECK_INSTANCE_TYPE (_tmp9_, RYGEL_TYPE_HTTP_BYTE_SEEK)) {
252
 
#line 253 "rygel-http-gst-sink.c"
 
247
                if (RYGEL_IS_HTTP_BYTE_SEEK (_tmp9_)) {
 
248
#line 249 "rygel-http-gst-sink.c"
253
249
                        RygelHTTPResponse* _tmp10_;
254
250
                        RygelHTTPSeek* _tmp11_;
255
251
                        gint64 _tmp12_;
264
260
                        _tmp13_ = _tmp12_;
265
261
#line 68 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
266
262
                        self->priv->max_bytes = _tmp13_;
267
 
#line 268 "rygel-http-gst-sink.c"
 
263
#line 264 "rygel-http-gst-sink.c"
268
264
                }
269
265
        }
270
266
#line 72 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
279
275
        g_signal_connect_object (_tmp16_, "wrote-chunk", (GCallback) _rygel_http_gst_sink_on_wrote_chunk_soup_message_wrote_chunk, self, 0);
280
276
#line 54 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
281
277
        return self;
282
 
#line 283 "rygel-http-gst-sink.c"
 
278
#line 279 "rygel-http-gst-sink.c"
283
279
}
284
280
 
285
281
 
286
282
RygelHTTPGstSink* rygel_http_gst_sink_new (RygelHTTPResponse* response) {
287
283
#line 54 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
288
284
        return rygel_http_gst_sink_construct (RYGEL_TYPE_HTTP_GST_SINK, response);
289
 
#line 290 "rygel-http-gst-sink.c"
 
285
#line 286 "rygel-http-gst-sink.c"
290
286
}
291
287
 
292
288
 
293
289
static gpointer _gst_buffer_ref0 (gpointer self) {
294
290
#line 76 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
295
291
        return self ? gst_buffer_ref (self) : NULL;
296
 
#line 297 "rygel-http-gst-sink.c"
 
292
#line 293 "rygel-http-gst-sink.c"
297
293
}
298
294
 
299
295
 
302
298
        g_atomic_int_inc (&_data2_->_ref_count_);
303
299
#line 76 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
304
300
        return _data2_;
305
 
#line 306 "rygel-http-gst-sink.c"
 
301
#line 302 "rygel-http-gst-sink.c"
306
302
}
307
303
 
308
304
 
311
307
        _data2_ = (Block2Data*) _userdata_;
312
308
#line 76 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
313
309
        if (g_atomic_int_dec_and_test (&_data2_->_ref_count_)) {
314
 
#line 315 "rygel-http-gst-sink.c"
 
310
#line 311 "rygel-http-gst-sink.c"
315
311
                RygelHTTPGstSink * self;
316
312
#line 76 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
317
313
                self = _data2_->self;
321
317
                _gst_object_unref0 (self);
322
318
#line 76 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
323
319
                g_slice_free (Block2Data, _data2_);
324
 
#line 325 "rygel-http-gst-sink.c"
 
320
#line 321 "rygel-http-gst-sink.c"
325
321
        }
326
322
}
327
323
 
341
337
        result = _tmp1_;
342
338
#line 90 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
343
339
        return result;
344
 
#line 345 "rygel-http-gst-sink.c"
 
340
#line 341 "rygel-http-gst-sink.c"
345
341
}
346
342
 
347
343
 
350
346
        result = __lambda4_ (self);
351
347
#line 89 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
352
348
        return result;
353
 
#line 354 "rygel-http-gst-sink.c"
 
349
#line 350 "rygel-http-gst-sink.c"
354
350
}
355
351
 
356
352
 
383
379
        g_mutex_lock (&self->priv->buffer_mutex);
384
380
#line 78 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
385
381
        while (TRUE) {
386
 
#line 387 "rygel-http-gst-sink.c"
 
382
#line 383 "rygel-http-gst-sink.c"
387
383
                gboolean _tmp2_ = FALSE;
388
384
                GCancellable* _tmp3_;
389
385
                gboolean _tmp4_ = FALSE;
395
391
                _tmp4_ = g_cancellable_is_cancelled (_tmp3_);
396
392
#line 78 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
397
393
                if (!_tmp4_) {
398
 
#line 399 "rygel-http-gst-sink.c"
 
394
#line 395 "rygel-http-gst-sink.c"
399
395
                        gint64 _tmp5_;
400
396
#line 79 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
401
397
                        _tmp5_ = self->priv->chunks_buffered;
402
398
#line 79 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
403
399
                        _tmp2_ = _tmp5_ > ((gint64) RYGEL_HTTP_GST_SINK_MAX_BUFFERED_CHUNKS);
404
 
#line 405 "rygel-http-gst-sink.c"
 
400
#line 401 "rygel-http-gst-sink.c"
405
401
                } else {
406
402
#line 78 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
407
403
                        _tmp2_ = FALSE;
408
 
#line 409 "rygel-http-gst-sink.c"
 
404
#line 405 "rygel-http-gst-sink.c"
409
405
                }
410
406
#line 78 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
411
407
                _tmp6_ = _tmp2_;
413
409
                if (!_tmp6_) {
414
410
#line 78 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
415
411
                        break;
416
 
#line 417 "rygel-http-gst-sink.c"
 
412
#line 413 "rygel-http-gst-sink.c"
417
413
                }
418
414
#line 81 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
419
415
                _tmp7_ = self->priv->buffer_mutex;
420
416
#line 81 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
421
417
                g_cond_wait (&self->priv->buffer_condition, &_tmp7_);
422
 
#line 423 "rygel-http-gst-sink.c"
 
418
#line 419 "rygel-http-gst-sink.c"
423
419
        }
424
420
#line 83 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
425
421
        g_mutex_unlock (&self->priv->buffer_mutex);
437
433
                _data2_ = NULL;
438
434
#line 86 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
439
435
                return result;
440
 
#line 441 "rygel-http-gst-sink.c"
 
436
#line 437 "rygel-http-gst-sink.c"
441
437
        }
442
438
#line 89 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
443
439
        _tmp10_ = self->priv->priority;
451
447
        _data2_ = NULL;
452
448
#line 93 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
453
449
        return result;
454
 
#line 455 "rygel-http-gst-sink.c"
 
450
#line 451 "rygel-http-gst-sink.c"
455
451
}
456
452
 
457
453
 
495
491
        if (_tmp4_) {
496
492
#line 100 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
497
493
                _tmp2_ = TRUE;
498
 
#line 499 "rygel-http-gst-sink.c"
 
494
#line 495 "rygel-http-gst-sink.c"
499
495
        } else {
500
496
                gint64 _tmp5_;
501
497
#line 100 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
502
498
                _tmp5_ = left;
503
499
#line 100 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
504
500
                _tmp2_ = _tmp5_ <= ((gint64) 0);
505
 
#line 506 "rygel-http-gst-sink.c"
 
501
#line 502 "rygel-http-gst-sink.c"
506
502
        }
507
503
#line 100 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
508
504
        _tmp6_ = _tmp2_;
512
508
                result = FALSE;
513
509
#line 101 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
514
510
                return result;
515
 
#line 516 "rygel-http-gst-sink.c"
 
511
#line 512 "rygel-http-gst-sink.c"
516
512
        }
517
513
#line 104 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
518
514
        _tmp7_ = buffer;
550
546
        result = FALSE;
551
547
#line 110 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
552
548
        return result;
553
 
#line 554 "rygel-http-gst-sink.c"
 
549
#line 550 "rygel-http-gst-sink.c"
554
550
}
555
551
 
556
552
 
573
569
        if (_tmp1_ < ((gint64) RYGEL_HTTP_GST_SINK_MIN_BUFFERED_CHUNKS)) {
574
570
#line 118 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
575
571
                g_cond_broadcast (&self->priv->buffer_condition);
 
572
#line 573 "rygel-http-gst-sink.c"
 
573
        }
 
574
#line 120 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
 
575
        g_mutex_unlock (&self->priv->buffer_mutex);
576
576
#line 577 "rygel-http-gst-sink.c"
577
 
        }
578
 
#line 120 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
579
 
        g_mutex_unlock (&self->priv->buffer_mutex);
580
 
#line 581 "rygel-http-gst-sink.c"
581
577
}
582
578
 
583
579
 
601
597
        g_signal_parse_name ("wrote-chunk", soup_message_get_type (), &_tmp2_, NULL, FALSE);
602
598
#line 128 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
603
599
        g_signal_handlers_disconnect_matched (_tmp1_, G_SIGNAL_MATCH_ID | G_SIGNAL_MATCH_FUNC | G_SIGNAL_MATCH_DATA, _tmp2_, 0, NULL, (GCallback) _rygel_http_gst_sink_on_wrote_chunk_soup_message_wrote_chunk, self);
604
 
#line 605 "rygel-http-gst-sink.c"
 
600
#line 601 "rygel-http-gst-sink.c"
605
601
}
606
602
 
607
603
 
608
604
static gpointer _gst_caps_ref0 (gpointer self) {
609
605
#line 47 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
610
606
        return self ? gst_caps_ref (self) : NULL;
611
 
#line 612 "rygel-http-gst-sink.c"
 
607
#line 608 "rygel-http-gst-sink.c"
612
608
}
613
609
 
614
610
 
650
646
        _gst_object_unref0 (template);
651
647
#line 45 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
652
648
        _gst_caps_unref0 (caps);
653
 
#line 654 "rygel-http-gst-sink.c"
 
649
#line 650 "rygel-http-gst-sink.c"
654
650
}
655
651
 
656
652
 
667
663
        g_cond_init (&_tmp1_);
668
664
#line 43 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
669
665
        self->priv->buffer_condition = _tmp1_;
670
 
#line 671 "rygel-http-gst-sink.c"
 
666
#line 667 "rygel-http-gst-sink.c"
671
667
}
672
668
 
673
669
 
674
670
static void rygel_http_gst_sink_finalize (GObject* obj) {
675
671
        RygelHTTPGstSink * self;
676
672
#line 26 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
677
 
        self = G_TYPE_CHECK_INSTANCE_CAST (obj, RYGEL_TYPE_HTTP_GST_SINK, RygelHTTPGstSink);
 
673
        self = RYGEL_HTTP_GST_SINK (obj);
678
674
#line 33 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
679
675
        _g_object_unref0 (self->cancellable);
680
676
#line 42 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
681
 
        _vala_clear_GMutex (&self->priv->buffer_mutex);
 
677
        g_mutex_clear (&self->priv->buffer_mutex);
682
678
#line 43 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
683
 
        _vala_clear_GCond (&self->priv->buffer_condition);
 
679
        g_cond_clear (&self->priv->buffer_condition);
684
680
#line 26 "/home/jens/Source/rygel/tests/rygel-http-gst-sink.vala"
685
681
        G_OBJECT_CLASS (rygel_http_gst_sink_parent_class)->finalize (obj);
686
 
#line 687 "rygel-http-gst-sink.c"
 
682
#line 683 "rygel-http-gst-sink.c"
687
683
}
688
684
 
689
685
 
699
695
}
700
696
 
701
697
 
702
 
static void _vala_clear_GMutex (GMutex * mutex) {
703
 
        GMutex zero_mutex = { 0 };
704
 
        if (memcmp (mutex, &zero_mutex, sizeof (GMutex))) {
705
 
                g_mutex_clear (mutex);
706
 
                memset (mutex, 0, sizeof (GMutex));
707
 
        }
708
 
}
709
 
 
710
 
 
711
 
static void _vala_clear_GRecMutex (GRecMutex * mutex) {
712
 
        GRecMutex zero_mutex = { 0 };
713
 
        if (memcmp (mutex, &zero_mutex, sizeof (GRecMutex))) {
714
 
                g_rec_mutex_clear (mutex);
715
 
                memset (mutex, 0, sizeof (GRecMutex));
716
 
        }
717
 
}
718
 
 
719
 
 
720
 
static void _vala_clear_GRWLock (GRWLock * mutex) {
721
 
        GRWLock zero_mutex = { 0 };
722
 
        if (memcmp (mutex, &zero_mutex, sizeof (GRWLock))) {
723
 
                g_rw_lock_clear (mutex);
724
 
                memset (mutex, 0, sizeof (GRWLock));
725
 
        }
726
 
}
727
 
 
728
 
 
729
 
static void _vala_clear_GCond (GCond * mutex) {
730
 
        GCond zero_mutex = { 0 };
731
 
        if (memcmp (mutex, &zero_mutex, sizeof (GCond))) {
732
 
                g_cond_clear (mutex);
733
 
                memset (mutex, 0, sizeof (GCond));
734
 
        }
735
 
}
736
 
 
737
 
 
738
698