mirror of
https://github.com/mongodb/mongo.git
synced 2024-11-30 17:10:48 +01:00
missing file
This commit is contained in:
parent
441557b1af
commit
99d2d6d077
65
db/curop.h
Normal file
65
db/curop.h
Normal file
@ -0,0 +1,65 @@
|
||||
// curop.h
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "namespace.h"
|
||||
#include "security.h"
|
||||
|
||||
namespace mongo {
|
||||
|
||||
extern struct CurOp {
|
||||
void reset(time_t now) {
|
||||
active = true;
|
||||
opNum++;
|
||||
startTime = now;
|
||||
ns[0] = '?'; // just in case not set later
|
||||
*query = 0;
|
||||
killCurrentOp = 0;
|
||||
}
|
||||
|
||||
bool active;
|
||||
unsigned opNum;
|
||||
time_t startTime;
|
||||
int op;
|
||||
char ns[Namespace::MaxNsLen+1];
|
||||
char query[128];
|
||||
char zero;
|
||||
|
||||
CurOp() {
|
||||
opNum = 0;
|
||||
ns[sizeof(ns)-1] = 0;
|
||||
query[sizeof(query)-1] = 0;
|
||||
}
|
||||
|
||||
BSONObj info() {
|
||||
BSONObjBuilder b;
|
||||
AuthenticationInfo *ai = authInfo.get();
|
||||
if( ai == 0 || !ai->isAuthorized("admin") ) {
|
||||
b.append("err", "unauthorized");
|
||||
return b.doneAndDecouple();
|
||||
}
|
||||
|
||||
b.append("opid", opNum);
|
||||
b.append("active", active);
|
||||
if( active )
|
||||
b.append("secs_running", (int) (time(0)-startTime));
|
||||
if( op == 2004 )
|
||||
b.append("op", "query");
|
||||
else if( op == 2005 )
|
||||
b.append("op", "getMore");
|
||||
else if( op == 2001 )
|
||||
b.append("op", "update");
|
||||
else if( op == 2002 )
|
||||
b.append("op", "insert");
|
||||
else if( op == 2006 )
|
||||
b.append("op", "delete");
|
||||
else
|
||||
b.append("op", op);
|
||||
b.append("ns", ns);
|
||||
b.append("query", query);
|
||||
b.append("inLock", dbMutexInfo.isLocked());
|
||||
return b.doneAndDecouple();
|
||||
}
|
||||
} currentOp;
|
||||
|
||||
}
|
Loading…
Reference in New Issue
Block a user