-package org.simantics.db.common;\r
-\r
-import java.io.ByteArrayInputStream;\r
-import java.io.ByteArrayOutputStream;\r
-import java.io.ObjectInputStream;\r
-import java.io.ObjectOutputStream;\r
-import java.util.Date;\r
-\r
-import org.simantics.db.Metadata;\r
-import org.simantics.db.Session;\r
-import org.simantics.db.common.utils.Logger;\r
-\r
-public class CommitMetadata implements Metadata {\r
- final boolean DEBUG = true;\r
- public final long opid;\r
- public final Date date;\r
- public CommitMetadata(long opid) {\r
- this.opid = opid;\r
- this.date = new Date();\r
- }\r
- public CommitMetadata(long opid, Date date) {\r
- this.opid = opid;\r
- this.date = date;\r
- }\r
- @Override\r
- public byte[] serialise(Session session) {\r
- try {\r
- ByteArrayOutputStream os = new ByteArrayOutputStream();\r
- ObjectOutputStream oos = new ObjectOutputStream(os);\r
- oos.writeLong(opid);\r
- oos.writeObject(date);\r
- oos.close();\r
- return os.toByteArray();\r
- } catch (Exception e) {\r
- Logger.defaultLogError(e.toString());\r
- if (DEBUG)\r
- e.printStackTrace();\r
- }\r
- return new byte[0];\r
- }\r
- public static CommitMetadata deserialise(Session session, byte[] input) {\r
- try {\r
- ByteArrayInputStream is = new ByteArrayInputStream(input);\r
- ObjectInputStream ois = new ObjectInputStream(is);\r
- long opid = ois.readLong();\r
- Object date = ois.readObject();\r
- ois.close();\r
- if (date instanceof Date)\r
- return new CommitMetadata(opid, (Date)date);\r
- } catch (Throwable e) {\r
- Logger.defaultLogError(e);\r
- }\r
- return null;\r
- }\r
-}\r
+package org.simantics.db.common;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.ObjectInputStream;
+import java.io.ObjectOutputStream;
+import java.util.Date;
+
+import org.simantics.db.Metadata;
+import org.simantics.db.Session;
+import org.simantics.db.common.utils.Logger;
+
+public class CommitMetadata implements Metadata {
+ final boolean DEBUG = true;
+ public final long opid;
+ public final Date date;
+ public CommitMetadata(long opid) {
+ this.opid = opid;
+ this.date = new Date();
+ }
+ public CommitMetadata(long opid, Date date) {
+ this.opid = opid;
+ this.date = date;
+ }
+ @Override
+ public byte[] serialise(Session session) {
+ try {
+ ByteArrayOutputStream os = new ByteArrayOutputStream();
+ ObjectOutputStream oos = new ObjectOutputStream(os);
+ oos.writeLong(opid);
+ oos.writeObject(date);
+ oos.close();
+ return os.toByteArray();
+ } catch (Exception e) {
+ Logger.defaultLogError(e.toString());
+ if (DEBUG)
+ e.printStackTrace();
+ }
+ return new byte[0];
+ }
+ public static CommitMetadata deserialise(Session session, byte[] input) {
+ try {
+ ByteArrayInputStream is = new ByteArrayInputStream(input);
+ ObjectInputStream ois = new ObjectInputStream(is);
+ long opid = ois.readLong();
+ Object date = ois.readObject();
+ ois.close();
+ if (date instanceof Date)
+ return new CommitMetadata(opid, (Date)date);
+ } catch (Throwable e) {
+ Logger.defaultLogError(e);
+ }
+ return null;
+ }
+}