Skip to main content
summaryrefslogtreecommitdiffstats
blob: 96c6c961d1e1695c52281202a960240a546593f7 (plain) (blame)
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
/*******************************************************************************
 * Copyright (c) 2013 Tasktop Technologies and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *     Tasktop Technologies - initial API and implementation
 *******************************************************************************/

package org.eclipse.mylyn.internal.tasks.index.tests;

import static org.junit.Assert.assertTrue;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.util.Random;

import org.eclipse.mylyn.tasks.core.ITask;
import org.junit.Test;

public class TaskListIndexCorruptTest extends AbstractTaskListIndexTest {

	private void setupCorruptIndex() throws Exception {
		setupIndex();
		context.createLocalTask();
		index.waitUntilIdle();

		index.close();
		disposeIndex();

		corruptIndex();
	}

	private void corruptIndex() throws IOException {
		File[] files = tempDir.listFiles();
		if (files == null || files.length == 0) {
			throw new IllegalStateException("index has no files");
		}
		for (File file : files) {
			if (file.isFile()) {
				corruptFile(file);
			}
		}
	}

	private void corruptFile(File file) throws IOException {
		Random random = new Random(System.currentTimeMillis());
		long length = file.length();
		OutputStream stream = new FileOutputStream(file);
		try {
			byte[] bytes = new byte[1];
			for (long i = 0; i < length; ++i) {
				random.nextBytes(bytes);
				stream.write(bytes[0]);
			}
		} finally {
			stream.close();
		}
	}

	@Test
	public void testCorrupt() throws Exception {
		setupCorruptIndex();
		setupIndex();

		ITask task = context.createLocalTask();

		index.waitUntilIdle();

		assertTrue(index.matches(task, task.getSummary()));
	}
}

Back to the top