之后调用rgw_process.cc中的process_request(),其中rest->get_handler根据请求的URL是否包含bucket、object信息，获取到对应的handler类型，之后调用handler->get_op(store)根据前面取得的handler对应request_method获取到最终的handler，之后触发handler对应的pre_exec()、execute()、complete()完整整个request请求的处理，代码如下:
#src/rgw/rgw_process.cc
int process_request(RGWRados* store, RGWREST* rest, RGWRequest* req,GWStreamIO* client_io, OpsLogSocket* olog)
{int ret = 0;
client_io->init(g_ceph_context);
...
RGWHandler_REST *handler = rest->get_handler(store, s, client_io, &mgr,&init_error); #这里根据URL里面是否包含bucket、Object字段会进一步获取到对应的handler类型
if (init_error != 0) {
abort_early(s, NULL, init_error, NULL);
goto done;
}
dout(10) << "handler=" << typeid(*handler).name() << dendl;
should_log = mgr->get_logging();
req->log_format(s, "getting op %d", s->op);
op = handler->get_op(store); #这里根据request_method获取到最终处理request请求的handler类型
...
req->log(s, "pre-executing");
op->pre_exec(); #请求预处理
req->log(s, "executing");
op->execute(); #具体请求的具体实现
req->log(s, "completing");
op->complete(); #完成请求处理#src/rgw/rgw_process.cc
RGWHandler_REST* RGWRESTMgr_S3::get_handler(struct req_state *s)
{
bool is_s3website = enable_s3website && (s->prot_flags & RGW_REST_WEBSITE);
int ret =
RGWHandler_REST_S3::init_from_header(s,
is_s3website ? RGW_FORMAT_HTML :
RGW_FORMAT_XML, true);
if (ret < 0)
return NULL;
RGWHandler_REST* handler;
// TODO: Make this more readable
if (is_s3website) {
if (s->init_state.url_bucket.empty()) {
handler = new RGWHandler_REST_Service_S3Website;
} else if (s->object.empty()) {
handler = new RGWHandler_REST_Bucket_S3Website;
} else {
handler = new RGWHandler_REST_Obj_S3Website;
}
} else {
if (s->init_state.url_bucket.empty()) {
handler = new RGWHandler_REST_Service_S3; #bucket为空则切换到RGWHandler_REST_Service_S3
} else if (s->object.empty()) {
handler = new RGWHandler_REST_Bucket_S3; #obj为空则切换RGWHandler_REST_Bucket_S3
} else {
handler = new RGWHandler_REST_Obj_S3; #bucket和Object都不为空，则切换到RGWHandler_REST_Obj_S3
}
}
ldout(s->cct, 20) << __func__ << " handler=" << typeid(*handler).name()
<< dendl;
return handler;
}#src/rgw/rgw_rest.cc
RGWOp* RGWHandler_REST::get_op(RGWRados* store)
{
RGWOp *op;
switch (s->op) #这里s对应一个req_state的结构体
{ rest->op
case OP_GET:
op = op_get();
break;
case OP_PUT:
op = op_put();
break;
case OP_DELETE:
op = op_delete();
break;
case OP_HEAD:
op = op_head();
break;
case OP_POST:
op = op_post();
break;
case OP_COPY:
op = op_copy();
break;
case OP_OPTIONS:
op = op_options();
break;
default:
return NULL;
}
if (op) {
op->init(store, s, this);
}
return op;
} /* get_op */结构体定义
struct req_state {
CephContext *cct;
RGWClientIO *cio;
RGWRequest *req; /// XXX: re-remove??
http_op op; #对应一个枚举类型，具体如下
RGWOpType op_type;
...
enum http_op {
OP_GET,
OP_PUT,
OP_DELETE,
OP_HEAD,
OP_POST,
OP_COPY,
OP_OPTIONS,
OP_UNKNOWN,
};
