return ret;
}
- g_idle_add(RequestCb, cynara_request);
res_cbs_[req_id] = std::make_shared<CynaraResponseCb>(req_id, callback, req);
+ CynaraManager::GetInst().SendRequest(
+ std::shared_ptr<CynaraRequest>(cynara_request));
return AMD_CYNARA_RET_UNKNOWN;
}
_W("END");
}
-gboolean CynaraManager::RequestCb(gpointer user_data) {
- auto* request = static_cast<CynaraRequest*>(user_data);
- _W("tag: %s", request->GetTag().c_str());
- CynaraManager::GetInst().SendRequest(std::shared_ptr<CynaraRequest>(request));
- return G_SOURCE_REMOVE;
-}
-
gboolean CynaraManager::ResponseCb(gpointer user_data) {
auto* response = static_cast<CynaraResponse*>(user_data);
CynaraManager::GetInst().DeliverResponse(
void SendRequest(std::shared_ptr<CynaraRequest> request);
void DeliverResponse(std::shared_ptr<CynaraResponse> response);
void CynaraThread();
- static gboolean RequestCb(gpointer user_data);
static gboolean ResponseCb(gpointer user_data);
void SetBoostingTimer();
void UnsetBoostingTimer();