mirror of
https://github.com/asterisk/asterisk.git
synced 2025-09-06 12:36:58 +00:00
Merge "json: Add conditionals to avoid locking if Jansson is thread safe." into 13
This commit is contained in:
@@ -54,7 +54,7 @@ PACKAGES_FBSD="$PACKAGES_FBSD sqlite3 libxslt jansson e2fsprogs-libuuid gsm libs
|
|||||||
|
|
||||||
KVERS=`uname -r`
|
KVERS=`uname -r`
|
||||||
|
|
||||||
JANSSON_VER=2.10
|
JANSSON_VER=2.11
|
||||||
|
|
||||||
case "$1" in
|
case "$1" in
|
||||||
test)
|
test)
|
||||||
|
46
main/json.c
46
main/json.c
@@ -46,6 +46,21 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
|
|||||||
#include <jansson.h>
|
#include <jansson.h>
|
||||||
#include <time.h>
|
#include <time.h>
|
||||||
|
|
||||||
|
#if defined(JANSSON_THREAD_SAFE_REFCOUNT)
|
||||||
|
void *ast_json_malloc(size_t size)
|
||||||
|
{
|
||||||
|
return ast_malloc(size);
|
||||||
|
}
|
||||||
|
|
||||||
|
void ast_json_free(void *p)
|
||||||
|
{
|
||||||
|
ast_free(p);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* No need to lock since jansson is thread safe. */
|
||||||
|
#define SCOPED_JSON_LOCK(json)
|
||||||
|
|
||||||
|
#else
|
||||||
/*! \brief Magic number, for safety checks. */
|
/*! \brief Magic number, for safety checks. */
|
||||||
#define JSON_MAGIC 0x1541992
|
#define JSON_MAGIC 0x1541992
|
||||||
|
|
||||||
@@ -189,6 +204,7 @@ void ast_json_free(void *p)
|
|||||||
|
|
||||||
AST_LIST_INSERT_HEAD(free_list, mem, list);
|
AST_LIST_INSERT_HEAD(free_list, mem, list);
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
void ast_json_set_alloc_funcs(void *(*malloc_fn)(size_t), void (*free_fn)(void*))
|
void ast_json_set_alloc_funcs(void *(*malloc_fn)(size_t), void (*free_fn)(void*))
|
||||||
{
|
{
|
||||||
@@ -202,7 +218,7 @@ void ast_json_reset_alloc_funcs(void)
|
|||||||
|
|
||||||
struct ast_json *ast_json_ref(struct ast_json *json)
|
struct ast_json *ast_json_ref(struct ast_json *json)
|
||||||
{
|
{
|
||||||
/* Jansson refcounting is non-atomic; lock it. */
|
/* If Jansson refcounting is non-atomic; lock it. */
|
||||||
SCOPED_JSON_LOCK(json);
|
SCOPED_JSON_LOCK(json);
|
||||||
json_incref((json_t *)json);
|
json_incref((json_t *)json);
|
||||||
return json;
|
return json;
|
||||||
@@ -210,6 +226,9 @@ struct ast_json *ast_json_ref(struct ast_json *json)
|
|||||||
|
|
||||||
void ast_json_unref(struct ast_json *json)
|
void ast_json_unref(struct ast_json *json)
|
||||||
{
|
{
|
||||||
|
#if defined(JANSSON_THREAD_SAFE_REFCOUNT)
|
||||||
|
json_decref((json_t *) json);
|
||||||
|
#else
|
||||||
struct json_mem_list *free_list;
|
struct json_mem_list *free_list;
|
||||||
struct json_mem *mem;
|
struct json_mem *mem;
|
||||||
|
|
||||||
@@ -234,6 +253,7 @@ void ast_json_unref(struct ast_json *json)
|
|||||||
while ((mem = AST_LIST_REMOVE_HEAD(free_list, list))) {
|
while ((mem = AST_LIST_REMOVE_HEAD(free_list, list))) {
|
||||||
json_mem_free(mem);
|
json_mem_free(mem);
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
enum ast_json_type ast_json_typeof(const struct ast_json *json)
|
enum ast_json_type ast_json_typeof(const struct ast_json *json)
|
||||||
@@ -666,7 +686,11 @@ char *ast_json_dump_string_format(struct ast_json *root, enum ast_json_encoding_
|
|||||||
{
|
{
|
||||||
/* Jansson's json_dump*, even though it's a read operation, isn't
|
/* Jansson's json_dump*, even though it's a read operation, isn't
|
||||||
* thread safe for concurrent reads. Locking is necessary.
|
* thread safe for concurrent reads. Locking is necessary.
|
||||||
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety. */
|
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety.
|
||||||
|
*
|
||||||
|
* This comment does not apply when JANSSON_THREAD_SAFE_REFCOUNT is defined,
|
||||||
|
* in that case SCOPED_JSON_LOCK is a no-op.
|
||||||
|
*/
|
||||||
SCOPED_JSON_LOCK(root);
|
SCOPED_JSON_LOCK(root);
|
||||||
return json_dumps((json_t *)root, dump_flags(format));
|
return json_dumps((json_t *)root, dump_flags(format));
|
||||||
}
|
}
|
||||||
@@ -706,7 +730,11 @@ int ast_json_dump_str_format(struct ast_json *root, struct ast_str **dst, enum a
|
|||||||
{
|
{
|
||||||
/* Jansson's json_dump*, even though it's a read operation, isn't
|
/* Jansson's json_dump*, even though it's a read operation, isn't
|
||||||
* thread safe for concurrent reads. Locking is necessary.
|
* thread safe for concurrent reads. Locking is necessary.
|
||||||
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety. */
|
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety.
|
||||||
|
*
|
||||||
|
* This comment does not apply when JANSSON_THREAD_SAFE_REFCOUNT is defined,
|
||||||
|
* in that case SCOPED_JSON_LOCK is a no-op.
|
||||||
|
*/
|
||||||
SCOPED_JSON_LOCK(root);
|
SCOPED_JSON_LOCK(root);
|
||||||
return json_dump_callback((json_t *)root, write_to_ast_str, dst, dump_flags(format));
|
return json_dump_callback((json_t *)root, write_to_ast_str, dst, dump_flags(format));
|
||||||
}
|
}
|
||||||
@@ -716,7 +744,11 @@ int ast_json_dump_file_format(struct ast_json *root, FILE *output, enum ast_json
|
|||||||
{
|
{
|
||||||
/* Jansson's json_dump*, even though it's a read operation, isn't
|
/* Jansson's json_dump*, even though it's a read operation, isn't
|
||||||
* thread safe for concurrent reads. Locking is necessary.
|
* thread safe for concurrent reads. Locking is necessary.
|
||||||
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety. */
|
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety.
|
||||||
|
*
|
||||||
|
* This comment does not apply when JANSSON_THREAD_SAFE_REFCOUNT is defined,
|
||||||
|
* in that case SCOPED_JSON_LOCK is a no-op.
|
||||||
|
*/
|
||||||
SCOPED_JSON_LOCK(root);
|
SCOPED_JSON_LOCK(root);
|
||||||
if (!root || !output) {
|
if (!root || !output) {
|
||||||
return -1;
|
return -1;
|
||||||
@@ -727,7 +759,11 @@ int ast_json_dump_new_file_format(struct ast_json *root, const char *path, enum
|
|||||||
{
|
{
|
||||||
/* Jansson's json_dump*, even though it's a read operation, isn't
|
/* Jansson's json_dump*, even though it's a read operation, isn't
|
||||||
* thread safe for concurrent reads. Locking is necessary.
|
* thread safe for concurrent reads. Locking is necessary.
|
||||||
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety. */
|
* See http://www.digip.org/jansson/doc/2.4/portability.html#thread-safety.
|
||||||
|
*
|
||||||
|
* This comment does not apply when JANSSON_THREAD_SAFE_REFCOUNT is defined,
|
||||||
|
* in that case SCOPED_JSON_LOCK is a no-op.
|
||||||
|
*/
|
||||||
SCOPED_JSON_LOCK(root);
|
SCOPED_JSON_LOCK(root);
|
||||||
if (!root || !path) {
|
if (!root || !path) {
|
||||||
return -1;
|
return -1;
|
||||||
|
Reference in New Issue
Block a user