namespace {
#if !GLIB_CHECK_VERSION(2, 62, 0)
- static inline gchar *
- g_date_time_format_iso8601 (GDateTime * datetime)
- {
- GString *
- outstr = NULL;
- gchar *
- main_date = NULL;
- gint64 offset;
-
- // Main date and time.
- main_date = g_date_time_format (datetime, "%Y-%m-%dT%H:%M:%S");
- outstr = g_string_new (main_date);
- g_free (main_date);
-
- // Timezone. Format it as `%:::z` unless the offset is zero, in which case
- // we can simply use `Z`.
- offset = g_date_time_get_utc_offset (datetime);
-
- if (offset == 0) {
- g_string_append_c (outstr, 'Z');
- } else {
- gchar *
- time_zone = g_date_time_format (datetime, "%:::z");
- g_string_append (outstr, time_zone);
- g_free (time_zone);
- }
-
- return g_string_free (outstr, FALSE);
+static inline gchar* g_date_time_format_iso8601(GDateTime* datetime) {
+ GString* outstr = NULL;
+ gchar* main_date = NULL;
+ gint64 offset;
+
+ // Main date and time.
+ main_date = g_date_time_format(datetime, "%Y-%m-%dT%H:%M:%S");
+ outstr = g_string_new(main_date);
+ g_free(main_date);
+
+ // Timezone. Format it as `%:::z` unless the offset is zero, in which case
+ // we can simply use `Z`.
+ offset = g_date_time_get_utc_offset(datetime);
+
+ if (offset == 0) {
+ g_string_append_c(outstr, 'Z');
+ } else {
+ gchar* time_zone = g_date_time_format(datetime, "%:::z");
+ g_string_append(outstr, time_zone);
+ g_free(time_zone);
}
+
+ return g_string_free(outstr, FALSE);
+}
#endif
} // namespace
-std::unique_ptr <
- google::cloud::storage::Client >
-gst_gs_create_client (const gchar * service_account_email, GError ** error)
-{
+std::unique_ptr<google::cloud::storage::Client> gst_gs_create_client(
+ const gchar* service_account_email,
+ GError** error) {
if (service_account_email) {
// Meant to be used from a container running in the Cloud.
- google::cloud::StatusOr < std::shared_ptr <
- gcs::oauth2::Credentials >> creds (std::make_shared <
- gcs::oauth2::ComputeEngineCredentials <>> (service_account_email));
+ google::cloud::StatusOr<std::shared_ptr<gcs::oauth2::Credentials>> creds(
+ std::make_shared<gcs::oauth2::ComputeEngineCredentials<>>(
+ service_account_email));
if (!creds) {
- g_set_error (error, GST_RESOURCE_ERROR,
- GST_RESOURCE_ERROR_NOT_AUTHORIZED,
- "Could not retrieve credentials for the given service account %s (%s)",
- service_account_email, creds.status ().message ().c_str ());
+ g_set_error(error, GST_RESOURCE_ERROR, GST_RESOURCE_ERROR_NOT_AUTHORIZED,
+ "Could not retrieve credentials for the given service "
+ "account %s (%s)",
+ service_account_email, creds.status().message().c_str());
return nullptr;
}
- gcs::ClientOptions client_options (std::move (creds.value ()));
- return std::make_unique < gcs::Client > (client_options,
- gcs::StrictIdempotencyPolicy ());
+ gcs::ClientOptions client_options(std::move(creds.value()));
+ return std::make_unique<gcs::Client>(client_options,
+ gcs::StrictIdempotencyPolicy());
}
// Default account. This is meant to retrieve the credentials automatically
// using diffrent methods.
- google::cloud::StatusOr < gcs::ClientOptions > client_options =
- gcs::ClientOptions::CreateDefaultClientOptions ();
+ google::cloud::StatusOr<gcs::ClientOptions> client_options =
+ gcs::ClientOptions::CreateDefaultClientOptions();
if (!client_options) {
- g_set_error (error, GST_RESOURCE_ERROR,
- GST_RESOURCE_ERROR_NOT_AUTHORIZED,
- "Could not create default client options (%s)",
- client_options.status ().message ().c_str ());
+ g_set_error(error, GST_RESOURCE_ERROR, GST_RESOURCE_ERROR_NOT_AUTHORIZED,
+ "Could not create default client options (%s)",
+ client_options.status().message().c_str());
return nullptr;
}
- return std::make_unique < gcs::Client > (client_options.value (),
- gcs::StrictIdempotencyPolicy ());
+ return std::make_unique<gcs::Client>(client_options.value(),
+ gcs::StrictIdempotencyPolicy());
}
-gboolean
-gst_gs_get_buffer_date (GstBuffer * buffer, GDateTime * start_date,
- gchar ** buffer_date_str_ptr)
-{
- gchar *
- buffer_date_str = NULL;
+gboolean gst_gs_get_buffer_date(GstBuffer* buffer,
+ GDateTime* start_date,
+ gchar** buffer_date_str_ptr) {
+ gchar* buffer_date_str = NULL;
GstClockTime buffer_timestamp = GST_CLOCK_TIME_NONE;
GTimeSpan buffer_timespan = 0;
if (!buffer || !start_date)
return FALSE;
- buffer_timestamp = GST_BUFFER_PTS (buffer);
+ buffer_timestamp = GST_BUFFER_PTS(buffer);
// GTimeSpan is in micro seconds.
- buffer_timespan = GST_TIME_AS_USECONDS (buffer_timestamp);
+ buffer_timespan = GST_TIME_AS_USECONDS(buffer_timestamp);
- GDateTime *
- buffer_date = g_date_time_add (start_date, buffer_timespan);
+ GDateTime* buffer_date = g_date_time_add(start_date, buffer_timespan);
if (!buffer_date)
return FALSE;
- buffer_date_str = g_date_time_format_iso8601 (buffer_date);
- g_date_time_unref (buffer_date);
+ buffer_date_str = g_date_time_format_iso8601(buffer_date);
+ g_date_time_unref(buffer_date);
if (!buffer_date_str)
return FALSE;