obs-data.c 48 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982
  1. /******************************************************************************
  2. Copyright (C) 2014 by Hugh Bailey <[email protected]>
  3. This program is free software: you can redistribute it and/or modify
  4. it under the terms of the GNU General Public License as published by
  5. the Free Software Foundation, either version 2 of the License, or
  6. (at your option) any later version.
  7. This program is distributed in the hope that it will be useful,
  8. but WITHOUT ANY WARRANTY; without even the implied warranty of
  9. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  10. GNU General Public License for more details.
  11. You should have received a copy of the GNU General Public License
  12. along with this program. If not, see <http://www.gnu.org/licenses/>.
  13. ******************************************************************************/
  14. #include "util/bmem.h"
  15. #include "util/threading.h"
  16. #include "util/dstr.h"
  17. #include "util/darray.h"
  18. #include "util/platform.h"
  19. #include "graphics/vec2.h"
  20. #include "graphics/vec3.h"
  21. #include "graphics/vec4.h"
  22. #include "graphics/quat.h"
  23. #include "obs-data.h"
  24. #include <jansson.h>
  25. struct obs_data_item {
  26. volatile long ref;
  27. struct obs_data *parent;
  28. struct obs_data_item *next;
  29. enum obs_data_type type;
  30. size_t name_len;
  31. size_t data_len;
  32. size_t data_size;
  33. size_t default_len;
  34. size_t default_size;
  35. size_t autoselect_size;
  36. size_t capacity;
  37. };
  38. struct obs_data {
  39. volatile long ref;
  40. char *json;
  41. struct obs_data_item *first_item;
  42. };
  43. struct obs_data_array {
  44. volatile long ref;
  45. DARRAY(obs_data_t*) objects;
  46. };
  47. struct obs_data_number {
  48. enum obs_data_number_type type;
  49. union {
  50. long long int_val;
  51. double double_val;
  52. };
  53. };
  54. /* ------------------------------------------------------------------------- */
  55. /* Item structure, designed to be one allocation only */
  56. static inline size_t get_align_size(size_t size)
  57. {
  58. const size_t alignment = base_get_alignment();
  59. return (size + alignment - 1) & ~(alignment - 1);
  60. }
  61. /* ensures data after the name has alignment (in case of SSE) */
  62. static inline size_t get_name_align_size(const char *name)
  63. {
  64. size_t name_size = strlen(name) + 1;
  65. size_t alignment = base_get_alignment();
  66. size_t total_size;
  67. total_size = sizeof(struct obs_data_item) + (name_size + alignment-1);
  68. total_size &= ~(alignment-1);
  69. return total_size - sizeof(struct obs_data_item);
  70. }
  71. static inline char *get_item_name(struct obs_data_item *item)
  72. {
  73. return (char*)item + sizeof(struct obs_data_item);
  74. }
  75. static inline void *get_data_ptr(obs_data_item_t *item)
  76. {
  77. return (uint8_t*)get_item_name(item) + item->name_len;
  78. }
  79. static inline void *get_item_data(struct obs_data_item *item)
  80. {
  81. if (!item->data_size && !item->default_size && !item->autoselect_size)
  82. return NULL;
  83. return get_data_ptr(item);
  84. }
  85. static inline void *get_default_data_ptr(obs_data_item_t *item)
  86. {
  87. return (uint8_t*)get_data_ptr(item) + item->data_len;
  88. }
  89. static inline void *get_item_default_data(struct obs_data_item *item)
  90. {
  91. return item->default_size ? get_default_data_ptr(item) : NULL;
  92. }
  93. static inline void *get_autoselect_data_ptr(obs_data_item_t *item)
  94. {
  95. return (uint8_t*)get_default_data_ptr(item) + item->default_len;
  96. }
  97. static inline void *get_item_autoselect_data(struct obs_data_item *item)
  98. {
  99. return item->autoselect_size ? get_autoselect_data_ptr(item) : NULL;
  100. }
  101. static inline size_t obs_data_item_total_size(struct obs_data_item *item)
  102. {
  103. return sizeof(struct obs_data_item) + item->name_len +
  104. item->data_len + item->default_len + item->autoselect_size;
  105. }
  106. static inline obs_data_t *get_item_obj(struct obs_data_item *item)
  107. {
  108. if (!item)
  109. return NULL;
  110. return *(obs_data_t**)get_item_data(item);
  111. }
  112. static inline obs_data_t *get_item_default_obj(struct obs_data_item *item)
  113. {
  114. if (!item || !item->default_size)
  115. return NULL;
  116. return *(obs_data_t**)get_default_data_ptr(item);
  117. }
  118. static inline obs_data_t *get_item_autoselect_obj(struct obs_data_item *item)
  119. {
  120. if (!item || !item->autoselect_size)
  121. return NULL;
  122. return *(obs_data_t**)get_autoselect_data_ptr(item);
  123. }
  124. static inline obs_data_array_t *get_item_array(struct obs_data_item *item)
  125. {
  126. if (!item)
  127. return NULL;
  128. return *(obs_data_array_t**)get_item_data(item);
  129. }
  130. static inline obs_data_array_t *get_item_default_array(
  131. struct obs_data_item *item)
  132. {
  133. if (!item || !item->default_size)
  134. return NULL;
  135. return *(obs_data_array_t**)get_default_data_ptr(item);
  136. }
  137. static inline obs_data_array_t *get_item_autoselect_array(
  138. struct obs_data_item *item)
  139. {
  140. if (!item || !item->autoselect_size)
  141. return NULL;
  142. return *(obs_data_array_t**)get_autoselect_data_ptr(item);
  143. }
  144. static inline void item_data_release(struct obs_data_item *item)
  145. {
  146. if (!obs_data_item_has_user_value(item))
  147. return;
  148. if (item->type == OBS_DATA_OBJECT) {
  149. obs_data_t *obj = get_item_obj(item);
  150. obs_data_release(obj);
  151. } else if (item->type == OBS_DATA_ARRAY) {
  152. obs_data_array_t *array = get_item_array(item);
  153. obs_data_array_release(array);
  154. }
  155. }
  156. static inline void item_default_data_release(struct obs_data_item *item)
  157. {
  158. if (item->type == OBS_DATA_OBJECT) {
  159. obs_data_t *obj = get_item_default_obj(item);
  160. obs_data_release(obj);
  161. } else if (item->type == OBS_DATA_ARRAY) {
  162. obs_data_array_t *array = get_item_default_array(item);
  163. obs_data_array_release(array);
  164. }
  165. }
  166. static inline void item_autoselect_data_release(struct obs_data_item *item)
  167. {
  168. if (item->type == OBS_DATA_OBJECT) {
  169. obs_data_t *obj = get_item_autoselect_obj(item);
  170. obs_data_release(obj);
  171. } else if (item->type == OBS_DATA_ARRAY) {
  172. obs_data_array_t *array = get_item_autoselect_array(item);
  173. obs_data_array_release(array);
  174. }
  175. }
  176. static inline void item_data_addref(struct obs_data_item *item)
  177. {
  178. if (item->type == OBS_DATA_OBJECT) {
  179. obs_data_t *obj = get_item_obj(item);
  180. obs_data_addref(obj);
  181. } else if (item->type == OBS_DATA_ARRAY) {
  182. obs_data_array_t *array = get_item_array(item);
  183. obs_data_array_addref(array);
  184. }
  185. }
  186. static inline void item_default_data_addref(struct obs_data_item *item)
  187. {
  188. if (!item->data_size)
  189. return;
  190. if (item->type == OBS_DATA_OBJECT) {
  191. obs_data_t *obj = get_item_default_obj(item);
  192. obs_data_addref(obj);
  193. } else if (item->type == OBS_DATA_ARRAY) {
  194. obs_data_array_t *array = get_item_default_array(item);
  195. obs_data_array_addref(array);
  196. }
  197. }
  198. static inline void item_autoselect_data_addref(struct obs_data_item *item)
  199. {
  200. if (item->type == OBS_DATA_OBJECT) {
  201. obs_data_t *obj = get_item_autoselect_obj(item);
  202. obs_data_addref(obj);
  203. } else if (item->type == OBS_DATA_ARRAY) {
  204. obs_data_array_t *array = get_item_autoselect_array(item);
  205. obs_data_array_addref(array);
  206. }
  207. }
  208. static struct obs_data_item *obs_data_item_create(const char *name,
  209. const void *data, size_t size, enum obs_data_type type,
  210. bool default_data, bool autoselect_data)
  211. {
  212. struct obs_data_item *item;
  213. size_t name_size, total_size;
  214. if (!name || !data)
  215. return NULL;
  216. name_size = get_name_align_size(name);
  217. total_size = name_size + sizeof(struct obs_data_item) + size;
  218. item = bzalloc(total_size);
  219. item->capacity = total_size;
  220. item->type = type;
  221. item->name_len = name_size;
  222. item->ref = 1;
  223. if (default_data) {
  224. item->default_len = size;
  225. item->default_size = size;
  226. } else if (autoselect_data) {
  227. item->autoselect_size = size;
  228. } else {
  229. item->data_len = size;
  230. item->data_size = size;
  231. }
  232. strcpy(get_item_name(item), name);
  233. memcpy(get_item_data(item), data, size);
  234. item_data_addref(item);
  235. return item;
  236. }
  237. static struct obs_data_item **get_item_prev_next(struct obs_data *data,
  238. struct obs_data_item *current)
  239. {
  240. if (!current || !data)
  241. return NULL;
  242. struct obs_data_item **prev_next = &data->first_item;
  243. struct obs_data_item *item = data->first_item;
  244. while (item) {
  245. if (item == current)
  246. return prev_next;
  247. prev_next = &item->next;
  248. item = item->next;
  249. }
  250. return NULL;
  251. }
  252. static inline void obs_data_item_detach(struct obs_data_item *item)
  253. {
  254. struct obs_data_item **prev_next = get_item_prev_next(item->parent,
  255. item);
  256. if (prev_next) {
  257. *prev_next = item->next;
  258. item->next = NULL;
  259. }
  260. }
  261. static inline void obs_data_item_reattach(struct obs_data_item *old_ptr,
  262. struct obs_data_item *new_ptr)
  263. {
  264. struct obs_data_item **prev_next = get_item_prev_next(new_ptr->parent,
  265. old_ptr);
  266. if (prev_next)
  267. *prev_next = new_ptr;
  268. }
  269. static struct obs_data_item *obs_data_item_ensure_capacity(
  270. struct obs_data_item *item)
  271. {
  272. size_t new_size = obs_data_item_total_size(item);
  273. struct obs_data_item *new_item;
  274. if (item->capacity >= new_size)
  275. return item;
  276. new_item = brealloc(item, new_size);
  277. new_item->capacity = new_size;
  278. obs_data_item_reattach(item, new_item);
  279. return new_item;
  280. }
  281. static inline void obs_data_item_destroy(struct obs_data_item *item)
  282. {
  283. item_data_release(item);
  284. item_default_data_release(item);
  285. item_autoselect_data_release(item);
  286. obs_data_item_detach(item);
  287. bfree(item);
  288. }
  289. static inline void move_data(obs_data_item_t *old_item, void *old_data,
  290. obs_data_item_t *item, void *data, size_t len)
  291. {
  292. ptrdiff_t old_offset = (uint8_t*)old_data - (uint8_t*)old_item;
  293. ptrdiff_t new_offset = (uint8_t*)data - (uint8_t*)item;
  294. if (!old_data)
  295. return;
  296. memmove((uint8_t*)item + new_offset, (uint8_t*)item + old_offset, len);
  297. }
  298. static inline void obs_data_item_setdata(
  299. struct obs_data_item **p_item, const void *data, size_t size,
  300. enum obs_data_type type)
  301. {
  302. if (!p_item || !*p_item)
  303. return;
  304. struct obs_data_item *item = *p_item;
  305. ptrdiff_t old_default_data_pos =
  306. (uint8_t*)get_default_data_ptr(item) - (uint8_t*)item;
  307. item_data_release(item);
  308. item->data_size = size;
  309. item->type = type;
  310. item->data_len = (item->default_size || item->autoselect_size) ?
  311. get_align_size(size) : size;
  312. item = obs_data_item_ensure_capacity(item);
  313. if (item->default_size || item->autoselect_size)
  314. memmove(get_default_data_ptr(item),
  315. (uint8_t*)item + old_default_data_pos,
  316. item->default_len + item->autoselect_size);
  317. if (size) {
  318. memcpy(get_item_data(item), data, size);
  319. item_data_addref(item);
  320. }
  321. *p_item = item;
  322. }
  323. static inline void obs_data_item_set_default_data(
  324. struct obs_data_item **p_item, const void *data, size_t size,
  325. enum obs_data_type type)
  326. {
  327. if (!p_item || !*p_item)
  328. return;
  329. struct obs_data_item *item = *p_item;
  330. void *old_autoselect_data = get_autoselect_data_ptr(item);
  331. item_default_data_release(item);
  332. item->type = type;
  333. item->default_size = size;
  334. item->default_len = item->autoselect_size ?
  335. get_align_size(size) : size;
  336. item->data_len = item->data_size ?
  337. get_align_size(item->data_size) : 0;
  338. item = obs_data_item_ensure_capacity(item);
  339. if (item->autoselect_size)
  340. move_data(*p_item, old_autoselect_data, item,
  341. get_autoselect_data_ptr(item),
  342. item->autoselect_size);
  343. if (size) {
  344. memcpy(get_item_default_data(item), data, size);
  345. item_default_data_addref(item);
  346. }
  347. *p_item = item;
  348. }
  349. static inline void obs_data_item_set_autoselect_data(
  350. struct obs_data_item **p_item, const void *data, size_t size,
  351. enum obs_data_type type)
  352. {
  353. if (!p_item || !*p_item)
  354. return;
  355. struct obs_data_item *item = *p_item;
  356. item_autoselect_data_release(item);
  357. item->autoselect_size = size;
  358. item->type = type;
  359. item->data_len = item->data_size ?
  360. get_align_size(item->data_size) : 0;
  361. item->default_len = item->default_size ?
  362. get_align_size(item->default_size) : 0;
  363. item = obs_data_item_ensure_capacity(item);
  364. if (size) {
  365. memcpy(get_item_autoselect_data(item), data, size);
  366. item_autoselect_data_addref(item);
  367. }
  368. *p_item = item;
  369. }
  370. /* ------------------------------------------------------------------------- */
  371. static void obs_data_add_json_item(obs_data_t *data, const char *key,
  372. json_t *json);
  373. static inline void obs_data_add_json_object_data(obs_data_t *data, json_t *jobj)
  374. {
  375. const char *item_key;
  376. json_t *jitem;
  377. json_object_foreach (jobj, item_key, jitem) {
  378. obs_data_add_json_item(data, item_key, jitem);
  379. }
  380. }
  381. static inline void obs_data_add_json_object(obs_data_t *data, const char *key,
  382. json_t *jobj)
  383. {
  384. obs_data_t *sub_obj = obs_data_create();
  385. obs_data_add_json_object_data(sub_obj, jobj);
  386. obs_data_set_obj(data, key, sub_obj);
  387. obs_data_release(sub_obj);
  388. }
  389. static void obs_data_add_json_array(obs_data_t *data, const char *key,
  390. json_t *jarray)
  391. {
  392. obs_data_array_t *array = obs_data_array_create();
  393. size_t idx;
  394. json_t *jitem;
  395. json_array_foreach (jarray, idx, jitem) {
  396. obs_data_t *item;
  397. if (!json_is_object(jitem))
  398. continue;
  399. item = obs_data_create();
  400. obs_data_add_json_object_data(item, jitem);
  401. obs_data_array_push_back(array, item);
  402. obs_data_release(item);
  403. }
  404. obs_data_set_array(data, key, array);
  405. obs_data_array_release(array);
  406. }
  407. static void obs_data_add_json_item(obs_data_t *data, const char *key,
  408. json_t *json)
  409. {
  410. if (json_is_object(json))
  411. obs_data_add_json_object(data, key, json);
  412. else if (json_is_array(json))
  413. obs_data_add_json_array(data, key, json);
  414. else if (json_is_string(json))
  415. obs_data_set_string(data, key, json_string_value(json));
  416. else if (json_is_integer(json))
  417. obs_data_set_int(data, key, json_integer_value(json));
  418. else if (json_is_real(json))
  419. obs_data_set_double(data, key, json_real_value(json));
  420. else if (json_is_true(json))
  421. obs_data_set_bool(data, key, true);
  422. else if (json_is_false(json))
  423. obs_data_set_bool(data, key, false);
  424. }
  425. /* ------------------------------------------------------------------------- */
  426. static inline void set_json_string(json_t *json, const char *name,
  427. obs_data_item_t *item)
  428. {
  429. const char *val = obs_data_item_get_string(item);
  430. json_object_set_new(json, name, json_string(val));
  431. }
  432. static inline void set_json_number(json_t *json, const char *name,
  433. obs_data_item_t *item)
  434. {
  435. enum obs_data_number_type type = obs_data_item_numtype(item);
  436. if (type == OBS_DATA_NUM_INT) {
  437. long long val = obs_data_item_get_int(item);
  438. json_object_set_new(json, name, json_integer(val));
  439. } else {
  440. double val = obs_data_item_get_double(item);
  441. json_object_set_new(json, name, json_real(val));
  442. }
  443. }
  444. static inline void set_json_bool(json_t *json, const char *name,
  445. obs_data_item_t *item)
  446. {
  447. bool val = obs_data_item_get_bool(item);
  448. json_object_set_new(json, name, val ? json_true() : json_false());
  449. }
  450. static json_t *obs_data_to_json(obs_data_t *data);
  451. static inline void set_json_obj(json_t *json, const char *name,
  452. obs_data_item_t *item)
  453. {
  454. obs_data_t *obj = obs_data_item_get_obj(item);
  455. json_object_set_new(json, name, obs_data_to_json(obj));
  456. obs_data_release(obj);
  457. }
  458. static inline void set_json_array(json_t *json, const char *name,
  459. obs_data_item_t *item)
  460. {
  461. json_t *jarray = json_array();
  462. obs_data_array_t *array = obs_data_item_get_array(item);
  463. size_t count = obs_data_array_count(array);
  464. for (size_t idx = 0; idx < count; idx++) {
  465. obs_data_t *sub_item = obs_data_array_item(array, idx);
  466. json_t *jitem = obs_data_to_json(sub_item);
  467. json_array_append_new(jarray, jitem);
  468. obs_data_release(sub_item);
  469. }
  470. json_object_set_new(json, name, jarray);
  471. obs_data_array_release(array);
  472. }
  473. static json_t *obs_data_to_json(obs_data_t *data)
  474. {
  475. json_t *json = json_object();
  476. obs_data_item_t *item = NULL;
  477. for (item = obs_data_first(data); item; obs_data_item_next(&item)) {
  478. enum obs_data_type type = obs_data_item_gettype(item);
  479. const char *name = get_item_name(item);
  480. if (!obs_data_item_has_user_value(item))
  481. continue;
  482. if (type == OBS_DATA_STRING)
  483. set_json_string(json, name, item);
  484. else if (type == OBS_DATA_NUMBER)
  485. set_json_number(json, name, item);
  486. else if (type == OBS_DATA_BOOLEAN)
  487. set_json_bool(json, name, item);
  488. else if (type == OBS_DATA_OBJECT)
  489. set_json_obj(json, name, item);
  490. else if (type == OBS_DATA_ARRAY)
  491. set_json_array(json, name, item);
  492. }
  493. return json;
  494. }
  495. /* ------------------------------------------------------------------------- */
  496. obs_data_t *obs_data_create()
  497. {
  498. struct obs_data *data = bzalloc(sizeof(struct obs_data));
  499. data->ref = 1;
  500. return data;
  501. }
  502. obs_data_t *obs_data_create_from_json(const char *json_string)
  503. {
  504. obs_data_t *data = obs_data_create();
  505. json_error_t error;
  506. json_t *root = json_loads(json_string, JSON_REJECT_DUPLICATES, &error);
  507. if (root) {
  508. obs_data_add_json_object_data(data, root);
  509. json_decref(root);
  510. } else {
  511. blog(LOG_ERROR, "obs-data.c: [obs_data_create_from_json] "
  512. "Failed reading json string (%d): %s",
  513. error.line, error.text);
  514. obs_data_release(data);
  515. data = NULL;
  516. }
  517. return data;
  518. }
  519. obs_data_t *obs_data_create_from_json_file(const char *json_file)
  520. {
  521. char *file_data = os_quick_read_utf8_file(json_file);
  522. obs_data_t *data = NULL;
  523. if (file_data) {
  524. data = obs_data_create_from_json(file_data);
  525. bfree(file_data);
  526. }
  527. return data;
  528. }
  529. obs_data_t *obs_data_create_from_json_file_safe(const char *json_file,
  530. const char *backup_ext)
  531. {
  532. obs_data_t *file_data = obs_data_create_from_json_file(json_file);
  533. if (!file_data && backup_ext && *backup_ext) {
  534. struct dstr backup_file = {0};
  535. dstr_copy(&backup_file, json_file);
  536. if (*backup_ext != '.')
  537. dstr_cat(&backup_file, ".");
  538. dstr_cat(&backup_file, backup_ext);
  539. if (os_file_exists(backup_file.array)) {
  540. blog(LOG_WARNING, "obs-data.c: "
  541. "[obs_data_create_from_json_file_safe] "
  542. "attempting backup file");
  543. /* delete current file if corrupt to prevent it from
  544. * being backed up again */
  545. os_unlink(json_file);
  546. os_rename(backup_file.array, json_file);
  547. file_data = obs_data_create_from_json_file(json_file);
  548. }
  549. dstr_free(&backup_file);
  550. }
  551. return file_data;
  552. }
  553. void obs_data_addref(obs_data_t *data)
  554. {
  555. if (data)
  556. os_atomic_inc_long(&data->ref);
  557. }
  558. static inline void obs_data_destroy(struct obs_data *data)
  559. {
  560. struct obs_data_item *item = data->first_item;
  561. while (item) {
  562. struct obs_data_item *next = item->next;
  563. obs_data_item_release(&item);
  564. item = next;
  565. }
  566. /* NOTE: don't use bfree for json text, allocated by json */
  567. free(data->json);
  568. bfree(data);
  569. }
  570. void obs_data_release(obs_data_t *data)
  571. {
  572. if (!data) return;
  573. if (os_atomic_dec_long(&data->ref) == 0)
  574. obs_data_destroy(data);
  575. }
  576. const char *obs_data_get_json(obs_data_t *data)
  577. {
  578. if (!data) return NULL;
  579. /* NOTE: don't use libobs bfree for json text */
  580. free(data->json);
  581. data->json = NULL;
  582. json_t *root = obs_data_to_json(data);
  583. data->json = json_dumps(root, JSON_PRESERVE_ORDER | JSON_INDENT(4));
  584. json_decref(root);
  585. return data->json;
  586. }
  587. bool obs_data_save_json(obs_data_t *data, const char *file)
  588. {
  589. const char *json = obs_data_get_json(data);
  590. if (json && *json) {
  591. return os_quick_write_utf8_file(file, json, strlen(json),
  592. false);
  593. }
  594. return false;
  595. }
  596. bool obs_data_save_json_safe(obs_data_t *data, const char *file,
  597. const char *temp_ext, const char *backup_ext)
  598. {
  599. const char *json = obs_data_get_json(data);
  600. if (json && *json) {
  601. return os_quick_write_utf8_file_safe(file, json, strlen(json),
  602. false, temp_ext, backup_ext);
  603. }
  604. return false;
  605. }
  606. static struct obs_data_item *get_item(struct obs_data *data, const char *name)
  607. {
  608. if (!data) return NULL;
  609. struct obs_data_item *item = data->first_item;
  610. while (item) {
  611. if (strcmp(get_item_name(item), name) == 0)
  612. return item;
  613. item = item->next;
  614. }
  615. return NULL;
  616. }
  617. static void set_item_data(struct obs_data *data, struct obs_data_item **item,
  618. const char *name, const void *ptr, size_t size,
  619. enum obs_data_type type,
  620. bool default_data, bool autoselect_data)
  621. {
  622. obs_data_item_t *new_item = NULL;
  623. if ((!item || (item && !*item)) && data) {
  624. new_item = obs_data_item_create(name, ptr, size, type,
  625. default_data, autoselect_data);
  626. obs_data_item_t *prev = obs_data_first(data);
  627. obs_data_item_t *next = obs_data_first(data);
  628. obs_data_item_next(&next);
  629. for (; prev && next; obs_data_item_next(&prev),
  630. obs_data_item_next(&next)) {
  631. if (strcmp(get_item_name(next), name) > 0)
  632. break;
  633. }
  634. new_item->parent = data;
  635. if (prev && strcmp(get_item_name(prev), name) < 0) {
  636. prev->next = new_item;
  637. new_item->next = next;
  638. } else {
  639. data->first_item = new_item;
  640. new_item->next = prev;
  641. }
  642. if (!prev)
  643. data->first_item = new_item;
  644. obs_data_item_release(&prev);
  645. obs_data_item_release(&next);
  646. } else if (default_data) {
  647. obs_data_item_set_default_data(item, ptr, size, type);
  648. } else if (autoselect_data) {
  649. obs_data_item_set_autoselect_data(item, ptr, size, type);
  650. } else {
  651. obs_data_item_setdata(item, ptr, size, type);
  652. }
  653. }
  654. static inline void set_item(struct obs_data *data, obs_data_item_t **item,
  655. const char *name,
  656. const void *ptr, size_t size, enum obs_data_type type)
  657. {
  658. obs_data_item_t *actual_item = NULL;
  659. if (!data && !item)
  660. return;
  661. if (!item) {
  662. actual_item = get_item(data, name);
  663. item = &actual_item;
  664. }
  665. set_item_data(data, item, name, ptr, size, type, false, false);
  666. }
  667. static inline void set_item_def(struct obs_data *data, obs_data_item_t **item,
  668. const char *name,
  669. const void *ptr, size_t size, enum obs_data_type type)
  670. {
  671. obs_data_item_t *actual_item = NULL;
  672. if (!data && !item)
  673. return;
  674. if (!item) {
  675. actual_item = get_item(data, name);
  676. item = &actual_item;
  677. }
  678. if (item && *item && (*item)->type == type)
  679. return;
  680. set_item_data(data, item, name, ptr, size, type, true, false);
  681. }
  682. static inline void set_item_auto(struct obs_data *data, obs_data_item_t **item,
  683. const char *name,
  684. const void *ptr, size_t size, enum obs_data_type type)
  685. {
  686. obs_data_item_t *actual_item = NULL;
  687. if (!data && !item)
  688. return;
  689. if (!item) {
  690. actual_item = get_item(data, name);
  691. item = &actual_item;
  692. }
  693. set_item_data(data, item, name, ptr, size, type, false, true);
  694. }
  695. static void copy_obj(struct obs_data *data, const char *name,
  696. struct obs_data *obj,
  697. void (*callback)(obs_data_t *, const char *, obs_data_t *))
  698. {
  699. if (obj) {
  700. obs_data_t *new_obj = obs_data_create();
  701. obs_data_apply(new_obj, obj);
  702. callback(data, name, new_obj);
  703. obs_data_release(new_obj);
  704. }
  705. }
  706. static void copy_array(struct obs_data *data, const char *name,
  707. struct obs_data_array *array,
  708. void (*callback)(obs_data_t*, const char*, obs_data_array_t*))
  709. {
  710. if (array) {
  711. obs_data_array_t *new_array = obs_data_array_create();
  712. da_reserve(new_array->objects, array->objects.num);
  713. for (size_t i = 0; i < array->objects.num; i++) {
  714. obs_data_t *new_obj = obs_data_create();
  715. obs_data_t *obj = array->objects.array[i];
  716. obs_data_apply(new_obj, obj);
  717. obs_data_array_push_back(new_array, new_obj);
  718. obs_data_release(new_obj);
  719. }
  720. callback(data, name, new_array);
  721. obs_data_array_release(new_array);
  722. }
  723. }
  724. static inline void copy_item(struct obs_data *data, struct obs_data_item *item)
  725. {
  726. const char *name = get_item_name(item);
  727. void *ptr = get_item_data(item);
  728. if (item->type == OBS_DATA_OBJECT) {
  729. obs_data_t **obj = item->data_size ? ptr : NULL;
  730. if (obj)
  731. copy_obj(data, name, *obj, obs_data_set_obj);
  732. } else if (item->type == OBS_DATA_ARRAY) {
  733. obs_data_array_t **array = item->data_size ? ptr : NULL;
  734. if (array)
  735. copy_array(data, name, *array, obs_data_set_array);
  736. } else {
  737. if (item->data_size)
  738. set_item(data, NULL, name, ptr, item->data_size,
  739. item->type);
  740. }
  741. }
  742. void obs_data_apply(obs_data_t *target, obs_data_t *apply_data)
  743. {
  744. struct obs_data_item *item;
  745. if (!target || !apply_data || target == apply_data)
  746. return;
  747. item = apply_data->first_item;
  748. while (item) {
  749. copy_item(target, item);
  750. item = item->next;
  751. }
  752. }
  753. void obs_data_erase(obs_data_t *data, const char *name)
  754. {
  755. struct obs_data_item *item = get_item(data, name);
  756. if (item) {
  757. obs_data_item_detach(item);
  758. obs_data_item_release(&item);
  759. }
  760. }
  761. static inline void clear_item(struct obs_data_item *item)
  762. {
  763. void *ptr = get_item_data(item);
  764. size_t size;
  765. if (item->data_len) {
  766. if (item->type == OBS_DATA_OBJECT) {
  767. obs_data_t **obj = item->data_size ? ptr : NULL;
  768. if (obj && *obj)
  769. obs_data_release(*obj);
  770. } else if (item->type == OBS_DATA_ARRAY) {
  771. obs_data_array_t **array = item->data_size ? ptr : NULL;
  772. if (array && *array)
  773. obs_data_array_release(*array);
  774. }
  775. size = item->default_len + item->autoselect_size;
  776. if (size)
  777. memmove(ptr, (uint8_t*)ptr + item->data_len, size);
  778. item->data_size = 0;
  779. item->data_len = 0;
  780. }
  781. }
  782. void obs_data_clear(obs_data_t *target)
  783. {
  784. struct obs_data_item *item;
  785. if (!target)
  786. return;
  787. item = target->first_item;
  788. while (item) {
  789. clear_item(item);
  790. item = item->next;
  791. }
  792. }
  793. typedef void (*set_item_t)(obs_data_t*, obs_data_item_t**, const char*,
  794. const void*, size_t, enum obs_data_type);
  795. static inline void obs_set_string(obs_data_t *data, obs_data_item_t **item,
  796. const char *name,
  797. const char *val, set_item_t set_item_)
  798. {
  799. if (!val) val = "";
  800. set_item_(data, item, name, val, strlen(val)+1, OBS_DATA_STRING);
  801. }
  802. static inline void obs_set_int(obs_data_t *data, obs_data_item_t **item,
  803. const char *name,
  804. long long val, set_item_t set_item_)
  805. {
  806. struct obs_data_number num;
  807. num.type = OBS_DATA_NUM_INT;
  808. num.int_val = val;
  809. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  810. OBS_DATA_NUMBER);
  811. }
  812. static inline void obs_set_double(obs_data_t *data, obs_data_item_t **item,
  813. const char *name,
  814. double val, set_item_t set_item_)
  815. {
  816. struct obs_data_number num;
  817. num.type = OBS_DATA_NUM_DOUBLE;
  818. num.double_val = val;
  819. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  820. OBS_DATA_NUMBER);
  821. }
  822. static inline void obs_set_bool(obs_data_t *data, obs_data_item_t **item,
  823. const char *name,
  824. bool val, set_item_t set_item_)
  825. {
  826. set_item_(data, item, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  827. }
  828. static inline void obs_set_obj(obs_data_t *data, obs_data_item_t **item,
  829. const char *name,
  830. obs_data_t *obj, set_item_t set_item_)
  831. {
  832. set_item_(data, item, name, &obj, sizeof(obs_data_t*), OBS_DATA_OBJECT);
  833. }
  834. static inline void obs_set_array(obs_data_t *data, obs_data_item_t **item,
  835. const char *name,
  836. obs_data_array_t *array, set_item_t set_item_)
  837. {
  838. set_item_(data, item, name, &array, sizeof(obs_data_t*), OBS_DATA_ARRAY);
  839. }
  840. void obs_data_set_string(obs_data_t *data, const char *name, const char *val)
  841. {
  842. obs_set_string(data, NULL, name, val, set_item);
  843. }
  844. void obs_data_set_int(obs_data_t *data, const char *name, long long val)
  845. {
  846. obs_set_int(data, NULL, name, val, set_item);
  847. }
  848. void obs_data_set_double(obs_data_t *data, const char *name, double val)
  849. {
  850. obs_set_double(data, NULL, name, val, set_item);
  851. }
  852. void obs_data_set_bool(obs_data_t *data, const char *name, bool val)
  853. {
  854. obs_set_bool(data, NULL, name, val, set_item);
  855. }
  856. void obs_data_set_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  857. {
  858. obs_set_obj(data, NULL, name, obj, set_item);
  859. }
  860. void obs_data_set_array(obs_data_t *data, const char *name,
  861. obs_data_array_t *array)
  862. {
  863. obs_set_array(data, NULL, name, array, set_item);
  864. }
  865. void obs_data_set_default_string(obs_data_t *data, const char *name,
  866. const char *val)
  867. {
  868. obs_set_string(data, NULL, name, val, set_item_def);
  869. }
  870. void obs_data_set_default_int(obs_data_t *data, const char *name, long long val)
  871. {
  872. obs_set_int(data, NULL, name, val, set_item_def);
  873. }
  874. void obs_data_set_default_double(obs_data_t *data, const char *name, double val)
  875. {
  876. obs_set_double(data, NULL, name, val, set_item_def);
  877. }
  878. void obs_data_set_default_bool(obs_data_t *data, const char *name, bool val)
  879. {
  880. obs_set_bool(data, NULL, name, val, set_item_def);
  881. }
  882. void obs_data_set_default_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  883. {
  884. obs_set_obj(data, NULL, name, obj, set_item_def);
  885. }
  886. void obs_data_set_autoselect_string(obs_data_t *data, const char *name,
  887. const char *val)
  888. {
  889. obs_set_string(data, NULL, name, val, set_item_auto);
  890. }
  891. void obs_data_set_autoselect_int(obs_data_t *data, const char *name,
  892. long long val)
  893. {
  894. obs_set_int(data, NULL, name, val, set_item_auto);
  895. }
  896. void obs_data_set_autoselect_double(obs_data_t *data, const char *name,
  897. double val)
  898. {
  899. obs_set_double(data, NULL, name, val, set_item_auto);
  900. }
  901. void obs_data_set_autoselect_bool(obs_data_t *data, const char *name, bool val)
  902. {
  903. obs_set_bool(data, NULL, name, val, set_item_auto);
  904. }
  905. void obs_data_set_autoselect_obj(obs_data_t *data, const char *name,
  906. obs_data_t *obj)
  907. {
  908. obs_set_obj(data, NULL, name, obj, set_item_auto);
  909. }
  910. void obs_data_set_autoselect_array(obs_data_t *data, const char *name,
  911. obs_data_array_t *arr)
  912. {
  913. obs_set_array(data, NULL, name, arr, set_item_auto);
  914. }
  915. const char *obs_data_get_string(obs_data_t *data, const char *name)
  916. {
  917. return obs_data_item_get_string(get_item(data, name));
  918. }
  919. long long obs_data_get_int(obs_data_t *data, const char *name)
  920. {
  921. return obs_data_item_get_int(get_item(data, name));
  922. }
  923. double obs_data_get_double(obs_data_t *data, const char *name)
  924. {
  925. return obs_data_item_get_double(get_item(data, name));
  926. }
  927. bool obs_data_get_bool(obs_data_t *data, const char *name)
  928. {
  929. return obs_data_item_get_bool(get_item(data, name));
  930. }
  931. obs_data_t *obs_data_get_obj(obs_data_t *data, const char *name)
  932. {
  933. return obs_data_item_get_obj(get_item(data, name));
  934. }
  935. obs_data_array_t *obs_data_get_array(obs_data_t *data, const char *name)
  936. {
  937. return obs_data_item_get_array(get_item(data, name));
  938. }
  939. const char *obs_data_get_default_string(obs_data_t *data, const char *name)
  940. {
  941. return obs_data_item_get_default_string(get_item(data, name));
  942. }
  943. long long obs_data_get_default_int(obs_data_t *data, const char *name)
  944. {
  945. return obs_data_item_get_default_int(get_item(data, name));
  946. }
  947. double obs_data_get_default_double(obs_data_t *data, const char *name)
  948. {
  949. return obs_data_item_get_default_double(get_item(data, name));
  950. }
  951. bool obs_data_get_default_bool(obs_data_t *data, const char *name)
  952. {
  953. return obs_data_item_get_default_bool(get_item(data, name));
  954. }
  955. obs_data_t *obs_data_get_default_obj(obs_data_t *data, const char *name)
  956. {
  957. return obs_data_item_get_default_obj(get_item(data, name));
  958. }
  959. obs_data_array_t *obs_data_get_default_array(obs_data_t *data, const char *name)
  960. {
  961. return obs_data_item_get_default_array(get_item(data, name));
  962. }
  963. const char *obs_data_get_autoselect_string(obs_data_t *data, const char *name)
  964. {
  965. return obs_data_item_get_autoselect_string(get_item(data, name));
  966. }
  967. long long obs_data_get_autoselect_int(obs_data_t *data, const char *name)
  968. {
  969. return obs_data_item_get_autoselect_int(get_item(data, name));
  970. }
  971. double obs_data_get_autoselect_double(obs_data_t *data, const char *name)
  972. {
  973. return obs_data_item_get_autoselect_double(get_item(data, name));
  974. }
  975. bool obs_data_get_autoselect_bool(obs_data_t *data, const char *name)
  976. {
  977. return obs_data_item_get_autoselect_bool(get_item(data, name));
  978. }
  979. obs_data_t *obs_data_get_autoselect_obj(obs_data_t *data, const char *name)
  980. {
  981. return obs_data_item_get_autoselect_obj(get_item(data, name));
  982. }
  983. obs_data_array_t *obs_data_get_autoselect_array(obs_data_t *data,
  984. const char *name)
  985. {
  986. return obs_data_item_get_autoselect_array(get_item(data, name));
  987. }
  988. obs_data_array_t *obs_data_array_create()
  989. {
  990. struct obs_data_array *array = bzalloc(sizeof(struct obs_data_array));
  991. array->ref = 1;
  992. return array;
  993. }
  994. void obs_data_array_addref(obs_data_array_t *array)
  995. {
  996. if (array)
  997. os_atomic_inc_long(&array->ref);
  998. }
  999. static inline void obs_data_array_destroy(obs_data_array_t *array)
  1000. {
  1001. if (array) {
  1002. for (size_t i = 0; i < array->objects.num; i++)
  1003. obs_data_release(array->objects.array[i]);
  1004. da_free(array->objects);
  1005. bfree(array);
  1006. }
  1007. }
  1008. void obs_data_array_release(obs_data_array_t *array)
  1009. {
  1010. if (!array)
  1011. return;
  1012. if (os_atomic_dec_long(&array->ref) == 0)
  1013. obs_data_array_destroy(array);
  1014. }
  1015. size_t obs_data_array_count(obs_data_array_t *array)
  1016. {
  1017. return array ? array->objects.num : 0;
  1018. }
  1019. obs_data_t *obs_data_array_item(obs_data_array_t *array, size_t idx)
  1020. {
  1021. obs_data_t *data;
  1022. if (!array)
  1023. return NULL;
  1024. data = (idx < array->objects.num) ? array->objects.array[idx] : NULL;
  1025. if (data)
  1026. os_atomic_inc_long(&data->ref);
  1027. return data;
  1028. }
  1029. size_t obs_data_array_push_back(obs_data_array_t *array, obs_data_t *obj)
  1030. {
  1031. if (!array || !obj)
  1032. return 0;
  1033. os_atomic_inc_long(&obj->ref);
  1034. return da_push_back(array->objects, &obj);
  1035. }
  1036. void obs_data_array_insert(obs_data_array_t *array, size_t idx, obs_data_t *obj)
  1037. {
  1038. if (!array || !obj)
  1039. return;
  1040. os_atomic_inc_long(&obj->ref);
  1041. da_insert(array->objects, idx, &obj);
  1042. }
  1043. void obs_data_array_erase(obs_data_array_t *array, size_t idx)
  1044. {
  1045. if (array) {
  1046. obs_data_release(array->objects.array[idx]);
  1047. da_erase(array->objects, idx);
  1048. }
  1049. }
  1050. /* ------------------------------------------------------------------------- */
  1051. /* Item status inspection */
  1052. bool obs_data_has_user_value(obs_data_t *data, const char *name)
  1053. {
  1054. return data && obs_data_item_has_user_value(get_item(data, name));
  1055. }
  1056. bool obs_data_has_default_value(obs_data_t *data, const char *name)
  1057. {
  1058. return data && obs_data_item_has_default_value(get_item(data, name));
  1059. }
  1060. bool obs_data_has_autoselect_value(obs_data_t *data, const char *name)
  1061. {
  1062. return data && obs_data_item_has_autoselect_value(get_item(data, name));
  1063. }
  1064. bool obs_data_item_has_user_value(obs_data_item_t *item)
  1065. {
  1066. return item && item->data_size;
  1067. }
  1068. bool obs_data_item_has_default_value(obs_data_item_t *item)
  1069. {
  1070. return item && item->default_size;
  1071. }
  1072. bool obs_data_item_has_autoselect_value(obs_data_item_t *item)
  1073. {
  1074. return item && item->autoselect_size;
  1075. }
  1076. /* ------------------------------------------------------------------------- */
  1077. /* Clearing data values */
  1078. void obs_data_unset_user_value(obs_data_t *data, const char *name)
  1079. {
  1080. obs_data_item_unset_user_value(get_item(data, name));
  1081. }
  1082. void obs_data_unset_default_value(obs_data_t *data, const char *name)
  1083. {
  1084. obs_data_item_unset_default_value(get_item(data, name));
  1085. }
  1086. void obs_data_unset_autoselect_value(obs_data_t *data, const char *name)
  1087. {
  1088. obs_data_item_unset_autoselect_value(get_item(data, name));
  1089. }
  1090. void obs_data_item_unset_user_value(obs_data_item_t *item)
  1091. {
  1092. if (!item || !item->data_size)
  1093. return;
  1094. void *old_non_user_data = get_default_data_ptr(item);
  1095. item_data_release(item);
  1096. item->data_size = 0;
  1097. item->data_len = 0;
  1098. if (item->default_size || item->autoselect_size)
  1099. move_data(item, old_non_user_data, item,
  1100. get_default_data_ptr(item),
  1101. item->default_len + item->autoselect_size);
  1102. }
  1103. void obs_data_item_unset_default_value(obs_data_item_t *item)
  1104. {
  1105. if (!item || !item->default_size)
  1106. return;
  1107. void *old_autoselect_data = get_autoselect_data_ptr(item);
  1108. item_default_data_release(item);
  1109. item->default_size = 0;
  1110. item->default_len = 0;
  1111. if (item->autoselect_size)
  1112. move_data(item, old_autoselect_data, item,
  1113. get_autoselect_data_ptr(item),
  1114. item->autoselect_size);
  1115. }
  1116. void obs_data_item_unset_autoselect_value(obs_data_item_t *item)
  1117. {
  1118. if (!item || !item->autoselect_size)
  1119. return;
  1120. item_autoselect_data_release(item);
  1121. item->autoselect_size = 0;
  1122. }
  1123. /* ------------------------------------------------------------------------- */
  1124. /* Item iteration */
  1125. obs_data_item_t *obs_data_first(obs_data_t *data)
  1126. {
  1127. if (!data)
  1128. return NULL;
  1129. if (data->first_item)
  1130. os_atomic_inc_long(&data->first_item->ref);
  1131. return data->first_item;
  1132. }
  1133. obs_data_item_t *obs_data_item_byname(obs_data_t *data, const char *name)
  1134. {
  1135. if (!data)
  1136. return NULL;
  1137. struct obs_data_item *item = get_item(data, name);
  1138. if (item)
  1139. os_atomic_inc_long(&item->ref);
  1140. return item;
  1141. }
  1142. bool obs_data_item_next(obs_data_item_t **item)
  1143. {
  1144. if (item && *item) {
  1145. obs_data_item_t *next = (*item)->next;
  1146. obs_data_item_release(item);
  1147. *item = next;
  1148. if (next) {
  1149. os_atomic_inc_long(&next->ref);
  1150. return true;
  1151. }
  1152. }
  1153. return false;
  1154. }
  1155. void obs_data_item_release(obs_data_item_t **item)
  1156. {
  1157. if (item && *item) {
  1158. long ref = os_atomic_dec_long(&(*item)->ref);
  1159. if (!ref) {
  1160. obs_data_item_destroy(*item);
  1161. *item = NULL;
  1162. }
  1163. }
  1164. }
  1165. void obs_data_item_remove(obs_data_item_t **item)
  1166. {
  1167. if (item && *item) {
  1168. obs_data_item_detach(*item);
  1169. obs_data_item_release(item);
  1170. }
  1171. }
  1172. enum obs_data_type obs_data_item_gettype(obs_data_item_t *item)
  1173. {
  1174. return item ? item->type : OBS_DATA_NULL;
  1175. }
  1176. enum obs_data_number_type obs_data_item_numtype(obs_data_item_t *item)
  1177. {
  1178. struct obs_data_number *num;
  1179. if (!item || item->type != OBS_DATA_NUMBER)
  1180. return OBS_DATA_NUM_INVALID;
  1181. num = get_item_data(item);
  1182. return num->type;
  1183. }
  1184. void obs_data_item_set_string(obs_data_item_t **item, const char *val)
  1185. {
  1186. obs_set_string(NULL, item, NULL, val, set_item);
  1187. }
  1188. void obs_data_item_set_int(obs_data_item_t **item, long long val)
  1189. {
  1190. obs_set_int(NULL, item, NULL, val, set_item);
  1191. }
  1192. void obs_data_item_set_double(obs_data_item_t **item, double val)
  1193. {
  1194. obs_set_double(NULL, item, NULL, val, set_item);
  1195. }
  1196. void obs_data_item_set_bool(obs_data_item_t **item, bool val)
  1197. {
  1198. obs_set_bool(NULL, item, NULL, val, set_item);
  1199. }
  1200. void obs_data_item_set_obj(obs_data_item_t **item, obs_data_t *val)
  1201. {
  1202. obs_set_obj(NULL, item, NULL, val, set_item);
  1203. }
  1204. void obs_data_item_set_array(obs_data_item_t **item, obs_data_array_t *val)
  1205. {
  1206. obs_set_array(NULL, item, NULL, val, set_item);
  1207. }
  1208. void obs_data_item_set_default_string(obs_data_item_t **item, const char *val)
  1209. {
  1210. obs_set_string(NULL, item, NULL, val, set_item_def);
  1211. }
  1212. void obs_data_item_set_default_int(obs_data_item_t **item, long long val)
  1213. {
  1214. obs_set_int(NULL, item, NULL, val, set_item_def);
  1215. }
  1216. void obs_data_item_set_default_double(obs_data_item_t **item, double val)
  1217. {
  1218. obs_set_double(NULL, item, NULL, val, set_item_def);
  1219. }
  1220. void obs_data_item_set_default_bool(obs_data_item_t **item, bool val)
  1221. {
  1222. obs_set_bool(NULL, item, NULL, val, set_item_def);
  1223. }
  1224. void obs_data_item_set_default_obj(obs_data_item_t **item, obs_data_t *val)
  1225. {
  1226. obs_set_obj(NULL, item, NULL, val, set_item_def);
  1227. }
  1228. void obs_data_item_set_default_array(obs_data_item_t **item,
  1229. obs_data_array_t *val)
  1230. {
  1231. obs_set_array(NULL, item, NULL, val, set_item_def);
  1232. }
  1233. void obs_data_item_set_autoselect_string(obs_data_item_t **item, const char *val)
  1234. {
  1235. obs_set_string(NULL, item, NULL, val, set_item_auto);
  1236. }
  1237. void obs_data_item_set_autoselect_int(obs_data_item_t **item, long long val)
  1238. {
  1239. obs_set_int(NULL, item, NULL, val, set_item_auto);
  1240. }
  1241. void obs_data_item_set_autoselect_double(obs_data_item_t **item, double val)
  1242. {
  1243. obs_set_double(NULL, item, NULL, val, set_item_auto);
  1244. }
  1245. void obs_data_item_set_autoselect_bool(obs_data_item_t **item, bool val)
  1246. {
  1247. obs_set_bool(NULL, item, NULL, val, set_item_auto);
  1248. }
  1249. void obs_data_item_set_autoselect_obj(obs_data_item_t **item, obs_data_t *val)
  1250. {
  1251. obs_set_obj(NULL, item, NULL, val, set_item_auto);
  1252. }
  1253. void obs_data_item_set_autoselect_array(obs_data_item_t **item,
  1254. obs_data_array_t *val)
  1255. {
  1256. obs_set_array(NULL, item, NULL, val, set_item_auto);
  1257. }
  1258. static inline bool item_valid(struct obs_data_item *item,
  1259. enum obs_data_type type)
  1260. {
  1261. return item && item->type == type;
  1262. }
  1263. typedef void *(*get_data_t)(obs_data_item_t*);
  1264. static inline const char *data_item_get_string(obs_data_item_t *item,
  1265. get_data_t get_data)
  1266. {
  1267. return item_valid(item, OBS_DATA_STRING) && get_data(item) ?
  1268. get_data(item) : "";
  1269. }
  1270. static inline long long item_int(struct obs_data_item *item,
  1271. get_data_t get_data)
  1272. {
  1273. if (item && get_data(item)) {
  1274. struct obs_data_number *num = get_data(item);
  1275. return (num->type == OBS_DATA_NUM_INT) ?
  1276. num->int_val : (long long)num->double_val;
  1277. }
  1278. return 0;
  1279. }
  1280. static inline long long data_item_get_int(obs_data_item_t *item,
  1281. get_data_t get_data)
  1282. {
  1283. return item_int(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1284. get_data);
  1285. }
  1286. static inline double item_double(struct obs_data_item *item,
  1287. get_data_t get_data)
  1288. {
  1289. if (item && get_data(item)) {
  1290. struct obs_data_number *num = get_data(item);
  1291. return (num->type == OBS_DATA_NUM_INT) ?
  1292. (double)num->int_val : num->double_val;
  1293. }
  1294. return 0.0;
  1295. }
  1296. static inline double data_item_get_double(obs_data_item_t *item,
  1297. get_data_t get_data)
  1298. {
  1299. return item_double(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1300. get_data);
  1301. }
  1302. static inline bool data_item_get_bool(obs_data_item_t *item, get_data_t get_data)
  1303. {
  1304. return item_valid(item, OBS_DATA_BOOLEAN) && get_data(item) ?
  1305. *(bool*)get_data(item) : false;
  1306. }
  1307. typedef obs_data_t *(*get_obj_t)(obs_data_item_t*);
  1308. static inline obs_data_t *data_item_get_obj(obs_data_item_t *item,
  1309. get_obj_t get_obj)
  1310. {
  1311. obs_data_t *obj = item_valid(item, OBS_DATA_OBJECT) ?
  1312. get_obj(item) : NULL;
  1313. if (obj)
  1314. os_atomic_inc_long(&obj->ref);
  1315. return obj;
  1316. }
  1317. typedef obs_data_array_t *(*get_array_t)(obs_data_item_t*);
  1318. static inline obs_data_array_t *data_item_get_array(obs_data_item_t *item,
  1319. get_array_t get_array)
  1320. {
  1321. obs_data_array_t *array = item_valid(item, OBS_DATA_ARRAY) ?
  1322. get_array(item) : NULL;
  1323. if (array)
  1324. os_atomic_inc_long(&array->ref);
  1325. return array;
  1326. }
  1327. const char *obs_data_item_get_string(obs_data_item_t *item)
  1328. {
  1329. return data_item_get_string(item, get_item_data);
  1330. }
  1331. long long obs_data_item_get_int(obs_data_item_t *item)
  1332. {
  1333. return data_item_get_int(item, get_item_data);
  1334. }
  1335. double obs_data_item_get_double(obs_data_item_t *item)
  1336. {
  1337. return data_item_get_double(item, get_item_data);
  1338. }
  1339. bool obs_data_item_get_bool(obs_data_item_t *item)
  1340. {
  1341. return data_item_get_bool(item, get_item_data);
  1342. }
  1343. obs_data_t *obs_data_item_get_obj(obs_data_item_t *item)
  1344. {
  1345. return data_item_get_obj(item, get_item_obj);
  1346. }
  1347. obs_data_array_t *obs_data_item_get_array(obs_data_item_t *item)
  1348. {
  1349. return data_item_get_array(item, get_item_array);
  1350. }
  1351. const char *obs_data_item_get_default_string(obs_data_item_t *item)
  1352. {
  1353. return data_item_get_string(item, get_item_default_data);
  1354. }
  1355. long long obs_data_item_get_default_int(obs_data_item_t *item)
  1356. {
  1357. return data_item_get_int(item, get_item_default_data);
  1358. }
  1359. double obs_data_item_get_default_double(obs_data_item_t *item)
  1360. {
  1361. return data_item_get_double(item, get_item_default_data);
  1362. }
  1363. bool obs_data_item_get_default_bool(obs_data_item_t *item)
  1364. {
  1365. return data_item_get_bool(item, get_item_default_data);
  1366. }
  1367. obs_data_t *obs_data_item_get_default_obj(obs_data_item_t *item)
  1368. {
  1369. return data_item_get_obj(item, get_item_obj);
  1370. }
  1371. obs_data_array_t *obs_data_item_get_default_array(obs_data_item_t *item)
  1372. {
  1373. return data_item_get_array(item, get_item_array);
  1374. }
  1375. const char *obs_data_item_get_autoselect_string(obs_data_item_t *item)
  1376. {
  1377. return data_item_get_string(item, get_item_autoselect_data);
  1378. }
  1379. long long obs_data_item_get_autoselect_int(obs_data_item_t *item)
  1380. {
  1381. return data_item_get_int(item, get_item_autoselect_data);
  1382. }
  1383. double obs_data_item_get_autoselect_double(obs_data_item_t *item)
  1384. {
  1385. return data_item_get_double(item, get_item_autoselect_data);
  1386. }
  1387. bool obs_data_item_get_autoselect_bool(obs_data_item_t *item)
  1388. {
  1389. return data_item_get_bool(item, get_item_autoselect_data);
  1390. }
  1391. obs_data_t *obs_data_item_get_autoselect_obj(obs_data_item_t *item)
  1392. {
  1393. return data_item_get_obj(item, get_item_autoselect_obj);
  1394. }
  1395. obs_data_array_t *obs_data_item_get_autoselect_array(obs_data_item_t *item)
  1396. {
  1397. return data_item_get_array(item, get_item_autoselect_array);
  1398. }
  1399. /* ------------------------------------------------------------------------- */
  1400. /* Helper functions for certain structures */
  1401. typedef void (*set_obj_t)(obs_data_t*, const char*, obs_data_t*);
  1402. static inline void set_vec2(obs_data_t *data, const char *name,
  1403. const struct vec2 *val, set_obj_t set_obj)
  1404. {
  1405. obs_data_t *obj = obs_data_create();
  1406. obs_data_set_double(obj, "x", val->x);
  1407. obs_data_set_double(obj, "y", val->y);
  1408. set_obj(data, name, obj);
  1409. obs_data_release(obj);
  1410. }
  1411. static inline void set_vec3(obs_data_t *data, const char *name,
  1412. const struct vec3 *val, set_obj_t set_obj)
  1413. {
  1414. obs_data_t *obj = obs_data_create();
  1415. obs_data_set_double(obj, "x", val->x);
  1416. obs_data_set_double(obj, "y", val->y);
  1417. obs_data_set_double(obj, "z", val->z);
  1418. set_obj(data, name, obj);
  1419. obs_data_release(obj);
  1420. }
  1421. static inline void set_vec4(obs_data_t *data, const char *name,
  1422. const struct vec4 *val, set_obj_t set_obj)
  1423. {
  1424. obs_data_t *obj = obs_data_create();
  1425. obs_data_set_double(obj, "x", val->x);
  1426. obs_data_set_double(obj, "y", val->y);
  1427. obs_data_set_double(obj, "z", val->z);
  1428. obs_data_set_double(obj, "w", val->w);
  1429. set_obj(data, name, obj);
  1430. obs_data_release(obj);
  1431. }
  1432. static inline void set_quat(obs_data_t *data, const char *name,
  1433. const struct quat *val, set_obj_t set_obj)
  1434. {
  1435. obs_data_t *obj = obs_data_create();
  1436. obs_data_set_double(obj, "x", val->x);
  1437. obs_data_set_double(obj, "y", val->y);
  1438. obs_data_set_double(obj, "z", val->z);
  1439. obs_data_set_double(obj, "w", val->w);
  1440. set_obj(data, name, obj);
  1441. obs_data_release(obj);
  1442. }
  1443. void obs_data_set_vec2(obs_data_t *data, const char *name,
  1444. const struct vec2 *val)
  1445. {
  1446. set_vec2(data, name, val, obs_data_set_obj);
  1447. }
  1448. void obs_data_set_vec3(obs_data_t *data, const char *name,
  1449. const struct vec3 *val)
  1450. {
  1451. set_vec3(data, name, val, obs_data_set_obj);
  1452. }
  1453. void obs_data_set_vec4(obs_data_t *data, const char *name,
  1454. const struct vec4 *val)
  1455. {
  1456. set_vec4(data, name, val, obs_data_set_obj);
  1457. }
  1458. void obs_data_set_quat(obs_data_t *data, const char *name,
  1459. const struct quat *val)
  1460. {
  1461. set_quat(data, name, val, obs_data_set_obj);
  1462. }
  1463. void obs_data_set_default_vec2(obs_data_t *data, const char *name,
  1464. const struct vec2 *val)
  1465. {
  1466. set_vec2(data, name, val, obs_data_set_default_obj);
  1467. }
  1468. void obs_data_set_default_vec3(obs_data_t *data, const char *name,
  1469. const struct vec3 *val)
  1470. {
  1471. set_vec3(data, name, val, obs_data_set_default_obj);
  1472. }
  1473. void obs_data_set_default_vec4(obs_data_t *data, const char *name,
  1474. const struct vec4 *val)
  1475. {
  1476. set_vec4(data, name, val, obs_data_set_default_obj);
  1477. }
  1478. void obs_data_set_default_quat(obs_data_t *data, const char *name,
  1479. const struct quat *val)
  1480. {
  1481. set_quat(data, name, val, obs_data_set_default_obj);
  1482. }
  1483. void obs_data_set_autoselect_vec2(obs_data_t *data, const char *name,
  1484. const struct vec2 *val)
  1485. {
  1486. set_vec2(data, name, val, obs_data_set_autoselect_obj);
  1487. }
  1488. void obs_data_set_autoselect_vec3(obs_data_t *data, const char *name,
  1489. const struct vec3 *val)
  1490. {
  1491. set_vec3(data, name, val, obs_data_set_autoselect_obj);
  1492. }
  1493. void obs_data_set_autoselect_vec4(obs_data_t *data, const char *name,
  1494. const struct vec4 *val)
  1495. {
  1496. set_vec4(data, name, val, obs_data_set_autoselect_obj);
  1497. }
  1498. void obs_data_set_autoselect_quat(obs_data_t *data, const char *name,
  1499. const struct quat *val)
  1500. {
  1501. set_quat(data, name, val, obs_data_set_autoselect_obj);
  1502. }
  1503. static inline void get_vec2(obs_data_t *obj, struct vec2 *val)
  1504. {
  1505. if (!obj) return;
  1506. val->x = (float)obs_data_get_double(obj, "x");
  1507. val->y = (float)obs_data_get_double(obj, "y");
  1508. obs_data_release(obj);
  1509. }
  1510. static inline void get_vec3(obs_data_t *obj, struct vec3 *val)
  1511. {
  1512. if (!obj) return;
  1513. val->x = (float)obs_data_get_double(obj, "x");
  1514. val->y = (float)obs_data_get_double(obj, "y");
  1515. val->z = (float)obs_data_get_double(obj, "z");
  1516. obs_data_release(obj);
  1517. }
  1518. static inline void get_vec4(obs_data_t *obj, struct vec4 *val)
  1519. {
  1520. if (!obj) return;
  1521. val->x = (float)obs_data_get_double(obj, "x");
  1522. val->y = (float)obs_data_get_double(obj, "y");
  1523. val->z = (float)obs_data_get_double(obj, "z");
  1524. val->w = (float)obs_data_get_double(obj, "w");
  1525. obs_data_release(obj);
  1526. }
  1527. static inline void get_quat(obs_data_t *obj, struct quat *val)
  1528. {
  1529. if (!obj) return;
  1530. val->x = (float)obs_data_get_double(obj, "x");
  1531. val->y = (float)obs_data_get_double(obj, "y");
  1532. val->z = (float)obs_data_get_double(obj, "z");
  1533. val->w = (float)obs_data_get_double(obj, "w");
  1534. obs_data_release(obj);
  1535. }
  1536. void obs_data_get_vec2(obs_data_t *data, const char *name, struct vec2 *val)
  1537. {
  1538. get_vec2(obs_data_get_obj(data, name), val);
  1539. }
  1540. void obs_data_get_vec3(obs_data_t *data, const char *name, struct vec3 *val)
  1541. {
  1542. get_vec3(obs_data_get_obj(data, name), val);
  1543. }
  1544. void obs_data_get_vec4(obs_data_t *data, const char *name, struct vec4 *val)
  1545. {
  1546. get_vec4(obs_data_get_obj(data, name), val);
  1547. }
  1548. void obs_data_get_quat(obs_data_t *data, const char *name, struct quat *val)
  1549. {
  1550. get_quat(obs_data_get_obj(data, name), val);
  1551. }
  1552. void obs_data_get_default_vec2(obs_data_t *data, const char *name,
  1553. struct vec2 *val)
  1554. {
  1555. get_vec2(obs_data_get_default_obj(data, name), val);
  1556. }
  1557. void obs_data_get_default_vec3(obs_data_t *data, const char *name,
  1558. struct vec3 *val)
  1559. {
  1560. get_vec3(obs_data_get_default_obj(data, name), val);
  1561. }
  1562. void obs_data_get_default_vec4(obs_data_t *data, const char *name,
  1563. struct vec4 *val)
  1564. {
  1565. get_vec4(obs_data_get_default_obj(data, name), val);
  1566. }
  1567. void obs_data_get_default_quat(obs_data_t *data, const char *name,
  1568. struct quat *val)
  1569. {
  1570. get_quat(obs_data_get_default_obj(data, name), val);
  1571. }
  1572. void obs_data_get_autoselect_vec2(obs_data_t *data, const char *name,
  1573. struct vec2 *val)
  1574. {
  1575. get_vec2(obs_data_get_autoselect_obj(data, name), val);
  1576. }
  1577. void obs_data_get_autoselect_vec3(obs_data_t *data, const char *name,
  1578. struct vec3 *val)
  1579. {
  1580. get_vec3(obs_data_get_autoselect_obj(data, name), val);
  1581. }
  1582. void obs_data_get_autoselect_vec4(obs_data_t *data, const char *name,
  1583. struct vec4 *val)
  1584. {
  1585. get_vec4(obs_data_get_autoselect_obj(data, name), val);
  1586. }
  1587. void obs_data_get_autoselect_quat(obs_data_t *data, const char *name,
  1588. struct quat *val)
  1589. {
  1590. get_quat(obs_data_get_autoselect_obj(data, name), val);
  1591. }