/*******************************************************************************

 * Copyright (c) 2009 Broadcom Coporation 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:

 *    James Blackburn (Broadcom Corp.) - initial API and implementation

 *******************************************************************************/

package org.eclipse.core.tests.resources.regression;

import java.io.*;

import org.eclipse.core.resources.*;

import org.eclipse.core.runtime.*;

import org.eclipse.core.runtime.jobs.Job;

import org.eclipse.core.tests.resources.ResourceTest;

import org.eclipse.swt.widgets.Display;

/**

 * Testsuite for resources plugin lock-up

 */

public class Bug_294894 extends ResourceTest {

	protected void setUp() throws Exception {

		super.setUp();

	}

	protected void tearDown() throws Exception {

		super.tearDown();

	}

	public void testDeadLockFail() throws Exception {

		final String proj = "testProject";

		final IProject project = ResourcesPlugin.getWorkspace().getRoot().getProject(proj);

		create(project, true);

		final IFile file = project.getFile("foo");

		project.getFile("foo").create(new ByteArrayInputStream(new byte[] {'a'}), true, null);

		for (int i = 0; i < 1000; i++) {

			System.out.println(i);

			// Run this in a job holding the appropriate scheduling rule

			Job j = new Job("jobwithfilelock") {

				protected IStatus run(IProgressMonitor monitor) {

					// Job to deadlock with this: Display -> Resource Lock

					Job j = new Job("Workspace refresh") {

						protected IStatus run(IProgressMonitor monitor) {

							Display.getDefault().syncExec(new Runnable() {

								public void run() {

									try {

										appendContentsWithException(project);

										ResourcesPlugin.getWorkspace().getRoot().refreshLocal(IResource.DEPTH_INFINITE, null);

									} catch (Exception e) {

										fail();

									}

								}

							});

							return Status.OK_STATUS;

						}

					};

					j.schedule();

					try {

						Thread.sleep(1);

					} catch (Exception e) {

						fail();

					}

					// Grab Display and refresh the file... [Resource -> Display ]

					Display.getDefault().syncExec(new Runnable() {

						public void run() {

							try {

								file.refreshLocal(IResource.DEPTH_ONE, null);

							} catch (Exception e) {

								fail();

							}

						}

					});

					return Status.OK_STATUS;

				}

			};

			j.setRule(file);

			j.schedule();

			j.join();

			// Now try to append to the file

			file.appendContents(new ByteArrayInputStream(new byte[] {'a'}), IResource.FORCE, null);

		}

	}

	public InputStream getContents(String text) {

		return new ByteArrayInputStream(text.getBytes());

	}

	public void appendContentsWithException(IProject project) {

		int count = 5;

		final IFile targets[] = new IFile[count];

		for (int i = 0; i < count; i++)

			targets[i] = project.getFile("file" + i);

		try {

			for (int i = 0; i < count; i++)

				if (!targets[i].exists())

					targets[i].create(getContents("abc"), false, null);

		} catch (CoreException e) {

			fail("1.0");

		}

		// Run [count] failing append content jobs

		Job[] js = new Job[count];

		for (int i = 0; i < count; i++) {

			final int j = i;

			js[i] = new Job("bad append") {

				protected IStatus run(IProgressMonitor monitor) {

					try {

						targets[j].appendContents(new InputStream() {

							public int read() throws IOException {

								throw new IOException("Stream closed");

							}

						}, false, false, null);

					} catch (CoreException e) {

						fail("2.0");

					}

					return Status.OK_STATUS;

				}

			};

			js[i].schedule();

		}

	}

}