obs-data.c 45 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866
  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. typedef void (*set_item_t)(obs_data_t*, obs_data_item_t**, const char*,
  705. const void*, size_t, enum obs_data_type);
  706. static inline void obs_set_string(obs_data_t *data, obs_data_item_t **item,
  707. const char *name,
  708. const char *val, set_item_t set_item_)
  709. {
  710. if (!val) val = "";
  711. set_item_(data, item, name, val, strlen(val)+1, OBS_DATA_STRING);
  712. }
  713. static inline void obs_set_int(obs_data_t *data, obs_data_item_t **item,
  714. const char *name,
  715. long long val, set_item_t set_item_)
  716. {
  717. struct obs_data_number num;
  718. num.type = OBS_DATA_NUM_INT;
  719. num.int_val = val;
  720. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  721. OBS_DATA_NUMBER);
  722. }
  723. static inline void obs_set_double(obs_data_t *data, obs_data_item_t **item,
  724. const char *name,
  725. double val, set_item_t set_item_)
  726. {
  727. struct obs_data_number num;
  728. num.type = OBS_DATA_NUM_DOUBLE;
  729. num.double_val = val;
  730. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  731. OBS_DATA_NUMBER);
  732. }
  733. static inline void obs_set_bool(obs_data_t *data, obs_data_item_t **item,
  734. const char *name,
  735. bool val, set_item_t set_item_)
  736. {
  737. set_item_(data, item, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  738. }
  739. static inline void obs_set_obj(obs_data_t *data, obs_data_item_t **item,
  740. const char *name,
  741. obs_data_t *obj, set_item_t set_item_)
  742. {
  743. set_item_(data, item, name, &obj, sizeof(obs_data_t*), OBS_DATA_OBJECT);
  744. }
  745. static inline void obs_set_array(obs_data_t *data, obs_data_item_t **item,
  746. const char *name,
  747. obs_data_array_t *array, set_item_t set_item_)
  748. {
  749. set_item_(data, item, name, &array, sizeof(obs_data_t*), OBS_DATA_ARRAY);
  750. }
  751. void obs_data_set_string(obs_data_t *data, const char *name, const char *val)
  752. {
  753. obs_set_string(data, NULL, name, val, set_item);
  754. }
  755. void obs_data_set_int(obs_data_t *data, const char *name, long long val)
  756. {
  757. obs_set_int(data, NULL, name, val, set_item);
  758. }
  759. void obs_data_set_double(obs_data_t *data, const char *name, double val)
  760. {
  761. obs_set_double(data, NULL, name, val, set_item);
  762. }
  763. void obs_data_set_bool(obs_data_t *data, const char *name, bool val)
  764. {
  765. obs_set_bool(data, NULL, name, val, set_item);
  766. }
  767. void obs_data_set_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  768. {
  769. obs_set_obj(data, NULL, name, obj, set_item);
  770. }
  771. void obs_data_set_array(obs_data_t *data, const char *name,
  772. obs_data_array_t *array)
  773. {
  774. obs_set_array(data, NULL, name, array, set_item);
  775. }
  776. void obs_data_set_default_string(obs_data_t *data, const char *name,
  777. const char *val)
  778. {
  779. obs_set_string(data, NULL, name, val, set_item_def);
  780. }
  781. void obs_data_set_default_int(obs_data_t *data, const char *name, long long val)
  782. {
  783. obs_set_int(data, NULL, name, val, set_item_def);
  784. }
  785. void obs_data_set_default_double(obs_data_t *data, const char *name, double val)
  786. {
  787. obs_set_double(data, NULL, name, val, set_item_def);
  788. }
  789. void obs_data_set_default_bool(obs_data_t *data, const char *name, bool val)
  790. {
  791. obs_set_bool(data, NULL, name, val, set_item_def);
  792. }
  793. void obs_data_set_default_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  794. {
  795. obs_set_obj(data, NULL, name, obj, set_item_def);
  796. }
  797. void obs_data_set_autoselect_string(obs_data_t *data, const char *name,
  798. const char *val)
  799. {
  800. obs_set_string(data, NULL, name, val, set_item_auto);
  801. }
  802. void obs_data_set_autoselect_int(obs_data_t *data, const char *name,
  803. long long val)
  804. {
  805. obs_set_int(data, NULL, name, val, set_item_auto);
  806. }
  807. void obs_data_set_autoselect_double(obs_data_t *data, const char *name,
  808. double val)
  809. {
  810. obs_set_double(data, NULL, name, val, set_item_auto);
  811. }
  812. void obs_data_set_autoselect_bool(obs_data_t *data, const char *name, bool val)
  813. {
  814. obs_set_bool(data, NULL, name, val, set_item_auto);
  815. }
  816. void obs_data_set_autoselect_obj(obs_data_t *data, const char *name,
  817. obs_data_t *obj)
  818. {
  819. obs_set_obj(data, NULL, name, obj, set_item_auto);
  820. }
  821. void obs_data_set_autoselect_array(obs_data_t *data, const char *name,
  822. obs_data_array_t *arr)
  823. {
  824. obs_set_array(data, NULL, name, arr, set_item_auto);
  825. }
  826. const char *obs_data_get_string(obs_data_t *data, const char *name)
  827. {
  828. return obs_data_item_get_string(get_item(data, name));
  829. }
  830. long long obs_data_get_int(obs_data_t *data, const char *name)
  831. {
  832. return obs_data_item_get_int(get_item(data, name));
  833. }
  834. double obs_data_get_double(obs_data_t *data, const char *name)
  835. {
  836. return obs_data_item_get_double(get_item(data, name));
  837. }
  838. bool obs_data_get_bool(obs_data_t *data, const char *name)
  839. {
  840. return obs_data_item_get_bool(get_item(data, name));
  841. }
  842. obs_data_t *obs_data_get_obj(obs_data_t *data, const char *name)
  843. {
  844. return obs_data_item_get_obj(get_item(data, name));
  845. }
  846. obs_data_array_t *obs_data_get_array(obs_data_t *data, const char *name)
  847. {
  848. return obs_data_item_get_array(get_item(data, name));
  849. }
  850. const char *obs_data_get_default_string(obs_data_t *data, const char *name)
  851. {
  852. return obs_data_item_get_default_string(get_item(data, name));
  853. }
  854. long long obs_data_get_default_int(obs_data_t *data, const char *name)
  855. {
  856. return obs_data_item_get_default_int(get_item(data, name));
  857. }
  858. double obs_data_get_default_double(obs_data_t *data, const char *name)
  859. {
  860. return obs_data_item_get_default_double(get_item(data, name));
  861. }
  862. bool obs_data_get_default_bool(obs_data_t *data, const char *name)
  863. {
  864. return obs_data_item_get_default_bool(get_item(data, name));
  865. }
  866. obs_data_t *obs_data_get_default_obj(obs_data_t *data, const char *name)
  867. {
  868. return obs_data_item_get_default_obj(get_item(data, name));
  869. }
  870. obs_data_array_t *obs_data_get_default_array(obs_data_t *data, const char *name)
  871. {
  872. return obs_data_item_get_default_array(get_item(data, name));
  873. }
  874. const char *obs_data_get_autoselect_string(obs_data_t *data, const char *name)
  875. {
  876. return obs_data_item_get_autoselect_string(get_item(data, name));
  877. }
  878. long long obs_data_get_autoselect_int(obs_data_t *data, const char *name)
  879. {
  880. return obs_data_item_get_autoselect_int(get_item(data, name));
  881. }
  882. double obs_data_get_autoselect_double(obs_data_t *data, const char *name)
  883. {
  884. return obs_data_item_get_autoselect_double(get_item(data, name));
  885. }
  886. bool obs_data_get_autoselect_bool(obs_data_t *data, const char *name)
  887. {
  888. return obs_data_item_get_autoselect_bool(get_item(data, name));
  889. }
  890. obs_data_t *obs_data_get_autoselect_obj(obs_data_t *data, const char *name)
  891. {
  892. return obs_data_item_get_autoselect_obj(get_item(data, name));
  893. }
  894. obs_data_array_t *obs_data_get_autoselect_array(obs_data_t *data,
  895. const char *name)
  896. {
  897. return obs_data_item_get_autoselect_array(get_item(data, name));
  898. }
  899. obs_data_array_t *obs_data_array_create()
  900. {
  901. struct obs_data_array *array = bzalloc(sizeof(struct obs_data_array));
  902. array->ref = 1;
  903. return array;
  904. }
  905. void obs_data_array_addref(obs_data_array_t *array)
  906. {
  907. if (array)
  908. os_atomic_inc_long(&array->ref);
  909. }
  910. static inline void obs_data_array_destroy(obs_data_array_t *array)
  911. {
  912. if (array) {
  913. for (size_t i = 0; i < array->objects.num; i++)
  914. obs_data_release(array->objects.array[i]);
  915. da_free(array->objects);
  916. bfree(array);
  917. }
  918. }
  919. void obs_data_array_release(obs_data_array_t *array)
  920. {
  921. if (!array)
  922. return;
  923. if (os_atomic_dec_long(&array->ref) == 0)
  924. obs_data_array_destroy(array);
  925. }
  926. size_t obs_data_array_count(obs_data_array_t *array)
  927. {
  928. return array ? array->objects.num : 0;
  929. }
  930. obs_data_t *obs_data_array_item(obs_data_array_t *array, size_t idx)
  931. {
  932. obs_data_t *data;
  933. if (!array)
  934. return NULL;
  935. data = (idx < array->objects.num) ? array->objects.array[idx] : NULL;
  936. if (data)
  937. os_atomic_inc_long(&data->ref);
  938. return data;
  939. }
  940. size_t obs_data_array_push_back(obs_data_array_t *array, obs_data_t *obj)
  941. {
  942. if (!array || !obj)
  943. return 0;
  944. os_atomic_inc_long(&obj->ref);
  945. return da_push_back(array->objects, &obj);
  946. }
  947. void obs_data_array_insert(obs_data_array_t *array, size_t idx, obs_data_t *obj)
  948. {
  949. if (!array || !obj)
  950. return;
  951. os_atomic_inc_long(&obj->ref);
  952. da_insert(array->objects, idx, &obj);
  953. }
  954. void obs_data_array_erase(obs_data_array_t *array, size_t idx)
  955. {
  956. if (array) {
  957. obs_data_release(array->objects.array[idx]);
  958. da_erase(array->objects, idx);
  959. }
  960. }
  961. /* ------------------------------------------------------------------------- */
  962. /* Item status inspection */
  963. bool obs_data_has_user_value(obs_data_t *data, const char *name)
  964. {
  965. return data && obs_data_item_has_user_value(get_item(data, name));
  966. }
  967. bool obs_data_has_default_value(obs_data_t *data, const char *name)
  968. {
  969. return data && obs_data_item_has_default_value(get_item(data, name));
  970. }
  971. bool obs_data_has_autoselect_value(obs_data_t *data, const char *name)
  972. {
  973. return data && obs_data_item_has_autoselect_value(get_item(data, name));
  974. }
  975. bool obs_data_item_has_user_value(obs_data_item_t *item)
  976. {
  977. return item && item->data_size;
  978. }
  979. bool obs_data_item_has_default_value(obs_data_item_t *item)
  980. {
  981. return item && item->default_size;
  982. }
  983. bool obs_data_item_has_autoselect_value(obs_data_item_t *item)
  984. {
  985. return item && item->autoselect_size;
  986. }
  987. /* ------------------------------------------------------------------------- */
  988. /* Clearing data values */
  989. void obs_data_unset_user_value(obs_data_t *data, const char *name)
  990. {
  991. obs_data_item_unset_user_value(get_item(data, name));
  992. }
  993. void obs_data_unset_default_value(obs_data_t *data, const char *name)
  994. {
  995. obs_data_item_unset_default_value(get_item(data, name));
  996. }
  997. void obs_data_unset_autoselect_value(obs_data_t *data, const char *name)
  998. {
  999. obs_data_item_unset_autoselect_value(get_item(data, name));
  1000. }
  1001. void obs_data_item_unset_user_value(obs_data_item_t *item)
  1002. {
  1003. if (!item || !item->data_size)
  1004. return;
  1005. void *old_non_user_data = get_default_data_ptr(item);
  1006. item_data_release(item);
  1007. item->data_size = 0;
  1008. item->data_len = 0;
  1009. if (item->default_size || item->autoselect_size)
  1010. move_data(item, old_non_user_data, item,
  1011. get_default_data_ptr(item),
  1012. item->default_len + item->autoselect_size);
  1013. }
  1014. void obs_data_item_unset_default_value(obs_data_item_t *item)
  1015. {
  1016. if (!item || !item->default_size)
  1017. return;
  1018. void *old_autoselect_data = get_autoselect_data_ptr(item);
  1019. item_default_data_release(item);
  1020. item->default_size = 0;
  1021. item->default_len = 0;
  1022. if (item->autoselect_size)
  1023. move_data(item, old_autoselect_data, item,
  1024. get_autoselect_data_ptr(item),
  1025. item->autoselect_size);
  1026. }
  1027. void obs_data_item_unset_autoselect_value(obs_data_item_t *item)
  1028. {
  1029. if (!item || !item->autoselect_size)
  1030. return;
  1031. item_autoselect_data_release(item);
  1032. item->autoselect_size = 0;
  1033. }
  1034. /* ------------------------------------------------------------------------- */
  1035. /* Item iteration */
  1036. obs_data_item_t *obs_data_first(obs_data_t *data)
  1037. {
  1038. if (!data)
  1039. return NULL;
  1040. if (data->first_item)
  1041. os_atomic_inc_long(&data->first_item->ref);
  1042. return data->first_item;
  1043. }
  1044. obs_data_item_t *obs_data_item_byname(obs_data_t *data, const char *name)
  1045. {
  1046. if (!data)
  1047. return NULL;
  1048. struct obs_data_item *item = get_item(data, name);
  1049. if (item)
  1050. os_atomic_inc_long(&item->ref);
  1051. return item;
  1052. }
  1053. bool obs_data_item_next(obs_data_item_t **item)
  1054. {
  1055. if (item && *item) {
  1056. obs_data_item_t *next = (*item)->next;
  1057. obs_data_item_release(item);
  1058. *item = next;
  1059. if (next) {
  1060. os_atomic_inc_long(&next->ref);
  1061. return true;
  1062. }
  1063. }
  1064. return false;
  1065. }
  1066. void obs_data_item_release(obs_data_item_t **item)
  1067. {
  1068. if (item && *item) {
  1069. long ref = os_atomic_dec_long(&(*item)->ref);
  1070. if (!ref) {
  1071. obs_data_item_destroy(*item);
  1072. *item = NULL;
  1073. }
  1074. }
  1075. }
  1076. void obs_data_item_remove(obs_data_item_t **item)
  1077. {
  1078. if (item && *item) {
  1079. obs_data_item_detach(*item);
  1080. obs_data_item_release(item);
  1081. }
  1082. }
  1083. enum obs_data_type obs_data_item_gettype(obs_data_item_t *item)
  1084. {
  1085. return item ? item->type : OBS_DATA_NULL;
  1086. }
  1087. enum obs_data_number_type obs_data_item_numtype(obs_data_item_t *item)
  1088. {
  1089. struct obs_data_number *num;
  1090. if (!item || item->type != OBS_DATA_NUMBER)
  1091. return OBS_DATA_NUM_INVALID;
  1092. num = get_item_data(item);
  1093. return num->type;
  1094. }
  1095. void obs_data_item_set_string(obs_data_item_t **item, const char *val)
  1096. {
  1097. obs_set_string(NULL, item, NULL, val, set_item);
  1098. }
  1099. void obs_data_item_set_int(obs_data_item_t **item, long long val)
  1100. {
  1101. obs_set_int(NULL, item, NULL, val, set_item);
  1102. }
  1103. void obs_data_item_set_double(obs_data_item_t **item, double val)
  1104. {
  1105. obs_set_double(NULL, item, NULL, val, set_item);
  1106. }
  1107. void obs_data_item_set_bool(obs_data_item_t **item, bool val)
  1108. {
  1109. obs_set_bool(NULL, item, NULL, val, set_item);
  1110. }
  1111. void obs_data_item_set_obj(obs_data_item_t **item, obs_data_t *val)
  1112. {
  1113. obs_set_obj(NULL, item, NULL, val, set_item);
  1114. }
  1115. void obs_data_item_set_array(obs_data_item_t **item, obs_data_array_t *val)
  1116. {
  1117. obs_set_array(NULL, item, NULL, val, set_item);
  1118. }
  1119. void obs_data_item_set_default_string(obs_data_item_t **item, const char *val)
  1120. {
  1121. obs_set_string(NULL, item, NULL, val, set_item_def);
  1122. }
  1123. void obs_data_item_set_default_int(obs_data_item_t **item, long long val)
  1124. {
  1125. obs_set_int(NULL, item, NULL, val, set_item_def);
  1126. }
  1127. void obs_data_item_set_default_double(obs_data_item_t **item, double val)
  1128. {
  1129. obs_set_double(NULL, item, NULL, val, set_item_def);
  1130. }
  1131. void obs_data_item_set_default_bool(obs_data_item_t **item, bool val)
  1132. {
  1133. obs_set_bool(NULL, item, NULL, val, set_item_def);
  1134. }
  1135. void obs_data_item_set_default_obj(obs_data_item_t **item, obs_data_t *val)
  1136. {
  1137. obs_set_obj(NULL, item, NULL, val, set_item_def);
  1138. }
  1139. void obs_data_item_set_default_array(obs_data_item_t **item,
  1140. obs_data_array_t *val)
  1141. {
  1142. obs_set_array(NULL, item, NULL, val, set_item_def);
  1143. }
  1144. void obs_data_item_set_autoselect_string(obs_data_item_t **item, const char *val)
  1145. {
  1146. obs_set_string(NULL, item, NULL, val, set_item_auto);
  1147. }
  1148. void obs_data_item_set_autoselect_int(obs_data_item_t **item, long long val)
  1149. {
  1150. obs_set_int(NULL, item, NULL, val, set_item_auto);
  1151. }
  1152. void obs_data_item_set_autoselect_double(obs_data_item_t **item, double val)
  1153. {
  1154. obs_set_double(NULL, item, NULL, val, set_item_auto);
  1155. }
  1156. void obs_data_item_set_autoselect_bool(obs_data_item_t **item, bool val)
  1157. {
  1158. obs_set_bool(NULL, item, NULL, val, set_item_auto);
  1159. }
  1160. void obs_data_item_set_autoselect_obj(obs_data_item_t **item, obs_data_t *val)
  1161. {
  1162. obs_set_obj(NULL, item, NULL, val, set_item_auto);
  1163. }
  1164. void obs_data_item_set_autoselect_array(obs_data_item_t **item,
  1165. obs_data_array_t *val)
  1166. {
  1167. obs_set_array(NULL, item, NULL, val, set_item_auto);
  1168. }
  1169. static inline bool item_valid(struct obs_data_item *item,
  1170. enum obs_data_type type)
  1171. {
  1172. return item && item->type == type;
  1173. }
  1174. typedef void *(*get_data_t)(obs_data_item_t*);
  1175. static inline const char *data_item_get_string(obs_data_item_t *item,
  1176. get_data_t get_data)
  1177. {
  1178. return item_valid(item, OBS_DATA_STRING) && get_data(item) ?
  1179. get_data(item) : "";
  1180. }
  1181. static inline long long item_int(struct obs_data_item *item,
  1182. get_data_t get_data)
  1183. {
  1184. if (item && get_data(item)) {
  1185. struct obs_data_number *num = get_data(item);
  1186. return (num->type == OBS_DATA_NUM_INT) ?
  1187. num->int_val : (long long)num->double_val;
  1188. }
  1189. return 0;
  1190. }
  1191. static inline long long data_item_get_int(obs_data_item_t *item,
  1192. get_data_t get_data)
  1193. {
  1194. return item_int(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1195. get_data);
  1196. }
  1197. static inline double item_double(struct obs_data_item *item,
  1198. get_data_t get_data)
  1199. {
  1200. if (item && get_data(item)) {
  1201. struct obs_data_number *num = get_data(item);
  1202. return (num->type == OBS_DATA_NUM_INT) ?
  1203. (double)num->int_val : num->double_val;
  1204. }
  1205. return 0.0;
  1206. }
  1207. static inline double data_item_get_double(obs_data_item_t *item,
  1208. get_data_t get_data)
  1209. {
  1210. return item_double(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1211. get_data);
  1212. }
  1213. static inline bool data_item_get_bool(obs_data_item_t *item, get_data_t get_data)
  1214. {
  1215. return item_valid(item, OBS_DATA_BOOLEAN) && get_data(item) ?
  1216. *(bool*)get_data(item) : false;
  1217. }
  1218. typedef obs_data_t *(*get_obj_t)(obs_data_item_t*);
  1219. static inline obs_data_t *data_item_get_obj(obs_data_item_t *item,
  1220. get_obj_t get_obj)
  1221. {
  1222. obs_data_t *obj = item_valid(item, OBS_DATA_OBJECT) ?
  1223. get_obj(item) : NULL;
  1224. if (obj)
  1225. os_atomic_inc_long(&obj->ref);
  1226. return obj;
  1227. }
  1228. typedef obs_data_array_t *(*get_array_t)(obs_data_item_t*);
  1229. static inline obs_data_array_t *data_item_get_array(obs_data_item_t *item,
  1230. get_array_t get_array)
  1231. {
  1232. obs_data_array_t *array = item_valid(item, OBS_DATA_ARRAY) ?
  1233. get_array(item) : NULL;
  1234. if (array)
  1235. os_atomic_inc_long(&array->ref);
  1236. return array;
  1237. }
  1238. const char *obs_data_item_get_string(obs_data_item_t *item)
  1239. {
  1240. return data_item_get_string(item, get_item_data);
  1241. }
  1242. long long obs_data_item_get_int(obs_data_item_t *item)
  1243. {
  1244. return data_item_get_int(item, get_item_data);
  1245. }
  1246. double obs_data_item_get_double(obs_data_item_t *item)
  1247. {
  1248. return data_item_get_double(item, get_item_data);
  1249. }
  1250. bool obs_data_item_get_bool(obs_data_item_t *item)
  1251. {
  1252. return data_item_get_bool(item, get_item_data);
  1253. }
  1254. obs_data_t *obs_data_item_get_obj(obs_data_item_t *item)
  1255. {
  1256. return data_item_get_obj(item, get_item_obj);
  1257. }
  1258. obs_data_array_t *obs_data_item_get_array(obs_data_item_t *item)
  1259. {
  1260. return data_item_get_array(item, get_item_array);
  1261. }
  1262. const char *obs_data_item_get_default_string(obs_data_item_t *item)
  1263. {
  1264. return data_item_get_string(item, get_item_default_data);
  1265. }
  1266. long long obs_data_item_get_default_int(obs_data_item_t *item)
  1267. {
  1268. return data_item_get_int(item, get_item_default_data);
  1269. }
  1270. double obs_data_item_get_default_double(obs_data_item_t *item)
  1271. {
  1272. return data_item_get_double(item, get_item_default_data);
  1273. }
  1274. bool obs_data_item_get_default_bool(obs_data_item_t *item)
  1275. {
  1276. return data_item_get_bool(item, get_item_default_data);
  1277. }
  1278. obs_data_t *obs_data_item_get_default_obj(obs_data_item_t *item)
  1279. {
  1280. return data_item_get_obj(item, get_item_obj);
  1281. }
  1282. obs_data_array_t *obs_data_item_get_default_array(obs_data_item_t *item)
  1283. {
  1284. return data_item_get_array(item, get_item_array);
  1285. }
  1286. const char *obs_data_item_get_autoselect_string(obs_data_item_t *item)
  1287. {
  1288. return data_item_get_string(item, get_item_autoselect_data);
  1289. }
  1290. long long obs_data_item_get_autoselect_int(obs_data_item_t *item)
  1291. {
  1292. return data_item_get_int(item, get_item_autoselect_data);
  1293. }
  1294. double obs_data_item_get_autoselect_double(obs_data_item_t *item)
  1295. {
  1296. return data_item_get_double(item, get_item_autoselect_data);
  1297. }
  1298. bool obs_data_item_get_autoselect_bool(obs_data_item_t *item)
  1299. {
  1300. return data_item_get_bool(item, get_item_autoselect_data);
  1301. }
  1302. obs_data_t *obs_data_item_get_autoselect_obj(obs_data_item_t *item)
  1303. {
  1304. return data_item_get_obj(item, get_item_autoselect_obj);
  1305. }
  1306. obs_data_array_t *obs_data_item_get_autoselect_array(obs_data_item_t *item)
  1307. {
  1308. return data_item_get_array(item, get_item_autoselect_array);
  1309. }
  1310. /* ------------------------------------------------------------------------- */
  1311. /* Helper functions for certain structures */
  1312. typedef void (*set_obj_t)(obs_data_t*, const char*, obs_data_t*);
  1313. static inline void set_vec2(obs_data_t *data, const char *name,
  1314. const struct vec2 *val, set_obj_t set_obj)
  1315. {
  1316. obs_data_t *obj = obs_data_create();
  1317. obs_data_set_double(obj, "x", val->x);
  1318. obs_data_set_double(obj, "y", val->y);
  1319. set_obj(data, name, obj);
  1320. obs_data_release(obj);
  1321. }
  1322. static inline void set_vec3(obs_data_t *data, const char *name,
  1323. const struct vec3 *val, set_obj_t set_obj)
  1324. {
  1325. obs_data_t *obj = obs_data_create();
  1326. obs_data_set_double(obj, "x", val->x);
  1327. obs_data_set_double(obj, "y", val->y);
  1328. obs_data_set_double(obj, "z", val->z);
  1329. set_obj(data, name, obj);
  1330. obs_data_release(obj);
  1331. }
  1332. static inline void set_vec4(obs_data_t *data, const char *name,
  1333. const struct vec4 *val, set_obj_t set_obj)
  1334. {
  1335. obs_data_t *obj = obs_data_create();
  1336. obs_data_set_double(obj, "x", val->x);
  1337. obs_data_set_double(obj, "y", val->y);
  1338. obs_data_set_double(obj, "z", val->z);
  1339. obs_data_set_double(obj, "w", val->w);
  1340. set_obj(data, name, obj);
  1341. obs_data_release(obj);
  1342. }
  1343. static inline void set_quat(obs_data_t *data, const char *name,
  1344. const struct quat *val, set_obj_t set_obj)
  1345. {
  1346. obs_data_t *obj = obs_data_create();
  1347. obs_data_set_double(obj, "x", val->x);
  1348. obs_data_set_double(obj, "y", val->y);
  1349. obs_data_set_double(obj, "z", val->z);
  1350. obs_data_set_double(obj, "w", val->w);
  1351. set_obj(data, name, obj);
  1352. obs_data_release(obj);
  1353. }
  1354. void obs_data_set_vec2(obs_data_t *data, const char *name,
  1355. const struct vec2 *val)
  1356. {
  1357. set_vec2(data, name, val, obs_data_set_obj);
  1358. }
  1359. void obs_data_set_vec3(obs_data_t *data, const char *name,
  1360. const struct vec3 *val)
  1361. {
  1362. set_vec3(data, name, val, obs_data_set_obj);
  1363. }
  1364. void obs_data_set_vec4(obs_data_t *data, const char *name,
  1365. const struct vec4 *val)
  1366. {
  1367. set_vec4(data, name, val, obs_data_set_obj);
  1368. }
  1369. void obs_data_set_quat(obs_data_t *data, const char *name,
  1370. const struct quat *val)
  1371. {
  1372. set_quat(data, name, val, obs_data_set_obj);
  1373. }
  1374. void obs_data_set_default_vec2(obs_data_t *data, const char *name,
  1375. const struct vec2 *val)
  1376. {
  1377. set_vec2(data, name, val, obs_data_set_default_obj);
  1378. }
  1379. void obs_data_set_default_vec3(obs_data_t *data, const char *name,
  1380. const struct vec3 *val)
  1381. {
  1382. set_vec3(data, name, val, obs_data_set_default_obj);
  1383. }
  1384. void obs_data_set_default_vec4(obs_data_t *data, const char *name,
  1385. const struct vec4 *val)
  1386. {
  1387. set_vec4(data, name, val, obs_data_set_default_obj);
  1388. }
  1389. void obs_data_set_default_quat(obs_data_t *data, const char *name,
  1390. const struct quat *val)
  1391. {
  1392. set_quat(data, name, val, obs_data_set_default_obj);
  1393. }
  1394. void obs_data_set_autoselect_vec2(obs_data_t *data, const char *name,
  1395. const struct vec2 *val)
  1396. {
  1397. set_vec2(data, name, val, obs_data_set_autoselect_obj);
  1398. }
  1399. void obs_data_set_autoselect_vec3(obs_data_t *data, const char *name,
  1400. const struct vec3 *val)
  1401. {
  1402. set_vec3(data, name, val, obs_data_set_autoselect_obj);
  1403. }
  1404. void obs_data_set_autoselect_vec4(obs_data_t *data, const char *name,
  1405. const struct vec4 *val)
  1406. {
  1407. set_vec4(data, name, val, obs_data_set_autoselect_obj);
  1408. }
  1409. void obs_data_set_autoselect_quat(obs_data_t *data, const char *name,
  1410. const struct quat *val)
  1411. {
  1412. set_quat(data, name, val, obs_data_set_autoselect_obj);
  1413. }
  1414. static inline void get_vec2(obs_data_t *obj, struct vec2 *val)
  1415. {
  1416. if (!obj) return;
  1417. val->x = (float)obs_data_get_double(obj, "x");
  1418. val->y = (float)obs_data_get_double(obj, "y");
  1419. obs_data_release(obj);
  1420. }
  1421. static inline void get_vec3(obs_data_t *obj, struct vec3 *val)
  1422. {
  1423. if (!obj) return;
  1424. val->x = (float)obs_data_get_double(obj, "x");
  1425. val->y = (float)obs_data_get_double(obj, "y");
  1426. val->z = (float)obs_data_get_double(obj, "z");
  1427. obs_data_release(obj);
  1428. }
  1429. static inline void get_vec4(obs_data_t *obj, struct vec4 *val)
  1430. {
  1431. if (!obj) return;
  1432. val->x = (float)obs_data_get_double(obj, "x");
  1433. val->y = (float)obs_data_get_double(obj, "y");
  1434. val->z = (float)obs_data_get_double(obj, "z");
  1435. val->w = (float)obs_data_get_double(obj, "w");
  1436. obs_data_release(obj);
  1437. }
  1438. static inline void get_quat(obs_data_t *obj, struct quat *val)
  1439. {
  1440. if (!obj) return;
  1441. val->x = (float)obs_data_get_double(obj, "x");
  1442. val->y = (float)obs_data_get_double(obj, "y");
  1443. val->z = (float)obs_data_get_double(obj, "z");
  1444. val->w = (float)obs_data_get_double(obj, "w");
  1445. obs_data_release(obj);
  1446. }
  1447. void obs_data_get_vec2(obs_data_t *data, const char *name, struct vec2 *val)
  1448. {
  1449. get_vec2(obs_data_get_obj(data, name), val);
  1450. }
  1451. void obs_data_get_vec3(obs_data_t *data, const char *name, struct vec3 *val)
  1452. {
  1453. get_vec3(obs_data_get_obj(data, name), val);
  1454. }
  1455. void obs_data_get_vec4(obs_data_t *data, const char *name, struct vec4 *val)
  1456. {
  1457. get_vec4(obs_data_get_obj(data, name), val);
  1458. }
  1459. void obs_data_get_quat(obs_data_t *data, const char *name, struct quat *val)
  1460. {
  1461. get_quat(obs_data_get_obj(data, name), val);
  1462. }
  1463. void obs_data_get_default_vec2(obs_data_t *data, const char *name,
  1464. struct vec2 *val)
  1465. {
  1466. get_vec2(obs_data_get_default_obj(data, name), val);
  1467. }
  1468. void obs_data_get_default_vec3(obs_data_t *data, const char *name,
  1469. struct vec3 *val)
  1470. {
  1471. get_vec3(obs_data_get_default_obj(data, name), val);
  1472. }
  1473. void obs_data_get_default_vec4(obs_data_t *data, const char *name,
  1474. struct vec4 *val)
  1475. {
  1476. get_vec4(obs_data_get_default_obj(data, name), val);
  1477. }
  1478. void obs_data_get_default_quat(obs_data_t *data, const char *name,
  1479. struct quat *val)
  1480. {
  1481. get_quat(obs_data_get_default_obj(data, name), val);
  1482. }
  1483. void obs_data_get_autoselect_vec2(obs_data_t *data, const char *name,
  1484. struct vec2 *val)
  1485. {
  1486. get_vec2(obs_data_get_autoselect_obj(data, name), val);
  1487. }
  1488. void obs_data_get_autoselect_vec3(obs_data_t *data, const char *name,
  1489. struct vec3 *val)
  1490. {
  1491. get_vec3(obs_data_get_autoselect_obj(data, name), val);
  1492. }
  1493. void obs_data_get_autoselect_vec4(obs_data_t *data, const char *name,
  1494. struct vec4 *val)
  1495. {
  1496. get_vec4(obs_data_get_autoselect_obj(data, name), val);
  1497. }
  1498. void obs_data_get_autoselect_quat(obs_data_t *data, const char *name,
  1499. struct quat *val)
  1500. {
  1501. get_quat(obs_data_get_autoselect_obj(data, name), val);
  1502. }