message_queue.h 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  1. /*************************************************************************/
  2. /* message_queue.h */
  3. /*************************************************************************/
  4. /* This file is part of: */
  5. /* GODOT ENGINE */
  6. /* http://www.godotengine.org */
  7. /*************************************************************************/
  8. /* Copyright (c) 2007-2015 Juan Linietsky, Ariel Manzur. */
  9. /* */
  10. /* Permission is hereby granted, free of charge, to any person obtaining */
  11. /* a copy of this software and associated documentation files (the */
  12. /* "Software"), to deal in the Software without restriction, including */
  13. /* without limitation the rights to use, copy, modify, merge, publish, */
  14. /* distribute, sublicense, and/or sell copies of the Software, and to */
  15. /* permit persons to whom the Software is furnished to do so, subject to */
  16. /* the following conditions: */
  17. /* */
  18. /* The above copyright notice and this permission notice shall be */
  19. /* included in all copies or substantial portions of the Software. */
  20. /* */
  21. /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
  22. /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
  23. /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
  24. /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
  25. /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
  26. /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
  27. /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
  28. /*************************************************************************/
  29. #ifndef MESSAGE_QUEUE_H
  30. #define MESSAGE_QUEUE_H
  31. #include "object.h"
  32. #include "os/mutex.h"
  33. #include "os/thread_safe.h"
  34. class MessageQueue {
  35. _THREAD_SAFE_CLASS_
  36. enum {
  37. DEFAULT_QUEUE_SIZE_KB=1024
  38. };
  39. Mutex *mutex;
  40. enum {
  41. TYPE_CALL,
  42. TYPE_NOTIFICATION,
  43. TYPE_SET
  44. };
  45. struct Message {
  46. ObjectID instance_ID;
  47. StringName target;
  48. int16_t type;
  49. union {
  50. int16_t notification;
  51. int16_t args;
  52. };
  53. };
  54. uint8_t *buffer;
  55. uint32_t buffer_end;
  56. uint32_t buffer_max_used;
  57. uint32_t buffer_size;
  58. static MessageQueue *singleton;
  59. public:
  60. static MessageQueue *get_singleton();
  61. Error push_call(ObjectID p_id, const StringName& p_method, VARIANT_ARG_LIST);
  62. Error push_notification(ObjectID p_id, int p_notification);
  63. Error push_set(ObjectID p_id, const StringName& p_prop, const Variant& p_value);
  64. Error push_call(Object *p_object, const StringName& p_method, VARIANT_ARG_LIST);
  65. Error push_notification(Object *p_object, int p_notification);
  66. Error push_set(Object *p_object, const StringName& p_prop, const Variant& p_value);
  67. bool print();
  68. void statistics();
  69. void flush();
  70. int get_max_buffer_usage() const;
  71. MessageQueue();
  72. ~MessageQueue();
  73. };
  74. #endif // MESSAGE_QUEUE_H