restvar.cpp 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306
  1. #include "restvar.h"
  2. /////////////////////////////////////////////////////////////////////////////
  3. CRestVariable::CRestVariable(void *pData, const std::type_info &rti, HSHM hShm, const char *pszName, int nIndex, CRest *pParent)
  4. : m_name(pszName), m_pszPath(NULL), m_nIndex(nIndex), m_vt(VT_Invalid), m_data({NULL}), m_pParent(pParent), m_nCbVarpath(0)
  5. {
  6. if(!pData || !hShm)
  7. {
  8. ASSERT(false);
  9. return;
  10. }
  11. m_data.pVoid = pData;
  12. m_hShm = hShm;
  13. if(rti == typeid(bool))
  14. {
  15. m_vt = VT_bool;
  16. }
  17. else if(rti == typeid(char))
  18. {
  19. #ifdef __CHAR_UNSIGNED__
  20. m_vt = VT_UI1;
  21. #else
  22. m_vt = VT_I1;
  23. #endif
  24. }
  25. else if(rti == typeid(signed char))
  26. {
  27. m_vt = VT_I1;
  28. }
  29. else if(rti == typeid(unsigned char))
  30. {
  31. m_vt = VT_UI1;
  32. }
  33. else if(rti == typeid(short))
  34. {
  35. m_vt = VT_I2;
  36. }
  37. else if(rti == typeid(unsigned short))
  38. {
  39. m_vt = VT_UI2;
  40. }
  41. else if(rti == typeid(int))
  42. {
  43. m_vt = VT_I4;
  44. }
  45. else if(rti == typeid(unsigned int))
  46. {
  47. m_vt = VT_UI4;
  48. }
  49. else if(rti == typeid(long))
  50. {
  51. if(sizeof(long) == sizeof(long long))
  52. {
  53. m_vt = VT_I8;
  54. }
  55. else
  56. {
  57. m_vt = VT_I4;
  58. }
  59. }
  60. else if(rti == typeid(unsigned long))
  61. {
  62. if(sizeof(unsigned long) == sizeof(unsigned long long))
  63. {
  64. m_vt = VT_UI8;
  65. }
  66. else
  67. {
  68. m_vt = VT_UI4;
  69. }
  70. }
  71. else if(rti == typeid(long long))
  72. {
  73. m_vt = VT_I8;
  74. }
  75. else if(rti == typeid(unsigned long long))
  76. {
  77. m_vt = VT_UI8;
  78. }
  79. else if(rti == typeid(float))
  80. {
  81. m_vt = VT_float;
  82. }
  83. else if(rti == typeid(double))
  84. {
  85. m_vt = VT_double;
  86. }
  87. else
  88. {
  89. ASSERT(false);
  90. }
  91. }
  92. CRestVariable::~CRestVariable(void)
  93. {
  94. }
  95. /////////////////////////////////////////////////////////////////////////////
  96. void CRestVariable::CreateMembersTable(CRestVarTable &vt)
  97. {
  98. vt.AddVar(static_cast<CRest*>(this));
  99. }
  100. void CRestVariable::InitPath(CRest *pParent, const char *pszMemberName, int nIndex)
  101. {
  102. CRest::CreatePath(pParent, pszMemberName, nIndex, m_path);
  103. m_pszPath = m_path.c_str();
  104. m_nCbVarpath = m_path.length();
  105. }
  106. void CRestVariable::GetValue(int nReqIndex, json_t *pjtMap)
  107. {
  108. json_array_append_new(pjtMap, GetValue(nReqIndex));
  109. }
  110. json_t* CRestVariable::GetValue(int nReqIndex)
  111. {
  112. json_t *pjtVal = NULL;
  113. Lock();
  114. switch(m_vt)
  115. {
  116. case VT_bool:
  117. pjtVal = json_boolean(*m_data.pBool);
  118. break;
  119. case VT_I1:
  120. pjtVal = json_integer((json_int_t)*m_data.pI1);
  121. break;
  122. case VT_UI1:
  123. pjtVal = json_integer((json_int_t)*m_data.pUI1);
  124. break;
  125. case VT_I2:
  126. pjtVal = json_integer((json_int_t)*m_data.pI2);
  127. break;
  128. case VT_UI2:
  129. pjtVal = json_integer((json_int_t)*m_data.pUI2);
  130. break;
  131. case VT_I4:
  132. pjtVal = json_integer((json_int_t)*m_data.pI4);
  133. break;
  134. case VT_UI4:
  135. pjtVal = json_integer((json_int_t)*m_data.pUI4);
  136. break;
  137. case VT_I8:
  138. pjtVal = json_integer((json_int_t)*m_data.pI8);
  139. break;
  140. case VT_UI8:
  141. pjtVal = json_integer((json_int_t)*m_data.pUI8);
  142. break;
  143. case VT_float:
  144. pjtVal = json_real((double)*m_data.pFloat);
  145. break;
  146. case VT_double:
  147. pjtVal = json_real(*m_data.pDouble);
  148. break;
  149. default:
  150. ASSERT(false);
  151. break;
  152. }
  153. Unlock();
  154. if(pjtVal)
  155. return CreateValueObject(nReqIndex, m_pszPath, m_nIndex, json_typeof(pjtVal), m_name.c_str(), pjtVal);
  156. else
  157. return CreateStatusObject(nReqIndex, -1, "Unexpected Error!", m_pszPath);
  158. }
  159. json_t* CRestVariable::SetValue(int nReqIndex, json_t *pjtVal)
  160. {
  161. if(!pjtVal)
  162. return CreateStatusObject(nReqIndex, -1, "Unexpected error!", GetPath());
  163. json_int_t jInt;
  164. double jReal;
  165. int nCode = 0;
  166. const char *pszMsg = NULL;
  167. int nType = json_typeof(pjtVal);
  168. switch(nType)
  169. {
  170. case JSON_INTEGER:
  171. jInt = json_integer_value(pjtVal);
  172. switch(m_vt)
  173. {
  174. case VT_bool:
  175. Lock();
  176. *m_data.pBool = !!jInt;
  177. Unlock();
  178. break;
  179. case VT_I1:
  180. Lock();
  181. *m_data.pI1 = (signed char)jInt;
  182. Unlock();
  183. break;
  184. case VT_UI1:
  185. Lock();
  186. *m_data.pUI1 = (unsigned char)jInt;
  187. Unlock();
  188. break;
  189. case VT_I2:
  190. Lock();
  191. *m_data.pI2 = (signed short)jInt;
  192. Unlock();
  193. break;
  194. case VT_UI2:
  195. Lock();
  196. *m_data.pUI2 = (unsigned short)jInt;
  197. Unlock();
  198. break;
  199. case VT_I4:
  200. Lock();
  201. *m_data.pI4 = (signed int)jInt;
  202. Unlock();
  203. break;
  204. case VT_UI4:
  205. Lock();
  206. *m_data.pUI4 = (unsigned int)jInt;
  207. Unlock();
  208. break;
  209. case VT_I8:
  210. Lock();
  211. *m_data.pI8 = (signed long long)jInt;
  212. Unlock();
  213. break;
  214. case VT_UI8:
  215. Lock();
  216. *m_data.pUI8 = (unsigned long long)jInt;
  217. Unlock();
  218. break;
  219. case VT_float:
  220. Lock();
  221. *m_data.pFloat = (float)jInt;
  222. Unlock();
  223. break;
  224. case VT_double:
  225. Lock();
  226. *m_data.pDouble = (double)jInt;
  227. Unlock();
  228. break;
  229. default:
  230. nCode = 1;
  231. pszMsg = "Cannot assign JSON integer value! Variable is not an integer or real type!";
  232. break;
  233. }
  234. break;
  235. case JSON_REAL:
  236. jReal = json_real_value(pjtVal);
  237. switch(m_vt)
  238. {
  239. case VT_float:
  240. Lock();
  241. *m_data.pFloat = (float)jReal;
  242. Unlock();
  243. break;
  244. case VT_double:
  245. Lock();
  246. *m_data.pDouble = jReal;
  247. Unlock();
  248. break;
  249. default:
  250. nCode = 2;
  251. pszMsg = "Cannot assign JSON real value! Variable is not of type real!";
  252. break;
  253. }
  254. break;
  255. case JSON_TRUE:
  256. case JSON_FALSE:
  257. switch(m_vt)
  258. {
  259. case VT_bool:
  260. Lock();
  261. *m_data.pBool = (nType == JSON_TRUE);
  262. Unlock();
  263. break;
  264. default:
  265. nCode = 3;
  266. pszMsg = "Cannot assign JSON bool value! Variable is not of type bool!";
  267. break;
  268. }
  269. break;
  270. default:
  271. nCode = 4;
  272. pszMsg = "Cannot assign incompatible JSON type!";
  273. break;
  274. }
  275. return CreateStatusObject(nReqIndex, nCode, pszMsg, GetPath());
  276. }
  277. /////////////////////////////////////////////////////////////////////////////
  278. void CRestVariable::Lock(void)
  279. {
  280. ::GfaIpcLockSHM(m_hShm);
  281. }
  282. void CRestVariable::Unlock(void)
  283. {
  284. ::GfaIpcUnlockSHM(m_hShm);
  285. }