学步园

        writelock lk(ns);
        
//
 如果不更新所有节点（sharding）且当前物理结点是shard 状态时


        
if
 ( 
!
 broadcast 
&
 handlePossibleShardedMessage( m , 
0
 ) )
            
return
;
        
//
if this ever moves to outside of lock, need to adjust check Client::Context::_finishInit


        Client::Context ctx(ns);

        
long
 
long
 n 
=
 deleteObjects(ns, pattern, justOne, 
true
);
//
删除对象信息


        lastError.getSafe()
->
recordDelete( n );
    }

        NamespaceDetails 
*
d 
=
 nsdetails( ns );
//
获取名空间详细信息


        
if
 ( 
!
 d )
            
return
 
0
;
        uassert( 
10101
 ,  
"
can't remove from a capped collection
"
 , 
!
 d
->
capped );
//
确保当前collection不是capped类型（该类型集合会自动删除旧数据）



        
long
 
long
 nDeleted 
=
 
0
;

        
int
 best 
=
 
0
;
        shared_ptr
<
 MultiCursor::CursorOp 
>
 opPtr( 
new
 DeleteOp( justOneOrig, best ) );
//
构造“删除操作”实例对象并用其构造游标操作（符）实例


        shared_ptr
<
 MultiCursor 
>
 creal( 
new
 MultiCursor( ns, pattern, BSONObj(), opPtr, 
!
god ) );
//
构造MultiCursor查询游标（参见构造方法中的 nextClause()语句）



        
if
( 
!
creal
->
ok() )
//
如果查询游标指向地址是否正常(主要判断是否null)，因为系统会根据上面游标初始信息决定使用什么样的方式进行信息查询(比如是否使用B树索引等）


            
return
 nDeleted;

        shared_ptr
<
 Cursor 
>
 cPtr 
=
 creal;
        auto_ptr
<
ClientCursor
>
 cc( 
new
 ClientCursor( QueryOption_NoCursorTimeout, cPtr, ns) );
//
将游标封装以便下面遍历使用


        cc
->
setDoingDeletes( 
true
 );
//
设置_doingDeletes(删除中)标志



        CursorId id 
=
 cc
->
cursorid();

        
bool
 justOne 
=
 justOneOrig;
        
bool
 canYield 
=
 
!
god 
&&
 
!
creal
->
matcher()
->
docMatcher().atomic();

        
do
 {
            
if
 ( canYield 
&&
 
!
 cc
->
yieldSometimes() ) {
//
查
看是否已到期（每个cc都会有一个读写操作时间，该值取决子获取读写锁时系统分配的时间，详见client.cpp 文件中的方
法 int Client::recommendedYieldMicros( int * writers , int * readers ) {）


                cc.release(); 
//
 时间已到则释放该对象（意味着已在别的地方被删除?）
                
//
 TODO should we assert or something?


                
break
;
            }
            
if
 ( 
!
cc
->
ok() ) {
                
break
; 
//
 if we yielded, could have hit the end


            }

            
//
 this way we can avoid calling updateLocation() every time (expensive)
            
//
 as well as some other nuances handled


            cc
->
setDoingDeletes( 
true
 );

            DiskLoc rloc 
=
 cc
->
currLoc();
//
游标当前所指向的记录所在地址


            BSONObj key 
=
 cc
->
currKey();
//
游标当前所指向的记录的key

            
//
 NOTE Calling advance() may change the matcher, so it's important
            
//
 to try to match first.


            
bool
 match 
=
 creal
->
matcher()
->
matches( key , rloc );
//
将当前游标指向的记录与游标中的where条件进行比较



            
if
 ( 
!
 cc
->
advance() )
//
游标移到下一个记录位置


                justOne 
=
 
true
;

            
if
 ( 
!
 match )
                
continue
;

            assert( 
!
cc
->
c()
->
getsetdup(rloc) ); 
//
不允许复本, 因为在多键值索引中可能会返回复本



            
if
 ( 
!
justOne ) {
                
/*
 NOTE: this is SLOW.  this is not good, noteLocation() was designed to be called across getMore
                    blocks.  here we might call millions of times which would be bad.
                    
*/

                cc
->
c()
->
noteLocation();
//
记录当前游标移动到的位置


            }

            
if
 ( logop ) {
//
是否保存操作日志


                BSONElement e;
                
if
( BSONObj( rloc.rec() ).getObjectID( e ) ) {
                    BSONObjBuilder b;
                    b.append( e );
                    
bool
 replJustOne 
=
 
true
;
                    logOp( 
"
d
"
, ns, b.done(), 
0
, 
&
replJustOne );
//
d表示delete


                }
                
else
 {
                    problem() 
<<
 
"
deleted object without id, not logging
"
 
<<
 endl;
                }
            }

            
if
 ( rs )
//
将删除记录的bson objects 信息保存到磁盘文件上


                rs
->
goingToDelete( rloc.obj() 
/*
cc->c->current()
*/
 );

            theDataFileMgr.deleteRecord(ns, rloc.rec(), rloc);
//
删除查询匹配到的记录


            nDeleted
++
;
//
累计删除信息数


            
if
 ( justOne ) {
                
break
;
            }
            cc
->
c()
->
checkLocation();
//
因为删除完记录好，会造成缓存中相关索引信息过期，用该方法能确保索引有效


         
            
if
( 
!
god )
                getDur().commitIfNeeded();

            
if
( debug 
&&
 god 
&&
 nDeleted 
==
 
100
 ) 
//
删除100条信息之后，显示内存使用预警信息


                log() 
<<
 
"
warning high number of deletes with god=true which could use significant memory
"
 
<<
 endl;
        }
        
while
 ( cc
->
ok() );

        
if
 ( cc.
get
() 
&&
 ClientCursor::find( id , 
false
 ) 
==
 
0
 ) {
//
再次在btree bucket中查找，如没有找到，表示记录已全部被删除


            cc.release();
        }

        
return
 nDeleted;
//
返回已删除的记录数


    }

        
//
如果还有别的游标指向当前dl（并发情况下），则提升它们


        ClientCursor::aboutToDelete(dl);
        
//
将要删除的记录信息从索引b村中移除


        unindexRecord(d, todelete, dl, noWarn);
        
//
删除指定记录信息


        _deleteRecord(d, ns, todelete, dl);
        NamespaceDetailsTransient::get_w( ns ).notifyOfWriteOp();
    }

    
