1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/* SPDX-License-Identifier: GPL-3.0-or-later */
/*
* ostream.h
*
* Copyright (C) 2019 David Oberhollenzer <goliath@infraroot.at>
*/
#ifndef IO_OSTREAM_H
#define IO_OSTREAM_H
#include "sqfs/predef.h"
#include "io/istream.h"
/**
* @struct ostream_t
*
* @extends sqfs_object_t
*
* @brief An append-only data stream.
*/
typedef struct ostream_t {
sqfs_object_t base;
int (*append)(struct ostream_t *strm, const void *data, size_t size);
int (*append_sparse)(struct ostream_t *strm, size_t size);
int (*flush)(struct ostream_t *strm);
const char *(*get_filename)(struct ostream_t *strm);
} ostream_t;
enum {
OSTREAM_OPEN_OVERWRITE = 0x01,
OSTREAM_OPEN_SPARSE = 0x02,
};
#ifdef __cplusplus
extern "C" {
#endif
/**
* @brief Append a block of data to an output stream.
*
* @memberof ostream_t
*
* @param strm A pointer to an output stream.
* @param data A pointer to the data block to append.
* @param size The number of bytes to append.
*
* @return Zero on success, -1 on failure.
*/
SQFS_INLINE int ostream_append(ostream_t *strm, const void *data,
size_t size)
{
return strm->append(strm, data, size);
}
/**
* @brief Append a number of zero bytes to an output stream.
*
* @memberof ostream_t
*
* If the unerlying implementation supports sparse files, this function can be
* used to create a "hole". If the implementation does not support it, a
* fallback is used that just appends a block of zeros manualy.
*
* @param strm A pointer to an output stream.
* @param size The number of zero bytes to append.
*
* @return Zero on success, -1 on failure.
*/
SQFS_INTERNAL int ostream_append_sparse(ostream_t *strm, size_t size);
/**
* @brief Process all pending, buffered data and flush it to disk.
*
* @memberof ostream_t
*
* If the stream performs some kind of transformation (e.g. transparent data
* compression), flushing caues the wrapped format to insert a termination
* token. Only call this function when you are absolutely DONE appending data,
* shortly before destroying the stream.
*
* @param strm A pointer to an output stream.
*
* @return Zero on success, -1 on failure.
*/
SQFS_INLINE int ostream_flush(ostream_t *strm)
{
return strm->flush(strm);
}
/**
* @brief Get the underlying filename of a output stream.
*
* @memberof ostream_t
*
* @param strm The output stream to get the filename from.
*
* @return A string holding the underlying filename.
*/
SQFS_INLINE const char *ostream_get_filename(ostream_t *strm)
{
return strm->get_filename(strm);
}
/**
* @brief Read data from an input stream and append it to an output stream
*
* @memberof ostream_t
*
* @param out A pointer to an output stream to append to.
* @param in A pointer to an input stream to read from.
* @param size The number of bytes to copy over.
*
* @return The number of bytes copied on success, -1 on failure,
* 0 on end-of-file.
*/
SQFS_INTERNAL sqfs_s32 ostream_append_from_istream(ostream_t *out,
istream_t *in,
sqfs_u32 size);
#ifdef __cplusplus
}
#endif
#endif /* IO_OSTREAM_H */
|
