<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    小明思考

    Just a software engineer
    posts - 124, comments - 36, trackbacks - 0, articles - 0
      BlogJava :: 首頁 :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理

    leveldb研究5- Snapshot

    Posted on 2012-03-13 16:54 小明 閱讀(4498) 評(píng)論(0)  編輯  收藏 所屬分類: 分布式計(jì)算
    所謂snapshot就是一個(gè)快照,我們可以從快照中讀到舊的數(shù)據(jù)。

    先寫一個(gè)測(cè)試程序來看看snapshot的使用:

    #include <iostream>
    #include 
    "leveldb/db.h"

    using namespace std;
    using namespace leveldb;


    int main() {
        DB 
    *db ;
        Options op;
        op.create_if_missing 
    = true;
        Status s 
    = DB::Open(op,"/tmp/testdb",&db);

        
    if(s.ok()){
            cout 
    << "create successfully" << endl;
            s 
    = db->Put(WriteOptions(),"abcd","1234");
            
    if(s.ok()){
                cout 
    << "put successfully" << endl;
                
    string value;
                s 
    = db->Get(ReadOptions(),"abcd",&value);
                
    if(s.ok()){
                    cout 
    << "get successfully,value:" << value << endl;
                }
            }
            
    if(s.ok()){
                
    string value;
                
    const Snapshot * ss =db->GetSnapshot();
                ReadOptions rop;
                db
    ->Put(WriteOptions(),"abcd","123456");
                db
    ->Get(rop,"abcd",&value);
                
    if(s.ok()){
                        cout 
    << "get successfully,value:" << value << endl;
                }
                rop.snapshot 
    = ss;
                db
    ->Get(rop,"abcd",&value);
                
    if(s.ok()){
                        cout 
    << "get from snapshot successfully,value:" << value << endl;
                }
                db
    ->ReleaseSnapshot(ss);
            }
        }
        delete db;
        
    return 0;
    }

    程序運(yùn)行的輸出結(jié)果是:
    create successfully
    put successfully
    get successfully,value:1234
    get successfully,value:123456
    get from snapshot successfully,value:1234

    可以看出,即使在數(shù)據(jù)更新后,我們?nèi)匀豢梢詮膕napshot中讀到舊的數(shù)據(jù)。

    下面我們來分析leveldb中snapshot的實(shí)現(xiàn)。

    SequenceNumber(db/dbformat.h)
    SequenceNumber是leveldb很重要的東西,每次對(duì)數(shù)據(jù)庫進(jìn)行更新操作,都會(huì)生成一個(gè)新的SequenceNumber,64bits,其中高8位為0,可以跟key的類型(8bits)進(jìn)行合并成64bits。
    typedef uint64_t SequenceNumber;

    // We leave eight bits empty at the bottom so a type and sequence#
    // can be packed together into 64-bits.
    static const SequenceNumber kMaxSequenceNumber =
        ((0x1ull << 56) - 1);

    SnapShot(db/snapshot.h),,可以看出snapshot其實(shí)就是一個(gè)sequence number
    class SnapshotImpl : public Snapshot {
     
    public:
      
    //創(chuàng)建后保持不變
      SequenceNumber number_;  

     
    private:
      friend 
    class SnapshotList; 

      
    //雙向循環(huán)鏈表
      SnapshotImpl* prev_;
      SnapshotImpl
    * next_;

      SnapshotList
    * list_;                 // just for sanity checks
    };

    創(chuàng)建snapshot:
    const Snapshot* DBImpl::GetSnapshot() {
      MutexLock l(
    &mutex_);
      
    return snapshots_.New(versions_->LastSequence());
    }

    刪除snapshot:
    void DBImpl::ReleaseSnapshot(const Snapshot* s) {
      MutexLock l(
    &mutex_);
      snapshots_.Delete(reinterpret_cast
    <const SnapshotImpl*>(s));
    }




    主站蜘蛛池模板: 亚洲一区二区三区写真| 一级毛片成人免费看a| 亚洲国产欧美一区二区三区| 一级毛片免费视频网站| 国产伦一区二区三区免费| 一区二区三区亚洲| 日韩在线观看免费| 免费可以看黄的视频s色| 久久亚洲中文字幕精品一区| 亚洲AV一二三区成人影片| 西西人体免费视频| 免费人成视频x8x8入口| 亚洲av无码一区二区三区观看| 国产香蕉免费精品视频| 亚洲AV无码专区国产乱码电影 | 久久精品国产亚洲AV麻豆不卡| 国产一区二区三区免费观看在线 | 国产一级片免费看| 亚洲成?v人片天堂网无码| 亚洲日本乱码卡2卡3卡新区| 免费国产叼嘿视频大全网站| 亚洲免费在线视频| 男女作爱在线播放免费网站| 中文字幕亚洲专区| 无码国产精品一区二区免费模式| 国产亚洲av人片在线观看| 国产亚洲精品免费| 性做久久久久免费看| 亚洲另类无码专区首页| 一二三四视频在线观看中文版免费 | 国产美女做a免费视频软件| 亚洲国产精品综合久久网各| 中文字幕日本人妻久久久免费| 亚洲综合精品香蕉久久网97| 美女视频黄的全免费视频网站| 亚洲av乱码中文一区二区三区| 成人激情免费视频| 亚洲一区二区无码偷拍| AV在线亚洲男人的天堂 | 免费国产成人α片| 亚洲精品无码aⅴ中文字幕蜜桃|