文件映射操作类的实现

文章目录

1 文件映射操作类的实现

1 文件映射操作类的实现

mmap_file_op.h：

#ifndef QINIU_LARGEFILE_MMAPFILE_OP_H_
#define QINIU_LARGEFILE_MMAPFILE_OP_H_#include "common.h"
#include "file_op.h"
#include "mmap_file.h"namespace qiniu
{namespace largefile{class MMapFileOperation: public FileOperation{public:MMapFileOperation(const std::string& file_name, const int open_flags = O_CREAT | O_RDWR | O_LARGEFILE):FileOperation(file_name, open_flags),  map_file_(NULL),  is_mapped_(false){}~MMapFileOperation(){if(map_file_){delete(map_file_);map_file_ = NULL;}}int mmap_file(const MMapOption& mmap_option);int munmap_file();int pread_file(char *buf, const int32_t size, const int64_t offset);int pwrite_file(const char* buf, const int32_t sized, const int64_t offset);void *get_map_data() const ;int flush_file();private:MMapFile *map_file_;bool is_mapped_;};}
}#endif  //QINIU_LARGEFILE_MMAPFILE_OP_H_

mmap_file_op.cpp：

#include "mmap_file_op.h"
#include "common.h"
//#include "file_op.h"
//#include "mmap_file.h"static int debug = 1;namespace qiniu
{namespace largefile{int MMapFileOperation::mmap_file(const MMapOption& mmap_option){if(mmap_option.max_mmap_size_ < mmap_option.first_mmap_size_){return TFS_ERROR;}if(mmap_option.max_mmap_size_  <= 0){return TFS_ERROR;}int fd = check_file();if(fd < 0){fprintf(stderr,  "MMapFileOperation::mmap_file - checking file failed!");return TFS_ERROR;}if(!is_mapped_){if(map_file_){delete(map_file_);}map_file_ = new MMapFile(mmap_option, fd);is_mapped_ = map_file_->map_file(true);}if(is_mapped_){return TFS_SUCCESS;}else {return TFS_ERROR;}}int MMapFileOperation::munmap_file(){if(is_mapped_ && map_file_ != NULL){delete(map_file_);is_mapped_ = false;}return TFS_SUCCESS;}void *MMapFileOperation::get_map_data() const {if(is_mapped_){return map_file_->get_data();}return NULL;}int MMapFileOperation::pread_file(char *buf, const int32_t size, const int64_t offset){//情况1，内存已经映射if(is_mapped_ && (offset + size) >map_file_->get_size()){if(debug) fprintf(stdout, "MMapFileOperation: pread,size: %d, offset: %" __PRI64_PREFIX "d，map file size: %d. need remap\n",size, offset, map_file_->get_size());map_file_->remap_file();}if(is_mapped_ && (offset + size) <=map_file_->get_size()){memcpy(buf, (char *)map_file_->get_data() +offset, size);return TFS_SUCCESS;}//情况2，内存没有映射或是要读取的数据映射不全return FileOperation::pread_file(buf, size, offset);}int MMapFileOperation::pwrite_file(const char* buf, const int32_t size, const int64_t offset){//情况1，内存已经映射if(is_mapped_ && (offset + size) >map_file_->get_size()){if(debug) fprintf(stdout, "MMapFileOperation: pwrite,size: %d, offset: %" __PRI64_PREFIX "d，map file size: %d. need remap\n",size, offset, map_file_->get_size());map_file_->remap_file();}if(is_mapped_ && (offset + size) <=map_file_->get_size()){memcpy((char *)map_file_->get_data() +offset, buf, size);return TFS_SUCCESS;}//情况2，内存没有映射或是要写入的数据映射不全return FileOperation::pwrite_file(buf, size, offset);}int MMapFileOperation::flush_file(){if(is_mapped_){if(map_file_->sync_file()){return TFS_SUCCESS;}else {return TFS_ERROR;}}return FileOperation::flush_file();}}
}

test.cpp：

#include "mmap_file_op.h"
#include <iostream>using namespace std;
using namespace qiniu;const static largefile::MMapOption  mmap_option={10240000, 4096, 4096};  //内存映射的参数int main(void)
{int ret = 0;const char * filename = "mmap_file_op.txt";largefile::MMapFileOperation   *mmfo = new largefile::MMapFileOperation(filename);int fd = mmfo->open_file();if(fd < 0){fprintf(stderr, "open file %s failed. reason: %s\n", filename, strerror(-fd));exit(-1);}ret  = mmfo->mmap_file(mmap_option);if(ret == largefile::TFS_ERROR){fprintf(stderr, "mmap_file failed.  reason: %s\n", strerror(errno));mmfo->close_file();exit(-2);}char buffer[128+1];memset(buffer, '6', 128);buffer[127]='\n';ret = mmfo->pwrite_file(buffer, 128, 8);if(ret < 0){if(ret == largefile::EXIT_DISK_OPER_INCOMPLETE){fprintf(stderr, " pwrite_file: read  length is less than required!\n");}else {fprintf(stderr, "pwrite file %s failed. reason: %s\n", filename, strerror(-ret));}}memset(buffer, 0, 128);ret = mmfo->pread_file(buffer, 128, 8);if(ret < 0){if(ret ==  largefile::EXIT_DISK_OPER_INCOMPLETE){fprintf(stderr, " pread_file: read  length is less than required!");}else {fprintf(stderr, "pread file %s failed. reason: %s\n", filename, strerror(-ret));}}else {buffer[128] = '\0';printf("read: %s\n", buffer);}ret = mmfo->flush_file();if(ret == largefile::TFS_ERROR){fprintf(stderr, "flush file failed. reason: %s\n", strerror(errno));}memset(buffer, '8', 128);buffer[127]='\n';ret = mmfo->pwrite_file(buffer, 128, 4000);    // 即使这里的偏移量很大，也会自动扩充文件的mmfo->munmap_file();mmfo->close_file();return 0;
}

参考资料：

C/C++从入门到精通-高级程序员之路【奇牛学院】

文件映射操作类的实现相关推荐

java文件读写操作类
借鉴了项目以前的文件写入功能,实现了对文件读写操作的封装仅仅需要在读写方法传入路径即可(可以是绝对或相对路径) 以后使用时,可以在此基础上改进,比如: 写操作: 1,对java GUI中文本框中的内 ...
史上最完整的文件和目录操作类
[文件操作类]史上最完整的文件和目录操作类 <a target=_blank href="http://bbs.cskin.net/thread-114-1-1.html"& ...
java大文件读写操作，java nio 之MappedByteBuffer，高效文件/内存映射
http://langgufu.iteye.com/blog/2107023 java处理大文件,一般用BufferedReader,BufferedInputStream这类带缓冲的Io类,不过如果 ...
【JavaNIO的深入研究4】内存映射文件I/O，大文件读写操作，Java nio之MappedByteBuffer，高效文件/内存映射...
内存映射文件能让你创建和修改那些因为太大而无法放入内存的文件.有了内存映射文件,你就可以认为文件已经全部读进了内存,然后把它当成一个非常大的数组来访问.这种解决办法能大大简化修改文件的代码. file ...
Java学习总结：41(文件操作类：File)
Java文件操作类:File 在java.io包中,如果要进行文件自身的操作(例如:创建.删除等),只能依靠java.io.File类完成. File类的常用操作方法 No. 方法类型描述 1 p ...
如何在xaml文件中操作用户在后台代码定义的类(1)
本文主要示例如何在xaml文件中操作用户使用C#代码自定义的类.主要步骤如下: 1.在VS2008中创建一个新项目CustomTypesInXaml,在此项目下我们新建两个类,一个是Client类,一 ...
黄聪：C# MP3操作类,能播放指定的mp3文件,或播放嵌入的资源中的Mp3文件
以下为我写的Mp3操作类源代码: using System; using System.Collections.Generic; using System.Linq; using System.Tex ...
用MyEclipse自动生成hibernate映射文件和实体类
创建web工程,使用Hibernate的时候,在工程里一个一个创建实体类太麻烦,浪费时间,现在教大家如何用MyEclipse自动生成Hibernate映射文件及实体类方法/步骤 1 创建数据库,创建 ...
SilverLight学习笔记--如何在xaml文件中操作用户在后台代码定义的类(2)--示例篇：创建一个登录控件(原创)(转载本文请注明出处)...
本文将示例如何运用前篇所写知识来建立一个用户自定义的登录控件.此控件界面非常简单,主要涉及的知识点是: 如何创建用户控件(包括对此控件的自定义事件和属性的编写,此处我们将创建一个名为LoginBo ...

文件映射操作类的实现

文章目录

1 文件映射操作类的实现

文件映射操作类的实现相关推荐

最新文章

热门文章