{
GstDV1394Src *dv1394src = GST_DV1394SRC (cbdata);
- if (!GST_PAD_CAPS (GST_BASE_SRC_PAD (dv1394src))) {
+ if (G_UNLIKELY (!GST_PAD_CAPS (GST_BASE_SRC_PAD (dv1394src)))) {
GstCaps *caps;
unsigned char *p = data;
gst_pad_set_caps (GST_BASE_SRC_PAD (dv1394src), caps);
gst_caps_unref (caps);
}
+
dv1394src->frame = NULL;
- if ((dv1394src->frame_sequence + 1) % (dv1394src->skip +
- dv1394src->consecutive) < dv1394src->consecutive) {
+ if (G_LIKELY ((dv1394src->frame_sequence + 1) % (dv1394src->skip +
+ dv1394src->consecutive) < dv1394src->consecutive)) {
if (complete && len == dv1394src->frame_size) {
gint64 i64;
guint8 *bufdata;
while (TRUE) {
int res = poll (pollfds, 2, -1);
- if (res < 0) {
+ if (G_UNLIKELY (res < 0)) {
if (errno == EAGAIN || errno == EINTR)
continue;
else
goto error_while_polling;
}
+
if (G_UNLIKELY (pollfds[1].revents)) {
char command;
GST_LOG ("data:%p, len:%d, dropped:%d", data, len, dropped);
/* error out if we don't have enough room ! */
- if (dv1394src->outoffset > (2048 * 188 - len))
+ if (G_UNLIKELY (dv1394src->outoffset > (2048 * 188 - len)))
return -1;
- if (len == IEC61883_MPEG2_TSP_SIZE) {
+ if (G_LIKELY (len == IEC61883_MPEG2_TSP_SIZE)) {
memcpy ((guint8 *) dv1394src->outdata + dv1394src->outoffset, data, len);
dv1394src->outoffset += len;
}
GST_LOG ("res:%d", res);
- if (res < 0) {
+ if (G_UNLIKELY (res < 0)) {
if (errno == EAGAIN || errno == EINTR)
continue;
else
goto error_while_polling;
}
+
if (G_UNLIKELY (pollfds[1].revents)) {
char command;