-
Type: Bug
-
Resolution: Done
-
Priority: Critical - P2
-
Affects Version/s: 2.4, 2.5
-
Component/s: None
-
None
-
Environment:Single MongoDB instance, Java 6 (OS X 10.6.6).
-
Fully Compatible
DBTCPConnector._set() is susceptible to a race condition where two threads call it at the same time, allowing a thread to mistaking think _masterPortPool is set when it is still null, and go on to cause a NullPointerException in DBTCPConnector$MyPort.get().
Further detail:
I have two threads invoking DB.getCollection("differentCollectionForEachThread").drop() at approximately the same time. These are the first connections to Mongo. Approximately every 2nd run of this causes a NullPointerException in DBTCPConnector$MyPort.get(). I've tried to make a simple test app to reproduce, but can't - timing issues are tricky to replicate.
The problem occurs here:
private boolean _set( ServerAddress addr )
{ if ( _curMaster == addr) // should check that _masterPortPool != null return false; _curMaster = addr; // _curMaster set before _masterPortPool. At this point _masterPortPool is still null. _masterPortPool = _portHolder.get( addr ); return true; }Then in MyPort.get() the NPE happens:
_pool = _masterPortPool;
DBPort p = _pool.get(); // NPE
In the above code,
- Thread 1 enters _set() first, sets _curMaster = addr.
- Thread 2 enters _set() next, sees _curMaster already == addr so exits early.
- Thread 2 enters get(), assigns _pool to _masterPortPool (null) then calls _pool.get() and NPE
- Thread 1 continues in _set(), sets _masterPortPool to addr
Stack Trace (based on git head, commit a052b4f35af4069121cbf47adc88d6199563c4d4):
java.lang.NullPointerException
at com.mongodb.DBTCPConnector$MyPort.get(DBTCPConnector.java:296)
at com.mongodb.DBTCPConnector.call(DBTCPConnector.java:205)
at com.mongodb.DBApiLayer$MyCollection.__find(DBApiLayer.java:271)
at com.mongodb.DB.command(DB.java:154)
at com.mongodb.DB.command(DB.java:139)
at com.mongodb.DBCollection.drop(DBCollection.java:683)
Suggested fix:
private boolean _set( ServerAddress addr )
{ if ( _curMaster == addr && _masterPortPool != null) return false; _curMaster = addr; _masterPortPool = _portHolder.get( addr ); return true; }