xcode.c

   1 /*
   2  * gstfs - gstreamer glue routines for transcoding
   3  */
   4
   5 #include <gst/gst.h>
   6 #include <glib.h>
   7 #include <unistd.h>
   8 #include <sys/wait.h>
   9 #include <pthread.h>
  10
  11 struct pipe_params
  12 {
  13     int fd;
  14     void (*add_data_cb)(char *, size_t, void *);
  15     void *user_data;
  16 };
  17
  18 void *send_pipe(void *data)
  19 {
  20     struct pipe_params *param = (struct pipe_params *) data;
  21     char buf[PIPE_BUF];
  22     size_t sizeread;
  23
  24     while ((sizeread = read(param->fd, buf, sizeof(buf))) > 0)
  25     {
  26         param->add_data_cb(buf, sizeread, param->user_data);
  27     }
  28     return NULL;
  29 }
  30
  31 /*
  32  *  Transcodes a file into a buffer, blocking until done.
  33  */
  34 int transcode(char *pipeline_str, char *filename,
  35     void (*add_data_cb)(char *, size_t, void *), void *user_data)
  36 {
  37     GstElement *pipeline, *source, *dest;
  38     GError *error = NULL;
  39     GstBus *bus;
  40     int pipefds[2];
  41
  42     struct pipe_params thread_params;
  43     pthread_t thread;
  44     void *thread_status;
  45
  46     pipeline = gst_parse_launch(pipeline_str, &error);
  47     if (error)
  48     {
  49         fprintf(stderr, "Error parsing pipeline: %s\n", error->message);
  50         return -1;
  51     }
  52
  53     source = gst_bin_get_by_name(GST_BIN(pipeline), "_source");
  54     dest = gst_bin_get_by_name(GST_BIN(pipeline), "_dest");
  55
  56     if (!pipeline || !source || !dest)
  57     {
  58         fprintf(stderr, "Could not initialize pipeline\n");
  59         return -2;
  60     }
  61
  62     if (pipe(pipefds))
  63     {
  64         perror("gstfs");
  65         return -1;
  66     }
  67
  68     thread_params.fd = pipefds[0];
  69     thread_params.add_data_cb = add_data_cb;
  70     thread_params.user_data = user_data;
  71
  72     pthread_create(&thread, NULL, send_pipe, (void *) &thread_params);
  73
  74     g_object_set(G_OBJECT(source), "location", filename, NULL);
  75     g_object_set(G_OBJECT(dest), "fd", pipefds[1], NULL);
  76
  77     bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline));
  78     gst_bus_add_signal_watch(bus);
  79     gst_element_set_state(pipeline, GST_STATE_PLAYING);
  80     GstMessage *message = gst_bus_poll(bus, GST_MESSAGE_EOS |
  81             GST_MESSAGE_ERROR, -1);
  82     gst_message_unref(message);
  83
  84     // close read-side so pipe will terminate
  85     close(pipefds[1]);
  86     pthread_join(thread, thread_status);
  87
  88     return 0;
  89 }