天天看点

leveldb源码学习——系统函数封装Env

Env是一个接口类,提供了基本的系统访问接口,如操作文件,线程等。

leveldb在util中实现了PosixEnv,实现上述接口

首先定义了几个基本类型

SequentialFile,提供顺序读方法的接口类

RandomAccessFile,提供随机读方法的接口类

WritableFile, 提供顺序写方法的接口类

Env接口类定义了以下接口

  • 创建文件句柄读文件
    • 顺序读句柄
    • 随机读句柄
    • -
  • 创建文件句柄写文件
    • 创建顺序写句柄,已经存在此文件,删除
    • 创建append写句柄,已经存在,则append
    • -
  • 创建/删除文件夹
  • 文件lock/unlock

posix 的实现

posix实现了Env的含义分两个方面:1,实现了Posix版本的RandomAccessFile,SequentialFile等,2,实现了PosixEnv类,继承Env

  • 顺序读文件

    FILE* file

    fread来提供read

  • random读文件

    两种,第一种使用fd/pread

    int fd

    第二种,使用mmap,直接取内存映射

  • 写文件

    FILE *file

    fwirte提供写

另外,Env定义了在后台运行线程执行后台任务的接口

PosixEnv::Schedule(void (function)(void), void* arg)

这个函数会将function和arg包装成为一个BGItem,放到一个队列中,在这之前启动(如果已经存在,就不启动)一个后台进程,是任务的消费者,死循环的来消费此队列中的任务。

当使用pthread_create来创建一个线程,并使用对象方法来作为入口函数时,没有办法传递this指针,所以应该定义一个static function,接收this指针,然后执行对应的成员方法

class PosixEnv {
    //...
    static void* BGThreadWrapper(void* arg) {                                                                                                            
        reinterpret_cast<PosixEnv*>(arg)->BGThread();
        return NULL;
    }
    void BGThread() {
        while(true) {
        } 
    }
}

pthread_create(&bgthread_, NULL, &PosixEnv::BGThreadWrapper, this));