xuemingqiang/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

runMongoProgram

Browse Source
This commit is contained in:
Eliot Horowitz
2009-08-24 11:54:06 -04:00
parent 1681f080f0
commit a2e000830f
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
shell/utils.cpp
View File

@@ -82,11 +82,13 @@ namespace mongo {
BSONObjBuilder b;
b << "name" << p.string();
b.appendBool( "isDirectory", is_directory( p ) );
if ( ! is_directory( p ) )
b.append( "size" , (double)file_size( p ) );
stringstream ss;
ss << num;
string name = ss.str();
lst.append( name.c_str(), b.done() );
num++;
i++;
}
@@ -260,10 +262,11 @@ namespace mongo {
assert( pid_ != -1 );
if ( pid_ == 0 ) {
assert( dup2( pipeEnds[ 1 ], STDOUT_FILENO ) != -1 );
assert( dup2( pipeEnds[ 1 ], STDERR_FILENO ) != -1 );
execvp( argv_[ 0 ], argv_ );
assert( "Unable to start program" == 0 );
massert( "Unable to start program" , 0 );
}
cout << "shell: started mongo program";
@@ -327,6 +330,16 @@ namespace mongo {
return BSON( string( "" ) << int( r.pid() ) );
}
BSONObj RunMongoProgram( const BSONObj &a ) {
MongoProgramRunner r( a );
r.start();
boost::thread t( r );
int temp;
waitpid( r.pid() , &temp , 0 );
shells.erase( r.pid() );
return BSON( string( "" ) << int( r.pid() ) );
}
BSONObj ResetDbpath( const BSONObj &a ) {
assert( a.nFields() == 1 );
string path = a.firstElement().valuestrsafe();
@@ -451,6 +464,7 @@ namespace mongo {
#if !defined(_WIN32)
scope.injectNative( "allocatePorts", AllocatePorts );
scope.injectNative( "_startMongoProgram", StartMongoProgram );
scope.injectNative( "runMongoProgram", RunMongoProgram );
scope.injectNative( "stopMongod", StopMongoProgram );
scope.injectNative( "stopMongoProgram", StopMongoProgram );
scope.injectNative( "stopMongoProgramByPid", StopMongoProgramByPid );