leveldb源码分析-9-operation

内容简介：leveldb源码分析-9-operation

leveldb operation

leveldb的操作分别为 Put 、 Delete 、 Write 、 Get 、 CompactRange 、 NewIterator 、 GetSnapshot 、 ReleaseSnapshot 等。

其中 Put 、 Delete 都是 Write 操作的简单封装， Delete 就是写入一条删除记录。

Write

Status Write(const WriteOptions& options, WriteBatch* my_batch) 写入一批记录到leveldb中。Write 操作会先分配一个Writer，然后将这个Writer添加到Writer队列中，该队列将全部Writer的操作串行化（Write 操作可能在多个线程中被调用，但是其相关的Writer会通过Writer队列串行化，最总在其中的一个Write调用线 程中被批量执行）。

Writer被调用时，leveldb先调用 MakeRoomForWrite 。 MakeRoomForWrite 会判断写缓存的空间，当空间不够 时会触发compaction，或者当有compaction进行是，会进行限速。

然后把Writer中的内容构建一个WriteBatch，填充这些记录的sequence值，然后把WriteBatch写入binlog和memtable。

最后唤醒等待中的Write调用。

Get

Status Get(const ReadOptions& options, const Slice& key, std::string* value) 被用户调用时，会按照 memtable、immutable、SSTable的查询顺序查询，只要查询到结果就返回给用户。当查询到SSTable时，会记录一 个state，当用户的本次查询操作需要seek的文件超过阈值时会触发一次compaction。

Snapshot

GetSnapshot 获取的是一个隐含leveldb当前sequence的数据结构，对外用户不可见。snapshot用于用户调用 Get 操作时使用，leveldb在存储用户的key时，扩展了8byte，用于填充记录的type和sequence值。用户调用 Get 操作时，会比较sequence，当用于传入一个snapshot时，大于该snapshot的sequence的记录会被隐藏。 因此用于只能得到该早于sequence的记录。

用户调用 GetSnapshot 时，会分配一个Snapshot数据结构，中记录当前的sequence，然后添加到leveldb的 VersionSet中一个链表上。之所以记录全部分配的snapshot，防止compaction时，删除早先的记录。

ReleaseSnapshot 会是否掉VersionSet链表上的资源。

CompactRange

void CompactRange(const Slice* begin, const Slice* end) 被调用时，先遍历每个level，找到与 begin 和 end 重叠的最大level( max_level )，然调用一次 Write(WriteOptions(), NULL) ，触发一次compaction。 然后在遍历level-0到 max_level ，每个level在触发一次手动compaction。

可见CompactRange是一个特别重的操作，因此调用时要慎之又慎。通常情况下，不需要手动调用，依赖leveldb 自动触发的compaction即可。

NewIterator

调用 NewIterator 时，先调用 Iterator* NewInternalIterator(const ReadOptions& options, SequenceNumber* latest_snapshot, uint32_t* seed) ， 锁定当前sequence作为遍历时的snapshot，选取memtable、immutable和version。从memtable、immutable中各 生成一个iteration，从每层SSTable中生成文件的iteration，然后将这些iteration合并成一个MergingIterator。

然后用这个MergingIterator生成DBIterator返回给用户。

在使用DBIterator时会对遍历的数据进行采样，当遍历时seek文件达到阈值时，会触发自动的compaction。

以上所述就是小编给大家介绍的《leveldb源码分析-9-operation》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！

查看所有标签

猜你喜欢:

• 以太坊源码分析(36)ethdb源码分析
• [源码分析] kubelet源码分析（一）之 NewKubeletCommand
• libmodbus源码分析（3）从机（服务端）功能源码分析
• [源码分析] nfs-client-provisioner源码分析
• [源码分析] kubelet源码分析（三）之 Pod的创建
• Spring事务源码分析专题（一）JdbcTemplate使用及源码分析

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。