event.cpp 2.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. // Copyright 2014 Citra Emulator Project
  2. // Licensed under GPLv2 or any later version
  3. // Refer to the license.txt file included.
  4. #include <map>
  5. #include <algorithm>
  6. #include <vector>
  7. #include "common/common.h"
  8. #include "core/hle/kernel/kernel.h"
  9. #include "core/hle/kernel/event.h"
  10. #include "core/hle/kernel/thread.h"
  11. namespace Kernel {
  12. class Event : public WaitObject {
  13. public:
  14. std::string GetTypeName() const override { return "Event"; }
  15. std::string GetName() const override { return name; }
  16. static const HandleType HANDLE_TYPE = HandleType::Event;
  17. HandleType GetHandleType() const override { return HANDLE_TYPE; }
  18. ResetType intitial_reset_type; ///< ResetType specified at Event initialization
  19. ResetType reset_type; ///< Current ResetType
  20. bool signaled; ///< Whether the event has already been signaled
  21. std::string name; ///< Name of event (optional)
  22. ResultVal<bool> Wait(unsigned index) override {
  23. bool wait = !signaled;
  24. if (wait) {
  25. AddWaitingThread(GetCurrentThread());
  26. Kernel::WaitCurrentThread_WaitSynchronization(WAITTYPE_EVENT, this, index);
  27. }
  28. return MakeResult<bool>(wait);
  29. }
  30. ResultVal<bool> Acquire() override {
  31. return MakeResult<bool>(true);
  32. }
  33. };
  34. ResultCode SignalEvent(const Handle handle) {
  35. Event* evt = g_handle_table.Get<Event>(handle).get();
  36. if (evt == nullptr)
  37. return InvalidHandle(ErrorModule::Kernel);
  38. evt->signaled = true;
  39. evt->ReleaseAllWaitingThreads();
  40. return RESULT_SUCCESS;
  41. }
  42. ResultCode ClearEvent(Handle handle) {
  43. Event* evt = g_handle_table.Get<Event>(handle).get();
  44. if (evt == nullptr)
  45. return InvalidHandle(ErrorModule::Kernel);
  46. evt->signaled = false;
  47. return RESULT_SUCCESS;
  48. }
  49. /**
  50. * Creates an event
  51. * @param handle Reference to handle for the newly created mutex
  52. * @param reset_type ResetType describing how to create event
  53. * @param name Optional name of event
  54. * @return Newly created Event object
  55. */
  56. Event* CreateEvent(Handle& handle, const ResetType reset_type, const std::string& name) {
  57. Event* evt = new Event;
  58. // TOOD(yuriks): Fix error reporting
  59. handle = Kernel::g_handle_table.Create(evt).ValueOr(INVALID_HANDLE);
  60. evt->signaled = false;
  61. evt->reset_type = evt->intitial_reset_type = reset_type;
  62. evt->name = name;
  63. return evt;
  64. }
  65. Handle CreateEvent(const ResetType reset_type, const std::string& name) {
  66. Handle handle;
  67. Event* evt = CreateEvent(handle, reset_type, name);
  68. return handle;
  69. }
  70. } // namespace