#include "asterisk/network.h"
#include <time.h>
#include <unistd.h>
#include "asterisk/lock.h"
#include "asterisk/logger.h"
#include "asterisk/localtime.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 |
Defines | |
#define | ARRAY_LEN(a) (sizeof(a) / sizeof(0[a])) |
#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_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 *attribute_malloc | _ast_calloc (size_t num, size_t len, const char *file, int lineno, const char *func) |
void *attribute_malloc | _ast_malloc (size_t len, const char *file, int lineno, const char *func) |
void *attribute_malloc | _ast_realloc (void *p, size_t len, const char *file, int lineno, const char *func) |
char *attribute_malloc | _ast_strdup (const char *str, const char *file, int lineno, const char *func) |
char *attribute_malloc | _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. | |
hostent * | ast_gethostbyname (const char *host, struct ast_hostent *hp) |
Thread-safe gethostbyname function to use in Asterisk. | |
void | ast_md5_hash (char *output, char *input) |
Produces MD5 hash based on input string. | |
int | ast_mkdir (const char *path, int mode) |
Recursively create directory path. | |
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, 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 doreserved) |
Turn text string to URI-encoded XX version. | |
int | ast_utils_init (void) |
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 ARRAY_LEN | ( | a | ) | (sizeof(a) / sizeof(0[a])) |
Definition at line 652 of file utils.h.
Referenced by __ast_cli_generator(), __unload_module(), _sip_show_peer(), action_events(), ais_err2str(), alarm2str(), ast_best_codec(), ast_cause2str(), ast_channels_init(), ast_cli_netstats(), ast_codec2str(), ast_codec_choose(), ast_codec_pref_append(), ast_codec_pref_getsize(), ast_codec_pref_prepend(), ast_codec_pref_remove(), ast_codec_pref_setsize(), ast_describe_caller_presentation(), ast_dsp_prog_reset(), ast_dsp_set_call_progress_zone(), ast_event_cmp(), ast_event_str_to_event_type(), ast_event_str_to_ie_type(), ast_expand_codec_alias(), ast_extension_state2str(), ast_get_format_list(), ast_getformatbyname(), ast_getformatname(), ast_getformatname_multiple(), ast_image_init(), ast_named_caller_presentation(), ast_parse_caller_presentation(), ast_rtp_lookup_mime_subtype(), ast_rtp_set_rtpmap_type(), ast_str2cause(), ast_str2tos(), ast_timing_init(), ast_tos2str(), ast_tps_init(), ast_utils_init(), astobj2_init(), authority_to_str(), bearer2str(), cache_get_callno_locked(), cb_events(), check_blacklist(), common_exec(), complete_dpreply(), complete_ulimit(), conf_exec(), convert_attribute_name_from_ldap(), convert_attribute_name_to_ldap(), devstate_cache_cb(), dump_cause(), dump_ies(), dundi_eid_zero(), dundi_ie2str(), dundi_query_read(), event2str(), fac2str(), fill_rxgain(), fill_txgain(), find_alias(), find_cache(), find_sip_method(), find_subscription_type(), ftype2mtype(), get_perm(), geteventbyname(), getjustifybyname(), handle_cli_iax2_show_cache(), handle_cli_iax2_show_channels(), handle_cli_ulimit(), handle_input(), handle_jack_audio(), iax_ie2str(), iax_provflags2str(), iax_showframe(), iax_str2flags(), int2strat(), jack_status_to_str(), jb_choose_impl(), lin16tog722_sample(), lintog722_sample(), load_module(), main(), milliwatt_generate(), minivm_accmess_exec(), minivm_greet_exec(), minivm_notify_exec(), minivm_record_exec(), mute_fragment(), parkandannounce_exec(), parse_naptr(), parse_sip_options(), pbx_retrieve_variable(), process_echocancel(), process_opcode(), process_returncode(), queue_voice_frame(), resample_frame(), rotate_file(), set_queue_result(), sip_show_channel(), slin16_to_slin8_sample(), slin8_to_slin16_sample(), ss_thread(), str2desc(), str2limit(), strat2int(), strings_to_mask(), subscription_type2str(), unload_module(), and update_max_trunk().
#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 678 of file utils.h.
Referenced by ast_hangup(), ast_odbc_request_obj(), ast_rtcp_read(), ast_rtp_read(), ast_sched_del(), ast_udptl_read(), create_jb(), find_timer(), jb_get_and_deliver(), pthread_timer_ack(), and read_pipe().
#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 75 of file utils.h.
Referenced by __ast_read(), __do_deliver(), aji_filter_roster(), ast_autoservice_stop(), ast_bridge_call(), ast_cdr_reset(), ast_cdr_specialized_reset(), ast_channel_bridge(), ast_channel_undefer_dtmf(), ast_deactivate_generator(), ast_hangup(), ast_jb_destroy(), ast_jb_put(), ast_park_call_full(), ast_rtp_stop(), ast_sendtext(), ast_speech_start(), ast_waitfor_nandfds(), ast_waitfordigit_full(), ast_write(), authenticate_verify(), bridge_p2p_loop(), build_peer(), build_user(), builtin_atxfer(), change_spy_mode(), channel_spy(), chanspy_exec(), check_goto_on_transfer(), check_pendings(), common_exec(), config_function_read(), config_text_file_load(), create_addr(), dahdi_read(), dial_exec_full(), dictate_exec(), disa_exec(), dundi_lookup_local(), extenspy_exec(), find_conf(), find_conf_realtime(), 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(), iax2_destroy_helper(), init_acf_query(), linear_alloc(), load_config(), load_moh_classes(), local_ast_moh_stop(), local_attended_transfer(), local_hangup(), local_queue_frame(), main(), manage_parkinglot(), odbc_load_module(), parkandannounce_exec(), parse_options(), phone_read(), playtones_alloc(), process_sdp(), register_verify(), reload_config(), reset_transaction(), set_config(), set_config_destroy(), set_config_flags(), setup_dahdi(), sip_dtmfmode(), sip_hangup(), socket_process(), speech_background(), ss_thread(), update_call_counter(), and waitstream_core().
#define ast_clear_flag64 | ( | p, | |||
flag | ) |
#define ast_clear_flag_nonstd | ( | p, | |||
flag | ) |
Value:
do { \ ((p)->flags &= ~(flag)); \ } while(0)
Definition at line 178 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 82 of file utils.h.
Referenced by __find_callno(), add_features_datastores(), agent_read(), aji_create_client(), aji_filter_roster(), ast_call_forward(), ast_cdr_reset(), ast_cdr_specialized_reset(), ast_feature_interpret(), ast_frdup(), ast_frisolate(), build_peer(), build_user(), builtin_atxfer(), cache_lookup_internal(), channel_spy(), check_access(), check_peer_ok(), create_addr(), create_addr_from_peer(), dundi_lookup_local(), framein(), iax2_request(), minivm_greet_exec(), minivm_record_exec(), park_exec_full(), 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 | ) |
#define ast_copy_flags_nonstd | ( | dest, | |||
src, | |||||
flagz | ) |
#define AST_FLAGS_ALL UINT_MAX |
Definition at line 194 of file utils.h.
Referenced by add_features_datastores(), aji_create_client(), ast_cdr_reset(), ast_cdr_specialized_reset(), ast_feature_interpret(), builtin_atxfer(), cache_lookup_internal(), channel_spy(), chanspy_exec(), check_goto_on_transfer(), dundi_lookup_local(), extenspy_exec(), load_moh_classes(), park_exec_full(), parse_options(), populate_defaults(), and set_config_flags().
#define ast_free free |
#define ast_free_ptr ast_free |
Definition at line 421 of file utils.h.
Referenced by ast_extension_state_add(), ast_merge_contexts_and_delete(), ast_park_call_full(), build_parkinglot(), handle_cli_dialplan_add_extension(), load_module(), manage_parkinglot(), pbx_load_config(), pbx_load_users(), register_exten(), and register_peer_exten().
#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 376 of file utils.h.
Referenced by ast_bridge_call_thread_launch(), ast_dial_run(), ast_features_init(), ast_taskprocessor_get(), function_autopatchup(), 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(), local_dtmf_helper(), restart_monitor(), rpt_master(), rpt_telemetry(), setup_dahdi(), show_console(), 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 384 of file utils.h.
Referenced by aji_reload(), ast_autoservice_start(), ast_device_state_engine_init(), ast_enable_distributed_devstate(), ast_makesocket(), ast_tcptls_server_start(), conf_run(), do_reload(), init_app_class(), init_timing_thread(), load_module(), local_ast_moh_start(), pri_dchannel(), reload_config(), restart_monitor(), sip_prepare_socket(), start_network_thread(), start_stream(), store_config(), and usbradio_call().
#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 380 of file utils.h.
Referenced by accept_thread(), action_originate(), 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(), spawn_dp_lookup(), and start_network_thread().
#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 389 of file utils.h.
Referenced by ast_cdr_submit_batch(), ast_tcptls_server_root(), conf_run(), find_idle_thread(), iax_park(), launch_monitor_thread(), listener(), load_module(), sip_park(), 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 92 of file utils.h.
Referenced by _macro_exec(), aji_create_client(), aji_load_config(), apply_general_options(), apply_option(), apply_outgoing(), ast_bridge_call(), ast_jb_read_conf(), ast_rtp_setdtmf(), ast_rtp_setdtmfcompensate(), ast_rtp_setstun(), ast_translate(), build_peer(), build_user(), check_access(), 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 set_config().
#define ast_set2_flag64 | ( | p, | |||
value, | |||||
flag | ) |
#define ast_set_flag | ( | p, | |||
flag | ) |
Definition at line 68 of file utils.h.
Referenced by __ast_channel_alloc_ap(), __ast_pbx_run(), __ast_read(), __ast_request_and_dial(), _macro_exec(), action_redirect(), aji_load_config(), app_exec(), apply_peer(), ast_autoservice_start(), ast_bridge_call(), 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_generic_bridge(), ast_hangup(), ast_jb_do_usecheck(), ast_jb_put(), ast_park_call_full(), ast_rtp_bridge(), ast_rtp_new_init(), ast_rtp_raw_write(), ast_rtp_read(), ast_speech_change_state(), ast_waitfor_nandfds(), ast_waitfordigit_full(), asyncgoto_exec(), authenticate_reply(), authenticate_request(), bridge_p2p_rtp_write(), build_peer(), build_user(), builtin_atxfer(), builtin_blindtransfer(), cb_extensionstate(), change_spy_mode(), channel_spy(), chanspy_exec(), check_access(), check_availability(), check_bridge(), check_peer_ok(), check_user_full(), check_via(), common_exec(), conf_exec(), connect_link(), create_addr_from_peer(), create_transaction(), dahdi_read(), decrypt_frame(), dial_exec_full(), dictate_exec(), directory_exec(), disa_exec(), do_register(), do_timelimit(), dundi_encrypt(), dundi_lookup_local(), dundi_send(), extenspy_exec(), find_peer(), find_user_realtime(), free_vm_users(), handle_cli_iax2_prune_realtime(), handle_common_options(), handle_exec(), handle_invite_replaces(), handle_request_invite(), handle_request_refer(), handle_request_subscribe(), handle_response(), handle_response_invite(), handle_t38_options(), handle_verbose(), hanguptree(), iax2_predestroy(), iax2_provision(), iax2_start_transfer(), init_acf_query(), init_app_class(), init_files_class(), init_outgoing(), interpret_t38_parameters(), launch_monitor_thread(), leave_voicemail(), linear_alloc(), load_moh_classes(), local_alloc(), local_ast_moh_start(), local_attended_transfer(), local_call(), local_hangup(), local_queue_frame(), login_exec(), main(), manage_parkinglot(), manager_sipnotify(), minivm_greet_exec(), nocdr_exec(), odbc_load_module(), park_exec_full(), parse_options(), peer_delme_cb(), playtones_alloc(), post_cdr(), process_rfc3389(), process_sdp(), pvt_destructor(), qualify_peer(), record_exec(), register_verify(), rpt(), rpt_call(), rpt_exec(), rpt_tele_thread(), run_station(), set_bridge_features_on_config(), set_config(), set_config_flags(), set_insecure_flags(), sip_answer(), sip_call(), 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(), sla_station_exec(), sla_trunk_exec(), socket_process(), ss_thread(), start_spying(), tonepair_alloc(), transmit_register(), transmit_reinvite_with_sdp(), try_calling(), update_call_counter(), user_delme_cb(), vm_execmain(), volume_write(), and waitstream_core().
#define ast_set_flag64 | ( | p, | |||
flag | ) |
#define ast_set_flag_nonstd | ( | p, | |||
flag | ) |
Value:
do { \ ((p)->flags |= (flag)); \ } while(0)
Definition at line 174 of file utils.h.
Referenced by dundi_lookup_internal(), dundi_query_eid_internal(), and handle_command_response().
#define ast_set_flags_to | ( | 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 616 of file utils.h.
Referenced by __ast_channel_alloc_ap(), __ast_play_and_record(), __verboser(), _ast_device_state(), _build_port_config(), _macro_exec(), _parse(), _while_exec(), acf_channel_read(), acf_meetme_info(), acf_odbc_write(), action_agents(), action_setvar(), action_status(), add_agent(), add_peer_mailboxes(), add_redirect(), add_var(), admin_exec(), advanced_options(), agent_logoff_maintenance(), agi_handle_command(), aji_send_exec(), aji_status_exec(), answer_exec_enable(), app_exec(), append_mailbox(), append_mailbox_mapping(), append_var_and_value_to_filter(), apply_options(), aqm_exec(), array(), ast_aji_get_client(), ast_app_getdata(), ast_append_ha(), ast_bridge_call(), ast_callerid_split(), ast_cdr_fork(), ast_eivr_setvariable(), ast_event_check_subscriber(), ast_event_new(), ast_feature_interpret(), ast_filehelper(), ast_format_str_reduce(), ast_func_read(), ast_func_write(), ast_get_group(), ast_mkdir(), ast_monitor_change_fname(), ast_monitor_start(), ast_netsock_bind(), ast_parse_allow_disallow(), ast_parse_arg(), ast_playtones_start(), ast_register_file_version(), ast_writefile(), astman_get_variables(), asyncgoto_exec(), auth_exec(), authenticate_reply(), authenticate_verify(), background_detect_exec(), bridge_exec(), bridge_play_sounds(), build_channels(), build_device(), build_gateway(), build_mapping(), build_peer(), build_profile(), build_user(), builtin_atxfer(), builtin_automixmonitor(), builtin_automonitor(), cache_get_callno_locked(), callerid_write(), chanavail_exec(), channel_admin_exec(), channel_spy(), chanspy_exec(), check_access(), check_blacklist(), check_goto_on_transfer(), check_peer_ok(), check_user_full(), complete_meetmecmd(), conf_exec(), conf_run(), conf_start_moh(), config_function_read(), config_module(), controlplayback_exec(), count_exec(), create_addr(), create_addr_from_peer(), create_vmaccount(), cut_internal(), dahdi_request(), dahdiras_exec(), decrypt_frame(), del_exec(), deltree_exec(), dial_exec_full(), dial_trunk(), dialgroup_refreshdb(), dialgroup_write(), dictate_exec(), directory_exec(), disa_exec(), do_immediate_setup(), do_message(), do_say(), do_timelimit(), dundi_query_read(), dundi_result_read(), dundifunc_read(), enum_query_read(), enum_result_read(), exec_exec(), execif_exec(), extenspy_exec(), festival_exec(), fileexists_core(), find_conf_realtime(), find_gtalk(), find_sdp(), find_table(), find_table_cb(), findmeexec(), function_agent(), function_iaxpeer(), function_realtime_store(), get_destination(), get_refer_info(), gosub_exec(), gosubif_exec(), gtalk_action(), gtalk_alloc(), gtalk_create_candidates(), gtalk_digit(), gtalk_invite(), gtalk_invite_response(), gtalk_request(), handle_call_forward(), handle_cli_file_convert(), handle_debug_dialplan(), handle_options(), handle_request_invite(), handle_request_subscribe(), handle_response(), handle_show_dialplan(), handle_t38_options(), has_voicemail(), iax2_call(), iax2_devicestate(), iax2_prov_app(), iax2_request(), iconv_read(), ind_load_module(), init_acf_query(), init_jack_data(), insert_penaltychange(), is_prefix(), is_valid_dtmf(), isAnsweringMachine(), isexten_function_read(), ivr_dispatch(), jingle_request(), launch_monitor_thread(), launch_netscript(), leave_voicemail(), load_config(), local_devicestate(), log_exec(), login_exec(), lua_func_read(), lua_get_variable(), lua_get_variable_value(), lua_pbx_exec(), lua_set_variable_value(), macroif_exec(), main(), make_components(), make_email_file(), manage_parkinglot(), masq_park_call(), meetmemute(), metermaidstate(), mgcp_devicestate(), minivm_accmess_exec(), minivm_account_func_read(), minivm_counter_func_read(), minivm_counter_func_write(), minivm_greet_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(), notify_message(), notify_new_message(), orig_app(), orig_exten(), ospauth_exec(), ospfinished_exec(), osplookup_exec(), ospnext_exec(), oss_call(), oss_request(), page_exec(), park_call_exec(), park_space_reserve(), parkandannounce_exec(), parse_session_expires(), parse_sip_options(), parse_uri(), 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(), pbx_retrieve_variable(), peer_set_srcaddr(), pickup_exec(), pickupchan_exec(), play_message(), play_moh_exec(), playback_exec(), pqm_exec(), prep_email_sub_vars(), privacy_exec(), process_echocancel(), process_sdp(), process_sdp_o(), 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_odbc(), realtime_multi_pgsql(), record_exec(), register_verify(), registry_authrequest(), reload_followme(), replace_cid(), resource_name_match(), retrydial_exec(), rqm_exec(), sayunixtime_exec(), senddtmf_exec(), sendmail(), sendtext_exec(), sendurl_exec(), set_config_flags(), setup_privacy_args(), sip_devicestate(), sip_new(), sip_sipredirect(), sip_uri_cmp(), sip_uri_headers_cmp(), sip_uri_params_cmp(), 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(), start_moh_exec(), start_monitor_action(), start_monitor_exec(), timezone_add(), transfer_exec(), transmit_invite(), transmit_refer(), 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(), wait_for_winner(), waitstream_core(), 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 61 of file utils.h.
Referenced by __ast_pbx_run(), __ast_queue_frame(), __ast_read(), __do_deliver(), __expire_registry(), __get_from_jb(), __iax2_show_peers(), __sip_destroy(), _macro_exec(), _sip_show_peer(), _sip_show_peers(), acf_odbc_read(), add_agent(), add_codec_to_sdp(), add_sdp(), aji_pruneregister(), app_exec(), ast_audiohook_write_frame(), ast_autoservice_start(), ast_bridge_call(), ast_call(), 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_setuserfield(), ast_cdr_setvar(), ast_cdr_specialized_reset(), ast_cdr_start(), ast_cdr_update(), ast_channel_bridge(), ast_channel_defer_dtmf(), ast_channel_free(), ast_cli_netstats(), ast_do_masquerade(), ast_explicit_goto(), ast_frisolate(), 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_park_call_full(), ast_quiet_chan(), ast_raw_answer(), ast_readstring_full(), ast_rtp_bridge(), ast_rtp_early_bridge(), ast_rtp_getnat(), ast_rtp_make_compatible(), ast_rtp_raw_write(), ast_sendtext(), ast_softhangup_nolock(), ast_streamfile(), ast_transfer(), ast_translate(), ast_waitfordigit_full(), ast_write(), auth_exec(), authenticate_request(), authenticate_verify(), bridge_exec(), bridge_native_loop(), bridge_p2p_rtp_write(), build_peer(), build_radius_record(), build_user(), build_via(), callback_dialoptions(), cb_extensionstate(), cdr_read(), cdr_write(), channel_spy(), chanspy_exec(), check_access(), 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(), conf_exec(), config_text_file_load(), controlplayback_exec(), copy_via_headers(), create_addr(), create_addr_from_peer(), create_dtmf_frame(), create_jb(), decrypt_frame(), destroy_trans(), dial_exec_full(), dictate_exec(), directory_exec(), disa_exec(), do_directory(), 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(), execute_cb(), expire_register(), extenspy_exec(), feature_exec_app(), feature_interpret_helper(), find_cache(), find_call_cb(), find_conf(), find_conf_realtime(), find_or_create(), find_user(), find_user_realtime(), forward_message(), free_user(), function_iaxpeer(), get_destination(), get_insecure_variable_from_config(), gosub_exec(), handle_cli_iax2_prune_realtime(), handle_cli_iax2_show_channels(), handle_cli_iax2_show_peer(), handle_cli_iax2_show_users(), handle_cli_moh_show_classes(), 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_call(), iax2_destroy_helper(), iax2_getpeertrunk(), iax2_hangup(), iax2_predestroy(), iax2_request(), iax2_send(), iax2_trunk_queue(), iax2_write(), initreqprep(), interpret_t38_parameters(), leave_voicemail(), load_dynamic_module(), load_resource(), local_alloc(), local_ast_moh_start(), local_bridgedchannel(), local_hangup(), local_indicate(), local_queue_frame(), local_write(), log_jitterstats(), main(), make_email_file(), manager_iax2_show_peer_list(), manager_list_voicemail_users(), 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(), p2p_callback_disable(), page_exec(), 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(), precache_transactions(), process_cisco_dtmf(), process_rfc2833(), process_rfc3389(), process_sdp(), process_sdp_a_audio(), process_sdp_o(), process_text_line(), prune_peers(), prune_users(), read_exec(), readexten_exec(), record_exec(), reg_source_db(), register_verify(), reload_config(), remove_from_queue(), replace_cid(), reqprep(), respprep(), retrydial_exec(), rpt_master(), schedule_delivery(), search_directory(), select_entry(), select_item_pause(), send_request(), send_trunk(), sendmail(), sendurl_exec(), serialize_showchan(), set_address_from_contact(), set_config(), set_config_flags(), set_t38_capabilities(), should_skip_dtmf(), show_channels_cb(), sip_alloc(), 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_show_channel(), sip_show_settings(), sip_show_user(), 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_notify_with_mwi(), transmit_refer(), transmit_reinvite_with_sdp(), transmit_response_using_temp(), transmit_response_with_sdp(), try_calling(), update_call_counter(), update_peer(), update_registry(), vm_exec(), vm_execmain(), vm_instructions_en(), vm_intro(), vm_newuser(), and waitstream_core().
#define ast_test_flag64 | ( | p, | |||
flag | ) |
Definition at line 118 of file utils.h.
Referenced by ast_app_options2str64(), dial_exec_full(), do_forward(), retrydial_exec(), setup_privacy_args(), valid_priv_reply(), and wait_for_answer().
#define ast_test_flag_nonstd | ( | p, | |||
flag | ) | ((p)->flags & (flag)) |
Definition at line 171 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 226 of file utils.h.
Referenced by __ast_answer(), handle_mousedown(), 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 224 of file utils.h.
Referenced by _sip_tcp_helper_thread(), autoanswer_complete(), calculate_local_max_datagram(), h263p_encap(), h264_encap(), interpret_t38_parameters(), and mpeg4_encap().
int _ast_asprintf | ( | char ** | ret, | |
const char * | file, | |||
int | lineno, | |||
const char * | func, | |||
const char * | fmt, | |||
... | ||||
) |
Definition at line 1877 of file utils.c.
References MALLOC_FAILURE_MSG, and vasprintf.
01878 { 01879 int res; 01880 va_list ap; 01881 01882 va_start(ap, fmt); 01883 if ((res = vasprintf(ret, fmt, ap)) == -1) { 01884 MALLOC_FAILURE_MSG; 01885 } 01886 va_end(ap); 01887 01888 return res; 01889 }
void *attribute_malloc _ast_calloc | ( | size_t | num, | |
size_t | len, | |||
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
void *attribute_malloc _ast_malloc | ( | size_t | len, | |
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
void *attribute_malloc _ast_realloc | ( | void * | p, | |
size_t | len, | |||
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
char *attribute_malloc _ast_strdup | ( | const char * | str, | |
const char * | file, | |||
int | lineno, | |||
const char * | func | |||
) | [inline] |
char *attribute_malloc _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 264 of file utils.c.
Referenced by __ast_check_signature(), base64_decode(), and osp_validate_token().
00265 { 00266 int cnt = 0; 00267 unsigned int byte = 0; 00268 unsigned int bits = 0; 00269 int incnt = 0; 00270 while(*src && *src != '=' && (cnt < max)) { 00271 /* Shift in 6 bits of input */ 00272 byte <<= 6; 00273 byte |= (b2a[(int)(*src)]) & 0x3f; 00274 bits += 6; 00275 src++; 00276 incnt++; 00277 /* If we have at least 8 bits left over, take that character 00278 off the top */ 00279 if (bits >= 8) { 00280 bits -= 8; 00281 *dst = (byte >> bits) & 0xff; 00282 dst++; 00283 cnt++; 00284 } 00285 } 00286 /* Dont worry about left over bits, they're extra anyway */ 00287 return cnt; 00288 }
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 342 of file utils.c.
References ast_base64encode_full().
Referenced by __ast_sign(), aji_start_sasl(), base64_encode(), build_secret(), and osp_check_destination().
00343 { 00344 return ast_base64encode_full(dst, src, srclen, max, 0); 00345 }
int ast_base64encode_full | ( | char * | dst, | |
const unsigned char * | src, | |||
int | srclen, | |||
int | max, | |||
int | linebreaks | |||
) |
encode text to BASE64 coding
Definition at line 291 of file utils.c.
Referenced by ast_base64encode().
00292 { 00293 int cnt = 0; 00294 int col = 0; 00295 unsigned int byte = 0; 00296 int bits = 0; 00297 int cntin = 0; 00298 /* Reserve space for null byte at end of string */ 00299 max--; 00300 while ((cntin < srclen) && (cnt < max)) { 00301 byte <<= 8; 00302 byte |= *(src++); 00303 bits += 8; 00304 cntin++; 00305 if ((bits == 24) && (cnt + 4 <= max)) { 00306 *dst++ = base64[(byte >> 18) & 0x3f]; 00307 *dst++ = base64[(byte >> 12) & 0x3f]; 00308 *dst++ = base64[(byte >> 6) & 0x3f]; 00309 *dst++ = base64[byte & 0x3f]; 00310 cnt += 4; 00311 col += 4; 00312 bits = 0; 00313 byte = 0; 00314 } 00315 if (linebreaks && (cnt < max) && (col == 64)) { 00316 *dst++ = '\n'; 00317 cnt++; 00318 col = 0; 00319 } 00320 } 00321 if (bits && (cnt + 4 <= max)) { 00322 /* Add one last character for the remaining bits, 00323 padding the rest with 0 */ 00324 byte <<= 24 - bits; 00325 *dst++ = base64[(byte >> 18) & 0x3f]; 00326 *dst++ = base64[(byte >> 12) & 0x3f]; 00327 if (bits == 16) 00328 *dst++ = base64[(byte >> 6) & 0x3f]; 00329 else 00330 *dst++ = '='; 00331 *dst++ = '='; 00332 cnt += 4; 00333 } 00334 if (linebreaks && (cnt < max)) { 00335 *dst++ = '\n'; 00336 cnt++; 00337 } 00338 *dst = '\0'; 00339 return cnt; 00340 }
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 1154 of file utils.c.
References ast_log(), ast_tvdiff_ms(), ast_tvnow(), ast_wait_for_output(), errno, fwrite, and LOG_ERROR.
Referenced by send_string().
01155 { 01156 struct timeval start = ast_tvnow(); 01157 int n = 0; 01158 int elapsed = 0; 01159 01160 while (len) { 01161 if (ast_wait_for_output(fd, timeoutms - elapsed)) { 01162 /* poll returned a fatal error, so bail out immediately. */ 01163 return -1; 01164 } 01165 01166 /* Clear any errors from a previous write */ 01167 clearerr(f); 01168 01169 n = fwrite(src, 1, len, f); 01170 01171 if (ferror(f) && errno != EINTR && errno != EAGAIN) { 01172 /* fatal error from fwrite() */ 01173 if (!feof(f)) { 01174 /* Don't spam the logs if it was just that the connection is closed. */ 01175 ast_log(LOG_ERROR, "fwrite() returned error: %s\n", strerror(errno)); 01176 } 01177 n = -1; 01178 break; 01179 } 01180 01181 /* Update for data already written to the socket */ 01182 len -= n; 01183 src += n; 01184 01185 elapsed = ast_tvdiff_ms(ast_tvnow(), start); 01186 if (elapsed >= timeoutms) { 01187 /* We've taken too long to write 01188 * This is only an error condition if we haven't finished writing. */ 01189 n = len ? -1 : 0; 01190 break; 01191 } 01192 } 01193 01194 while (fflush(f)) { 01195 if (errno == EAGAIN || errno == EINTR) { 01196 continue; 01197 } 01198 if (!feof(f)) { 01199 /* Don't spam the logs if it was just that the connection is closed. */ 01200 ast_log(LOG_ERROR, "fflush() returned error: %s\n", strerror(errno)); 01201 } 01202 n = -1; 01203 break; 01204 } 01205 01206 return n < 0 ? -1 : 0; 01207 }
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 1113 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().
01114 { 01115 struct timeval start = ast_tvnow(); 01116 int res = 0; 01117 int elapsed = 0; 01118 01119 while (len) { 01120 if (ast_wait_for_output(fd, timeoutms - elapsed)) { 01121 return -1; 01122 } 01123 01124 res = write(fd, s, len); 01125 01126 if (res < 0 && errno != EAGAIN && errno != EINTR) { 01127 /* fatal error from write() */ 01128 ast_log(LOG_ERROR, "write() returned error: %s\n", strerror(errno)); 01129 return -1; 01130 } 01131 01132 if (res < 0) { 01133 /* It was an acceptable error */ 01134 res = 0; 01135 } 01136 01137 /* Update how much data we have left to write */ 01138 len -= res; 01139 s += res; 01140 res = 0; 01141 01142 elapsed = ast_tvdiff_ms(ast_tvnow(), start); 01143 if (elapsed >= timeoutms) { 01144 /* We've taken too long to write 01145 * This is only an error condition if we haven't finished writing. */ 01146 res = len ? -1 : 0; 01147 break; 01148 } 01149 } 01150 01151 return res; 01152 }
Compare two EIDs.
Definition at line 294 of file netsock.c.
Referenced by build_peer(), build_transactions(), destroy_trans(), dundi_answer_entity(), dundi_answer_query(), dundi_ie_append_eid_appropriately(), dundi_lookup_internal(), dundi_query_thread(), 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 218 of file netsock.c.
References ast_eid::eid.
Referenced by append_transaction(), ast_set_default_eid(), 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(), 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(), pbx_retrieve_variable(), populate_addr(), register_request(), and update_key().
00219 { 00220 int x; 00221 char *os = s; 00222 if (maxlen < 18) { 00223 if (s && (maxlen > 0)) 00224 *s = '\0'; 00225 } else { 00226 for (x = 0; x < 5; x++) { 00227 sprintf(s, "%02x:", eid->eid[x]); 00228 s += 3; 00229 } 00230 sprintf(s, "%02x", eid->eid[5]); 00231 } 00232 return os; 00233 }
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 1817 of file utils.c.
References ast_log(), and LOG_WARNING.
Referenced by ast_netsock_bindaddr().
01818 { 01819 #if defined(HAVE_IP_MTU_DISCOVER) 01820 int val = IP_PMTUDISC_DONT; 01821 01822 if (setsockopt(sock, IPPROTO_IP, IP_MTU_DISCOVER, &val, sizeof(val))) 01823 ast_log(LOG_WARNING, "Unable to disable PMTU discovery. Large UDP packets may fail to be delivered when sent from this socket.\n"); 01824 #endif /* HAVE_IP_MTU_DISCOVER */ 01825 }
struct hostent* ast_gethostbyname | ( | const char * | host, | |
struct ast_hostent * | hp | |||
) |
Thread-safe gethostbyname function to use in Asterisk.
Definition at line 182 of file utils.c.
Referenced by __init_manager(), __set_address_from_contact(), ast_find_ourip(), ast_get_ip_or_srv(), ast_parse_arg(), check_via(), create_addr(), festival_exec(), get_ip_and_port_from_sdp(), gtalk_load_config(), gtalk_update_stun(), handle_cli_udptl_debug_deprecated(), handle_cli_udptl_set_debug(), iax_template_parse(), jingle_load_config(), jingle_update_stun(), launch_netscript(), parse_register_contact(), process_sdp(), process_sdp_c(), realtime_peer(), realtime_user(), reload_config(), rpt_exec(), rtcp_do_debug_ip(), rtp_do_debug_ip(), set_config(), set_destination(), and sip_do_debug_ip().
00183 { 00184 int res; 00185 int herrno; 00186 int dots = 0; 00187 const char *s; 00188 struct hostent *result = NULL; 00189 /* Although it is perfectly legitimate to lookup a pure integer, for 00190 the sake of the sanity of people who like to name their peers as 00191 integers, we break with tradition and refuse to look up a 00192 pure integer */ 00193 s = host; 00194 res = 0; 00195 while (s && *s) { 00196 if (*s == '.') 00197 dots++; 00198 else if (!isdigit(*s)) 00199 break; 00200 s++; 00201 } 00202 if (!s || !*s) { 00203 /* Forge a reply for IP's to avoid octal IP's being interpreted as octal */ 00204 if (dots != 3) 00205 return NULL; 00206 memset(hp, 0, sizeof(struct ast_hostent)); 00207 hp->hp.h_addrtype = AF_INET; 00208 hp->hp.h_addr_list = (void *) hp->buf; 00209 hp->hp.h_addr = hp->buf + sizeof(void *); 00210 if (inet_pton(AF_INET, host, hp->hp.h_addr) > 0) 00211 return &hp->hp; 00212 return NULL; 00213 00214 } 00215 #ifdef HAVE_GETHOSTBYNAME_R_5 00216 result = gethostbyname_r(host, &hp->hp, hp->buf, sizeof(hp->buf), &herrno); 00217 00218 if (!result || !hp->hp.h_addr_list || !hp->hp.h_addr_list[0]) 00219 return NULL; 00220 #else 00221 res = gethostbyname_r(host, &hp->hp, hp->buf, sizeof(hp->buf), &result, &herrno); 00222 00223 if (res || !result || !hp->hp.h_addr_list || !hp->hp.h_addr_list[0]) 00224 return NULL; 00225 #endif 00226 return &hp->hp; 00227 }
void ast_md5_hash | ( | char * | output, | |
char * | input | |||
) |
Produces MD5 hash based on input string.
Definition at line 230 of file utils.c.
References md5(), MD5Final(), MD5Init(), and MD5Update().
Referenced by build_reply_digest(), check_auth(), and md5().
00231 { 00232 struct MD5Context md5; 00233 unsigned char digest[16]; 00234 char *ptr; 00235 int x; 00236 00237 MD5Init(&md5); 00238 MD5Update(&md5, (unsigned char *)input, strlen(input)); 00239 MD5Final(digest, &md5); 00240 ptr = output; 00241 for (x = 0; x < 16; x++) 00242 ptr += sprintf(ptr, "%2.2x", digest[x]); 00243 }
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 1827 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(), 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().
01828 { 01829 char *ptr; 01830 int len = strlen(path), count = 0, x, piececount = 0; 01831 char *tmp = ast_strdupa(path); 01832 char **pieces; 01833 char *fullpath = alloca(len + 1); 01834 int res = 0; 01835 01836 for (ptr = tmp; *ptr; ptr++) { 01837 if (*ptr == '/') 01838 count++; 01839 } 01840 01841 /* Count the components to the directory path */ 01842 pieces = alloca(count * sizeof(*pieces)); 01843 for (ptr = tmp; *ptr; ptr++) { 01844 if (*ptr == '/') { 01845 *ptr = '\0'; 01846 pieces[piececount++] = ptr + 1; 01847 } 01848 } 01849 01850 *fullpath = '\0'; 01851 for (x = 0; x < piececount; x++) { 01852 /* This looks funky, but the buffer is always ideally-sized, so it's fine. */ 01853 strcat(fullpath, "/"); 01854 strcat(fullpath, pieces[x]); 01855 res = mkdir(fullpath, mode); 01856 if (res && errno != EEXIST) 01857 return errno; 01858 } 01859 return 0; 01860 }
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 1425 of file utils.c.
01426 { 01427 char *dataPut = start; 01428 int inEscape = 0; 01429 int inQuotes = 0; 01430 01431 for (; *start; start++) { 01432 if (inEscape) { 01433 *dataPut++ = *start; /* Always goes verbatim */ 01434 inEscape = 0; 01435 } else { 01436 if (*start == '\\') { 01437 inEscape = 1; /* Do not copy \ into the data */ 01438 } else if (*start == '\'') { 01439 inQuotes = 1 - inQuotes; /* Do not copy ' into the data */ 01440 } else { 01441 /* Replace , with |, unless in quotes */ 01442 *dataPut++ = inQuotes ? *start : ((*start == find) ? replace_with : *start); 01443 } 01444 } 01445 } 01446 if (start != dataPut) 01447 *dataPut = 0; 01448 return dataPut; 01449 }
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 1026 of file utils.c.
References ast_log(), ast_pthread_create_stack(), errno, and LOG_WARNING.
01029 { 01030 unsigned char attr_destroy = 0; 01031 int res; 01032 01033 if (!attr) { 01034 attr = alloca(sizeof(*attr)); 01035 pthread_attr_init(attr); 01036 attr_destroy = 1; 01037 } 01038 01039 if ((errno = pthread_attr_setdetachstate(attr, PTHREAD_CREATE_DETACHED))) 01040 ast_log(LOG_WARNING, "pthread_attr_setdetachstate: %s\n", strerror(errno)); 01041 01042 res = ast_pthread_create_stack(thread, attr, start_routine, data, 01043 stacksize, file, caller, line, start_fn); 01044 01045 if (attr_destroy) 01046 pthread_attr_destroy(attr); 01047 01048 return res; 01049 }
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 977 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().
00980 { 00981 #if !defined(LOW_MEMORY) 00982 struct thr_arg *a; 00983 #endif 00984 00985 if (!attr) { 00986 attr = alloca(sizeof(*attr)); 00987 pthread_attr_init(attr); 00988 } 00989 00990 #ifdef __linux__ 00991 /* On Linux, pthread_attr_init() defaults to PTHREAD_EXPLICIT_SCHED, 00992 which is kind of useless. Change this here to 00993 PTHREAD_INHERIT_SCHED; that way the -p option to set realtime 00994 priority will propagate down to new threads by default. 00995 This does mean that callers cannot set a different priority using 00996 PTHREAD_EXPLICIT_SCHED in the attr argument; instead they must set 00997 the priority afterwards with pthread_setschedparam(). */ 00998 if ((errno = pthread_attr_setinheritsched(attr, PTHREAD_INHERIT_SCHED))) 00999 ast_log(LOG_WARNING, "pthread_attr_setinheritsched: %s\n", strerror(errno)); 01000 #endif 01001 01002 if (!stacksize) 01003 stacksize = AST_STACKSIZE; 01004 01005 if ((errno = pthread_attr_setstacksize(attr, stacksize ? stacksize : AST_STACKSIZE))) 01006 ast_log(LOG_WARNING, "pthread_attr_setstacksize: %s\n", strerror(errno)); 01007 01008 #if !defined(LOW_MEMORY) 01009 if ((a = ast_malloc(sizeof(*a)))) { 01010 a->start_routine = start_routine; 01011 a->data = data; 01012 start_routine = dummy_start; 01013 if (asprintf(&a->name, "%-20s started at [%5d] %s %s()", 01014 start_fn, line, file, caller) < 0) { 01015 ast_log(LOG_WARNING, "asprintf() failed: %s\n", strerror(errno)); 01016 a->name = NULL; 01017 } 01018 data = a; 01019 } 01020 #endif /* !LOW_MEMORY */ 01021 01022 return pthread_create(thread, attr, start_routine, data); /* We're in ast_pthread_create, so it's okay */ 01023 }
long int ast_random | ( | void | ) |
Definition at line 1401 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_init(), ast_rtp_new_with_bindaddr(), ast_udptl_new_with_bindaddr(), authenticate_request(), build_gateway(), build_iv(), build_rand_pad(), build_reply_digest(), calc_metric(), calc_rxstamp(), callno_hash(), dahdi_new(), generate_random_string(), get_trans_id(), gtalk_alloc(), gtalk_create_candidates(), gtalk_new(), 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(), 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().
01402 { 01403 long int res; 01404 #ifdef HAVE_DEV_URANDOM 01405 if (dev_urandom_fd >= 0) { 01406 int read_res = read(dev_urandom_fd, &res, sizeof(res)); 01407 if (read_res > 0) { 01408 long int rm = RAND_MAX; 01409 res = res < 0 ? ~res : res; 01410 rm++; 01411 return res % rm; 01412 } 01413 } 01414 #endif 01415 #ifdef linux 01416 res = random(); 01417 #else 01418 ast_mutex_lock(&randomlock); 01419 res = random(); 01420 ast_mutex_unlock(&randomlock); 01421 #endif 01422 return res; 01423 }
void ast_register_thread | ( | char * | name | ) |
Definition at line 347 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().
00348 { 00349 struct thread_list_t *new = ast_calloc(1, sizeof(*new)); 00350 00351 if (!new) 00352 return; 00353 new->id = pthread_self(); 00354 new->name = name; /* steal the allocated memory for the thread name */ 00355 AST_RWLIST_WRLOCK(&thread_list); 00356 AST_RWLIST_INSERT_HEAD(&thread_list, new, list); 00357 AST_RWLIST_UNLOCK(&thread_list); 00358 }
void ast_set_default_eid | ( | struct ast_eid * | eid | ) |
Fill in an ast_eid with the default eid of this machine.
Definition at line 235 of file netsock.c.
References ast_debug, ast_eid_to_str(), ast_eid::eid, and s.
Referenced by ast_readconfig().
00236 { 00237 #if defined(SIOCGIFHWADDR) 00238 int s, x = 0; 00239 char eid_str[20]; 00240 struct ifreq ifr; 00241 00242 s = socket(AF_INET, SOCK_STREAM, 0); 00243 if (s < 0) 00244 return; 00245 for (x = 0; x < 10; x++) { 00246 memset(&ifr, 0, sizeof(ifr)); 00247 snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "eth%d", x); 00248 if (ioctl(s, SIOCGIFHWADDR, &ifr)) 00249 continue; 00250 memcpy(eid, ((unsigned char *)&ifr.ifr_hwaddr) + 2, sizeof(*eid)); 00251 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); 00252 close(s); 00253 return; 00254 } 00255 close(s); 00256 #else 00257 #if defined(ifa_broadaddr) && !defined(SOLARIS) 00258 char eid_str[20]; 00259 struct ifaddrs *ifap; 00260 00261 if (getifaddrs(&ifap) == 0) { 00262 struct ifaddrs *p; 00263 for (p = ifap; p; p = p->ifa_next) { 00264 if ((p->ifa_addr->sa_family == AF_LINK) && !(p->ifa_flags & IFF_LOOPBACK) && (p->ifa_flags & IFF_RUNNING)) { 00265 struct sockaddr_dl* sdp = (struct sockaddr_dl*) p->ifa_addr; 00266 memcpy(&(eid->eid), sdp->sdl_data + sdp->sdl_nlen, 6); 00267 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); 00268 freeifaddrs(ifap); 00269 return; 00270 } 00271 } 00272 freeifaddrs(ifap); 00273 } 00274 #endif 00275 #endif 00276 ast_debug(1, "No ethernet interface found for seeding global EID. You will have to set it manually.\n"); 00277 }
void ast_sha1_hash | ( | char * | output, | |
char * | input | |||
) |
Produces SHA1 hash based on input string.
Definition at line 246 of file utils.c.
References SHA1Input(), SHA1Reset(), and SHA1Result().
Referenced by aji_act_hook(), handle_call_token(), jabber_make_auth(), and sha1().
00247 { 00248 struct SHA1Context sha; 00249 char *ptr; 00250 int x; 00251 uint8_t Message_Digest[20]; 00252 00253 SHA1Reset(&sha); 00254 00255 SHA1Input(&sha, (const unsigned char *) input, strlen(input)); 00256 00257 SHA1Result(&sha, Message_Digest); 00258 ptr = output; 00259 for (x = 0; x < 20; x++) 00260 ptr += sprintf(ptr, "%2.2x", Message_Digest[x]); 00261 }
static force_inline void ast_slinear_saturated_add | ( | short * | input, | |
short * | value | |||
) | [static] |
Definition at line 271 of file utils.h.
Referenced by ast_frame_slinear_sum(), and audio_audiohook_write_list().
00272 { 00273 int res; 00274 00275 res = (int) *input + *value; 00276 if (res > 32767) 00277 *input = 32767; 00278 else if (res < -32767) 00279 *input = -32767; 00280 else 00281 *input = (short) res; 00282 }
static force_inline void ast_slinear_saturated_divide | ( | short * | input, | |
short * | value | |||
) | [static] |
Definition at line 310 of file utils.h.
Referenced by ast_frame_adjust_volume(), and audiohook_read_frame_both().
00311 { 00312 *input /= *value; 00313 }
static force_inline void ast_slinear_saturated_multiply | ( | short * | input, | |
short * | value | |||
) | [static] |
Definition at line 297 of file utils.h.
Referenced by ast_frame_adjust_volume(), and audiohook_read_frame_both().
00298 { 00299 int res; 00300 00301 res = (int) *input * *value; 00302 if (res > 32767) 00303 *input = 32767; 00304 else if (res < -32767) 00305 *input = -32767; 00306 else 00307 *input = (short) res; 00308 }
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 279 of file netsock.c.
References ast_eid::eid.
Referenced by dundi_do_query(), and set_config().
00280 { 00281 unsigned int eid_int[6]; 00282 int x; 00283 00284 if (sscanf(s, "%2x:%2x:%2x:%2x:%2x:%2x", &eid_int[0], &eid_int[1], &eid_int[2], 00285 &eid_int[3], &eid_int[4], &eid_int[5]) != 6) 00286 return -1; 00287 00288 for (x = 0; x < 6; x++) 00289 eid->eid[x] = eid_int[x]; 00290 00291 return 0; 00292 }
void ast_unregister_thread | ( | void * | id | ) |
Definition at line 360 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().
00361 { 00362 struct thread_list_t *x; 00363 00364 AST_RWLIST_WRLOCK(&thread_list); 00365 AST_RWLIST_TRAVERSE_SAFE_BEGIN(&thread_list, x, list) { 00366 if ((void *) x->id == id) { 00367 AST_RWLIST_REMOVE_CURRENT(list); 00368 break; 00369 } 00370 } 00371 AST_RWLIST_TRAVERSE_SAFE_END; 00372 AST_RWLIST_UNLOCK(&thread_list); 00373 if (x) { 00374 ast_free(x->name); 00375 ast_free(x); 00376 } 00377 }
void ast_uri_decode | ( | char * | s | ) |
Decode URI, URN, URL (overwrite string).
s | String to be decoded |
Definition at line 414 of file utils.c.
Referenced by check_user_full(), config_curl(), get_also_info(), get_destination(), get_refer_info(), handle_request_invite(), http_decode(), realtime_curl(), realtime_multi_curl(), register_verify(), sip_new(), and uridecode().
00415 { 00416 char *o; 00417 unsigned int tmp; 00418 00419 for (o = s; *s; s++, o++) { 00420 if (*s == '%' && strlen(s) > 2 && sscanf(s + 1, "%2x", &tmp) == 1) { 00421 /* have '%', two chars and correct parsing */ 00422 *o = tmp; 00423 s += 2; /* Will be incremented once more when we break out */ 00424 } else /* all other cases, just copy */ 00425 *o = *s; 00426 } 00427 *o = '\0'; 00428 }
char* ast_uri_encode | ( | const char * | string, | |
char * | outbuf, | |||
int | buflen, | |||
int | doreserved | |||
) |
Turn text string to URI-encoded XX version.
Definition at line 383 of file utils.c.
References ast_copy_string().
Referenced by config_curl(), destroy_curl(), initreqprep(), launch_asyncagi(), realtime_curl(), realtime_multi_curl(), require_curl(), store_curl(), update_curl(), and uriencode().
00384 { 00385 char *reserved = ";/?:@&=+$,# "; /* Reserved chars */ 00386 00387 const char *ptr = string; /* Start with the string */ 00388 char *out = NULL; 00389 char *buf = NULL; 00390 00391 ast_copy_string(outbuf, string, buflen); 00392 00393 /* If there's no characters to convert, just go through and don't do anything */ 00394 while (*ptr) { 00395 if ((*ptr < 32) || (doreserved && strchr(reserved, *ptr))) { 00396 /* Oops, we need to start working here */ 00397 if (!buf) { 00398 buf = outbuf; 00399 out = buf + (ptr - string) ; /* Set output ptr */ 00400 } 00401 out += sprintf(out, "%%%02x", (unsigned char) *ptr); 00402 } else if (buf) { 00403 *out = *ptr; /* Continue copying the string */ 00404 out++; 00405 } 00406 ptr++; 00407 } 00408 if (buf) 00409 *out = '\0'; 00410 return outbuf; 00411 }
int ast_utils_init | ( | void | ) |
Definition at line 1862 of file utils.c.
References ARRAY_LEN, ast_cli_register_multiple(), and base64_init().
Referenced by main().
01863 { 01864 #ifdef HAVE_DEV_URANDOM 01865 dev_urandom_fd = open("/dev/urandom", O_RDONLY); 01866 #endif 01867 base64_init(); 01868 #ifdef DEBUG_THREADS 01869 #if !defined(LOW_MEMORY) 01870 ast_cli_register_multiple(utils_cli, ARRAY_LEN(utils_cli)); 01871 #endif 01872 #endif 01873 return 0; 01874 }
int ast_wait_for_input | ( | int | fd, | |
int | ms | |||
) |
Definition at line 1051 of file utils.c.
References ast_poll.
Referenced by action_waitevent(), ast_tcptls_server_root(), dahdi_test_timer(), get_input(), and moh_class_destructor().
01052 { 01053 struct pollfd pfd[1]; 01054 memset(pfd, 0, sizeof(pfd)); 01055 pfd[0].fd = fd; 01056 pfd[0].events = POLLIN|POLLPRI; 01057 return ast_poll(pfd, 1, ms); 01058 }
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 165 of file asterisk.c.
Referenced by ast_event_new(), ast_readconfig(), handle_show_settings(), pbx_retrieve_variable(), and set_config().