}
};
-// convert int status to string - including RGW specific values
-std::string status_to_string(int s) {
- switch (s) {
- case STATUS_OK:
- return "STATUS_OK";
- case STATUS_CONNECTION_CLOSED:
- return "RGW_KAFKA_STATUS_CONNECTION_CLOSED";
- case STATUS_QUEUE_FULL:
- return "RGW_KAFKA_STATUS_QUEUE_FULL";
- case STATUS_MAX_INFLIGHT:
- return "RGW_KAFKA_STATUS_MAX_INFLIGHT";
- case STATUS_MANAGER_STOPPED:
- return "RGW_KAFKA_STATUS_MANAGER_STOPPED";
- case STATUS_CONF_ALLOC_FAILED:
- return "RGW_KAFKA_STATUS_CONF_ALLOC_FAILED";
- case STATUS_CONF_REPLCACE:
- return "RGW_KAFKA_STATUS_CONF_REPLCACE";
- case STATUS_CONNECTION_IDLE:
- return "RGW_KAFKA_STATUS_CONNECTION_IDLE";
- }
- return std::string(rd_kafka_err2str((rd_kafka_resp_err_t)s));
-}
-
void message_callback(rd_kafka_t* rk, const rd_kafka_message_t* rkmessage, void* opaque) {
ceph_assert(opaque);
void parse_post_action(const std::string& post_body, req_state* s)
{
if (post_body.size() > 0) {
- ldpp_dout(s, 10) << "Content of POST: " << post_body << dendl;
-
if (post_body.find("Action") != string::npos) {
const boost::char_separator<char> sep("&");
const boost::tokenizer<boost::char_separator<char>> tokens(post_body, sep);