ceph rgw:rgw的I/O路径 前篇

导言

radosgw使用OP线程处理外部应用的I/O请求,OP线程由rgw main函数初始化后创建,当rgw的frontend为civetweb时,可以通过修改rgw_thread_pool_size指定OP线程的数目。

OP线程的处理逻辑可分为 HTTP前端、REST API通用处理层、API操作执行层、RADOS接口适配层、librados接口层等几部分。具体的作用会在后面逐步解释。

有关整个I/O路径,可能会分多篇文章来分析,这篇文章不涉及OP线程,从main函数入手,看看rgw初始化的一些工作。

main函数

radosgw代码位于ceph/src/rgw目录下,其main函数位于rgw_main.cc。下面按顺序列出main函数中主要的操作,一些细节暂时忽略。

  • 根据配置确认rgw提供哪一个或哪几个frontends。frontend有civetweb、apache等,在最新版本中,其默认frontend是civetweb。frontend是rgw与外界交互的组件。然后为每个被要求提供的frontend的配置创建一个 RGWFrontendConfig 对象,并写入数据。然后所有的RGWFrontendConfig 存储在一个list中。
    civetweb的官方描述:

CivetWeb can be used by developers as a library, to add web server functionality to an existing application. It can also be used by end users as a stand-alone web server. It is available as single executable, no installation is required.

  • 初始化RGWRados对象,建立起与rados的联系。

  • 从配置中获取要对外提供的apis,并存储在一个 apiname->bool的apis_map中,目前支持的api包括s3、swift、admin等等,要注意的是s3和swift不能同时提供。api的选择通过判断apis_map中是否有对应的apiname来确定。比如s3的判断如下:

  if (apis_map.count("s3") > 0 || s3website_enabled) {
    if (! swift_at_root) {
      rest.register_default_mgr(set_logging(rest_filter(store, RGW_REST_S3,
                                                        new RGWRESTMgr_S3(s3website_enabled))));
    } else {
      derr << "Cannot have the S3 or S3 Website enabled together with "
           << "Swift API placed in the root of hierarchy" << dendl;
      return EINVAL;
    }
  }
  • 初始化与日志服务器的连接

  • 注册必要的信号处理函数

  • 遍历之前创建的RGWFrontendConfig列表,为每个frontend创建对象,比如civetweb对应于RGWCivetWebFrontend类对象,loadgen对应于RGWLoadGenFrontend类对象,这些类都继承了同一个基类RGWFrontend。

class RGWFrontend {
public:
  virtual ~RGWFrontend() {}

  virtual int init() = 0; // 进行对象的初始化

  virtual int run() = 0; // 开始服务,frontend一般作为一个服务器接受请求
  virtual void stop() = 0; // 停止服务
  virtual void join() = 0; // 释放对象前调用

  virtual void pause_for_new_config() = 0; // 当rgw的配置发生改变时,需要暂停服务器
  virtual void unpause_with_new_config(RGWRados* store,
                                       rgw_auth_registry_ptr_t auth_registry) = 0; //取消暂停
};

然后将有关frontend的元数据信息存入service_map_meta,如下,fe_count代表当前是第几个frontend,从0开始计数。

service_map_meta["frontend_type#" + stringify(fe_count)] = framework;
service_map_meta["frontend_config#" + stringify(fe_count)] = config->get_config();

然后调用RGWFrontend的init()函数进行初始化。初始化成功后,调用run()函数在其他线程运行frontend。

做完这一切,将创建并初始化的RGWFrontend对象指针放入一个list,list<RGWFrontend *> fes;

  • 运行时事件,因为rgw需要在运行过程中同时监听一些时间的notify,对指定的notify做对应的处理,比如当配置文件修改时,需要暂停frontend的工作,apply新的配置后然后继续工作。rgw是通过将不同的组件注册到一个RGWRealmWatcher上,然后RGWRealmWatcher会监听外部事件,并将其通知注册的组件。代码如下,去看看这几个类的定义会更容易理解。
  RGWPeriodPusher pusher(store);
  RGWFrontendPauser pauser(fes, &pusher);
  RGWRealmReloader reloader(store, service_map_meta, &pauser);

  RGWRealmWatcher realm_watcher(g_ceph_context, store->realm);
  realm_watcher.add_watcher(RGWRealmNotify::Reload, reloader);
  realm_watcher.add_watcher(RGWRealmNotify::ZonesNeedPeriod, pusher);
  • 等待停止信号,进入阻塞状态。
    当收到停止信号后,遍历RGWFrontend列表,为每个对象调用stop函数,然后再遍历一次,为每个对象调用join函数并delete对象。遍历RGWFrontendConfig列表,delete配置对象。

  • 其他各种资源释放,收尾工作。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,670评论 5 460
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,928评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,926评论 0 320
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,238评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 61,112评论 4 356
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,138评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,545评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,232评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,496评论 1 290
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,596评论 2 310
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,369评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,226评论 3 313
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,600评论 3 299
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,906评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,185评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,516评论 2 341
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,721评论 2 335

推荐阅读更多精彩内容