Library.java : fix mdb_reader_check api, Env.java : readerCheck impl (#212)

tran4o · web-flow · commit 9cf97a5cd28c · 2023-03-09T12:31:27.000+11:00
* Library.java : fix mdb_reader_check api, Env.java : readerCheck impl

* whitespace in Library.java

* upd

* update Env.java

* remove tabs
diff --git a/src/main/java/org/lmdbjava/Env.java b/src/main/java/org/lmdbjava/Env.java
@@ -41,6 +41,7 @@
 import java.util.List;
 
 import jnr.ffi.Pointer;
+import jnr.ffi.byref.IntByReference;
 import jnr.ffi.byref.PointerByReference;
 import org.lmdbjava.Library.MDB_envinfo;
 import org.lmdbjava.Library.MDB_stat;
@@ -500,6 +501,15 @@ private void validatePath(final File path) {
     validateDirectoryEmpty(path);
   }
 
+  
+  /* Check for stale entries in the reader lock table. */
+  public int readerCheck() {
+    final IntByReference resultPtr = new IntByReference();
+    checkRc(LIB.mdb_reader_check(ptr, resultPtr));
+    return resultPtr.intValue();
+  }
+  
+  
   /**
    * Object has already been closed and the operation is therefore prohibited.
    */
@@ -530,6 +540,7 @@ public AlreadyOpenException() {
     }
   }
 
+ 
   /**
    * Builder for configuring and opening Env.
    *
@@ -595,6 +606,7 @@ public Env<T> open(final File path, final EnvFlags... flags) {
       return open(path, 0664, flags);
     }
 
+
     /**
      * Sets the map size.
      *
diff --git a/src/main/java/org/lmdbjava/Library.java b/src/main/java/org/lmdbjava/Library.java
@@ -291,7 +291,7 @@ int mdb_put(@In Pointer txn, @In Pointer dbi, @In Pointer key,
                 @In Pointer data,
                 int flags);
 
-    int mdb_reader_check(@In Pointer env, int dead);
+    int mdb_reader_check(@In Pointer env, @Out IntByReference dead);
 
     int mdb_set_compare(@In Pointer txn, @In Pointer dbi, ComparatorCallback cb);
 

Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,7 @@`
`41`	`41`	`import java.util.List;`
`42`	`42`
`43`	`43`	`import jnr.ffi.Pointer;`
	`44`	`+import jnr.ffi.byref.IntByReference;`
`44`	`45`	`import jnr.ffi.byref.PointerByReference;`
`45`	`46`	`import org.lmdbjava.Library.MDB_envinfo;`
`46`	`47`	`import org.lmdbjava.Library.MDB_stat;`
`@@ -500,6 +501,15 @@ private void validatePath(final File path) {`
`500`	`501`	`validateDirectoryEmpty(path);`
`501`	`502`	`}`
`502`	`503`
	`504`	`+`
	`505`	`+ /* Check for stale entries in the reader lock table. */`
	`506`	`+ public int readerCheck() {`
	`507`	`+ final IntByReference resultPtr = new IntByReference();`
	`508`	`+ checkRc(LIB.mdb_reader_check(ptr, resultPtr));`
	`509`	`+ return resultPtr.intValue();`
	`510`	`+ }`
	`511`	`+`
	`512`	`+`
`503`	`513`	`/**`
`504`	`514`	`* Object has already been closed and the operation is therefore prohibited.`
`505`	`515`	`*/`
`@@ -530,6 +540,7 @@ public AlreadyOpenException() {`
`530`	`540`	`}`
`531`	`541`	`}`
`532`	`542`
	`543`	`+`
`533`	`544`	`/**`
`534`	`545`	`* Builder for configuring and opening Env.`
`535`	`546`	`*`
`@@ -595,6 +606,7 @@ public Env<T> open(final File path, final EnvFlags... flags) {`
`595`	`606`	`return open(path, 0664, flags);`
`596`	`607`	`}`
`597`	`608`
	`609`	`+`
`598`	`610`	`/**`
`599`	`611`	`* Sets the map size.`
`600`	`612`	`*`