Namespaces | |
namespace | base64 |
namespace | dur |
namespace | JSFiles |
namespace | task |
namespace | threadpool |
namespace | v8Locks |
Classes | |
struct | _Chars |
struct | _Ints |
struct | _KeyNode |
class | _MultiCommandJob |
struct | _OWS |
class | AbstractMessagingPort |
class | AdminAccess |
class | AdvanceStrategy |
class | AlignedBuilder |
class | AScopedConnection |
class | AssertionCount |
class | AssertionException |
struct | atleastreadlock |
class | Atomic |
struct | AtomicUInt |
struct | Auth |
class | AuthenticationInfo |
struct | AuthInfo |
class | BackgroundJob |
class | BackgroundOperation |
class | Balancer |
class | BalancerPolicy |
class | BasicCursor |
struct | BinDataHolder |
class | BlockingQueue |
struct | BSONArray |
class | BSONArrayBuilder |
class | BSONElement |
struct | BSONElementCmpWithoutField |
struct | BSONElementFieldNameCmp |
class | BSONElementManipulator |
class | BSONField |
class | BSONFieldValue |
class | BSONObj |
class | BSONObjBuilder |
class | BSONObjBuilderValueStream |
class | BSONObjCmp |
class | BSONObjCmpDefaultOrder |
class | BSONObjExternalSorter |
class | BSONObjIterator |
class | BSONObjIteratorSorted |
class | BSONSizeTracker |
class | BtreeBucket |
class | BtreeBuilder |
class | BtreeCursor |
class | BtreeData |
class | BucketBasics |
class | BufBuilder |
class | BufReader |
struct | ByLocKey |
class | CachedBSONObj |
class | Chunk |
class | ChunkCmp |
class | ChunkManager |
class | ChunkRange |
class | ChunkRangeManager |
class | Client |
class | ClientCursor |
class | ClientCursorMonitor |
class | ClientInfo |
struct | ClockSkewException |
class | ClusteredCursor |
struct | CmdLine |
class | CodeBlock |
class | Command |
class | ConfigServer |
class | ConnectException |
class | ConnectionString |
class | Consensus |
class | CoveredIndexMatcher |
class | CurOp |
class | Cursor |
class | CursorCache |
class | Database |
class | DatabaseHolder |
class | DataFileHeader |
class | DataFileMgr |
struct | Date_t |
struct | DateNowLabeler |
class | DBClientBase |
class | DBClientConnection |
class | DBClientCursor |
class | DBClientCursorBatchIterator |
class | DBClientCursorInterface |
class | DBClientInterface |
class | DBClientMockCursor |
class | DBClientReplicaSet |
class | DBClientWithCommands |
class | DBConfig |
class | DBConnectionHook |
class | DBConnectionPool |
class | DBConnector |
class | DBDirectClient |
class | DBException |
class | DbIds |
struct | dblock |
class | DbMessage |
struct | DbResponse |
class | DbSet |
struct | dbtemprelease |
struct | dbtempreleasecond |
class | DbWebHandler |
class | DeletedRecord |
struct | DiagLog |
class | DiagStr |
class | DiskLoc |
class | dist_lock_try |
class | DistributedLock |
class | ElapsedTracker |
struct | element_lt |
class | ElementMatcher |
class | EmbeddedBuilder |
struct | eq_str |
struct | ExceptionInfo |
class | Extent |
class | FastArray |
struct | FieldBound |
struct | FieldInterval |
class | FieldRange |
class | FieldRangeOrSet |
class | FieldRangeSet |
class | FieldRangeVector |
class | File |
class | FileAllocator |
class | FileInterface |
class | FilteringClientCursor |
class | FindingStartCursor |
class | FineClock |
class | FlushCounters |
class | ForwardCappedCursor |
class | Future |
class | GenericCounter |
struct | GENOIDLabeler |
struct | GetMoreWaitException |
class | Grid |
class | GridFile |
class | GridFS |
class | GridFSChunk |
class | HashTable |
struct | HealthOptions |
class | HeartbeatInfo |
struct | Helpers |
class | Histogram |
struct | HostAndPort |
class | HttpClient |
class | IdTracker |
struct | IndexChanges |
class | IndexCounters |
class | IndexDetails |
class | IndexPlugin |
class | IndexSpec |
class | IndexType |
class | JavaJSImpl |
class | JavaScope |
struct | JSFile |
class | KeyNode |
class | KeyType |
class | KillCurrentOp |
class | Labeler |
struct | LastError |
class | LastErrorHolder |
class | LazyString |
class | LazyStringImpl |
struct | LimitsFields |
class | List1 |
class | Listener |
class | ListeningSockets |
class | LogFile |
struct | LogIndentLevel |
class | Logstream |
class | LRUishMap |
class | Manager |
struct | MatchDetails |
class | Matcher |
struct | MaxKeyLabeler |
class | Member |
struct | MemberState |
class | MemIds |
class | MemoryMappedFile |
class | Message |
class | MessageHandler |
class | MessageServer |
class | MessagingPort |
class | MiniWebServer |
struct | MinKeyLabeler |
struct | Mod |
class | Model |
class | ModSet |
class | ModSetState |
class | ModState |
class | Module |
class | MongoDataFile |
class | MongoFile |
struct | MongoFileAllowWrites |
class | MongoFileFinder |
class | mongolock |
class | MongoMMF |
class | MongoMutex |
struct | MoveableBuffer |
class | MsgAssertionException |
struct | MsgData |
struct | MSGHEADER |
class | MultiCursor |
class | MultiPlanScanner |
class | mutex |
class | MutexDebugger |
class | MutexInfo |
class | MVar |
class | Namespace |
class | NamespaceDetails |
class | NamespaceDetailsTransient |
class | NamespaceIndex |
class | NamespaceString |
class | NetworkCounter |
class | NoAdminAccess |
class | Notification |
class | NotifyAll |
class | Nullstream |
class | OID |
struct | OP_GETMORE |
class | OpCounters |
class | OpDebug |
class | OplogReader |
class | OpTime |
class | Ordering |
class | PairSync |
class | ParallelSortClusteredCursor |
class | ParameterValidator |
class | ParsedQuery |
struct | PasswordValue |
class | PointerToMMF |
class | PoolForHost |
class | Prioritizable |
class | ProcessInfo |
class | ProgressMeter |
class | ProgressMeterHolder |
class | Projection |
struct | ptr |
class | Query |
class | QueryMessage |
class | QueryOp |
class | QueryPattern |
class | QueryPlan |
class | QueryPlanSet |
struct | QueryResult |
class | RamLog |
struct | readlock |
struct | readlocktry |
struct | readlocktryassert |
class | Record |
class | RegexMatcher |
struct | RelativePath |
class | RemoveSaver |
class | ReplicaSetMonitor |
class | ReplPair |
class | ReplSet |
class | ReplSetCmdline |
class | ReplSetCommand |
class | ReplSetConfig |
class | ReplSetImpl |
class | ReplSettings |
class | ReplSource |
class | Request |
class | RestAdminAccess |
class | RetryAfterSleepException |
class | ReverseCappedCursor |
class | ReverseCursor |
class | RSBase |
class | rwlock |
class | RWLock |
class | rwlock_try_write |
class | ScanAndOrder |
class | Scope |
class | ScopedConn |
class | ScopedDbConnection |
class | ScriptEngine |
struct | Security |
class | SerialServerClusteredCursor |
class | ServerAndQuery |
class | Servers |
class | ServiceStats |
class | Shard |
class | ShardChunkManager |
struct | ShardChunkVersion |
class | ShardConnection |
class | ShardedClientCursor |
class | ShardedConnectionInfo |
struct | ShardFields |
struct | ShardForceVersionOkModeBlock |
class | ShardingState |
class | ShardKeyPattern |
struct | ShardNS |
class | ShardStatus |
class | SnapshotData |
class | SnapshotDelta |
class | Snapshots |
class | SnapshotThread |
struct | SockAddr |
class | SocketException |
class | SpinLock |
class | StaleConfigException |
class | StateBox |
class | StaticObserver |
class | Strategy |
class | StringBuilder |
class | StringData |
class | StringSplitter |
class | SyncClusterConnection |
class | SyncException |
struct | Target |
class | TaskQueue |
class | Tee |
class | ThreadLocalValue |
class | ThreadSafeString |
class | TicketHolder |
class | TicketHolderReleaser |
class | Timer |
class | Top |
class | TopOld |
struct | UnitTest |
class | UpdateNotTheSame |
struct | UpdateResult |
class | UserException |
class | V8Lock |
class | V8Scope |
class | V8ScriptEngine |
struct | V8Unlock |
class | VoteException |
class | WebStatusPlugin |
struct | WrappingInt |
class | WriteBackListener |
class | WriteBackManager |
struct | writelock |
struct | writelocktry |
Typedefs | |
typedef char | _TCHAR |
typedef multimap< BSONObj, BSONObj, BSONObjCmp > | BestMap |
typedef vector< pair< BSONObj, BSONObj > > | BoundList |
typedef set< BSONElement, BSONElementCmpWithoutField > | BSONElementSet |
typedef map< string, BSONElement > | BSONMap |
typedef set< BSONObj, BSONObjCmpDefaultOrder > | BSONObjSetDefaultOrder |
typedef set< BSONElement, BSONElementFieldNameCmp > | BSONSortedElements |
typedef map< CursorId, ClientCursor * > | CCById |
typedef map< ByLocKey, ClientCursor * > | CCByLoc |
typedef char | CHARS [400] |
typedef struct mongo::_Chars * | Chars |
typedef shared_ptr< ChunkManager > | ChunkManagerPtr |
typedef map< BSONObj, ChunkPtr, BSONObjCmp > | ChunkMap |
typedef shared_ptr< Chunk > | ChunkPtr |
typedef map< BSONObj, shared_ptr< ChunkRange > , BSONObjCmp > | ChunkRangeMap |
typedef ShardChunkVersion | ConfigVersion |
typedef long long | ConnectionId |
typedef long long | CursorId |
typedef boost::shared_ptr < DBConfig > | DBConfigPtr |
typedef uint64_t | fileofs |
typedef unsigned long long | gridfs_offset |
typedef int | HANDLE |
typedef struct mongo::_Ints * | Ints |
typedef unsigned char | md5digest [16] |
typedef MemoryMappedFile | MMF |
typedef AtomicUInt | MSGID |
typedef const char * | MyStr |
typedef BSONObj(* | NativeFunction )(const BSONObj &args) |
typedef unsigned long long | nonce |
typedef map< string, ConfigVersion > | NSVersionMap |
typedef struct mongo::_OWS * | OWS |
typedef boost::recursive_mutex::scoped_lock | recursive_scoped_lock |
typedef shared_ptr < ReplicaSetMonitor > | ReplicaSetMonitorPtr |
typedef unsigned long long | ReplTime |
typedef mutex::scoped_lock | scoped_lock |
typedef unsigned long long | ScriptingFunction |
typedef shared_ptr < ShardChunkManager > | ShardChunkManagerPtr |
typedef boost::shared_ptr < ShardedClientCursor > | ShardedClientCursorPtr |
typedef int | SOCKET |
typedef hash_map< const char *, int, hash< const char * > , eq_str > | strhashmap |
Enumerations | |
enum | { ASSERT_ID_DUPKEY = 11000 } |
enum | { DEBUG_BUILD = 0 } |
enum | BinDataType { BinDataGeneral = 0, Function = 1, ByteArrayDeprecated = 2, bdtUUID = 3, MD5Type = 5, bdtCustom = 128 } |
enum | BSONType { MinKey = -1, EOO = 0, NumberDouble = 1, String = 2, Object = 3, Array = 4, BinData = 5, Undefined = 6, jstOID = 7, Bool = 8, Date = 9, jstNULL = 10, RegEx = 11, DBRef = 12, Code = 13, Symbol = 14, CodeWScope = 15, NumberInt = 16, Timestamp = 17, NumberLong = 18, JSTypeMax = 18, MaxKey = 127 } |
enum | CommonErrorCodes { DatabaseDifferCaseCode = 13297, StaleConfigInContextCode = 13388 } |
enum | ExitCode { EXIT_CLEAN = 0, EXIT_BADOPTIONS = 2, EXIT_REPLICATION_ERROR = 3, EXIT_NEED_UPGRADE = 4, EXIT_SHARDING_ERROR = 5, EXIT_KILL = 12, EXIT_ABRUPT = 14, EXIT_NTSERVICE_ERROR = 20, EXIT_JAVA = 21, EXIT_OOM_MALLOC = 42, EXIT_OOM_REALLOC = 43, EXIT_FS = 45, EXIT_CLOCK_SKEW = 47, EXIT_NET_ERROR = 48, EXIT_POSSIBLE_CORRUPTION = 60, EXIT_UNCAUGHT = 100, EXIT_TEST = 101 } |
enum | FieldCompareResult { LEFT_SUBFIELD = -2, LEFT_BEFORE = -1, SAME = 0, RIGHT_BEFORE = 1, RIGHT_SUBFIELD = 2 } |
enum | IndexSuitability { USELESS = 0, HELPFUL = 1, OPTIMAL = 2 } |
enum | JsonStringFormat { Strict, TenGen, JS } |
enum | LogLevel { LL_DEBUG, LL_INFO, LL_NOTICE, LL_WARNING, LL_ERROR, LL_SEVERE } |
enum | Operations { opReply = 1, dbMsg = 1000, dbUpdate = 2001, dbInsert = 2002, dbQuery = 2004, dbGetMore = 2005, dbDelete = 2006, dbKillCursors = 2007 } |
enum | QueryOptions { QueryOption_CursorTailable = 1 << 1, QueryOption_SlaveOk = 1 << 2, QueryOption_OplogReplay = 1 << 3, QueryOption_NoCursorTimeout = 1 << 4, QueryOption_AwaitData = 1 << 5, QueryOption_Exhaust = 1 << 6, QueryOption_PartialResults = 1 << 7, QueryOption_AllSupported = QueryOption_CursorTailable | QueryOption_SlaveOk | QueryOption_OplogReplay | QueryOption_NoCursorTimeout | QueryOption_AwaitData | QueryOption_Exhaust | QueryOption_PartialResults } |
enum | RemoveOptions { RemoveOption_JustOne = 1 << 0, RemoveOption_Broadcast = 1 << 1 } |
enum | ResultFlagType { ResultFlag_CursorNotFound = 1, ResultFlag_ErrSet = 2, ResultFlag_ShardConfigStale = 4, ResultFlag_AwaitCapable = 8 } |
enum | SlaveTypes { NotSlave = 0, SimpleSlave, ReplPairSlave } |
enum | UpdateOptions { UpdateOption_Upsert = 1 << 0, UpdateOption_Multi = 1 << 1, UpdateOption_Broadcast = 1 << 2 } |
enum | WriteConcern { W_NONE = 0, W_NORMAL = 1 } |
Functions | |
bool | _handlePossibleShardedMessage (Message &m, DbResponse *dbresponse) |
bool | _isMaster () |
Nullstream & | _log (int level=0) |
void | _logOpObjRS (const BSONObj &op) |
bool | _runCommands (const char *ns, BSONObj &jsobj, BufBuilder &b, BSONObjBuilder &anObjBuilder, bool fromRepl, int queryOptions) |
UpdateResult | _updateObjects (bool god, const char *ns, const BSONObj &updateobj, BSONObj pattern, bool upsert, bool multi, bool logop, OpDebug &debug, RemoveSaver *rs=0) |
void | aboutToDeleteForSharding (const Database *db, const DiskLoc &dl) |
void | acquirePathLock () |
bool | anyReplEnabled () |
void | appendReplicationInfo (BSONObjBuilder &result, bool authed, int level=0) |
bool | appendSpecialDBObject (Convertor *c, BSONObjBuilder &b, const string &name, jsval val, JSObject *o) |
void | applyOperation_inlock (const BSONObj &op, bool fromRepl=true) |
long long | applySkipLimit (long long num, const BSONObj &cmd) |
std::string | askPassword () |
void | assembleResponse (Message &m, DbResponse &dbresponse, const SockAddr &client=unknownAddress) |
void | assert (bool expr) |
void | asserted (const char *msg, const char *file, unsigned line) |
void | assertInWriteLock () |
void | assertStreamGood (unsigned msgid, string msg, std::ios &myios) |
shared_ptr< Cursor > | bestGuessCursor (const char *ns, const BSONObj &query, const BSONObj &sort) |
v8::Handle< v8::Value > | binDataInit (const v8::Arguments &args) |
v8::Handle< v8::Value > | binDataToString (const v8::Arguments &args) |
BOOST_STATIC_ASSERT (16==sizeof(DeletedRecord)) | |
void | breakif (bool test) |
void | breakpoint () |
BSONMap | bson2map (const BSONObj &obj) |
BSONSortedElements | bson2set (const BSONObj &obj) |
v8::Handle< v8::Value > | bsonsize (const v8::Arguments &args) |
Client & | cc () |
void | checkDataFileVersion (NamespaceDetails &d) |
void | checkIndexFileVersion (NamespaceDetails &d) |
bool | cloneFrom (const char *masterHost, string &errmsg, const string &fromdb, bool logForReplication, bool slaveOk, bool useReplAuth, bool snapshot) |
void | closesocket (int s) |
v8::Handle< v8::Value > | collectionFallback (v8::Local< v8::String > name, const v8::AccessorInfo &info) |
v8::Handle< v8::Value > | collectionInit (const v8::Arguments &args) |
FieldCompareResult | compareDottedFieldNames (const string &l, const string &r) |
int | compareElementValues (const BSONElement &l, const BSONElement &r) |
DBClientBase * | createDirectClient () |
void | createOplog () |
MessageServer * | createServer (const MessageServer::Options &opts, MessageHandler *handler) |
WrapperHolder * | createWrapperHolder (const BSONObj *o, bool readOnly, bool iDelete) |
void | curopGotLock (Client *) |
Client * | curopWaitingForLock (int type) |
boost::gregorian::date | currentDate () |
unsigned | curTimeMicros () |
unsigned long long | curTimeMicros64 () |
unsigned | curTimeMillis () |
void | dbexit (ExitCode returnCode, const char *whyMsg="", bool tryToGetLock=false) |
v8::Handle< v8::Value > | dbInit (const v8::Arguments &args) |
v8::Handle< v8::Value > | dbPointerInit (const v8::Arguments &args) |
v8::Handle< v8::Value > | dbQueryIndexAccess (uint32_t index, const v8::AccessorInfo &info) |
v8::Handle< v8::Value > | dbQueryInit (const v8::Arguments &args) |
v8::Handle< v8::Value > | dbRefInit (const v8::Arguments &args) |
boost::intmax_t | dbSize (const char *database) |
v8::Handle< v8::Value > | dbTimestampInit (const v8::Arguments &args) |
void | dbunlocking_read () |
void | dbunlocking_write () |
string | debugString (Message &m) |
long long | deleteObjects (const char *ns, BSONObj pattern, bool justOne, bool logop=false, bool god=false, RemoveSaver *rs=0) |
string | demangleName (const type_info &typeinfo) |
std::string | digestToString (md5digest digest) |
void | disableNagle (int sock) |
void | disableV8Interrupt () |
bool | doesOpGetAResponse (int op) |
void | dontDeleteScope (SMScope *s) |
BSONObj | dotted2nested (const BSONObj &obj) |
void | dotted2nested (BSONObjBuilder &b, const BSONObj &obj) |
void | dropCollection (const string &name, string &errmsg, BSONObjBuilder &result) |
void | dropDatabase (string db) |
bool | dropIndexes (NamespaceDetails *d, const char *ns, const char *name, string &errmsg, BSONObjBuilder &anObjBuilder, bool maydeleteIdIndex) |
void | dropNS (const string &dropNs) |
void | dumpmemory (const char *data, int len) |
void | dupCheck (vector< IndexChanges > &v, NamespaceDetails &d, DiskLoc curObjLoc) |
void | enableIPv6 (bool state=true) |
void | enableV8Interrupt () |
bool | endsWith (const char *p, const char *suffix) |
void | ensureHaveIdIndex (const char *ns) |
void | ensureParentDirCreated (const boost::filesystem::path &p) |
string | errnoWithDescription (int x=errno) |
string | errnoWithPrefix (const char *prefix) |
Nullstream & | error () |
void | errorReporter (JSContext *cx, const char *message, JSErrorReport *report) |
void | exit (ExitCode returnCode) |
void | exitCleanly (ExitCode code) |
unsigned long long | extractVersion (BSONElement e, string &errmsg) |
void | fillQueryResultFromObj (BufBuilder &bb, Projection *filter, const BSONObj &js, DiskLoc *loc=NULL) |
const char * | findEd (const char *) |
const char * | findEd () |
const string | findJars () |
shared_ptr< Cursor > | findTableScan (const char *ns, const BSONObj &order, const DiskLoc &startLoc=DiskLoc()) |
unsigned long | fixEndian (unsigned long x) |
const AdvanceStrategy * | forward () |
boost::intmax_t | freeSpace (const string &path=dbpath) |
char | fromHex (const char *c) |
int | fromHex (char c) |
BSONObj | fromjson (const char *str, int *len=NULL) |
BSONObj | fromjson (const string &str) |
v8::Handle< v8::Value > | GCV8 (const v8::Arguments &args) |
string | getAddrInfoStrError (int code) |
mongo::DBClientBase * | getConnection (const v8::Arguments &args) |
pthread_t | GetCurrentThreadId () |
void | getDatabaseNames (vector< string > &names, const string &usePath=dbpath) |
dur::DurableInterface & | getDur () |
int | getGtLtOp (const BSONElement &e) |
string | getHostName () |
string | getHostNameCached () |
void | getIndexChanges (vector< IndexChanges > &v, NamespaceDetails &d, BSONObj newObj, BSONObj oldObj, bool &cangedId) |
v8::Handle< v8::FunctionTemplate > | getMongoFunctionTemplate (bool local) |
v8::Function * | getNamedCons (const char *name) |
v8::Function * | getObjectIdCons () |
v8::Handle< v8::FunctionTemplate > | getObjectWrapperTemplate () |
unsigned | getRandomNumber () |
unsigned | getSlaveCount () |
string | getThreadName () |
const char * | gitVersion () |
bool | handlePossibleShardedMessage (Message &m, DbResponse *dbresponse) |
bool | hasJSReturn (const string &s) |
bool | haveClient () |
bool | haveLocalShardingInfo (const string &ns) |
string | hexdump (const char *data, unsigned len) |
string | hostbyname (const char *hostname) |
boost::xtime | incxtimemillis (long long s) |
IndexDetails * | indexDetailsForRange (const char *ns, string &errmsg, BSONObj &min, BSONObj &max, BSONObj &keyPattern) |
void | initLogging (const string &logpath, bool append) |
void | initMongoJS (SMScope *scope, JSContext *cx, JSObject *global, bool local) |
bool | inShutdown () |
void | installChunkShardVersioning () |
void | installDBTypes (v8::Handle< v8::Object > &global) |
void | installDBTypes (v8::Handle< v8::ObjectTemplate > &global) |
void | installFork (v8::Handle< v8::Object > &global, v8::Handle< v8::Context > &context) |
void | installGlobalUtils (Scope &scope) |
v8::Handle< v8::Value > | internalCursorCons (const v8::Arguments &args) |
v8::Handle< v8::Value > | internalCursorHasNext (const v8::Arguments &args) |
v8::Handle< v8::Value > | internalCursorNext (const v8::Arguments &args) |
v8::Handle< v8::Value > | internalCursorObjsLeftInBatch (const v8::Arguments &args) |
bool | IPv6Enabled () |
bool | isANormalNSName (const char *ns) |
bool | isDate (JSContext *cx, JSObject *o) |
bool | isMaster (const char *client=0) |
bool | isMasterNs (const char *ns) |
bool | isNumber (char c) |
bool | isPrime (int n) |
bool | isSimpleIdQuery (const BSONObj &query) |
bool | isValidNS (const StringData &ns) |
bool | isValidUTF8 (string s) |
bool | isValidUTF8 (const char *s) |
void | jasserted (const char *msg, const char *file, unsigned line) |
JNIEXPORT jint JNICALL | java_native_call (JNIEnv *, jclass, jobject outBuffer, jobject inBuffer) |
JNIEXPORT void JNICALL | java_native_say (JNIEnv *, jclass, jobject outBuffer) |
void | joinStringDelim (const vector< string > &strs, string *res, char delim) |
const char * | jsSkipWhiteSpace (const char *raw) |
Date_t | jsTime () |
bool | legalClientSystemNS (const string &ns, bool write) |
int | lexNumCmp (const char *s1, const char *s2) |
Nullstream & | log () |
Nullstream & | log (LogLevel l) |
Nullstream & | log (int level) |
void | logflush (int level=0) |
void | logKeepalive () |
const char * | logLevelToString (LogLevel l) |
void | logOp (const char *opstr, const char *ns, const BSONObj &obj, BSONObj *patt=0, bool *b=0) |
void | logOpComment (const BSONObj &obj) |
void | logOpForSharding (const char *opstr, const char *ns, const BSONObj &obj, BSONObj *patt) |
string | makeUnixSockPath (int port) |
void | massert (unsigned msgid, std::string msg, bool expr) |
const DiskLoc | maxDiskLoc (0x7fffffff, 0x7fffffff) |
void | maybeCreatePidFile () |
void | md5 (const char *str, md5digest digest) |
void | md5 (const void *buf, int nbytes, md5digest digest) |
std::string | md5simpledigest (string s) |
std::string | md5simpledigest (const void *buf, int nbytes) |
const DiskLoc | minDiskLoc (0, 1) |
v8::Handle< v8::Value > | mongoConsExternal (const v8::Arguments &args) |
v8::Handle< v8::Value > | mongoConsLocal (const v8::Arguments &args) |
string | mongodVersion () |
v8::Handle< v8::Value > | mongoFind (const v8::Arguments &args) |
v8::Handle< v8::Value > | mongoInsert (const v8::Arguments &args) |
v8::Handle< v8::Value > | mongoRemove (const v8::Arguments &args) |
v8::Local< v8::Object > | mongoToV8 (const mongo::BSONObj &m, bool array=0, bool readOnly=false) |
v8::Handle< v8::Value > | mongoToV8Element (const BSONElement &f) |
v8::Handle< v8::Value > | mongoUpdate (const v8::Arguments &args) |
void | msgasserted (int msgid, string msg) |
void | msgasserted (int msgid, const std::string &msg) |
void | msgasserted (int msgid, const char *msg) |
void | msgassertedNoTrace (int msgid, const string &msg) |
void | msgassertedNoTrace (int msgid, const char *msg) |
void | multiCommand (BSONObj cmd, list< Target > &L) |
BSONObj | nested2dotted (const BSONObj &obj) |
void | nested2dotted (BSONObjBuilder &b, const BSONObj &obj, const string &base="") |
template<v8::Handle< v8::Value >(*)(const v8::Arguments &) f> | |
v8::Local< v8::FunctionTemplate > | newV8Function () |
MSGID | nextMessageId () |
int | nextPrime (int n) |
void | notMasterUnless (bool expr) |
NamespaceDetails * | nsdetails (const char *ns) |
NamespaceIndex * | nsindex (const char *ns) |
string | nsToDatabase (const string &ns) |
string | nsToDatabase (const char *ns) |
void | nsToDatabase (const char *ns, char *database) |
v8::Handle< v8::Value > | numberLongInit (const v8::Arguments &args) |
v8::Handle< v8::Value > | numberLongToNumber (const v8::Arguments &args) |
v8::Handle< v8::Value > | numberLongToString (const v8::Arguments &args) |
v8::Handle< v8::Value > | numberLongValueOf (const v8::Arguments &args) |
v8::Handle< v8::Value > | objectIdInit (const v8::Arguments &args) |
ostream & | operator<< (ostream &s, const ThreadSafeString &o) |
std::ostream & | operator<< (std::ostream &s, const v8::Handle< v8::TryCatch > *try_catch) |
std::ostream & | operator<< (std::ostream &s, const v8::Handle< v8::Value > &o) |
ostream & | operator<< (ostream &s, const ShardChunkVersion &v) |
StringBuilder & | operator<< (StringBuilder &s, const OID &o) |
ostream & | operator<< (ostream &s, const OID &o) |
StringBuilder & | operator<< (StringBuilder &s, const BSONElement &e) |
StringBuilder & | operator<< (StringBuilder &s, const BSONObj &o) |
ostream & | operator<< (ostream &s, const BSONElement &e) |
ostream & | operator<< (ostream &s, const BSONObj &o) |
bool | opIsWrite (int op) |
void | oplogCheckCloseDatabase (Database *db) |
bool | opReplicatedEnough (OpTime op, int w) |
const char * | opToString (int op) |
BSONObj | OR (const BSONObj &a, const BSONObj &b, const BSONObj &c, const BSONObj &d, const BSONObj &e, const BSONObj &f) |
BSONObj | OR (const BSONObj &a, const BSONObj &b, const BSONObj &c, const BSONObj &d, const BSONObj &e) |
BSONObj | OR (const BSONObj &a, const BSONObj &b, const BSONObj &c, const BSONObj &d) |
BSONObj | OR (const BSONObj &a, const BSONObj &b, const BSONObj &c) |
BSONObj | OR (const BSONObj &a, const BSONObj &b) |
void * | ourmalloc (size_t size) |
void * | ourrealloc (void *ptr, size_t size) |
Nullstream & | out (int level=0) |
long long | parseLL (const char *n) |
void | parseReplsetCmdLine (string cfgString, string &setname, vector< HostAndPort > &seeds, set< HostAndPort > &seedSet) |
void | prebindOptions (int sock) |
void | pretouchN (vector< BSONObj > &, unsigned a, unsigned b) |
void | pretouchOperation (const BSONObj &op) |
string | prettyHostName () |
v8::Handle< v8::Value > | Print (const v8::Arguments &args) |
void | printGitVersion () |
void | printMemInfo (const char *where) |
void | printStackAndExit (int signalNum) |
void | printStackTrace (ostream &o=cout) |
void | printSysInfo () |
Nullstream & | problem (int level=0) |
QueryResult * | processGetMore (const char *ns, int ntoreturn, long long cursorid, CurOp &op, int pass, bool &exhaust) |
void | processRequest (Message &m, MessagingPort &p) |
void | profile (const char *str, int millis) |
void | raiseError (int code, const char *msg) |
void | rawOut (const string &s) |
void | renameNamespace (const char *from, const char *to) |
bool | repairDatabase (string db, string &errmsg, bool preserveClonedFilesOnFailure=false, bool backupOriginalFiles=false) |
bool | replHasDatabases () |
void | replVerifyReadsOk (ParsedQuery &pq) |
void | replyToQuery (int queryResultFlags, Message &m, DbResponse &dbresponse, BSONObj obj) |
void | replyToQuery (int queryResultFlags, AbstractMessagingPort *p, Message &requestMsg, BSONObj &responseObj) |
void | replyToQuery (int queryResultFlags, AbstractMessagingPort *p, Message &requestMsg, void *data, int size, int nReturned, int startingFrom=0, long long cursorId=0) |
void | ReportException (v8::TryCatch *handler) |
bool | requestHeartbeat (string setname, string fromHost, string memberFullName, BSONObj &result, int myConfigVersion, int &theirConfigVersion, bool checkEmpty=false) |
void | resetSlaveCache () |
JSBool | resolveBSONField (JSContext *cx, JSObject *obj, jsval id, uintN flags, JSObject **objp) |
const AdvanceStrategy * | reverse () |
void | rotateLogs (int signal=0) |
long long | runCount (const char *ns, const BSONObj &cmd, string &err) |
const char * | runQuery (Message &m, QueryMessage &q, CurOp &curop, Message &result) |
bool | sameHostname (const string &a, const string &b) |
string | sayClientState () |
void | sayDbContext (const char *msg=0) |
bool | serverAlive (const string &uri) |
bool | setShardVersion (DBClientBase &conn, const string &ns, ShardChunkVersion version, bool authoritative, BSONObj &result) |
void | setSockTimeouts (int sock, double secs) |
unsigned | setThreadName (const char *name) |
void | setupCoreSignals () |
bool | setUpSecurityKey (const string &filename) |
void | setupSIGTRAPforGDB () |
bool | shardVersionOk (const string &ns, bool write, string &errmsg) |
void | show_warnings () |
string | simpleRegex (const char *regex, const char *flags, bool *purePrefix=NULL) |
string | simpleRegexEnd (string prefix) |
void | sleepmicros (long long s) |
void | sleepmillis (long long s) |
void | sleepsecs (int s) |
void | splitStringDelim (const string &str, vector< string > *res, char delim) |
bool | startsWith (string s, string p) |
bool | startsWith (const char *str, const char *prefix) |
void | strcpy_s (char *dst, unsigned len, const char *src) |
void | streamNotGood (int code, string msg, std::ios &myios) |
unsigned | stringToNum (const char *str) |
int | strnlen (const char *s, int n) |
unsigned long | swapEndian (unsigned long x) |
string | sysInfo () |
int | tdiff (unsigned told, unsigned tnew) |
string | terseCurrentTime (bool colonsOk=true) |
string | time_t_to_String (time_t t=time(0)) |
void | time_t_to_String (time_t t, char *buf) |
string | time_t_to_String_no_year (time_t t) |
string | time_t_to_String_short (time_t t) |
void | time_t_to_Struct (time_t t, struct tm *buf, bool local=false) |
Nullstream & | tlog (int level=0) |
string | toHex (const void *inRaw, int len) |
string | toHexLower (const void *inRaw, int len) |
string | tolowerString (const string &input) |
bool | toPointInTime (const string &str, boost::posix_time::ptime *timeOfDay) |
std::string | toSTLString (const v8::TryCatch *try_catch) |
std::string | toSTLString (const v8::Handle< v8::Value > &o) |
template<class T > | |
string | ToString (const T &t) |
std::string | toUtf8String (const std::wstring &wide) |
BSONObj | transformOrderFromArrayFormat (BSONObj order) |
void | uassert (unsigned msgid, std::string msg, bool expr) |
void | uassert_nothrow (const char *msg) |
void | uasserted (int msgid, string msg) |
void | uasserted (int msgid, const char *msg) |
void | uasserted (unsigned msgid, std::string s) |
UpdateResult | updateObjects (const char *ns, const BSONObj &updateobj, BSONObj pattern, bool upsert, bool multi, bool logop, OpDebug &debug) |
void | updateSlaveLocation (CurOp &curop, const char *oplog_ns, OpTime lastOp) |
bool | userCreateNS (const char *ns, BSONObj j, string &err, bool logForReplication, bool *deferIdIndex=0) |
template<v8::Handle< v8::Value >(*)(const v8::Arguments &) f> | |
v8::Handle< v8::Value > | v8Callback (const v8::Arguments &args) |
mongo::BSONObj | v8ToMongo (v8::Handle< v8::Object > o, int depth=0) |
void | v8ToMongoElement (BSONObjBuilder &b, v8::Handle< v8::String > name, const string sname, v8::Handle< v8::Value > value, int depth=0) |
v8::Handle< v8::Value > | Version (const v8::Arguments &args) |
int | versionCmp (StringData rhs, StringData lhs) |
void | waitForWriteback (const OID &oid) |
Nullstream & | warning () |
void | wasserted (const char *msg, const char *file, unsigned line) |
void | webServerThread (const AdminAccess *admins) |
void | writePidFile (const std::string &path) |
Variables | |
int | __findingStartInitialTimeout |
map< unsigned, int > | __interruptSpecToThreadId |
mutex | _atomicMutex |
DiagLog | _diaglog |
AssertionCount | assertionCount |
Balancer | balancer |
JSClass | bindata_class |
JSClass | bson_class |
JSClass | bson_ro_class |
const int | BSONObjMaxInternalSize = BSONObjMaxUserSize + ( 16 * 1024 ) |
const int | BSONObjMaxUserSize = 16 * 1024 * 1024 |
const int | Buckets = 19 |
const int | BucketSize = 8192 |
int | bucketSizes [] |
const int | BufferMaxSize = 64 * 1024 * 1024 |
boost::function4< bool, DBClientBase &, const string &, bool, int > | checkShardVersionCB |
ClientCursorMonitor | clientCursorMonitor |
CmdLine | cmdLine |
ConfigServer & | configServer |
DBConfigPtr | configServerPtr |
TicketHolder | connTicketHolder |
boost::thread_specific_ptr < Client > | currentClient |
boost::thread_specific_ptr < SMScope > | currentScope |
CursorCache | cursorCache |
struct mongo::DateNowLabeler | DATENOW |
string | dbExecCommand |
DatabaseHolder | dbHolder |
MongoMutex & | dbMutex |
string | dbpath |
JSClass | dbpointer_class |
JSClass | dbref_class |
const bool | debug = false |
bool | directoryperdb |
struct mongo::GENOIDLabeler | GENOID |
const char *(* | getcurns )() |
FlushCounters | globalFlushCounters |
IndexCounters | globalIndexCounters |
OpCounters | globalOpCounters |
ScriptEngine * | globalScriptEngine |
Grid | grid |
Labeler::Label | GT |
Labeler::Label | GTE |
BSONObj | id_obj |
AuthInfo | internalSecurity |
const int | INVALID_SOCKET = -1 |
JavaJSImpl * | JavaJS |
class mongo::KillCurrentOp | killCurrentOp |
char | last = 0 |
class mongo::LastErrorHolder | lastError |
int | lockFile |
int | logLevel |
Labeler::Label | LT |
Labeler::Label | LTE |
const int | MaxBucket = 18 |
const int | MaxBytesToReturnToClientAtOnce |
const int | MaxDatabaseNameLen = 256 |
BSONObj | maxKey |
struct mongo::MaxKeyLabeler | MAXKEY |
JSClass | maxkey_class |
const int | MaxMTU = 16384 |
BSONObj | minKey |
struct mongo::MinKeyLabeler | MINKEY |
JSClass | minkey_class |
const int | MsgDataHeaderSize = sizeof(MsgData) - 4 |
MutexDebugger & | mutexDebugger |
Labeler::Label | NE |
NetworkCounter | networkCounter |
bool | noauth |
bool | noUnixSocket |
Nullstream | nullstream |
JSClass | numberlong_class |
bool | objcheck |
JSClass | object_id_class |
OpCounters | opsNonSharded |
OpCounters | opsSharded |
char * | p = code |
DBConnectionPool | pool |
PointerToMMF | privateViews |
const char * | replAllDead |
OpCounters | replOpCounters |
ReplPair * | replPair |
bool | replSet |
ReplSettings | replSettings |
boost::function1< void, DBClientBase * > | resetShardVersionCB |
const BSONObj | reverseNaturalObj = BSON( "$natural" << -1 ) |
const string | rsConfigNs = "local.system.replset" |
Tee * | rsLog |
const char | rsoplog [] = "local.oplog.rs" |
Security | security |
OID | serverID |
Strategy * | SHARDED |
GenericCounter | shardedCursorTypes |
ShardingState | shardingState |
Strategy * | SINGLE |
Labeler::Label | SIZE |
SnapshotThread | snapshotThread |
const int | SOCK_FAMILY_UNKNOWN_ERROR = 13078 |
Snapshots | statsSnapshots |
DataFileMgr | theDataFileMgr |
class ReplSet * | theReplSet |
JSClass | timestamp_class |
int | tlogLevel |
SockAddr | unknownAddress |
const int | VERSION = 4 |
const int | VERSION_MINOR = 5 |
const char | versionString [] |
WriteBackManager | writeBackManager |
tools for working in parallel/sharded/clustered environment
Copyright (C) 2010 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.
Copyright (C) 2008 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.
Copyright (C) 2009 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.
jsobjManipulator.h Copyright (C) 2009 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.
Copyright (C) 2008 10gen Inc.info
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.
replica set member
Copyright (C) 2008 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>. local.slaves - current location for all slaves
Copyright (C) 2008 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>. handles snapshotting performance metrics and other such things
Copyright (C) 2008 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>. some generic sharding utils that can be used in mongod or mongos
Copyright (C) 2008 10gen Inc.
This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License, version 3, as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful,b but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.
typedef char mongo::_TCHAR |
typedef multimap<BSONObj,BSONObj,BSONObjCmp> mongo::BestMap |
Definition at line 72 of file scanandorder.h.
typedef vector< pair< BSONObj, BSONObj > > mongo::BoundList |
Definition at line 195 of file queryutil.h.
typedef set< BSONElement, BSONElementCmpWithoutField > mongo::BSONElementSet |
typedef map<string, BSONElement> mongo::BSONMap |
Definition at line 240 of file bson-inl.h.
typedef set< BSONObj, BSONObjCmpDefaultOrder > mongo::BSONObjSetDefaultOrder |
Definition at line 45 of file bsonmisc.h.
typedef set<BSONElement, BSONElementFieldNameCmp> mongo::BSONSortedElements |
Definition at line 257 of file bson-inl.h.
typedef map<CursorId, ClientCursor*> mongo::CCById |
Definition at line 66 of file clientcursor.h.
typedef map< ByLocKey, ClientCursor * > mongo::CCByLoc |
Definition at line 67 of file clientcursor.h.
typedef char mongo::CHARS[400] |
Definition at line 34 of file debug_util.h.
typedef struct mongo::_Chars * mongo::Chars |
typedef shared_ptr<ChunkManager> mongo::ChunkManagerPtr |
typedef map<BSONObj,ChunkPtr,BSONObjCmp> mongo::ChunkMap |
typedef shared_ptr<Chunk> mongo::ChunkPtr |
typedef map<BSONObj,shared_ptr<ChunkRange>,BSONObjCmp> mongo::ChunkRangeMap |
typedef long long mongo::ConnectionId |
Definition at line 45 of file db/client.h.
typedef long long mongo::CursorId |
Definition at line 39 of file clientcursor.h.
typedef boost::shared_ptr<DBConfig> mongo::DBConfigPtr |
typedef uint64_t mongo::fileofs |
typedef unsigned long long mongo::gridfs_offset |
typedef int mongo::HANDLE |
typedef struct mongo::_Ints * mongo::Ints |
typedef unsigned char mongo::md5digest[16] |
typedef MemoryMappedFile mongo::MMF |
typedef AtomicUInt mongo::MSGID |
typedef const char* mongo::MyStr |
typedef BSONObj(* mongo::NativeFunction)(const BSONObj &args) |
typedef unsigned long long mongo::nonce |
typedef map<string,ConfigVersion> mongo::NSVersionMap |
typedef struct mongo::_OWS * mongo::OWS |
typedef boost::recursive_mutex::scoped_lock mongo::recursive_scoped_lock |
typedef shared_ptr<ReplicaSetMonitor> mongo::ReplicaSetMonitorPtr |
Definition at line 25 of file dbclient_rs.h.
typedef unsigned long long mongo::ReplTime |
typedef mutex::scoped_lock mongo::scoped_lock |
typedef unsigned long long mongo::ScriptingFunction |
typedef shared_ptr<ShardChunkManager> mongo::ShardChunkManagerPtr |
Definition at line 148 of file d_chunk_manager.h.
typedef boost::shared_ptr<ShardedClientCursor> mongo::ShardedClientCursorPtr |
typedef int mongo::SOCKET |
typedef hash_map<const char*, int, hash<const char *>, eq_str > mongo::strhashmap |
anonymous enum |
Definition at line 179 of file assert_util.h.
anonymous enum |
Definition at line 45 of file debug_util.h.
enum mongo::BinDataType |
Definition at line 97 of file bsontypes.h.
enum mongo::BSONType |
the complete list of valid BSON types see also bsonspec.org
MinKey |
smaller than all other types |
EOO |
end of object |
NumberDouble |
double precision floating point value |
String |
character string, stored in utf8 |
Object |
an embedded object |
Array |
an embedded array |
BinData |
binary data |
Undefined |
Undefined type |
jstOID |
ObjectId |
Bool |
boolean type |
Date |
date type |
jstNULL |
null type |
RegEx |
regular expression, a pattern with options |
DBRef |
deprecated / will be redesigned |
Code |
deprecated / use CodeWScope |
Symbol |
a programming language (e.g., Python) symbol |
CodeWScope |
javascript code that can execute on the database server, with SavedContext |
NumberInt |
32 bit signed integer |
Timestamp |
Updated to a Date with value next OpTime on insert |
NumberLong |
64 bit integer |
JSTypeMax |
max type that is not MaxKey |
MaxKey |
larger than all other types |
Definition at line 46 of file bsontypes.h.
Definition at line 25 of file assert_util.h.
enum mongo::ExitCode |
Definition at line 47 of file bsonmisc.h.
Definition at line 34 of file indexkey.h.
Formatting mode for generating JSON from BSON. See <http://mongodb.onconfluence.com/display/DOCS/Mongo+Extended+JSON> for details.
enum mongo::LogLevel |
enum mongo::Operations |
enum mongo::QueryOptions |
the query field 'options' can have these bits set:
QueryOption_CursorTailable |
Tailable means cursor is not closed when the last data is retrieved. rather, the cursor marks the final object's position. you can resume using the cursor later, from where it was located, if more data were received. Set on dbQuery and dbGetMore. like any "latent cursor", the cursor may become invalid at some point -- for example if that final object it references were deleted. Thus, you should be prepared to requery if you get back ResultFlag_CursorNotFound. |
QueryOption_SlaveOk |
allow query of replica slave. normally these return an error except for namespace "local". |
QueryOption_OplogReplay | |
QueryOption_NoCursorTimeout |
The server normally times out idle cursors after an inactivy period to prevent excess memory uses Set this option to prevent that. |
QueryOption_AwaitData |
Use with QueryOption_CursorTailable. If we are at the end of the data, block for a while rather than returning no data. After a timeout period, we do return as normal. |
QueryOption_Exhaust |
Stream the data down full blast in multiple "more" packages, on the assumption that the client will fully read all data queried. Faster when you are pulling a lot of data and know you want to pull it all down. Note: it is not allowed to not read all the data unless you close the connection. Use the query( boost::function<void(const BSONObj&)> f, ... ) version of the connection's query() method, and it will take care of all the details for you. |
QueryOption_PartialResults |
When sharded, this means its ok to return partial results Usually we will fail a query if all required shards aren't up If this is set, it'll be a partial result set |
QueryOption_AllSupported |
Definition at line 29 of file dbclient.h.
enum mongo::RemoveOptions |
RemoveOption_JustOne |
only delete one option |
RemoveOption_Broadcast |
flag from mongo saying this update went everywhere |
Definition at line 95 of file dbclient.h.
ResultFlag_CursorNotFound | |
ResultFlag_ErrSet | |
ResultFlag_ShardConfigStale | |
ResultFlag_AwaitCapable |
Definition at line 8 of file constants.h.
enum mongo::SlaveTypes |
enum mongo::UpdateOptions |
Definition at line 83 of file dbclient.h.
enum mongo::WriteConcern |
controls how much a clients cares about writes default is NORMAL
Definition at line 204 of file dbclient.h.
bool mongo::_handlePossibleShardedMessage | ( | Message & | m, | |
DbResponse * | dbresponse | |||
) |
bool mongo::_isMaster | ( | ) | [inline] |
Definition at line 113 of file replpair.h.
Nullstream& mongo::_log | ( | int | level = 0 |
) | [inline] |
void mongo::_logOpObjRS | ( | const BSONObj & | op | ) |
bool mongo::_runCommands | ( | const char * | ns, | |
BSONObj & | jsobj, | |||
BufBuilder & | b, | |||
BSONObjBuilder & | anObjBuilder, | |||
bool | fromRepl, | |||
int | queryOptions | |||
) |
UpdateResult mongo::_updateObjects | ( | bool | god, | |
const char * | ns, | |||
const BSONObj & | updateobj, | |||
BSONObj | pattern, | |||
bool | upsert, | |||
bool | multi, | |||
bool | logop, | |||
OpDebug & | debug, | |||
RemoveSaver * | rs = 0 | |||
) |
void mongo::aboutToDeleteForSharding | ( | const Database * | db, | |
const DiskLoc & | dl | |||
) |
void mongo::acquirePathLock | ( | ) |
bool mongo::anyReplEnabled | ( | ) |
void mongo::appendReplicationInfo | ( | BSONObjBuilder & | result, | |
bool | authed, | |||
int | level = 0 | |||
) |
bool mongo::appendSpecialDBObject | ( | Convertor * | c, | |
BSONObjBuilder & | b, | |||
const string & | name, | |||
jsval | val, | |||
JSObject * | o | |||
) |
void mongo::applyOperation_inlock | ( | const BSONObj & | op, | |
bool | fromRepl = true | |||
) |
take an op and apply locally used for applying from an oplog
fromRepl | really from replication or for testing/internal/command/etc... |
long long mongo::applySkipLimit | ( | long long | num, | |
const BSONObj & | cmd | |||
) |
std::string mongo::askPassword | ( | ) |
void mongo::assembleResponse | ( | Message & | m, | |
DbResponse & | dbresponse, | |||
const SockAddr & | client = unknownAddress | |||
) |
void mongo::asserted | ( | const char * | msg, | |
const char * | file, | |||
unsigned | line | |||
) |
void mongo::assertInWriteLock | ( | ) | [inline] |
Definition at line 196 of file concurrency.h.
void mongo::assertStreamGood | ( | unsigned | msgid, | |
string | msg, | |||
std::ios & | myios | |||
) | [inline] |
Definition at line 184 of file assert_util.h.
shared_ptr< Cursor > mongo::bestGuessCursor | ( | const char * | ns, | |
const BSONObj & | query, | |||
const BSONObj & | sort | |||
) | [inline] |
Definition at line 444 of file queryoptimizer.h.
v8::Handle<v8::Value> mongo::binDataInit | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::binDataToString | ( | const v8::Arguments & | args | ) |
mongo::BOOST_STATIC_ASSERT | ( | 16 | = =sizeof(DeletedRecord) |
) |
void mongo::breakif | ( | bool | test | ) | [inline] |
Definition at line 101 of file debug_util.h.
void mongo::breakpoint | ( | ) | [inline] |
Definition at line 78 of file debug_util.h.
BSONMap mongo::bson2map | ( | const BSONObj & | obj | ) | [inline] |
Definition at line 241 of file bson-inl.h.
BSONSortedElements mongo::bson2set | ( | const BSONObj & | obj | ) | [inline] |
Definition at line 258 of file bson-inl.h.
v8::Handle<v8::Value> mongo::bsonsize | ( | const v8::Arguments & | args | ) |
Client& mongo::cc | ( | ) | [inline] |
get the Client object for this thread.
Definition at line 209 of file db/client.h.
void mongo::checkDataFileVersion | ( | NamespaceDetails & | d | ) | [inline] |
void mongo::checkIndexFileVersion | ( | NamespaceDetails & | d | ) | [inline] |
bool mongo::cloneFrom | ( | const char * | masterHost, | |
string & | errmsg, | |||
const string & | fromdb, | |||
bool | logForReplication, | |||
bool | slaveOk, | |||
bool | useReplAuth, | |||
bool | snapshot | |||
) |
v8::Handle<v8::Value> mongo::collectionFallback | ( | v8::Local< v8::String > | name, | |
const v8::AccessorInfo & | info | |||
) |
v8::Handle<v8::Value> mongo::collectionInit | ( | const v8::Arguments & | args | ) |
FieldCompareResult mongo::compareDottedFieldNames | ( | const string & | l, | |
const string & | r | |||
) |
int mongo::compareElementValues | ( | const BSONElement & | l, | |
const BSONElement & | r | |||
) |
DBClientBase* mongo::createDirectClient | ( | ) |
void mongo::createOplog | ( | ) |
MessageServer* mongo::createServer | ( | const MessageServer::Options & | opts, | |
MessageHandler * | handler | |||
) |
WrapperHolder* mongo::createWrapperHolder | ( | const BSONObj * | o, | |
bool | readOnly, | |||
bool | iDelete | |||
) |
void mongo::curopGotLock | ( | Client * | ) |
Client* mongo::curopWaitingForLock | ( | int | type | ) |
boost::gregorian::date mongo::currentDate | ( | ) | [inline] |
Definition at line 55 of file time_support.h.
unsigned mongo::curTimeMicros | ( | ) | [inline] |
Definition at line 193 of file time_support.h.
unsigned long long mongo::curTimeMicros64 | ( | ) | [inline] |
Definition at line 185 of file time_support.h.
unsigned mongo::curTimeMillis | ( | ) | [inline] |
curTimeMillis will overflow - use curTimeMicros64 instead if you care about that.
Definition at line 170 of file time_support.h.
void mongo::dbexit | ( | ExitCode | returnCode, | |
const char * | whyMsg = "" , |
|||
bool | tryToGetLock = false | |||
) |
v8::Handle<v8::Value> mongo::dbInit | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::dbPointerInit | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::dbQueryIndexAccess | ( | uint32_t | index, | |
const v8::AccessorInfo & | info | |||
) |
v8::Handle<v8::Value> mongo::dbQueryInit | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::dbRefInit | ( | const v8::Arguments & | args | ) |
boost::intmax_t mongo::dbSize | ( | const char * | database | ) |
v8::Handle<v8::Value> mongo::dbTimestampInit | ( | const v8::Arguments & | args | ) |
void mongo::dbunlocking_read | ( | ) | [inline] |
Definition at line 81 of file concurrency.h.
void mongo::dbunlocking_write | ( | ) | [inline] |
Definition at line 80 of file concurrency.h.
string mongo::debugString | ( | Message & | m | ) |
long long mongo::deleteObjects | ( | const char * | ns, | |
BSONObj | pattern, | |||
bool | justOne, | |||
bool | logop = false , |
|||
bool | god = false , |
|||
RemoveSaver * | rs = 0 | |||
) |
string mongo::demangleName | ( | const type_info & | typeinfo | ) |
std::string mongo::digestToString | ( | md5digest | digest | ) | [inline] |
void mongo::disableV8Interrupt | ( | ) |
bool mongo::doesOpGetAResponse | ( | int | op | ) |
void mongo::dontDeleteScope | ( | SMScope * | s | ) |
Definition at line 102 of file engine_spidermonkey.h.
BSONObj mongo::dotted2nested | ( | const BSONObj & | obj | ) | [inline] |
Definition at line 215 of file bson-inl.h.
void mongo::dotted2nested | ( | BSONObjBuilder & | b, | |
const BSONObj & | obj | |||
) |
void mongo::dropCollection | ( | const string & | name, | |
string & | errmsg, | |||
BSONObjBuilder & | result | |||
) |
void mongo::dropDatabase | ( | string | db | ) |
bool mongo::dropIndexes | ( | NamespaceDetails * | d, | |
const char * | ns, | |||
const char * | name, | |||
string & | errmsg, | |||
BSONObjBuilder & | anObjBuilder, | |||
bool | maydeleteIdIndex | |||
) |
void mongo::dropNS | ( | const string & | dropNs | ) |
void mongo::dumpmemory | ( | const char * | data, | |
int | len | |||
) | [inline] |
void mongo::dupCheck | ( | vector< IndexChanges > & | v, | |
NamespaceDetails & | d, | |||
DiskLoc | curObjLoc | |||
) |
void mongo::enableIPv6 | ( | bool | state = true |
) |
void mongo::enableV8Interrupt | ( | ) |
bool mongo::endsWith | ( | const char * | p, | |
const char * | suffix | |||
) | [inline] |
void mongo::ensureHaveIdIndex | ( | const char * | ns | ) |
void mongo::ensureParentDirCreated | ( | const boost::filesystem::path & | p | ) |
like "mkdir -p" but on parent dir of p rather than p itself
string mongo::errnoWithPrefix | ( | const char * | prefix | ) |
output the error # and error message with prefix. handy for use as parm in uassert/massert.
Nullstream& mongo::error | ( | ) | [inline] |
void mongo::errorReporter | ( | JSContext * | cx, | |
const char * | message, | |||
JSErrorReport * | report | |||
) |
void mongo::exit | ( | ExitCode | returnCode | ) |
this is here so you can't just type exit() to quit the program you should either use dbexit to shutdown cleanly, or exit to tell the system to quit if you use this, you'll get a link error since mongo::exit isn't defined
void mongo::exitCleanly | ( | ExitCode | code | ) |
unsigned long long mongo::extractVersion | ( | BSONElement | e, | |
string & | errmsg | |||
) |
void mongo::fillQueryResultFromObj | ( | BufBuilder & | bb, | |
Projection * | filter, | |||
const BSONObj & | js, | |||
DiskLoc * | loc = NULL | |||
) | [inline] |
Definition at line 53 of file scanandorder.h.
const char* mongo::findEd | ( | const char * | ) |
const char* mongo::findEd | ( | ) |
const string mongo::findJars | ( | ) |
shared_ptr<Cursor> mongo::findTableScan | ( | const char * | ns, | |
const BSONObj & | order, | |||
const DiskLoc & | startLoc = DiskLoc() | |||
) |
unsigned long mongo::fixEndian | ( | unsigned long | x | ) | [inline] |
const AdvanceStrategy* mongo::forward | ( | ) |
boost::intmax_t mongo::freeSpace | ( | const string & | path = dbpath |
) |
BSONObj mongo::fromjson | ( | const char * | str, | |
int * | len = NULL | |||
) |
len will be size of JSON object in text chars.
BSONObj mongo::fromjson | ( | const string & | str | ) |
Create a BSONObj from a JSON <http://www.json.org> string. In addition to the JSON extensions extensions described here <http://mongodb.onconfluence.com/display/DOCS/Mongo+Extended+JSON>, this function accepts certain unquoted field names and allows single quotes to optionally be used when specifying field names and string values instead of double quotes. JSON unicode escape sequences (of the form ) are converted to utf8.
MsgAssertionException | if parsing fails. The message included with this assertion includes a rough indication of where parsing failed. |
v8::Handle<v8::Value> mongo::GCV8 | ( | const v8::Arguments & | args | ) |
string mongo::getAddrInfoStrError | ( | int | code | ) |
mongo::DBClientBase* mongo::getConnection | ( | const v8::Arguments & | args | ) |
void mongo::getDatabaseNames | ( | vector< string > & | names, | |
const string & | usePath = dbpath | |||
) |
dur::DurableInterface& mongo::getDur | ( | ) | [inline] |
int mongo::getGtLtOp | ( | const BSONElement & | e | ) |
string mongo::getHostNameCached | ( | ) |
void mongo::getIndexChanges | ( | vector< IndexChanges > & | v, | |
NamespaceDetails & | d, | |||
BSONObj | newObj, | |||
BSONObj | oldObj, | |||
bool & | cangedId | |||
) |
v8::Handle<v8::FunctionTemplate> mongo::getMongoFunctionTemplate | ( | bool | local | ) |
v8::Function* mongo::getNamedCons | ( | const char * | name | ) |
v8::Function* mongo::getObjectIdCons | ( | ) |
v8::Handle<v8::FunctionTemplate> mongo::getObjectWrapperTemplate | ( | ) |
unsigned mongo::getSlaveCount | ( | ) |
string mongo::getThreadName | ( | ) |
const char* mongo::gitVersion | ( | ) |
bool mongo::handlePossibleShardedMessage | ( | Message & | m, | |
DbResponse * | dbresponse | |||
) | [inline] |
bool mongo::hasJSReturn | ( | const string & | s | ) |
bool mongo::haveClient | ( | ) | [inline] |
bool mongo::haveLocalShardingInfo | ( | const string & | ns | ) |
string mongo::hexdump | ( | const char * | data, | |
unsigned | len | |||
) |
string mongo::hostbyname | ( | const char * | hostname | ) |
IndexDetails* mongo::indexDetailsForRange | ( | const char * | ns, | |
string & | errmsg, | |||
BSONObj & | min, | |||
BSONObj & | max, | |||
BSONObj & | keyPattern | |||
) |
void mongo::initLogging | ( | const string & | logpath, | |
bool | append | |||
) |
log to a file rather than stdout defined in assert_util.cpp
void mongo::initMongoJS | ( | SMScope * | scope, | |
JSContext * | cx, | |||
JSObject * | global, | |||
bool | local | |||
) |
bool mongo::inShutdown | ( | ) |
void mongo::installChunkShardVersioning | ( | ) |
void mongo::installDBTypes | ( | v8::Handle< v8::Object > & | global | ) |
void mongo::installDBTypes | ( | v8::Handle< v8::ObjectTemplate > & | global | ) |
void mongo::installFork | ( | v8::Handle< v8::Object > & | global, | |
v8::Handle< v8::Context > & | context | |||
) |
void mongo::installGlobalUtils | ( | Scope & | scope | ) |
v8::Handle<v8::Value> mongo::internalCursorCons | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::internalCursorHasNext | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::internalCursorNext | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::internalCursorObjsLeftInBatch | ( | const v8::Arguments & | args | ) |
bool mongo::IPv6Enabled | ( | ) |
bool mongo::isANormalNSName | ( | const char * | ns | ) | [inline] |
bool mongo::isDate | ( | JSContext * | cx, | |
JSObject * | o | |||
) |
bool mongo::isMaster | ( | const char * | client = 0 |
) | [inline] |
Definition at line 143 of file replpair.h.
bool mongo::isMasterNs | ( | const char * | ns | ) | [inline] |
Definition at line 174 of file replpair.h.
bool mongo::isPrime | ( | int | n | ) |
bool mongo::isSimpleIdQuery | ( | const BSONObj & | query | ) | [inline] |
Definition at line 434 of file queryoptimizer.h.
bool mongo::isValidNS | ( | const StringData & | ns | ) |
bool mongo::isValidUTF8 | ( | const char * | s | ) |
void mongo::jasserted | ( | const char * | msg, | |
const char * | file, | |||
unsigned | line | |||
) |
JNIEXPORT jint JNICALL mongo::java_native_call | ( | JNIEnv * | , | |
jclass | , | |||
jobject | outBuffer, | |||
jobject | inBuffer | |||
) |
JNIEXPORT void JNICALL mongo::java_native_say | ( | JNIEnv * | , | |
jclass | , | |||
jobject | outBuffer | |||
) |
void mongo::joinStringDelim | ( | const vector< string > & | strs, | |
string * | res, | |||
char | delim | |||
) |
const char* mongo::jsSkipWhiteSpace | ( | const char * | raw | ) |
Date_t mongo::jsTime | ( | ) | [inline] |
Date_t is milliseconds since epoch
Definition at line 178 of file time_support.h.
bool mongo::legalClientSystemNS | ( | const string & | ns, | |
bool | write | |||
) |
write | used when .system.js |
int mongo::lexNumCmp | ( | const char * | s1, | |
const char * | s2 | |||
) | [inline] |
Nullstream& mongo::log | ( | ) | [inline] |
Nullstream& mongo::log | ( | LogLevel | l | ) | [inline] |
Nullstream& mongo::log | ( | int | level | ) | [inline] |
void mongo::logKeepalive | ( | ) |
void mongo::logOp | ( | const char * | opstr, | |
const char * | ns, | |||
const BSONObj & | obj, | |||
BSONObj * | patt = 0 , |
|||
bool * | b = 0 | |||
) |
Write operation to the log (local.oplog.$main)
opstr | "i" insert "u" update "d" delete "c" db cmd "n" no-op "db" declares presence of a database (ns is set to the db name + '.') |
See _logOp() in oplog.cpp for more details.
void mongo::logOpComment | ( | const BSONObj & | obj | ) |
puts obj in the oplog as a comment (a no-op). Just for diags. convention is { msg : "text", ... }
void mongo::logOpForSharding | ( | const char * | opstr, | |
const char * | ns, | |||
const BSONObj & | obj, | |||
BSONObj * | patt | |||
) |
void mongo::massert | ( | unsigned | msgid, | |
std::string | msg, | |||
bool | expr | |||
) | [inline] |
const DiskLoc mongo::maxDiskLoc | ( | 0x7fffffff | , | |
0x7fffffff | ||||
) |
void mongo::maybeCreatePidFile | ( | ) |
void mongo::md5 | ( | const char * | str, | |
md5digest | digest | |||
) | [inline] |
void mongo::md5 | ( | const void * | buf, | |
int | nbytes, | |||
md5digest | digest | |||
) | [inline] |
std::string mongo::md5simpledigest | ( | const void * | buf, | |
int | nbytes | |||
) | [inline] |
const DiskLoc mongo::minDiskLoc | ( | 0 | , | |
1 | ||||
) |
v8::Handle<v8::Value> mongo::mongoConsExternal | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::mongoConsLocal | ( | const v8::Arguments & | args | ) |
string mongo::mongodVersion | ( | ) |
v8::Handle<v8::Value> mongo::mongoFind | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::mongoInsert | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::mongoRemove | ( | const v8::Arguments & | args | ) |
v8::Local<v8::Object> mongo::mongoToV8 | ( | const mongo::BSONObj & | m, | |
bool | array = 0 , |
|||
bool | readOnly = false | |||
) |
v8::Handle<v8::Value> mongo::mongoToV8Element | ( | const BSONElement & | f | ) |
v8::Handle<v8::Value> mongo::mongoUpdate | ( | const v8::Arguments & | args | ) |
void mongo::msgasserted | ( | int | msgid, | |
string | msg | |||
) | [inline] |
Definition at line 139 of file assert_util.h.
void mongo::msgasserted | ( | int | msgid, | |
const std::string & | msg | |||
) | [inline] |
void mongo::msgasserted | ( | int | msgid, | |
const char * | msg | |||
) | [inline] |
void mongo::msgassertedNoTrace | ( | int | msgid, | |
const string & | msg | |||
) | [inline] |
Definition at line 137 of file assert_util.h.
void mongo::msgassertedNoTrace | ( | int | msgid, | |
const char * | msg | |||
) |
msgassert and massert are for errors that are internal but have a well defined error text string. a stack trace is logged.
void mongo::multiCommand | ( | BSONObj | cmd, | |
list< Target > & | L | |||
) | [inline] |
Definition at line 54 of file multicmd.h.
BSONObj mongo::nested2dotted | ( | const BSONObj & | obj | ) | [inline] |
Definition at line 207 of file bson-inl.h.
void mongo::nested2dotted | ( | BSONObjBuilder & | b, | |
const BSONObj & | obj, | |||
const string & | base = "" | |||
) |
v8::Local< v8::FunctionTemplate > mongo::newV8Function | ( | ) | [inline] |
MSGID mongo::nextMessageId | ( | ) |
int mongo::nextPrime | ( | int | n | ) |
void mongo::notMasterUnless | ( | bool | expr | ) | [inline] |
Definition at line 154 of file replpair.h.
NamespaceDetails* mongo::nsdetails | ( | const char * | ns | ) | [inline] |
NamespaceIndex* mongo::nsindex | ( | const char * | ns | ) | [inline] |
string mongo::nsToDatabase | ( | const string & | ns | ) | [inline] |
Definition at line 602 of file namespace.h.
string mongo::nsToDatabase | ( | const char * | ns | ) | [inline] |
Definition at line 597 of file namespace.h.
void mongo::nsToDatabase | ( | const char * | ns, | |
char * | database | |||
) | [inline] |
Definition at line 583 of file namespace.h.
v8::Handle<v8::Value> mongo::numberLongInit | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::numberLongToNumber | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::numberLongToString | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::numberLongValueOf | ( | const v8::Arguments & | args | ) |
v8::Handle<v8::Value> mongo::objectIdInit | ( | const v8::Arguments & | args | ) |
ostream& mongo::operator<< | ( | ostream & | s, | |
const ThreadSafeString & | o | |||
) |
std::ostream& mongo::operator<< | ( | std::ostream & | s, | |
const v8::Handle< v8::TryCatch > * | try_catch | |||
) |
std::ostream& mongo::operator<< | ( | std::ostream & | s, | |
const v8::Handle< v8::Value > & | o | |||
) |
ostream& mongo::operator<< | ( | ostream & | s, | |
const ShardChunkVersion & | v | |||
) | [inline] |
StringBuilder& mongo::operator<< | ( | StringBuilder & | s, | |
const OID & | o | |||
) | [inline] |
ostream & mongo::operator<< | ( | ostream & | s, | |
const OID & | o | |||
) | [inline] |
StringBuilder & mongo::operator<< | ( | StringBuilder & | s, | |
const BSONElement & | e | |||
) | [inline] |
StringBuilder & mongo::operator<< | ( | StringBuilder & | s, | |
const BSONObj & | o | |||
) | [inline] |
ostream & mongo::operator<< | ( | ostream & | s, | |
const BSONElement & | e | |||
) | [inline] |
ostream & mongo::operator<< | ( | ostream & | s, | |
const BSONObj & | o | |||
) | [inline] |
void mongo::oplogCheckCloseDatabase | ( | Database * | db | ) |
bool mongo::opReplicatedEnough | ( | OpTime | op, | |
int | w | |||
) |
BSONObj mongo::OR | ( | const BSONObj & | a, | |
const BSONObj & | b, | |||
const BSONObj & | c, | |||
const BSONObj & | d, | |||
const BSONObj & | e, | |||
const BSONObj & | f | |||
) | [inline] |
Definition at line 771 of file bsonobjbuilder.h.
BSONObj mongo::OR | ( | const BSONObj & | a, | |
const BSONObj & | b, | |||
const BSONObj & | c, | |||
const BSONObj & | d, | |||
const BSONObj & | e | |||
) | [inline] |
Definition at line 769 of file bsonobjbuilder.h.
BSONObj mongo::OR | ( | const BSONObj & | a, | |
const BSONObj & | b, | |||
const BSONObj & | c, | |||
const BSONObj & | d | |||
) | [inline] |
Definition at line 767 of file bsonobjbuilder.h.
BSONObj mongo::OR | ( | const BSONObj & | a, | |
const BSONObj & | b, | |||
const BSONObj & | c | |||
) | [inline] |
Definition at line 765 of file bsonobjbuilder.h.
BSONObj mongo::OR | ( | const BSONObj & | a, | |
const BSONObj & | b | |||
) | [inline] |
Definition at line 763 of file bsonobjbuilder.h.
void* mongo::ourmalloc | ( | size_t | size | ) | [inline] |
Definition at line 22 of file allocator.h.
void* mongo::ourrealloc | ( | void * | ptr, | |
size_t | size | |||
) | [inline] |
Definition at line 28 of file allocator.h.
Nullstream& mongo::out | ( | int | level = 0 |
) | [inline] |
void mongo::parseReplsetCmdLine | ( | string | cfgString, | |
string & | setname, | |||
vector< HostAndPort > & | seeds, | |||
set< HostAndPort > & | seedSet | |||
) |
void mongo::pretouchN | ( | vector< BSONObj > & | , | |
unsigned | a, | |||
unsigned | b | |||
) |
void mongo::pretouchOperation | ( | const BSONObj & | op | ) |
string mongo::prettyHostName | ( | ) |
v8::Handle<v8::Value> mongo::Print | ( | const v8::Arguments & | args | ) |
void mongo::printGitVersion | ( | ) |
void mongo::printMemInfo | ( | const char * | where | ) |
void mongo::printStackAndExit | ( | int | signalNum | ) |
Obtains the log file handler and writes the current thread's stack trace to it. This call issues an exit(). The function can safely be called from within a signal handler.
signal | that this hadler is called for |
void mongo::printStackTrace | ( | ostream & | o = cout |
) | [inline] |
void mongo::printSysInfo | ( | ) |
Nullstream& mongo::problem | ( | int | level = 0 |
) | [inline] |
QueryResult* mongo::processGetMore | ( | const char * | ns, | |
int | ntoreturn, | |||
long long | cursorid, | |||
CurOp & | op, | |||
int | pass, | |||
bool & | exhaust | |||
) |
void mongo::processRequest | ( | Message & | m, | |
MessagingPort & | p | |||
) |
void mongo::profile | ( | const char * | str, | |
int | millis | |||
) |
void mongo::raiseError | ( | int | code, | |
const char * | msg | |||
) |
void mongo::rawOut | ( | const string & | s | ) |
void mongo::renameNamespace | ( | const char * | from, | |
const char * | to | |||
) |
bool mongo::repairDatabase | ( | string | db, | |
string & | errmsg, | |||
bool | preserveClonedFilesOnFailure = false , |
|||
bool | backupOriginalFiles = false | |||
) |
bool mongo::replHasDatabases | ( | ) |
void mongo::replVerifyReadsOk | ( | ParsedQuery & | pq | ) | [inline] |
Definition at line 162 of file replpair.h.
void mongo::replyToQuery | ( | int | queryResultFlags, | |
Message & | m, | |||
DbResponse & | dbresponse, | |||
BSONObj | obj | |||
) | [inline] |
Definition at line 251 of file dbmessage.h.
void mongo::replyToQuery | ( | int | queryResultFlags, | |
AbstractMessagingPort * | p, | |||
Message & | requestMsg, | |||
BSONObj & | responseObj | |||
) | [inline] |
Definition at line 242 of file dbmessage.h.
void mongo::replyToQuery | ( | int | queryResultFlags, | |
AbstractMessagingPort * | p, | |||
Message & | requestMsg, | |||
void * | data, | |||
int | size, | |||
int | nReturned, | |||
int | startingFrom = 0 , |
|||
long long | cursorId = 0 | |||
) | [inline] |
Definition at line 213 of file dbmessage.h.
void mongo::ReportException | ( | v8::TryCatch * | handler | ) |
bool mongo::requestHeartbeat | ( | string | setname, | |
string | fromHost, | |||
string | memberFullName, | |||
BSONObj & | result, | |||
int | myConfigVersion, | |||
int & | theirConfigVersion, | |||
bool | checkEmpty = false | |||
) |
void mongo::resetSlaveCache | ( | ) |
JSBool mongo::resolveBSONField | ( | JSContext * | cx, | |
JSObject * | obj, | |||
jsval | id, | |||
uintN | flags, | |||
JSObject ** | objp | |||
) |
const AdvanceStrategy* mongo::reverse | ( | ) |
void mongo::rotateLogs | ( | int | signal = 0 |
) |
long long mongo::runCount | ( | const char * | ns, | |
const BSONObj & | cmd, | |||
string & | err | |||
) |
const char* mongo::runQuery | ( | Message & | m, | |
QueryMessage & | q, | |||
CurOp & | curop, | |||
Message & | result | |||
) |
bool mongo::sameHostname | ( | const string & | a, | |
const string & | b | |||
) | [inline] |
returns true if strings seem to be the same hostname. "nyc1", "nyc1.acme", and "nyc1.acme.com" are treated as the same.
Definition at line 92 of file hostandport.h.
string mongo::sayClientState | ( | ) |
void mongo::sayDbContext | ( | const char * | msg = 0 |
) |
bool mongo::serverAlive | ( | const string & | uri | ) |
pings server to check if it's up
bool mongo::setShardVersion | ( | DBClientBase & | conn, | |
const string & | ns, | |||
ShardChunkVersion | version, | |||
bool | authoritative, | |||
BSONObj & | result | |||
) |
void mongo::setSockTimeouts | ( | int | sock, | |
double | secs | |||
) | [inline] |
unsigned mongo::setThreadName | ( | const char * | name | ) |
void mongo::setupCoreSignals | ( | ) |
bool mongo::setUpSecurityKey | ( | const string & | filename | ) |
This method checks the validity of filename as a security key, hashes its contents, and stores it in the internalSecurity variable. Prints an error message to the logs if there's an error.
filename | the file containing the key |
void mongo::setupSIGTRAPforGDB | ( | ) |
bool mongo::shardVersionOk | ( | const string & | ns, | |
bool | write, | |||
string & | errmsg | |||
) |
void mongo::show_warnings | ( | ) |
string mongo::simpleRegex | ( | const char * | regex, | |
const char * | flags, | |||
bool * | purePrefix = NULL | |||
) |
returns a string that when used as a matcher, would match a super set of regex() returns "" for complex regular expressions used to optimize queries in some simple regex cases that start with '^'
if purePrefix != NULL, sets it to whether the regex can be converted to a range query
string mongo::simpleRegexEnd | ( | string | prefix | ) |
returns the upper bound of a query that matches prefix
void mongo::sleepmicros | ( | long long | s | ) | [inline] |
Definition at line 148 of file time_support.h.
void mongo::sleepmillis | ( | long long | s | ) | [inline] |
Definition at line 159 of file time_support.h.
void mongo::sleepsecs | ( | int | s | ) | [inline] |
Definition at line 140 of file time_support.h.
void mongo::splitStringDelim | ( | const string & | str, | |
vector< string > * | res, | |||
char | delim | |||
) |
bool mongo::startsWith | ( | const char * | str, | |
const char * | prefix | |||
) | [inline] |
void mongo::strcpy_s | ( | char * | dst, | |
unsigned | len, | |||
const char * | src | |||
) | [inline] |
void mongo::streamNotGood | ( | int | code, | |
string | msg, | |||
std::ios & | myios | |||
) |
unsigned long mongo::swapEndian | ( | unsigned long | x | ) | [inline] |
string mongo::sysInfo | ( | ) |
int mongo::tdiff | ( | unsigned | told, | |
unsigned | tnew | |||
) | [inline] |
Definition at line 165 of file time_support.h.
string mongo::terseCurrentTime | ( | bool | colonsOk = true |
) | [inline] |
Definition at line 45 of file time_support.h.
string mongo::time_t_to_String | ( | time_t | t = time(0) |
) | [inline] |
void mongo::time_t_to_String | ( | time_t | t, | |
char * | buf | |||
) | [inline] |
void mongo::time_t_to_Struct | ( | time_t | t, | |
struct tm * | buf, | |||
bool | local = false | |||
) | [inline] |
Definition at line 29 of file time_support.h.
Nullstream& mongo::tlog | ( | int | level = 0 |
) | [inline] |
string mongo::toHexLower | ( | const void * | inRaw, | |
int | len | |||
) | [inline] |
string mongo::tolowerString | ( | const string & | input | ) | [inline] |
Definition at line 29 of file stringutils.h.
bool mongo::toPointInTime | ( | const string & | str, | |
boost::posix_time::ptime * | timeOfDay | |||
) | [inline] |
Definition at line 61 of file time_support.h.
std::string mongo::toSTLString | ( | const v8::TryCatch * | try_catch | ) |
std::string mongo::toSTLString | ( | const v8::Handle< v8::Value > & | o | ) |
string mongo::ToString | ( | const T & | t | ) | [inline] |
std::string mongo::toUtf8String | ( | const std::wstring & | wide | ) |
BSONObj mongo::transformOrderFromArrayFormat | ( | BSONObj | order | ) | [inline] |
void mongo::uassert | ( | unsigned | msgid, | |
std::string | msg, | |||
bool | expr | |||
) | [inline] |
void mongo::uassert_nothrow | ( | const char * | msg | ) |
reported via lasterror, but don't throw exception
void mongo::uasserted | ( | int | msgid, | |
string | msg | |||
) | [inline] |
Definition at line 128 of file assert_util.h.
void mongo::uasserted | ( | int | msgid, | |
const char * | msg | |||
) |
a "user assertion". throws UserAssertion. logs. typically used for errors that a user could cause, such as dupliate key, disk full, etc.
void mongo::uasserted | ( | unsigned | msgid, | |
std::string | s | |||
) | [inline] |
UpdateResult mongo::updateObjects | ( | const char * | ns, | |
const BSONObj & | updateobj, | |||
BSONObj | pattern, | |||
bool | upsert, | |||
bool | multi, | |||
bool | logop, | |||
OpDebug & | debug | |||
) |
void mongo::updateSlaveLocation | ( | CurOp & | curop, | |
const char * | oplog_ns, | |||
OpTime | lastOp | |||
) |
bool mongo::userCreateNS | ( | const char * | ns, | |
BSONObj | j, | |||
string & | err, | |||
bool | logForReplication, | |||
bool * | deferIdIndex = 0 | |||
) |
v8::Handle< v8::Value > mongo::v8Callback | ( | const v8::Arguments & | args | ) | [inline] |
mongo::BSONObj mongo::v8ToMongo | ( | v8::Handle< v8::Object > | o, | |
int | depth = 0 | |||
) |
void mongo::v8ToMongoElement | ( | BSONObjBuilder & | b, | |
v8::Handle< v8::String > | name, | |||
const string | sname, | |||
v8::Handle< v8::Value > | value, | |||
int | depth = 0 | |||
) |
v8::Handle<v8::Value> mongo::Version | ( | const v8::Arguments & | args | ) |
int mongo::versionCmp | ( | StringData | rhs, | |
StringData | lhs | |||
) |
void mongo::waitForWriteback | ( | const OID & | oid | ) |
Nullstream& mongo::warning | ( | ) | [inline] |
void mongo::wasserted | ( | const char * | msg, | |
const char * | file, | |||
unsigned | line | |||
) |
void mongo::webServerThread | ( | const AdminAccess * | admins | ) |
void mongo::writePidFile | ( | const std::string & | path | ) |
map< unsigned, int > mongo::__interruptSpecToThreadId |
JSClass mongo::bindata_class |
JSClass mongo::bson_class |
JSClass mongo::bson_ro_class |
const int mongo::BSONObjMaxInternalSize = BSONObjMaxUserSize + ( 16 * 1024 ) |
const int mongo::BSONObjMaxUserSize = 16 * 1024 * 1024 |
const int mongo::Buckets = 19 |
Definition at line 105 of file namespace.h.
const int mongo::BucketSize = 8192 |
int mongo::bucketSizes[] |
const int mongo::BufferMaxSize = 64 * 1024 * 1024 |
boost::function4<bool, DBClientBase&, const string&, bool, int> mongo::checkShardVersionCB |
boost::thread_specific_ptr<Client> mongo::currentClient |
boost::thread_specific_ptr<SMScope> mongo::currentScope |
string mongo::dbExecCommand |
string mongo::dbpath |
JSClass mongo::dbpointer_class |
JSClass mongo::dbref_class |
const bool mongo::debug = false |
const char*(* mongo::getcurns)() |
Definition at line 121 of file engine_v8.h.
const int mongo::INVALID_SOCKET = -1 |
char mongo::last = 0 |
int mongo::lockFile |
int mongo::logLevel |
const int mongo::MaxBucket = 18 |
Definition at line 106 of file namespace.h.
const int mongo::MaxBytesToReturnToClientAtOnce |
const int mongo::MaxDatabaseNameLen = 256 |
Definition at line 32 of file namespace.h.
JSClass mongo::maxkey_class |
const int mongo::MaxMTU = 16384 |
JSClass mongo::minkey_class |
const int mongo::MsgDataHeaderSize = sizeof(MsgData) - 4 |
bool mongo::noauth |
bool mongo::noUnixSocket |
JSClass mongo::numberlong_class |
bool mongo::objcheck |
JSClass mongo::object_id_class |
const char* mongo::replAllDead |
bool mongo::replSet |
boost::function1<void, DBClientBase*> mongo::resetShardVersionCB |
const BSONObj mongo::reverseNaturalObj = BSON( "$natural" << -1 ) |
Definition at line 31 of file dbhelpers.h.
const string mongo::rsConfigNs = "local.system.replset" |
Definition at line 29 of file rs_config.h.
const char mongo::rsoplog[] = "local.oplog.rs" |
Definition at line 25 of file rs_optime.h.
const int mongo::SOCK_FAMILY_UNKNOWN_ERROR = 13078 |
class ReplSet * mongo::theReplSet |
JSClass mongo::timestamp_class |
int mongo::tlogLevel |
const int mongo::VERSION = 4 |
const int mongo::VERSION_MINOR = 5 |
const char mongo::versionString[] |