lib/deltas: Move variant read helper into the deltas code
authorColin Walters <walters@verbum.org>
Thu, 5 Oct 2017 15:14:17 +0000 (11:14 -0400)
committerAtomic Bot <atomic-devel@projectatomic.io>
Thu, 5 Oct 2017 15:41:00 +0000 (15:41 +0000)
What the deltas code is doing is weird/unfortunate.  The name
`ot_variant_read()` conflicts too much with `ot_variant_read_fd()`.
Since nothing else uses it, move it into the deltas code.

Closes: #1254
Approved by: jlebon

src/libostree/ostree-repo-static-delta-compilation.c
src/libotutil/ot-variant-utils.c
src/libotutil/ot-variant-utils.h

index 759a75a4f5c32c52826fb1a0272c76c0d6df44a4..a3b2847092ec9f4082c15f0caaf95466cbe6cf05 100644 (file)
@@ -1141,6 +1141,19 @@ get_fallback_headers (OstreeRepo               *self,
   return TRUE;
 }
 
+/* Get an input stream for a GVariant */
+static GInputStream *
+variant_to_inputstream (GVariant             *variant)
+{
+  GMemoryInputStream *ret = (GMemoryInputStream*)
+    g_memory_input_stream_new_from_data (g_variant_get_data (variant),
+                                         g_variant_get_size (variant),
+                                         NULL);
+  g_object_set_data_full ((GObject*)ret, "ot-variant-data",
+                          g_variant_ref (variant), (GDestroyNotify) g_variant_unref);
+  return (GInputStream*)ret;
+}
+
 /**
  * ostree_repo_static_delta_generate:
  * @self: Repo
@@ -1349,7 +1362,7 @@ ostree_repo_static_delta_generate (OstreeRepo                   *self,
       /* Hardcode xz for now */
       compressor = (GConverter*)_ostree_lzma_compressor_new (NULL);
       compression_type_char = 'x';
-      part_payload_in = ot_variant_read (delta_part_content);
+      part_payload_in = variant_to_inputstream (delta_part_content);
       part_payload_out = (GMemoryOutputStream*)g_memory_output_stream_new (NULL, 0, g_realloc, g_free);
       part_payload_compressor = (GConverterOutputStream*)g_converter_output_stream_new ((GOutputStream*)part_payload_out, compressor);
 
@@ -1386,7 +1399,7 @@ ostree_repo_static_delta_generate (OstreeRepo                   *self,
           g_ptr_array_add (part_temp_paths, g_steal_pointer (&part_tmpf));
         }
 
-      part_in = ot_variant_read (delta_part);
+      part_in = variant_to_inputstream (delta_part);
       if (!ot_gio_splice_get_checksum (part_temp_outstream, part_in,
                                        &part_checksum,
                                        cancellable, error))
index afb80be10713a0ad531dc7f70cc24b079d2e9fc8..11638794cfc4c00574f4f054cf17f5000c7ab76c 100644 (file)
@@ -81,19 +81,6 @@ ot_variant_read_fd (int                    fd,
   return TRUE;
 }
 
-/* Get an input stream for a GVariant */
-GInputStream *
-ot_variant_read (GVariant             *variant)
-{
-  GMemoryInputStream *ret = (GMemoryInputStream*)
-    g_memory_input_stream_new_from_data (g_variant_get_data (variant),
-                                         g_variant_get_size (variant),
-                                         NULL);
-  g_object_set_data_full ((GObject*)ret, "ot-variant-data",
-                          g_variant_ref (variant), (GDestroyNotify) g_variant_unref);
-  return (GInputStream*)ret;
-}
-
 /* GVariants are immutable; this function allows generating an open builder
  * for a new variant, inherting the data from @variant.
  */
index e69104704a8f67a077508fc513a1c45d87473449..a59cbffb17f9b2addf9c6e6e75239d17ce04b8ae 100644 (file)
@@ -39,8 +39,6 @@ gboolean ot_variant_read_fd (int                  fd,
                              GVariant           **out_variant,
                              GError             **error);
 
-GInputStream *ot_variant_read (GVariant             *variant);
-
 GVariantBuilder *ot_util_variant_builder_from_variant (GVariant            *variant,
                                                        const GVariantType  *type);