X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=grpc-proxy%2Fgrpc-async-cb.cpp;h=680756477200d3bf0cd6b403bd7af04ba5de72ab;hb=e7ccf51adc37748d3ca000109d16d0495dc0a7e8;hp=9cbbb4d4e58016acff37155b8673108e5188ca7b;hpb=ca537df2c52990acf97fb1c42ec2d993c60eae2d;p=src%2Fagl-compositor.git diff --git a/grpc-proxy/grpc-async-cb.cpp b/grpc-proxy/grpc-async-cb.cpp index 9cbbb4d..6807564 100644 --- a/grpc-proxy/grpc-async-cb.cpp +++ b/grpc-proxy/grpc-async-cb.cpp @@ -89,6 +89,10 @@ GrpcServiceImpl::ActivateApp(grpc::CallbackServerContext *context, { LOG("activating app %s on output %s\n", request->app_id().c_str(), request->output_name().c_str()); + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->ActivateApp(request->app_id(), request->output_name()); @@ -102,6 +106,11 @@ GrpcServiceImpl::DeactivateApp(grpc::CallbackServerContext *context, const ::agl_shell_ipc::DeactivateRequest* request, ::agl_shell_ipc::DeactivateResponse* /*response*/) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } + m_aglShell->DeactivateApp(request->app_id()); grpc::ServerUnaryReactor* reactor = context->DefaultReactor(); @@ -114,6 +123,10 @@ GrpcServiceImpl::SetAppFloat(grpc::CallbackServerContext *context, const ::agl_shell_ipc::FloatRequest* request, ::agl_shell_ipc::FloatResponse* /* response */) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->SetAppFloat(request->app_id(), request->x_pos(), request->y_pos()); @@ -127,6 +140,10 @@ GrpcServiceImpl::SetAppNormal(grpc::CallbackServerContext *context, const ::agl_shell_ipc::NormalRequest* request, ::agl_shell_ipc::NormalResponse* /* response */) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->SetAppNormal(request->app_id()); grpc::ServerUnaryReactor* reactor = context->DefaultReactor(); @@ -139,6 +156,10 @@ GrpcServiceImpl::SetAppFullscreen(grpc::CallbackServerContext *context, const ::agl_shell_ipc::FullscreenRequest* request, ::agl_shell_ipc::FullscreenResponse* /* response */) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->SetAppFullscreen(request->app_id()); grpc::ServerUnaryReactor* reactor = context->DefaultReactor(); @@ -151,6 +172,10 @@ GrpcServiceImpl::SetAppOnOutput(grpc::CallbackServerContext *context, const ::agl_shell_ipc::AppOnOutputRequest* request, ::agl_shell_ipc::AppOnOutputResponse* /* response */) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->SetAppOnOutput(request->app_id(), request->output()); grpc::ServerUnaryReactor* reactor = context->DefaultReactor(); @@ -163,6 +188,10 @@ GrpcServiceImpl::SetAppPosition(grpc::CallbackServerContext *context, const ::agl_shell_ipc::AppPositionRequest* request, ::agl_shell_ipc::AppPositionResponse* /* response */) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->SetAppPosition(request->app_id(), request->x(), request->y()); grpc::ServerUnaryReactor* reactor = context->DefaultReactor(); @@ -175,6 +204,10 @@ GrpcServiceImpl::SetAppScale(grpc::CallbackServerContext *context, const ::agl_shell_ipc::AppScaleRequest* request, ::agl_shell_ipc::AppScaleResponse* /* response */) { + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } m_aglShell->SetAppScale(request->app_id(), request->width(), request->height()); @@ -188,7 +221,13 @@ GrpcServiceImpl::SetAppSplit(grpc::CallbackServerContext *context, const ::agl_shell_ipc::SplitRequest* request, ::agl_shell_ipc::SplitResponse* /*response*/) { - m_aglShell->SetAppSplit(request->app_id(), request->tile_orientation()); + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } + m_aglShell->SetAppSplit(request->app_id(), request->tile_orientation(), + request->width(), request->sticky(), + request->output_name()); grpc::ServerUnaryReactor* reactor = context->DefaultReactor(); reactor->Finish(grpc::Status::OK); @@ -202,6 +241,11 @@ GrpcServiceImpl::GetOutputs(grpc::CallbackServerContext *context, { struct window_output *output; + if (!m_aglShell) { + LOG("m_aglShell not set-up\n"); + return nullptr; + } + struct wl_list *list = &m_aglShell->m_shell_data->output_list; wl_list_for_each(output, list, link) { auto m_output = response->add_outputs(); @@ -218,8 +262,13 @@ GrpcServiceImpl::AppStatusState(grpc::CallbackServerContext* context, const ::agl_shell_ipc::AppStateRequest* /*request */) { - Lister *n = new Lister(m_aglShell); + if (!m_aglShell) { + LOG(">> m_aglShell not set-up\n"); + return nullptr; + } + + Lister *n = new Lister(m_aglShell); m_aglShell->m_shell_data->server_context_list.push_back(std::pair(context, n)); LOG("added lister %p\n", static_cast(n));