server_wrap_mt_common.h 61 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764
  1. /*************************************************************************/
  2. /* server_wrap_mt_common.h */
  3. /*************************************************************************/
  4. /* This file is part of: */
  5. /* GODOT ENGINE */
  6. /* https://godotengine.org */
  7. /*************************************************************************/
  8. /* Copyright (c) 2007-2021 Juan Linietsky, Ariel Manzur. */
  9. /* Copyright (c) 2014-2021 Godot Engine contributors (cf. AUTHORS.md). */
  10. /* */
  11. /* Permission is hereby granted, free of charge, to any person obtaining */
  12. /* a copy of this software and associated documentation files (the */
  13. /* "Software"), to deal in the Software without restriction, including */
  14. /* without limitation the rights to use, copy, modify, merge, publish, */
  15. /* distribute, sublicense, and/or sell copies of the Software, and to */
  16. /* permit persons to whom the Software is furnished to do so, subject to */
  17. /* the following conditions: */
  18. /* */
  19. /* The above copyright notice and this permission notice shall be */
  20. /* included in all copies or substantial portions of the Software. */
  21. /* */
  22. /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
  23. /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
  24. /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
  25. /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
  26. /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
  27. /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
  28. /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
  29. /*************************************************************************/
  30. #define FUNC0R(m_r, m_type) \
  31. virtual m_r m_type() override { \
  32. if (Thread::get_caller_id() != server_thread) { \
  33. m_r ret; \
  34. command_queue.push_and_ret(server_name, &ServerName::m_type, &ret); \
  35. SYNC_DEBUG \
  36. return ret; \
  37. } else { \
  38. command_queue.flush_if_pending(); \
  39. return server_name->m_type(); \
  40. } \
  41. }
  42. #define FUNCRIDSPLIT(m_type) \
  43. virtual RID m_type##_create() override { \
  44. RID ret = server_name->m_type##_allocate(); \
  45. if (Thread::get_caller_id() != server_thread) { \
  46. command_queue.push(server_name, &ServerName::m_type##_initialize, ret); \
  47. } else { \
  48. server_name->m_type##_initialize(ret); \
  49. } \
  50. return ret; \
  51. }
  52. //RID now returns directly, ensure thread safety yourself
  53. #define FUNCRID(m_type) \
  54. virtual RID m_type##_create() override { \
  55. return server_name->m_type##_create(); \
  56. }
  57. #define FUNC0RC(m_r, m_type) \
  58. virtual m_r m_type() const override { \
  59. WRITE_ACTION \
  60. if (Thread::get_caller_id() != server_thread) { \
  61. m_r ret; \
  62. command_queue.push_and_ret(server_name, &ServerName::m_type, &ret); \
  63. SYNC_DEBUG \
  64. return ret; \
  65. } else { \
  66. command_queue.flush_if_pending(); \
  67. return server_name->m_type(); \
  68. } \
  69. }
  70. #define FUNC0(m_type) \
  71. virtual void m_type() override { \
  72. WRITE_ACTION \
  73. if (Thread::get_caller_id() != server_thread) { \
  74. command_queue.push(server_name, &ServerName::m_type); \
  75. } else { \
  76. command_queue.flush_if_pending(); \
  77. server_name->m_type(); \
  78. } \
  79. }
  80. #define FUNC0C(m_type) \
  81. virtual void m_type() const override { \
  82. if (Thread::get_caller_id() != server_thread) { \
  83. command_queue.push(server_name, &ServerName::m_type); \
  84. } else { \
  85. command_queue.flush_if_pending(); \
  86. server_name->m_type(); \
  87. } \
  88. }
  89. #define FUNC0S(m_type) \
  90. virtual void m_type() override { \
  91. WRITE_ACTION \
  92. if (Thread::get_caller_id() != server_thread) { \
  93. command_queue.push_and_sync(server_name, &ServerName::m_type); \
  94. SYNC_DEBUG \
  95. } else { \
  96. command_queue.flush_if_pending(); \
  97. server_name->m_type(); \
  98. } \
  99. }
  100. #define FUNC0SC(m_type) \
  101. virtual void m_type() const override { \
  102. if (Thread::get_caller_id() != server_thread) { \
  103. command_queue.push_and_sync(server_name, &ServerName::m_type); \
  104. SYNC_DEBUG \
  105. } else { \
  106. command_queue.flush_if_pending(); \
  107. server_name->m_type(); \
  108. } \
  109. }
  110. ///////////////////////////////////////////////
  111. #define FUNC1R(m_r, m_type, m_arg1) \
  112. virtual m_r m_type(m_arg1 p1) override { \
  113. WRITE_ACTION \
  114. if (Thread::get_caller_id() != server_thread) { \
  115. m_r ret; \
  116. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, &ret); \
  117. SYNC_DEBUG \
  118. return ret; \
  119. } else { \
  120. command_queue.flush_if_pending(); \
  121. return server_name->m_type(p1); \
  122. } \
  123. }
  124. #define FUNC1RC(m_r, m_type, m_arg1) \
  125. virtual m_r m_type(m_arg1 p1) const override { \
  126. if (Thread::get_caller_id() != server_thread) { \
  127. m_r ret; \
  128. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, &ret); \
  129. SYNC_DEBUG \
  130. return ret; \
  131. } else { \
  132. command_queue.flush_if_pending(); \
  133. return server_name->m_type(p1); \
  134. } \
  135. }
  136. #define FUNC1S(m_type, m_arg1) \
  137. virtual void m_type(m_arg1 p1) override { \
  138. WRITE_ACTION \
  139. if (Thread::get_caller_id() != server_thread) { \
  140. command_queue.push_and_sync(server_name, &ServerName::m_type, p1); \
  141. SYNC_DEBUG \
  142. } else { \
  143. command_queue.flush_if_pending(); \
  144. server_name->m_type(p1); \
  145. } \
  146. }
  147. #define FUNC1SC(m_type, m_arg1) \
  148. virtual void m_type(m_arg1 p1) const override { \
  149. if (Thread::get_caller_id() != server_thread) { \
  150. command_queue.push_and_sync(server_name, &ServerName::m_type, p1); \
  151. SYNC_DEBUG \
  152. } else { \
  153. command_queue.flush_if_pending(); \
  154. server_name->m_type(p1); \
  155. } \
  156. }
  157. #define FUNC1(m_type, m_arg1) \
  158. virtual void m_type(m_arg1 p1) override { \
  159. WRITE_ACTION \
  160. if (Thread::get_caller_id() != server_thread) { \
  161. command_queue.push(server_name, &ServerName::m_type, p1); \
  162. } else { \
  163. command_queue.flush_if_pending(); \
  164. server_name->m_type(p1); \
  165. } \
  166. }
  167. #define FUNC1C(m_type, m_arg1) \
  168. virtual void m_type(m_arg1 p1) const override { \
  169. if (Thread::get_caller_id() != server_thread) { \
  170. command_queue.push(server_name, &ServerName::m_type, p1); \
  171. } else { \
  172. command_queue.flush_if_pending(); \
  173. server_name->m_type(p1); \
  174. } \
  175. }
  176. #define FUNC2R(m_r, m_type, m_arg1, m_arg2) \
  177. virtual m_r m_type(m_arg1 p1, m_arg2 p2) override { \
  178. WRITE_ACTION \
  179. if (Thread::get_caller_id() != server_thread) { \
  180. m_r ret; \
  181. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, &ret); \
  182. SYNC_DEBUG \
  183. return ret; \
  184. } else { \
  185. command_queue.flush_if_pending(); \
  186. return server_name->m_type(p1, p2); \
  187. } \
  188. }
  189. #define FUNC2RC(m_r, m_type, m_arg1, m_arg2) \
  190. virtual m_r m_type(m_arg1 p1, m_arg2 p2) const override { \
  191. if (Thread::get_caller_id() != server_thread) { \
  192. m_r ret; \
  193. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, &ret); \
  194. SYNC_DEBUG \
  195. return ret; \
  196. } else { \
  197. command_queue.flush_if_pending(); \
  198. return server_name->m_type(p1, p2); \
  199. } \
  200. }
  201. #define FUNC2S(m_type, m_arg1, m_arg2) \
  202. virtual void m_type(m_arg1 p1, m_arg2 p2) override { \
  203. WRITE_ACTION \
  204. if (Thread::get_caller_id() != server_thread) { \
  205. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2); \
  206. SYNC_DEBUG \
  207. } else { \
  208. command_queue.flush_if_pending(); \
  209. server_name->m_type(p1, p2); \
  210. } \
  211. }
  212. #define FUNC2SC(m_type, m_arg1, m_arg2) \
  213. virtual void m_type(m_arg1 p1, m_arg2 p2) const override { \
  214. if (Thread::get_caller_id() != server_thread) { \
  215. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2); \
  216. SYNC_DEBUG \
  217. } else { \
  218. command_queue.flush_if_pending(); \
  219. server_name->m_type(p1, p2); \
  220. } \
  221. }
  222. #define FUNC2(m_type, m_arg1, m_arg2) \
  223. virtual void m_type(m_arg1 p1, m_arg2 p2) override { \
  224. WRITE_ACTION \
  225. if (Thread::get_caller_id() != server_thread) { \
  226. command_queue.push(server_name, &ServerName::m_type, p1, p2); \
  227. } else { \
  228. command_queue.flush_if_pending(); \
  229. server_name->m_type(p1, p2); \
  230. } \
  231. }
  232. #define FUNC2C(m_type, m_arg1, m_arg2) \
  233. virtual void m_type(m_arg1 p1, m_arg2 p2) const override { \
  234. if (Thread::get_caller_id() != server_thread) { \
  235. command_queue.push(server_name, &ServerName::m_type, p1, p2); \
  236. } else { \
  237. command_queue.flush_if_pending(); \
  238. server_name->m_type(p1, p2); \
  239. } \
  240. }
  241. #define FUNC3R(m_r, m_type, m_arg1, m_arg2, m_arg3) \
  242. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) override { \
  243. WRITE_ACTION \
  244. if (Thread::get_caller_id() != server_thread) { \
  245. m_r ret; \
  246. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, &ret); \
  247. SYNC_DEBUG \
  248. return ret; \
  249. } else { \
  250. command_queue.flush_if_pending(); \
  251. return server_name->m_type(p1, p2, p3); \
  252. } \
  253. }
  254. #define FUNC3RC(m_r, m_type, m_arg1, m_arg2, m_arg3) \
  255. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) const override { \
  256. if (Thread::get_caller_id() != server_thread) { \
  257. m_r ret; \
  258. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, &ret); \
  259. SYNC_DEBUG \
  260. return ret; \
  261. } else { \
  262. command_queue.flush_if_pending(); \
  263. return server_name->m_type(p1, p2, p3); \
  264. } \
  265. }
  266. #define FUNC3S(m_type, m_arg1, m_arg2, m_arg3) \
  267. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) override { \
  268. WRITE_ACTION \
  269. if (Thread::get_caller_id() != server_thread) { \
  270. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3); \
  271. SYNC_DEBUG \
  272. } else { \
  273. command_queue.flush_if_pending(); \
  274. server_name->m_type(p1, p2, p3); \
  275. } \
  276. }
  277. #define FUNC3SC(m_type, m_arg1, m_arg2, m_arg3) \
  278. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) const override { \
  279. if (Thread::get_caller_id() != server_thread) { \
  280. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3); \
  281. SYNC_DEBUG \
  282. } else { \
  283. command_queue.flush_if_pending(); \
  284. server_name->m_type(p1, p2, p3); \
  285. } \
  286. }
  287. #define FUNC3(m_type, m_arg1, m_arg2, m_arg3) \
  288. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) override { \
  289. WRITE_ACTION \
  290. if (Thread::get_caller_id() != server_thread) { \
  291. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3); \
  292. } else { \
  293. command_queue.flush_if_pending(); \
  294. server_name->m_type(p1, p2, p3); \
  295. } \
  296. }
  297. #define FUNC3C(m_type, m_arg1, m_arg2, m_arg3) \
  298. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) const override { \
  299. if (Thread::get_caller_id() != server_thread) { \
  300. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3); \
  301. } else { \
  302. command_queue.flush_if_pending(); \
  303. server_name->m_type(p1, p2, p3); \
  304. } \
  305. }
  306. #define FUNC4R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  307. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) override { \
  308. WRITE_ACTION \
  309. if (Thread::get_caller_id() != server_thread) { \
  310. m_r ret; \
  311. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, &ret); \
  312. SYNC_DEBUG \
  313. return ret; \
  314. } else { \
  315. command_queue.flush_if_pending(); \
  316. return server_name->m_type(p1, p2, p3, p4); \
  317. } \
  318. }
  319. #define FUNC4RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  320. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) const override { \
  321. if (Thread::get_caller_id() != server_thread) { \
  322. m_r ret; \
  323. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, &ret); \
  324. SYNC_DEBUG \
  325. return ret; \
  326. } else { \
  327. command_queue.flush_if_pending(); \
  328. return server_name->m_type(p1, p2, p3, p4); \
  329. } \
  330. }
  331. #define FUNC4S(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  332. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) override { \
  333. WRITE_ACTION \
  334. if (Thread::get_caller_id() != server_thread) { \
  335. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  336. SYNC_DEBUG \
  337. } else { \
  338. command_queue.flush_if_pending(); \
  339. server_name->m_type(p1, p2, p3, p4); \
  340. } \
  341. }
  342. #define FUNC4SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  343. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) const override { \
  344. if (Thread::get_caller_id() != server_thread) { \
  345. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  346. SYNC_DEBUG \
  347. } else { \
  348. command_queue.flush_if_pending(); \
  349. server_name->m_type(p1, p2, p3, p4); \
  350. } \
  351. }
  352. #define FUNC4(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  353. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) override { \
  354. WRITE_ACTION \
  355. if (Thread::get_caller_id() != server_thread) { \
  356. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  357. } else { \
  358. command_queue.flush_if_pending(); \
  359. server_name->m_type(p1, p2, p3, p4); \
  360. } \
  361. }
  362. #define FUNC4C(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  363. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) const override { \
  364. if (Thread::get_caller_id() != server_thread) { \
  365. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  366. } else { \
  367. command_queue.flush_if_pending(); \
  368. server_name->m_type(p1, p2, p3, p4); \
  369. } \
  370. }
  371. #define FUNC5R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  372. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) { \
  373. WRITE_ACTION \
  374. if (Thread::get_caller_id() != server_thread) { \
  375. m_r ret; \
  376. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, &ret); \
  377. SYNC_DEBUG \
  378. return ret; \
  379. } else { \
  380. command_queue.flush_if_pending(); \
  381. return server_name->m_type(p1, p2, p3, p4, p5); \
  382. } \
  383. }
  384. #define FUNC5RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  385. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) const override { \
  386. if (Thread::get_caller_id() != server_thread) { \
  387. m_r ret; \
  388. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, &ret); \
  389. SYNC_DEBUG \
  390. return ret; \
  391. } else { \
  392. command_queue.flush_if_pending(); \
  393. return server_name->m_type(p1, p2, p3, p4, p5); \
  394. } \
  395. }
  396. #define FUNC5S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  397. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) override { \
  398. WRITE_ACTION \
  399. if (Thread::get_caller_id() != server_thread) { \
  400. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  401. SYNC_DEBUG \
  402. } else { \
  403. command_queue.flush_if_pending(); \
  404. server_name->m_type(p1, p2, p3, p4, p5); \
  405. } \
  406. }
  407. #define FUNC5SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  408. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) const override { \
  409. if (Thread::get_caller_id() != server_thread) { \
  410. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  411. SYNC_DEBUG \
  412. } else { \
  413. command_queue.flush_if_pending(); \
  414. server_name->m_type(p1, p2, p3, p4, p5); \
  415. } \
  416. }
  417. #define FUNC5(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  418. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) override { \
  419. WRITE_ACTION \
  420. if (Thread::get_caller_id() != server_thread) { \
  421. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  422. } else { \
  423. command_queue.flush_if_pending(); \
  424. server_name->m_type(p1, p2, p3, p4, p5); \
  425. } \
  426. }
  427. #define FUNC5C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  428. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) const override { \
  429. if (Thread::get_caller_id() != server_thread) { \
  430. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  431. } else { \
  432. command_queue.flush_if_pending(); \
  433. server_name->m_type(p1, p2, p3, p4, p5); \
  434. } \
  435. }
  436. #define FUNC6R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  437. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) { \
  438. WRITE_ACTION \
  439. if (Thread::get_caller_id() != server_thread) { \
  440. m_r ret; \
  441. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, &ret); \
  442. SYNC_DEBUG \
  443. return ret; \
  444. } else { \
  445. command_queue.flush_if_pending(); \
  446. return server_name->m_type(p1, p2, p3, p4, p5, p6); \
  447. } \
  448. }
  449. #define FUNC6RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  450. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) const override { \
  451. if (Thread::get_caller_id() != server_thread) { \
  452. m_r ret; \
  453. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, &ret); \
  454. SYNC_DEBUG \
  455. return ret; \
  456. } else { \
  457. command_queue.flush_if_pending(); \
  458. return server_name->m_type(p1, p2, p3, p4, p5, p6); \
  459. } \
  460. }
  461. #define FUNC6S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  462. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) override { \
  463. WRITE_ACTION \
  464. if (Thread::get_caller_id() != server_thread) { \
  465. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  466. SYNC_DEBUG \
  467. } else { \
  468. command_queue.flush_if_pending(); \
  469. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  470. } \
  471. }
  472. #define FUNC6SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  473. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) const override { \
  474. if (Thread::get_caller_id() != server_thread) { \
  475. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  476. SYNC_DEBUG \
  477. } else { \
  478. command_queue.flush_if_pending(); \
  479. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  480. } \
  481. }
  482. #define FUNC6(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  483. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) override { \
  484. WRITE_ACTION \
  485. if (Thread::get_caller_id() != server_thread) { \
  486. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  487. } else { \
  488. command_queue.flush_if_pending(); \
  489. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  490. } \
  491. }
  492. #define FUNC6C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  493. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) const override { \
  494. if (Thread::get_caller_id() != server_thread) { \
  495. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  496. } else { \
  497. command_queue.flush_if_pending(); \
  498. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  499. } \
  500. }
  501. #define FUNC7R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  502. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7) override { \
  503. WRITE_ACTION \
  504. if (Thread::get_caller_id() != server_thread) { \
  505. m_r ret; \
  506. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, &ret); \
  507. SYNC_DEBUG \
  508. return ret; \
  509. } else { \
  510. command_queue.flush_if_pending(); \
  511. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  512. } \
  513. }
  514. #define FUNC7RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  515. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7) const override { \
  516. if (Thread::get_caller_id() != server_thread) { \
  517. m_r ret; \
  518. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, &ret); \
  519. SYNC_DEBUG \
  520. return ret; \
  521. } else { \
  522. command_queue.flush_if_pending(); \
  523. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  524. } \
  525. }
  526. #define FUNC7S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  527. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7) override { \
  528. WRITE_ACTION \
  529. if (Thread::get_caller_id() != server_thread) { \
  530. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  531. SYNC_DEBUG \
  532. } else { \
  533. command_queue.flush_if_pending(); \
  534. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  535. } \
  536. }
  537. #define FUNC7SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  538. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7) const override { \
  539. if (Thread::get_caller_id() != server_thread) { \
  540. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  541. SYNC_DEBUG \
  542. } else { \
  543. command_queue.flush_if_pending(); \
  544. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  545. } \
  546. }
  547. #define FUNC7(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  548. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7) override { \
  549. WRITE_ACTION \
  550. if (Thread::get_caller_id() != server_thread) { \
  551. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  552. } else { \
  553. command_queue.flush_if_pending(); \
  554. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  555. } \
  556. }
  557. #define FUNC7C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  558. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7) const override { \
  559. if (Thread::get_caller_id() != server_thread) { \
  560. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  561. } else { \
  562. command_queue.flush_if_pending(); \
  563. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  564. } \
  565. }
  566. #define FUNC8R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  567. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8) override { \
  568. WRITE_ACTION \
  569. if (Thread::get_caller_id() != server_thread) { \
  570. m_r ret; \
  571. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, &ret); \
  572. SYNC_DEBUG \
  573. return ret; \
  574. } else { \
  575. command_queue.flush_if_pending(); \
  576. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  577. } \
  578. }
  579. #define FUNC8RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  580. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8) const override { \
  581. if (Thread::get_caller_id() != server_thread) { \
  582. m_r ret; \
  583. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, &ret); \
  584. SYNC_DEBUG \
  585. return ret; \
  586. } else { \
  587. command_queue.flush_if_pending(); \
  588. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  589. } \
  590. }
  591. #define FUNC8S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  592. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8) override { \
  593. WRITE_ACTION \
  594. if (Thread::get_caller_id() != server_thread) { \
  595. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  596. SYNC_DEBUG \
  597. } else { \
  598. command_queue.flush_if_pending(); \
  599. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  600. } \
  601. }
  602. #define FUNC8SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  603. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8) const override { \
  604. if (Thread::get_caller_id() != server_thread) { \
  605. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  606. SYNC_DEBUG \
  607. } else { \
  608. command_queue.flush_if_pending(); \
  609. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  610. } \
  611. }
  612. #define FUNC8(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  613. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8) override { \
  614. WRITE_ACTION \
  615. if (Thread::get_caller_id() != server_thread) { \
  616. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  617. } else { \
  618. command_queue.flush_if_pending(); \
  619. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  620. } \
  621. }
  622. #define FUNC8C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  623. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8) const override { \
  624. if (Thread::get_caller_id() != server_thread) { \
  625. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  626. } else { \
  627. command_queue.flush_if_pending(); \
  628. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  629. } \
  630. }
  631. #define FUNC9(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9) \
  632. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9) override { \
  633. WRITE_ACTION \
  634. if (Thread::get_caller_id() != server_thread) { \
  635. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9); \
  636. } else { \
  637. command_queue.flush_if_pending(); \
  638. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9); \
  639. } \
  640. }
  641. #define FUNC10(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9, m_arg10) \
  642. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9, m_arg10 p10) override { \
  643. WRITE_ACTION \
  644. if (Thread::get_caller_id() != server_thread) { \
  645. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9, p10); \
  646. } else { \
  647. command_queue.flush_if_pending(); \
  648. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9, p10); \
  649. } \
  650. }
  651. #define FUNC11(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9, m_arg10, m_arg11) \
  652. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9, m_arg10 p10, m_arg11 p11) override { \
  653. WRITE_ACTION \
  654. if (Thread::get_caller_id() != server_thread) { \
  655. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11); \
  656. } else { \
  657. command_queue.flush_if_pending(); \
  658. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11); \
  659. } \
  660. }
  661. #define FUNC12(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9, m_arg10, m_arg11, m_arg12) \
  662. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9, m_arg10 p10, m_arg11 p11, m_arg12 p12) override { \
  663. WRITE_ACTION \
  664. if (Thread::get_caller_id() != server_thread) { \
  665. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12); \
  666. } else { \
  667. command_queue.flush_if_pending(); \
  668. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12); \
  669. } \
  670. }
  671. #define FUNC13(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9, m_arg10, m_arg11, m_arg12, m_arg13) \
  672. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9, m_arg10 p10, m_arg11 p11, m_arg12 p12, m_arg13 p13) override { \
  673. WRITE_ACTION \
  674. if (Thread::get_caller_id() != server_thread) { \
  675. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13); \
  676. } else { \
  677. command_queue.flush_if_pending(); \
  678. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13); \
  679. } \
  680. }
  681. #define FUNC14(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9, m_arg10, m_arg11, m_arg12, m_arg13, m_arg14) \
  682. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9, m_arg10 p10, m_arg11 p11, m_arg12 p12, m_arg13 p13, m_arg14 p14) override { \
  683. WRITE_ACTION \
  684. if (Thread::get_caller_id() != server_thread) { \
  685. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13, p14); \
  686. } else { \
  687. command_queue.flush_if_pending(); \
  688. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13, p14); \
  689. } \
  690. }
  691. #define FUNC15(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8, m_arg9, m_arg10, m_arg11, m_arg12, m_arg13, m_arg14, m_arg15) \
  692. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6, m_arg7 p7, m_arg8 p8, m_arg9 p9, m_arg10 p10, m_arg11 p11, m_arg12 p12, m_arg13 p13, m_arg14 p14, m_arg15 p15) override { \
  693. WRITE_ACTION \
  694. if (Thread::get_caller_id() != server_thread) { \
  695. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13, p14, p15); \
  696. } else { \
  697. command_queue.flush_if_pending(); \
  698. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8, p9, p10, p11, p12, p13, p14, p15); \
  699. } \
  700. }