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
  19 /*
  20 static gboolean bus_call (GstBus *bus, GstMessage *msg, gpointer data)
  21 {
  22     gchar  *debug;
  23     GError *error;
  24     done_cb_t callback = (done_cb_t) data;
  25
  26     switch (GST_MESSAGE_TYPE (msg)) {
  27
  28         case GST_MESSAGE_EOS:
  29             g_main_loop_quit (loop);
  30             break;
  31
  32         case GST_MESSAGE_ERROR:
  33             gst_message_parse_error (msg, &error, &debug);
  34             g_free (debug);
  35
  36             g_printerr ("Error: %s\n", error->message);
  37             g_error_free (error);
  38
  39             g_main_loop_quit (loop);
  40             break;
  41
  42         default:
  43             break;
  44     }
  45     return TRUE;
  46 }
  47 */
  48
  49 void close_pipe(void *data)
  50 {
  51     int fd = (int) data;
  52     printf("close pipe! %d\n", fd);
  53     close(fd);
  54 }
  55
  56 void *send_pipe(void *data)
  57 {
  58     struct pipe_params *param = (struct pipe_params *) data;
  59     char buf[PIPE_BUF];
  60     size_t sizeread;
  61
  62     while ((sizeread = read(param->fd, buf, sizeof(buf))) > 0)
  63     {
  64         param->add_data_cb(buf, sizeread, param->user_data);
  65     }
  66     return NULL;
  67 }
  68
  69 /*
  70  *  Transcodes a file into a buffer, blocking until done.
  71  */
  72 int transcode(char *filename, void (*add_data_cb)(char *, size_t, void *),
  73     void *user_data)
  74 {
  75     GstElement *pipeline, *source, *dest;
  76     GError *error = NULL;
  77     GstBus *bus;
  78     char *pipeline_str = "filesrc name=\"_source\" ! oggdemux ! vorbisdec ! audioconvert ! wavenc ! fdsink name=\"_dest\" sync=false";
  79     int pipefds[2];
  80
  81     struct pipe_params thread_params;
  82     pthread_t thread;
  83     void *thread_status;
  84
  85     pipeline = gst_parse_launch(pipeline_str, &error);
  86     if (error)
  87     {
  88         fprintf(stderr, "Error parsing pipeline: %s\n", error->message);
  89         return -1;
  90     }
  91
  92     source = gst_bin_get_by_name(GST_BIN(pipeline), "_source");
  93     dest = gst_bin_get_by_name(GST_BIN(pipeline), "_dest");
  94
  95     if (!pipeline || !source || !dest)
  96     {
  97         fprintf(stderr, "Could not initialize pipeline\n");
  98         return -2;
  99     }
 100
 101     if (pipe(pipefds))
 102     {
 103         perror("gstfs");
 104         return -1;
 105     }
 106
 107     thread_params.fd = pipefds[0];
 108     thread_params.add_data_cb = add_data_cb;
 109     thread_params.user_data = user_data;
 110
 111     pthread_create(&thread, NULL, send_pipe, (void *) &thread_params);
 112
 113     g_object_set(G_OBJECT(source), "location", filename, NULL);
 114     g_object_set(G_OBJECT(dest), "fd", pipefds[1], NULL);
 115
 116     bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline));
 117     gst_bus_add_signal_watch(bus);
 118     gst_element_set_state(pipeline, GST_STATE_PLAYING);
 119     GstMessage *message = gst_bus_poll(bus, GST_MESSAGE_EOS |
 120             GST_MESSAGE_ERROR, -1);
 121     gst_message_unref(message);
 122
 123     // close read-side so pipe will terminate
 124     close(pipefds[1]);
 125     pthread_join(&thread, thread_status);
 126
 127     return 0;
 128 }