1 files changed, 51 insertions, 137 deletions

diff --git a/src/post/planar/denoise3d.c b/src/post/planar/denoise3d.c
index 36ba6490c..e4d8d65b2 100644
--- a/src/post/planar/denoise3d.c
+++ b/src/post/planar/denoise3d.c
@@ -17,7 +17,7 @@
  * along with this program; if not, write to the Free Software
  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA
  *
- * $Id: denoise3d.c,v 1.11 2003/12/07 15:33:26 miguelfreitas Exp $
+ * $Id: denoise3d.c,v 1.12 2004/01/07 19:52:42 mroi Exp $
  *
  * mplayer's denoise3d
  * Copyright (C) 2003 Daniel Moreno <comac@comac.darktech.org>
@@ -70,16 +70,14 @@ struct post_plugin_denoise3d_s {
   post_plugin_t post;
 
   /* private data */
-  xine_video_port_t *vo_port;
-  xine_stream_t     *stream;
-
   denoise3d_parameters_t params;
+  xine_post_in_t         params_input;
 
-  int Coefs[4][512];
-  unsigned char Line[MAX_LINE_WIDTH];
-  vo_frame_t *prev_frame;
+  int                    Coefs[4][512];
+  unsigned char          Line[MAX_LINE_WIDTH];
+  vo_frame_t            *prev_frame;
 
-  pthread_mutex_t    lock;
+  pthread_mutex_t        lock;
 };
 
 #define ABS(A) ( (A) > 0 ? (A) : -(A) )
@@ -156,12 +154,6 @@ static xine_post_api_t post_api = {
   get_help,
 };
 
