1/*-
2 * Copyright (c) 2010 Michihiro NAKAJIMA
3 * Copyright (c) 2007-2009 Tim Kientzle
4 * All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 * 1. Redistributions of source code must retain the above copyright
10 *    notice, this list of conditions and the following disclaimer
11 *    in this position and unchanged.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 *    notice, this list of conditions and the following disclaimer in the
14 *    documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR(S) ``AS IS'' AND ANY EXPRESS OR
17 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 * IN NO EVENT SHALL THE AUTHOR(S) BE LIABLE FOR ANY DIRECT, INDIRECT,
20 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27
28#include "test.h"
29
30/*
31 * A basic exercise of lzip reading and writing.
32 *
33 */
34
35DEFINE_TEST(test_write_filter_lzip)
36{
37	struct archive_entry *ae;
38	struct archive* a;
39	char *buff, *data;
40	size_t buffsize, datasize;
41	char path[16];
42	size_t used1, used2;
43	int i, r;
44
45	buffsize = 2000000;
46	assert(NULL != (buff = (char *)malloc(buffsize)));
47	if (buff == NULL)
48		return;
49
50	datasize = 10000;
51	assert(NULL != (data = (char *)malloc(datasize)));
52	if (data == NULL) {
53		free(buff);
54		return;
55	}
56	memset(data, 0, datasize);
57
58	/*
59	 * Write a 100 files and read them all back.
60	 */
61	assert((a = archive_write_new()) != NULL);
62	assertEqualIntA(a, ARCHIVE_OK, archive_write_set_format_ustar(a));
63	r = archive_write_add_filter_lzip(a);
64	if (r == ARCHIVE_FATAL) {
65		skipping("lzip writing not supported on this platform");
66		assertEqualInt(ARCHIVE_OK, archive_write_free(a));
67		free(buff);
68		free(data);
69		return;
70	}
71	assertEqualIntA(a, ARCHIVE_OK,
72	    archive_write_set_bytes_per_block(a, 10));
73	assertEqualInt(ARCHIVE_FILTER_LZIP, archive_filter_code(a, 0));
74	assertEqualString("lzip", archive_filter_name(a, 0));
75	assertEqualIntA(a, ARCHIVE_OK,
76	    archive_write_open_memory(a, buff, buffsize, &used1));
77	assertEqualInt(ARCHIVE_FILTER_LZIP, archive_filter_code(a, 0));
78	assertEqualString("lzip", archive_filter_name(a, 0));
79	assert((ae = archive_entry_new()) != NULL);
80	archive_entry_set_filetype(ae, AE_IFREG);
81	archive_entry_set_size(ae, datasize);
82	for (i = 0; i < 100; i++) {
83		snprintf(path, sizeof(path), "file%03d", i);
84		archive_entry_copy_pathname(ae, path);
85		assertEqualIntA(a, ARCHIVE_OK, archive_write_header(a, ae));
86		assertA(datasize
87		    == (size_t)archive_write_data(a, data, datasize));
88	}
89	archive_entry_free(ae);
90	assertEqualIntA(a, ARCHIVE_OK, archive_write_close(a));
91	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
92
93	assert((a = archive_read_new()) != NULL);
94	assertEqualIntA(a, ARCHIVE_OK, archive_read_support_format_all(a));
95	r = archive_read_support_filter_lzip(a);
96	if (r == ARCHIVE_WARN) {
97		skipping("Can't verify lzip writing by reading back;"
98		    " lzip reading not fully supported on this platform");
99	} else {
100		assertEqualIntA(a, ARCHIVE_OK,
101		    archive_read_support_filter_all(a));
102		assertEqualIntA(a, ARCHIVE_OK,
103		    archive_read_open_memory(a, buff, used1));
104		for (i = 0; i < 100; i++) {
105			snprintf(path, sizeof(path), "file%03d", i);
106			if (!assertEqualInt(ARCHIVE_OK,
107				archive_read_next_header(a, &ae)))
108				break;
109			assertEqualString(path, archive_entry_pathname(ae));
110			assertEqualInt((int)datasize, archive_entry_size(ae));
111		}
112		assertEqualIntA(a, ARCHIVE_OK, archive_read_close(a));
113	}
114	assertEqualInt(ARCHIVE_OK, archive_read_free(a));
115
116	/*
117	 * Repeat the cycle again, this time setting some compression
118	 * options.
119	 */
120	assert((a = archive_write_new()) != NULL);
121	assertEqualIntA(a, ARCHIVE_OK, archive_write_set_format_ustar(a));
122	assertEqualIntA(a, ARCHIVE_OK,
123	    archive_write_set_bytes_per_block(a, 10));
124	assertEqualIntA(a, ARCHIVE_OK, archive_write_add_filter_lzip(a));
125	assertEqualIntA(a, ARCHIVE_FAILED,
126	    archive_write_set_filter_option(a, NULL, "nonexistent-option", "0"));
127	assertEqualIntA(a, ARCHIVE_FAILED,
128	    archive_write_set_filter_option(a, NULL, "compression-level", "abc"));
129	assertEqualIntA(a, ARCHIVE_FAILED,
130	    archive_write_set_filter_option(a, NULL, "compression-level", "99"));
131	assertEqualIntA(a, ARCHIVE_OK,
132	    archive_write_set_filter_option(a, NULL, "compression-level", "9"));
133	assertEqualIntA(a, ARCHIVE_OK, archive_write_open_memory(a, buff, buffsize, &used2));
134	for (i = 0; i < 100; i++) {
135		snprintf(path, sizeof(path), "file%03d", i);
136		assert((ae = archive_entry_new()) != NULL);
137		archive_entry_copy_pathname(ae, path);
138		archive_entry_set_size(ae, datasize);
139		archive_entry_set_filetype(ae, AE_IFREG);
140		assertEqualIntA(a, ARCHIVE_OK, archive_write_header(a, ae));
141		assertA(datasize == (size_t)archive_write_data(a, data, datasize));
142		archive_entry_free(ae);
143	}
144	assertEqualIntA(a, ARCHIVE_OK, archive_write_close(a));
145	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
146
147
148	assert((a = archive_read_new()) != NULL);
149	assertEqualIntA(a, ARCHIVE_OK, archive_read_support_format_all(a));
150	r = archive_read_support_filter_lzip(a);
151	if (r == ARCHIVE_WARN) {
152		skipping("lzip reading not fully supported on this platform");
153	} else {
154		assertEqualIntA(a, ARCHIVE_OK,
155		    archive_read_support_filter_all(a));
156		assertEqualIntA(a, ARCHIVE_OK,
157		    archive_read_open_memory(a, buff, used2));
158		for (i = 0; i < 100; i++) {
159			snprintf(path, sizeof(path), "file%03d", i);
160			failure("Trying to read %s", path);
161			if (!assertEqualIntA(a, ARCHIVE_OK,
162				archive_read_next_header(a, &ae)))
163				break;
164			assertEqualString(path, archive_entry_pathname(ae));
165			assertEqualInt((int)datasize, archive_entry_size(ae));
166		}
167		assertEqualIntA(a, ARCHIVE_OK, archive_read_close(a));
168	}
169	assertEqualInt(ARCHIVE_OK, archive_read_free(a));
170
171	/*
172	 * Repeat again, with much lower compression.
173	 */
174	assert((a = archive_write_new()) != NULL);
175	assertEqualIntA(a, ARCHIVE_OK, archive_write_set_format_ustar(a));
176	assertEqualIntA(a, ARCHIVE_OK,
177	    archive_write_set_bytes_per_block(a, 10));
178	assertEqualIntA(a, ARCHIVE_OK, archive_write_add_filter_lzip(a));
179	assertEqualIntA(a, ARCHIVE_OK,
180	    archive_write_set_filter_option(a, NULL, "compression-level", "0"));
181	assertEqualIntA(a, ARCHIVE_OK, archive_write_open_memory(a, buff, buffsize, &used2));
182	for (i = 0; i < 100; i++) {
183		snprintf(path, sizeof(path), "file%03d", i);
184		assert((ae = archive_entry_new()) != NULL);
185		archive_entry_copy_pathname(ae, path);
186		archive_entry_set_size(ae, datasize);
187		archive_entry_set_filetype(ae, AE_IFREG);
188		assertEqualIntA(a, ARCHIVE_OK, archive_write_header(a, ae));
189		failure("Writing file %s", path);
190		assertEqualIntA(a, datasize,
191		    (size_t)archive_write_data(a, data, datasize));
192		archive_entry_free(ae);
193	}
194	assertEqualIntA(a, ARCHIVE_OK, archive_write_close(a));
195	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
196
197	/* Level 0 really does result in larger data. */
198	failure("Compression-level=0 wrote %d bytes; default wrote %d bytes",
199	    (int)used2, (int)used1);
200	assert(used2 > used1);
201
202	assert((a = archive_read_new()) != NULL);
203	assertEqualIntA(a, ARCHIVE_OK, archive_read_support_format_all(a));
204	assertEqualIntA(a, ARCHIVE_OK, archive_read_support_filter_all(a));
205	r = archive_read_support_filter_lzip(a);
206	if (r == ARCHIVE_WARN) {
207		skipping("lzip reading not fully supported on this platform");
208	} else {
209		assertEqualIntA(a, ARCHIVE_OK,
210		    archive_read_open_memory(a, buff, used2));
211		for (i = 0; i < 100; i++) {
212			snprintf(path, sizeof(path), "file%03d", i);
213			if (!assertEqualInt(ARCHIVE_OK,
214				archive_read_next_header(a, &ae)))
215				break;
216			assertEqualString(path, archive_entry_pathname(ae));
217			assertEqualInt((int)datasize, archive_entry_size(ae));
218		}
219		assertEqualIntA(a, ARCHIVE_OK, archive_read_close(a));
220	}
221	assertEqualInt(ARCHIVE_OK, archive_read_free(a));
222
223	/*
224	 * Test various premature shutdown scenarios to make sure we
225	 * don't crash or leak memory.
226	 */
227	assert((a = archive_write_new()) != NULL);
228	assertEqualIntA(a, ARCHIVE_OK, archive_write_add_filter_lzip(a));
229	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
230
231	assert((a = archive_write_new()) != NULL);
232	assertEqualIntA(a, ARCHIVE_OK, archive_write_add_filter_lzip(a));
233	assertEqualInt(ARCHIVE_OK, archive_write_close(a));
234	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
235
236	assert((a = archive_write_new()) != NULL);
237	assertEqualIntA(a, ARCHIVE_OK, archive_write_set_format_ustar(a));
238	assertEqualIntA(a, ARCHIVE_OK, archive_write_add_filter_lzip(a));
239	assertEqualInt(ARCHIVE_OK, archive_write_close(a));
240	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
241
242	assert((a = archive_write_new()) != NULL);
243	assertEqualIntA(a, ARCHIVE_OK, archive_write_set_format_ustar(a));
244	assertEqualIntA(a, ARCHIVE_OK, archive_write_add_filter_lzip(a));
245	assertEqualIntA(a, ARCHIVE_OK, archive_write_open_memory(a, buff, buffsize, &used2));
246	assertEqualInt(ARCHIVE_OK, archive_write_close(a));
247	assertEqualInt(ARCHIVE_OK, archive_write_free(a));
248
249	/*
250	 * Clean up.
251	 */
252	free(data);
253	free(buff);
254}
255