obs-data.c 46 KB

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