1 files changed, 197 insertions, 197 deletions
diff --git a/plugins/org.eclipse.emf.cdo.common/src/org/eclipse/emf/cdo/spi/common/CDOLobStoreImpl.java b/plugins/org.eclipse.emf.cdo.common/src/org/eclipse/emf/cdo/spi/common/CDOLobStoreImpl.java
index 0fffa37750..3f525b10c4 100644
--- a/plugins/org.eclipse.emf.cdo.common/src/org/eclipse/emf/cdo/spi/common/CDOLobStoreImpl.java
+++ b/plugins/org.eclipse.emf.cdo.common/src/org/eclipse/emf/cdo/spi/common/CDOLobStoreImpl.java
@@ -1,197 +1,197 @@
-/*
- * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) 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:
- *    Eike Stepper - initial API and implementation
- */
-package org.eclipse.emf.cdo.spi.common;
-
-import org.eclipse.emf.cdo.common.lob.CDOLobInfo;
-import org.eclipse.emf.cdo.common.lob.CDOLobStore;
-
-import org.eclipse.net4j.util.HexUtil;
-import org.eclipse.net4j.util.WrappedException;
-import org.eclipse.net4j.util.io.DigestWriter;
-import org.eclipse.net4j.util.io.ExpectedFileInputStream;
-import org.eclipse.net4j.util.io.ExpectedFileReader;
-import org.eclipse.net4j.util.io.IORuntimeException;
-import org.eclipse.net4j.util.io.IOUtil;
-import org.eclipse.net4j.util.om.OMPlatform;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.Reader;
-import java.security.DigestOutputStream;
-import java.security.MessageDigest;
-import java.security.NoSuchAlgorithmException;
-
-/**
- * @author Eike Stepper
- * @since 4.0
- */
-public class CDOLobStoreImpl implements CDOLobStore
-{
-  public static final CDOLobStoreImpl INSTANCE = new CDOLobStoreImpl();
-
-  private File folder;
-
-  private int tempID;
-
-  public CDOLobStoreImpl(File folder)
-  {
-    this.folder = folder;
-    if (folder.exists())
-    {
-      checkDirectory();
-    }
-  }
-
-  public CDOLobStoreImpl()
-  {
-    this(getDefaultFolder());
-  }
-
-  public File getFolder()
-  {
-    if (!folder.exists())
-    {
-      folder.mkdirs();
-    }
-
-    checkDirectory();
-    return folder;
-  }
-
-  public File getBinaryFile(byte[] id)
-  {
-    return new File(getFolder(), HexUtil.bytesToHex(id) + ".blob");
-  }
-
-  public InputStream getBinary(CDOLobInfo info) throws IOException
-  {
-    File file = getBinaryFile(info.getID());
-    long expectedSize = info.getSize();
-    return new ExpectedFileInputStream(file, expectedSize);
-  }
-
-  public CDOLobInfo putBinary(InputStream contents) throws IOException
-  {
-    File tempFile = getTempFile();
-    MessageDigest digest = createDigest();
-    digest.update("BINARY".getBytes());
-
-    FileOutputStream fos = null;
-    long size;
-
-    try
-    {
-      fos = new FileOutputStream(tempFile);
-      DigestOutputStream dos = new DigestOutputStream(fos, digest);
-      size = IOUtil.copyBinary(contents, dos);
-    }
-    finally
-    {
-      IOUtil.close(fos);
-    }
-
-    byte[] id = digest.digest();
-    makePermanent(tempFile, getBinaryFile(id));
-    return new CDOLobInfo(id, size);
-  }
-
-  public File getCharacterFile(byte[] id)
-  {
-    return new File(getFolder(), HexUtil.bytesToHex(id) + ".clob");
-  }
-
-  public Reader getCharacter(CDOLobInfo info) throws IOException
-  {
-    File file = getCharacterFile(info.getID());
-    long expectedSize = info.getSize();
-    return new ExpectedFileReader(file, expectedSize);
-
-  }
-
-  public CDOLobInfo putCharacter(Reader contents) throws IOException
-  {
-    File tempFile = getTempFile();
-    MessageDigest digest = createDigest();
-    digest.update("CHARACTER".getBytes());
-
-    FileWriter fw = null;
-    long size;
-
-    try
-    {
-      fw = new FileWriter(tempFile);
-      DigestWriter dw = new DigestWriter(fw, digest);
-      size = IOUtil.copyCharacter(contents, dw);
-    }
-    finally
-    {
-      IOUtil.close(fw);
-    }
-
-    byte[] id = digest.digest();
-    makePermanent(tempFile, getCharacterFile(id));
-    return new CDOLobInfo(id, size);
-  }
-
-  protected MessageDigest createDigest()
-  {
-    try
-    {
-      return MessageDigest.getInstance("SHA-1");
-    }
-    catch (NoSuchAlgorithmException ex)
-    {
-      throw WrappedException.wrap(ex);
-    }
-  }
-
-  protected synchronized File getTempFile()
-  {
-    for (;;)
-    {
-      ++tempID;
-      File file = new File(getFolder(), "contents" + tempID + ".tmp");
-      if (!file.exists())
-      {
-        return file;
-      }
-    }
-  }
-
-  private void makePermanent(File tempFile, File file)
-  {
-    if (file.exists())
-    {
-      tempFile.delete();
-    }
-    else
-    {
-      tempFile.renameTo(file);
-    }
-  }
-
-  private void checkDirectory()
-  {
-    if (!folder.isDirectory())
-    {
-      throw new IORuntimeException("Not a folder: " + folder.getAbsolutePath());
-    }
-  }
-
-  private static File getDefaultFolder()
-  {
-    String path = OMPlatform.INSTANCE.getProperty("java.io.tmpdir");
-    return new File(new File(path), "cdo_lobs");
-  }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) 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:
+ *    Eike Stepper - initial API and implementation
+ */
+package org.eclipse.emf.cdo.spi.common;
+
+import org.eclipse.emf.cdo.common.lob.CDOLobInfo;
+import org.eclipse.emf.cdo.common.lob.CDOLobStore;
+
+import org.eclipse.net4j.util.HexUtil;
+import org.eclipse.net4j.util.WrappedException;
+import org.eclipse.net4j.util.io.DigestWriter;
+import org.eclipse.net4j.util.io.ExpectedFileInputStream;
+import org.eclipse.net4j.util.io.ExpectedFileReader;
+import org.eclipse.net4j.util.io.IORuntimeException;
+import org.eclipse.net4j.util.io.IOUtil;
+import org.eclipse.net4j.util.om.OMPlatform;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.Reader;
+import java.security.DigestOutputStream;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+/**
+ * @author Eike Stepper
+ * @since 4.0
+ */
+public class CDOLobStoreImpl implements CDOLobStore
+{
+  public static final CDOLobStoreImpl INSTANCE = new CDOLobStoreImpl();
+
+  private File folder;
+
+  private int tempID;
+
+  public CDOLobStoreImpl(File folder)
+  {
+    this.folder = folder;
+    if (folder.exists())
+    {
+      checkDirectory();
+    }
+  }
+
+  public CDOLobStoreImpl()
+  {
+    this(getDefaultFolder());
+  }
+
+  public File getFolder()
+  {
+    if (!folder.exists())
+    {
+      folder.mkdirs();
+    }
+
+    checkDirectory();
+    return folder;
+  }
+
+  public File getBinaryFile(byte[] id)
+  {
+    return new File(getFolder(), HexUtil.bytesToHex(id) + ".blob");
+  }
+
+  public InputStream getBinary(CDOLobInfo info) throws IOException
+  {
+    File file = getBinaryFile(info.getID());
+    long expectedSize = info.getSize();
+    return new ExpectedFileInputStream(file, expectedSize);
+  }
+
+  public CDOLobInfo putBinary(InputStream contents) throws IOException
+  {
+    File tempFile = getTempFile();
+    MessageDigest digest = createDigest();
+    digest.update("BINARY".getBytes());
+
+    FileOutputStream fos = null;
+    long size;
+
+    try
+    {
+      fos = new FileOutputStream(tempFile);
+      DigestOutputStream dos = new DigestOutputStream(fos, digest);
+      size = IOUtil.copyBinary(contents, dos);
+    }
+    finally
+    {
+      IOUtil.close(fos);
+    }
+
+    byte[] id = digest.digest();
+    makePermanent(tempFile, getBinaryFile(id));
+    return new CDOLobInfo(id, size);
+  }
+
+  public File getCharacterFile(byte[] id)
+  {
+    return new File(getFolder(), HexUtil.bytesToHex(id) + ".clob");
+  }
+
+  public Reader getCharacter(CDOLobInfo info) throws IOException
+  {
+    File file = getCharacterFile(info.getID());
+    long expectedSize = info.getSize();
+    return new ExpectedFileReader(file, expectedSize);
+
+  }
+
+  public CDOLobInfo putCharacter(Reader contents) throws IOException
+  {
+    File tempFile = getTempFile();
+    MessageDigest digest = createDigest();
+    digest.update("CHARACTER".getBytes());
+
+    FileWriter fw = null;
+    long size;
+
+    try
+    {
+      fw = new FileWriter(tempFile);
+      DigestWriter dw = new DigestWriter(fw, digest);
+      size = IOUtil.copyCharacter(contents, dw);
+    }
+    finally
+    {
+      IOUtil.close(fw);
+    }
+
+    byte[] id = digest.digest();
+    makePermanent(tempFile, getCharacterFile(id));
+    return new CDOLobInfo(id, size);
+  }
+
+  protected MessageDigest createDigest()
+  {
+    try
+    {
+      return MessageDigest.getInstance("SHA-1");
+    }
+    catch (NoSuchAlgorithmException ex)
+    {
+      throw WrappedException.wrap(ex);
+    }
+  }
+
+  protected synchronized File getTempFile()
+  {
+    for (;;)
+    {
+      ++tempID;
+      File file = new File(getFolder(), "contents" + tempID + ".tmp");
+      if (!file.exists())
+      {
+        return file;
+      }
+    }
+  }
+
+  private void makePermanent(File tempFile, File file)
+  {
+    if (file.exists())
+    {
+      tempFile.delete();
+    }
+    else
+    {
+      tempFile.renameTo(file);
+    }
+  }
+
+  private void checkDirectory()
+  {
+    if (!folder.isDirectory())
+    {
+      throw new IORuntimeException("Not a folder: " + folder.getAbsolutePath());
+    }
+  }
+
+  private static File getDefaultFolder()
+  {
+    String path = OMPlatform.INSTANCE.getProperty("java.io.tmpdir");
+    return new File(new File(path), "cdo_lobs");
+  }
+}