homescreen/src/AglShellManager.cpp

   1 #include <pthread.h>
   2 #include <sys/file.h>
   3 #include <sys/un.h>
   4 #include <unistd.h>
   5 #include <algorithm>
   6 #include <cassert>
   7 #include <climits>
   8 #include <cstdlib>
   9 #include <exception>
  10 #include <fstream>
  11 #include <iostream>
  12 #include <set>
  13 #include <sstream>
  14
  15 #include <grpc/grpc.h>
  16 #include <grpcpp/grpcpp.h>
  17 #include <grpcpp/server.h>
  18 #include <grpcpp/server_builder.h>
  19 #include <grpcpp/server_context.h>
  20
  21 #include <grpcpp/ext/proto_server_reflection_plugin.h>
  22 #include <grpcpp/health_check_service_interface.h>
  23
  24 #include "agl_shell.grpc.pb.h"
  25
  26 #include "homescreenhandler.h"
  27 #include "AglShellManager.h"
  28
  29 grpc::ServerUnaryReactor *
  30 GrpcServiceImpl::ActivateApp(grpc::CallbackServerContext *context,
  31                              const ::agl_shell_ipc::ActivateRequest* request,
  32                              google::protobuf::Empty* /*response*/)
  33 {
  34         fprintf(stderr, "Calling into ActivateApp with app %s and output %s\n",
  35                         request->app_id().c_str(),
  36                         request->output_name().c_str());
  37
  38         HomescreenHandler::Instance()->processAppStatusEvent(QString::fromStdString(request->app_id()),
  39                                                              QString::fromUtf8("started", -1));
  40
  41         grpc::ServerUnaryReactor* reactor = context->DefaultReactor();
  42         reactor->Finish(grpc::Status::OK);
  43         return reactor;
  44 }
  45
  46 grpc::ServerUnaryReactor *
  47 GrpcServiceImpl::DeactivateApp(grpc::CallbackServerContext *context,
  48                                const ::agl_shell_ipc::DeactivateRequest* request,
  49                                google::protobuf::Empty* /*response*/)
  50 {
  51         // FIXME, code here
  52
  53         grpc::ServerUnaryReactor* reactor = context->DefaultReactor();
  54         reactor->Finish(grpc::Status::OK);
  55         return reactor;
  56 }
  57
  58 grpc::ServerUnaryReactor *
  59 GrpcServiceImpl::SetAppSplit(grpc::CallbackServerContext *context,
  60             const ::agl_shell_ipc::SplitRequest* request,
  61             google::protobuf::Empty* /*response*/)
  62 {
  63         // FIXME, code here
  64
  65         grpc::ServerUnaryReactor* reactor = context->DefaultReactor();
  66         reactor->Finish(grpc::Status::OK);
  67         return reactor;
  68 }
  69
  70 grpc::ServerUnaryReactor *
  71 GrpcServiceImpl::SetAppFloat(grpc::CallbackServerContext *context,
  72                              const ::agl_shell_ipc::FloatRequest* request,
  73                              google::protobuf::Empty* /* response */)
  74 {
  75         // FIXME, code here
  76
  77         grpc::ServerUnaryReactor* reactor = context->DefaultReactor();
  78         reactor->Finish(grpc::Status::OK);
  79         return reactor;
  80 }