obs-data.c 25 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036
  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 capacity;
  31. };
  32. struct obs_data {
  33. volatile long ref;
  34. char *json;
  35. struct obs_data_item *first_item;
  36. };
  37. struct obs_data_array {
  38. volatile long ref;
  39. DARRAY(obs_data_t) objects;
  40. };
  41. struct obs_data_number {
  42. enum obs_data_number_type type;
  43. union {
  44. long long int_val;
  45. double double_val;
  46. };
  47. };
  48. /* ------------------------------------------------------------------------- */
  49. /* Item structure, designed to be one allocation only */
  50. /* ensures data after the name has alignment (in case of SSE) */
  51. static inline size_t get_name_align_size(const char *name)
  52. {
  53. size_t name_size = strlen(name) + 1;
  54. size_t alignment = base_get_alignment();
  55. size_t total_size;
  56. total_size = sizeof(struct obs_data_item) + (name_size + alignment-1);
  57. total_size &= ~(alignment-1);
  58. return total_size - sizeof(struct obs_data_item);
  59. }
  60. static inline char *get_item_name(struct obs_data_item *item)
  61. {
  62. return (char*)item + sizeof(struct obs_data_item);
  63. }
  64. static inline void *get_item_data(struct obs_data_item *item)
  65. {
  66. return (uint8_t*)get_item_name(item) + item->name_len;
  67. }
  68. static inline size_t obs_data_item_total_size(struct obs_data_item *item)
  69. {
  70. return sizeof(struct obs_data_item) + item->data_len + item->name_len;
  71. }
  72. static inline obs_data_t get_item_obj(struct obs_data_item *item)
  73. {
  74. if (!item)
  75. return NULL;
  76. return *(obs_data_t*)get_item_data(item);
  77. }
  78. static inline obs_data_array_t get_item_array(struct obs_data_item *item)
  79. {
  80. if (!item)
  81. return NULL;
  82. return *(obs_data_array_t*)get_item_data(item);
  83. }
  84. static inline void item_data_release(struct obs_data_item *item)
  85. {
  86. if (item->type == OBS_DATA_OBJECT) {
  87. obs_data_t obj = get_item_obj(item);
  88. obs_data_release(obj);
  89. } else if (item->type == OBS_DATA_ARRAY) {
  90. obs_data_array_t array = get_item_array(item);
  91. obs_data_array_release(array);
  92. }
  93. }
  94. static inline void item_data_addref(struct obs_data_item *item)
  95. {
  96. if (item->type == OBS_DATA_OBJECT) {
  97. obs_data_t obj = get_item_obj(item);
  98. obs_data_addref(obj);
  99. } else if (item->type == OBS_DATA_ARRAY) {
  100. obs_data_array_t array = get_item_array(item);
  101. obs_data_array_addref(array);
  102. }
  103. }
  104. static struct obs_data_item *obs_data_item_create(const char *name,
  105. const void *data, size_t size, enum obs_data_type type)
  106. {
  107. struct obs_data_item *item;
  108. size_t name_size, total_size;
  109. if (!name || !data)
  110. return NULL;
  111. name_size = get_name_align_size(name);
  112. total_size = name_size + sizeof(struct obs_data_item) + size;
  113. item = bzalloc(total_size);
  114. item->capacity = total_size;
  115. item->type = type;
  116. item->name_len = name_size;
  117. item->data_len = size;
  118. item->ref = 1;
  119. strcpy(get_item_name(item), name);
  120. memcpy(get_item_data(item), data, size);
  121. item_data_addref(item);
  122. return item;
  123. }
  124. static struct obs_data_item **get_item_prev_next(struct obs_data *data,
  125. struct obs_data_item *current)
  126. {
  127. if (!current || !data)
  128. return NULL;
  129. struct obs_data_item **prev_next = &data->first_item;
  130. struct obs_data_item *item = data->first_item;
  131. while (item) {
  132. if (item == current)
  133. return prev_next;
  134. prev_next = &item->next;
  135. item = item->next;
  136. }
  137. return NULL;
  138. }
  139. static inline void obs_data_item_detach(struct obs_data_item *item)
  140. {
  141. struct obs_data_item **prev_next = get_item_prev_next(item->parent,
  142. item);
  143. if (prev_next) {
  144. *prev_next = item->next;
  145. item->next = NULL;
  146. }
  147. }
  148. static inline void obs_data_item_reattach(struct obs_data_item *old_ptr,
  149. struct obs_data_item *new_ptr)
  150. {
  151. struct obs_data_item **prev_next = get_item_prev_next(new_ptr->parent,
  152. old_ptr);
  153. if (prev_next)
  154. *prev_next = new_ptr;
  155. }
  156. static struct obs_data_item *obs_data_item_ensure_capacity(
  157. struct obs_data_item *item)
  158. {
  159. size_t new_size = obs_data_item_total_size(item);
  160. struct obs_data_item *new_item;
  161. if (item->capacity >= new_size)
  162. return item;
  163. new_item = brealloc(item, new_size);
  164. new_item->capacity = new_size;
  165. obs_data_item_reattach(item, new_item);
  166. return new_item;
  167. }
  168. static inline void obs_data_item_destroy(struct obs_data_item *item)
  169. {
  170. item_data_release(item);
  171. obs_data_item_detach(item);
  172. bfree(item);
  173. }
  174. static inline void obs_data_item_setdata(
  175. struct obs_data_item **p_item, const void *data, size_t size,
  176. enum obs_data_type type)
  177. {
  178. if (!p_item || !*p_item)
  179. return;
  180. struct obs_data_item *item = *p_item;
  181. item_data_release(item);
  182. item->data_len = size;
  183. item->type = type;
  184. item = obs_data_item_ensure_capacity(item);
  185. if (size) {
  186. memcpy(get_item_data(item), data, size);
  187. item_data_addref(item);
  188. }
  189. *p_item = item;
  190. }
  191. /* ------------------------------------------------------------------------- */
  192. static void obs_data_add_json_item(obs_data_t data, const char *key,
  193. json_t *json);
  194. static inline void obs_data_add_json_object_data(obs_data_t data, json_t *jobj)
  195. {
  196. const char *item_key;
  197. json_t *jitem;
  198. json_object_foreach (jobj, item_key, jitem) {
  199. obs_data_add_json_item(data, item_key, jitem);
  200. }
  201. }
  202. static inline void obs_data_add_json_object(obs_data_t data, const char *key,
  203. json_t *jobj)
  204. {
  205. obs_data_t sub_obj = obs_data_create();
  206. obs_data_add_json_object_data(sub_obj, jobj);
  207. obs_data_setobj(data, key, sub_obj);
  208. obs_data_release(sub_obj);
  209. }
  210. static void obs_data_add_json_array(obs_data_t data, const char *key,
  211. json_t *jarray)
  212. {
  213. obs_data_array_t array = obs_data_array_create();
  214. size_t idx;
  215. json_t *jitem;
  216. json_array_foreach (jarray, idx, jitem) {
  217. obs_data_t item;
  218. if (!json_is_object(jitem))
  219. continue;
  220. item = obs_data_create();
  221. obs_data_add_json_object_data(item, jitem);
  222. obs_data_array_push_back(array, item);
  223. obs_data_release(item);
  224. }
  225. obs_data_setarray(data, key, array);
  226. obs_data_array_release(array);
  227. }
  228. static void obs_data_add_json_item(obs_data_t data, const char *key,
  229. json_t *json)
  230. {
  231. if (json_is_object(json))
  232. obs_data_add_json_object(data, key, json);
  233. else if (json_is_array(json))
  234. obs_data_add_json_array(data, key, json);
  235. else if (json_is_string(json))
  236. obs_data_setstring(data, key, json_string_value(json));
  237. else if (json_is_integer(json))
  238. obs_data_setint(data, key, json_integer_value(json));
  239. else if (json_is_real(json))
  240. obs_data_setdouble(data, key, json_real_value(json));
  241. else if (json_is_true(json))
  242. obs_data_setbool(data, key, true);
  243. else if (json_is_false(json))
  244. obs_data_setbool(data, key, false);
  245. }
  246. /* ------------------------------------------------------------------------- */
  247. static inline void set_json_string(json_t *json, const char *name,
  248. obs_data_item_t item)
  249. {
  250. const char *val = obs_data_item_getstring(item);
  251. json_object_set_new(json, name, json_string(val));
  252. }
  253. static inline void set_json_number(json_t *json, const char *name,
  254. obs_data_item_t item)
  255. {
  256. enum obs_data_number_type type = obs_data_item_numtype(item);
  257. if (type == OBS_DATA_NUM_INT) {
  258. long long val = obs_data_item_getint(item);
  259. json_object_set_new(json, name, json_integer(val));
  260. } else {
  261. double val = obs_data_item_getdouble(item);
  262. json_object_set_new(json, name, json_real(val));
  263. }
  264. }
  265. static inline void set_json_bool(json_t *json, const char *name,
  266. obs_data_item_t item)
  267. {
  268. bool val = obs_data_item_getbool(item);
  269. json_object_set_new(json, name, val ? json_true() : json_false());
  270. }
  271. static json_t *obs_data_to_json(obs_data_t data);
  272. static inline void set_json_obj(json_t *json, const char *name,
  273. obs_data_item_t item)
  274. {
  275. obs_data_t obj = obs_data_item_getobj(item);
  276. json_object_set_new(json, name, obs_data_to_json(obj));
  277. obs_data_release(obj);
  278. }
  279. static inline void set_json_array(json_t *json, const char *name,
  280. obs_data_item_t item)
  281. {
  282. json_t *jarray = json_array();
  283. obs_data_array_t array = obs_data_item_getarray(item);
  284. size_t count = obs_data_array_count(array);
  285. for (size_t idx = 0; idx < count; idx++) {
  286. obs_data_t sub_item = obs_data_array_item(array, idx);
  287. json_t *jitem = obs_data_to_json(sub_item);
  288. json_array_append_new(jarray, jitem);
  289. obs_data_release(sub_item);
  290. }
  291. json_object_set_new(json, name, jarray);
  292. obs_data_array_release(array);
  293. }
  294. static json_t *obs_data_to_json(obs_data_t data)
  295. {
  296. json_t *json = json_object();
  297. obs_data_item_t item = obs_data_first(data);
  298. while (item) {
  299. enum obs_data_type type = obs_data_item_gettype(item);
  300. const char *name = get_item_name(item);
  301. if (type == OBS_DATA_STRING)
  302. set_json_string(json, name, item);
  303. else if (type == OBS_DATA_NUMBER)
  304. set_json_number(json, name, item);
  305. else if (type == OBS_DATA_BOOLEAN)
  306. set_json_bool(json, name, item);
  307. else if (type == OBS_DATA_OBJECT)
  308. set_json_obj(json, name, item);
  309. else if (type == OBS_DATA_ARRAY)
  310. set_json_array(json, name, item);
  311. obs_data_item_next(&item);
  312. }
  313. return json;
  314. }
  315. /* ------------------------------------------------------------------------- */
  316. obs_data_t obs_data_create()
  317. {
  318. struct obs_data *data = bzalloc(sizeof(struct obs_data));
  319. data->ref = 1;
  320. return data;
  321. }
  322. obs_data_t obs_data_create_from_json(const char *json_string)
  323. {
  324. obs_data_t data = obs_data_create();
  325. json_error_t error;
  326. json_t *root = json_loads(json_string, JSON_REJECT_DUPLICATES, &error);
  327. if (root) {
  328. obs_data_add_json_object_data(data, root);
  329. json_decref(root);
  330. } else {
  331. blog(LOG_ERROR, "obs-data.c: [obs_data_create_from_json] "
  332. "Failed reading json string (%d): %s",
  333. error.line, error.text);
  334. }
  335. return data;
  336. }
  337. void obs_data_addref(obs_data_t data)
  338. {
  339. if (data)
  340. os_atomic_inc_long(&data->ref);
  341. }
  342. static inline void obs_data_destroy(struct obs_data *data)
  343. {
  344. struct obs_data_item *item = data->first_item;
  345. while (item) {
  346. struct obs_data_item *next = item->next;
  347. obs_data_item_release(&item);
  348. item = next;
  349. }
  350. /* NOTE: don't use bfree for json text, allocated by json */
  351. free(data->json);
  352. bfree(data);
  353. }
  354. void obs_data_release(obs_data_t data)
  355. {
  356. if (!data) return;
  357. if (os_atomic_dec_long(&data->ref) == 0)
  358. obs_data_destroy(data);
  359. }
  360. const char *obs_data_getjson(obs_data_t data)
  361. {
  362. if (!data) return NULL;
  363. /* NOTE: don't use libobs bfree for json text */
  364. free(data->json);
  365. data->json = NULL;
  366. json_t *root = obs_data_to_json(data);
  367. data->json = json_dumps(root, JSON_PRESERVE_ORDER | JSON_INDENT(4));
  368. json_decref(root);
  369. return data->json;
  370. }
  371. static struct obs_data_item *get_item(struct obs_data *data, const char *name)
  372. {
  373. if (!data) return NULL;
  374. struct obs_data_item *item = data->first_item;
  375. while (item) {
  376. if (strcmp(get_item_name(item), name) == 0)
  377. return item;
  378. item = item->next;
  379. }
  380. return NULL;
  381. }
  382. static inline struct obs_data_item *get_item_of(struct obs_data *data,
  383. const char *name, enum obs_data_type type)
  384. {
  385. if (!data)
  386. return NULL;
  387. struct obs_data_item *item = get_item(data, name);
  388. return (item && item->type == type) ? item : NULL;
  389. }
  390. static void set_item_data(struct obs_data *data, struct obs_data_item *item,
  391. const char *name, const void *ptr, size_t size,
  392. enum obs_data_type type)
  393. {
  394. if (!item) {
  395. item = obs_data_item_create(name, ptr, size, type);
  396. item->next = data->first_item;
  397. item->parent = data;
  398. data->first_item = item;
  399. } else {
  400. obs_data_item_setdata(&item, ptr, size, type);
  401. }
  402. }
  403. static inline void set_item(struct obs_data *data, const char *name,
  404. const void *ptr, size_t size, enum obs_data_type type)
  405. {
  406. if (!data)
  407. return;
  408. struct obs_data_item *item = get_item(data, name);
  409. set_item_data(data, item, name, ptr, size, type);
  410. }
  411. static inline void set_item_def(struct obs_data *data, const char *name,
  412. const void *ptr, size_t size, enum obs_data_type type)
  413. {
  414. if (!data)
  415. return;
  416. struct obs_data_item *item = get_item(data, name);
  417. if (item && item->type == type)
  418. return;
  419. set_item_data(data, item, name, ptr, size, type);
  420. }
  421. static inline void copy_item(struct obs_data *data, struct obs_data_item *item)
  422. {
  423. const char *name = get_item_name(item);
  424. void *ptr = get_item_data(item);
  425. set_item(data, name, ptr, item->data_len, item->type);
  426. }
  427. void obs_data_apply(obs_data_t target, obs_data_t apply_data)
  428. {
  429. struct obs_data_item *item;
  430. if (!target || !apply_data || target == apply_data)
  431. return;
  432. item = apply_data->first_item;
  433. while (item) {
  434. copy_item(target, item);
  435. item = item->next;
  436. }
  437. }
  438. void obs_data_erase(obs_data_t data, const char *name)
  439. {
  440. struct obs_data_item *item = get_item(data, name);
  441. if (item) {
  442. obs_data_item_detach(item);
  443. obs_data_item_release(&item);
  444. }
  445. }
  446. void obs_data_setstring(obs_data_t data, const char *name, const char *val)
  447. {
  448. if (!val) val = "";
  449. set_item(data, name, val, strlen(val)+1, OBS_DATA_STRING);
  450. }
  451. void obs_data_setint(obs_data_t data, const char *name, long long val)
  452. {
  453. struct obs_data_number num;
  454. num.type = OBS_DATA_NUM_INT;
  455. num.int_val = val;
  456. set_item(data, name, &num, sizeof(struct obs_data_number),
  457. OBS_DATA_NUMBER);
  458. }
  459. void obs_data_setdouble(obs_data_t data, const char *name, double val)
  460. {
  461. struct obs_data_number num;
  462. num.type = OBS_DATA_NUM_DOUBLE;
  463. num.double_val = val;
  464. set_item(data, name, &num, sizeof(struct obs_data_number),
  465. OBS_DATA_NUMBER);
  466. }
  467. void obs_data_setbool(obs_data_t data, const char *name, bool val)
  468. {
  469. set_item(data, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  470. }
  471. void obs_data_setobj(obs_data_t data, const char *name, obs_data_t obj)
  472. {
  473. set_item(data, name, &obj, sizeof(obs_data_t), OBS_DATA_OBJECT);
  474. }
  475. void obs_data_setarray(obs_data_t data, const char *name,
  476. obs_data_array_t array)
  477. {
  478. set_item(data, name, &array, sizeof(obs_data_t), OBS_DATA_ARRAY);
  479. }
  480. void obs_data_set_default_string(obs_data_t data, const char *name,
  481. const char *val)
  482. {
  483. if (!val) val = "";
  484. set_item_def(data, name, val, strlen(val)+1, OBS_DATA_STRING);
  485. }
  486. void obs_data_set_default_int(obs_data_t data, const char *name, long long val)
  487. {
  488. struct obs_data_number num;
  489. num.type = OBS_DATA_NUM_INT;
  490. num.int_val = val;
  491. set_item_def(data, name, &num, sizeof(struct obs_data_number),
  492. OBS_DATA_NUMBER);
  493. }
  494. void obs_data_set_default_double(obs_data_t data, const char *name, double val)
  495. {
  496. struct obs_data_number num;
  497. num.type = OBS_DATA_NUM_DOUBLE;
  498. num.double_val = val;
  499. set_item_def(data, name, &num, sizeof(struct obs_data_number),
  500. OBS_DATA_NUMBER);
  501. }
  502. void obs_data_set_default_bool(obs_data_t data, const char *name, bool val)
  503. {
  504. set_item_def(data, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  505. }
  506. void obs_data_set_default_obj(obs_data_t data, const char *name, obs_data_t obj)
  507. {
  508. set_item_def(data, name, &obj, sizeof(obs_data_t), OBS_DATA_OBJECT);
  509. }
  510. const char *obs_data_getstring(obs_data_t data, const char *name)
  511. {
  512. struct obs_data_item *item = get_item_of(data, name, OBS_DATA_STRING);
  513. return item ? get_item_data(item) : "";
  514. }
  515. static inline long long item_int(struct obs_data_item *item)
  516. {
  517. if (item) {
  518. struct obs_data_number *num = get_item_data(item);
  519. return (num->type == OBS_DATA_NUM_INT) ?
  520. num->int_val : (long long)num->double_val;
  521. }
  522. return 0;
  523. }
  524. static inline double item_double(struct obs_data_item *item)
  525. {
  526. if (item) {
  527. struct obs_data_number *num = get_item_data(item);
  528. return (num->type == OBS_DATA_NUM_INT) ?
  529. (double)num->int_val : num->double_val;
  530. }
  531. return 0.0;
  532. }
  533. long long obs_data_getint(obs_data_t data, const char *name)
  534. {
  535. return item_int(get_item_of(data, name, OBS_DATA_NUMBER));
  536. }
  537. double obs_data_getdouble(obs_data_t data, const char *name)
  538. {
  539. return item_double(get_item_of(data, name, OBS_DATA_NUMBER));
  540. }
  541. bool obs_data_getbool(obs_data_t data, const char *name)
  542. {
  543. struct obs_data_item *item = get_item_of(data, name, OBS_DATA_BOOLEAN);
  544. return item ? *(bool*)get_item_data(item) : false;
  545. }
  546. obs_data_t obs_data_getobj(obs_data_t data, const char *name)
  547. {
  548. struct obs_data_item *item = get_item_of(data, name, OBS_DATA_OBJECT);
  549. obs_data_t obj = get_item_obj(item);
  550. if (obj)
  551. os_atomic_inc_long(&obj->ref);
  552. return obj;
  553. }
  554. obs_data_array_t obs_data_getarray(obs_data_t data, const char *name)
  555. {
  556. struct obs_data_item *item = get_item_of(data, name, OBS_DATA_ARRAY);
  557. obs_data_array_t array = get_item_array(item);
  558. if (array)
  559. os_atomic_inc_long(&array->ref);
  560. return array;
  561. }
  562. obs_data_array_t obs_data_array_create()
  563. {
  564. struct obs_data_array *array = bzalloc(sizeof(struct obs_data_array));
  565. array->ref = 1;
  566. return array;
  567. }
  568. void obs_data_array_addref(obs_data_array_t array)
  569. {
  570. if (array)
  571. os_atomic_inc_long(&array->ref);
  572. }
  573. static inline void obs_data_array_destroy(obs_data_array_t array)
  574. {
  575. if (array) {
  576. for (size_t i = 0; i < array->objects.num; i++)
  577. obs_data_release(array->objects.array[i]);
  578. da_free(array->objects);
  579. bfree(array);
  580. }
  581. }
  582. void obs_data_array_release(obs_data_array_t array)
  583. {
  584. if (!array)
  585. return;
  586. if (os_atomic_dec_long(&array->ref) == 0)
  587. obs_data_array_destroy(array);
  588. }
  589. size_t obs_data_array_count(obs_data_array_t array)
  590. {
  591. return array ? array->objects.num : 0;
  592. }
  593. obs_data_t obs_data_array_item(obs_data_array_t array, size_t idx)
  594. {
  595. obs_data_t data;
  596. if (!array)
  597. return NULL;
  598. data = (idx < array->objects.num) ? array->objects.array[idx] : NULL;
  599. if (data)
  600. os_atomic_inc_long(&data->ref);
  601. return data;
  602. }
  603. size_t obs_data_array_push_back(obs_data_array_t array, obs_data_t obj)
  604. {
  605. if (!array || !obj)
  606. return 0;
  607. os_atomic_inc_long(&obj->ref);
  608. return da_push_back(array->objects, &obj);
  609. }
  610. void obs_data_array_insert(obs_data_array_t array, size_t idx, obs_data_t obj)
  611. {
  612. if (!array || !obj)
  613. return;
  614. os_atomic_inc_long(&obj->ref);
  615. da_insert(array->objects, idx, &obj);
  616. }
  617. void obs_data_array_erase(obs_data_array_t array, size_t idx)
  618. {
  619. if (array) {
  620. obs_data_release(array->objects.array[idx]);
  621. da_erase(array->objects, idx);
  622. }
  623. }
  624. /* ------------------------------------------------------------------------- */
  625. /* Item iteration */
  626. obs_data_item_t obs_data_first(obs_data_t data)
  627. {
  628. if (!data)
  629. return NULL;
  630. if (data->first_item)
  631. os_atomic_inc_long(&data->first_item->ref);
  632. return data->first_item;
  633. }
  634. obs_data_item_t obs_data_item_byname(obs_data_t data, const char *name)
  635. {
  636. if (!data)
  637. return NULL;
  638. struct obs_data_item *item = get_item(data, name);
  639. if (item)
  640. os_atomic_inc_long(&item->ref);
  641. return item;
  642. }
  643. bool obs_data_item_next(obs_data_item_t *item)
  644. {
  645. if (item && *item) {
  646. obs_data_item_t next = (*item)->next;
  647. obs_data_item_release(item);
  648. *item = next;
  649. if (next) {
  650. os_atomic_inc_long(&next->ref);
  651. return true;
  652. }
  653. }
  654. return false;
  655. }
  656. void obs_data_item_release(obs_data_item_t *item)
  657. {
  658. if (item && *item) {
  659. long ref = os_atomic_dec_long(&(*item)->ref);
  660. if (!ref) {
  661. obs_data_item_destroy(*item);
  662. *item = NULL;
  663. }
  664. }
  665. }
  666. void obs_data_item_remove(obs_data_item_t *item)
  667. {
  668. if (item && *item) {
  669. obs_data_item_detach(*item);
  670. obs_data_item_release(item);
  671. }
  672. }
  673. enum obs_data_type obs_data_item_gettype(obs_data_item_t item)
  674. {
  675. return item ? item->type : OBS_DATA_NULL;
  676. }
  677. enum obs_data_number_type obs_data_item_numtype(obs_data_item_t item)
  678. {
  679. struct obs_data_number *num;
  680. if (!item || item->type != OBS_DATA_NUMBER)
  681. return OBS_DATA_NUM_INVALID;
  682. num = get_item_data(item);
  683. return num->type;
  684. }
  685. void obs_data_item_setstring(obs_data_item_t *item, const char *val)
  686. {
  687. if (!val) val = "";
  688. obs_data_item_setdata(item, val, strlen(val)+1, OBS_DATA_STRING);
  689. }
  690. void obs_data_item_setint(obs_data_item_t *item, long long val)
  691. {
  692. struct obs_data_number num;
  693. num.type = OBS_DATA_NUM_INT;
  694. num.int_val = val;
  695. obs_data_item_setdata(item, &val, sizeof(struct obs_data_number),
  696. OBS_DATA_NUMBER);
  697. }
  698. void obs_data_item_setdouble(obs_data_item_t *item, double val)
  699. {
  700. struct obs_data_number num;
  701. num.type = OBS_DATA_NUM_DOUBLE;
  702. num.double_val = val;
  703. obs_data_item_setdata(item, &val, sizeof(struct obs_data_number),
  704. OBS_DATA_NUMBER);
  705. }
  706. void obs_data_item_setbool(obs_data_item_t *item, bool val)
  707. {
  708. obs_data_item_setdata(item, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  709. }
  710. void obs_data_item_setobj(obs_data_item_t *item, obs_data_t val)
  711. {
  712. obs_data_item_setdata(item, &val, sizeof(obs_data_t), OBS_DATA_OBJECT);
  713. }
  714. void obs_data_item_setarray(obs_data_item_t *item, obs_data_array_t val)
  715. {
  716. obs_data_item_setdata(item, &val, sizeof(obs_data_array_t),
  717. OBS_DATA_ARRAY);
  718. }
  719. static inline bool item_valid(struct obs_data_item *item,
  720. enum obs_data_type type)
  721. {
  722. return item && item->type == type;
  723. }
  724. const char *obs_data_item_getstring(obs_data_item_t item)
  725. {
  726. return item_valid(item, OBS_DATA_STRING) ? get_item_data(item) : "";
  727. }
  728. long long obs_data_item_getint(obs_data_item_t item)
  729. {
  730. return item_valid(item, OBS_DATA_NUMBER) ?
  731. item_int(item) : 0;
  732. }
  733. double obs_data_item_getdouble(obs_data_item_t item)
  734. {
  735. return item_valid(item, OBS_DATA_NUMBER) ?
  736. item_double(item) : 0.0;
  737. }
  738. bool obs_data_item_getbool(obs_data_item_t item)
  739. {
  740. return item_valid(item, OBS_DATA_BOOLEAN) ?
  741. *(bool*)get_item_data(item) : false;
  742. }
  743. obs_data_t obs_data_item_getobj(obs_data_item_t item)
  744. {
  745. obs_data_t obj = item_valid(item, OBS_DATA_OBJECT) ?
  746. get_item_obj(item) : NULL;
  747. if (obj)
  748. os_atomic_inc_long(&obj->ref);
  749. return obj;
  750. }
  751. obs_data_array_t obs_data_item_getarray(obs_data_item_t item)
  752. {
  753. obs_data_array_t array = item_valid(item, OBS_DATA_ARRAY) ?
  754. get_item_array(item) : NULL;
  755. if (array)
  756. os_atomic_inc_long(&array->ref);
  757. return array;
  758. }
  759. /* ------------------------------------------------------------------------- */
  760. /* Helper functions for certain structures */
  761. void obs_data_set_vec2(obs_data_t data, const char *name,
  762. const struct vec2 *val)
  763. {
  764. obs_data_t obj = obs_data_create();
  765. obs_data_setdouble(obj, "x", val->x);
  766. obs_data_setdouble(obj, "y", val->y);
  767. obs_data_setobj(data, name, obj);
  768. obs_data_release(obj);
  769. }
  770. void obs_data_set_vec3(obs_data_t data, const char *name,
  771. const struct vec3 *val)
  772. {
  773. obs_data_t obj = obs_data_create();
  774. obs_data_setdouble(obj, "x", val->x);
  775. obs_data_setdouble(obj, "y", val->y);
  776. obs_data_setdouble(obj, "z", val->z);
  777. obs_data_setobj(data, name, obj);
  778. obs_data_release(obj);
  779. }
  780. void obs_data_set_vec4(obs_data_t data, const char *name,
  781. const struct vec4 *val)
  782. {
  783. obs_data_t obj = obs_data_create();
  784. obs_data_setdouble(obj, "x", val->x);
  785. obs_data_setdouble(obj, "y", val->y);
  786. obs_data_setdouble(obj, "z", val->z);
  787. obs_data_setdouble(obj, "w", val->w);
  788. obs_data_setobj(data, name, obj);
  789. obs_data_release(obj);
  790. }
  791. void obs_data_set_quat(obs_data_t data, const char *name,
  792. const struct quat *val)
  793. {
  794. obs_data_t obj = obs_data_create();
  795. obs_data_setdouble(obj, "x", val->x);
  796. obs_data_setdouble(obj, "y", val->y);
  797. obs_data_setdouble(obj, "z", val->z);
  798. obs_data_setdouble(obj, "w", val->w);
  799. obs_data_setobj(data, name, obj);
  800. obs_data_release(obj);
  801. }
  802. void obs_data_get_vec2(obs_data_t data, const char *name, struct vec2 *val)
  803. {
  804. obs_data_t obj = obs_data_getobj(data, name);
  805. if (!obj) return;
  806. val->x = (float)obs_data_getdouble(obj, "x");
  807. val->y = (float)obs_data_getdouble(obj, "y");
  808. obs_data_release(obj);
  809. }
  810. void obs_data_get_vec3(obs_data_t data, const char *name, struct vec3 *val)
  811. {
  812. obs_data_t obj = obs_data_getobj(data, name);
  813. if (!obj) return;
  814. val->x = (float)obs_data_getdouble(obj, "x");
  815. val->y = (float)obs_data_getdouble(obj, "y");
  816. val->z = (float)obs_data_getdouble(obj, "z");
  817. obs_data_release(obj);
  818. }
  819. void obs_data_get_vec4(obs_data_t data, const char *name, struct vec4 *val)
  820. {
  821. obs_data_t obj = obs_data_getobj(data, name);
  822. if (!obj) return;
  823. val->x = (float)obs_data_getdouble(obj, "x");
  824. val->y = (float)obs_data_getdouble(obj, "y");
  825. val->z = (float)obs_data_getdouble(obj, "z");
  826. val->w = (float)obs_data_getdouble(obj, "w");
  827. obs_data_release(obj);
  828. }
  829. void obs_data_get_quat(obs_data_t data, const char *name, struct quat *val)
  830. {
  831. obs_data_t obj = obs_data_getobj(data, name);
  832. if (!obj) return;
  833. val->x = (float)obs_data_getdouble(obj, "x");
  834. val->y = (float)obs_data_getdouble(obj, "y");
  835. val->z = (float)obs_data_getdouble(obj, "z");
  836. val->w = (float)obs_data_getdouble(obj, "w");
  837. obs_data_release(obj);
  838. }