obs-data.c 56 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317
  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 + item->data_len +
  104. 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. obs_data_t **data = get_item_data(item);
  111. if (!data)
  112. return NULL;
  113. return *data;
  114. }
  115. static inline obs_data_t *get_item_default_obj(struct obs_data_item *item)
  116. {
  117. if (!item || !item->default_size)
  118. return NULL;
  119. return *(obs_data_t **)get_default_data_ptr(item);
  120. }
  121. static inline obs_data_t *get_item_autoselect_obj(struct obs_data_item *item)
  122. {
  123. if (!item || !item->autoselect_size)
  124. return NULL;
  125. return *(obs_data_t **)get_autoselect_data_ptr(item);
  126. }
  127. static inline obs_data_array_t *get_item_array(struct obs_data_item *item)
  128. {
  129. obs_data_array_t **array;
  130. if (!item)
  131. return NULL;
  132. array = (obs_data_array_t **)get_item_data(item);
  133. return array ? *array : NULL;
  134. }
  135. static inline obs_data_array_t *
  136. get_item_default_array(struct obs_data_item *item)
  137. {
  138. if (!item || !item->default_size)
  139. return NULL;
  140. return *(obs_data_array_t **)get_default_data_ptr(item);
  141. }
  142. static inline obs_data_array_t *
  143. get_item_autoselect_array(struct obs_data_item *item)
  144. {
  145. if (!item || !item->autoselect_size)
  146. return NULL;
  147. return *(obs_data_array_t **)get_autoselect_data_ptr(item);
  148. }
  149. static inline void item_data_release(struct obs_data_item *item)
  150. {
  151. if (!obs_data_item_has_user_value(item))
  152. return;
  153. if (item->type == OBS_DATA_OBJECT) {
  154. obs_data_t *obj = get_item_obj(item);
  155. obs_data_release(obj);
  156. } else if (item->type == OBS_DATA_ARRAY) {
  157. obs_data_array_t *array = get_item_array(item);
  158. obs_data_array_release(array);
  159. }
  160. }
  161. static inline void item_default_data_release(struct obs_data_item *item)
  162. {
  163. if (item->type == OBS_DATA_OBJECT) {
  164. obs_data_t *obj = get_item_default_obj(item);
  165. obs_data_release(obj);
  166. } else if (item->type == OBS_DATA_ARRAY) {
  167. obs_data_array_t *array = get_item_default_array(item);
  168. obs_data_array_release(array);
  169. }
  170. }
  171. static inline void item_autoselect_data_release(struct obs_data_item *item)
  172. {
  173. if (item->type == OBS_DATA_OBJECT) {
  174. obs_data_t *obj = get_item_autoselect_obj(item);
  175. obs_data_release(obj);
  176. } else if (item->type == OBS_DATA_ARRAY) {
  177. obs_data_array_t *array = get_item_autoselect_array(item);
  178. obs_data_array_release(array);
  179. }
  180. }
  181. static inline void item_data_addref(struct obs_data_item *item)
  182. {
  183. if (item->type == OBS_DATA_OBJECT) {
  184. obs_data_t *obj = get_item_obj(item);
  185. obs_data_addref(obj);
  186. } else if (item->type == OBS_DATA_ARRAY) {
  187. obs_data_array_t *array = get_item_array(item);
  188. obs_data_array_addref(array);
  189. }
  190. }
  191. static inline void item_default_data_addref(struct obs_data_item *item)
  192. {
  193. if (!item->data_size)
  194. return;
  195. if (item->type == OBS_DATA_OBJECT) {
  196. obs_data_t *obj = get_item_default_obj(item);
  197. obs_data_addref(obj);
  198. } else if (item->type == OBS_DATA_ARRAY) {
  199. obs_data_array_t *array = get_item_default_array(item);
  200. obs_data_array_addref(array);
  201. }
  202. }
  203. static inline void item_autoselect_data_addref(struct obs_data_item *item)
  204. {
  205. if (item->type == OBS_DATA_OBJECT) {
  206. obs_data_t *obj = get_item_autoselect_obj(item);
  207. obs_data_addref(obj);
  208. } else if (item->type == OBS_DATA_ARRAY) {
  209. obs_data_array_t *array = get_item_autoselect_array(item);
  210. obs_data_array_addref(array);
  211. }
  212. }
  213. static struct obs_data_item *obs_data_item_create(const char *name,
  214. const void *data, size_t size,
  215. enum obs_data_type type,
  216. bool default_data,
  217. bool autoselect_data)
  218. {
  219. struct obs_data_item *item;
  220. size_t name_size, total_size;
  221. if (!name || !data)
  222. return NULL;
  223. name_size = get_name_align_size(name);
  224. total_size = name_size + sizeof(struct obs_data_item) + size;
  225. item = bzalloc(total_size);
  226. item->capacity = total_size;
  227. item->type = type;
  228. item->name_len = name_size;
  229. item->ref = 1;
  230. if (default_data) {
  231. item->default_len = size;
  232. item->default_size = size;
  233. } else if (autoselect_data) {
  234. item->autoselect_size = size;
  235. } else {
  236. item->data_len = size;
  237. item->data_size = size;
  238. }
  239. strcpy(get_item_name(item), name);
  240. memcpy(get_item_data(item), data, size);
  241. item_data_addref(item);
  242. return item;
  243. }
  244. static struct obs_data_item **get_item_prev_next(struct obs_data *data,
  245. struct obs_data_item *current)
  246. {
  247. if (!current || !data)
  248. return NULL;
  249. struct obs_data_item **prev_next = &data->first_item;
  250. struct obs_data_item *item = data->first_item;
  251. while (item) {
  252. if (item == current)
  253. return prev_next;
  254. prev_next = &item->next;
  255. item = item->next;
  256. }
  257. return NULL;
  258. }
  259. static inline void obs_data_item_detach(struct obs_data_item *item)
  260. {
  261. struct obs_data_item **prev_next =
  262. get_item_prev_next(item->parent, item);
  263. if (prev_next) {
  264. *prev_next = item->next;
  265. item->next = NULL;
  266. }
  267. }
  268. static inline void obs_data_item_reattach(struct obs_data_item *old_ptr,
  269. struct obs_data_item *new_ptr)
  270. {
  271. struct obs_data_item **prev_next =
  272. get_item_prev_next(new_ptr->parent, old_ptr);
  273. if (prev_next)
  274. *prev_next = new_ptr;
  275. }
  276. static struct obs_data_item *
  277. obs_data_item_ensure_capacity(struct obs_data_item *item)
  278. {
  279. size_t new_size = obs_data_item_total_size(item);
  280. struct obs_data_item *new_item;
  281. if (item->capacity >= new_size)
  282. return item;
  283. new_item = brealloc(item, new_size);
  284. new_item->capacity = new_size;
  285. obs_data_item_reattach(item, new_item);
  286. return new_item;
  287. }
  288. static inline void obs_data_item_destroy(struct obs_data_item *item)
  289. {
  290. item_data_release(item);
  291. item_default_data_release(item);
  292. item_autoselect_data_release(item);
  293. obs_data_item_detach(item);
  294. bfree(item);
  295. }
  296. static inline void move_data(obs_data_item_t *old_item, void *old_data,
  297. obs_data_item_t *item, void *data, size_t len)
  298. {
  299. ptrdiff_t old_offset = (uint8_t *)old_data - (uint8_t *)old_item;
  300. ptrdiff_t new_offset = (uint8_t *)data - (uint8_t *)item;
  301. if (!old_data)
  302. return;
  303. memmove((uint8_t *)item + new_offset, (uint8_t *)item + old_offset,
  304. len);
  305. }
  306. static inline void obs_data_item_setdata(struct obs_data_item **p_item,
  307. const void *data, size_t size,
  308. enum obs_data_type type)
  309. {
  310. if (!p_item || !*p_item)
  311. return;
  312. struct obs_data_item *item = *p_item;
  313. ptrdiff_t old_default_data_pos =
  314. (uint8_t *)get_default_data_ptr(item) - (uint8_t *)item;
  315. item_data_release(item);
  316. item->data_size = size;
  317. item->type = type;
  318. item->data_len = (item->default_size || item->autoselect_size)
  319. ? get_align_size(size)
  320. : size;
  321. item = obs_data_item_ensure_capacity(item);
  322. if (item->default_size || item->autoselect_size)
  323. memmove(get_default_data_ptr(item),
  324. (uint8_t *)item + old_default_data_pos,
  325. item->default_len + item->autoselect_size);
  326. if (size) {
  327. memcpy(get_item_data(item), data, size);
  328. item_data_addref(item);
  329. }
  330. *p_item = item;
  331. }
  332. static inline void obs_data_item_set_default_data(struct obs_data_item **p_item,
  333. const void *data, size_t size,
  334. enum obs_data_type type)
  335. {
  336. if (!p_item || !*p_item)
  337. return;
  338. struct obs_data_item *item = *p_item;
  339. void *old_autoselect_data = get_autoselect_data_ptr(item);
  340. item_default_data_release(item);
  341. item->type = type;
  342. item->default_size = size;
  343. item->default_len = item->autoselect_size ? get_align_size(size) : size;
  344. item->data_len = item->data_size ? get_align_size(item->data_size) : 0;
  345. item = obs_data_item_ensure_capacity(item);
  346. if (item->autoselect_size)
  347. move_data(*p_item, old_autoselect_data, item,
  348. get_autoselect_data_ptr(item), item->autoselect_size);
  349. if (size) {
  350. memcpy(get_item_default_data(item), data, size);
  351. item_default_data_addref(item);
  352. }
  353. *p_item = item;
  354. }
  355. static inline void
  356. obs_data_item_set_autoselect_data(struct obs_data_item **p_item,
  357. const void *data, size_t size,
  358. enum obs_data_type type)
  359. {
  360. if (!p_item || !*p_item)
  361. return;
  362. struct obs_data_item *item = *p_item;
  363. item_autoselect_data_release(item);
  364. item->autoselect_size = size;
  365. item->type = type;
  366. item->data_len = item->data_size ? get_align_size(item->data_size) : 0;
  367. item->default_len =
  368. item->default_size ? get_align_size(item->default_size) : 0;
  369. item = obs_data_item_ensure_capacity(item);
  370. if (size) {
  371. memcpy(get_item_autoselect_data(item), data, size);
  372. item_autoselect_data_addref(item);
  373. }
  374. *p_item = item;
  375. }
  376. /* ------------------------------------------------------------------------- */
  377. static void obs_data_add_json_item(obs_data_t *data, const char *key,
  378. json_t *json);
  379. static inline void obs_data_add_json_object_data(obs_data_t *data, json_t *jobj)
  380. {
  381. const char *item_key;
  382. json_t *jitem;
  383. json_object_foreach (jobj, item_key, jitem) {
  384. obs_data_add_json_item(data, item_key, jitem);
  385. }
  386. }
  387. static inline void obs_data_add_json_object(obs_data_t *data, const char *key,
  388. json_t *jobj)
  389. {
  390. obs_data_t *sub_obj = obs_data_create();
  391. obs_data_add_json_object_data(sub_obj, jobj);
  392. obs_data_set_obj(data, key, sub_obj);
  393. obs_data_release(sub_obj);
  394. }
  395. static void obs_data_add_json_array(obs_data_t *data, const char *key,
  396. json_t *jarray)
  397. {
  398. obs_data_array_t *array = obs_data_array_create();
  399. size_t idx;
  400. json_t *jitem;
  401. json_array_foreach (jarray, idx, jitem) {
  402. obs_data_t *item;
  403. if (!json_is_object(jitem))
  404. continue;
  405. item = obs_data_create();
  406. obs_data_add_json_object_data(item, jitem);
  407. obs_data_array_push_back(array, item);
  408. obs_data_release(item);
  409. }
  410. obs_data_set_array(data, key, array);
  411. obs_data_array_release(array);
  412. }
  413. static void obs_data_add_json_item(obs_data_t *data, const char *key,
  414. json_t *json)
  415. {
  416. if (json_is_object(json))
  417. obs_data_add_json_object(data, key, json);
  418. else if (json_is_array(json))
  419. obs_data_add_json_array(data, key, json);
  420. else if (json_is_string(json))
  421. obs_data_set_string(data, key, json_string_value(json));
  422. else if (json_is_integer(json))
  423. obs_data_set_int(data, key, json_integer_value(json));
  424. else if (json_is_real(json))
  425. obs_data_set_double(data, key, json_real_value(json));
  426. else if (json_is_true(json))
  427. obs_data_set_bool(data, key, true);
  428. else if (json_is_false(json))
  429. obs_data_set_bool(data, key, false);
  430. }
  431. /* ------------------------------------------------------------------------- */
  432. static inline void set_json_string(json_t *json, const char *name,
  433. obs_data_item_t *item)
  434. {
  435. const char *val = obs_data_item_get_string(item);
  436. json_object_set_new(json, name, json_string(val));
  437. }
  438. static inline void set_json_number(json_t *json, const char *name,
  439. obs_data_item_t *item)
  440. {
  441. enum obs_data_number_type type = obs_data_item_numtype(item);
  442. if (type == OBS_DATA_NUM_INT) {
  443. long long val = obs_data_item_get_int(item);
  444. json_object_set_new(json, name, json_integer(val));
  445. } else {
  446. double val = obs_data_item_get_double(item);
  447. json_object_set_new(json, name, json_real(val));
  448. }
  449. }
  450. static inline void set_json_bool(json_t *json, const char *name,
  451. obs_data_item_t *item)
  452. {
  453. bool val = obs_data_item_get_bool(item);
  454. json_object_set_new(json, name, val ? json_true() : json_false());
  455. }
  456. static json_t *obs_data_to_json(obs_data_t *data);
  457. static inline void set_json_obj(json_t *json, const char *name,
  458. obs_data_item_t *item)
  459. {
  460. obs_data_t *obj = obs_data_item_get_obj(item);
  461. json_object_set_new(json, name, obs_data_to_json(obj));
  462. obs_data_release(obj);
  463. }
  464. static inline void set_json_array(json_t *json, const char *name,
  465. obs_data_item_t *item)
  466. {
  467. json_t *jarray = json_array();
  468. obs_data_array_t *array = obs_data_item_get_array(item);
  469. size_t count = obs_data_array_count(array);
  470. for (size_t idx = 0; idx < count; idx++) {
  471. obs_data_t *sub_item = obs_data_array_item(array, idx);
  472. json_t *jitem = obs_data_to_json(sub_item);
  473. json_array_append_new(jarray, jitem);
  474. obs_data_release(sub_item);
  475. }
  476. json_object_set_new(json, name, jarray);
  477. obs_data_array_release(array);
  478. }
  479. static json_t *obs_data_to_json(obs_data_t *data)
  480. {
  481. json_t *json = json_object();
  482. obs_data_item_t *item = NULL;
  483. for (item = obs_data_first(data); item; obs_data_item_next(&item)) {
  484. enum obs_data_type type = obs_data_item_gettype(item);
  485. const char *name = get_item_name(item);
  486. if (!obs_data_item_has_user_value(item))
  487. continue;
  488. if (type == OBS_DATA_STRING)
  489. set_json_string(json, name, item);
  490. else if (type == OBS_DATA_NUMBER)
  491. set_json_number(json, name, item);
  492. else if (type == OBS_DATA_BOOLEAN)
  493. set_json_bool(json, name, item);
  494. else if (type == OBS_DATA_OBJECT)
  495. set_json_obj(json, name, item);
  496. else if (type == OBS_DATA_ARRAY)
  497. set_json_array(json, name, item);
  498. }
  499. return json;
  500. }
  501. /* ------------------------------------------------------------------------- */
  502. obs_data_t *obs_data_create()
  503. {
  504. struct obs_data *data = bzalloc(sizeof(struct obs_data));
  505. data->ref = 1;
  506. return data;
  507. }
  508. obs_data_t *obs_data_create_from_json(const char *json_string)
  509. {
  510. obs_data_t *data = obs_data_create();
  511. json_error_t error;
  512. json_t *root = json_loads(json_string, JSON_REJECT_DUPLICATES, &error);
  513. if (root) {
  514. obs_data_add_json_object_data(data, root);
  515. json_decref(root);
  516. } else {
  517. blog(LOG_ERROR,
  518. "obs-data.c: [obs_data_create_from_json] "
  519. "Failed reading json string (%d): %s",
  520. error.line, error.text);
  521. obs_data_release(data);
  522. data = NULL;
  523. }
  524. return data;
  525. }
  526. obs_data_t *obs_data_create_from_json_file(const char *json_file)
  527. {
  528. char *file_data = os_quick_read_utf8_file(json_file);
  529. obs_data_t *data = NULL;
  530. if (file_data) {
  531. data = obs_data_create_from_json(file_data);
  532. bfree(file_data);
  533. }
  534. return data;
  535. }
  536. obs_data_t *obs_data_create_from_json_file_safe(const char *json_file,
  537. const char *backup_ext)
  538. {
  539. obs_data_t *file_data = obs_data_create_from_json_file(json_file);
  540. if (!file_data && backup_ext && *backup_ext) {
  541. struct dstr backup_file = {0};
  542. dstr_copy(&backup_file, json_file);
  543. if (*backup_ext != '.')
  544. dstr_cat(&backup_file, ".");
  545. dstr_cat(&backup_file, backup_ext);
  546. if (os_file_exists(backup_file.array)) {
  547. blog(LOG_WARNING,
  548. "obs-data.c: "
  549. "[obs_data_create_from_json_file_safe] "
  550. "attempting backup file");
  551. /* delete current file if corrupt to prevent it from
  552. * being backed up again */
  553. os_rename(backup_file.array, json_file);
  554. file_data = obs_data_create_from_json_file(json_file);
  555. }
  556. dstr_free(&backup_file);
  557. }
  558. return file_data;
  559. }
  560. void obs_data_addref(obs_data_t *data)
  561. {
  562. if (data)
  563. os_atomic_inc_long(&data->ref);
  564. }
  565. static inline void obs_data_destroy(struct obs_data *data)
  566. {
  567. struct obs_data_item *item = data->first_item;
  568. while (item) {
  569. struct obs_data_item *next = item->next;
  570. obs_data_item_release(&item);
  571. item = next;
  572. }
  573. /* NOTE: don't use bfree for json text, allocated by json */
  574. free(data->json);
  575. bfree(data);
  576. }
  577. void obs_data_release(obs_data_t *data)
  578. {
  579. if (!data)
  580. return;
  581. if (os_atomic_dec_long(&data->ref) == 0)
  582. obs_data_destroy(data);
  583. }
  584. const char *obs_data_get_json(obs_data_t *data)
  585. {
  586. if (!data)
  587. return NULL;
  588. /* NOTE: don't use libobs bfree for json text */
  589. free(data->json);
  590. data->json = NULL;
  591. json_t *root = obs_data_to_json(data);
  592. data->json = json_dumps(root, JSON_PRESERVE_ORDER | JSON_INDENT(4));
  593. json_decref(root);
  594. return data->json;
  595. }
  596. bool obs_data_save_json(obs_data_t *data, const char *file)
  597. {
  598. const char *json = obs_data_get_json(data);
  599. if (json && *json) {
  600. return os_quick_write_utf8_file(file, json, strlen(json),
  601. false);
  602. }
  603. return false;
  604. }
  605. bool obs_data_save_json_safe(obs_data_t *data, const char *file,
  606. const char *temp_ext, const char *backup_ext)
  607. {
  608. const char *json = obs_data_get_json(data);
  609. if (json && *json) {
  610. return os_quick_write_utf8_file_safe(
  611. file, json, strlen(json), false, temp_ext, backup_ext);
  612. }
  613. return false;
  614. }
  615. static void get_defaults_array_cb(obs_data_t *data, void *vp)
  616. {
  617. obs_data_array_t *defs = (obs_data_array_t *)vp;
  618. obs_data_t *obs_defaults = obs_data_get_defaults(data);
  619. obs_data_array_push_back(defs, obs_defaults);
  620. obs_data_release(obs_defaults);
  621. }
  622. obs_data_t *obs_data_get_defaults(obs_data_t *data)
  623. {
  624. obs_data_t *defaults = obs_data_create();
  625. if (!data)
  626. return defaults;
  627. struct obs_data_item *item = data->first_item;
  628. while (item) {
  629. const char *name = get_item_name(item);
  630. switch (item->type) {
  631. case OBS_DATA_NULL:
  632. break;
  633. case OBS_DATA_STRING: {
  634. const char *str =
  635. obs_data_get_default_string(data, name);
  636. obs_data_set_string(defaults, name, str);
  637. break;
  638. }
  639. case OBS_DATA_NUMBER: {
  640. switch (obs_data_item_numtype(item)) {
  641. case OBS_DATA_NUM_DOUBLE: {
  642. double val =
  643. obs_data_get_default_double(data, name);
  644. obs_data_set_double(defaults, name, val);
  645. break;
  646. }
  647. case OBS_DATA_NUM_INT: {
  648. int val = obs_data_get_default_int(data, name);
  649. obs_data_set_int(defaults, name, val);
  650. break;
  651. }
  652. case OBS_DATA_NUM_INVALID:
  653. break;
  654. }
  655. break;
  656. }
  657. case OBS_DATA_BOOLEAN: {
  658. bool val = obs_data_get_default_bool(data, name);
  659. obs_data_set_bool(defaults, name, val);
  660. break;
  661. }
  662. case OBS_DATA_OBJECT: {
  663. obs_data_t *val = obs_data_get_default_obj(data, name);
  664. obs_data_t *defs = obs_data_get_defaults(val);
  665. obs_data_set_obj(defaults, name, defs);
  666. obs_data_release(defs);
  667. obs_data_release(val);
  668. break;
  669. }
  670. case OBS_DATA_ARRAY: {
  671. obs_data_array_t *arr =
  672. obs_data_get_default_array(data, name);
  673. obs_data_array_t *defs = obs_data_array_create();
  674. obs_data_array_enum(arr, get_defaults_array_cb,
  675. (void *)defs);
  676. obs_data_set_array(defaults, name, defs);
  677. obs_data_array_release(defs);
  678. obs_data_array_release(arr);
  679. break;
  680. }
  681. }
  682. item = item->next;
  683. }
  684. return defaults;
  685. }
  686. static struct obs_data_item *get_item(struct obs_data *data, const char *name)
  687. {
  688. if (!data)
  689. return NULL;
  690. struct obs_data_item *item = data->first_item;
  691. while (item) {
  692. if (strcmp(get_item_name(item), name) == 0)
  693. return item;
  694. item = item->next;
  695. }
  696. return NULL;
  697. }
  698. static void set_item_data(struct obs_data *data, struct obs_data_item **item,
  699. const char *name, const void *ptr, size_t size,
  700. enum obs_data_type type, bool default_data,
  701. bool autoselect_data)
  702. {
  703. obs_data_item_t *new_item = NULL;
  704. if ((!item || !*item) && data) {
  705. new_item = obs_data_item_create(name, ptr, size, type,
  706. default_data, autoselect_data);
  707. obs_data_item_t *prev = obs_data_first(data);
  708. obs_data_item_t *next = obs_data_first(data);
  709. obs_data_item_next(&next);
  710. for (; prev && next;
  711. obs_data_item_next(&prev), obs_data_item_next(&next)) {
  712. if (strcmp(get_item_name(next), name) > 0)
  713. break;
  714. }
  715. new_item->parent = data;
  716. if (prev && strcmp(get_item_name(prev), name) < 0) {
  717. prev->next = new_item;
  718. new_item->next = next;
  719. } else {
  720. data->first_item = new_item;
  721. new_item->next = prev;
  722. }
  723. if (!prev)
  724. data->first_item = new_item;
  725. obs_data_item_release(&prev);
  726. obs_data_item_release(&next);
  727. } else if (default_data) {
  728. obs_data_item_set_default_data(item, ptr, size, type);
  729. } else if (autoselect_data) {
  730. obs_data_item_set_autoselect_data(item, ptr, size, type);
  731. } else {
  732. obs_data_item_setdata(item, ptr, size, type);
  733. }
  734. }
  735. static inline void set_item(struct obs_data *data, obs_data_item_t **item,
  736. const char *name, const void *ptr, size_t size,
  737. enum obs_data_type type)
  738. {
  739. obs_data_item_t *actual_item = NULL;
  740. if (!data && !item)
  741. return;
  742. if (!item) {
  743. actual_item = get_item(data, name);
  744. item = &actual_item;
  745. }
  746. set_item_data(data, item, name, ptr, size, type, false, false);
  747. }
  748. static inline void set_item_def(struct obs_data *data, obs_data_item_t **item,
  749. const char *name, const void *ptr, size_t size,
  750. enum obs_data_type type)
  751. {
  752. obs_data_item_t *actual_item = NULL;
  753. if (!data && !item)
  754. return;
  755. if (!item) {
  756. actual_item = get_item(data, name);
  757. item = &actual_item;
  758. }
  759. if (*item && (*item)->type != type)
  760. return;
  761. set_item_data(data, item, name, ptr, size, type, true, false);
  762. }
  763. static inline void set_item_auto(struct obs_data *data, obs_data_item_t **item,
  764. const char *name, const void *ptr, size_t size,
  765. enum obs_data_type type)
  766. {
  767. obs_data_item_t *actual_item = NULL;
  768. if (!data && !item)
  769. return;
  770. if (!item) {
  771. actual_item = get_item(data, name);
  772. item = &actual_item;
  773. }
  774. set_item_data(data, item, name, ptr, size, type, false, true);
  775. }
  776. static void copy_obj(struct obs_data *data, const char *name,
  777. struct obs_data *obj,
  778. void (*callback)(obs_data_t *, const char *, obs_data_t *))
  779. {
  780. if (obj) {
  781. obs_data_t *new_obj = obs_data_create();
  782. obs_data_apply(new_obj, obj);
  783. callback(data, name, new_obj);
  784. obs_data_release(new_obj);
  785. }
  786. }
  787. static void copy_array(struct obs_data *data, const char *name,
  788. struct obs_data_array *array,
  789. void (*callback)(obs_data_t *, const char *,
  790. obs_data_array_t *))
  791. {
  792. if (array) {
  793. obs_data_array_t *new_array = obs_data_array_create();
  794. da_reserve(new_array->objects, array->objects.num);
  795. for (size_t i = 0; i < array->objects.num; i++) {
  796. obs_data_t *new_obj = obs_data_create();
  797. obs_data_t *obj = array->objects.array[i];
  798. obs_data_apply(new_obj, obj);
  799. obs_data_array_push_back(new_array, new_obj);
  800. obs_data_release(new_obj);
  801. }
  802. callback(data, name, new_array);
  803. obs_data_array_release(new_array);
  804. }
  805. }
  806. static inline void copy_item(struct obs_data *data, struct obs_data_item *item)
  807. {
  808. const char *name = get_item_name(item);
  809. void *ptr = get_item_data(item);
  810. if (item->type == OBS_DATA_OBJECT) {
  811. obs_data_t **obj = item->data_size ? ptr : NULL;
  812. if (obj)
  813. copy_obj(data, name, *obj, obs_data_set_obj);
  814. } else if (item->type == OBS_DATA_ARRAY) {
  815. obs_data_array_t **array = item->data_size ? ptr : NULL;
  816. if (array)
  817. copy_array(data, name, *array, obs_data_set_array);
  818. } else {
  819. if (item->data_size)
  820. set_item(data, NULL, name, ptr, item->data_size,
  821. item->type);
  822. }
  823. }
  824. void obs_data_apply(obs_data_t *target, obs_data_t *apply_data)
  825. {
  826. struct obs_data_item *item;
  827. if (!target || !apply_data || target == apply_data)
  828. return;
  829. item = apply_data->first_item;
  830. while (item) {
  831. copy_item(target, item);
  832. item = item->next;
  833. }
  834. }
  835. void obs_data_erase(obs_data_t *data, const char *name)
  836. {
  837. struct obs_data_item *item = get_item(data, name);
  838. if (item) {
  839. obs_data_item_detach(item);
  840. obs_data_item_release(&item);
  841. }
  842. }
  843. static inline void clear_item(struct obs_data_item *item)
  844. {
  845. void *ptr = get_item_data(item);
  846. size_t size;
  847. if (item->data_len) {
  848. if (item->type == OBS_DATA_OBJECT) {
  849. obs_data_t **obj = item->data_size ? ptr : NULL;
  850. if (obj && *obj)
  851. obs_data_release(*obj);
  852. } else if (item->type == OBS_DATA_ARRAY) {
  853. obs_data_array_t **array = item->data_size ? ptr : NULL;
  854. if (array && *array)
  855. obs_data_array_release(*array);
  856. }
  857. size = item->default_len + item->autoselect_size;
  858. if (size)
  859. memmove(ptr, (uint8_t *)ptr + item->data_len, size);
  860. item->data_size = 0;
  861. item->data_len = 0;
  862. }
  863. }
  864. void obs_data_clear(obs_data_t *target)
  865. {
  866. struct obs_data_item *item;
  867. if (!target)
  868. return;
  869. item = target->first_item;
  870. while (item) {
  871. clear_item(item);
  872. item = item->next;
  873. }
  874. }
  875. typedef void (*set_item_t)(obs_data_t *, obs_data_item_t **, const char *,
  876. const void *, size_t, enum obs_data_type);
  877. static inline void obs_set_string(obs_data_t *data, obs_data_item_t **item,
  878. const char *name, const char *val,
  879. set_item_t set_item_)
  880. {
  881. if (!val)
  882. val = "";
  883. set_item_(data, item, name, val, strlen(val) + 1, OBS_DATA_STRING);
  884. }
  885. static inline void obs_set_int(obs_data_t *data, obs_data_item_t **item,
  886. const char *name, long long val,
  887. set_item_t set_item_)
  888. {
  889. struct obs_data_number num;
  890. num.type = OBS_DATA_NUM_INT;
  891. num.int_val = val;
  892. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  893. OBS_DATA_NUMBER);
  894. }
  895. static inline void obs_set_double(obs_data_t *data, obs_data_item_t **item,
  896. const char *name, double val,
  897. set_item_t set_item_)
  898. {
  899. struct obs_data_number num;
  900. num.type = OBS_DATA_NUM_DOUBLE;
  901. num.double_val = val;
  902. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  903. OBS_DATA_NUMBER);
  904. }
  905. static inline void obs_set_bool(obs_data_t *data, obs_data_item_t **item,
  906. const char *name, bool val,
  907. set_item_t set_item_)
  908. {
  909. set_item_(data, item, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  910. }
  911. static inline void obs_set_obj(obs_data_t *data, obs_data_item_t **item,
  912. const char *name, obs_data_t *obj,
  913. set_item_t set_item_)
  914. {
  915. set_item_(data, item, name, &obj, sizeof(obs_data_t *),
  916. OBS_DATA_OBJECT);
  917. }
  918. static inline void obs_set_array(obs_data_t *data, obs_data_item_t **item,
  919. const char *name, obs_data_array_t *array,
  920. set_item_t set_item_)
  921. {
  922. set_item_(data, item, name, &array, sizeof(obs_data_t *),
  923. OBS_DATA_ARRAY);
  924. }
  925. static inline void obs_take_obj(obs_data_t *data, obs_data_item_t **item,
  926. const char *name, obs_data_t *obj,
  927. set_item_t set_item_)
  928. {
  929. obs_set_obj(data, item, name, obj, set_item_);
  930. obs_data_release(obj);
  931. }
  932. void obs_data_set_string(obs_data_t *data, const char *name, const char *val)
  933. {
  934. obs_set_string(data, NULL, name, val, set_item);
  935. }
  936. void obs_data_set_int(obs_data_t *data, const char *name, long long val)
  937. {
  938. obs_set_int(data, NULL, name, val, set_item);
  939. }
  940. void obs_data_set_double(obs_data_t *data, const char *name, double val)
  941. {
  942. obs_set_double(data, NULL, name, val, set_item);
  943. }
  944. void obs_data_set_bool(obs_data_t *data, const char *name, bool val)
  945. {
  946. obs_set_bool(data, NULL, name, val, set_item);
  947. }
  948. void obs_data_set_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  949. {
  950. obs_set_obj(data, NULL, name, obj, set_item);
  951. }
  952. void obs_data_set_array(obs_data_t *data, const char *name,
  953. obs_data_array_t *array)
  954. {
  955. obs_set_array(data, NULL, name, array, set_item);
  956. }
  957. void obs_data_set_default_string(obs_data_t *data, const char *name,
  958. const char *val)
  959. {
  960. obs_set_string(data, NULL, name, val, set_item_def);
  961. }
  962. void obs_data_set_default_int(obs_data_t *data, const char *name, long long val)
  963. {
  964. obs_set_int(data, NULL, name, val, set_item_def);
  965. }
  966. void obs_data_set_default_double(obs_data_t *data, const char *name, double val)
  967. {
  968. obs_set_double(data, NULL, name, val, set_item_def);
  969. }
  970. void obs_data_set_default_bool(obs_data_t *data, const char *name, bool val)
  971. {
  972. obs_set_bool(data, NULL, name, val, set_item_def);
  973. }
  974. void obs_data_set_default_obj(obs_data_t *data, const char *name,
  975. obs_data_t *obj)
  976. {
  977. obs_set_obj(data, NULL, name, obj, set_item_def);
  978. }
  979. void obs_data_set_default_array(obs_data_t *data, const char *name,
  980. obs_data_array_t *arr)
  981. {
  982. obs_set_array(data, NULL, name, arr, set_item_def);
  983. }
  984. void obs_data_set_autoselect_string(obs_data_t *data, const char *name,
  985. const char *val)
  986. {
  987. obs_set_string(data, NULL, name, val, set_item_auto);
  988. }
  989. void obs_data_set_autoselect_int(obs_data_t *data, const char *name,
  990. long long val)
  991. {
  992. obs_set_int(data, NULL, name, val, set_item_auto);
  993. }
  994. void obs_data_set_autoselect_double(obs_data_t *data, const char *name,
  995. double val)
  996. {
  997. obs_set_double(data, NULL, name, val, set_item_auto);
  998. }
  999. void obs_data_set_autoselect_bool(obs_data_t *data, const char *name, bool val)
  1000. {
  1001. obs_set_bool(data, NULL, name, val, set_item_auto);
  1002. }
  1003. void obs_data_set_autoselect_obj(obs_data_t *data, const char *name,
  1004. obs_data_t *obj)
  1005. {
  1006. obs_set_obj(data, NULL, name, obj, set_item_auto);
  1007. }
  1008. void obs_data_set_autoselect_array(obs_data_t *data, const char *name,
  1009. obs_data_array_t *arr)
  1010. {
  1011. obs_set_array(data, NULL, name, arr, set_item_auto);
  1012. }
  1013. const char *obs_data_get_string(obs_data_t *data, const char *name)
  1014. {
  1015. return obs_data_item_get_string(get_item(data, name));
  1016. }
  1017. long long obs_data_get_int(obs_data_t *data, const char *name)
  1018. {
  1019. return obs_data_item_get_int(get_item(data, name));
  1020. }
  1021. double obs_data_get_double(obs_data_t *data, const char *name)
  1022. {
  1023. return obs_data_item_get_double(get_item(data, name));
  1024. }
  1025. bool obs_data_get_bool(obs_data_t *data, const char *name)
  1026. {
  1027. return obs_data_item_get_bool(get_item(data, name));
  1028. }
  1029. obs_data_t *obs_data_get_obj(obs_data_t *data, const char *name)
  1030. {
  1031. return obs_data_item_get_obj(get_item(data, name));
  1032. }
  1033. obs_data_array_t *obs_data_get_array(obs_data_t *data, const char *name)
  1034. {
  1035. return obs_data_item_get_array(get_item(data, name));
  1036. }
  1037. const char *obs_data_get_default_string(obs_data_t *data, const char *name)
  1038. {
  1039. return obs_data_item_get_default_string(get_item(data, name));
  1040. }
  1041. long long obs_data_get_default_int(obs_data_t *data, const char *name)
  1042. {
  1043. return obs_data_item_get_default_int(get_item(data, name));
  1044. }
  1045. double obs_data_get_default_double(obs_data_t *data, const char *name)
  1046. {
  1047. return obs_data_item_get_default_double(get_item(data, name));
  1048. }
  1049. bool obs_data_get_default_bool(obs_data_t *data, const char *name)
  1050. {
  1051. return obs_data_item_get_default_bool(get_item(data, name));
  1052. }
  1053. obs_data_t *obs_data_get_default_obj(obs_data_t *data, const char *name)
  1054. {
  1055. return obs_data_item_get_default_obj(get_item(data, name));
  1056. }
  1057. obs_data_array_t *obs_data_get_default_array(obs_data_t *data, const char *name)
  1058. {
  1059. return obs_data_item_get_default_array(get_item(data, name));
  1060. }
  1061. const char *obs_data_get_autoselect_string(obs_data_t *data, const char *name)
  1062. {
  1063. return obs_data_item_get_autoselect_string(get_item(data, name));
  1064. }
  1065. long long obs_data_get_autoselect_int(obs_data_t *data, const char *name)
  1066. {
  1067. return obs_data_item_get_autoselect_int(get_item(data, name));
  1068. }
  1069. double obs_data_get_autoselect_double(obs_data_t *data, const char *name)
  1070. {
  1071. return obs_data_item_get_autoselect_double(get_item(data, name));
  1072. }
  1073. bool obs_data_get_autoselect_bool(obs_data_t *data, const char *name)
  1074. {
  1075. return obs_data_item_get_autoselect_bool(get_item(data, name));
  1076. }
  1077. obs_data_t *obs_data_get_autoselect_obj(obs_data_t *data, const char *name)
  1078. {
  1079. return obs_data_item_get_autoselect_obj(get_item(data, name));
  1080. }
  1081. obs_data_array_t *obs_data_get_autoselect_array(obs_data_t *data,
  1082. const char *name)
  1083. {
  1084. return obs_data_item_get_autoselect_array(get_item(data, name));
  1085. }
  1086. obs_data_array_t *obs_data_array_create()
  1087. {
  1088. struct obs_data_array *array = bzalloc(sizeof(struct obs_data_array));
  1089. array->ref = 1;
  1090. return array;
  1091. }
  1092. void obs_data_array_addref(obs_data_array_t *array)
  1093. {
  1094. if (array)
  1095. os_atomic_inc_long(&array->ref);
  1096. }
  1097. static inline void obs_data_array_destroy(obs_data_array_t *array)
  1098. {
  1099. if (array) {
  1100. for (size_t i = 0; i < array->objects.num; i++)
  1101. obs_data_release(array->objects.array[i]);
  1102. da_free(array->objects);
  1103. bfree(array);
  1104. }
  1105. }
  1106. void obs_data_array_release(obs_data_array_t *array)
  1107. {
  1108. if (!array)
  1109. return;
  1110. if (os_atomic_dec_long(&array->ref) == 0)
  1111. obs_data_array_destroy(array);
  1112. }
  1113. size_t obs_data_array_count(obs_data_array_t *array)
  1114. {
  1115. return array ? array->objects.num : 0;
  1116. }
  1117. obs_data_t *obs_data_array_item(obs_data_array_t *array, size_t idx)
  1118. {
  1119. obs_data_t *data;
  1120. if (!array)
  1121. return NULL;
  1122. data = (idx < array->objects.num) ? array->objects.array[idx] : NULL;
  1123. if (data)
  1124. os_atomic_inc_long(&data->ref);
  1125. return data;
  1126. }
  1127. size_t obs_data_array_push_back(obs_data_array_t *array, obs_data_t *obj)
  1128. {
  1129. if (!array || !obj)
  1130. return 0;
  1131. os_atomic_inc_long(&obj->ref);
  1132. return da_push_back(array->objects, &obj);
  1133. }
  1134. void obs_data_array_insert(obs_data_array_t *array, size_t idx, obs_data_t *obj)
  1135. {
  1136. if (!array || !obj)
  1137. return;
  1138. os_atomic_inc_long(&obj->ref);
  1139. da_insert(array->objects, idx, &obj);
  1140. }
  1141. void obs_data_array_push_back_array(obs_data_array_t *array,
  1142. obs_data_array_t *array2)
  1143. {
  1144. if (!array || !array2)
  1145. return;
  1146. for (size_t i = 0; i < array2->objects.num; i++) {
  1147. obs_data_t *obj = array2->objects.array[i];
  1148. obs_data_addref(obj);
  1149. }
  1150. da_push_back_da(array->objects, array2->objects);
  1151. }
  1152. void obs_data_array_erase(obs_data_array_t *array, size_t idx)
  1153. {
  1154. if (array) {
  1155. obs_data_release(array->objects.array[idx]);
  1156. da_erase(array->objects, idx);
  1157. }
  1158. }
  1159. void obs_data_array_enum(obs_data_array_t *array,
  1160. void (*cb)(obs_data_t *data, void *param), void *param)
  1161. {
  1162. if (array && cb) {
  1163. for (size_t i = 0; i < array->objects.num; i++) {
  1164. cb(array->objects.array[i], param);
  1165. }
  1166. }
  1167. }
  1168. /* ------------------------------------------------------------------------- */
  1169. /* Item status inspection */
  1170. bool obs_data_has_user_value(obs_data_t *data, const char *name)
  1171. {
  1172. return data && obs_data_item_has_user_value(get_item(data, name));
  1173. }
  1174. bool obs_data_has_default_value(obs_data_t *data, const char *name)
  1175. {
  1176. return data && obs_data_item_has_default_value(get_item(data, name));
  1177. }
  1178. bool obs_data_has_autoselect_value(obs_data_t *data, const char *name)
  1179. {
  1180. return data && obs_data_item_has_autoselect_value(get_item(data, name));
  1181. }
  1182. bool obs_data_item_has_user_value(obs_data_item_t *item)
  1183. {
  1184. return item && item->data_size;
  1185. }
  1186. bool obs_data_item_has_default_value(obs_data_item_t *item)
  1187. {
  1188. return item && item->default_size;
  1189. }
  1190. bool obs_data_item_has_autoselect_value(obs_data_item_t *item)
  1191. {
  1192. return item && item->autoselect_size;
  1193. }
  1194. /* ------------------------------------------------------------------------- */
  1195. /* Clearing data values */
  1196. void obs_data_unset_user_value(obs_data_t *data, const char *name)
  1197. {
  1198. obs_data_item_unset_user_value(get_item(data, name));
  1199. }
  1200. void obs_data_unset_default_value(obs_data_t *data, const char *name)
  1201. {
  1202. obs_data_item_unset_default_value(get_item(data, name));
  1203. }
  1204. void obs_data_unset_autoselect_value(obs_data_t *data, const char *name)
  1205. {
  1206. obs_data_item_unset_autoselect_value(get_item(data, name));
  1207. }
  1208. void obs_data_item_unset_user_value(obs_data_item_t *item)
  1209. {
  1210. if (!item || !item->data_size)
  1211. return;
  1212. void *old_non_user_data = get_default_data_ptr(item);
  1213. item_data_release(item);
  1214. item->data_size = 0;
  1215. item->data_len = 0;
  1216. if (item->default_size || item->autoselect_size)
  1217. move_data(item, old_non_user_data, item,
  1218. get_default_data_ptr(item),
  1219. item->default_len + item->autoselect_size);
  1220. }
  1221. void obs_data_item_unset_default_value(obs_data_item_t *item)
  1222. {
  1223. if (!item || !item->default_size)
  1224. return;
  1225. void *old_autoselect_data = get_autoselect_data_ptr(item);
  1226. item_default_data_release(item);
  1227. item->default_size = 0;
  1228. item->default_len = 0;
  1229. if (item->autoselect_size)
  1230. move_data(item, old_autoselect_data, item,
  1231. get_autoselect_data_ptr(item), item->autoselect_size);
  1232. }
  1233. void obs_data_item_unset_autoselect_value(obs_data_item_t *item)
  1234. {
  1235. if (!item || !item->autoselect_size)
  1236. return;
  1237. item_autoselect_data_release(item);
  1238. item->autoselect_size = 0;
  1239. }
  1240. /* ------------------------------------------------------------------------- */
  1241. /* Item iteration */
  1242. obs_data_item_t *obs_data_first(obs_data_t *data)
  1243. {
  1244. if (!data)
  1245. return NULL;
  1246. if (data->first_item)
  1247. os_atomic_inc_long(&data->first_item->ref);
  1248. return data->first_item;
  1249. }
  1250. obs_data_item_t *obs_data_item_byname(obs_data_t *data, const char *name)
  1251. {
  1252. if (!data)
  1253. return NULL;
  1254. struct obs_data_item *item = get_item(data, name);
  1255. if (item)
  1256. os_atomic_inc_long(&item->ref);
  1257. return item;
  1258. }
  1259. bool obs_data_item_next(obs_data_item_t **item)
  1260. {
  1261. if (item && *item) {
  1262. obs_data_item_t *next = (*item)->next;
  1263. obs_data_item_release(item);
  1264. *item = next;
  1265. if (next) {
  1266. os_atomic_inc_long(&next->ref);
  1267. return true;
  1268. }
  1269. }
  1270. return false;
  1271. }
  1272. void obs_data_item_release(obs_data_item_t **item)
  1273. {
  1274. if (item && *item) {
  1275. long ref = os_atomic_dec_long(&(*item)->ref);
  1276. if (!ref) {
  1277. obs_data_item_destroy(*item);
  1278. *item = NULL;
  1279. }
  1280. }
  1281. }
  1282. void obs_data_item_remove(obs_data_item_t **item)
  1283. {
  1284. if (item && *item) {
  1285. obs_data_item_detach(*item);
  1286. obs_data_item_release(item);
  1287. }
  1288. }
  1289. enum obs_data_type obs_data_item_gettype(obs_data_item_t *item)
  1290. {
  1291. return item ? item->type : OBS_DATA_NULL;
  1292. }
  1293. enum obs_data_number_type obs_data_item_numtype(obs_data_item_t *item)
  1294. {
  1295. struct obs_data_number *num;
  1296. if (!item || item->type != OBS_DATA_NUMBER)
  1297. return OBS_DATA_NUM_INVALID;
  1298. num = get_item_data(item);
  1299. if (!num)
  1300. return OBS_DATA_NUM_INVALID;
  1301. return num->type;
  1302. }
  1303. const char *obs_data_item_get_name(obs_data_item_t *item)
  1304. {
  1305. if (!item)
  1306. return NULL;
  1307. return get_item_name(item);
  1308. }
  1309. void obs_data_item_set_string(obs_data_item_t **item, const char *val)
  1310. {
  1311. obs_set_string(NULL, item, NULL, val, set_item);
  1312. }
  1313. void obs_data_item_set_int(obs_data_item_t **item, long long val)
  1314. {
  1315. obs_set_int(NULL, item, NULL, val, set_item);
  1316. }
  1317. void obs_data_item_set_double(obs_data_item_t **item, double val)
  1318. {
  1319. obs_set_double(NULL, item, NULL, val, set_item);
  1320. }
  1321. void obs_data_item_set_bool(obs_data_item_t **item, bool val)
  1322. {
  1323. obs_set_bool(NULL, item, NULL, val, set_item);
  1324. }
  1325. void obs_data_item_set_obj(obs_data_item_t **item, obs_data_t *val)
  1326. {
  1327. obs_set_obj(NULL, item, NULL, val, set_item);
  1328. }
  1329. void obs_data_item_set_array(obs_data_item_t **item, obs_data_array_t *val)
  1330. {
  1331. obs_set_array(NULL, item, NULL, val, set_item);
  1332. }
  1333. void obs_data_item_set_default_string(obs_data_item_t **item, const char *val)
  1334. {
  1335. obs_set_string(NULL, item, NULL, val, set_item_def);
  1336. }
  1337. void obs_data_item_set_default_int(obs_data_item_t **item, long long val)
  1338. {
  1339. obs_set_int(NULL, item, NULL, val, set_item_def);
  1340. }
  1341. void obs_data_item_set_default_double(obs_data_item_t **item, double val)
  1342. {
  1343. obs_set_double(NULL, item, NULL, val, set_item_def);
  1344. }
  1345. void obs_data_item_set_default_bool(obs_data_item_t **item, bool val)
  1346. {
  1347. obs_set_bool(NULL, item, NULL, val, set_item_def);
  1348. }
  1349. void obs_data_item_set_default_obj(obs_data_item_t **item, obs_data_t *val)
  1350. {
  1351. obs_set_obj(NULL, item, NULL, val, set_item_def);
  1352. }
  1353. void obs_data_item_set_default_array(obs_data_item_t **item,
  1354. obs_data_array_t *val)
  1355. {
  1356. obs_set_array(NULL, item, NULL, val, set_item_def);
  1357. }
  1358. void obs_data_item_set_autoselect_string(obs_data_item_t **item,
  1359. const char *val)
  1360. {
  1361. obs_set_string(NULL, item, NULL, val, set_item_auto);
  1362. }
  1363. void obs_data_item_set_autoselect_int(obs_data_item_t **item, long long val)
  1364. {
  1365. obs_set_int(NULL, item, NULL, val, set_item_auto);
  1366. }
  1367. void obs_data_item_set_autoselect_double(obs_data_item_t **item, double val)
  1368. {
  1369. obs_set_double(NULL, item, NULL, val, set_item_auto);
  1370. }
  1371. void obs_data_item_set_autoselect_bool(obs_data_item_t **item, bool val)
  1372. {
  1373. obs_set_bool(NULL, item, NULL, val, set_item_auto);
  1374. }
  1375. void obs_data_item_set_autoselect_obj(obs_data_item_t **item, obs_data_t *val)
  1376. {
  1377. obs_set_obj(NULL, item, NULL, val, set_item_auto);
  1378. }
  1379. void obs_data_item_set_autoselect_array(obs_data_item_t **item,
  1380. obs_data_array_t *val)
  1381. {
  1382. obs_set_array(NULL, item, NULL, val, set_item_auto);
  1383. }
  1384. static inline bool item_valid(struct obs_data_item *item,
  1385. enum obs_data_type type)
  1386. {
  1387. return item && item->type == type;
  1388. }
  1389. typedef void *(*get_data_t)(obs_data_item_t *);
  1390. static inline const char *data_item_get_string(obs_data_item_t *item,
  1391. get_data_t get_data)
  1392. {
  1393. return item_valid(item, OBS_DATA_STRING) && get_data(item)
  1394. ? get_data(item)
  1395. : "";
  1396. }
  1397. static inline long long item_int(struct obs_data_item *item,
  1398. get_data_t get_data)
  1399. {
  1400. if (item && get_data(item)) {
  1401. struct obs_data_number *num = get_data(item);
  1402. return (num->type == OBS_DATA_NUM_INT)
  1403. ? num->int_val
  1404. : (long long)num->double_val;
  1405. }
  1406. return 0;
  1407. }
  1408. static inline long long data_item_get_int(obs_data_item_t *item,
  1409. get_data_t get_data)
  1410. {
  1411. return item_int(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1412. get_data);
  1413. }
  1414. static inline double item_double(struct obs_data_item *item,
  1415. get_data_t get_data)
  1416. {
  1417. if (item && get_data(item)) {
  1418. struct obs_data_number *num = get_data(item);
  1419. return (num->type == OBS_DATA_NUM_INT) ? (double)num->int_val
  1420. : num->double_val;
  1421. }
  1422. return 0.0;
  1423. }
  1424. static inline double data_item_get_double(obs_data_item_t *item,
  1425. get_data_t get_data)
  1426. {
  1427. return item_double(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1428. get_data);
  1429. }
  1430. static inline bool data_item_get_bool(obs_data_item_t *item,
  1431. get_data_t get_data)
  1432. {
  1433. return item_valid(item, OBS_DATA_BOOLEAN) && get_data(item)
  1434. ? *(bool *)get_data(item)
  1435. : false;
  1436. }
  1437. typedef obs_data_t *(*get_obj_t)(obs_data_item_t *);
  1438. static inline obs_data_t *data_item_get_obj(obs_data_item_t *item,
  1439. get_obj_t get_obj)
  1440. {
  1441. obs_data_t *obj = item_valid(item, OBS_DATA_OBJECT) ? get_obj(item)
  1442. : NULL;
  1443. if (obj)
  1444. os_atomic_inc_long(&obj->ref);
  1445. return obj;
  1446. }
  1447. typedef obs_data_array_t *(*get_array_t)(obs_data_item_t *);
  1448. static inline obs_data_array_t *data_item_get_array(obs_data_item_t *item,
  1449. get_array_t get_array)
  1450. {
  1451. obs_data_array_t *array =
  1452. item_valid(item, OBS_DATA_ARRAY) ? get_array(item) : NULL;
  1453. if (array)
  1454. os_atomic_inc_long(&array->ref);
  1455. return array;
  1456. }
  1457. const char *obs_data_item_get_string(obs_data_item_t *item)
  1458. {
  1459. return data_item_get_string(item, get_item_data);
  1460. }
  1461. long long obs_data_item_get_int(obs_data_item_t *item)
  1462. {
  1463. return data_item_get_int(item, get_item_data);
  1464. }
  1465. double obs_data_item_get_double(obs_data_item_t *item)
  1466. {
  1467. return data_item_get_double(item, get_item_data);
  1468. }
  1469. bool obs_data_item_get_bool(obs_data_item_t *item)
  1470. {
  1471. return data_item_get_bool(item, get_item_data);
  1472. }
  1473. obs_data_t *obs_data_item_get_obj(obs_data_item_t *item)
  1474. {
  1475. return data_item_get_obj(item, get_item_obj);
  1476. }
  1477. obs_data_array_t *obs_data_item_get_array(obs_data_item_t *item)
  1478. {
  1479. return data_item_get_array(item, get_item_array);
  1480. }
  1481. const char *obs_data_item_get_default_string(obs_data_item_t *item)
  1482. {
  1483. return data_item_get_string(item, get_item_default_data);
  1484. }
  1485. long long obs_data_item_get_default_int(obs_data_item_t *item)
  1486. {
  1487. return data_item_get_int(item, get_item_default_data);
  1488. }
  1489. double obs_data_item_get_default_double(obs_data_item_t *item)
  1490. {
  1491. return data_item_get_double(item, get_item_default_data);
  1492. }
  1493. bool obs_data_item_get_default_bool(obs_data_item_t *item)
  1494. {
  1495. return data_item_get_bool(item, get_item_default_data);
  1496. }
  1497. obs_data_t *obs_data_item_get_default_obj(obs_data_item_t *item)
  1498. {
  1499. return data_item_get_obj(item, get_item_default_obj);
  1500. }
  1501. obs_data_array_t *obs_data_item_get_default_array(obs_data_item_t *item)
  1502. {
  1503. return data_item_get_array(item, get_item_default_array);
  1504. }
  1505. const char *obs_data_item_get_autoselect_string(obs_data_item_t *item)
  1506. {
  1507. return data_item_get_string(item, get_item_autoselect_data);
  1508. }
  1509. long long obs_data_item_get_autoselect_int(obs_data_item_t *item)
  1510. {
  1511. return data_item_get_int(item, get_item_autoselect_data);
  1512. }
  1513. double obs_data_item_get_autoselect_double(obs_data_item_t *item)
  1514. {
  1515. return data_item_get_double(item, get_item_autoselect_data);
  1516. }
  1517. bool obs_data_item_get_autoselect_bool(obs_data_item_t *item)
  1518. {
  1519. return data_item_get_bool(item, get_item_autoselect_data);
  1520. }
  1521. obs_data_t *obs_data_item_get_autoselect_obj(obs_data_item_t *item)
  1522. {
  1523. return data_item_get_obj(item, get_item_autoselect_obj);
  1524. }
  1525. obs_data_array_t *obs_data_item_get_autoselect_array(obs_data_item_t *item)
  1526. {
  1527. return data_item_get_array(item, get_item_autoselect_array);
  1528. }
  1529. /* ------------------------------------------------------------------------- */
  1530. /* Helper functions for certain structures */
  1531. typedef void (*set_obj_t)(obs_data_t *, const char *, obs_data_t *);
  1532. static inline void set_vec2(obs_data_t *data, const char *name,
  1533. const struct vec2 *val, set_obj_t set_obj)
  1534. {
  1535. obs_data_t *obj = obs_data_create();
  1536. obs_data_set_double(obj, "x", val->x);
  1537. obs_data_set_double(obj, "y", val->y);
  1538. set_obj(data, name, obj);
  1539. obs_data_release(obj);
  1540. }
  1541. static inline void set_vec3(obs_data_t *data, const char *name,
  1542. const struct vec3 *val, set_obj_t set_obj)
  1543. {
  1544. obs_data_t *obj = obs_data_create();
  1545. obs_data_set_double(obj, "x", val->x);
  1546. obs_data_set_double(obj, "y", val->y);
  1547. obs_data_set_double(obj, "z", val->z);
  1548. set_obj(data, name, obj);
  1549. obs_data_release(obj);
  1550. }
  1551. static inline void set_vec4(obs_data_t *data, const char *name,
  1552. const struct vec4 *val, set_obj_t set_obj)
  1553. {
  1554. obs_data_t *obj = obs_data_create();
  1555. obs_data_set_double(obj, "x", val->x);
  1556. obs_data_set_double(obj, "y", val->y);
  1557. obs_data_set_double(obj, "z", val->z);
  1558. obs_data_set_double(obj, "w", val->w);
  1559. set_obj(data, name, obj);
  1560. obs_data_release(obj);
  1561. }
  1562. static inline void set_quat(obs_data_t *data, const char *name,
  1563. const struct quat *val, set_obj_t set_obj)
  1564. {
  1565. obs_data_t *obj = obs_data_create();
  1566. obs_data_set_double(obj, "x", val->x);
  1567. obs_data_set_double(obj, "y", val->y);
  1568. obs_data_set_double(obj, "z", val->z);
  1569. obs_data_set_double(obj, "w", val->w);
  1570. set_obj(data, name, obj);
  1571. obs_data_release(obj);
  1572. }
  1573. void obs_data_set_vec2(obs_data_t *data, const char *name,
  1574. const struct vec2 *val)
  1575. {
  1576. set_vec2(data, name, val, obs_data_set_obj);
  1577. }
  1578. void obs_data_set_vec3(obs_data_t *data, const char *name,
  1579. const struct vec3 *val)
  1580. {
  1581. set_vec3(data, name, val, obs_data_set_obj);
  1582. }
  1583. void obs_data_set_vec4(obs_data_t *data, const char *name,
  1584. const struct vec4 *val)
  1585. {
  1586. set_vec4(data, name, val, obs_data_set_obj);
  1587. }
  1588. void obs_data_set_quat(obs_data_t *data, const char *name,
  1589. const struct quat *val)
  1590. {
  1591. set_quat(data, name, val, obs_data_set_obj);
  1592. }
  1593. void obs_data_set_default_vec2(obs_data_t *data, const char *name,
  1594. const struct vec2 *val)
  1595. {
  1596. set_vec2(data, name, val, obs_data_set_default_obj);
  1597. }
  1598. void obs_data_set_default_vec3(obs_data_t *data, const char *name,
  1599. const struct vec3 *val)
  1600. {
  1601. set_vec3(data, name, val, obs_data_set_default_obj);
  1602. }
  1603. void obs_data_set_default_vec4(obs_data_t *data, const char *name,
  1604. const struct vec4 *val)
  1605. {
  1606. set_vec4(data, name, val, obs_data_set_default_obj);
  1607. }
  1608. void obs_data_set_default_quat(obs_data_t *data, const char *name,
  1609. const struct quat *val)
  1610. {
  1611. set_quat(data, name, val, obs_data_set_default_obj);
  1612. }
  1613. void obs_data_set_autoselect_vec2(obs_data_t *data, const char *name,
  1614. const struct vec2 *val)
  1615. {
  1616. set_vec2(data, name, val, obs_data_set_autoselect_obj);
  1617. }
  1618. void obs_data_set_autoselect_vec3(obs_data_t *data, const char *name,
  1619. const struct vec3 *val)
  1620. {
  1621. set_vec3(data, name, val, obs_data_set_autoselect_obj);
  1622. }
  1623. void obs_data_set_autoselect_vec4(obs_data_t *data, const char *name,
  1624. const struct vec4 *val)
  1625. {
  1626. set_vec4(data, name, val, obs_data_set_autoselect_obj);
  1627. }
  1628. void obs_data_set_autoselect_quat(obs_data_t *data, const char *name,
  1629. const struct quat *val)
  1630. {
  1631. set_quat(data, name, val, obs_data_set_autoselect_obj);
  1632. }
  1633. static inline void get_vec2(obs_data_t *obj, struct vec2 *val)
  1634. {
  1635. if (!obj)
  1636. return;
  1637. val->x = (float)obs_data_get_double(obj, "x");
  1638. val->y = (float)obs_data_get_double(obj, "y");
  1639. obs_data_release(obj);
  1640. }
  1641. static inline void get_vec3(obs_data_t *obj, struct vec3 *val)
  1642. {
  1643. if (!obj)
  1644. return;
  1645. val->x = (float)obs_data_get_double(obj, "x");
  1646. val->y = (float)obs_data_get_double(obj, "y");
  1647. val->z = (float)obs_data_get_double(obj, "z");
  1648. obs_data_release(obj);
  1649. }
  1650. static inline void get_vec4(obs_data_t *obj, struct vec4 *val)
  1651. {
  1652. if (!obj)
  1653. return;
  1654. val->x = (float)obs_data_get_double(obj, "x");
  1655. val->y = (float)obs_data_get_double(obj, "y");
  1656. val->z = (float)obs_data_get_double(obj, "z");
  1657. val->w = (float)obs_data_get_double(obj, "w");
  1658. obs_data_release(obj);
  1659. }
  1660. static inline void get_quat(obs_data_t *obj, struct quat *val)
  1661. {
  1662. if (!obj)
  1663. return;
  1664. val->x = (float)obs_data_get_double(obj, "x");
  1665. val->y = (float)obs_data_get_double(obj, "y");
  1666. val->z = (float)obs_data_get_double(obj, "z");
  1667. val->w = (float)obs_data_get_double(obj, "w");
  1668. obs_data_release(obj);
  1669. }
  1670. void obs_data_get_vec2(obs_data_t *data, const char *name, struct vec2 *val)
  1671. {
  1672. get_vec2(obs_data_get_obj(data, name), val);
  1673. }
  1674. void obs_data_get_vec3(obs_data_t *data, const char *name, struct vec3 *val)
  1675. {
  1676. get_vec3(obs_data_get_obj(data, name), val);
  1677. }
  1678. void obs_data_get_vec4(obs_data_t *data, const char *name, struct vec4 *val)
  1679. {
  1680. get_vec4(obs_data_get_obj(data, name), val);
  1681. }
  1682. void obs_data_get_quat(obs_data_t *data, const char *name, struct quat *val)
  1683. {
  1684. get_quat(obs_data_get_obj(data, name), val);
  1685. }
  1686. void obs_data_get_default_vec2(obs_data_t *data, const char *name,
  1687. struct vec2 *val)
  1688. {
  1689. get_vec2(obs_data_get_default_obj(data, name), val);
  1690. }
  1691. void obs_data_get_default_vec3(obs_data_t *data, const char *name,
  1692. struct vec3 *val)
  1693. {
  1694. get_vec3(obs_data_get_default_obj(data, name), val);
  1695. }
  1696. void obs_data_get_default_vec4(obs_data_t *data, const char *name,
  1697. struct vec4 *val)
  1698. {
  1699. get_vec4(obs_data_get_default_obj(data, name), val);
  1700. }
  1701. void obs_data_get_default_quat(obs_data_t *data, const char *name,
  1702. struct quat *val)
  1703. {
  1704. get_quat(obs_data_get_default_obj(data, name), val);
  1705. }
  1706. void obs_data_get_autoselect_vec2(obs_data_t *data, const char *name,
  1707. struct vec2 *val)
  1708. {
  1709. get_vec2(obs_data_get_autoselect_obj(data, name), val);
  1710. }
  1711. void obs_data_get_autoselect_vec3(obs_data_t *data, const char *name,
  1712. struct vec3 *val)
  1713. {
  1714. get_vec3(obs_data_get_autoselect_obj(data, name), val);
  1715. }
  1716. void obs_data_get_autoselect_vec4(obs_data_t *data, const char *name,
  1717. struct vec4 *val)
  1718. {
  1719. get_vec4(obs_data_get_autoselect_obj(data, name), val);
  1720. }
  1721. void obs_data_get_autoselect_quat(obs_data_t *data, const char *name,
  1722. struct quat *val)
  1723. {
  1724. get_quat(obs_data_get_autoselect_obj(data, name), val);
  1725. }
  1726. /* ------------------------------------------------------------------------- */
  1727. /* Helper functions for media_frames_per_seconds */
  1728. static inline obs_data_t *
  1729. make_frames_per_second(struct media_frames_per_second fps, const char *option)
  1730. {
  1731. obs_data_t *obj = obs_data_create();
  1732. if (!option) {
  1733. obs_data_set_double(obj, "numerator", fps.numerator);
  1734. obs_data_set_double(obj, "denominator", fps.denominator);
  1735. } else {
  1736. obs_data_set_string(obj, "option", option);
  1737. }
  1738. return obj;
  1739. }
  1740. void obs_data_set_frames_per_second(obs_data_t *data, const char *name,
  1741. struct media_frames_per_second fps,
  1742. const char *option)
  1743. {
  1744. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1745. set_item);
  1746. }
  1747. void obs_data_set_default_frames_per_second(obs_data_t *data, const char *name,
  1748. struct media_frames_per_second fps,
  1749. const char *option)
  1750. {
  1751. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1752. set_item_def);
  1753. }
  1754. void obs_data_set_autoselect_frames_per_second(
  1755. obs_data_t *data, const char *name, struct media_frames_per_second fps,
  1756. const char *option)
  1757. {
  1758. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1759. set_item_auto);
  1760. }
  1761. static inline bool get_option(obs_data_t *data, const char **option)
  1762. {
  1763. if (!option)
  1764. return false;
  1765. struct obs_data_item *opt = obs_data_item_byname(data, "option");
  1766. if (!opt)
  1767. return false;
  1768. *option = obs_data_item_get_string(opt);
  1769. obs_data_item_release(&opt);
  1770. obs_data_release(data);
  1771. return true;
  1772. }
  1773. #define CLAMP(x, min, max) ((x) < min ? min : ((x) > max ? max : (x)))
  1774. static inline bool get_frames_per_second(obs_data_t *data,
  1775. struct media_frames_per_second *fps,
  1776. const char **option)
  1777. {
  1778. if (!data)
  1779. return false;
  1780. if (get_option(data, option))
  1781. return true;
  1782. if (!fps)
  1783. goto free;
  1784. struct obs_data_item *num = obs_data_item_byname(data, "numerator");
  1785. struct obs_data_item *den = obs_data_item_byname(data, "denominator");
  1786. if (!num || !den) {
  1787. obs_data_item_release(&num);
  1788. obs_data_item_release(&den);
  1789. goto free;
  1790. }
  1791. long long num_ll = obs_data_item_get_int(num);
  1792. long long den_ll = obs_data_item_get_int(den);
  1793. fps->numerator = (uint32_t)CLAMP(num_ll, 0, (long long)UINT32_MAX);
  1794. fps->denominator = (uint32_t)CLAMP(den_ll, 0, (long long)UINT32_MAX);
  1795. obs_data_item_release(&num);
  1796. obs_data_item_release(&den);
  1797. obs_data_release(data);
  1798. return media_frames_per_second_is_valid(*fps);
  1799. free:
  1800. obs_data_release(data);
  1801. return false;
  1802. }
  1803. bool obs_data_get_frames_per_second(obs_data_t *data, const char *name,
  1804. struct media_frames_per_second *fps,
  1805. const char **option)
  1806. {
  1807. return get_frames_per_second(obs_data_get_obj(data, name), fps, option);
  1808. }
  1809. bool obs_data_get_default_frames_per_second(obs_data_t *data, const char *name,
  1810. struct media_frames_per_second *fps,
  1811. const char **option)
  1812. {
  1813. return get_frames_per_second(obs_data_get_default_obj(data, name), fps,
  1814. option);
  1815. }
  1816. bool obs_data_get_autoselect_frames_per_second(
  1817. obs_data_t *data, const char *name, struct media_frames_per_second *fps,
  1818. const char **option)
  1819. {
  1820. return get_frames_per_second(obs_data_get_autoselect_obj(data, name),
  1821. fps, option);
  1822. }
  1823. void obs_data_item_set_frames_per_second(obs_data_item_t **item,
  1824. struct media_frames_per_second fps,
  1825. const char *option)
  1826. {
  1827. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1828. set_item);
  1829. }
  1830. void obs_data_item_set_default_frames_per_second(
  1831. obs_data_item_t **item, struct media_frames_per_second fps,
  1832. const char *option)
  1833. {
  1834. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1835. set_item_def);
  1836. }
  1837. void obs_data_item_set_autoselect_frames_per_second(
  1838. obs_data_item_t **item, struct media_frames_per_second fps,
  1839. const char *option)
  1840. {
  1841. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1842. set_item_auto);
  1843. }
  1844. bool obs_data_item_get_frames_per_second(obs_data_item_t *item,
  1845. struct media_frames_per_second *fps,
  1846. const char **option)
  1847. {
  1848. return get_frames_per_second(obs_data_item_get_obj(item), fps, option);
  1849. }
  1850. bool obs_data_item_get_default_frames_per_second(
  1851. obs_data_item_t *item, struct media_frames_per_second *fps,
  1852. const char **option)
  1853. {
  1854. return get_frames_per_second(obs_data_item_get_default_obj(item), fps,
  1855. option);
  1856. }
  1857. bool obs_data_item_get_autoselect_frames_per_second(
  1858. obs_data_item_t *item, struct media_frames_per_second *fps,
  1859. const char **option)
  1860. {
  1861. return get_frames_per_second(obs_data_item_get_autoselect_obj(item),
  1862. fps, option);
  1863. }