public
Fork of 10gen/mongo
Description: 10gen database
Homepage: http://www.10gen.com/wiki/db
Clone URL: git://github.com/tmm1/mongo.git
cleanup
Dwight (author)
Tue Aug 19 13:12:13 -0700 2008
commit  bfb61b7795d1fbef980a41889021078f00fd2fa2
tree    69a8c37d066332d7296aff3b3971a147b565e71e
parent  4e922d955bf8975059bf8fc39010027aa9f0882e
...
839
840
841
842
843
844
845
846
847
848
849
850
851
852
 
853
854
855
856
857
858
859
860
861
862
863
864
...
868
869
870
871
872
873
874
...
910
911
912
913
914
915
916
...
929
930
931
932
933
934
935
...
839
840
841
 
842
843
844
845
 
846
847
848
849
 
850
851
852
853
 
854
855
856
857
 
858
859
860
...
864
865
866
 
867
868
869
...
905
906
907
 
908
909
910
...
923
924
925
 
926
927
928
0
@@ -839,26 +839,22 @@ int main(int argc, char* argv[], char *envp[] )
0
     
0
      msg(m, "127.0.0.1", thePort);
0
     
0
- goingAway = true;
0
       return 0;
0
     }
0
     if( strcmp(argv[1], "msglots") == 0 ) {
0
       msg(argc >= 3 ? argv[2] : "ping", 1000);
0
- goingAway = true;
0
       return 0;
0
     }
0
     if( strcmp( argv[1], "testclient") == 0 ) {
0
       testClient();
0
- goingAway = true; return 0;
0
+ return 0;
0
     }
0
     if( strcmp(argv[1], "zzz") == 0 ) {
0
       msg(argc >= 3 ? argv[2] : "ping", 1000);
0
- goingAway = true;
0
       return 0;
0
     }
0
     if( strcmp(argv[1], "run") == 0 ) {
0
       initAndListen(port, dbpath);
0
- goingAway = true;
0
       return 0;
0
     }
0
     if( strcmp(argv[1], "longmsg") == 0 ) {
0
@@ -868,7 +864,6 @@ int main(int argc, char* argv[], char *envp[] )
0
       buf[799998] = 'b';
0
       buf[0] = 'c';
0
       msg(buf);
0
- goingAway = true;
0
       return 0;
0
     }
0
 
0
@@ -910,7 +905,6 @@ int main(int argc, char* argv[], char *envp[] )
0
         
0
         initAndListen(port, dbpath, appsrvPath);
0
         
0
- goingAway = true;
0
     exit(0);
0
   }
0
 
0
@@ -929,7 +923,6 @@ int main(int argc, char* argv[], char *envp[] )
0
   cout << " --oplog<n> 0=off 1=W 2=R 3=both 7=W+some reads" << endl;
0
   cout << endl;
0
   
0
- goingAway = true;
0
   return 0;
0
 }
0
 
...
349
350
351
352
353
354
355
356
357
358
...
349
350
351
 
 
 
 
352
353
354
0
@@ -349,10 +349,6 @@
0
         >
0
       </File>
0
       <File
0
- RelativePath="..\grid\protoimpl.h"
0
- >
0
- </File>
0
- <File
0
         RelativePath=".\query.h"
0
         >
0
       </File>
...
187
188
189
 
 
 
 
 
190
191
192
...
187
188
189
190
191
192
193
194
195
196
197
0
@@ -187,6 +187,11 @@ bool Source::resync(string db) {
0
   }
0
 
0
   log() << "resync: done " << db << endl;
0
+
0
+ /* add the db to our dbs array which we will write back to local.sources.
0
+ note we are not in a consistent state until the oplog gets applied,
0
+ which happens next when this returns.
0
+ */
0
   dbs.insert(db);
0
   return true;
0
 }
...
18
19
20
 
 
21
22
23
...
18
19
20
21
22
23
24
25
0
@@ -18,6 +18,8 @@
0
 
0
 #pragma once
0
 
0
+#error deprecated
0
+
0
 /* packet dumping level of detail. */
0
 const bool dumpPackets = false; // this must be true to get anything at all
0
 const bool dumpIP = false; // output the ip address

Comments

    No one has commented yet.