java: add Java and C++ source files

new file mode 100644
index 0000000..540425d
@@ -0,0 +1,43 @@
+libcephfs Java wrappers
+=======================
+
+- native/: C++
+- java/: Java
+- test/: JUnit tests
+- lib/: JUnit library
+- build.xml: Test runner
+
+Building
+--------
+
+Autotools handles the build using the configure flag --enable-cephfs-java
+
+Testing
+-------
+
+Testing depends on JUnit. To run the tests make sure that the JUnit JAR is
+available in the lib/ directory. For example:
+
+  $ mkdir lib
+  $ cd lib
+  $ curl -O https://github.com/downloads/KentBeck/junit/junit-4.8.2.jar
+
+Ant is used to run the unit tests:
+
+  $ ant test
+
+1. The tests depend on the compiled wrappers. If the wrappers are installed as
+part of a package (e.g. Debian package) then this should 'just work'. Ant will
+also look in the current directory for 'libcephfs.jar' and in ../.libs for the
+JNI library.  If all else fails, set the environment variables CEPHFS_JAR, and
+CEPHFS_JNI_LIB accordingly.
+
+2. Set CEPHFS_CONF environment variable to point to a ceph.conf. This can be
+ommitted if the desired configuration file can be found in a default location.
+
+Documentation
+-------------
+
+Ant is used to build the Javadocs:
+
+  $ ant docs

67 lines not on this page · raw message

new file mode 100644
index 0000000..5e4c5a7
@@ -0,0 +1,38 @@
+package net.newdream.ceph.fs;
+
+public class CephConstants {
+
+	/*
+	 * The constants here are initialized from JNI.
+	 */
+	static {
+		CephNativeLoader.checkLoaded();
+	}
+
+	/* lseek */
+	public static int SEEK_SET;
+	public static int SEEK_CUR;
+	public static int SEEK_END;
+
+	/* open */
+	public static int O_RDONLY;
+	public static int O_RDWR;
+	public static int O_APPEND;
+	public static int O_CREAT;
+	public static int O_TRUNC;
+	public static int O_EXCL;
+
+	/* setattr */
+	public static int SETATTR_MODE;
+	public static int SETATTR_UID;
+	public static int SETATTR_GID;
+	public static int SETATTR_MTIME;
+	public static int SETATTR_ATIME;
+
+	/* errno */
+	public static int EINVAL;
+	public static int ENOENT;
+	public static int EEXIST;
+	public static int ERANGE;
+	public static int ENAMETOOLONG;
+}

84 lines not on this page · raw message

new file mode 100644
index 0000000..4af7bfe
@@ -0,0 +1,21 @@
+package net.newdream.ceph.fs;
+
+/**
+ * Class that represents generic Ceph exception.
+ */
+public class CephException extends Exception {
+
+    /**
+     * Create basic CephException.
+     */
+    public CephException() {
+        super();
+    }
+
+    /**
+     * Create CephException with message.
+     */
+    public CephException(String s) {
+        super(s);
+    }
+}

new file mode 100644
index 0000000..e995b09
@@ -0,0 +1,11 @@
+package net.newdream.ceph.fs;
+
+/**
+ * Represents invalid use of low-level Ceph pointers.
+ */
+public class CephInvalidStateException extends CephException {
+	
+	public CephInvalidStateException(String m) {
+		super(m);
+	}
+}

360 lines not on this page · raw message

new file mode 100644
index 0000000..5a681ca
@@ -0,0 +1,16 @@
+package net.newdream.ceph.fs;
+
+class CephNativeLoader {
+
+	private static boolean loaded = false;
+
+	static {
+		if (!loaded) {
+			System.loadLibrary("cephfs_jni");
+			CephProxy.native_initialize();
+			loaded = true;
+		}
+	}
+
+	static void checkLoaded() { assert(loaded); }
+}

217 lines not on this page · raw message

new file mode 100644
index 0000000..10faec1
@@ -0,0 +1,15 @@
+package net.newdream.ceph.fs;
+
+/**
+ * Holds struct stat fields.
+ */
+public class CephStat {
+	int mode;
+	int uid;
+	int gid;
+	long size;
+	long blksize;
+	long blocks;
+	long a_time;
+	long m_time;
+}

new file mode 100644
index 0000000..f4a7287
@@ -0,0 +1,14 @@
+package net.newdream.ceph.fs;
+
+/**
+ * Holds struct statvfs fields.
+ */
+public class CephStatVFS {
+	long bsize;
+	long frsize;
+	long blocks;
+	long bavail;
+	long files;
+	long fsid;
+	long namemax;
+}

new file mode 100644
index 0000000..efea86d
@@ -0,0 +1,33 @@
+package net.newdream.ceph.fs;
+
+/**
+ * Basic handling of low-level Ceph structs.
+ *
+ * - Enforces state
+ * - Holds JNI C pointer (to be implemented)
+ */
+abstract class CephStruct<T extends Enum<T>> {
+	private T state;
+
+	CephStruct(T initState) {
+		state = initState;
+	}
+
+	void setState(T state) {
+		this.state = state;
+	}
+
+	void requireState(T ... states) throws CephException {
+		for (int i = 0; i < states.length; i++) {
+			if (this.state == states[i])
+				return;
+		}
+		String msg = "valid state(s):";
+		for (int i = 0; i < states.length; i++) {
+			msg += " " + states[i].name();
+			if (i < (states.length-1))
+				msg += ",";
+		}
+		throw new CephInvalidStateException(msg);
+	}
+}

1,037 lines not on this page · raw message

76 lines not on this page · raw message

72 lines not on this page · raw message