1 /*
2 * Copyright (C) 2012, Roberto Tyley <roberto.tyley@gmail.com>
3 *
4 * This program and the accompanying materials are made available
5 * under the terms of the Eclipse Distribution License v1.0 which
6 * accompanies this distribution, is reproduced below, and is
7 * available at http://www.eclipse.org/org/documents/edl-v10.php
8 *
9 * All rights reserved.
10 *
11 * Redistribution and use in source and binary forms, with or
12 * without modification, are permitted provided that the following
13 * conditions are met:
14 *
15 * - Redistributions of source code must retain the above copyright
16 * notice, this list of conditions and the following disclaimer.
17 *
18 * - Redistributions in binary form must reproduce the above
19 * copyright notice, this list of conditions and the following
20 * disclaimer in the documentation and/or other materials provided
21 * with the distribution.
22 *
23 * - Neither the name of the Eclipse Foundation, Inc. nor the
24 * names of its contributors may be used to endorse or promote
25 * products derived from this software without specific prior
26 * written permission.
27 *
28 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
29 * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
30 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
31 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
32 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
33 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
34 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
35 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
36 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
37 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
38 * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
39 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
40 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
41 */
42
43 package org.eclipse.jgit.internal.storage.file;
44
45 import java.util.Collection;
46 import java.util.Collections;
47 import java.util.concurrent.Callable;
48 import java.util.concurrent.ExecutorService;
49 import java.util.concurrent.Executors;
50 import java.util.concurrent.Future;
51
52 import org.eclipse.jgit.internal.storage.file.ObjectDirectory;
53 import org.eclipse.jgit.junit.RepositoryTestCase;
54 import org.eclipse.jgit.lib.Constants;
55 import org.eclipse.jgit.lib.ObjectId;
56 import org.junit.Test;
57
58 public class ObjectDirectoryTest extends RepositoryTestCase {
59
60 @Test
61 public void testConcurrentInsertionOfBlobsToTheSameNewFanOutDirectory()
62 throws Exception {
63 ExecutorService e = Executors.newCachedThreadPool();
64 for (int i=0; i < 100; ++i) {
65 ObjectDirectory db = createBareRepository().getObjectDatabase();
66 for (Future f : e.invokeAll(blobInsertersForTheSameFanOutDir(db))) {
67 f.get();
68 }
69 }
70 }
71
72 private Collection<Callable<ObjectId>> blobInsertersForTheSameFanOutDir(
73 final ObjectDirectory db) {
74 Callable<ObjectId> callable = new Callable<ObjectId>() {
75 public ObjectId call() throws Exception {
76 return db.newInserter().insert(Constants.OBJ_BLOB, new byte[0]);
77 }
78 };
79 return Collections.nCopies(4, callable);
80 }
81
82 }