2
0

server_wrap_mt_common.h 55 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749
  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-2019 Juan Linietsky, Ariel Manzur. */
  9. /* Copyright (c) 2014-2019 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() { \
  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. return server_name->m_type(); \
  39. } \
  40. }
  41. #define FUNCRID(m_type) \
  42. int m_type##allocn() { \
  43. for (int i = 0; i < m_type##_pool_max_size; i++) { \
  44. m_type##_id_pool.push_back(server_name->m_type##_create()); \
  45. } \
  46. return 0; \
  47. } \
  48. void m_type##_free_cached_ids() { \
  49. while (m_type##_id_pool.size()) { \
  50. free(m_type##_id_pool.front()->get()); \
  51. m_type##_id_pool.pop_front(); \
  52. } \
  53. } \
  54. virtual RID m_type##_create() { \
  55. if (Thread::get_caller_ID() != server_thread) { \
  56. RID rid; \
  57. alloc_mutex->lock(); \
  58. if (m_type##_id_pool.size() == 0) { \
  59. int ret; \
  60. command_queue.push_and_ret(this, &ServerNameWrapMT::m_type##allocn, &ret); \
  61. } \
  62. rid = m_type##_id_pool.front()->get(); \
  63. m_type##_id_pool.pop_front(); \
  64. alloc_mutex->unlock(); \
  65. return rid; \
  66. } else { \
  67. return server_name->m_type##_create(); \
  68. } \
  69. }
  70. #define FUNC1RID(m_type, m_arg1) \
  71. int m_type##allocn() { \
  72. for (int i = 0; i < m_type##_pool_max_size; i++) { \
  73. m_type##_id_pool.push_back(server_name->m_type##_create()); \
  74. } \
  75. return 0; \
  76. } \
  77. void m_type##_free_cached_ids() { \
  78. while (m_type##_id_pool.size()) { \
  79. free(m_type##_id_pool.front()->get()); \
  80. m_type##_id_pool.pop_front(); \
  81. } \
  82. } \
  83. virtual RID m_type##_create(m_arg1 p1) { \
  84. if (Thread::get_caller_ID() != server_thread) { \
  85. RID rid; \
  86. alloc_mutex->lock(); \
  87. if (m_type##_id_pool.size() == 0) { \
  88. int ret; \
  89. command_queue.push_and_ret(this, &ServerNameWrapMT::m_type##allocn, p1, &ret); \
  90. } \
  91. rid = m_type##_id_pool.front()->get(); \
  92. m_type##_id_pool.pop_front(); \
  93. alloc_mutex->unlock(); \
  94. return rid; \
  95. } else { \
  96. return server_name->m_type##_create(p1); \
  97. } \
  98. }
  99. #define FUNC2RID(m_type, m_arg1, m_arg2) \
  100. int m_type##allocn() { \
  101. for (int i = 0; i < m_type##_pool_max_size; i++) { \
  102. m_type##_id_pool.push_back(server_name->m_type##_create()); \
  103. } \
  104. return 0; \
  105. } \
  106. void m_type##_free_cached_ids() { \
  107. while (m_type##_id_pool.size()) { \
  108. free(m_type##_id_pool.front()->get()); \
  109. m_type##_id_pool.pop_front(); \
  110. } \
  111. } \
  112. virtual RID m_type##_create(m_arg1 p1, m_arg2 p2) { \
  113. if (Thread::get_caller_ID() != server_thread) { \
  114. RID rid; \
  115. alloc_mutex->lock(); \
  116. if (m_type##_id_pool.size() == 0) { \
  117. int ret; \
  118. command_queue.push_and_ret(this, &ServerNameWrapMT::m_type##allocn, p1, p2, &ret); \
  119. } \
  120. rid = m_type##_id_pool.front()->get(); \
  121. m_type##_id_pool.pop_front(); \
  122. alloc_mutex->unlock(); \
  123. return rid; \
  124. } else { \
  125. return server_name->m_type##_create(p1, p2); \
  126. } \
  127. }
  128. #define FUNC3RID(m_type, m_arg1, m_arg2, m_arg3) \
  129. int m_type##allocn() { \
  130. for (int i = 0; i < m_type##_pool_max_size; i++) { \
  131. m_type##_id_pool.push_back(server_name->m_type##_create()); \
  132. } \
  133. return 0; \
  134. } \
  135. void m_type##_free_cached_ids() { \
  136. while (m_type##_id_pool.size()) { \
  137. free(m_type##_id_pool.front()->get()); \
  138. m_type##_id_pool.pop_front(); \
  139. } \
  140. } \
  141. virtual RID m_type##_create(m_arg1 p1, m_arg2 p2, m_arg3 p3) { \
  142. if (Thread::get_caller_ID() != server_thread) { \
  143. RID rid; \
  144. alloc_mutex->lock(); \
  145. if (m_type##_id_pool.size() == 0) { \
  146. int ret; \
  147. command_queue.push_and_ret(this, &ServerNameWrapMT::m_type##allocn, p1, p2, p3, &ret); \
  148. } \
  149. rid = m_type##_id_pool.front()->get(); \
  150. m_type##_id_pool.pop_front(); \
  151. alloc_mutex->unlock(); \
  152. return rid; \
  153. } else { \
  154. return server_name->m_type##_create(p1, p2, p3); \
  155. } \
  156. }
  157. #define FUNC4RID(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  158. int m_type##allocn() { \
  159. for (int i = 0; i < m_type##_pool_max_size; i++) { \
  160. m_type##_id_pool.push_back(server_name->m_type##_create()); \
  161. } \
  162. return 0; \
  163. } \
  164. void m_type##_free_cached_ids() { \
  165. while (m_type##_id_pool.size()) { \
  166. free(m_type##_id_pool.front()->get()); \
  167. m_type##_id_pool.pop_front(); \
  168. } \
  169. } \
  170. virtual RID m_type##_create(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) { \
  171. if (Thread::get_caller_ID() != server_thread) { \
  172. RID rid; \
  173. alloc_mutex->lock(); \
  174. if (m_type##_id_pool.size() == 0) { \
  175. int ret; \
  176. command_queue.push_and_ret(this, &ServerNameWrapMT::m_type##allocn, p1, p2, p3, p4, &ret); \
  177. } \
  178. rid = m_type##_id_pool.front()->get(); \
  179. m_type##_id_pool.pop_front(); \
  180. alloc_mutex->unlock(); \
  181. return rid; \
  182. } else { \
  183. return server_name->m_type##_create(p1, p2, p3, p4); \
  184. } \
  185. }
  186. #define FUNC5RID(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  187. int m_type##allocn() { \
  188. for (int i = 0; i < m_type##_pool_max_size; i++) { \
  189. m_type##_id_pool.push_back(server_name->m_type##_create()); \
  190. } \
  191. return 0; \
  192. } \
  193. void m_type##_free_cached_ids() { \
  194. while (m_type##_id_pool.size()) { \
  195. free(m_type##_id_pool.front()->get()); \
  196. m_type##_id_pool.pop_front(); \
  197. } \
  198. } \
  199. virtual RID m_type##_create(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) { \
  200. if (Thread::get_caller_ID() != server_thread) { \
  201. RID rid; \
  202. alloc_mutex->lock(); \
  203. if (m_type##_id_pool.size() == 0) { \
  204. int ret; \
  205. command_queue.push_and_ret(this, &ServerNameWrapMT::m_type##allocn, p1, p2, p3, p4, p5, &ret); \
  206. } \
  207. rid = m_type##_id_pool.front()->get(); \
  208. m_type##_id_pool.pop_front(); \
  209. alloc_mutex->unlock(); \
  210. return rid; \
  211. } else { \
  212. return server_name->m_type##_create(p1, p2, p3, p4, p5); \
  213. } \
  214. }
  215. #define FUNC0RC(m_r, m_type) \
  216. virtual m_r m_type() const { \
  217. if (Thread::get_caller_ID() != server_thread) { \
  218. m_r ret; \
  219. command_queue.push_and_ret(server_name, &ServerName::m_type, &ret); \
  220. SYNC_DEBUG \
  221. return ret; \
  222. } else { \
  223. return server_name->m_type(); \
  224. } \
  225. }
  226. #define FUNC0(m_type) \
  227. virtual void m_type() { \
  228. if (Thread::get_caller_ID() != server_thread) { \
  229. command_queue.push(server_name, &ServerName::m_type); \
  230. } else { \
  231. server_name->m_type(); \
  232. } \
  233. }
  234. #define FUNC0C(m_type) \
  235. virtual void m_type() const { \
  236. if (Thread::get_caller_ID() != server_thread) { \
  237. command_queue.push(server_name, &ServerName::m_type); \
  238. } else { \
  239. server_name->m_type(); \
  240. } \
  241. }
  242. #define FUNC0S(m_type) \
  243. virtual void m_type() { \
  244. if (Thread::get_caller_ID() != server_thread) { \
  245. command_queue.push_and_sync(server_name, &ServerName::m_type); \
  246. } else { \
  247. server_name->m_type(); \
  248. } \
  249. }
  250. #define FUNC0SC(m_type) \
  251. virtual void m_type() const { \
  252. if (Thread::get_caller_ID() != server_thread) { \
  253. command_queue.push_and_sync(server_name, &ServerName::m_type); \
  254. } else { \
  255. server_name->m_type(); \
  256. } \
  257. }
  258. ///////////////////////////////////////////////
  259. #define FUNC1R(m_r, m_type, m_arg1) \
  260. virtual m_r m_type(m_arg1 p1) { \
  261. if (Thread::get_caller_ID() != server_thread) { \
  262. m_r ret; \
  263. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, &ret); \
  264. SYNC_DEBUG \
  265. return ret; \
  266. } else { \
  267. return server_name->m_type(p1); \
  268. } \
  269. }
  270. #define FUNC1RC(m_r, m_type, m_arg1) \
  271. virtual m_r m_type(m_arg1 p1) const { \
  272. if (Thread::get_caller_ID() != server_thread) { \
  273. m_r ret; \
  274. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, &ret); \
  275. SYNC_DEBUG \
  276. return ret; \
  277. } else { \
  278. return server_name->m_type(p1); \
  279. } \
  280. }
  281. #define FUNC1S(m_type, m_arg1) \
  282. virtual void m_type(m_arg1 p1) { \
  283. if (Thread::get_caller_ID() != server_thread) { \
  284. command_queue.push_and_sync(server_name, &ServerName::m_type, p1); \
  285. } else { \
  286. server_name->m_type(p1); \
  287. } \
  288. }
  289. #define FUNC1SC(m_type, m_arg1) \
  290. virtual void m_type(m_arg1 p1) const { \
  291. if (Thread::get_caller_ID() != server_thread) { \
  292. command_queue.push_and_sync(server_name, &ServerName::m_type, p1); \
  293. } else { \
  294. server_name->m_type(p1); \
  295. } \
  296. }
  297. #define FUNC1(m_type, m_arg1) \
  298. virtual void m_type(m_arg1 p1) { \
  299. if (Thread::get_caller_ID() != server_thread) { \
  300. command_queue.push(server_name, &ServerName::m_type, p1); \
  301. } else { \
  302. server_name->m_type(p1); \
  303. } \
  304. }
  305. #define FUNC1C(m_type, m_arg1) \
  306. virtual void m_type(m_arg1 p1) const { \
  307. if (Thread::get_caller_ID() != server_thread) { \
  308. command_queue.push(server_name, &ServerName::m_type, p1); \
  309. } else { \
  310. server_name->m_type(p1); \
  311. } \
  312. }
  313. #define FUNC2R(m_r, m_type, m_arg1, m_arg2) \
  314. virtual m_r m_type(m_arg1 p1, m_arg2 p2) { \
  315. if (Thread::get_caller_ID() != server_thread) { \
  316. m_r ret; \
  317. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, &ret); \
  318. SYNC_DEBUG \
  319. return ret; \
  320. } else { \
  321. return server_name->m_type(p1, p2); \
  322. } \
  323. }
  324. #define FUNC2RC(m_r, m_type, m_arg1, m_arg2) \
  325. virtual m_r m_type(m_arg1 p1, m_arg2 p2) const { \
  326. if (Thread::get_caller_ID() != server_thread) { \
  327. m_r ret; \
  328. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, &ret); \
  329. SYNC_DEBUG \
  330. return ret; \
  331. } else { \
  332. return server_name->m_type(p1, p2); \
  333. } \
  334. }
  335. #define FUNC2S(m_type, m_arg1, m_arg2) \
  336. virtual void m_type(m_arg1 p1, m_arg2 p2) { \
  337. if (Thread::get_caller_ID() != server_thread) { \
  338. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2); \
  339. } else { \
  340. server_name->m_type(p1, p2); \
  341. } \
  342. }
  343. #define FUNC2SC(m_type, m_arg1, m_arg2) \
  344. virtual void m_type(m_arg1 p1, m_arg2 p2) const { \
  345. if (Thread::get_caller_ID() != server_thread) { \
  346. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2); \
  347. } else { \
  348. server_name->m_type(p1, p2); \
  349. } \
  350. }
  351. #define FUNC2(m_type, m_arg1, m_arg2) \
  352. virtual void m_type(m_arg1 p1, m_arg2 p2) { \
  353. if (Thread::get_caller_ID() != server_thread) { \
  354. command_queue.push(server_name, &ServerName::m_type, p1, p2); \
  355. } else { \
  356. server_name->m_type(p1, p2); \
  357. } \
  358. }
  359. #define FUNC2C(m_type, m_arg1, m_arg2) \
  360. virtual void m_type(m_arg1 p1, m_arg2 p2) const { \
  361. if (Thread::get_caller_ID() != server_thread) { \
  362. command_queue.push(server_name, &ServerName::m_type, p1, p2); \
  363. } else { \
  364. server_name->m_type(p1, p2); \
  365. } \
  366. }
  367. #define FUNC3R(m_r, m_type, m_arg1, m_arg2, m_arg3) \
  368. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) { \
  369. if (Thread::get_caller_ID() != server_thread) { \
  370. m_r ret; \
  371. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, &ret); \
  372. SYNC_DEBUG \
  373. return ret; \
  374. } else { \
  375. return server_name->m_type(p1, p2, p3); \
  376. } \
  377. }
  378. #define FUNC3RC(m_r, m_type, m_arg1, m_arg2, m_arg3) \
  379. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) const { \
  380. if (Thread::get_caller_ID() != server_thread) { \
  381. m_r ret; \
  382. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, &ret); \
  383. return ret; \
  384. } else { \
  385. return server_name->m_type(p1, p2, p3); \
  386. } \
  387. }
  388. #define FUNC3S(m_type, m_arg1, m_arg2, m_arg3) \
  389. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) { \
  390. if (Thread::get_caller_ID() != server_thread) { \
  391. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3); \
  392. } else { \
  393. server_name->m_type(p1, p2, p3); \
  394. } \
  395. }
  396. #define FUNC3SC(m_type, m_arg1, m_arg2, m_arg3) \
  397. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) const { \
  398. if (Thread::get_caller_ID() != server_thread) { \
  399. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3); \
  400. } else { \
  401. server_name->m_type(p1, p2, p3); \
  402. } \
  403. }
  404. #define FUNC3(m_type, m_arg1, m_arg2, m_arg3) \
  405. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) { \
  406. if (Thread::get_caller_ID() != server_thread) { \
  407. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3); \
  408. } else { \
  409. server_name->m_type(p1, p2, p3); \
  410. } \
  411. }
  412. #define FUNC3C(m_type, m_arg1, m_arg2, m_arg3) \
  413. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3) const { \
  414. if (Thread::get_caller_ID() != server_thread) { \
  415. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3); \
  416. } else { \
  417. server_name->m_type(p1, p2, p3); \
  418. } \
  419. }
  420. #define FUNC4R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  421. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) { \
  422. if (Thread::get_caller_ID() != server_thread) { \
  423. m_r ret; \
  424. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, &ret); \
  425. SYNC_DEBUG \
  426. return ret; \
  427. } else { \
  428. return server_name->m_type(p1, p2, p3, p4); \
  429. } \
  430. }
  431. #define FUNC4RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  432. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) const { \
  433. if (Thread::get_caller_ID() != server_thread) { \
  434. m_r ret; \
  435. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, &ret); \
  436. SYNC_DEBUG \
  437. return ret; \
  438. } else { \
  439. return server_name->m_type(p1, p2, p3, p4); \
  440. } \
  441. }
  442. #define FUNC4S(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  443. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) { \
  444. if (Thread::get_caller_ID() != server_thread) { \
  445. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  446. } else { \
  447. server_name->m_type(p1, p2, p3, p4); \
  448. } \
  449. }
  450. #define FUNC4SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  451. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) const { \
  452. if (Thread::get_caller_ID() != server_thread) { \
  453. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  454. } else { \
  455. server_name->m_type(p1, p2, p3, p4); \
  456. } \
  457. }
  458. #define FUNC4(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  459. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) { \
  460. if (Thread::get_caller_ID() != server_thread) { \
  461. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  462. } else { \
  463. server_name->m_type(p1, p2, p3, p4); \
  464. } \
  465. }
  466. #define FUNC4C(m_type, m_arg1, m_arg2, m_arg3, m_arg4) \
  467. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4) const { \
  468. if (Thread::get_caller_ID() != server_thread) { \
  469. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4); \
  470. } else { \
  471. server_name->m_type(p1, p2, p3, p4); \
  472. } \
  473. }
  474. #define FUNC5R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  475. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) { \
  476. if (Thread::get_caller_ID() != server_thread) { \
  477. m_r ret; \
  478. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, &ret); \
  479. SYNC_DEBUG \
  480. return ret; \
  481. } else { \
  482. return server_name->m_type(p1, p2, p3, p4, p5); \
  483. } \
  484. }
  485. #define FUNC5RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  486. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) const { \
  487. if (Thread::get_caller_ID() != server_thread) { \
  488. m_r ret; \
  489. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, &ret); \
  490. SYNC_DEBUG \
  491. return ret; \
  492. } else { \
  493. return server_name->m_type(p1, p2, p3, p4, p5); \
  494. } \
  495. }
  496. #define FUNC5S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  497. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) { \
  498. if (Thread::get_caller_ID() != server_thread) { \
  499. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  500. } else { \
  501. server_name->m_type(p1, p2, p3, p4, p5); \
  502. } \
  503. }
  504. #define FUNC5SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  505. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) const { \
  506. if (Thread::get_caller_ID() != server_thread) { \
  507. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  508. } else { \
  509. server_name->m_type(p1, p2, p3, p4, p5); \
  510. } \
  511. }
  512. #define FUNC5(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  513. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) { \
  514. if (Thread::get_caller_ID() != server_thread) { \
  515. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  516. } else { \
  517. server_name->m_type(p1, p2, p3, p4, p5); \
  518. } \
  519. }
  520. #define FUNC5C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5) \
  521. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5) const { \
  522. if (Thread::get_caller_ID() != server_thread) { \
  523. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5); \
  524. } else { \
  525. server_name->m_type(p1, p2, p3, p4, p5); \
  526. } \
  527. }
  528. #define FUNC6R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  529. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) { \
  530. if (Thread::get_caller_ID() != server_thread) { \
  531. m_r ret; \
  532. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, &ret); \
  533. SYNC_DEBUG \
  534. return ret; \
  535. } else { \
  536. return server_name->m_type(p1, p2, p3, p4, p5, p6); \
  537. } \
  538. }
  539. #define FUNC6RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  540. virtual m_r m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) const { \
  541. if (Thread::get_caller_ID() != server_thread) { \
  542. m_r ret; \
  543. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, &ret); \
  544. return ret; \
  545. } else { \
  546. return server_name->m_type(p1, p2, p3, p4, p5, p6); \
  547. } \
  548. }
  549. #define FUNC6S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  550. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) { \
  551. if (Thread::get_caller_ID() != server_thread) { \
  552. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  553. } else { \
  554. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  555. } \
  556. }
  557. #define FUNC6SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  558. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) const { \
  559. if (Thread::get_caller_ID() != server_thread) { \
  560. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  561. } else { \
  562. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  563. } \
  564. }
  565. #define FUNC6(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  566. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) { \
  567. if (Thread::get_caller_ID() != server_thread) { \
  568. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  569. } else { \
  570. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  571. } \
  572. }
  573. #define FUNC6C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6) \
  574. virtual void m_type(m_arg1 p1, m_arg2 p2, m_arg3 p3, m_arg4 p4, m_arg5 p5, m_arg6 p6) const { \
  575. if (Thread::get_caller_ID() != server_thread) { \
  576. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6); \
  577. } else { \
  578. server_name->m_type(p1, p2, p3, p4, p5, p6); \
  579. } \
  580. }
  581. #define FUNC7R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  582. 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) { \
  583. if (Thread::get_caller_ID() != server_thread) { \
  584. m_r ret; \
  585. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, &ret); \
  586. SYNC_DEBUG \
  587. return ret; \
  588. } else { \
  589. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  590. } \
  591. }
  592. #define FUNC7RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  593. 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 { \
  594. if (Thread::get_caller_ID() != server_thread) { \
  595. m_r ret; \
  596. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, &ret); \
  597. SYNC_DEBUG \
  598. return ret; \
  599. } else { \
  600. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  601. } \
  602. }
  603. #define FUNC7S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  604. 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) { \
  605. if (Thread::get_caller_ID() != server_thread) { \
  606. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  607. } else { \
  608. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  609. } \
  610. }
  611. #define FUNC7SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  612. 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 { \
  613. if (Thread::get_caller_ID() != server_thread) { \
  614. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  615. } else { \
  616. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  617. } \
  618. }
  619. #define FUNC7(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  620. 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) { \
  621. if (Thread::get_caller_ID() != server_thread) { \
  622. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  623. } else { \
  624. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  625. } \
  626. }
  627. #define FUNC7C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7) \
  628. 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 { \
  629. if (Thread::get_caller_ID() != server_thread) { \
  630. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7); \
  631. } else { \
  632. server_name->m_type(p1, p2, p3, p4, p5, p6, p7); \
  633. } \
  634. }
  635. #define FUNC8R(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  636. 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) { \
  637. if (Thread::get_caller_ID() != server_thread) { \
  638. m_r ret; \
  639. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, &ret); \
  640. SYNC_DEBUG \
  641. return ret; \
  642. } else { \
  643. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  644. } \
  645. }
  646. #define FUNC8RC(m_r, m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  647. 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 { \
  648. if (Thread::get_caller_ID() != server_thread) { \
  649. m_r ret; \
  650. command_queue.push_and_ret(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8, &ret); \
  651. SYNC_DEBUG \
  652. return ret; \
  653. } else { \
  654. return server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  655. } \
  656. }
  657. #define FUNC8S(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  658. 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) { \
  659. if (Thread::get_caller_ID() != server_thread) { \
  660. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  661. } else { \
  662. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  663. } \
  664. }
  665. #define FUNC8SC(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  666. 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 { \
  667. if (Thread::get_caller_ID() != server_thread) { \
  668. command_queue.push_and_sync(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  669. } else { \
  670. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  671. } \
  672. }
  673. #define FUNC8(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  674. 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) { \
  675. if (Thread::get_caller_ID() != server_thread) { \
  676. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  677. } else { \
  678. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  679. } \
  680. }
  681. #define FUNC8C(m_type, m_arg1, m_arg2, m_arg3, m_arg4, m_arg5, m_arg6, m_arg7, m_arg8) \
  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) const { \
  683. if (Thread::get_caller_ID() != server_thread) { \
  684. command_queue.push(server_name, &ServerName::m_type, p1, p2, p3, p4, p5, p6, p7, p8); \
  685. } else { \
  686. server_name->m_type(p1, p2, p3, p4, p5, p6, p7, p8); \
  687. } \
  688. }