llsdmessagebuilder.cpp
上传用户:king477883
上传日期:2021-03-01
资源大小:9553k
文件大小:10k
源码类别:

游戏引擎

开发平台:

C++ Builder

  1. /** 
  2.  * @file llsdmessagebuilder.cpp
  3.  * @brief LLSDMessageBuilder class implementation.
  4.  *
  5.  * $LicenseInfo:firstyear=2007&license=viewergpl$
  6.  * 
  7.  * Copyright (c) 2007-2010, Linden Research, Inc.
  8.  * 
  9.  * Second Life Viewer Source Code
  10.  * The source code in this file ("Source Code") is provided by Linden Lab
  11.  * to you under the terms of the GNU General Public License, version 2.0
  12.  * ("GPL"), unless you have obtained a separate licensing agreement
  13.  * ("Other License"), formally executed by you and Linden Lab.  Terms of
  14.  * the GPL can be found in doc/GPL-license.txt in this distribution, or
  15.  * online at http://secondlifegrid.net/programs/open_source/licensing/gplv2
  16.  * 
  17.  * There are special exceptions to the terms and conditions of the GPL as
  18.  * it is applied to this Source Code. View the full text of the exception
  19.  * in the file doc/FLOSS-exception.txt in this software distribution, or
  20.  * online at
  21.  * http://secondlifegrid.net/programs/open_source/licensing/flossexception
  22.  * 
  23.  * By copying, modifying or distributing this software, you acknowledge
  24.  * that you have read and understood your obligations described above,
  25.  * and agree to abide by those obligations.
  26.  * 
  27.  * ALL LINDEN LAB SOURCE CODE IS PROVIDED "AS IS." LINDEN LAB MAKES NO
  28.  * WARRANTIES, EXPRESS, IMPLIED OR OTHERWISE, REGARDING ITS ACCURACY,
  29.  * COMPLETENESS OR PERFORMANCE.
  30.  * $/LicenseInfo$
  31.  */
  32. #include "linden_common.h"
  33. #include "llsdmessagebuilder.h"
  34. #include "llmessagetemplate.h"
  35. #include "llquaternion.h"
  36. #include "llsdutil.h"
  37. #include "llsdutil_math.h"
  38. #include "llsdserialize.h"
  39. #include "u64.h"
  40. #include "v3dmath.h"
  41. #include "v3math.h"
  42. #include "v4math.h"
  43. LLSDMessageBuilder::LLSDMessageBuilder() :
  44. mCurrentMessage(LLSD::emptyMap()),
  45. mCurrentBlock(NULL),
  46. mCurrentMessageName(""),
  47. mCurrentBlockName(""),
  48. mbSBuilt(FALSE),
  49. mbSClear(TRUE)
  50. {
  51. }
  52. //virtual
  53. LLSDMessageBuilder::~LLSDMessageBuilder()
  54. {
  55. }
  56. // virtual
  57. void LLSDMessageBuilder::newMessage(const char* name)
  58. {
  59. mbSBuilt = FALSE;
  60. mbSClear = FALSE;
  61. mCurrentMessage = LLSD::emptyMap();
  62. mCurrentMessageName = (char*)name;
  63. }
  64. // virtual
  65. void LLSDMessageBuilder::clearMessage()
  66. {
  67. mbSBuilt = FALSE;
  68. mbSClear = TRUE;
  69. mCurrentMessage = LLSD::emptyMap();
  70. mCurrentMessageName = "";
  71. }
  72. // virtual
  73. void LLSDMessageBuilder::nextBlock(const char* blockname)
  74. {
  75. LLSD& block = mCurrentMessage[blockname];
  76. if(block.isUndefined())
  77. {
  78. block[0] = LLSD::emptyMap();
  79. mCurrentBlock = &(block[0]);
  80. }
  81. else if(block.isArray())
  82. {
  83. block[block.size()] = LLSD::emptyMap();
  84. mCurrentBlock = &(block[block.size() - 1]);
  85. }
  86. else
  87. {
  88. llerrs << "existing block not array" << llendl;
  89. }
  90. }
  91. // TODO: Remove this horror...
  92. BOOL LLSDMessageBuilder::removeLastBlock()
  93. {
  94. /* TODO: finish implementing this */
  95. return FALSE;
  96. }
  97. void LLSDMessageBuilder::addBinaryData(
  98. const char* varname, 
  99. const void* data,
  100. S32 size)
  101. {
  102. std::vector<U8> v;
  103. v.resize(size);
  104. memcpy(&(v[0]), reinterpret_cast<const U8*>(data), size);
  105. (*mCurrentBlock)[varname] = v;
  106. }
  107. void LLSDMessageBuilder::addS8(const char* varname, S8 v)
  108. {
  109. (*mCurrentBlock)[varname] = v;
  110. }
  111. void LLSDMessageBuilder::addU8(const char* varname, U8 v)
  112. {
  113. (*mCurrentBlock)[varname] = v;
  114. }
  115. void LLSDMessageBuilder::addS16(const char* varname, S16 v)
  116. {
  117. (*mCurrentBlock)[varname] = v;
  118. }
  119. void LLSDMessageBuilder::addU16(const char* varname, U16 v)
  120. {
  121. (*mCurrentBlock)[varname] = v;
  122. }
  123. void LLSDMessageBuilder::addF32(const char* varname, F32 v)
  124. {
  125. (*mCurrentBlock)[varname] = v;
  126. }
  127. void LLSDMessageBuilder::addS32(const char* varname, S32 v)
  128. {
  129. (*mCurrentBlock)[varname] = v;
  130. }
  131. void LLSDMessageBuilder::addU32(const char* varname, U32 v)
  132. {
  133. (*mCurrentBlock)[varname] = ll_sd_from_U32(v);
  134. }
  135. void LLSDMessageBuilder::addU64(const char* varname, U64 v)
  136. {
  137. (*mCurrentBlock)[varname] = ll_sd_from_U64(v);
  138. }
  139. void LLSDMessageBuilder::addF64(const char* varname, F64 v)
  140. {
  141. (*mCurrentBlock)[varname] = v;
  142. }
  143. void LLSDMessageBuilder::addIPAddr(const char* varname, U32 v)
  144. {
  145. (*mCurrentBlock)[varname] = ll_sd_from_ipaddr(v);
  146. }
  147. void LLSDMessageBuilder::addIPPort(const char* varname, U16 v)
  148. {
  149. (*mCurrentBlock)[varname] = v;
  150. }
  151. void LLSDMessageBuilder::addBOOL(const char* varname, BOOL v)
  152. {
  153. (*mCurrentBlock)[varname] = (v == TRUE);
  154. }
  155. void LLSDMessageBuilder::addString(const char* varname, const char* v)
  156. {
  157. if (v)
  158. (*mCurrentBlock)[varname] = v;  /* Flawfinder: ignore */  
  159. else
  160. (*mCurrentBlock)[varname] = ""; 
  161. }
  162. void LLSDMessageBuilder::addString(const char* varname, const std::string& v)
  163. {
  164. if (v.size())
  165. (*mCurrentBlock)[varname] = v; 
  166. else
  167. (*mCurrentBlock)[varname] = ""; 
  168. }
  169. void LLSDMessageBuilder::addVector3(const char* varname, const LLVector3& v)
  170. {
  171. (*mCurrentBlock)[varname] = ll_sd_from_vector3(v);
  172. }
  173. void LLSDMessageBuilder::addVector4(const char* varname, const LLVector4& v)
  174. {
  175. (*mCurrentBlock)[varname] = ll_sd_from_vector4(v);
  176. }
  177. void LLSDMessageBuilder::addVector3d(const char* varname, const LLVector3d& v)
  178. {
  179. (*mCurrentBlock)[varname] = ll_sd_from_vector3d(v);
  180. }
  181. void LLSDMessageBuilder::addQuat(const char* varname, const LLQuaternion& v)
  182. {
  183. (*mCurrentBlock)[varname] = ll_sd_from_quaternion(v);
  184. }
  185. void LLSDMessageBuilder::addUUID(const char* varname, const LLUUID& v)
  186. {
  187. (*mCurrentBlock)[varname] = v;
  188. }
  189. void LLSDMessageBuilder::compressMessage(U8*& buf_ptr, U32& buffer_length)
  190. {
  191. }
  192. BOOL LLSDMessageBuilder::isMessageFull(const char* blockname) const
  193. {
  194. return FALSE;
  195. }
  196. U32 LLSDMessageBuilder::buildMessage(U8*, U32, U8)
  197. {
  198. return 0;
  199. }
  200. void LLSDMessageBuilder::copyFromMessageData(const LLMsgData& data)
  201. {
  202. // copy the blocks
  203. // counting variables used to encode multiple block info
  204. S32 block_count = 0;
  205.     char* block_name = NULL;
  206. // loop through msg blocks to loop through variables, totalling up size
  207. // data and filling the new (send) message
  208. LLMsgData::msg_blk_data_map_t::const_iterator iter = 
  209. data.mMemberBlocks.begin();
  210. LLMsgData::msg_blk_data_map_t::const_iterator end = 
  211. data.mMemberBlocks.end();
  212. for(; iter != end; ++iter)
  213. {
  214. const LLMsgBlkData* mbci = iter->second;
  215. if(!mbci) continue;
  216. // do we need to encode a block code?
  217. if (block_count == 0)
  218. {
  219. block_count = mbci->mBlockNumber;
  220. block_name = (char*)mbci->mName;
  221. }
  222. // counting down mutliple blocks
  223. block_count--;
  224. nextBlock(block_name);
  225. // now loop through the variables
  226. LLMsgBlkData::msg_var_data_map_t::const_iterator dit = mbci->mMemberVarData.begin();
  227. LLMsgBlkData::msg_var_data_map_t::const_iterator dend = mbci->mMemberVarData.end();
  228. for(; dit != dend; ++dit)
  229. {
  230. const LLMsgVarData& mvci = *dit;
  231. const char* varname = mvci.getName();
  232. switch(mvci.getType())
  233. {
  234. case MVT_FIXED:
  235. addBinaryData(varname, mvci.getData(), mvci.getSize());
  236. break;
  237. case MVT_VARIABLE:
  238. {
  239. const char end = ((const char*)mvci.getData())[mvci.getSize()-1]; // Ensure null terminated
  240. if (mvci.getDataSize() == 1 && end == 0) 
  241. {
  242. addString(varname, (const char*)mvci.getData());
  243. }
  244. else
  245. {
  246. addBinaryData(varname, mvci.getData(), mvci.getSize());
  247. }
  248. break;
  249. }
  250. case MVT_U8:
  251. addU8(varname, *(U8*)mvci.getData());
  252. break;
  253. case MVT_U16:
  254. addU16(varname, *(U16*)mvci.getData());
  255. break;
  256. case MVT_U32:
  257. addU32(varname, *(U32*)mvci.getData());
  258. break;
  259. case MVT_U64:
  260. addU64(varname, *(U64*)mvci.getData());
  261. break;
  262. case MVT_S8:
  263. addS8(varname, *(S8*)mvci.getData());
  264. break;
  265. case MVT_S16:
  266. addS16(varname, *(S16*)mvci.getData());
  267. break;
  268. case MVT_S32:
  269. addS32(varname, *(S32*)mvci.getData());
  270. break;
  271. // S64 not supported in LLSD so we just truncate it
  272. case MVT_S64:
  273. addS32(varname, *(S64*)mvci.getData());
  274. break;
  275. case MVT_F32:
  276. addF32(varname, *(F32*)mvci.getData());
  277. break;
  278. case MVT_F64:
  279. addF64(varname, *(F64*)mvci.getData());
  280. break;
  281. case MVT_LLVector3:
  282. addVector3(varname, *(LLVector3*)mvci.getData());
  283. break;
  284. case MVT_LLVector3d:
  285. addVector3d(varname, *(LLVector3d*)mvci.getData());
  286. break;
  287. case MVT_LLVector4:
  288. addVector4(varname, *(LLVector4*)mvci.getData());
  289. break;
  290. case MVT_LLQuaternion:
  291. {
  292. LLVector3 v = *(LLVector3*)mvci.getData();
  293. LLQuaternion q;
  294. q.unpackFromVector3(v);
  295. addQuat(varname, q);
  296. break;
  297. }
  298. case MVT_LLUUID:
  299. addUUID(varname, *(LLUUID*)mvci.getData());
  300. break;
  301. case MVT_BOOL:
  302. addBOOL(varname, *(BOOL*)mvci.getData());
  303. break;
  304. case MVT_IP_ADDR:
  305. addIPAddr(varname, *(U32*)mvci.getData());
  306. break;
  307. case MVT_IP_PORT:
  308. addIPPort(varname, *(U16*)mvci.getData());
  309. break;
  310. case MVT_U16Vec3:
  311. //treated as an array of 6 bytes
  312. addBinaryData(varname, mvci.getData(), 6);
  313. break;
  314. case MVT_U16Quat:
  315. //treated as an array of 8 bytes
  316. addBinaryData(varname, mvci.getData(), 8);
  317. break;
  318. case MVT_S16Array:
  319. addBinaryData(varname, mvci.getData(), mvci.getSize());
  320. break;
  321. default:
  322. llwarns << "Unknown type in conversion of message to LLSD" << llendl;
  323. break;
  324. }
  325. }
  326. }
  327. }
  328. //virtual
  329. void LLSDMessageBuilder::copyFromLLSD(const LLSD& msg)
  330. {
  331. mCurrentMessage = msg;
  332. lldebugs << LLSDNotationStreamer(mCurrentMessage) << llendl;
  333. }
  334. const LLSD& LLSDMessageBuilder::getMessage() const
  335. {
  336.  return mCurrentMessage;
  337. }
  338. //virtual
  339. void LLSDMessageBuilder::setBuilt(BOOL b) { mbSBuilt = b; }
  340. //virtual 
  341. BOOL LLSDMessageBuilder::isBuilt() const {return mbSBuilt;}
  342. //virtual 
  343. BOOL LLSDMessageBuilder::isClear() const {return mbSClear;}
  344. //virtual 
  345. S32 LLSDMessageBuilder::getMessageSize()
  346. {
  347. // babbage: size is unknown as message stored as LLSD.
  348. // return non-zero if pending data, as send can be skipped for 0 size.
  349. // return 1 to encourage senders checking size against splitting message.
  350. return mCurrentMessage.size()? 1 : 0;
  351. }
  352. //virtual 
  353. const char* LLSDMessageBuilder::getMessageName() const 
  354. {
  355. return mCurrentMessageName.c_str();
  356. }