//
pdfile.cpp文件 815行


    
/*
 unindex all keys in index for this record. 
*/

    
static
 
void
 _unindexRecord(IndexDetails
&
 id, BSONObj
&
 obj, 
const
 DiskLoc
&
 dl, 
bool
 logMissing 
=
 
true
) {
        BSONObjSetDefaultOrder keys;
        id.getKeysFromObject(obj, keys);
//
通过记录获取键值信息


        
for
 ( BSONObjSetDefaultOrder::iterator i
=
keys.begin(); i 
!=
 keys.end(); i
++
 ) {
            BSONObj j 
=
 
*
i;
            
if
 ( otherTraceLevel 
>=
 
5
 ) {
//
otherTraceLevel为外部变量，定义在query.cpp中，目前作用不清楚


                
out
() 
<<
 
"
_unindexRecord() 
"
 
<<
 obj.toString();
                
out
() 
<<
 
"
/n  unindex:
"
 
<<
 j.toString() 
<<
 endl;
            }
            nUnindexes
++
;
//
累加索引数


            
bool
 ok 
=
 
false
;
            
try
 {
                ok 
=
 id.head.btree()
->
unindex(id.head, id, j, dl);
//
在btree bucket中删除记录的索引信息


            }
            
catch
 (AssertionException
&
 e) {
                problem() 
<<
 
"
Assertion failure: _unindex failed 
"
 
<<
 id.indexNamespace() 
<<
 endl;
                
out
() 
<<
 
"
Assertion failure: _unindex failed: 
"
 
<<
 e.what() 
<<
 
'
/n
'
;
                
out
() 
<<
 
"
  obj:
"
 
<<
 obj.toString() 
<<
 
'
/n
'
;
                
out
() 
<<
 
"
  key:
"
 
<<
 j.toString() 
<<
 
'
/n
'
;
                
out
() 
<<
 
"
  dl:
"
 
<<
 dl.toString() 
<<
 endl;
                sayDbContext();
            }

            
if
 ( 
!
ok 
&&
 logMissing ) {
                
out
() 
<<
 
"
unindex failed (key too big?) 
"
 
<<
 id.indexNamespace() 
<<
 
'
/n
'
;
            }
        }
    }

        
int
 pos;
        
bool
 found;
        DiskLoc loc 
=
 locate(id, thisLoc, key, Ordering::make(id.keyPattern()), pos, found, recordLoc, 
1
);
//
从btree bucket中查找指定记录并获得位置信息（pos）


        
if