diff options
Diffstat (limited to 'src/libotutil/ot-checksum-instream.c')
-rw-r--r-- | src/libotutil/ot-checksum-instream.c | 50 |
1 files changed, 18 insertions, 32 deletions
diff --git a/src/libotutil/ot-checksum-instream.c b/src/libotutil/ot-checksum-instream.c index b48b2360..31286a50 100644 --- a/src/libotutil/ot-checksum-instream.c +++ b/src/libotutil/ot-checksum-instream.c @@ -23,22 +23,20 @@ #include "ot-checksum-instream.h" #include "ot-checksum-utils.h" -struct _OtChecksumInstreamPrivate { +struct _OtChecksumInstreamPrivate +{ OtChecksum checksum; }; G_DEFINE_TYPE_WITH_PRIVATE (OtChecksumInstream, ot_checksum_instream, G_TYPE_FILTER_INPUT_STREAM) -static gssize ot_checksum_instream_read (GInputStream *stream, - void *buffer, - gsize count, - GCancellable *cancellable, - GError **error); +static gssize ot_checksum_instream_read (GInputStream *stream, void *buffer, gsize count, + GCancellable *cancellable, GError **error); static void ot_checksum_instream_finalize (GObject *object) { - OtChecksumInstream *self = (OtChecksumInstream*)object; + OtChecksumInstream *self = (OtChecksumInstream *)object; ot_checksum_clear (&self->priv->checksum); @@ -62,26 +60,21 @@ ot_checksum_instream_init (OtChecksumInstream *self) } OtChecksumInstream * -ot_checksum_instream_new (GInputStream *base, - GChecksumType checksum_type) +ot_checksum_instream_new (GInputStream *base, GChecksumType checksum_type) { return ot_checksum_instream_new_with_start (base, checksum_type, NULL, 0); } /* Initialize a checksum stream with starting state from data */ OtChecksumInstream * -ot_checksum_instream_new_with_start (GInputStream *base, - GChecksumType checksum_type, - const guint8 *buf, - size_t len) +ot_checksum_instream_new_with_start (GInputStream *base, GChecksumType checksum_type, + const guint8 *buf, size_t len) { OtChecksumInstream *stream; g_return_val_if_fail (G_IS_INPUT_STREAM (base), NULL); - stream = g_object_new (OT_TYPE_CHECKSUM_INSTREAM, - "base-stream", base, - NULL); + stream = g_object_new (OT_TYPE_CHECKSUM_INSTREAM, "base-stream", base, NULL); /* For now */ g_assert (checksum_type == G_CHECKSUM_SHA256); @@ -89,25 +82,18 @@ ot_checksum_instream_new_with_start (GInputStream *base, if (buf) ot_checksum_update (&stream->priv->checksum, buf, len); - return (OtChecksumInstream*) (stream); + return (OtChecksumInstream *)(stream); } static gssize -ot_checksum_instream_read (GInputStream *stream, - void *buffer, - gsize count, - GCancellable *cancellable, - GError **error) +ot_checksum_instream_read (GInputStream *stream, void *buffer, gsize count, + GCancellable *cancellable, GError **error) { - OtChecksumInstream *self = (OtChecksumInstream*) stream; - GFilterInputStream *fself = (GFilterInputStream*) self; + OtChecksumInstream *self = (OtChecksumInstream *)stream; + GFilterInputStream *fself = (GFilterInputStream *)self; gssize res = -1; - res = g_input_stream_read (fself->base_stream, - buffer, - count, - cancellable, - error); + res = g_input_stream_read (fself->base_stream, buffer, count, cancellable, error); if (res > 0) ot_checksum_update (&self->priv->checksum, buffer, res); @@ -117,7 +103,7 @@ ot_checksum_instream_read (GInputStream *stream, char * ot_checksum_instream_get_string (OtChecksumInstream *stream) { - char buf[_OSTREE_SHA256_STRING_LEN+1]; - ot_checksum_get_hexdigest (&stream->priv->checksum, buf, sizeof(buf)); - return g_strndup (buf, sizeof(buf)); + char buf[_OSTREE_SHA256_STRING_LEN + 1]; + ot_checksum_get_hexdigest (&stream->priv->checksum, buf, sizeof (buf)); + return g_strndup (buf, sizeof (buf)); } |