-typedef struct post_denoise3d_out_s post_denoise3d_out_t;
-struct post_denoise3d_out_s {
-  xine_post_out_t  xine_out;
-
-  post_plugin_denoise3d_t *plugin;
-};
 
 /* plugin class functions */
 static post_plugin_t *denoise3d_open_plugin(post_class_t *class_gen, int inputs,
@@ -174,16 +166,12 @@ static void           denoise3d_class_dispose(post_class_t *class_gen);
 /* plugin instance functions */
 static void           denoise3d_dispose(post_plugin_t *this_gen);
 
-/* rewire function */
-static int            denoise3d_rewire(xine_post_out_t *output, void *data);
-
-/* replaced video_port functions */
-static void           denoise3d_open(xine_video_port_t *port_gen, xine_stream_t *stream);
-static vo_frame_t    *denoise3d_get_frame(xine_video_port_t *port_gen, uint32_t width, 
-				       uint32_t height, double ratio, 
-				       int format, int flags);
+/* replaced video_port functios */
 static void           denoise3d_close(xine_video_port_t *port_gen, xine_stream_t *stream);
 
+/* frame intercept check */
+static int            denoise3d_intercept_frame(post_video_port_t *port, vo_frame_t *frame);
+
 /* replaced vo_frame functions */
 static int            denoise3d_draw(vo_frame_t *frame, xine_stream_t *stream);
 
@@ -208,61 +196,41 @@ static post_plugin_t *denoise3d_open_plugin(post_class_t *class_gen, int inputs,
 					 xine_audio_port_t **audio_target,
 					 xine_video_port_t **video_target)
 {
-  post_plugin_denoise3d_t *this = (post_plugin_denoise3d_t *)malloc(sizeof(post_plugin_denoise3d_t));
-  xine_post_in_t            *input = (xine_post_in_t *)malloc(sizeof(xine_post_in_t));
-  xine_post_in_t            *input_api = (xine_post_in_t *)malloc(sizeof(xine_post_in_t));
-  post_denoise3d_out_t    *output = (post_denoise3d_out_t *)malloc(sizeof(post_denoise3d_out_t));
-  post_video_port_t *port;
+  post_plugin_denoise3d_t *this = (post_plugin_denoise3d_t *)xine_xmalloc(sizeof(post_plugin_denoise3d_t));
+  post_in_t               *input;
+  xine_post_in_t          *input_api;
+  post_out_t              *output;
+  post_video_port_t       *port;
   
-  if (!this || !input || !input_api || !output || !video_target || !video_target[0]) {
+  if (!this || !video_target || !video_target[0]) {
     free(this);
-    free(input);
-    free(input_api);
-    free(output);
     return NULL;
   }
 
-  this->stream = NULL;
-
+  _x_post_init(&this->post, 0, 1);
+  
   this->params.luma = PARAM1_DEFAULT;
   this->params.chroma = PARAM2_DEFAULT;
   this->params.time = PARAM3_DEFAULT;
   this->prev_frame = NULL;
 
-  pthread_mutex_init (&this->lock, NULL);
+  pthread_mutex_init(&this->lock, NULL);
 
-  port = _x_post_intercept_video_port(&this->post, video_target[0]);
-  /* replace with our own get_frame function */
-  port->port.open         = denoise3d_open;
-  port->port.get_frame    = denoise3d_get_frame;
-  port->port.close        = denoise3d_close;
+  port = _x_post_intercept_video_port(&this->post, video_target[0], &input, &output);
+  port->new_port.close  = denoise3d_close;
+  port->intercept_frame = denoise3d_intercept_frame;
+  port->new_frame->draw = denoise3d_draw;
   
-  input->name = "video";
-  input->type = XINE_POST_DATA_VIDEO;
-  input->data = (xine_video_port_t *)&port->port;
-
+  input_api       = &this->params_input;
   input_api->name = "parameters";
   input_api->type = XINE_POST_DATA_PARAMETERS;
   input_api->data = &post_api;
+  xine_list_append_content(this->post.input, input_api);
 
+  input->xine_in.name     = "video";
   output->xine_out.name   = "denoise3d video";
-  output->xine_out.type   = XINE_POST_DATA_VIDEO;
-  output->xine_out.data   = (xine_video_port_t **)&port->original_port;
-  output->xine_out.rewire = denoise3d_rewire;
-  output->plugin          = this;
-  
-  this->post.xine_post.audio_input    = (xine_audio_port_t **)malloc(sizeof(xine_audio_port_t *));
-  this->post.xine_post.audio_input[0] = NULL;
-  this->post.xine_post.video_input    = (xine_video_port_t **)malloc(sizeof(xine_video_port_t *) * 2);
-  this->post.xine_post.video_input[0] = &port->port;
-  this->post.xine_post.video_input[1] = NULL;
   
-  this->post.input  = xine_list_new();
-  this->post.output = xine_list_new();
-  
-  xine_list_append_content(this->post.input, input);
-  xine_list_append_content(this->post.input, input_api);
-  xine_list_append_content(this->post.output, output);
+  this->post.xine_post.video_input[0] = &port->new_port;
   
   this->post.dispose = denoise3d_dispose;
 
@@ -290,72 +258,13 @@ static void denoise3d_class_dispose(post_class_t *class_gen)
 static void denoise3d_dispose(post_plugin_t *this_gen)
 {
   post_plugin_denoise3d_t *this = (post_plugin_denoise3d_t *)this_gen;
-  post_denoise3d_out_t *output = (post_denoise3d_out_t *)xine_list_first_content(this->post.output);
-  xine_video_port_t *port = *(xine_video_port_t **)output->xine_out.data;
-
-  if (this->stream)
-    port->close(port, this->stream);
-
-  free(this->post.xine_post.audio_input);
-  free(this->post.xine_post.video_input);
-  free(xine_list_first_content(this->post.input));
-  free(xine_list_next_content(this->post.input));
-  free(xine_list_first_content(this->post.output));
-  xine_list_free(this->post.input);
-  xine_list_free(this->post.output);
-  free(this);
-}
-
-
-static int denoise3d_rewire(xine_post_out_t *output_gen, void *data)
-{
-  post_denoise3d_out_t *output = (post_denoise3d_out_t *)output_gen;
-  xine_video_port_t *old_port = *(xine_video_port_t **)output_gen->data;
-  xine_video_port_t *new_port = (xine_video_port_t *)data;
   
-  if (!data)
-    return 0;
-
-  if (output->plugin->stream) {
-    /* register our stream at the new output port */
-    old_port->close(old_port, output->plugin->stream);
-    new_port->open(new_port, output->plugin->stream);
+  if (_x_post_dispose(this_gen)) {
+    pthread_mutex_destroy(&this->lock);
+    free(this);
   }
-  /* reconnect ourselves */
-  *(xine_video_port_t **)output_gen->data = new_port;
-
-  return 1;
 }
 
-static void denoise3d_open(xine_video_port_t *port_gen, xine_stream_t *stream)
-{
-  post_video_port_t *port = (post_video_port_t *)port_gen;
-  post_plugin_denoise3d_t *this = (post_plugin_denoise3d_t *)port->post;
-  this->stream = stream;
-  port->original_port->open(port->original_port, stream);
-}
-
-static vo_frame_t *denoise3d_get_frame(xine_video_port_t *port_gen, uint32_t width, 
-				    uint32_t height, double ratio, 
-				    int format, int flags)
-{
-  post_video_port_t *port = (post_video_port_t *)port_gen;
-  vo_frame_t        *frame;
-
-  frame = port->original_port->get_frame(port->original_port,
-    width, height, ratio, format, flags);
-
-  _x_post_intercept_video_frame(frame, port);
-  if( format == XINE_IMGFMT_YV12 || format == XINE_IMGFMT_YUY2 ) {
-    /* replace with our own draw function */
-    frame->draw = denoise3d_draw;
-    /* decoders should not copy the frames, since they won't be displayed */
-    frame->proc_slice = NULL;
-    frame->proc_frame = NULL;
-  }
-
-  return frame;
-}
 
 static void denoise3d_close(xine_video_port_t *port_gen, xine_stream_t *stream)
 {
@@ -367,11 +276,18 @@ static void denoise3d_close(xine_video_port_t *port_gen, xine_stream_t *stream)
     this->prev_frame = NULL;
   }
 
-  this->stream = NULL;
-  
   port->original_port->close(port->original_port, stream);
+  port->stream = NULL;
+  _x_post_dec_usage(port);
+}
+
+
+static int denoise3d_intercept_frame(post_video_port_t *port, vo_frame_t *frame)
+{
+  return (frame->format == XINE_IMGFMT_YV12 || frame->format == XINE_IMGFMT_YUY2);
 }
 
+
 #define LowPass(Prev, Curr, Coef) (((Prev)*Coef[Prev - Curr] + (Curr)*(65536-(Coef[Prev - Curr]))) / 65536)
 
 static void deNoise(unsigned char *Frame,        
@@ -427,8 +343,6 @@ static int denoise3d_draw(vo_frame_t *frame, xine_stream_t *stream)
   int cw, ch;
   int skip;
 
-  _x_post_restore_video_frame(frame, port);
-
   if( !frame->bad_frame ) {
 
 
@@ -438,9 +352,7 @@ static int denoise3d_draw(vo_frame_t *frame, xine_stream_t *stream)
       yv12_frame = port->original_port->get_frame(port->original_port,
         frame->width, frame->height, frame->ratio, XINE_IMGFMT_YV12, frame->flags | VO_BOTH_FIELDS);
   
-      yv12_frame->pts = frame->pts;
-      yv12_frame->duration = frame->duration;
-      _x_extra_info_merge(yv12_frame->extra_info, frame->extra_info);
+      _x_post_frame_copy_up(frame, yv12_frame);
   
       yuy2_to_yv12(frame->base[0], frame->pitches[0],
                    yv12_frame->base[0], yv12_frame->pitches[0],
@@ -457,11 +369,7 @@ static int denoise3d_draw(vo_frame_t *frame, xine_stream_t *stream)
     out_frame = port->original_port->get_frame(port->original_port,
       frame->width, frame->height, frame->ratio, XINE_IMGFMT_YV12, frame->flags | VO_BOTH_FIELDS);
 
-  
-    _x_extra_info_merge(out_frame->extra_info, frame->extra_info);
-  
-    out_frame->pts = frame->pts;
-    out_frame->duration = frame->duration;
+    _x_post_frame_copy_up(frame, out_frame);
 
     pthread_mutex_lock (&this->lock);
 
@@ -492,18 +400,24 @@ static int denoise3d_draw(vo_frame_t *frame, xine_stream_t *stream)
 
     skip = out_frame->draw(out_frame, stream);
   
-    frame->vpts = out_frame->vpts;
+    _x_post_frame_copy_down(frame, out_frame);
 
     out_frame->free(out_frame);
 
     if(this->prev_frame)
       this->prev_frame->free(this->prev_frame);
-    this->prev_frame = yv12_frame;
+    if(port->stream)
+      this->prev_frame = yv12_frame;
+    else
+      /* do not keep this frame when no stream is connected to us,
+       * otherwise, this frame might never get freed */
+      yv12_frame->free(yv12_frame);
 
   } else {
-    skip = frame->draw(frame, stream);
+    _x_post_frame_copy_up(frame, frame->next);
+    skip = frame->next->draw(frame->next, stream);
+    _x_post_frame_copy_down(frame, frame->next);
   }
 
-  
   return skip;
 }