Ignore tests that rely on the fsync command if the storage engine does not support it. Currently that includes the inMemory storage engine.

Author: jyemin

driver-core/src/test/functional/com/mongodb/ClusterFixture.java

@@ -114,6 +114,11 @@ public static Document getBuildInfo() {
                 .execute(getBinding());
     }
 
+    public static Document getServerStatus() {
+        return new CommandWriteOperation<Document>("admin", new BsonDocument("serverStatus", new BsonInt32(1)), new DocumentCodec())
+               .execute(getBinding());
+    }
+
     @SuppressWarnings("unchecked")
     public static boolean isEnterpriseServer() {
         Document buildInfo = getBuildInfo();
@@ -125,6 +130,13 @@ public static boolean isEnterpriseServer() {
         return modules.contains("enterprise");
     }
 
+    public static boolean supportsFsync() {
+        Document serverStatus = getServerStatus();
+        Document storageEngine = (Document) serverStatus.get("storageEngine");
+
+        return !storageEngine.get("name").equals("inMemory");
+    }
+
     private static ServerVersion getConnectedServerVersion() {
         ClusterDescription clusterDescription = getCluster().getDescription();
         int retries = 0;

driver-core/src/test/functional/com/mongodb/operation/FsyncUnlockOperationSpecification.groovy

@@ -25,10 +25,10 @@ import spock.lang.Specification
 
 import static com.mongodb.ClusterFixture.getBinding
 import static com.mongodb.ClusterFixture.isSharded
-
+import static com.mongodb.ClusterFixture.supportsFsync
 
 class FsyncUnlockOperationSpecification extends Specification {
-    @IgnoreIf({ isSharded() })
+    @IgnoreIf({ isSharded() || !supportsFsync() })
     def 'should unlock server'() {
         given:
         new CommandWriteOperation('admin', new BsonDocument('fsync', new BsonInt32(1)).append('lock', new BsonInt32(1)),

driver/src/test/functional/com/mongodb/MongoMethodsTest.java

@@ -21,12 +21,14 @@
 import java.net.UnknownHostException;
 
 import static com.mongodb.ClusterFixture.clusterIsType;
+import static com.mongodb.ClusterFixture.supportsFsync;
 import static com.mongodb.connection.ClusterType.SHARDED;
 import static org.hamcrest.CoreMatchers.hasItems;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertThat;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assume.assumeFalse;
+import static org.junit.Assume.assumeTrue;
 
 public class MongoMethodsTest extends DatabaseTestCase {
     @Test
@@ -46,6 +48,7 @@ public void shouldGetDatabaseNames() throws UnknownHostException {
     @Test
     public void shouldLockAndUnlock() {
         assumeFalse(clusterIsType(SHARDED));
+        assumeTrue(supportsFsync());
 
         assertFalse(getClient().isLocked());