<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));
    }




    主站蜘蛛池模板: 有色视频在线观看免费高清在线直播| 亚洲色大成网站www永久网站| 激情五月亚洲色图| 国产精品亚洲一区二区三区在线观看| 国产男女爽爽爽免费视频| 免费观看91视频| 全部免费a级毛片| 中文字幕亚洲综合久久| 国产精品亚洲一区二区三区| 久草免费手机视频| 国产免费观看黄AV片| 久久精品国产亚洲AV高清热| 免费精品视频在线| 最近中文字幕大全中文字幕免费| 免费吃奶摸下激烈视频| 亚洲成a人片7777| 国产性生大片免费观看性| 大陆一级毛片免费视频观看i| 亚洲福利在线视频| aa午夜免费剧场| 免费看美女被靠到爽| 亚洲在成人网在线看| 97在线免费视频| 国产成人高清精品免费软件| 亚洲婷婷在线视频| 久久精品成人免费观看| 亚洲国产成人久久综合碰| 亚洲七久久之综合七久久| 5555在线播放免费播放| 人人狠狠综合久久亚洲婷婷| 香港一级毛片免费看| 国外成人免费高清激情视频| 亚洲国产视频一区| 亚洲视频免费观看| 亚洲美女视频免费| 精品无码国产污污污免费网站| 最近国语视频在线观看免费播放 | 国产成人精品无码免费看| 综合亚洲伊人午夜网 | 亚洲国产精品第一区二区| 一级A毛片免费观看久久精品|