#include "asterisk/network.h"
#include <time.h>
#include <unistd.h>
#include <string.h>
#include "asterisk/lock.h"
#include "asterisk/logger.h"
#include "asterisk/localtime.h"
#include "asterisk/stringfields.h"
#include "asterisk/strings.h"
Go to the source code of this file.
Data Structures | |
struct | ast_eid |
An Entity ID is essentially a MAC address, brief and unique. More... | |
struct | ast_flags |
Structure used to handle boolean flags. More... | |
struct | ast_flags64 |
Structure used to handle a large number of boolean flags == used only in app_dial? More... | |
struct | ast_hostent |
struct | ast_http_digest |
Defines | |
#define | ARRAY_LEN(a) (size_t) (sizeof(a) / sizeof(0[a])) |
#define | ast_align_for(offset, type) (((offset + __alignof__(type) - 1) / __alignof__(type)) * __alignof__(type)) |
Increase offset so it is a multiple of the required alignment of type. | |
#define | ast_alignof(type) __alignof__(type) |
Return the number of bytes used in the alignment of type. | |
#define | ast_asprintf(ret, fmt,) _ast_asprintf((ret), __FILE__, __LINE__, __PRETTY_FUNCTION__, fmt, __VA_ARGS__) |
A wrapper for asprintf(). | |
#define | ast_assert(a) |
#define | AST_BACKGROUND_STACKSIZE AST_STACKSIZE |
#define | ast_calloc(num, len) _ast_calloc((num), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for calloc(). | |
#define | ast_calloc_cache(num, len) _ast_calloc((num), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for calloc() for use in cache pools. | |
#define | ast_clear_flag(p, flag) |
#define | ast_clear_flag64(p, flag) |
#define | ast_clear_flag_nonstd(p, flag) |
#define | ast_copy_flags(dest, src, flagz) |
#define | ast_copy_flags64(dest, src, flagz) |
#define | ast_copy_flags_nonstd(dest, src, flagz) |
#define | AST_FLAGS_ALL UINT_MAX |
#define | ast_free free |
free() wrapper | |
#define | ast_free_ptr ast_free |
#define | ast_make_room_for(offset, type) (((offset + (2 * __alignof__(type) - 1)) / __alignof__(type)) * __alignof__(type)) |
Increase offset by the required alignment of type and make sure it is a multiple of said alignment. | |
#define | ast_malloc(len) _ast_malloc((len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for malloc(). | |
#define | ast_pthread_create(a, b, c, d) |
#define | ast_pthread_create_background(a, b, c, d) |
#define | ast_pthread_create_detached(a, b, c, d) |
#define | ast_pthread_create_detached_background(a, b, c, d) |
#define | ast_realloc(p, len) _ast_realloc((p), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for realloc(). | |
#define | ast_set2_flag(p, value, flag) |
#define | ast_set2_flag64(p, value, flag) |
#define | ast_set2_flag_nonstd(p, value, flag) |
#define | ast_set_flag(p, flag) |
#define | ast_set_flag64(p, flag) |
#define | ast_set_flag_nonstd(p, flag) |
#define | ast_set_flags_to(p, flag, value) |
#define | ast_set_flags_to64(p, flag, value) |
#define | AST_STACKSIZE (((sizeof(void *) * 8 * 8) - 16) * 1024) |
#define | ast_strdup(str) _ast_strdup((str), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for strdup(). | |
#define | ast_strdupa(s) |
duplicate a string in memory from the stack | |
#define | ast_strndup(str, len) _ast_strndup((str), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for strndup(). | |
#define | ast_test_flag(p, flag) |
#define | ast_test_flag64(p, flag) |
#define | ast_test_flag_nonstd(p, flag) ((p)->flags & (flag)) |
#define | ast_vasprintf(ret, fmt, ap) _ast_vasprintf((ret), __FILE__, __LINE__, __PRETTY_FUNCTION__, (fmt), (ap)) |
A wrapper for vasprintf(). | |
#define | localtime_r __dont_use_localtime_r_use_ast_localtime_instead__ |
#define | MALLOC_FAILURE_MSG ast_log(LOG_ERROR, "Memory Allocation Failure in function %s at line %d of %s\n", func, lineno, file); |
#define | MAX(a, b) ({ typeof(a) __a = (a); typeof(b) __b = (b); ((__a < __b) ? __b : __a);}) |
#define | MIN(a, b) ({ typeof(a) __a = (a); typeof(b) __b = (b); ((__a > __b) ? __b : __a);}) |
Functions | |
int | _ast_asprintf (char **ret, const char *file, int lineno, const char *func, const char *fmt,...) |
void * | _ast_calloc (size_t num, size_t len, const char *file, int lineno, const char *func) |
void * | _ast_malloc (size_t len, const char *file, int lineno, const char *func) |
void * | _ast_realloc (void *p, size_t len, const char *file, int lineno, const char *func) |
char * | _ast_strdup (const char *str, const char *file, int lineno, const char *func) |
char * | _ast_strndup (const char *str, size_t len, const char *file, int lineno, const char *func) |
int | _ast_vasprintf (char **ret, const char *file, int lineno, const char *func, const char *fmt, va_list ap) |
int | ast_base64decode (unsigned char *dst, const char *src, int max) |
Decode data from base64. | |
int | ast_base64encode (char *dst, const unsigned char *src, int srclen, int max) |
Encode data in base64. | |
int | ast_base64encode_full (char *dst, const unsigned char *src, int srclen, int max, int linebreaks) |
encode text to BASE64 coding | |
int | ast_careful_fwrite (FILE *f, int fd, const char *s, size_t len, int timeoutms) |
Write data to a file stream with a timeout. | |
int | ast_carefulwrite (int fd, char *s, int len, int timeoutms) |
Try to write string, but wait no more than ms milliseconds before timing out. | |
int | ast_eid_cmp (const struct ast_eid *eid1, const struct ast_eid *eid2) |
Compare two EIDs. | |
char * | ast_eid_to_str (char *s, int maxlen, struct ast_eid *eid) |
void | ast_enable_packet_fragmentation (int sock) |
Disable PMTU discovery on a socket. | |
char * | ast_escape_quoted (const char *string, char *outbuf, int buflen) |
Escape characters found in a quoted string. | |
hostent * | ast_gethostbyname (const char *host, struct ast_hostent *hp) |
Thread-safe gethostbyname function to use in Asterisk. | |
void | ast_md5_hash (char *output, const char *input) |
Produces MD5 hash based on input string. | |
int | ast_mkdir (const char *path, int mode) |
Recursively create directory path. | |
int | ast_parse_digest (const char *digest, struct ast_http_digest *d, int request, int pedantic) |
Parse digest authorization header. | |
char * | ast_process_quotes_and_slashes (char *start, char find, char replace_with) |
Process a string to find and replace characters. | |
int | ast_pthread_create_detached_stack (pthread_t *thread, pthread_attr_t *attr, void *(*start_routine)(void *), void *data, size_t stacksize, const char *file, const char *caller, int line, const char *start_fn) |
int | ast_pthread_create_stack (pthread_t *thread, pthread_attr_t *attr, void *(*start_routine)(void *), void *data, size_t stacksize, const char *file, const char *caller, int line, const char *start_fn) |
long int | ast_random (void) |
void | ast_register_thread (char *name) |
void | ast_set_default_eid (struct ast_eid *eid) |
Fill in an ast_eid with the default eid of this machine. | |
void | ast_sha1_hash (char *output, const char *input) |
Produces SHA1 hash based on input string. | |
static force_inline void | ast_slinear_saturated_add (short *input, short *value) |
static force_inline void | ast_slinear_saturated_divide (short *input, short *value) |
static force_inline void | ast_slinear_saturated_multiply (short *input, short *value) |
static force_inline void | ast_slinear_saturated_subtract (short *input, short *value) |
int | ast_str_to_eid (struct ast_eid *eid, const char *s) |
Convert a string into an EID. | |
void | ast_unregister_thread (void *id) |
void | ast_uri_decode (char *s) |
Decode URI, URN, URL (overwrite string). | |
char * | ast_uri_encode (const char *string, char *outbuf, int buflen, int do_special_char) |
Turn text string to URI-encoded XX version. | |
int | ast_utils_init (void) |
char * | ast_utils_which (const char *binary, char *fullpath, size_t fullpath_size) |
Resolve a binary to a full pathname. | |
int | ast_wait_for_input (int fd, int ms) |
Variables | |
unsigned int | __unsigned_int_flags_dummy |
uint64_t | __unsigned_int_flags_dummy64 |
ast_eid | ast_eid_default |
Global EID. |
Definition in file utils.h.
#define ast_align_for | ( | offset, | |||
type | ) | (((offset + __alignof__(type) - 1) / __alignof__(type)) * __alignof__(type)) |
Increase offset so it is a multiple of the required alignment of type.
offset | The value that should be increased. | |
type | The data type that offset should be aligned to. |
Examples: ast_align_for(0x17, int64_t) ==> 0x18 ast_align_for(0x18, int64_t) ==> 0x18 ast_align_for(0x19, int64_t) ==> 0x20
Don't mind the ugliness, the compiler will optimize it.
Definition at line 756 of file utils.h.
Referenced by __ast_string_field_ptr_build_va().
#define ast_alignof | ( | type | ) | __alignof__(type) |
Return the number of bytes used in the alignment of type.
type |
Definition at line 736 of file utils.h.
Referenced by __ast_string_field_alloc_space(), and __ast_string_field_ptr_build_va().
#define ast_asprintf | ( | ret, | |||
fmt | ) | _ast_asprintf((ret), __FILE__, __LINE__, __PRETTY_FUNCTION__, fmt, __VA_ARGS__) |
A wrapper for asprintf().
ast_asprintf() is a wrapper for asprintf() that will generate an Asterisk log message in the case that the allocation fails.
The arguments and return value are the same as asprintf()
#define ast_assert | ( | a | ) |
Definition at line 723 of file utils.h.
Referenced by __ast_string_field_alloc_space(), _ast_odbc_request_obj2(), append_ie(), ast_cc_is_recall(), ast_channel_change_linkedid(), ast_channel_get_cc_config_params(), ast_hangup(), ast_rtcp_read(), ast_rtp_read(), ast_sched_del(), ast_udptl_read(), cc_generic_agent_start_monitoring(), cc_generic_agent_start_offer_timer(), cc_generic_monitor_cancel_available_timer(), check_callback_sanity(), create_jb(), create_new_sip_etag(), dahdi_pri_cc_agent_init(), determine_sip_publish_type(), find_timer(), handle_response_publish(), jb_get_and_deliver(), odbc_obj_connect(), parkinglot_destroy(), pthread_timer_ack(), publish_expire(), queue_exec(), read_pipe(), security_event_cb(), sig_pri_call(), sip_cc_agent_init(), and sip_cc_monitor_unsuspend().
#define ast_calloc | ( | num, | |||
len | ) | _ast_calloc((num), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
#define ast_calloc_cache | ( | num, | |||
len | ) | _ast_calloc((num), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for calloc() for use in cache pools.
ast_calloc_cache() is a wrapper for calloc() that will generate an Asterisk log message in the case that the allocation fails. When memory debugging is in use, the memory allocated by this function will be marked as 'cache' so it can be distinguished from normal memory allocations.
The arguments and return value are the same as calloc()
#define ast_clear_flag | ( | p, | |||
flag | ) |
Definition at line 77 of file utils.h.
Referenced by __analog_ss_thread(), __ast_read(), __do_deliver(), __transmit_response(), aji_create_client(), aji_filter_roster(), analog_ss_thread(), ast_audiohook_set_mute(), ast_autoservice_stop(), ast_bridge_call(), ast_cdr_reset(), ast_cdr_specialized_reset(), ast_channel_bridge(), ast_channel_undefer_dtmf(), ast_deactivate_generator(), ast_generic_bridge(), ast_jb_destroy(), ast_jb_put(), ast_rtp_raw_write(), ast_sendtext(), ast_speech_start(), ast_tls_read_conf(), ast_waitfor_nandfds(), ast_waitfordigit_full(), ast_write(), bridge_channel_feature(), bridge_p2p_rtp_write(), builtin_atxfer(), change_hold_state(), change_spy_mode(), channel_spy(), chanspy_exec(), check_goto_on_transfer(), check_pendings(), common_exec(), config_function_read(), config_text_file_load(), dahdi_read(), dahdiscan_exec(), dial_exec_full(), dictate_exec(), disa_exec(), dundi_lookup_local(), extenspy_exec(), forward_message(), handle_common_options(), handle_exec(), handle_request_bye(), handle_request_invite(), handle_request_refer(), handle_response(), handle_response_notify(), handle_speechrecognize(), handle_t38_options(), handle_verbose(), init_acf_query(), initialize_udptl(), linear_alloc(), load_config(), load_moh_classes(), local_ast_moh_stop(), local_attended_transfer(), local_hangup(), main(), manage_parked_call(), manager_optimize_away(), odbc_load_module(), park_call_full(), parkandannounce_exec(), parse_options(), phone_read(), playtones_alloc(), process_sdp(), register_verify(), reload_config(), reset_transaction(), set_config(), set_config_flags(), setup_dahdi_int(), sip_call(), sip_dtmfmode(), sip_hangup(), socket_process(), speech_background(), update_call_counter(), update_connectedline(), and waitstream_core().
#define ast_clear_flag64 | ( | p, | |||
flag | ) |
Definition at line 134 of file utils.h.
Referenced by authenticate_verify(), build_peer(), build_user(), create_addr(), do_forward(), find_conf(), iax2_destroy_helper(), iax2_setoption(), set_config(), set_config_destroy(), and socket_process().
#define ast_clear_flag_nonstd | ( | p, | |||
flag | ) |
Value:
do { \ ((p)->flags &= ~(flag)); \ } while(0)
Definition at line 180 of file utils.h.
Referenced by build_transactions(), cache_lookup_internal(), dundi_lookup_local(), dundi_prop_precache(), and handle_command_response().
#define ast_copy_flags | ( | dest, | |||
src, | |||||
flagz | ) |
Definition at line 84 of file utils.h.
Referenced by add_features_datastore(), agent_read(), aji_create_client(), aji_filter_roster(), ast_call_forward(), ast_cdr_reset(), ast_cdr_specialized_reset(), ast_frdup(), ast_frisolate(), build_peer(), builtin_atxfer(), cache_lookup_internal(), channel_spy(), check_peer_ok(), create_addr_from_peer(), dundi_lookup_local(), feature_interpret(), framein(), minivm_greet_exec(), minivm_record_exec(), parked_call_exec(), populate_defaults(), register_verify(), set_peer_defaults(), sip_alloc(), sip_poke_peer(), transmit_response_using_temp(), and vm_exec().
#define ast_copy_flags64 | ( | dest, | |||
src, | |||||
flagz | ) |
Definition at line 141 of file utils.h.
Referenced by __find_callno(), build_peer(), build_user(), check_access(), create_addr(), dial_exec_full(), iax2_request(), and wait_for_answer().
#define ast_copy_flags_nonstd | ( | dest, | |||
src, | |||||
flagz | ) |
#define AST_FLAGS_ALL UINT_MAX |
Definition at line 196 of file utils.h.
Referenced by add_features_datastore(), aji_create_client(), ast_cdr_reset(), ast_cdr_specialized_reset(), builtin_atxfer(), cache_lookup_internal(), channel_spy(), chanspy_exec(), check_goto_on_transfer(), dahdiscan_exec(), disa_exec(), dundi_lookup_local(), extenspy_exec(), feature_interpret(), handle_queue_reload(), load_module(), load_moh_classes(), manager_queue_reload(), parked_call_exec(), parse_options(), populate_defaults(), reload(), reload_config(), and set_config_flags().
#define ast_free free |
#define ast_free_ptr ast_free |
Definition at line 439 of file utils.h.
Referenced by add_extensions(), ast_extension_state(), ast_extension_state_add_destroy(), ast_merge_contexts_and_delete(), handle_cli_dialplan_add_extension(), load_module(), manage_parked_call(), park_call_full(), parkinglot_activate(), pbx_load_users(), register_exten(), and register_peer_exten().
#define ast_make_room_for | ( | offset, | |||
type | ) | (((offset + (2 * __alignof__(type) - 1)) / __alignof__(type)) * __alignof__(type)) |
Increase offset by the required alignment of type and make sure it is a multiple of said alignment.
offset | The value that should be increased. | |
type | The data type that room should be reserved for. |
Examples: ast_make_room_for(0x17, int64_t) ==> 0x20 ast_make_room_for(0x18, int64_t) ==> 0x20 ast_make_room_for(0x19, int64_t) ==> 0x28
Don't mind the ugliness, the compiler will optimize it.
Definition at line 779 of file utils.h.
Referenced by __ast_string_field_alloc_space(), and __ast_string_field_ptr_build_va().
#define ast_malloc | ( | len | ) | _ast_malloc((len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
#define ast_pthread_create | ( | a, | |||
b, | |||||
c, | |||||
d | ) |
Value:
ast_pthread_create_stack(a, b, c, d, \ 0, __FILE__, __FUNCTION__, __LINE__, #c)
Definition at line 394 of file utils.h.
Referenced by accept_thread(), ast_bridge_impart(), ast_dial_run(), ast_features_init(), ast_taskprocessor_get(), bridge_call_thread_launch(), bridge_channel_join(), handle_callforward_button(), handle_enbloc_call_message(), handle_offhook_message(), handle_soft_key_event_message(), handle_stimulus_message(), handle_transfer_button(), HandleCallOutgoing(), init_logger(), load_module(), restart_monitor(), sla_load_config(), and start_poll_thread().
#define ast_pthread_create_background | ( | a, | |||
b, | |||||
c, | |||||
d | ) |
Value:
ast_pthread_create_stack(a, b, c, d, \ AST_BACKGROUND_STACKSIZE, \ __FILE__, __FUNCTION__, __LINE__, #c)
Definition at line 402 of file utils.h.
Referenced by add_notify(), aji_reload(), ast_autoservice_start(), ast_device_state_engine_init(), ast_enable_distributed_devstate(), ast_makesocket(), ast_safe_fork(), ast_sched_thread_create(), ast_tcptls_server_start(), astdb_init(), calendar_event_notify(), conf_run(), config_load(), do_reload(), find_idle_thread(), init_app_class(), init_timing_thread(), load_module(), local_ast_moh_start(), pri_dchannel(), restart_monitor(), restart_pktc_thread(), start_network_thread(), and start_stream().
#define ast_pthread_create_detached | ( | a, | |||
b, | |||||
c, | |||||
d | ) |
Value:
ast_pthread_create_detached_stack(a, b, c, d, \ 0, __FILE__, __FUNCTION__, __LINE__, #c)
Definition at line 398 of file utils.h.
Referenced by __analog_handle_event(), action_originate(), analog_handle_init_event(), analog_ss_thread_start(), ast_pbx_outgoing_app(), ast_pbx_outgoing_exten(), ast_pbx_start(), dahdi_handle_event(), dundi_answer_entity(), dundi_answer_query(), handle_hd_hf(), handle_init_event(), launch_service(), main(), mwi_thread(), and spawn_dp_lookup().
#define ast_pthread_create_detached_background | ( | a, | |||
b, | |||||
c, | |||||
d | ) |
Value:
ast_pthread_create_detached_stack(a, b, c, d, \ AST_BACKGROUND_STACKSIZE, \ __FILE__, __FUNCTION__, __LINE__, #c)
Definition at line 407 of file utils.h.
Referenced by ast_cdr_submit_batch(), ast_tcptls_server_root(), cc_generic_agent_recall(), conf_run(), iax_park(), launch_monitor_thread(), listener(), load_module(), sip_park(), sip_pickup(), sip_prepare_socket(), sla_handle_dial_state_event(), and sla_station_exec().
#define ast_realloc | ( | p, | |||
len | ) | _ast_realloc((p), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
#define ast_set2_flag | ( | p, | |||
value, | |||||
flag | ) |
Definition at line 94 of file utils.h.
Referenced by _macro_exec(), actual_load_config(), aji_create_client(), aji_load_config(), apply_general_options(), apply_option(), apply_outgoing(), ast_bridge_call(), ast_jb_read_conf(), ast_plc_reload(), ast_tls_read_conf(), ast_translate(), build_peer(), dial_exec_full(), do_reload(), find_account(), find_user(), handle_common_options(), handle_t38_options(), load_config(), load_module(), load_moh_classes(), local_ast_moh_start(), and sip_setoption().
#define ast_set2_flag64 | ( | p, | |||
value, | |||||
flag | ) |
Definition at line 151 of file utils.h.
Referenced by build_peer(), build_user(), check_access(), dial_exec_full(), and set_config().
#define ast_set_flag | ( | p, | |||
flag | ) |
Definition at line 70 of file utils.h.
Referenced by __analog_ss_thread(), __ast_pbx_run(), __ast_read(), __ast_request_and_dial(), __sip_subscribe_mwi_do(), _macro_exec(), action_redirect(), aji_create_client(), aji_load_config(), analog_ss_thread(), app_exec(), apply_peer(), ast_audiohook_set_mute(), ast_autoservice_start(), ast_bridge_call(), ast_bridge_features_set_flag(), ast_bridge_new(), ast_bridge_timelimit(), ast_call(), ast_cdr_detach(), ast_cdr_fork(), ast_cdr_merge(), ast_cdr_reset(), ast_cdr_specialized_reset(), ast_channel_bridge(), ast_channel_defer_dtmf(), ast_do_masquerade(), ast_do_pickup(), ast_generic_bridge(), ast_hangup(), ast_jb_do_usecheck(), ast_jb_put(), ast_rtp_change_source(), ast_rtp_local_bridge(), ast_rtp_raw_write(), ast_rtp_read(), ast_rtp_stop(), ast_rtp_update_source(), ast_speech_change_state(), AST_TEST_DEFINE(), ast_tls_read_conf(), ast_waitfor_nandfds(), ast_waitfordigit_full(), asyncgoto_exec(), bridge_channel_feature(), bridge_exec(), bridge_p2p_rtp_write(), build_peer(), builtin_atxfer(), builtin_blindtransfer(), cb_extensionstate(), cc_generic_agent_init(), change_hold_state(), change_spy_mode(), channel_spy(), chanspy_exec(), check_bridge(), check_peer_ok(), check_user_full(), check_via(), common_exec(), create_addr_from_peer(), create_transaction(), dahdiscan_exec(), dial_exec_full(), dictate_exec(), directory_exec(), disa_exec(), do_register(), dundi_encrypt(), dundi_lookup_local(), dundi_send(), extenspy_exec(), find_peer(), find_user_realtime(), free_vm_users(), handle_common_options(), handle_exec(), handle_invite_replaces(), handle_queue_reload(), handle_request_invite(), handle_request_refer(), handle_request_subscribe(), handle_response(), handle_response_invite(), handle_t38_options(), handle_verbose(), hangupcalls(), hanguptree(), init_acf_query(), init_app_class(), init_files_class(), init_outgoing(), interpret_t38_parameters(), launch_monitor_thread(), linear_alloc(), load_config(), load_moh_classes(), local_alloc(), local_ast_moh_start(), local_attended_transfer(), local_call(), local_hangup(), login_exec(), main(), manage_parked_call(), manager_queue_reload(), manager_sipnotify(), minivm_greet_exec(), nocdr_exec(), odbc_load_module(), park_call_full(), parked_call_exec(), parse_options(), playtones_alloc(), post_cdr(), process_applicationmap_line(), process_cn_rfc3389(), process_crypto(), process_sdp(), qualify_peer(), record_exec(), register_verify(), reload_config(), ring_entry(), set_bridge_features_on_config(), set_config_flags(), set_insecure_flags(), sip_answer(), sip_call(), sip_cc_agent_init(), sip_cc_agent_respond(), sip_cc_monitor_request_cc(), sip_cli_notify(), sip_dtmfmode(), sip_hangup(), sip_indicate(), sip_poke_peer(), sip_reinvite_retry(), sip_send_mwi_to_peer(), sip_sendhtml(), sip_set_rtp_peer(), sip_set_udptl_peer(), sip_write(), socket_process(), start_spying(), tonepair_alloc(), transmit_publish(), transmit_register(), transmit_reinvite_with_sdp(), try_calling(), update_call_counter(), update_connectedline(), vm_execmain(), volume_write(), and waitstream_core().
#define ast_set_flag64 | ( | p, | |||
flag | ) |
Definition at line 127 of file utils.h.
Referenced by authenticate_reply(), authenticate_request(), build_peer(), build_user(), check_access(), conf_run(), decrypt_frame(), dial_exec_full(), do_forward(), handle_cli_iax2_prune_realtime(), iax2_predestroy(), iax2_provision(), iax2_setoption(), iax2_start_transfer(), parse_options(), peer_delme_cb(), pvt_destructor(), run_station(), set_config(), sla_station_exec(), sla_trunk_exec(), socket_process(), and user_delme_cb().
#define ast_set_flag_nonstd | ( | p, | |||
flag | ) |
Value:
do { \ ((p)->flags |= (flag)); \ } while(0)
Definition at line 176 of file utils.h.
Referenced by dundi_lookup_internal(), dundi_query_eid_internal(), and handle_command_response().
#define ast_set_flags_to64 | ( | p, | |||
flag, | |||||
value | ) |
#define AST_STACKSIZE (((sizeof(void *) * 8 * 8) - 16) * 1024) |
A wrapper for strdup().
ast_strdup() is a wrapper for strdup() that will generate an Asterisk log message in the case that the allocation fails.
ast_strdup(), unlike strdup(), can safely accept a NULL argument. If a NULL argument is provided, ast_strdup will return NULL without generating any kind of error log message.
The argument and return value are the same as strdup()
#define ast_strdupa | ( | s | ) |
duplicate a string in memory from the stack
s | The string to duplicate |
Definition at line 634 of file utils.h.
Referenced by __ast_channel_alloc_ap(), __ast_play_and_record(), __dahdi_exception(), _ast_device_state(), _build_port_config(), _macro_exec(), _parse(), _sip_show_peers(), _while_exec(), acf_jabberreceive_read(), acf_meetme_info(), acf_odbc_write(), action_agents(), action_status(), actual_load_config(), add_agent(), add_peer_mailboxes(), add_realm_authentication(), add_redirect(), add_var(), admin_exec(), advanced_options(), aelsub_exec(), agent_hangup(), agi_exec_full(), agi_handle_command(), aji_join_exec(), aji_leave_exec(), aji_send_exec(), aji_sendgroup_exec(), aji_status_exec(), analog_exception(), answer_exec_enable(), app_exec(), append_mailbox(), append_mailbox_mapping(), append_var_and_value_to_filter(), apply_directmedia_ha(), apply_options(), aqm_exec(), array(), ast_aji_get_client(), ast_app_getdata(), ast_append_ha(), ast_async_goto(), ast_bridge_call(), ast_bridge_timelimit(), ast_build_timing(), ast_callerid_split(), ast_cdr_fork(), ast_cdr_setaccount(), ast_cdr_setpeeraccount(), ast_cel_report_event(), ast_channel_connected_line_macro(), ast_channel_redirecting_macro(), ast_channel_set_linkgroup(), ast_data_iterator_init(), ast_do_pickup(), ast_eivr_senddtmf(), ast_eivr_setvariable(), ast_el_add_history(), ast_event_append_ie_str(), ast_event_sub_append_ie_str(), ast_filehelper(), ast_format_str_reduce(), ast_func_read(), ast_func_read2(), ast_func_write(), ast_get_group(), ast_http_get_cookies(), ast_masq_park_call(), ast_masq_park_call_exten(), ast_mkdir(), ast_monitor_change_fname(), ast_monitor_start(), ast_netsock_bind(), ast_ouraddrfor(), ast_park_call_exten(), ast_parse_allow_disallow(), ast_parse_arg(), ast_playtones_start(), ast_register_file_version(), ast_rtp_read(), ast_sockaddr_parse(), ast_sockaddr_resolve(), ast_str_retrieve_variable(), ast_utils_which(), ast_writefile(), asyncgoto_exec(), auth_exec(), authenticate_reply(), authenticate_verify(), background_detect_exec(), bridge_exec(), bridge_play_sounds(), build_channels(), build_mapping(), build_peer(), build_profile(), build_route(), build_user(), builtin_atxfer(), builtin_automixmonitor(), builtin_automonitor(), cache_get_callno_locked(), callerid_read(), callerid_write(), celgenuserevent_exec(), chanavail_exec(), channel_admin_exec(), channel_spy(), chanspy_exec(), check_access(), check_blacklist(), check_day(), check_dow(), check_goto_on_transfer(), check_month(), check_peer_ok(), check_switch_expr(), check_timerange(), check_user_full(), complete_meetmecmd(), conf_exec(), conf_run(), conf_start_moh(), confbridge_exec(), config_function_read(), config_line(), config_module(), connectedline_read(), connectedline_write(), controlplayback_exec(), count_exec(), create_addr(), create_addr_from_peer(), create_dynamic_parkinglot(), create_followme_number(), create_queue_member(), create_vmaccount(), cut_internal(), dahdi_send_callrerouting_facility_exec(), dahdiras_exec(), dahdiscan_exec(), data_filter_add_nodes(), data_filter_alloc(), data_filter_generate(), data_provider_create(), data_provider_release(), data_result_generate(), data_result_get_node(), data_search_create(), data_search_generate(), data_search_get_node(), decrypt_frame(), del_exec(), deltree_exec(), determine_starting_point(), dial_exec_full(), dial_trunk(), dialgroup_refreshdb(), dialgroup_write(), dictate_exec(), directory_exec(), disa_exec(), dnsmgr_refresh(), do_bridge_masquerade(), do_immediate_setup(), do_notify(), do_say(), dundi_query_read(), dundi_result_read(), dundifunc_read(), enum_query_read(), enum_result_read(), ewscal_write_event(), exec_exec(), execif_exec(), extenspy_exec(), feature_check(), feature_interpret(), festival_exec(), fileexists_core(), find_conf_realtime(), find_generic_monitor_instance_list(), find_gtalk(), find_sdp(), find_table(), find_table_cb(), function_agent(), function_iaxpeer(), function_realtime_store(), generic_recall(), get_cid_name(), get_destination(), get_refer_info(), gosub_exec(), gosubif_exec(), gtalk_action(), gtalk_alloc(), gtalk_create_candidates(), gtalk_invite(), gtalk_request(), gtalk_update_externip(), handle_call_forward(), handle_cli_check_permissions(), handle_cli_dialplan_add_extension(), handle_cli_file_convert(), handle_common_options(), handle_debug_dialplan(), handle_mfcr2_set_debug(), handle_mgcp_audit_endpoint(), handle_options(), handle_request_invite(), handle_request_notify(), handle_request_refer(), handle_response(), handle_show_dialplan(), handle_t38_options(), handle_verbose(), has_voicemail(), iax2_call(), iax2_devicestate(), iax2_prov_app(), iax2_request(), iconv_read(), init_acf_query(), init_jack_data(), insert_penaltychange(), is_prefix(), is_valid_dtmf(), isAnsweringMachine(), isexten_function_read(), ivr_dispatch(), jingle_request(), launch_ha_netscript(), launch_monitor_thread(), launch_netscript(), leave_voicemail(), load_channelvars(), load_config(), load_dynamic_module(), local_call(), local_devicestate(), log_exec(), logger_print_normal(), login_exec(), lua_get_variable_value(), lua_pbx_exec(), lua_set_variable_value(), macroif_exec(), main(), make_components(), make_email_file(), man_do_variable_value(), manage_parked_call(), match_ie_val(), match_sub_ie_val_to_event(), meetmemute(), metermaidstate(), mgcp_devicestate(), minivm_accmess_exec(), minivm_account_func_read(), minivm_counter_func_read(), minivm_counter_func_write(), minivm_greet_exec(), minivm_mwi_exec(), minivm_notify_exec(), minivm_record_exec(), misdn_call(), misdn_check_l2l1(), misdn_facility_exec(), misdn_request(), misdn_set_opt_exec(), mixmonitor_exec(), moh_handle_digit(), monitor_dial(), multicast_rtp_request(), my_pri_make_cc_dialstring(), notify_message(), notify_new_message(), odbc_log(), on_dns_update_mwi(), on_dns_update_peer(), on_dns_update_registry(), orig_app(), orig_exten(), originate_exec(), ospauth_exec(), ospfinished_exec(), osplookup_exec(), ospnext_exec(), oss_call(), oss_request(), page_exec(), park_call_exec(), park_space_reserve(), parkandannounce_exec(), parked_call_exec(), parse_allowed_methods(), parse_apps(), parse_empty_options(), parse_events(), parse_register_contact(), parse_session_expires(), parse_sip_options(), parse_uri_full(), party_id_write(), party_name_write(), party_number_write(), pbx_builtin_answer(), pbx_builtin_background(), pbx_builtin_execiftime(), pbx_builtin_gotoif(), pbx_builtin_gotoiftime(), pbx_builtin_importvar(), pbx_builtin_pushvar_helper(), pbx_builtin_resetcdr(), pbx_builtin_setvar(), pbx_builtin_setvar_helper(), pbx_builtin_setvar_multiple(), pbx_builtin_waitexten(), pbx_find_extension(), pbx_parseable_goto(), peer_set_srcaddr(), pickup_exec(), pickupchan_exec(), play_message(), play_moh_exec(), playback_exec(), pqm_exec(), prep_email_sub_vars(), privacy_exec(), process_applicationmap_line(), process_echocancel(), process_sdp(), process_sdp_o(), proxy_from_config(), ql_exec(), queue_exec(), queue_mwi_event(), queue_set_param(), rcvfax_exec(), read_exec(), readexten_exec(), readfile_exec(), realtime_common(), realtime_exec(), realtime_multi_curl(), realtime_multi_ldap(), realtime_multi_odbc(), realtime_multi_pgsql(), receivefax_exec(), record_exec(), redirecting_read(), redirecting_write(), register_verify(), registry_authrequest(), reload_single_member(), resource_name_match(), retrydial_exec(), rqm_exec(), rtcp_do_debug_ip(), rtp_do_debug_ip(), saycountedadj_exec(), saycountednoun_exec(), sayunixtime_exec(), sdp_crypto_process(), senddtmf_exec(), sendfax_exec(), sendmail(), sendurl_exec(), set_config_flags(), set_hangup_source_and_cause(), setup_privacy_args(), setup_stunaddr(), sig_pri_extract_called_num_subaddr(), sig_pri_msn_match(), sip_acf_channel_read(), sip_devicestate(), sip_get_cc_information(), sip_new(), sip_queue_hangup_cause(), sip_send_mwi_to_peer(), sip_show_settings(), sip_sipredirect(), sip_uri_cmp(), sip_uri_headers_cmp(), sip_uri_params_cmp(), skel_exec(), skinny_devicestate(), sla_add_trunk_to_station(), sla_check_device(), sla_queue_event_conf(), sla_ring_station(), sla_state(), sla_station_exec(), sla_trunk_exec(), smdi_msg_read(), smdi_msg_retrieve_read(), sms_exec(), sndfax_exec(), socket_process(), softhangup_exec(), sort_internal(), speech_background(), speech_load(), srv_result_read(), stackpeek_read(), start_moh_exec(), start_monitor_action(), start_monitor_exec(), state_notify_build_xml(), stun_monitor_request(), timezone_add(), transfer_exec(), transmit_invite(), tryexec_exec(), unistim_send_mwi_to_peer(), update_bridge_vars(), update_common_options(), update_registry(), upqm_exec(), userevent_exec(), verbose_exec(), vm_box_exists(), vm_check_password_shell(), vm_exec(), vm_execmain(), vmauthenticate(), vmsayname_exec(), wait_for_answer(), wait_for_winner(), waitstream_core(), xfer_park_call_helper(), xmldoc_get_syntax_fun(), and zapateller_exec().
#define ast_strndup | ( | str, | |||
len | ) | _ast_strndup((str), (len), __FILE__, __LINE__, __PRETTY_FUNCTION__) |
A wrapper for strndup().
ast_strndup() is a wrapper for strndup() that will generate an Asterisk log message in the case that the allocation fails.
ast_strndup(), unlike strndup(), can safely accept a NULL argument for the string to duplicate. If a NULL argument is provided, ast_strdup will return NULL without generating any kind of error log message.
The arguments and return value are the same as strndup()
#define ast_test_flag | ( | p, | |||
flag | ) |
Definition at line 63 of file utils.h.
Referenced by __ast_channel_masquerade(), __ast_pbx_run(), __ast_queue_frame(), __ast_read(), __sip_destroy(), __ssl_setup(), __transmit_response(), _ast_odbc_request_obj2(), _macro_exec(), _sip_show_peer(), _sip_show_peers(), acf_odbc_read(), action_login(), add_agent(), add_codec_to_sdp(), add_rpid(), add_sdp(), aji_build_publish_skeleton(), aji_cli_purge_pubsub_nodes(), aji_create_client(), aji_handle_pubsub_error(), aji_handle_subscribe(), aji_pruneregister(), aji_publish_device_state(), aji_pubsub_subscribe(), app_exec(), ast_audiohook_write_frame(), ast_autoservice_start(), ast_bridge_call(), ast_bridge_merge(), ast_call(), ast_can_pickup(), ast_cdr_answer(), ast_cdr_appenduserfield(), ast_cdr_busy(), ast_cdr_end(), ast_cdr_failed(), ast_cdr_fork(), ast_cdr_init(), ast_cdr_merge(), ast_cdr_noanswer(), ast_cdr_reset(), ast_cdr_setaccount(), ast_cdr_setamaflags(), ast_cdr_setanswer(), ast_cdr_setapp(), ast_cdr_setcid(), ast_cdr_setdestchan(), ast_cdr_setdisposition(), ast_cdr_setpeeraccount(), ast_cdr_setuserfield(), ast_cdr_setvar(), ast_cdr_specialized_reset(), ast_cdr_start(), ast_cdr_update(), ast_channel_bridge(), ast_channel_defer_dtmf(), ast_config_internal_load(), ast_do_masquerade(), ast_explicit_goto(), ast_frisolate(), ast_generic_bridge(), ast_hangup(), ast_indicate_data(), ast_jb_destroy(), ast_jb_do_usecheck(), ast_jb_empty_and_reset(), ast_jb_get_and_deliver(), ast_jb_get_when_to_wakeup(), ast_jb_put(), ast_moh_files_next(), ast_pbx_run_args(), ast_pbx_start(), ast_quiet_chan(), ast_raw_answer(), ast_readstring_full(), ast_rtp_raw_write(), ast_sendtext(), ast_softhangup_nolock(), ast_streamfile(), AST_TEST_DEFINE(), ast_transfer(), ast_translate(), ast_waitfordigit_full(), ast_write(), auth_exec(), authenticate_verify(), bridge_channel_join(), bridge_check_dissolve(), bridge_exec(), bridge_p2p_rtp_write(), build_peer(), build_radius_record(), build_via(), builtin_atxfer(), call_forward_inherit(), callback_dialoptions(), cb_extensionstate(), cdr_read(), cdr_write(), change_hold_state(), channel_data_add_flags(), channel_spy(), chanspy_exec(), check_bridge(), check_peer_ok(), check_pendings(), check_post(), check_rtp_timeout(), check_user_full(), close_mailbox(), common_exec(), complete_sip_peer(), complete_sip_registered_peer(), confbridge_exec(), config_text_file_load(), connectedline_write(), controlplayback_exec(), copy_via_headers(), create_addr_from_peer(), create_jb(), destroy_trans(), dial_exec_full(), dialog_initialize_rtp(), dictate_exec(), directory_exec(), disa_exec(), display_nat_warning(), do_directory(), do_setnat(), dtmf_audiohook_write_list(), dundi_encrypt(), dundi_exec(), dundi_helper(), dundi_lookup_local(), dundi_lookup_thread(), dundi_precache_thread(), dundi_query_read(), dundi_query_thread(), dundi_rexmit(), dundi_send(), dundifunc_read(), eivr_comm(), enable_dsp_detect(), execute_cb(), expire_register(), extenspy_exec(), feature_exec_app(), feature_interpret_helper(), find_cache(), find_or_create(), find_user(), find_user_realtime(), forward_message(), free_user(), function_sippeer(), get_destination(), get_insecure_variable_from_config(), get_insecure_variable_from_sipregs(), get_rpid(), gosub_exec(), handle_cli_moh_show_classes(), handle_cli_wait_fullybooted(), handle_command_response(), handle_exec(), handle_frame(), handle_minivm_show_settings(), handle_options(), handle_request_bye(), handle_request_cancel(), handle_request_info(), handle_request_invite(), handle_request_refer(), handle_request_subscribe(), handle_response(), handle_response_invite(), handle_response_notify(), handle_show_settings(), handle_showchan(), handle_skinny_show_settings(), handle_speechrecognize(), handle_tcptls_connection(), hint_read(), iax2_write(), initialize_udptl(), initreqprep(), interpret_t38_parameters(), is_state_change_valid(), join_conference_bridge(), leave_conference_bridge(), leave_voicemail(), load_dynamic_module(), load_resource(), local_alloc(), local_ast_moh_start(), local_bridgedchannel(), local_call(), local_hangup(), local_indicate(), local_write(), main(), make_email_file(), manager_list_voicemail_users(), masq_park_call(), match_req_to_dialog(), menu_callback(), minivm_accmess_exec(), minivm_account_func_read(), minivm_greet_exec(), minivm_notify_exec(), minivm_record_exec(), mixmonitor_exec(), mixmonitor_thread(), mod_load_cmp(), moh_files_alloc(), notify_new_message(), odbc_load_module(), park_call_exec(), park_call_full(), park_space_reserve(), parse_moved_contact(), parse_register_contact(), pbx_builtin_background(), pbx_builtin_waitexten(), peer_ipcmp_cb(), pick_unlocked_cdr(), play_mailbox_owner(), play_message(), play_record_review(), post_cdr(), post_join_marked(), post_join_unmarked(), precache_transactions(), process_cn_rfc3389(), process_crypto(), process_sdp(), process_sdp_a_audio(), process_sdp_o(), process_text_line(), read_exec(), readexten_exec(), realtime_switch_common(), receivefax_exec(), record_exec(), redirecting_write(), reload_config(), reload_handler(), reload_queues(), reload_single_queue(), remove_from_queue(), reqprep(), respprep(), retrans_pkt(), retrydial_exec(), search_directory_sub(), select_entry(), select_item_pause(), send_request(), sendfax_exec(), sendmail(), sendurl_exec(), serialize_showchan(), set_address_from_contact(), set_config_flags(), set_pvt_allowed_methods(), set_t38_capabilities(), should_skip_dtmf(), show_channels_cb(), sig_pri_call(), sip_alloc(), sip_call(), sip_cc_agent_destructor(), sip_destroy_peer(), sip_dtmfmode(), sip_fixup(), sip_get_rtp_peer(), sip_get_trtp_peer(), sip_get_udptl_peer(), sip_get_vrtp_peer(), sip_hangup(), sip_indicate(), sip_nat_mode(), sip_new(), sip_prune_realtime(), sip_queryoption(), sip_read(), sip_real_dst(), sip_rtp_read(), sip_send_mwi_to_peer(), sip_senddigit_begin(), sip_senddigit_end(), sip_sendhtml(), sip_set_rtp_peer(), sip_set_udptl_peer(), sip_setoption(), sip_show_channel(), sip_show_settings(), sip_show_users(), sip_write(), sla_trunk_exec(), smdi_msg_find(), sms_exec(), socket_process(), socket_process_meta(), softhangup_exec(), spawn_mp3(), speech_background(), speech_read(), spy_generate(), start_spying(), startmon(), transmit_info_with_digit(), transmit_invite(), transmit_notify_with_mwi(), transmit_refer(), transmit_reinvite_with_sdp(), transmit_request_with_auth(), transmit_response_with_sdp(), try_calling(), update_call_counter(), update_connectedline(), update_peer(), update_redirecting(), update_registry(), vm_exec(), vm_execmain(), vm_instructions_en(), vm_intro(), vm_newuser(), volume_callback(), wait_for_winner(), waitstream_core(), and xfer_park_call_helper().
#define ast_test_flag64 | ( | p, | |||
flag | ) |
Definition at line 120 of file utils.h.
Referenced by __do_deliver(), __expire_registry(), __get_from_jb(), __iax2_show_peers(), action_meetmelist(), admin_exec(), ast_app_options2str64(), ast_cli_netstats(), authenticate_reply(), authenticate_request(), authenticate_verify(), build_peer(), build_user(), can_write(), check_access(), complete_iax2_peers(), conf_exec(), conf_run(), decrypt_frame(), dial_exec_full(), do_forward(), find_conf(), function_iaxpeer(), handle_cli_iax2_prune_realtime(), handle_cli_iax2_show_channels(), handle_cli_iax2_show_peer(), handle_cli_iax2_show_users(), iax2_call(), iax2_destroy_helper(), iax2_getpeertrunk(), iax2_hangup(), iax2_indicate(), iax2_predestroy(), iax2_queryoption(), iax2_request(), iax2_send(), iax2_trunk_queue(), iax2_write(), log_jitterstats(), manager_iax2_show_peer_list(), peers_data_provider_get(), prune_peers(), prune_users(), realtime_update_peer(), reg_source_db(), register_verify(), retrydial_exec(), schedule_delivery(), send_trunk(), set_config(), setup_privacy_args(), socket_process(), update_registry(), user_set_kickme_cb(), user_set_muted_cb(), user_set_unmuted_cb(), users_data_provider_get(), valid_priv_reply(), and wait_for_answer().
#define ast_test_flag_nonstd | ( | p, | |||
flag | ) | ((p)->flags & (flag)) |
Definition at line 173 of file utils.h.
Referenced by cache_save_hint(), dundi_lookup_thread(), dundi_precache_thread(), and handle_command_response().
#define ast_vasprintf | ( | ret, | |||
fmt, | |||||
ap | ) | _ast_vasprintf((ret), __FILE__, __LINE__, __PRETTY_FUNCTION__, (fmt), (ap)) |
A wrapper for vasprintf().
ast_vasprintf() is a wrapper for vasprintf() that will generate an Asterisk log message in the case that the allocation fails.
The arguments and return value are the same as vasprintf()
#define localtime_r __dont_use_localtime_r_use_ast_localtime_instead__ |
#define MALLOC_FAILURE_MSG ast_log(LOG_ERROR, "Memory Allocation Failure in function %s at line %d of %s\n", func, lineno, file); |
#define MAX | ( | a, | |||
b | ) | ({ typeof(a) __a = (a); typeof(b) __b = (b); ((__a < __b) ? __b : __a);}) |
Definition at line 228 of file utils.h.
Referenced by __ast_answer(), ast_dsp_busydetect(), handle_mousedown(), handle_request_subscribe(), handle_response_register(), and sdl_setup().
#define MIN | ( | a, | |||
b | ) | ({ typeof(a) __a = (a); typeof(b) __b = (b); ((__a > __b) ? __b : __a);}) |
Definition at line 226 of file utils.h.
Referenced by autoanswer_complete(), calculate_local_max_datagram(), h263p_encap(), h264_encap(), interpret_t38_parameters(), mpeg4_encap(), and process_db_keys().
int _ast_asprintf | ( | char ** | ret, | |
const char * | file, | |||
int | lineno, | |||
const char * | func, | |||
const char * | fmt, | |||
... | ||||
) |
Definition at line 2104 of file utils.c.
References MALLOC_FAILURE_MSG, and vasprintf.
02105 { 02106 int res; 02107 va_list ap; 02108 02109 va_start(ap, fmt); 02110 if ((res = vasprintf(ret, fmt, ap)) == -1) { 02111 MALLOC_FAILURE_MSG; 02112 } 02113 va_end(ap); 02114 02115 return res; 02116 }
void * _ast_calloc | ( | size_t | num, | |
size_t | len, | |||
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
void * _ast_malloc | ( | size_t | len, | |
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
void * _ast_realloc | ( | void * | p, | |
size_t | len, | |||
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
char * _ast_strdup | ( | const char * | str, | |
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
char * _ast_strndup | ( | const char * | str, | |
size_t | len, | |||
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
int _ast_vasprintf | ( | char ** | ret, | |
const char * | file, | |||
int | lineno, | |||
const char * | func, | |||
const char * | fmt, | |||
va_list | ap | |||
) | [inline] |
int ast_base64decode | ( | unsigned char * | dst, | |
const char * | src, | |||
int | max | |||
) |
Decode data from base64.
dst | the destination buffer | |
src | the source buffer | |
max | The maximum number of bytes to write into the destination buffer. Note that this function will not ensure that the destination buffer is NULL terminated. So, in general, this parameter should be sizeof(dst) - 1. |
Definition at line 271 of file utils.c.
Referenced by aes_helper(), ast_check_signature(), base64_helper(), osp_validate_token(), sdp_crypto_process(), and sdp_crypto_setup().
00272 { 00273 int cnt = 0; 00274 unsigned int byte = 0; 00275 unsigned int bits = 0; 00276 int incnt = 0; 00277 while(*src && *src != '=' && (cnt < max)) { 00278 /* Shift in 6 bits of input */ 00279 byte <<= 6; 00280 byte |= (b2a[(int)(*src)]) & 0x3f; 00281 bits += 6; 00282 src++; 00283 incnt++; 00284 /* If we have at least 8 bits left over, take that character 00285 off the top */ 00286 if (bits >= 8) { 00287 bits -= 8; 00288 *dst = (byte >> bits) & 0xff; 00289 dst++; 00290 cnt++; 00291 } 00292 } 00293 /* Don't worry about left over bits, they're extra anyway */ 00294 return cnt; 00295 }
int ast_base64encode | ( | char * | dst, | |
const unsigned char * | src, | |||
int | srclen, | |||
int | max | |||
) |
Encode data in base64.
dst | the destination buffer | |
src | the source data to be encoded | |
srclen | the number of bytes present in the source buffer | |
max | the maximum number of bytes to write into the destination buffer, *including* the terminating NULL character. |
Definition at line 349 of file utils.c.
References ast_base64encode_full().
Referenced by aes_helper(), aji_start_sasl(), ast_sign(), base64_helper(), build_secret(), osp_check_destination(), and sdp_crypto_setup().
00350 { 00351 return ast_base64encode_full(dst, src, srclen, max, 0); 00352 }
int ast_base64encode_full | ( | char * | dst, | |
const unsigned char * | src, | |||
int | srclen, | |||
int | max, | |||
int | linebreaks | |||
) |
encode text to BASE64 coding
Definition at line 298 of file utils.c.
Referenced by ast_base64encode().
00299 { 00300 int cnt = 0; 00301 int col = 0; 00302 unsigned int byte = 0; 00303 int bits = 0; 00304 int cntin = 0; 00305 /* Reserve space for null byte at end of string */ 00306 max--; 00307 while ((cntin < srclen) && (cnt < max)) { 00308 byte <<= 8; 00309 byte |= *(src++); 00310 bits += 8; 00311 cntin++; 00312 if ((bits == 24) && (cnt + 4 <= max)) { 00313 *dst++ = base64[(byte >> 18) & 0x3f]; 00314 *dst++ = base64[(byte >> 12) & 0x3f]; 00315 *dst++ = base64[(byte >> 6) & 0x3f]; 00316 *dst++ = base64[byte & 0x3f]; 00317 cnt += 4; 00318 col += 4; 00319 bits = 0; 00320 byte = 0; 00321 } 00322 if (linebreaks && (cnt < max) && (col == 64)) { 00323 *dst++ = '\n'; 00324 cnt++; 00325 col = 0; 00326 } 00327 } 00328 if (bits && (cnt + 4 <= max)) { 00329 /* Add one last character for the remaining bits, 00330 padding the rest with 0 */ 00331 byte <<= 24 - bits; 00332 *dst++ = base64[(byte >> 18) & 0x3f]; 00333 *dst++ = base64[(byte >> 12) & 0x3f]; 00334 if (bits == 16) 00335 *dst++ = base64[(byte >> 6) & 0x3f]; 00336 else 00337 *dst++ = '='; 00338 *dst++ = '='; 00339 cnt += 4; 00340 } 00341 if (linebreaks && (cnt < max)) { 00342 *dst++ = '\n'; 00343 cnt++; 00344 } 00345 *dst = '\0'; 00346 return cnt; 00347 }
int ast_careful_fwrite | ( | FILE * | f, | |
int | fd, | |||
const char * | s, | |||
size_t | len, | |||
int | timeoutms | |||
) |
Write data to a file stream with a timeout.
f | the file stream to write to | |
fd | the file description to poll on to know when the file stream can be written to without blocking. | |
s | the buffer to write from | |
len | the number of bytes to write | |
timeoutms | The maximum amount of time to block in this function trying to write, specified in milliseconds. |
0 | success | |
-1 | error |
Definition at line 1194 of file utils.c.
References ast_log(), ast_tvdiff_ms(), ast_tvnow(), ast_wait_for_output(), errno, and LOG_ERROR.
Referenced by send_string().
01195 { 01196 struct timeval start = ast_tvnow(); 01197 int n = 0; 01198 int elapsed = 0; 01199 01200 while (len) { 01201 if (ast_wait_for_output(fd, timeoutms - elapsed)) { 01202 /* poll returned a fatal error, so bail out immediately. */ 01203 return -1; 01204 } 01205 01206 /* Clear any errors from a previous write */ 01207 clearerr(f); 01208 01209 n = fwrite(src, 1, len, f); 01210 01211 if (ferror(f) && errno != EINTR && errno != EAGAIN) { 01212 /* fatal error from fwrite() */ 01213 if (!feof(f)) { 01214 /* Don't spam the logs if it was just that the connection is closed. */ 01215 ast_log(LOG_ERROR, "fwrite() returned error: %s\n", strerror(errno)); 01216 } 01217 n = -1; 01218 break; 01219 } 01220 01221 /* Update for data already written to the socket */ 01222 len -= n; 01223 src += n; 01224 01225 elapsed = ast_tvdiff_ms(ast_tvnow(), start); 01226 if (elapsed >= timeoutms) { 01227 /* We've taken too long to write 01228 * This is only an error condition if we haven't finished writing. */ 01229 n = len ? -1 : 0; 01230 break; 01231 } 01232 } 01233 01234 while (fflush(f)) { 01235 if (errno == EAGAIN || errno == EINTR) { 01236 continue; 01237 } 01238 if (!feof(f)) { 01239 /* Don't spam the logs if it was just that the connection is closed. */ 01240 ast_log(LOG_ERROR, "fflush() returned error: %s\n", strerror(errno)); 01241 } 01242 n = -1; 01243 break; 01244 } 01245 01246 return n < 0 ? -1 : 0; 01247 }
int ast_carefulwrite | ( | int | fd, | |
char * | s, | |||
int | len, | |||
int | timeoutms | |||
) |
Try to write string, but wait no more than ms milliseconds before timing out.
Try to write string, but wait no more than ms milliseconds before timing out.
Definition at line 1153 of file utils.c.
References ast_log(), ast_tvdiff_ms(), ast_tvnow(), ast_wait_for_output(), errno, and LOG_ERROR.
Referenced by ast_agi_send(), and ast_cli().
01154 { 01155 struct timeval start = ast_tvnow(); 01156 int res = 0; 01157 int elapsed = 0; 01158 01159 while (len) { 01160 if (ast_wait_for_output(fd, timeoutms - elapsed)) { 01161 return -1; 01162 } 01163 01164 res = write(fd, s, len); 01165 01166 if (res < 0 && errno != EAGAIN && errno != EINTR) { 01167 /* fatal error from write() */ 01168 ast_log(LOG_ERROR, "write() returned error: %s\n", strerror(errno)); 01169 return -1; 01170 } 01171 01172 if (res < 0) { 01173 /* It was an acceptable error */ 01174 res = 0; 01175 } 01176 01177 /* Update how much data we have left to write */ 01178 len -= res; 01179 s += res; 01180 res = 0; 01181 01182 elapsed = ast_tvdiff_ms(ast_tvnow(), start); 01183 if (elapsed >= timeoutms) { 01184 /* We've taken too long to write 01185 * This is only an error condition if we haven't finished writing. */ 01186 res = len ? -1 : 0; 01187 break; 01188 } 01189 } 01190 01191 return res; 01192 }
Compare two EIDs.
Definition at line 320 of file netsock.c.
Referenced by aji_devstate_cb(), aji_handle_pubsub_event(), aji_mwi_cb(), ast_event_cb(), build_peer(), build_transactions(), destroy_trans(), dundi_answer_entity(), dundi_answer_query(), dundi_ie_append_eid_appropriately(), dundi_lookup_internal(), dundi_query_thread(), evt_event_deliver_cb(), find_peer(), optimize_transactions(), and register_request().
char* ast_eid_to_str | ( | char * | s, | |
int | maxlen, | |||
struct ast_eid * | eid | |||
) |
/brief Convert an EID to a string
Definition at line 222 of file netsock.c.
References ast_eid::eid.
Referenced by aji_publish_device_state(), aji_publish_mwi(), append_transaction(), ast_set_default_eid(), ast_str_retrieve_variable(), build_transactions(), cache_lookup(), cache_lookup_internal(), check_key(), complete_peer_helper(), destroy_trans(), do_autokill(), do_register(), do_register_expire(), dump_answer(), dump_eid(), dump_raw_ie(), dundi_answer_entity(), dundi_lookup_internal(), dundi_lookup_local(), dundi_lookup_thread(), dundi_precache_thread(), dundi_prop_precache(), dundi_query_thread(), dundi_send(), dundi_show_entityid(), dundi_show_peer(), dundi_show_peers(), dundi_show_requests(), handle_command_response(), handle_show_settings(), populate_addr(), register_request(), and update_key().
00223 { 00224 int x; 00225 char *os = s; 00226 if (maxlen < 18) { 00227 if (s && (maxlen > 0)) 00228 *s = '\0'; 00229 } else { 00230 for (x = 0; x < 5; x++) { 00231 sprintf(s, "%02x:", eid->eid[x]); 00232 s += 3; 00233 } 00234 sprintf(s, "%02x", eid->eid[5]); 00235 } 00236 return os; 00237 }
void ast_enable_packet_fragmentation | ( | int | sock | ) |
Disable PMTU discovery on a socket.
sock | The socket to manipulate |
Because of this, UDP packets sent by Asterisk that are larger than the MTU of any hop in the path will be lost. This function can be called on a socket to ensure that the DF bit will not be set.
Definition at line 1922 of file utils.c.
References ast_log(), and LOG_WARNING.
Referenced by ast_netsock_bindaddr().
01923 { 01924 #if defined(HAVE_IP_MTU_DISCOVER) 01925 int val = IP_PMTUDISC_DONT; 01926 01927 if (setsockopt(sock, IPPROTO_IP, IP_MTU_DISCOVER, &val, sizeof(val))) 01928 ast_log(LOG_WARNING, "Unable to disable PMTU discovery. Large UDP packets may fail to be delivered when sent from this socket.\n"); 01929 #endif /* HAVE_IP_MTU_DISCOVER */ 01930 }
char* ast_escape_quoted | ( | const char * | string, | |
char * | outbuf, | |||
int | buflen | |||
) |
Escape characters found in a quoted string.
string | string to be escaped | |
outbuf | resulting escaped string | |
buflen | size of output buffer |
Definition at line 423 of file utils.c.
Referenced by initreqprep().
00424 { 00425 const char *ptr = string; 00426 char *out = outbuf; 00427 char *allow = "\t\v !"; /* allow LWS (minus \r and \n) and "!" */ 00428 00429 while (*ptr && out - outbuf < buflen - 1) { 00430 if (!(strchr(allow, *ptr)) 00431 && !(*ptr >= '#' && *ptr <= '[') /* %x23 - %x5b */ 00432 && !(*ptr >= ']' && *ptr <= '~') /* %x5d - %x7e */ 00433 && !((unsigned char) *ptr > 0x7f)) { /* UTF8-nonascii */ 00434 00435 if (out - outbuf >= buflen - 2) { 00436 break; 00437 } 00438 out += sprintf(out, "\\%c", (unsigned char) *ptr); 00439 } else { 00440 *out = *ptr; 00441 out++; 00442 } 00443 ptr++; 00444 } 00445 00446 if (buflen) { 00447 *out = '\0'; 00448 } 00449 00450 return outbuf; 00451 }
struct hostent* ast_gethostbyname | ( | const char * | host, | |
struct ast_hostent * | hp | |||
) |
Thread-safe gethostbyname function to use in Asterisk.
Definition at line 187 of file utils.c.
References hp.
Referenced by ast_parse_arg(), config_load(), config_parse_variables(), create_addr(), festival_exec(), gtalk_update_stun(), iax_template_parse(), jingle_load_config(), jingle_update_stun(), launch_netscript(), process_sdp(), realtime_peer(), realtime_user(), reload_config(), and set_config().
00188 { 00189 int res; 00190 int herrno; 00191 int dots = 0; 00192 const char *s; 00193 struct hostent *result = NULL; 00194 /* Although it is perfectly legitimate to lookup a pure integer, for 00195 the sake of the sanity of people who like to name their peers as 00196 integers, we break with tradition and refuse to look up a 00197 pure integer */ 00198 s = host; 00199 res = 0; 00200 while (s && *s) { 00201 if (*s == '.') 00202 dots++; 00203 else if (!isdigit(*s)) 00204 break; 00205 s++; 00206 } 00207 if (!s || !*s) { 00208 /* Forge a reply for IP's to avoid octal IP's being interpreted as octal */ 00209 if (dots != 3) 00210 return NULL; 00211 memset(hp, 0, sizeof(struct ast_hostent)); 00212 hp->hp.h_addrtype = AF_INET; 00213 hp->hp.h_addr_list = (void *) hp->buf; 00214 hp->hp.h_addr = hp->buf + sizeof(void *); 00215 /* For AF_INET, this will always be 4 */ 00216 hp->hp.h_length = 4; 00217 if (inet_pton(AF_INET, host, hp->hp.h_addr) > 0) 00218 return &hp->hp; 00219 return NULL; 00220 00221 } 00222 #ifdef HAVE_GETHOSTBYNAME_R_5 00223 result = gethostbyname_r(host, &hp->hp, hp->buf, sizeof(hp->buf), &herrno); 00224 00225 if (!result || !hp->hp.h_addr_list || !hp->hp.h_addr_list[0]) 00226 return NULL; 00227 #else 00228 res = gethostbyname_r(host, &hp->hp, hp->buf, sizeof(hp->buf), &result, &herrno); 00229 00230 if (res || !result || !hp->hp.h_addr_list || !hp->hp.h_addr_list[0]) 00231 return NULL; 00232 #endif 00233 return &hp->hp; 00234 }
void ast_md5_hash | ( | char * | output, | |
const char * | input | |||
) |
Produces MD5 hash based on input string.
Definition at line 237 of file utils.c.
References md5(), MD5Final(), MD5Init(), and MD5Update().
Referenced by build_reply_digest(), and md5().
00238 { 00239 struct MD5Context md5; 00240 unsigned char digest[16]; 00241 char *ptr; 00242 int x; 00243 00244 MD5Init(&md5); 00245 MD5Update(&md5, (const unsigned char *) input, strlen(input)); 00246 MD5Final(digest, &md5); 00247 ptr = output; 00248 for (x = 0; x < 16; x++) 00249 ptr += sprintf(ptr, "%2.2x", digest[x]); 00250 }
int ast_mkdir | ( | const char * | path, | |
int | mode | |||
) |
Recursively create directory path.
path | The directory path to create | |
mode | The permissions with which to try to create the directory |
Definition at line 1932 of file utils.c.
References ast_strdupa, errno, and len().
Referenced by ast_monitor_change_fname(), ast_monitor_start(), conf_run(), create_dirpath(), dictate_exec(), filename_parse(), init_logger(), load_module(), mixmonitor_exec(), reload_logger(), remove_from_queue(), setup_privacy_args(), sms_nextoutgoing(), sms_writefile(), testclient_exec(), testserver_exec(), and write_history().
01933 { 01934 char *ptr; 01935 int len = strlen(path), count = 0, x, piececount = 0; 01936 char *tmp = ast_strdupa(path); 01937 char **pieces; 01938 char *fullpath = alloca(len + 1); 01939 int res = 0; 01940 01941 for (ptr = tmp; *ptr; ptr++) { 01942 if (*ptr == '/') 01943 count++; 01944 } 01945 01946 /* Count the components to the directory path */ 01947 pieces = alloca(count * sizeof(*pieces)); 01948 for (ptr = tmp; *ptr; ptr++) { 01949 if (*ptr == '/') { 01950 *ptr = '\0'; 01951 pieces[piececount++] = ptr + 1; 01952 } 01953 } 01954 01955 *fullpath = '\0'; 01956 for (x = 0; x < piececount; x++) { 01957 /* This looks funky, but the buffer is always ideally-sized, so it's fine. */ 01958 strcat(fullpath, "/"); 01959 strcat(fullpath, pieces[x]); 01960 res = mkdir(fullpath, mode); 01961 if (res && errno != EEXIST) 01962 return errno; 01963 } 01964 return 0; 01965 }
int ast_parse_digest | ( | const char * | digest, | |
struct ast_http_digest * | d, | |||
int | request, | |||
int | pedantic | |||
) |
Parse digest authorization header.
Definition at line 1989 of file utils.c.
References ast_free, ast_log(), ast_skip_blanks(), ast_str_buffer(), ast_str_create(), ast_str_set(), ast_string_field_ptr_set, ast_string_field_set, ast_strlen_zero(), ast_unescape_c(), ast_http_digest::cnonce, ast_http_digest::domain, LOG_WARNING, ast_http_digest::nonce, ast_http_digest::opaque, ast_http_digest::qop, ast_http_digest::realm, ast_http_digest::response, str, strsep(), ast_http_digest::uri, and ast_http_digest::username.
01989 { 01990 char *c; 01991 struct ast_str *str = ast_str_create(16); 01992 01993 /* table of recognised keywords, and places where they should be copied */ 01994 const struct x { 01995 const char *key; 01996 const ast_string_field *field; 01997 } *i, keys[] = { 01998 { "username=", &d->username }, 01999 { "realm=", &d->realm }, 02000 { "nonce=", &d->nonce }, 02001 { "uri=", &d->uri }, 02002 { "domain=", &d->domain }, 02003 { "response=", &d->response }, 02004 { "cnonce=", &d->cnonce }, 02005 { "opaque=", &d->opaque }, 02006 /* Special cases that cannot be directly copied */ 02007 { "algorithm=", NULL }, 02008 { "qop=", NULL }, 02009 { "nc=", NULL }, 02010 { NULL, 0 }, 02011 }; 02012 02013 if (ast_strlen_zero(digest) || !d || !str) { 02014 ast_free(str); 02015 return -1; 02016 } 02017 02018 ast_str_set(&str, 0, "%s", digest); 02019 02020 c = ast_skip_blanks(ast_str_buffer(str)); 02021 02022 if (strncasecmp(c, "Digest ", strlen("Digest "))) { 02023 ast_log(LOG_WARNING, "Missing Digest.\n"); 02024 ast_free(str); 02025 return -1; 02026 } 02027 c += strlen("Digest "); 02028 02029 /* lookup for keys/value pair */ 02030 while (c && *c && *(c = ast_skip_blanks(c))) { 02031 /* find key */ 02032 for (i = keys; i->key != NULL; i++) { 02033 char *src, *separator; 02034 int unescape = 0; 02035 if (strncasecmp(c, i->key, strlen(i->key)) != 0) { 02036 continue; 02037 } 02038 02039 /* Found. Skip keyword, take text in quotes or up to the separator. */ 02040 c += strlen(i->key); 02041 if (*c == '"') { 02042 src = ++c; 02043 separator = "\""; 02044 unescape = 1; 02045 } else { 02046 src = c; 02047 separator = ","; 02048 } 02049 strsep(&c, separator); /* clear separator and move ptr */ 02050 if (unescape) { 02051 ast_unescape_c(src); 02052 } 02053 if (i->field) { 02054 ast_string_field_ptr_set(d, i->field, src); 02055 } else { 02056 /* Special cases that require additional procesing */ 02057 if (!strcasecmp(i->key, "algorithm=")) { 02058 if (strcasecmp(src, "MD5")) { 02059 ast_log(LOG_WARNING, "Digest algorithm: \"%s\" not supported.\n", src); 02060 ast_free(str); 02061 return -1; 02062 } 02063 } else if (!strcasecmp(i->key, "qop=") && !strcasecmp(src, "auth")) { 02064 d->qop = 1; 02065 } else if (!strcasecmp(i->key, "nc=")) { 02066 unsigned long u; 02067 if (sscanf(src, "%30lx", &u) != 1) { 02068 ast_log(LOG_WARNING, "Incorrect Digest nc value: \"%s\".\n", src); 02069 ast_free(str); 02070 return -1; 02071 } 02072 ast_string_field_set(d, nc, src); 02073 } 02074 } 02075 break; 02076 } 02077 if (i->key == NULL) { /* not found, try ',' */ 02078 strsep(&c, ","); 02079 } 02080 } 02081 ast_free(str); 02082 02083 /* Digest checkout */ 02084 if (ast_strlen_zero(d->realm) || ast_strlen_zero(d->nonce)) { 02085 /* "realm" and "nonce" MUST be always exist */ 02086 return -1; 02087 } 02088 02089 if (!request) { 02090 /* Additional check for Digest response */ 02091 if (ast_strlen_zero(d->username) || ast_strlen_zero(d->uri) || ast_strlen_zero(d->response)) { 02092 return -1; 02093 } 02094 02095 if (pedantic && d->qop && (ast_strlen_zero(d->cnonce) || ast_strlen_zero(d->nc))) { 02096 return -1; 02097 } 02098 } 02099 02100 return 0; 02101 }
char* ast_process_quotes_and_slashes | ( | char * | start, | |
char | find, | |||
char | replace_with | |||
) |
Process a string to find and replace characters.
start | The string to analyze | |
find | The character to find | |
replace_with | The character that will replace the one we are looking for |
Definition at line 1465 of file utils.c.
01466 { 01467 char *dataPut = start; 01468 int inEscape = 0; 01469 int inQuotes = 0; 01470 01471 for (; *start; start++) { 01472 if (inEscape) { 01473 *dataPut++ = *start; /* Always goes verbatim */ 01474 inEscape = 0; 01475 } else { 01476 if (*start == '\\') { 01477 inEscape = 1; /* Do not copy \ into the data */ 01478 } else if (*start == '\'') { 01479 inQuotes = 1 - inQuotes; /* Do not copy ' into the data */ 01480 } else { 01481 /* Replace , with |, unless in quotes */ 01482 *dataPut++ = inQuotes ? *start : ((*start == find) ? replace_with : *start); 01483 } 01484 } 01485 } 01486 if (start != dataPut) 01487 *dataPut = 0; 01488 return dataPut; 01489 }
int ast_pthread_create_detached_stack | ( | pthread_t * | thread, | |
pthread_attr_t * | attr, | |||
void *(*)(void *) | start_routine, | |||
void * | data, | |||
size_t | stacksize, | |||
const char * | file, | |||
const char * | caller, | |||
int | line, | |||
const char * | start_fn | |||
) |
Definition at line 1066 of file utils.c.
References ast_log(), ast_pthread_create_stack(), errno, and LOG_WARNING.
01069 { 01070 unsigned char attr_destroy = 0; 01071 int res; 01072 01073 if (!attr) { 01074 attr = alloca(sizeof(*attr)); 01075 pthread_attr_init(attr); 01076 attr_destroy = 1; 01077 } 01078 01079 if ((errno = pthread_attr_setdetachstate(attr, PTHREAD_CREATE_DETACHED))) 01080 ast_log(LOG_WARNING, "pthread_attr_setdetachstate: %s\n", strerror(errno)); 01081 01082 res = ast_pthread_create_stack(thread, attr, start_routine, data, 01083 stacksize, file, caller, line, start_fn); 01084 01085 if (attr_destroy) 01086 pthread_attr_destroy(attr); 01087 01088 return res; 01089 }
int ast_pthread_create_stack | ( | pthread_t * | thread, | |
pthread_attr_t * | attr, | |||
void *(*)(void *) | start_routine, | |||
void * | data, | |||
size_t | stacksize, | |||
const char * | file, | |||
const char * | caller, | |||
int | line, | |||
const char * | start_fn | |||
) |
Definition at line 1017 of file utils.c.
References asprintf, ast_log(), ast_malloc, AST_STACKSIZE, dummy_start(), errno, LOG_WARNING, and pthread_create.
Referenced by ast_pthread_create_detached_stack().
01020 { 01021 #if !defined(LOW_MEMORY) 01022 struct thr_arg *a; 01023 #endif 01024 01025 if (!attr) { 01026 attr = alloca(sizeof(*attr)); 01027 pthread_attr_init(attr); 01028 } 01029 01030 #ifdef __linux__ 01031 /* On Linux, pthread_attr_init() defaults to PTHREAD_EXPLICIT_SCHED, 01032 which is kind of useless. Change this here to 01033 PTHREAD_INHERIT_SCHED; that way the -p option to set realtime 01034 priority will propagate down to new threads by default. 01035 This does mean that callers cannot set a different priority using 01036 PTHREAD_EXPLICIT_SCHED in the attr argument; instead they must set 01037 the priority afterwards with pthread_setschedparam(). */ 01038 if ((errno = pthread_attr_setinheritsched(attr, PTHREAD_INHERIT_SCHED))) 01039 ast_log(LOG_WARNING, "pthread_attr_setinheritsched: %s\n", strerror(errno)); 01040 #endif 01041 01042 if (!stacksize) 01043 stacksize = AST_STACKSIZE; 01044 01045 if ((errno = pthread_attr_setstacksize(attr, stacksize ? stacksize : AST_STACKSIZE))) 01046 ast_log(LOG_WARNING, "pthread_attr_setstacksize: %s\n", strerror(errno)); 01047 01048 #if !defined(LOW_MEMORY) 01049 if ((a = ast_malloc(sizeof(*a)))) { 01050 a->start_routine = start_routine; 01051 a->data = data; 01052 start_routine = dummy_start; 01053 if (asprintf(&a->name, "%-20s started at [%5d] %s %s()", 01054 start_fn, line, file, caller) < 0) { 01055 ast_log(LOG_WARNING, "asprintf() failed: %s\n", strerror(errno)); 01056 a->name = NULL; 01057 } 01058 data = a; 01059 } 01060 #endif /* !LOW_MEMORY */ 01061 01062 return pthread_create(thread, attr, start_routine, data); /* We're in ast_pthread_create, so it's okay */ 01063 }
long int ast_random | ( | void | ) |
Definition at line 1441 of file utils.c.
References ast_mutex_lock, ast_mutex_unlock, and randomlock.
Referenced by acf_rand_exec(), action_challenge(), add_sdp(), agent_new(), agi_handle_command(), ast_lock_path_lockfile(), ast_moh_files_next(), ast_rtp_change_source(), ast_rtp_new(), ast_udptl_new_with_bindaddr(), authenticate_request(), build_iv(), build_rand_pad(), build_reply_digest(), calc_metric(), calc_rxstamp(), caldav_write_event(), callno_hash(), create_channel_name(), generate_exchange_uuid(), generate_random_string(), get_trans_id(), gtalk_alloc(), gtalk_create_candidates(), gtalk_new(), handle_incoming(), handle_response_invite(), iax2_key_rotate(), iax2_start_transfer(), jingle_alloc(), jingle_create_candidates(), jingle_new(), load_module(), local_new(), make_email_file(), make_our_tag(), moh_files_alloc(), multicast_rtp_new(), ogg_vorbis_rewrite(), osp_create_uuid(), page_exec(), park_space_reserve(), process_weights(), reg_source_db(), registry_authrequest(), reqprep(), say_periodic_announcement(), sendmail(), set_nonce_randdata(), sip_alloc(), socket_read(), start_rtp(), stun_req_id(), transmit_invite(), transmit_register(), transmit_response_using_temp(), and try_firmware().
01442 { 01443 long int res; 01444 #ifdef HAVE_DEV_URANDOM 01445 if (dev_urandom_fd >= 0) { 01446 int read_res = read(dev_urandom_fd, &res, sizeof(res)); 01447 if (read_res > 0) { 01448 long int rm = RAND_MAX; 01449 res = res < 0 ? ~res : res; 01450 rm++; 01451 return res % rm; 01452 } 01453 } 01454 #endif 01455 #ifdef linux 01456 res = random(); 01457 #else 01458 ast_mutex_lock(&randomlock); 01459 res = random(); 01460 ast_mutex_unlock(&randomlock); 01461 #endif 01462 return res; 01463 }
void ast_register_thread | ( | char * | name | ) |
Definition at line 399 of file asterisk.c.
References ast_calloc, AST_RWLIST_INSERT_HEAD, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, and ast_atexit::list.
Referenced by dummy_start().
00400 { 00401 struct thread_list_t *new = ast_calloc(1, sizeof(*new)); 00402 00403 if (!new) 00404 return; 00405 new->id = pthread_self(); 00406 new->name = name; /* steal the allocated memory for the thread name */ 00407 AST_RWLIST_WRLOCK(&thread_list); 00408 AST_RWLIST_INSERT_HEAD(&thread_list, new, list); 00409 AST_RWLIST_UNLOCK(&thread_list); 00410 }
void ast_set_default_eid | ( | struct ast_eid * | eid | ) |
Fill in an ast_eid with the default eid of this machine.
Definition at line 239 of file netsock.c.
References ARRAY_LEN, ast_debug, ast_eid_to_str(), and ast_eid::eid.
Referenced by ast_readconfig().
00240 { 00241 #if defined(SIOCGIFHWADDR) && defined(HAVE_STRUCT_IFREQ_IFR_IFRU_IFRU_HWADDR) 00242 int s, x = 0; 00243 char eid_str[20]; 00244 struct ifreq ifr; 00245 static const unsigned int MAXIF = 10; 00246 00247 s = socket(AF_INET, SOCK_STREAM, 0); 00248 if (s < 0) 00249 return; 00250 for (x = 0; x < MAXIF; x++) { 00251 static const char *prefixes[] = { "eth", "em" }; 00252 unsigned int i; 00253 00254 for (i = 0; i < ARRAY_LEN(prefixes); i++) { 00255 memset(&ifr, 0, sizeof(ifr)); 00256 snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "%s%d", prefixes[i], x); 00257 if (!ioctl(s, SIOCGIFHWADDR, &ifr)) { 00258 break; 00259 } 00260 } 00261 00262 if (i == ARRAY_LEN(prefixes)) { 00263 /* Try pciX#[1..N] */ 00264 for (i = 0; i < MAXIF; i++) { 00265 memset(&ifr, 0, sizeof(ifr)); 00266 snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "pci%u#%u", x, i); 00267 if (!ioctl(s, SIOCGIFHWADDR, &ifr)) { 00268 break; 00269 } 00270 } 00271 if (i == MAXIF) { 00272 continue; 00273 } 00274 } 00275 00276 memcpy(eid, ((unsigned char *)&ifr.ifr_hwaddr) + 2, sizeof(*eid)); 00277 ast_debug(1, "Seeding global EID '%s' from '%s' using 'siocgifhwaddr'\n", ast_eid_to_str(eid_str, sizeof(eid_str), eid), ifr.ifr_name); 00278 close(s); 00279 return; 00280 } 00281 close(s); 00282 #else 00283 #if defined(ifa_broadaddr) && !defined(SOLARIS) 00284 char eid_str[20]; 00285 struct ifaddrs *ifap; 00286 00287 if (getifaddrs(&ifap) == 0) { 00288 struct ifaddrs *p; 00289 for (p = ifap; p; p = p->ifa_next) { 00290 if ((p->ifa_addr->sa_family == AF_LINK) && !(p->ifa_flags & IFF_LOOPBACK) && (p->ifa_flags & IFF_RUNNING)) { 00291 struct sockaddr_dl* sdp = (struct sockaddr_dl*) p->ifa_addr; 00292 memcpy(&(eid->eid), sdp->sdl_data + sdp->sdl_nlen, 6); 00293 ast_debug(1, "Seeding global EID '%s' from '%s' using 'getifaddrs'\n", ast_eid_to_str(eid_str, sizeof(eid_str), eid), p->ifa_name); 00294 freeifaddrs(ifap); 00295 return; 00296 } 00297 } 00298 freeifaddrs(ifap); 00299 } 00300 #endif 00301 #endif 00302 ast_debug(1, "No ethernet interface found for seeding global EID. You will have to set it manually.\n"); 00303 }
void ast_sha1_hash | ( | char * | output, | |
const char * | input | |||
) |
Produces SHA1 hash based on input string.
Definition at line 253 of file utils.c.
References SHA1Input(), SHA1Reset(), and SHA1Result().
Referenced by aji_act_hook(), handle_call_token(), jabber_make_auth(), and sha1().
00254 { 00255 struct SHA1Context sha; 00256 char *ptr; 00257 int x; 00258 uint8_t Message_Digest[20]; 00259 00260 SHA1Reset(&sha); 00261 00262 SHA1Input(&sha, (const unsigned char *) input, strlen(input)); 00263 00264 SHA1Result(&sha, Message_Digest); 00265 ptr = output; 00266 for (x = 0; x < 20; x++) 00267 ptr += sprintf(ptr, "%2.2x", Message_Digest[x]); 00268 }
static force_inline void ast_slinear_saturated_add | ( | short * | input, | |
short * | value | |||
) | [static] |
Definition at line 289 of file utils.h.
Referenced by ast_frame_slinear_sum(), audio_audiohook_write_list(), and softmix_bridge_thread().
00290 { 00291 int res; 00292 00293 res = (int) *input + *value; 00294 if (res > 32767) 00295 *input = 32767; 00296 else if (res < -32767) 00297 *input = -32767; 00298 else 00299 *input = (short) res; 00300 }
static force_inline void ast_slinear_saturated_divide | ( | short * | input, | |
short * | value | |||
) | [static] |
Definition at line 328 of file utils.h.
Referenced by ast_frame_adjust_volume(), and audiohook_read_frame_both().
static force_inline void ast_slinear_saturated_multiply | ( | short * | input, | |
short * | value | |||
) | [static] |
Definition at line 315 of file utils.h.
Referenced by ast_frame_adjust_volume(), and audiohook_read_frame_both().
00316 { 00317 int res; 00318 00319 res = (int) *input * *value; 00320 if (res > 32767) 00321 *input = 32767; 00322 else if (res < -32767) 00323 *input = -32767; 00324 else 00325 *input = (short) res; 00326 }
static force_inline void ast_slinear_saturated_subtract | ( | short * | input, | |
short * | value | |||
) | [static] |
int ast_str_to_eid | ( | struct ast_eid * | eid, | |
const char * | s | |||
) |
Convert a string into an EID.
This function expects an EID in the format: 00:11:22:33:44:55
Definition at line 305 of file netsock.c.
References ast_eid::eid.
Referenced by aji_handle_pubsub_event(), dundi_do_query(), and set_config().
00306 { 00307 unsigned int eid_int[6]; 00308 int x; 00309 00310 if (sscanf(s, "%2x:%2x:%2x:%2x:%2x:%2x", &eid_int[0], &eid_int[1], &eid_int[2], 00311 &eid_int[3], &eid_int[4], &eid_int[5]) != 6) 00312 return -1; 00313 00314 for (x = 0; x < 6; x++) 00315 eid->eid[x] = eid_int[x]; 00316 00317 return 0; 00318 }
void ast_unregister_thread | ( | void * | id | ) |
Definition at line 412 of file asterisk.c.
References ast_free, AST_RWLIST_REMOVE_CURRENT, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, thread_list_t::id, ast_atexit::list, and thread_list_t::name.
Referenced by dummy_start().
00413 { 00414 struct thread_list_t *x; 00415 00416 AST_RWLIST_WRLOCK(&thread_list); 00417 AST_RWLIST_TRAVERSE_SAFE_BEGIN(&thread_list, x, list) { 00418 if ((void *) x->id == id) { 00419 AST_RWLIST_REMOVE_CURRENT(list); 00420 break; 00421 } 00422 } 00423 AST_RWLIST_TRAVERSE_SAFE_END; 00424 AST_RWLIST_UNLOCK(&thread_list); 00425 if (x) { 00426 ast_free(x->name); 00427 ast_free(x); 00428 } 00429 }
void ast_uri_decode | ( | char * | s | ) |
Decode URI, URN, URL (overwrite string).
s | String to be decoded |
Definition at line 454 of file utils.c.
Referenced by acf_curl_helper(), config_curl(), get_destination(), get_name_and_number(), get_refer_info(), handle_request_invite(), http_decode(), parse_moved_contact(), realtime_curl(), realtime_multi_curl(), sip_new(), sip_uri_cmp(), and uridecode().
00455 { 00456 char *o; 00457 unsigned int tmp; 00458 00459 for (o = s; *s; s++, o++) { 00460 if (*s == '%' && s[1] != '\0' && s[2] != '\0' && sscanf(s + 1, "%2x", &tmp) == 1) { 00461 /* have '%', two chars and correct parsing */ 00462 *o = tmp; 00463 s += 2; /* Will be incremented once more when we break out */ 00464 } else /* all other cases, just copy */ 00465 *o = *s; 00466 } 00467 *o = '\0'; 00468 }
char* ast_uri_encode | ( | const char * | string, | |
char * | outbuf, | |||
int | buflen, | |||
int | do_special_char | |||
) |
Turn text string to URI-encoded XX version.
Definition at line 390 of file utils.c.
Referenced by add_rpid(), build_contact(), config_curl(), destroy_curl(), initreqprep(), launch_asyncagi(), realtime_curl(), realtime_multi_curl(), require_curl(), store_curl(), update2_curl(), update_curl(), and uriencode().
00391 { 00392 const char *ptr = string; /* Start with the string */ 00393 char *out = outbuf; 00394 const char *mark = "-_.!~*'()"; /* no encode set, RFC 2396 section 2.3, RFC 3261 sec 25 */ 00395 00396 while (*ptr && out - outbuf < buflen - 1) { 00397 if ((const signed char) *ptr < 32 || *ptr == 0x7f || *ptr == '%' || 00398 (do_special_char && 00399 !(*ptr >= '0' && *ptr <= '9') && /* num */ 00400 !(*ptr >= 'A' && *ptr <= 'Z') && /* ALPHA */ 00401 !(*ptr >= 'a' && *ptr <= 'z') && /* alpha */ 00402 !strchr(mark, *ptr))) { /* mark set */ 00403 if (out - outbuf >= buflen - 3) { 00404 break; 00405 } 00406 00407 out += sprintf(out, "%%%02X", (unsigned char) *ptr); 00408 } else { 00409 *out = *ptr; /* Continue copying the string */ 00410 out++; 00411 } 00412 ptr++; 00413 } 00414 00415 if (buflen) { 00416 *out = '\0'; 00417 } 00418 00419 return outbuf; 00420 }
int ast_utils_init | ( | void | ) |
Definition at line 1967 of file utils.c.
References ARRAY_LEN, ast_cli_register_multiple(), and base64_init().
Referenced by main().
01968 { 01969 #ifdef HAVE_DEV_URANDOM 01970 dev_urandom_fd = open("/dev/urandom", O_RDONLY); 01971 #endif 01972 base64_init(); 01973 #ifdef DEBUG_THREADS 01974 #if !defined(LOW_MEMORY) 01975 ast_cli_register_multiple(utils_cli, ARRAY_LEN(utils_cli)); 01976 #endif 01977 #endif 01978 return 0; 01979 }
char* ast_utils_which | ( | const char * | binary, | |
char * | fullpath, | |||
size_t | fullpath_size | |||
) |
Resolve a binary to a full pathname.
binary | Name of the executable to resolve | |
fullpath | Buffer to hold the complete pathname | |
fullpath_size | Size of fullpath |
NULL | binary was not found or the environment variable PATH is not set |
Definition at line 2119 of file utils.c.
References ast_strdupa, and strsep().
Referenced by ast_bt_get_symbols().
02120 { 02121 const char *envPATH = getenv("PATH"); 02122 char *tpath, *path; 02123 struct stat unused; 02124 if (!envPATH) { 02125 return NULL; 02126 } 02127 tpath = ast_strdupa(envPATH); 02128 while ((path = strsep(&tpath, ":"))) { 02129 snprintf(fullpath, fullpath_size, "%s/%s", path, binary); 02130 if (!stat(fullpath, &unused)) { 02131 return fullpath; 02132 } 02133 } 02134 return NULL; 02135 }
int ast_wait_for_input | ( | int | fd, | |
int | ms | |||
) |
Definition at line 1091 of file utils.c.
References ast_poll.
Referenced by ast_tcptls_server_root(), dahdi_test_timer(), and moh_class_destructor().
01092 { 01093 struct pollfd pfd[1]; 01094 memset(pfd, 0, sizeof(pfd)); 01095 pfd[0].fd = fd; 01096 pfd[0].events = POLLIN|POLLPRI; 01097 return ast_poll(pfd, 1, ms); 01098 }
unsigned int __unsigned_int_flags_dummy |
Note: It is very important to use only unsigned variables to hold bit flags, as otherwise you can fall prey to the compiler's sign-extension antics if you try to use the top two bits in your variable. The flag macros below use a set of compiler tricks to verify that the caller is using an "unsigned int" variable to hold the flags, and nothing else. If the caller uses any other type of variable, a warning message similar to this: warning: comparison of distinct pointer types lacks cast will be generated. The "dummy" variable below is used to make these comparisons. Also note that at -O2 or above, this type-safety checking does _not_ produce any additional object code at all.
uint64_t __unsigned_int_flags_dummy64 |
struct ast_eid ast_eid_default |
Global EID.
This is set in asterisk.conf, or determined automatically by taking the mac address of an Ethernet interface on the system.
Definition at line 192 of file asterisk.c.
Referenced by aji_devstate_cb(), aji_handle_pubsub_event(), aji_mwi_cb(), aji_publish_device_state(), aji_publish_mwi(), ast_event_append_eid(), ast_event_cb(), ast_readconfig(), ast_str_retrieve_variable(), evt_event_deliver_cb(), handle_show_settings(), and set_config().