2 * Copyright (C) STMicroelectronics SA 2015
3 * Authors: Hugues Fruchet <hugues.fruchet@st.com>
4 * Jean-Christophe Trotin <jean-christophe.trotin@st.com>
5 * for STMicroelectronics.
6 * License terms: GNU General Public License (GPL), version 2
10 #include <linux/module.h>
11 #include <linux/platform_device.h>
12 #include <linux/pm_runtime.h>
13 #include <linux/slab.h>
15 #include <media/v4l2-ioctl.h>
16 #include <media/v4l2-event.h>
17 #include <media/videobuf2-dma-contig.h>
20 #include "delta-debug.h"
21 #include "delta-ipc.h"
23 #define DELTA_NAME "st-delta"
25 #define DELTA_PREFIX "[---:----]"
27 #define to_ctx(__fh) container_of(__fh, struct delta_ctx, fh)
28 #define to_au(__vbuf) container_of(__vbuf, struct delta_au, vbuf)
29 #define to_frame(__vbuf) container_of(__vbuf, struct delta_frame, vbuf)
31 #define call_dec_op(dec, op, args...)\
32 ((dec && (dec)->op) ? (dec)->op(args) : 0)
34 /* registry of available decoders */
35 static const struct delta_dec *delta_decoders[] = {
36 #ifdef CONFIG_VIDEO_STI_DELTA_MJPEG
41 static inline int frame_size(u32 w, u32 h, u32 fmt)
44 case V4L2_PIX_FMT_NV12:
45 return (w * h * 3) / 2;
51 static inline int frame_stride(u32 w, u32 fmt)
54 case V4L2_PIX_FMT_NV12:
61 static void dump_au(struct delta_ctx *ctx, struct delta_au *au)
63 struct delta_dev *delta = ctx->dev;
64 u32 size = 10; /* dump first & last 10 bytes */
65 u8 *data = (u8 *)(au->vaddr);
67 if (au->size <= (size * 2))
68 dev_dbg(delta->dev, "%s dump au[%d] dts=%lld size=%d data=%*ph\n",
69 ctx->name, au->vbuf.vb2_buf.index, au->dts, au->size,
72 dev_dbg(delta->dev, "%s dump au[%d] dts=%lld size=%d data=%*ph..%*ph\n",
73 ctx->name, au->vbuf.vb2_buf.index, au->dts, au->size,
74 size, data, size, data + au->size - size);
77 static void dump_frame(struct delta_ctx *ctx, struct delta_frame *frame)
79 struct delta_dev *delta = ctx->dev;
80 u32 size = 10; /* dump first 10 bytes */
81 u8 *data = (u8 *)(frame->vaddr);
83 dev_dbg(delta->dev, "%s dump frame[%d] dts=%lld type=%s field=%s data=%*ph\n",
84 ctx->name, frame->index, frame->dts,
85 frame_type_str(frame->flags),
86 frame_field_str(frame->field),
90 static void delta_au_done(struct delta_ctx *ctx, struct delta_au *au, int err)
92 struct vb2_v4l2_buffer *vbuf;
95 vbuf->sequence = ctx->au_num++;
96 v4l2_m2m_buf_done(vbuf, err ? VB2_BUF_STATE_ERROR : VB2_BUF_STATE_DONE);
99 static void delta_frame_done(struct delta_ctx *ctx, struct delta_frame *frame,
102 struct vb2_v4l2_buffer *vbuf;
104 dump_frame(ctx, frame);
106 /* decoded frame is now output to user */
107 frame->state |= DELTA_FRAME_OUT;
110 vbuf->sequence = ctx->frame_num++;
111 v4l2_m2m_buf_done(vbuf, err ? VB2_BUF_STATE_ERROR : VB2_BUF_STATE_DONE);
113 if (frame->info.size) /* ignore EOS */
114 ctx->output_frames++;
117 static void requeue_free_frames(struct delta_ctx *ctx)
119 struct vb2_v4l2_buffer *vbuf;
120 struct delta_frame *frame;
123 /* requeue all free frames */
124 for (i = 0; i < ctx->nb_of_frames; i++) {
125 frame = ctx->frames[i];
126 if (frame->state == DELTA_FRAME_FREE) {
128 v4l2_m2m_buf_queue(ctx->fh.m2m_ctx, vbuf);
129 frame->state = DELTA_FRAME_M2M;
134 static int delta_recycle(struct delta_ctx *ctx, struct delta_frame *frame)
136 const struct delta_dec *dec = ctx->dec;
138 /* recycle frame on decoder side */
139 call_dec_op(dec, recycle, ctx, frame);
141 /* this frame is no more output */
142 frame->state &= ~DELTA_FRAME_OUT;
144 /* requeue free frame */
145 if (frame->state == DELTA_FRAME_FREE) {
146 struct vb2_v4l2_buffer *vbuf = &frame->vbuf;
148 v4l2_m2m_buf_queue(ctx->fh.m2m_ctx, vbuf);
149 frame->state = DELTA_FRAME_M2M;
152 /* reset other frame fields */
159 static void delta_push_dts(struct delta_ctx *ctx, u64 val)
161 struct delta_dts *dts;
163 dts = kzalloc(sizeof(*dts), GFP_KERNEL);
167 INIT_LIST_HEAD(&dts->list);
170 * protected by global lock acquired
171 * by V4L2 when calling delta_vb2_au_queue
174 list_add_tail(&dts->list, &ctx->dts);
177 static void delta_pop_dts(struct delta_ctx *ctx, u64 *val)
179 struct delta_dev *delta = ctx->dev;
180 struct delta_dts *dts;
183 * protected by global lock acquired
184 * by V4L2 when calling delta_vb2_au_queue
186 if (list_empty(&ctx->dts)) {
187 dev_warn(delta->dev, "%s no dts to pop ... output dts = 0\n",
193 dts = list_first_entry(&ctx->dts, struct delta_dts, list);
194 list_del(&dts->list);
201 static void delta_flush_dts(struct delta_ctx *ctx)
203 struct delta_dts *dts;
204 struct delta_dts *next;
207 * protected by global lock acquired
208 * by V4L2 when calling delta_vb2_au_queue
211 /* free all pending dts */
212 list_for_each_entry_safe(dts, next, &ctx->dts, list)
216 INIT_LIST_HEAD(&ctx->dts);
219 static inline int frame_alignment(u32 fmt)
222 case V4L2_PIX_FMT_NV12:
223 case V4L2_PIX_FMT_NV21:
231 static inline int estimated_au_size(u32 w, u32 h)
234 * for a MJPEG stream encoded from YUV422 pixel format,
235 * assuming a compression ratio of 2, the maximum size
236 * of an access unit is (width x height x 2) / 2,
237 * so (width x height)
242 static void set_default_params(struct delta_ctx *ctx)
244 struct delta_frameinfo *frameinfo = &ctx->frameinfo;
245 struct delta_streaminfo *streaminfo = &ctx->streaminfo;
247 memset(frameinfo, 0, sizeof(*frameinfo));
248 frameinfo->pixelformat = V4L2_PIX_FMT_NV12;
249 frameinfo->width = DELTA_DEFAULT_WIDTH;
250 frameinfo->height = DELTA_DEFAULT_HEIGHT;
251 frameinfo->aligned_width = ALIGN(frameinfo->width,
252 DELTA_WIDTH_ALIGNMENT);
253 frameinfo->aligned_height = ALIGN(frameinfo->height,
254 DELTA_HEIGHT_ALIGNMENT);
255 frameinfo->size = frame_size(frameinfo->aligned_width,
256 frameinfo->aligned_height,
257 frameinfo->pixelformat);
258 frameinfo->field = V4L2_FIELD_NONE;
259 frameinfo->colorspace = V4L2_COLORSPACE_REC709;
260 frameinfo->xfer_func = V4L2_XFER_FUNC_DEFAULT;
261 frameinfo->ycbcr_enc = V4L2_YCBCR_ENC_DEFAULT;
262 frameinfo->quantization = V4L2_QUANTIZATION_DEFAULT;
264 memset(streaminfo, 0, sizeof(*streaminfo));
265 streaminfo->streamformat = DELTA_DEFAULT_STREAMFORMAT;
266 streaminfo->width = DELTA_DEFAULT_WIDTH;
267 streaminfo->height = DELTA_DEFAULT_HEIGHT;
268 streaminfo->field = V4L2_FIELD_NONE;
269 streaminfo->colorspace = V4L2_COLORSPACE_REC709;
270 streaminfo->xfer_func = V4L2_XFER_FUNC_DEFAULT;
271 streaminfo->ycbcr_enc = V4L2_YCBCR_ENC_DEFAULT;
272 streaminfo->quantization = V4L2_QUANTIZATION_DEFAULT;
274 ctx->max_au_size = estimated_au_size(streaminfo->width,
278 static const struct delta_dec *delta_find_decoder(struct delta_ctx *ctx,
282 struct delta_dev *delta = ctx->dev;
283 const struct delta_dec *dec;
286 for (i = 0; i < delta->nb_of_decoders; i++) {
287 dec = delta->decoders[i];
288 if ((dec->pixelformat == pixelformat) &&
289 (dec->streamformat == streamformat))
296 static void register_format(u32 format, u32 formats[], u32 *nb_of_formats)
300 for (i = 0; i < *nb_of_formats; i++) {
301 if (format == formats[i])
305 formats[(*nb_of_formats)++] = format;
308 static void register_formats(struct delta_dev *delta)
312 for (i = 0; i < delta->nb_of_decoders; i++) {
313 register_format(delta->decoders[i]->pixelformat,
315 &delta->nb_of_pixelformats);
317 register_format(delta->decoders[i]->streamformat,
318 delta->streamformats,
319 &delta->nb_of_streamformats);
323 static void register_decoders(struct delta_dev *delta)
327 for (i = 0; i < ARRAY_SIZE(delta_decoders); i++) {
328 if (delta->nb_of_decoders >= DELTA_MAX_DECODERS) {
330 "%s failed to register %s decoder (%d maximum reached)\n",
331 DELTA_PREFIX, delta_decoders[i]->name,
336 delta->decoders[delta->nb_of_decoders++] = delta_decoders[i];
337 dev_info(delta->dev, "%s %s decoder registered\n",
338 DELTA_PREFIX, delta_decoders[i]->name);
342 static void delta_lock(void *priv)
344 struct delta_ctx *ctx = priv;
345 struct delta_dev *delta = ctx->dev;
347 mutex_lock(&delta->lock);
350 static void delta_unlock(void *priv)
352 struct delta_ctx *ctx = priv;
353 struct delta_dev *delta = ctx->dev;
355 mutex_unlock(&delta->lock);
358 static int delta_open_decoder(struct delta_ctx *ctx, u32 streamformat,
359 u32 pixelformat, const struct delta_dec **pdec)
361 struct delta_dev *delta = ctx->dev;
362 const struct delta_dec *dec;
365 dec = delta_find_decoder(ctx, streamformat, ctx->frameinfo.pixelformat);
367 dev_err(delta->dev, "%s no decoder found matching %4.4s => %4.4s\n",
368 ctx->name, (char *)&streamformat, (char *)&pixelformat);
372 dev_dbg(delta->dev, "%s one decoder matching %4.4s => %4.4s\n",
373 ctx->name, (char *)&streamformat, (char *)&pixelformat);
375 /* update instance name */
376 snprintf(ctx->name, sizeof(ctx->name), "[%3d:%4.4s]",
377 delta->instance_id, (char *)&streamformat);
379 /* open decoder instance */
380 ret = call_dec_op(dec, open, ctx);
382 dev_err(delta->dev, "%s failed to open decoder instance (%d)\n",
387 dev_dbg(delta->dev, "%s %s decoder opened\n", ctx->name, dec->name);
395 * V4L2 ioctl operations
398 static int delta_querycap(struct file *file, void *priv,
399 struct v4l2_capability *cap)
401 struct delta_ctx *ctx = to_ctx(file->private_data);
402 struct delta_dev *delta = ctx->dev;
404 strlcpy(cap->driver, DELTA_NAME, sizeof(cap->driver));
405 strlcpy(cap->card, delta->vdev->name, sizeof(cap->card));
406 snprintf(cap->bus_info, sizeof(cap->bus_info), "platform:%s",
412 static int delta_enum_fmt_stream(struct file *file, void *priv,
413 struct v4l2_fmtdesc *f)
415 struct delta_ctx *ctx = to_ctx(file->private_data);
416 struct delta_dev *delta = ctx->dev;
418 if (unlikely(f->index >= delta->nb_of_streamformats))
421 f->pixelformat = delta->streamformats[f->index];
426 static int delta_enum_fmt_frame(struct file *file, void *priv,
427 struct v4l2_fmtdesc *f)
429 struct delta_ctx *ctx = to_ctx(file->private_data);
430 struct delta_dev *delta = ctx->dev;
432 if (unlikely(f->index >= delta->nb_of_pixelformats))
435 f->pixelformat = delta->pixelformats[f->index];
440 static int delta_g_fmt_stream(struct file *file, void *fh,
441 struct v4l2_format *f)
443 struct delta_ctx *ctx = to_ctx(file->private_data);
444 struct delta_dev *delta = ctx->dev;
445 struct v4l2_pix_format *pix = &f->fmt.pix;
446 struct delta_streaminfo *streaminfo = &ctx->streaminfo;
447 unsigned char str[100] = "";
449 if (!(ctx->flags & DELTA_FLAG_STREAMINFO))
451 "%s V4L2 GET_FMT (OUTPUT): no stream information available, default to %s\n",
453 delta_streaminfo_str(streaminfo, str, sizeof(str)));
455 pix->pixelformat = streaminfo->streamformat;
456 pix->width = streaminfo->width;
457 pix->height = streaminfo->height;
458 pix->field = streaminfo->field;
459 pix->bytesperline = 0;
460 pix->sizeimage = ctx->max_au_size;
461 pix->colorspace = streaminfo->colorspace;
462 pix->xfer_func = streaminfo->xfer_func;
463 pix->ycbcr_enc = streaminfo->ycbcr_enc;
464 pix->quantization = streaminfo->quantization;
469 static int delta_g_fmt_frame(struct file *file, void *fh, struct v4l2_format *f)
471 struct delta_ctx *ctx = to_ctx(file->private_data);
472 struct delta_dev *delta = ctx->dev;
473 struct v4l2_pix_format *pix = &f->fmt.pix;
474 struct delta_frameinfo *frameinfo = &ctx->frameinfo;
475 struct delta_streaminfo *streaminfo = &ctx->streaminfo;
476 unsigned char str[100] = "";
478 if (!(ctx->flags & DELTA_FLAG_FRAMEINFO))
480 "%s V4L2 GET_FMT (CAPTURE): no frame information available, default to %s\n",
482 delta_frameinfo_str(frameinfo, str, sizeof(str)));
484 pix->pixelformat = frameinfo->pixelformat;
485 pix->width = frameinfo->aligned_width;
486 pix->height = frameinfo->aligned_height;
487 pix->field = frameinfo->field;
488 pix->bytesperline = frame_stride(frameinfo->aligned_width,
489 frameinfo->pixelformat);
490 pix->sizeimage = frameinfo->size;
492 if (ctx->flags & DELTA_FLAG_STREAMINFO) {
493 /* align colorspace & friends on stream ones if any set */
494 frameinfo->colorspace = streaminfo->colorspace;
495 frameinfo->xfer_func = streaminfo->xfer_func;
496 frameinfo->ycbcr_enc = streaminfo->ycbcr_enc;
497 frameinfo->quantization = streaminfo->quantization;
499 pix->colorspace = frameinfo->colorspace;
500 pix->xfer_func = frameinfo->xfer_func;
501 pix->ycbcr_enc = frameinfo->ycbcr_enc;
502 pix->quantization = frameinfo->quantization;
507 static int delta_try_fmt_stream(struct file *file, void *priv,
508 struct v4l2_format *f)
510 struct delta_ctx *ctx = to_ctx(file->private_data);
511 struct delta_dev *delta = ctx->dev;
512 struct v4l2_pix_format *pix = &f->fmt.pix;
513 u32 streamformat = pix->pixelformat;
514 const struct delta_dec *dec;
518 dec = delta_find_decoder(ctx, streamformat, ctx->frameinfo.pixelformat);
521 "%s V4L2 TRY_FMT (OUTPUT): unsupported format %4.4s\n",
522 ctx->name, (char *)&pix->pixelformat);
526 /* adjust width & height */
528 height = pix->height;
529 v4l_bound_align_image
532 dec->max_width ? dec->max_width : DELTA_MAX_WIDTH,
536 dec->max_height ? dec->max_height : DELTA_MAX_HEIGHT,
539 if ((pix->width != width) || (pix->height != height))
541 "%s V4L2 TRY_FMT (OUTPUT): resolution updated %dx%d -> %dx%d to fit min/max/alignment\n",
542 ctx->name, width, height,
543 pix->width, pix->height);
545 au_size = estimated_au_size(pix->width, pix->height);
546 if (pix->sizeimage < au_size) {
548 "%s V4L2 TRY_FMT (OUTPUT): size updated %d -> %d to fit estimated size\n",
549 ctx->name, pix->sizeimage, au_size);
550 pix->sizeimage = au_size;
553 pix->bytesperline = 0;
555 if (pix->field == V4L2_FIELD_ANY)
556 pix->field = V4L2_FIELD_NONE;
561 static int delta_try_fmt_frame(struct file *file, void *priv,
562 struct v4l2_format *f)
564 struct delta_ctx *ctx = to_ctx(file->private_data);
565 struct delta_dev *delta = ctx->dev;
566 struct v4l2_pix_format *pix = &f->fmt.pix;
567 u32 pixelformat = pix->pixelformat;
568 const struct delta_dec *dec;
571 dec = delta_find_decoder(ctx, ctx->streaminfo.streamformat,
575 "%s V4L2 TRY_FMT (CAPTURE): unsupported format %4.4s\n",
576 ctx->name, (char *)&pixelformat);
580 /* adjust width & height */
582 height = pix->height;
583 v4l_bound_align_image(&pix->width,
584 DELTA_MIN_WIDTH, DELTA_MAX_WIDTH,
585 frame_alignment(pixelformat) - 1,
587 DELTA_MIN_HEIGHT, DELTA_MAX_HEIGHT,
588 frame_alignment(pixelformat) - 1, 0);
590 if ((pix->width != width) || (pix->height != height))
592 "%s V4L2 TRY_FMT (CAPTURE): resolution updated %dx%d -> %dx%d to fit min/max/alignment\n",
593 ctx->name, width, height, pix->width, pix->height);
595 /* default decoder alignment constraint */
596 width = ALIGN(pix->width, DELTA_WIDTH_ALIGNMENT);
597 height = ALIGN(pix->height, DELTA_HEIGHT_ALIGNMENT);
598 if ((pix->width != width) || (pix->height != height))
600 "%s V4L2 TRY_FMT (CAPTURE): resolution updated %dx%d -> %dx%d to fit decoder alignment\n",
601 ctx->name, width, height, pix->width, pix->height);
603 if (!pix->colorspace) {
604 pix->colorspace = V4L2_COLORSPACE_REC709;
605 pix->xfer_func = V4L2_XFER_FUNC_DEFAULT;
606 pix->ycbcr_enc = V4L2_YCBCR_ENC_DEFAULT;
607 pix->quantization = V4L2_QUANTIZATION_DEFAULT;
611 pix->height = height;
612 pix->bytesperline = frame_stride(pix->width, pixelformat);
613 pix->sizeimage = frame_size(pix->width, pix->height, pixelformat);
615 if (pix->field == V4L2_FIELD_ANY)
616 pix->field = V4L2_FIELD_NONE;
621 static int delta_s_fmt_stream(struct file *file, void *fh,
622 struct v4l2_format *f)
624 struct delta_ctx *ctx = to_ctx(file->private_data);
625 struct delta_dev *delta = ctx->dev;
626 struct vb2_queue *vq;
627 struct v4l2_pix_format *pix = &f->fmt.pix;
630 ret = delta_try_fmt_stream(file, fh, f);
633 "%s V4L2 S_FMT (OUTPUT): unsupported format %4.4s\n",
634 ctx->name, (char *)&pix->pixelformat);
638 vq = v4l2_m2m_get_vq(ctx->fh.m2m_ctx, f->type);
639 if (vb2_is_streaming(vq)) {
640 dev_dbg(delta->dev, "%s V4L2 S_FMT (OUTPUT): queue busy\n",
645 ctx->max_au_size = pix->sizeimage;
646 ctx->streaminfo.width = pix->width;
647 ctx->streaminfo.height = pix->height;
648 ctx->streaminfo.streamformat = pix->pixelformat;
649 ctx->streaminfo.colorspace = pix->colorspace;
650 ctx->streaminfo.xfer_func = pix->xfer_func;
651 ctx->streaminfo.ycbcr_enc = pix->ycbcr_enc;
652 ctx->streaminfo.quantization = pix->quantization;
653 ctx->flags |= DELTA_FLAG_STREAMINFO;
658 static int delta_s_fmt_frame(struct file *file, void *fh, struct v4l2_format *f)
660 struct delta_ctx *ctx = to_ctx(file->private_data);
661 struct delta_dev *delta = ctx->dev;
662 const struct delta_dec *dec = ctx->dec;
663 struct v4l2_pix_format *pix = &f->fmt.pix;
664 struct delta_frameinfo frameinfo;
665 unsigned char str[100] = "";
666 struct vb2_queue *vq;
669 vq = v4l2_m2m_get_vq(ctx->fh.m2m_ctx, f->type);
670 if (vb2_is_streaming(vq)) {
671 dev_dbg(delta->dev, "%s V4L2 S_FMT (CAPTURE): queue busy\n",
676 if (ctx->state < DELTA_STATE_READY) {
678 * decoder not yet opened and valid stream header not found,
679 * could not negotiate format with decoder, check at least
680 * pixel format & negotiate resolution boundaries
683 ret = delta_try_fmt_frame(file, fh, f);
686 "%s V4L2 S_FMT (CAPTURE): unsupported format %4.4s\n",
687 ctx->name, (char *)&pix->pixelformat);
694 /* set frame information to decoder */
695 memset(&frameinfo, 0, sizeof(frameinfo));
696 frameinfo.pixelformat = pix->pixelformat;
697 frameinfo.width = pix->width;
698 frameinfo.height = pix->height;
699 frameinfo.aligned_width = pix->width;
700 frameinfo.aligned_height = pix->height;
701 frameinfo.size = pix->sizeimage;
702 frameinfo.field = pix->field;
703 frameinfo.colorspace = pix->colorspace;
704 frameinfo.xfer_func = pix->xfer_func;
705 frameinfo.ycbcr_enc = pix->ycbcr_enc;
706 frameinfo.quantization = pix->quantization;
707 ret = call_dec_op(dec, set_frameinfo, ctx, &frameinfo);
711 /* then get what decoder can really do */
712 ret = call_dec_op(dec, get_frameinfo, ctx, &frameinfo);
716 ctx->flags |= DELTA_FLAG_FRAMEINFO;
717 ctx->frameinfo = frameinfo;
719 "%s V4L2 SET_FMT (CAPTURE): frameinfo updated to %s\n",
721 delta_frameinfo_str(&frameinfo, str, sizeof(str)));
723 pix->pixelformat = frameinfo.pixelformat;
724 pix->width = frameinfo.aligned_width;
725 pix->height = frameinfo.aligned_height;
726 pix->bytesperline = frame_stride(pix->width, pix->pixelformat);
727 pix->sizeimage = frameinfo.size;
728 pix->field = frameinfo.field;
729 pix->colorspace = frameinfo.colorspace;
730 pix->xfer_func = frameinfo.xfer_func;
731 pix->ycbcr_enc = frameinfo.ycbcr_enc;
732 pix->quantization = frameinfo.quantization;
737 static int delta_g_selection(struct file *file, void *fh,
738 struct v4l2_selection *s)
740 struct delta_ctx *ctx = to_ctx(fh);
741 struct delta_frameinfo *frameinfo = &ctx->frameinfo;
742 struct v4l2_rect crop;
744 if (s->type != V4L2_BUF_TYPE_VIDEO_CAPTURE)
747 if ((ctx->flags & DELTA_FLAG_FRAMEINFO) &&
748 (frameinfo->flags & DELTA_FRAMEINFO_FLAG_CROP)) {
749 crop = frameinfo->crop;
751 /* default to video dimensions */
754 crop.width = frameinfo->width;
755 crop.height = frameinfo->height;
759 case V4L2_SEL_TGT_COMPOSE:
760 case V4L2_SEL_TGT_COMPOSE_DEFAULT:
761 /* visible area inside video */
764 case V4L2_SEL_TGT_COMPOSE_PADDED:
765 case V4L2_SEL_TGT_COMPOSE_BOUNDS:
766 /* up to aligned dimensions */
769 s->r.width = frameinfo->aligned_width;
770 s->r.height = frameinfo->aligned_height;
779 static void delta_complete_eos(struct delta_ctx *ctx,
780 struct delta_frame *frame)
782 struct delta_dev *delta = ctx->dev;
783 const struct v4l2_event ev = {.type = V4L2_EVENT_EOS};
787 * - by returning an empty frame flagged to V4L2_BUF_FLAG_LAST
788 * - and then send EOS event
792 frame->info.size = 0;
794 /* set the last buffer flag */
795 frame->flags |= V4L2_BUF_FLAG_LAST;
797 /* release frame to user */
798 delta_frame_done(ctx, frame, 0);
801 v4l2_event_queue_fh(&ctx->fh, &ev);
803 dev_dbg(delta->dev, "%s EOS completed\n", ctx->name);
806 static int delta_try_decoder_cmd(struct file *file, void *fh,
807 struct v4l2_decoder_cmd *cmd)
809 if (cmd->cmd != V4L2_DEC_CMD_STOP)
812 if (cmd->flags & V4L2_DEC_CMD_STOP_TO_BLACK)
815 if (!(cmd->flags & V4L2_DEC_CMD_STOP_IMMEDIATELY) &&
816 (cmd->stop.pts != 0))
822 static int delta_decoder_stop_cmd(struct delta_ctx *ctx, void *fh)
824 const struct delta_dec *dec = ctx->dec;
825 struct delta_dev *delta = ctx->dev;
826 struct delta_frame *frame = NULL;
829 dev_dbg(delta->dev, "%s EOS received\n", ctx->name);
831 if (ctx->state != DELTA_STATE_READY)
834 /* drain the decoder */
835 call_dec_op(dec, drain, ctx);
837 /* release to user drained frames */
840 ret = call_dec_op(dec, get_frame, ctx, &frame);
841 if (ret == -ENODATA) {
842 /* no more decoded frames */
846 dev_dbg(delta->dev, "%s drain frame[%d]\n",
847 ctx->name, frame->index);
849 /* pop timestamp and mark frame with it */
850 delta_pop_dts(ctx, &frame->dts);
852 /* release decoded frame to user */
853 delta_frame_done(ctx, frame, 0);
857 /* try to complete EOS */
858 ret = delta_get_free_frame(ctx, &frame);
862 /* new frame available, EOS can now be completed */
863 delta_complete_eos(ctx, frame);
865 ctx->state = DELTA_STATE_EOS;
871 * EOS completion from driver is delayed because
872 * we don't have a free empty frame available.
873 * EOS completion is so delayed till next frame_queue() call
874 * to be sure to have a free empty frame available.
876 ctx->state = DELTA_STATE_WF_EOS;
877 dev_dbg(delta->dev, "%s EOS delayed\n", ctx->name);
882 static int delta_decoder_cmd(struct file *file, void *fh,
883 struct v4l2_decoder_cmd *cmd)
885 struct delta_ctx *ctx = to_ctx(fh);
888 ret = delta_try_decoder_cmd(file, fh, cmd);
892 return delta_decoder_stop_cmd(ctx, fh);
895 static int delta_subscribe_event(struct v4l2_fh *fh,
896 const struct v4l2_event_subscription *sub)
900 return v4l2_event_subscribe(fh, sub, 2, NULL);
909 static const struct v4l2_ioctl_ops delta_ioctl_ops = {
910 .vidioc_querycap = delta_querycap,
911 .vidioc_enum_fmt_vid_cap = delta_enum_fmt_frame,
912 .vidioc_g_fmt_vid_cap = delta_g_fmt_frame,
913 .vidioc_try_fmt_vid_cap = delta_try_fmt_frame,
914 .vidioc_s_fmt_vid_cap = delta_s_fmt_frame,
915 .vidioc_enum_fmt_vid_out = delta_enum_fmt_stream,
916 .vidioc_g_fmt_vid_out = delta_g_fmt_stream,
917 .vidioc_try_fmt_vid_out = delta_try_fmt_stream,
918 .vidioc_s_fmt_vid_out = delta_s_fmt_stream,
919 .vidioc_reqbufs = v4l2_m2m_ioctl_reqbufs,
920 .vidioc_create_bufs = v4l2_m2m_ioctl_create_bufs,
921 .vidioc_querybuf = v4l2_m2m_ioctl_querybuf,
922 .vidioc_expbuf = v4l2_m2m_ioctl_expbuf,
923 .vidioc_qbuf = v4l2_m2m_ioctl_qbuf,
924 .vidioc_dqbuf = v4l2_m2m_ioctl_dqbuf,
925 .vidioc_streamon = v4l2_m2m_ioctl_streamon,
926 .vidioc_streamoff = v4l2_m2m_ioctl_streamoff,
927 .vidioc_g_selection = delta_g_selection,
928 .vidioc_try_decoder_cmd = delta_try_decoder_cmd,
929 .vidioc_decoder_cmd = delta_decoder_cmd,
930 .vidioc_subscribe_event = delta_subscribe_event,
931 .vidioc_unsubscribe_event = v4l2_event_unsubscribe,
935 * mem-to-mem operations
938 static void delta_run_work(struct work_struct *work)
940 struct delta_ctx *ctx = container_of(work, struct delta_ctx, run_work);
941 struct delta_dev *delta = ctx->dev;
942 const struct delta_dec *dec = ctx->dec;
944 struct delta_frame *frame = NULL;
946 bool discard = false;
947 struct vb2_v4l2_buffer *vbuf;
950 dev_err(delta->dev, "%s no decoder opened yet\n", ctx->name);
954 /* protect instance against reentrancy */
955 mutex_lock(&ctx->lock);
957 vbuf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx);
959 dev_err(delta->dev, "%s no buffer to decode\n", ctx->name);
960 mutex_unlock(&ctx->lock);
964 au->size = vb2_get_plane_payload(&vbuf->vb2_buf, 0);
965 au->dts = vbuf->vb2_buf.timestamp;
967 /* dump access unit */
970 /* enable the hardware */
972 ret = delta_get_sync(ctx);
974 delta_put_autosuspend(ctx);
979 /* decode this access unit */
980 ret = call_dec_op(dec, decode, ctx, au);
983 * if the (-ENODATA) value is returned, it refers to the interlaced
984 * stream case for which 2 access units are needed to get 1 frame.
985 * So, this returned value doesn't mean that the decoding fails, but
986 * indicates that the timestamp information of the access unit shall
987 * not be taken into account, and that the V4L2 buffer associated with
988 * the access unit shall be flagged with V4L2_BUF_FLAG_ERROR to inform
989 * the user of this situation
991 if (ret == -ENODATA) {
994 dev_err(delta->dev, "%s decoding failed (%d)\n",
997 /* disable the hardware */
999 delta_put_autosuspend(ctx);
1004 /* disable the hardware */
1006 delta_put_autosuspend(ctx);
1008 /* push au timestamp in FIFO */
1010 delta_push_dts(ctx, au->dts);
1012 /* get available decoded frames */
1014 ret = call_dec_op(dec, get_frame, ctx, &frame);
1015 if (ret == -ENODATA) {
1016 /* no more decoded frames */
1020 dev_err(delta->dev, "%s cannot get decoded frame (%d)\n",
1026 "%s NULL decoded frame\n",
1032 /* pop timestamp and mark frame with it */
1033 delta_pop_dts(ctx, &frame->dts);
1035 /* release decoded frame to user */
1036 delta_frame_done(ctx, frame, 0);
1040 requeue_free_frames(ctx);
1041 delta_au_done(ctx, au, (discard ? -ENODATA : 0));
1042 mutex_unlock(&ctx->lock);
1043 v4l2_m2m_job_finish(delta->m2m_dev, ctx->fh.m2m_ctx);
1047 requeue_free_frames(ctx);
1048 delta_au_done(ctx, au, ret);
1049 mutex_unlock(&ctx->lock);
1050 v4l2_m2m_job_finish(delta->m2m_dev, ctx->fh.m2m_ctx);
1053 static void delta_device_run(void *priv)
1055 struct delta_ctx *ctx = priv;
1056 struct delta_dev *delta = ctx->dev;
1058 queue_work(delta->work_queue, &ctx->run_work);
1061 static void delta_job_abort(void *priv)
1063 struct delta_ctx *ctx = priv;
1064 struct delta_dev *delta = ctx->dev;
1066 dev_dbg(delta->dev, "%s aborting job\n", ctx->name);
1068 ctx->aborting = true;
1071 static int delta_job_ready(void *priv)
1073 struct delta_ctx *ctx = priv;
1074 struct delta_dev *delta = ctx->dev;
1075 int src_bufs = v4l2_m2m_num_src_bufs_ready(ctx->fh.m2m_ctx);
1078 dev_dbg(delta->dev, "%s not ready: not enough video buffers.\n",
1083 if (!v4l2_m2m_num_dst_bufs_ready(ctx->fh.m2m_ctx)) {
1084 dev_dbg(delta->dev, "%s not ready: not enough video capture buffers.\n",
1089 if (ctx->aborting) {
1090 dev_dbg(delta->dev, "%s job not ready: aborting\n", ctx->name);
1094 dev_dbg(delta->dev, "%s job ready\n", ctx->name);
1099 /* mem-to-mem ops */
1100 static const struct v4l2_m2m_ops delta_m2m_ops = {
1101 .device_run = delta_device_run,
1102 .job_ready = delta_job_ready,
1103 .job_abort = delta_job_abort,
1105 .unlock = delta_unlock,
1109 * VB2 queue operations
1112 static int delta_vb2_au_queue_setup(struct vb2_queue *vq,
1113 unsigned int *num_buffers,
1114 unsigned int *num_planes,
1115 unsigned int sizes[],
1116 struct device *alloc_devs[])
1118 struct delta_ctx *ctx = vb2_get_drv_priv(vq);
1119 unsigned int size = ctx->max_au_size;
1122 return sizes[0] < size ? -EINVAL : 0;
1125 if (*num_buffers < 1)
1127 if (*num_buffers > DELTA_MAX_AUS)
1128 *num_buffers = DELTA_MAX_AUS;
1135 static int delta_vb2_au_prepare(struct vb2_buffer *vb)
1137 struct vb2_queue *q = vb->vb2_queue;
1138 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1139 struct delta_dev *delta = ctx->dev;
1140 struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb);
1141 struct delta_au *au = to_au(vbuf);
1143 if (!au->prepared) {
1144 /* get memory addresses */
1145 au->vaddr = vb2_plane_vaddr(&au->vbuf.vb2_buf, 0);
1146 au->paddr = vb2_dma_contig_plane_dma_addr
1147 (&au->vbuf.vb2_buf, 0);
1148 au->prepared = true;
1149 dev_dbg(delta->dev, "%s au[%d] prepared; virt=0x%p, phy=0x%pad\n",
1150 ctx->name, vb->index, au->vaddr, &au->paddr);
1153 if (vbuf->field == V4L2_FIELD_ANY)
1154 vbuf->field = V4L2_FIELD_NONE;
1159 static int delta_setup_frame(struct delta_ctx *ctx,
1160 struct delta_frame *frame)
1162 struct delta_dev *delta = ctx->dev;
1163 const struct delta_dec *dec = ctx->dec;
1165 if (frame->index >= DELTA_MAX_FRAMES) {
1167 "%s frame index=%d exceeds output frame count (%d)\n",
1168 ctx->name, frame->index, DELTA_MAX_FRAMES);
1172 if (ctx->nb_of_frames >= DELTA_MAX_FRAMES) {
1174 "%s number of frames exceeds output frame count (%d > %d)\n",
1175 ctx->name, ctx->nb_of_frames, DELTA_MAX_FRAMES);
1179 if (frame->index != ctx->nb_of_frames) {
1180 dev_warn(delta->dev,
1181 "%s frame index discontinuity detected, expected %d, got %d\n",
1182 ctx->name, ctx->nb_of_frames, frame->index);
1185 frame->state = DELTA_FRAME_FREE;
1186 ctx->frames[ctx->nb_of_frames] = frame;
1187 ctx->nb_of_frames++;
1189 /* setup frame on decoder side */
1190 return call_dec_op(dec, setup_frame, ctx, frame);
1194 * default implementation of get_frameinfo decoder ops
1195 * matching frame information from stream information
1196 * & with default pixel format & default alignment.
1198 int delta_get_frameinfo_default(struct delta_ctx *ctx,
1199 struct delta_frameinfo *frameinfo)
1201 struct delta_streaminfo *streaminfo = &ctx->streaminfo;
1203 memset(frameinfo, 0, sizeof(*frameinfo));
1204 frameinfo->pixelformat = V4L2_PIX_FMT_NV12;
1205 frameinfo->width = streaminfo->width;
1206 frameinfo->height = streaminfo->height;
1207 frameinfo->aligned_width = ALIGN(streaminfo->width,
1208 DELTA_WIDTH_ALIGNMENT);
1209 frameinfo->aligned_height = ALIGN(streaminfo->height,
1210 DELTA_HEIGHT_ALIGNMENT);
1211 frameinfo->size = frame_size(frameinfo->aligned_width,
1212 frameinfo->aligned_height,
1213 frameinfo->pixelformat);
1214 if (streaminfo->flags & DELTA_STREAMINFO_FLAG_CROP) {
1215 frameinfo->flags |= DELTA_FRAMEINFO_FLAG_CROP;
1216 frameinfo->crop = streaminfo->crop;
1218 if (streaminfo->flags & DELTA_STREAMINFO_FLAG_PIXELASPECT) {
1219 frameinfo->flags |= DELTA_FRAMEINFO_FLAG_PIXELASPECT;
1220 frameinfo->pixelaspect = streaminfo->pixelaspect;
1222 frameinfo->field = streaminfo->field;
1228 * default implementation of recycle decoder ops
1229 * consisting to relax the "decoded" frame state
1231 int delta_recycle_default(struct delta_ctx *pctx,
1232 struct delta_frame *frame)
1234 frame->state &= ~DELTA_FRAME_DEC;
1239 static void dump_frames_status(struct delta_ctx *ctx)
1241 struct delta_dev *delta = ctx->dev;
1243 struct delta_frame *frame;
1244 unsigned char str[100] = "";
1246 dev_info(delta->dev,
1247 "%s dumping frames status...\n", ctx->name);
1249 for (i = 0; i < ctx->nb_of_frames; i++) {
1250 frame = ctx->frames[i];
1251 dev_info(delta->dev,
1252 "%s frame[%d] %s\n",
1253 ctx->name, frame->index,
1254 frame_state_str(frame->state,
1259 int delta_get_free_frame(struct delta_ctx *ctx,
1260 struct delta_frame **pframe)
1262 struct delta_dev *delta = ctx->dev;
1263 struct vb2_v4l2_buffer *vbuf;
1264 struct delta_frame *frame;
1268 vbuf = v4l2_m2m_dst_buf_remove(ctx->fh.m2m_ctx);
1270 dev_err(delta->dev, "%s no frame available",
1275 frame = to_frame(vbuf);
1276 frame->state &= ~DELTA_FRAME_M2M;
1277 if (frame->state != DELTA_FRAME_FREE) {
1279 "%s frame[%d] is not free\n",
1280 ctx->name, frame->index);
1281 dump_frames_status(ctx);
1286 "%s get free frame[%d]\n", ctx->name, frame->index);
1292 int delta_get_sync(struct delta_ctx *ctx)
1294 struct delta_dev *delta = ctx->dev;
1297 /* enable the hardware */
1298 ret = pm_runtime_get_sync(delta->dev);
1300 dev_err(delta->dev, "%s pm_runtime_get_sync failed (%d)\n",
1308 void delta_put_autosuspend(struct delta_ctx *ctx)
1310 struct delta_dev *delta = ctx->dev;
1312 pm_runtime_put_autosuspend(delta->dev);
1315 static void delta_vb2_au_queue(struct vb2_buffer *vb)
1317 struct vb2_queue *q = vb->vb2_queue;
1318 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1319 struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb);
1321 v4l2_m2m_buf_queue(ctx->fh.m2m_ctx, vbuf);
1324 static int delta_vb2_au_start_streaming(struct vb2_queue *q,
1327 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1328 struct delta_dev *delta = ctx->dev;
1329 const struct delta_dec *dec = ctx->dec;
1330 struct delta_au *au;
1332 struct vb2_v4l2_buffer *vbuf = NULL;
1333 struct delta_streaminfo *streaminfo = &ctx->streaminfo;
1334 struct delta_frameinfo *frameinfo = &ctx->frameinfo;
1335 unsigned char str1[100] = "";
1336 unsigned char str2[100] = "";
1338 if ((ctx->state != DELTA_STATE_WF_FORMAT) &&
1339 (ctx->state != DELTA_STATE_WF_STREAMINFO))
1342 if (ctx->state == DELTA_STATE_WF_FORMAT) {
1343 /* open decoder if not yet done */
1344 ret = delta_open_decoder(ctx,
1345 ctx->streaminfo.streamformat,
1346 ctx->frameinfo.pixelformat, &dec);
1350 ctx->state = DELTA_STATE_WF_STREAMINFO;
1354 * first buffer should contain stream header,
1355 * decode it to get the infos related to stream
1356 * such as width, height, dpb, ...
1358 vbuf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx);
1360 dev_err(delta->dev, "%s failed to start streaming, no stream header buffer enqueued\n",
1366 au->size = vb2_get_plane_payload(&vbuf->vb2_buf, 0);
1367 au->dts = vbuf->vb2_buf.timestamp;
1369 delta_push_dts(ctx, au->dts);
1371 /* dump access unit */
1374 /* decode this access unit */
1375 ret = call_dec_op(dec, decode, ctx, au);
1377 dev_err(delta->dev, "%s failed to start streaming, header decoding failed (%d)\n",
1382 ret = call_dec_op(dec, get_streaminfo, ctx, streaminfo);
1384 dev_dbg_ratelimited(delta->dev,
1385 "%s failed to start streaming, valid stream header not yet decoded\n",
1389 ctx->flags |= DELTA_FLAG_STREAMINFO;
1391 ret = call_dec_op(dec, get_frameinfo, ctx, frameinfo);
1394 ctx->flags |= DELTA_FLAG_FRAMEINFO;
1396 ctx->state = DELTA_STATE_READY;
1398 dev_dbg(delta->dev, "%s %s => %s\n", ctx->name,
1399 delta_streaminfo_str(streaminfo, str1, sizeof(str1)),
1400 delta_frameinfo_str(frameinfo, str2, sizeof(str2)));
1402 delta_au_done(ctx, au, ret);
1407 * return all buffers to vb2 in QUEUED state.
1408 * This will give ownership back to userspace
1411 v4l2_m2m_buf_done(vbuf, VB2_BUF_STATE_QUEUED);
1413 while ((vbuf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx)))
1414 v4l2_m2m_buf_done(vbuf, VB2_BUF_STATE_QUEUED);
1418 static void delta_vb2_au_stop_streaming(struct vb2_queue *q)
1420 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1421 struct vb2_v4l2_buffer *vbuf;
1423 delta_flush_dts(ctx);
1425 /* return all buffers to vb2 in ERROR state */
1426 while ((vbuf = v4l2_m2m_src_buf_remove(ctx->fh.m2m_ctx)))
1427 v4l2_m2m_buf_done(vbuf, VB2_BUF_STATE_ERROR);
1431 ctx->aborting = false;
1434 static int delta_vb2_frame_queue_setup(struct vb2_queue *vq,
1435 unsigned int *num_buffers,
1436 unsigned int *num_planes,
1437 unsigned int sizes[],
1438 struct device *alloc_devs[])
1440 struct delta_ctx *ctx = vb2_get_drv_priv(vq);
1441 struct delta_dev *delta = ctx->dev;
1442 struct delta_streaminfo *streaminfo = &ctx->streaminfo;
1443 struct delta_frameinfo *frameinfo = &ctx->frameinfo;
1444 unsigned int size = frameinfo->size;
1447 * the number of output buffers needed for decoding =
1448 * user need (*num_buffers given, usually for display pipeline) +
1449 * stream need (streaminfo->dpb) +
1450 * decoding peak smoothing (depends on DELTA IP perf)
1452 if (*num_buffers < DELTA_MIN_FRAME_USER) {
1454 "%s num_buffers too low (%d), increasing to %d\n",
1455 ctx->name, *num_buffers, DELTA_MIN_FRAME_USER);
1456 *num_buffers = DELTA_MIN_FRAME_USER;
1459 *num_buffers += streaminfo->dpb + DELTA_PEAK_FRAME_SMOOTHING;
1461 if (*num_buffers > DELTA_MAX_FRAMES) {
1463 "%s output frame count too high (%d), cut to %d\n",
1464 ctx->name, *num_buffers, DELTA_MAX_FRAMES);
1465 *num_buffers = DELTA_MAX_FRAMES;
1469 return sizes[0] < size ? -EINVAL : 0;
1471 /* single plane for Y and CbCr */
1476 ctx->nb_of_frames = 0;
1481 static int delta_vb2_frame_prepare(struct vb2_buffer *vb)
1483 struct vb2_queue *q = vb->vb2_queue;
1484 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1485 struct delta_dev *delta = ctx->dev;
1486 struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb);
1487 struct delta_frame *frame = to_frame(vbuf);
1490 if (!frame->prepared) {
1491 frame->index = vbuf->vb2_buf.index;
1492 frame->vaddr = vb2_plane_vaddr(&vbuf->vb2_buf, 0);
1493 frame->paddr = vb2_dma_contig_plane_dma_addr(&vbuf->vb2_buf, 0);
1494 frame->info = ctx->frameinfo;
1496 ret = delta_setup_frame(ctx, frame);
1499 "%s setup_frame() failed (%d)\n",
1503 frame->prepared = true;
1505 "%s frame[%d] prepared; virt=0x%p, phy=0x%pad\n",
1506 ctx->name, vb->index, frame->vaddr,
1510 frame->flags = vbuf->flags;
1515 static void delta_vb2_frame_finish(struct vb2_buffer *vb)
1517 struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb);
1518 struct delta_frame *frame = to_frame(vbuf);
1520 /* update V4L2 fields for user */
1521 vb2_set_plane_payload(&vbuf->vb2_buf, 0, frame->info.size);
1522 vb->timestamp = frame->dts;
1523 vbuf->field = frame->field;
1524 vbuf->flags = frame->flags;
1527 static void delta_vb2_frame_queue(struct vb2_buffer *vb)
1529 struct vb2_queue *q = vb->vb2_queue;
1530 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1531 struct vb2_v4l2_buffer *vbuf = to_vb2_v4l2_buffer(vb);
1532 struct delta_frame *frame = to_frame(vbuf);
1534 if (ctx->state == DELTA_STATE_WF_EOS) {
1535 /* new frame available, EOS can now be completed */
1536 delta_complete_eos(ctx, frame);
1538 ctx->state = DELTA_STATE_EOS;
1540 /* return, no need to recycle this buffer to decoder */
1544 /* recycle this frame */
1545 delta_recycle(ctx, frame);
1548 static void delta_vb2_frame_stop_streaming(struct vb2_queue *q)
1550 struct delta_ctx *ctx = vb2_get_drv_priv(q);
1551 struct vb2_v4l2_buffer *vbuf;
1552 struct delta_frame *frame;
1553 const struct delta_dec *dec = ctx->dec;
1556 delta_flush_dts(ctx);
1558 call_dec_op(dec, flush, ctx);
1561 * return all buffers to vb2 in ERROR state
1562 * & reset each frame state to OUT
1564 for (i = 0; i < ctx->nb_of_frames; i++) {
1565 frame = ctx->frames[i];
1566 if (!(frame->state & DELTA_FRAME_OUT)) {
1567 vbuf = &frame->vbuf;
1568 v4l2_m2m_buf_done(vbuf, VB2_BUF_STATE_ERROR);
1570 frame->state = DELTA_FRAME_OUT;
1575 ctx->aborting = false;
1579 static const struct vb2_ops delta_vb2_au_ops = {
1580 .queue_setup = delta_vb2_au_queue_setup,
1581 .buf_prepare = delta_vb2_au_prepare,
1582 .buf_queue = delta_vb2_au_queue,
1583 .wait_prepare = vb2_ops_wait_prepare,
1584 .wait_finish = vb2_ops_wait_finish,
1585 .start_streaming = delta_vb2_au_start_streaming,
1586 .stop_streaming = delta_vb2_au_stop_streaming,
1589 static const struct vb2_ops delta_vb2_frame_ops = {
1590 .queue_setup = delta_vb2_frame_queue_setup,
1591 .buf_prepare = delta_vb2_frame_prepare,
1592 .buf_finish = delta_vb2_frame_finish,
1593 .buf_queue = delta_vb2_frame_queue,
1594 .wait_prepare = vb2_ops_wait_prepare,
1595 .wait_finish = vb2_ops_wait_finish,
1596 .stop_streaming = delta_vb2_frame_stop_streaming,
1600 * V4L2 file operations
1603 static int queue_init(void *priv,
1604 struct vb2_queue *src_vq, struct vb2_queue *dst_vq)
1606 struct vb2_queue *q;
1607 struct delta_ctx *ctx = priv;
1608 struct delta_dev *delta = ctx->dev;
1611 /* setup vb2 queue for stream input */
1613 q->type = V4L2_BUF_TYPE_VIDEO_OUTPUT;
1614 q->io_modes = VB2_MMAP | VB2_DMABUF;
1616 /* overload vb2 buf with private au struct */
1617 q->buf_struct_size = sizeof(struct delta_au);
1618 q->ops = &delta_vb2_au_ops;
1619 q->mem_ops = &vb2_dma_contig_memops;
1620 q->timestamp_flags = V4L2_BUF_FLAG_TIMESTAMP_COPY;
1621 q->lock = &delta->lock;
1622 q->dev = delta->dev;
1624 ret = vb2_queue_init(q);
1628 /* setup vb2 queue for frame output */
1630 q->type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
1631 q->io_modes = VB2_MMAP | VB2_DMABUF;
1633 /* overload vb2 buf with private frame struct */
1634 q->buf_struct_size = sizeof(struct delta_frame)
1635 + DELTA_MAX_FRAME_PRIV_SIZE;
1636 q->ops = &delta_vb2_frame_ops;
1637 q->mem_ops = &vb2_dma_contig_memops;
1638 q->timestamp_flags = V4L2_BUF_FLAG_TIMESTAMP_COPY;
1639 q->lock = &delta->lock;
1640 q->dev = delta->dev;
1642 return vb2_queue_init(q);
1645 static int delta_open(struct file *file)
1647 struct delta_dev *delta = video_drvdata(file);
1648 struct delta_ctx *ctx = NULL;
1651 mutex_lock(&delta->lock);
1653 ctx = kzalloc(sizeof(*ctx), GFP_KERNEL);
1660 v4l2_fh_init(&ctx->fh, video_devdata(file));
1661 file->private_data = &ctx->fh;
1662 v4l2_fh_add(&ctx->fh);
1664 INIT_WORK(&ctx->run_work, delta_run_work);
1665 mutex_init(&ctx->lock);
1667 ctx->fh.m2m_ctx = v4l2_m2m_ctx_init(delta->m2m_dev, ctx,
1669 if (IS_ERR(ctx->fh.m2m_ctx)) {
1670 ret = PTR_ERR(ctx->fh.m2m_ctx);
1671 dev_err(delta->dev, "%s failed to initialize m2m context (%d)\n",
1677 * wait stream format to determine which
1680 ctx->state = DELTA_STATE_WF_FORMAT;
1682 INIT_LIST_HEAD(&ctx->dts);
1684 /* set the instance name */
1685 delta->instance_id++;
1686 snprintf(ctx->name, sizeof(ctx->name), "[%3d:----]",
1687 delta->instance_id);
1689 /* default parameters for frame and stream */
1690 set_default_params(ctx);
1692 /* enable ST231 clocks */
1693 if (delta->clk_st231)
1694 if (clk_prepare_enable(delta->clk_st231))
1695 dev_warn(delta->dev, "failed to enable st231 clk\n");
1697 /* enable FLASH_PROMIP clock */
1698 if (delta->clk_flash_promip)
1699 if (clk_prepare_enable(delta->clk_flash_promip))
1700 dev_warn(delta->dev, "failed to enable delta promip clk\n");
1702 mutex_unlock(&delta->lock);
1704 dev_dbg(delta->dev, "%s decoder instance created\n", ctx->name);
1709 v4l2_fh_del(&ctx->fh);
1710 v4l2_fh_exit(&ctx->fh);
1713 mutex_unlock(&delta->lock);
1718 static int delta_release(struct file *file)
1720 struct delta_ctx *ctx = to_ctx(file->private_data);
1721 struct delta_dev *delta = ctx->dev;
1722 const struct delta_dec *dec = ctx->dec;
1724 mutex_lock(&delta->lock);
1727 call_dec_op(dec, close, ctx);
1730 * trace a summary of instance
1731 * before closing (debug purpose)
1733 delta_trace_summary(ctx);
1735 v4l2_m2m_ctx_release(ctx->fh.m2m_ctx);
1737 v4l2_fh_del(&ctx->fh);
1738 v4l2_fh_exit(&ctx->fh);
1740 /* disable ST231 clocks */
1741 if (delta->clk_st231)
1742 clk_disable_unprepare(delta->clk_st231);
1744 /* disable FLASH_PROMIP clock */
1745 if (delta->clk_flash_promip)
1746 clk_disable_unprepare(delta->clk_flash_promip);
1748 dev_dbg(delta->dev, "%s decoder instance released\n", ctx->name);
1752 mutex_unlock(&delta->lock);
1757 static const struct v4l2_file_operations delta_fops = {
1758 .owner = THIS_MODULE,
1760 .release = delta_release,
1761 .unlocked_ioctl = video_ioctl2,
1762 .mmap = v4l2_m2m_fop_mmap,
1763 .poll = v4l2_m2m_fop_poll,
1767 * Platform device operations
1770 static int delta_register_device(struct delta_dev *delta)
1773 struct video_device *vdev;
1778 delta->m2m_dev = v4l2_m2m_init(&delta_m2m_ops);
1779 if (IS_ERR(delta->m2m_dev)) {
1780 dev_err(delta->dev, "%s failed to initialize v4l2-m2m device\n",
1782 ret = PTR_ERR(delta->m2m_dev);
1786 vdev = video_device_alloc();
1788 dev_err(delta->dev, "%s failed to allocate video device\n",
1791 goto err_m2m_release;
1794 vdev->fops = &delta_fops;
1795 vdev->ioctl_ops = &delta_ioctl_ops;
1796 vdev->release = video_device_release;
1797 vdev->lock = &delta->lock;
1798 vdev->vfl_dir = VFL_DIR_M2M;
1799 vdev->device_caps = V4L2_CAP_STREAMING | V4L2_CAP_VIDEO_M2M;
1800 vdev->v4l2_dev = &delta->v4l2_dev;
1801 snprintf(vdev->name, sizeof(vdev->name), "%s-%s",
1802 DELTA_NAME, DELTA_FW_VERSION);
1804 ret = video_register_device(vdev, VFL_TYPE_GRABBER, -1);
1806 dev_err(delta->dev, "%s failed to register video device\n",
1808 goto err_vdev_release;
1812 video_set_drvdata(vdev, delta);
1816 video_device_release(vdev);
1818 v4l2_m2m_release(delta->m2m_dev);
1823 static void delta_unregister_device(struct delta_dev *delta)
1829 v4l2_m2m_release(delta->m2m_dev);
1831 video_unregister_device(delta->vdev);
1834 static int delta_probe(struct platform_device *pdev)
1836 struct delta_dev *delta;
1837 struct device *dev = &pdev->dev;
1840 delta = devm_kzalloc(dev, sizeof(*delta), GFP_KERNEL);
1848 platform_set_drvdata(pdev, delta);
1850 mutex_init(&delta->lock);
1852 /* get clock resources */
1853 delta->clk_delta = devm_clk_get(dev, "delta");
1854 if (IS_ERR(delta->clk_delta)) {
1855 dev_dbg(dev, "%s can't get delta clock\n", DELTA_PREFIX);
1856 delta->clk_delta = NULL;
1859 delta->clk_st231 = devm_clk_get(dev, "delta-st231");
1860 if (IS_ERR(delta->clk_st231)) {
1861 dev_dbg(dev, "%s can't get delta-st231 clock\n", DELTA_PREFIX);
1862 delta->clk_st231 = NULL;
1865 delta->clk_flash_promip = devm_clk_get(dev, "delta-flash-promip");
1866 if (IS_ERR(delta->clk_flash_promip)) {
1867 dev_dbg(dev, "%s can't get delta-flash-promip clock\n",
1869 delta->clk_flash_promip = NULL;
1872 /* init pm_runtime used for power management */
1873 pm_runtime_set_autosuspend_delay(dev, DELTA_HW_AUTOSUSPEND_DELAY_MS);
1874 pm_runtime_use_autosuspend(dev);
1875 pm_runtime_set_suspended(dev);
1876 pm_runtime_enable(dev);
1878 /* init firmware ipc channel */
1879 ret = delta_ipc_init(delta);
1881 dev_err(delta->dev, "%s failed to initialize firmware ipc channel\n",
1883 goto err_pm_disable;
1886 /* register all available decoders */
1887 register_decoders(delta);
1889 /* register all supported formats */
1890 register_formats(delta);
1892 /* register on V4L2 */
1893 ret = v4l2_device_register(dev, &delta->v4l2_dev);
1895 dev_err(delta->dev, "%s failed to register V4L2 device\n",
1897 goto err_pm_disable;
1900 delta->work_queue = create_workqueue(DELTA_NAME);
1901 if (!delta->work_queue) {
1902 dev_err(delta->dev, "%s failed to allocate work queue\n",
1908 /* register device */
1909 ret = delta_register_device(delta);
1911 goto err_work_queue;
1913 dev_info(dev, "%s %s registered as /dev/video%d\n",
1914 DELTA_PREFIX, delta->vdev->name, delta->vdev->num);
1919 destroy_workqueue(delta->work_queue);
1921 v4l2_device_unregister(&delta->v4l2_dev);
1923 pm_runtime_disable(dev);
1928 static int delta_remove(struct platform_device *pdev)
1930 struct delta_dev *delta = platform_get_drvdata(pdev);
1932 delta_ipc_exit(delta);
1934 delta_unregister_device(delta);
1936 destroy_workqueue(delta->work_queue);
1938 pm_runtime_put_autosuspend(delta->dev);
1939 pm_runtime_disable(delta->dev);
1941 v4l2_device_unregister(&delta->v4l2_dev);
1946 static int delta_runtime_suspend(struct device *dev)
1948 struct delta_dev *delta = dev_get_drvdata(dev);
1950 if (delta->clk_delta)
1951 clk_disable_unprepare(delta->clk_delta);
1956 static int delta_runtime_resume(struct device *dev)
1958 struct delta_dev *delta = dev_get_drvdata(dev);
1960 if (delta->clk_delta)
1961 if (clk_prepare_enable(delta->clk_delta))
1962 dev_warn(dev, "failed to prepare/enable delta clk\n");
1968 static const struct dev_pm_ops delta_pm_ops = {
1969 .runtime_suspend = delta_runtime_suspend,
1970 .runtime_resume = delta_runtime_resume,
1973 static const struct of_device_id delta_match_types[] = {
1975 .compatible = "st,st-delta",
1982 MODULE_DEVICE_TABLE(of, delta_match_types);
1984 static struct platform_driver delta_driver = {
1985 .probe = delta_probe,
1986 .remove = delta_remove,
1989 .of_match_table = delta_match_types,
1990 .pm = &delta_pm_ops},
1993 module_platform_driver(delta_driver);
1995 MODULE_LICENSE("GPL");
1996 MODULE_AUTHOR("Hugues Fruchet <hugues.fruchet@st.com>");
1997 MODULE_DESCRIPTION("STMicroelectronics DELTA video decoder V4L2 driver");