int main (int argc, char *argv[])
{
  GstBus *bus = NULL;
  guint bus_watch_id;
  guint i, num_sources;
  guint tiler_rows, tiler_columns;
  guint pgie_batch_size;

#ifdef PLATFORM_TEGRA
  GstElement *nvtransform;
#endif

  num_sources = 1;

  /* Standard GStreamer initialization */
  gst_init (&argc, &argv);
  loop = g_main_loop_new (NULL, FALSE);

  g_mutex_init (&eos_lock);
  /* Create gstreamer elements */
  /* Create Pipeline element that will form a connection of other elements */
  pipeline = gst_pipeline_new ("dstest-pipeline");

  streammux = gst_element_factory_make ("nvstreammux", "stream-muxer");
  streamdemux = gst_element_factory_make("nvstreamdemux", "demuxer");

  if (!pipeline || !streammux || !streamdemux) {
    g_printerr ("One element could not be created. Exiting.\n");
    return -1;
  }

  gst_bin_add_many(GST_BIN(pipeline), streammux, streamdemux,NULL);

  g_object_set (G_OBJECT (streammux), "live-source", 1, NULL);
  g_object_set (G_OBJECT (streammux), "batched-push-timeout", 2500000, NULL);
  g_object_set (G_OBJECT (streammux), "batch-size", 10, NULL);
  g_object_set (G_OBJECT (streammux), "width", MUXER_OUTPUT_WIDTH, "height",MUXER_OUTPUT_HEIGHT, NULL);
  SET_GPU_ID (streammux, GPU_ID);


  g_source_bin_list = g_malloc0 (sizeof (GstElement *) * MAX_NUM_SOURCES);

  /* Inital create the input source  */
  g_print("\nEnter the Source_ID: ");
  // source_id
  g_print("\nEnter the Source_Uri: ");
  // uri
 
  g_print("\nSource_ID = %d --- Source_URI = %s \n\n",source_id,uri);

  GstElement *source_bin = create_uridecode_bin (source_id,uri);
  if (!source_bin) {
    g_printerr ("Failed to create source bin. Exiting.\n");
    return -1;
  }
  g_source_bin_list[source_id] = source_bin;
  gst_bin_add (GST_BIN (pipeline), source_bin);
  
  g_num_sources = num_sources;

  /* Creating Element_Facctory_Make */
  for (i=0; i<MAX_NUM_SOURCES; i++){


    gchar temp_conv[16] = {};
    g_snprintf(temp_conv, 15, "converter%u", i);
    nvvidconv[i] = gst_element_factory_make("nvvideoconvert",temp_conv);
    
    if ( !nvvidconv[i] ) {
      g_printerr ("Nvvidconv element could not be created. Exiting.\n");
      return -1;
    }

    gchar temp_caps[16] = {};
    g_snprintf(temp_caps, 15, "filter%u", i);
    filter[i]=gst_element_factory_make("capsfilter",temp_caps);
    caps=gst_caps_from_string("video/x-raw(memory:NVMM), format=I420");
    g_object_set (G_OBJECT (filter[i]),"caps",caps,NULL);
    if ( !filter[i] ) {
      g_printerr ("Nvvidconv element could not be created. Exiting.\n");
      return -1;
    }
    gst_caps_unref (caps);


    gchar temp_encoder[16] = {};
    g_snprintf(temp_encoder, 15, "encoder%u", i);
    if (codec[3]='4'){
      encoder[i]=gst_element_factory_make("nvv4l2h264enc", temp_encoder);
    }
    else if (codec[3]='5'){
      encoder[i]=gst_element_factory_make("nvv4l2h265enc", temp_encoder);
    }
    if (!encoder[i]) {
      g_printerr ("Nvvidconv element could not be created. Exiting.\n");
      return -1;
    }

    gchar temp_rtppay[16] = {};
    g_snprintf(temp_rtppay, 15, "rtp-payer%u", i);
    if (codec[3]='4'){
      rtppay[i]=gst_element_factory_make("rtph264pay", temp_rtppay);
    }
    else if (codec[3]='5'){
      rtppay[i]=gst_element_factory_make("rtph265pay",temp_rtppay);
    }
    if ( !rtppay[i] ) {
      g_printerr ("Nvvidconv element could not be created. Exiting.\n");
      return -1;
    }

    gchar temp_sink[16] = {};
    g_snprintf(temp_sink, 15, "udp-sink%u", i);
    sink[i]=gst_element_factory_make("udpsink",temp_sink);
    g_object_set (G_OBJECT (sink[i]),"host","224.224.255.255",
                              "port", updsink_port_num[i],
                              "async", FALSE, "sync", 1, NULL);
    if ( !sink[i] ) {
      g_printerr ("Nvvidconv element could not be created. Exiting.\n");
      return -1;
    }
    gst_bin_add_many(GST_BIN(pipeline), nvvidconv[i], filter[i], encoder[i], rtppay[i], sink[i], NULL);
  }


#ifdef PLATFORM_TEGRA
  gst_bin_add (GST_BIN (pipeline), nvtransform);
#endif

  /* we link the elements together */
  gst_element_link_many(streammux,streamdemux,NULL);

  for (i=0; i < MAX_NUM_SOURCES; i++){
    GstPad *sinkpad1, *srcpad1;
    gchar pad_name[16] = {};
    g_snprintf(pad_name, 15, "src_%u", i); 
    srcpad1=gst_element_get_request_pad(streamdemux,pad_name);

    if (!srcpad1){
      g_printerr ("Unable to get the src padd of streamdemux\n");
    }

    sinkpad1 = gst_element_get_static_pad(nvvidconv[i],"sink");
    if (!sinkpad1){
      g_printerr("Failed to get sink pad of sink bin. Exiting.\n");
    }

    if (gst_pad_link(srcpad1, sinkpad1) != GST_PAD_LINK_OK){
      g_printerr("Failed to link source bin to stream-demuxer. Exiting.\n");
    }
    
    gst_element_link_many( nvvidconv[i], filter[i], encoder[i], 
                            rtppay[i], sink[i], NULL);

    gst_object_unref(srcpad1);
    gst_object_unref(sinkpad1);
  }

  /* we add a message handler */
  bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
  bus_watch_id = gst_bus_add_watch (bus, bus_call, loop);
  gst_object_unref (bus);

  gst_element_set_state (pipeline, GST_STATE_PAUSED);

  /* Set the pipeline to "playing" state */
  if (gst_element_set_state (pipeline,
          GST_STATE_PLAYING) == GST_STATE_CHANGE_FAILURE) {
    g_printerr ("Failed to set pipeline to playing. Exiting.\n");
    return -1;
  }


}