tools/interfaces/IHardware.py

   1 import gbinder
   2 import logging
   3 from tools import helpers
   4 from gi.repository import GLib
   5
   6
   7 INTERFACE = "lineageos.waydroid.IHardware"
   8 SERVICE_NAME = "waydroidhardware"
   9
  10 TRANSACTION_enableNFC = 1
  11 TRANSACTION_enableBluetooth = 2
  12 TRANSACTION_suspend = 3
  13 TRANSACTION_reboot = 4
  14 TRANSACTION_upgrade = 5
  15
  16 def add_service(args, enableNFC, enableBluetooth, suspend, reboot, upgrade):
  17     helpers.drivers.loadBinderNodes(args)
  18     serviceManager = gbinder.ServiceManager("/dev/" + args.BINDER_DRIVER)
  19
  20     def response_handler(req, code, flags):
  21         logging.debug(
  22             "{}: Received transaction: {}".format(SERVICE_NAME, code))
  23         reader = req.init_reader()
  24         local_response = response.new_reply()
  25         if code == TRANSACTION_enableNFC:
  26             status, arg1 = reader.read_int32()
  27             ret = enableNFC(arg1 != 0)
  28             local_response.append_int32(0)
  29             local_response.append_int32(ret)
  30         if code == TRANSACTION_enableBluetooth:
  31             status, arg1 = reader.read_int32()
  32             ret = enableBluetooth(arg1 != 0)
  33             local_response.append_int32(0)
  34             local_response.append_int32(ret)
  35         if code == TRANSACTION_suspend:
  36             suspend()
  37             local_response.append_int32(0)
  38         if code == TRANSACTION_reboot:
  39             reboot()
  40             local_response.append_int32(0)
  41         if code == TRANSACTION_upgrade:
  42             arg1 = reader.read_string16()
  43             status, arg2 = reader.read_int32()
  44             arg3 = reader.read_string16()
  45             status, arg4 = reader.read_int32()
  46             upgrade(arg1, arg2, arg3, arg4)
  47             local_response.append_int32(0)
  48
  49         return local_response, 0
  50
  51     def binder_presence():
  52         if serviceManager.is_present():
  53             status = serviceManager.add_service_sync(SERVICE_NAME, response)
  54
  55             if status:
  56                 logging.error("Failed to add service {}: {}".format(
  57                     SERVICE_NAME, status))
  58                 args.hardwareLoop.quit()
  59
  60     response = serviceManager.new_local_object(INTERFACE, response_handler)
  61     args.hardwareLoop = GLib.MainLoop()
  62     binder_presence()
  63     status = serviceManager.add_presence_handler(binder_presence)
  64     if status:
  65         args.hardwareLoop.run()
  66         serviceManager.remove_handler(status)
  67         del serviceManager
  68     else:
  69         logging.error("Failed to add presence handler: {}".format(status))