diff options
Diffstat (limited to 'ahl-binding/interrupt.cpp')
| -rw-r--r-- | ahl-binding/interrupt.cpp | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/ahl-binding/interrupt.cpp b/ahl-binding/interrupt.cpp index 6826764..b0eebec 100644 --- a/ahl-binding/interrupt.cpp +++ b/ahl-binding/interrupt.cpp @@ -40,7 +40,7 @@ void interrupt_t::args(json_object* v) args_ = v; } -int interrupt_t::apply(afb_request* req, const role_t& role) +int interrupt_t::apply(afb_req_t req, const role_t& role) { /*if (type_ == "mute") { @@ -63,13 +63,13 @@ int interrupt_t::apply(afb_request* req, const role_t& role) json_object_get(args_); json_object* result = nullptr; - AFB_DYNAPI_DEBUG(ahl_binding_t::instance().handle(), + AFB_API_DEBUG(ahl_binding_t::instance().handle(), "Call '%s'/'%s' '%s'", r.hal().c_str(), r.stream().c_str(), json_object_to_json_string(arg)); - if(afb_dynapi_call_sync(ahl_binding_t::instance().handle(), r.hal().c_str(), r.stream().c_str(), arg, &result)) + if(afb_api_call_sync(ahl_binding_t::instance().handle(), r.hal().c_str(), r.stream().c_str(), arg, &result, nullptr, nullptr)) { - afb_request_fail(req, "Failed to call 'ramp' action on stream", nullptr); + afb_req_fail(req, "Failed to call 'ramp' action on stream", nullptr); return -1; } json_object* response = nullptr; @@ -79,7 +79,7 @@ int interrupt_t::apply(afb_request* req, const role_t& role) if (json_object_object_get_ex(response, "volold", &jvolold)) { applied_on_.push_back(std::make_tuple<std::string, int>(r.uid(), json_object_get_int(jvolold))); - AFB_DYNAPI_DEBUG(ahl_binding_t::instance().handle(), + AFB_API_DEBUG(ahl_binding_t::instance().handle(), "POLICY: Applying a ramp to '%s' stream because '%s' is opened and have higher priority!", r.stream().c_str(), role.stream().c_str()); } @@ -90,7 +90,7 @@ int interrupt_t::apply(afb_request* req, const role_t& role) } else { - afb_request_fail(req, "Unkown interrupt uid!", nullptr); + afb_req_fail(req, "Unkown interrupt uid!", nullptr); return -1; } } @@ -133,18 +133,18 @@ void interrupt_t::clear() json_object_object_add(arg, "ramp", interrupt); json_object* result = nullptr; - AFB_DYNAPI_DEBUG(ahl_binding_t::instance().handle(), + AFB_API_DEBUG(ahl_binding_t::instance().handle(), "Call '%s'/'%s' '%s", r.hal().c_str(), r.stream().c_str(), json_object_to_json_string(arg)); - if(afb_dynapi_call_sync(ahl_binding_t::instance().handle(), r.hal().c_str(), r.stream().c_str(), arg, &result)) + if(afb_api_call_sync(ahl_binding_t::instance().handle(), r.hal().c_str(), r.stream().c_str(), arg, &result, nullptr, nullptr)) { - AFB_DYNAPI_ERROR(ahl_binding_t::instance().handle(), + AFB_API_ERROR(ahl_binding_t::instance().handle(), "Failed to call 'ramp' action on '%s'", role.c_str()); } else { - AFB_DYNAPI_DEBUG(ahl_binding_t::instance().handle(), + AFB_API_DEBUG(ahl_binding_t::instance().handle(), "Called 'ramp' action on '%s'", role.c_str()); } } |