Asterisk - The Open Source Telephony Project GIT-master-773870a
Loading...
Searching...
No Matches
Data Structures | Macros | Functions | Variables
utils.c File Reference

Utility functions. More...

#include "asterisk.h"
#include <ctype.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/syscall.h>
#include <unistd.h>
#include "asterisk/network.h"
#include "asterisk/ast_version.h"
#include "asterisk/lock.h"
#include "asterisk/io.h"
#include "asterisk/md5.h"
#include "asterisk/sha1.h"
#include "asterisk/cli.h"
#include "asterisk/linkedlists.h"
#include "asterisk/astobj2.h"
#include "asterisk/strings.h"
#include "asterisk/time.h"
#include "asterisk/utils.h"
#include "asterisk/threadstorage.h"
#include "asterisk/config.h"
#include "asterisk/alertpipe.h"
Include dependency graph for utils.c:

Go to the source code of this file.

Data Structures

struct  baseio
 Structure used for base64 encoding. More...
 
struct  thr_arg
 

Macros

#define AST_API_MODULE   /* ensure that inlinable API functions will be built in lock.h if required */
 
#define AST_API_MODULE   /* ensure that inlinable API functions will be built in this module if required */
 
#define AST_API_MODULE   /* ensure that inlinable API functions will be built in this module if required */
 
#define AST_API_MODULE   /* ensure that inlinable API functions will be built in this module if required */
 
#define AST_API_MODULE
 
#define AST_API_MODULE
 
#define AST_API_MODULE
 
#define BASELINELEN   72
 
#define BASEMAXINLINE   256
 
#define ONE_MILLION   1000000
 

Functions

void DO_CRASH_NORETURN __ast_assert_failed (int condition, const char *condition_str, const char *file, int line, const char *function)
 
int __ast_fd_set_flags (int fd, int flags, enum ast_fd_flag_operation op, const char *file, int lineno, const char *function)
 
int ast_background_stacksize (void)
 
int ast_base64_encode_file (FILE *inputfile, FILE *outputfile, const char *endl)
 Performs a base 64 encode algorithm on the contents of a File.
 
int ast_base64_encode_file_path (const char *filename, FILE *outputfile, const char *endl)
 Performs a base 64 encode algorithm on the contents of a File.
 
int ast_base64decode (unsigned char *dst, const char *src, int max)
 decode BASE64 encoded text
 
char * ast_base64decode_string (const char *src)
 Decode BASE64 encoded text and return the string.
 
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
 
char * ast_base64encode_string (const char *src)
 Encode to BASE64 and return encoded string.
 
int ast_base64url_decode (unsigned char *dst, const char *src, int max)
 Decode data from base64 URL.
 
char * ast_base64url_decode_string (const char *src)
 Decode string from base64 URL.
 
int ast_base64url_encode (char *dst, const unsigned char *src, int srclen, int max)
 Encode data in base64 URL.
 
int ast_base64url_encode_full (char *dst, const unsigned char *src, int srclen, int max, int linebreaks)
 Same as ast_base64encode_full but for base64 URL.
 
char * ast_base64url_encode_string (const char *src)
 Encode string in base64 URL.
 
int ast_build_string (char **buffer, size_t *space, const char *fmt,...)
 Build a string in a buffer, designed to be called repeatedly.
 
int ast_build_string_va (char **buffer, size_t *space, const char *fmt, va_list ap)
 Build a string in a buffer, designed to be called repeatedly.
 
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_check_command_in_path (const char *cmd)
 Test for the presence of an executable command in $PATH.
 
int ast_check_ipv6 (void)
 Test that an OS supports IPv6 Networking.
 
int ast_compare_versions (const char *version1, const char *version2)
 Compare 2 major.minor.patch.extra version strings.
 
void DO_CRASH_NORETURN ast_do_crash (void)
 Force a crash if DO_CRASH is defined.
 
int ast_eid_cmp (const struct ast_eid *eid1, const struct ast_eid *eid2)
 Compare two EIDs.
 
int ast_eid_is_empty (const struct ast_eid *eid)
 Check if EID is empty.
 
char * ast_eid_to_str (char *s, int maxlen, struct ast_eid *eid)
 Convert an EID to a string.
 
void ast_enable_packet_fragmentation (int sock)
 Disable PMTU discovery on a socket.
 
char * ast_escape (char *dest, const char *s, size_t size, const char *to_escape)
 Escape the 'to_escape' characters in the given string.
 
char * ast_escape_alloc (const char *s, const char *to_escape)
 Escape the 'to_escape' characters in the given string.
 
char * ast_escape_c (char *dest, const char *s, size_t size)
 Escape standard 'C' sequences in the given string.
 
char * ast_escape_c_alloc (const char *s)
 Escape standard 'C' sequences in the given string.
 
char * ast_escape_quoted (const char *string, char *outbuf, int buflen)
 Escape characters found in a quoted string.
 
char * ast_escape_semicolons (const char *string, char *outbuf, int buflen)
 Escape semicolons found in a string.
 
int ast_false (const char *s)
 Make sure something is false. Determine if a string containing a boolean value is "false". This function checks to see whether a string passed to it is an indication of an "false" value. It checks to see if the string is "no", "false", "n", "f", "off" or "0".
 
int ast_file_is_readable (const char *filename)
 Test that a file exists and is readable by the effective user.
 
void ast_format_duration_hh_mm_ss (int duration, char *buf, size_t length)
 Formats a duration into HH:MM:SS.
 
int ast_get_tid (void)
 Get current thread ID.
 
int ast_get_time_t (const char *src, time_t *dst, time_t _default, int *consumed)
 get values from config variables.
 
int ast_get_timeval (const char *src, struct timeval *dst, struct timeval _default, int *consumed)
 get values from config variables.
 
struct hostent * ast_gethostbyname (const char *host, struct ast_hostent *hp)
 Re-entrant (thread safe) version of gethostbyname that replaces the standard gethostbyname (which is not thread safe)
 
const char * ast_inet_ntoa (struct in_addr ia)
 ast_inet_ntoa: Recursive thread safe replacement of inet_ntoa
 
void ast_join_delim (char *s, size_t len, const char *const w[], unsigned int size, char delim)
 Join an array of strings into a single string.
 
void ast_md5_hash (char *output, const char *input)
 Produce 32 char MD5 hash of value.
 
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)
 
int ast_regex_string_to_regex_pattern (const char *regex_string, struct ast_str **regex_pattern)
 Given a string regex_string in the form of "/regex/", convert it into the form of "regex".
 
int ast_remaining_ms (struct timeval start, int max_ms)
 Calculate remaining milliseconds given a starting timestamp and upper bound.
 
void ast_replace_subargument_delimiter (char *s)
 Replace '^' in a string with ','.
 
int ast_safe_mkdir (const char *base_path, const char *path, int mode)
 Recursively create directory path, but only if it resolves within the given base_path.
 
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)
 Produce 40 char SHA1 hash of value.
 
void ast_sha1_hash_uint (uint8_t *digest, const char *input)
 Produce a 20 byte SHA1 hash of value.
 
int ast_str_to_eid (struct ast_eid *eid, const char *s)
 Convert a string into an EID.
 
char * ast_strip_quoted (char *s, const char *beg_quotes, const char *end_quotes)
 Strip leading/trailing whitespace and quotes from a string.
 
char * ast_strsep (char **iss, const char sep, uint32_t flags)
 Act like strsep but ignore separators inside quotes.
 
char * ast_strsep_quoted (char **iss, const char sep, const char quote, uint32_t flags)
 Like ast_strsep() except you can specify a specific quote character.
 
int ast_thread_is_user_interface (void)
 Indicates whether the current thread is a user interface.
 
int ast_thread_user_interface_set (int is_user_interface)
 Set the current thread's user interface status.
 
 AST_THREADSTORAGE_CUSTOM_SCOPE (inet_ntoa_buf, NULL, ast_free_ptr, static)
 
 AST_THREADSTORAGE_CUSTOM_SCOPE (thread_user_interface_tl, NULL, ast_free_ptr, static)
 A thread local indicating whether the current thread is a user interface.
 
char * ast_to_camel_case_delim (const char *s, const char *delim)
 Attempts to convert the given string to camel case using the specified delimiter.
 
int ast_true (const char *s)
 Make sure something is true. Determine if a string containing a boolean value is "true". This function checks to see whether a string passed to it is an indication of an "true" value. It checks to see if the string is "yes", "true", "y", "t", "on" or "1".
 
struct timeval ast_tvadd (struct timeval a, struct timeval b)
 Returns the sum of two timevals a + b.
 
struct timeval ast_tvsub (struct timeval a, struct timeval b)
 Returns the difference of two timevals a - b.
 
char * ast_unescape_c (char *src)
 Convert some C escape sequences.
 
void ast_unescape_quoted (char *quote_str)
 Unescape quotes in a string.
 
char * ast_unescape_semicolon (char *s)
 Strip backslash for "escaped" semicolons, the string to be stripped (will be modified).
 
void ast_uri_decode (char *s, struct ast_flags spec)
 Decode URI, URN, URL (overwrite string)
 
char * ast_uri_encode (const char *string, char *outbuf, int buflen, struct ast_flags spec)
 Turn text string to URI-encoded XX version.
 
int ast_uri_verify_encoded (const char *string)
 Verify if a string is valid as a URI component.
 
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)
 
int ast_wait_for_output (int fd, int ms)
 
int ast_xml_escape (const char *string, char *const outbuf, const size_t buflen)
 Escape reserved characters for use in XML.
 
static void base64_init (void)
 
static void * dummy_start (void *data)
 
static char * escape_alloc (const char *s, size_t *size)
 
static int inbuf (struct baseio *bio, FILE *fi)
 utility used by inchar(), for base_encode()
 
static int inchar (struct baseio *bio, FILE *fi)
 utility used by base_encode()
 
static int ochar (struct baseio *bio, int c, FILE *so, const char *endl)
 utility used by base_encode()
 
static int safe_mkdir (const char *base_path, char *path, int mode)
 
static struct timeval tvfix (struct timeval a)
 
static void utils_shutdown (void)
 
static int wait_for_output (int fd, int timeoutms)
 

Variables

const struct ast_flags ast_uri_http = {AST_URI_UNRESERVED}
 
const struct ast_flags ast_uri_http_legacy = {AST_URI_LEGACY_SPACE | AST_URI_UNRESERVED}
 
const struct ast_flags ast_uri_sip_user = {AST_URI_UNRESERVED | AST_URI_SIP_USER_UNRESERVED}
 
static char b2a [256]
 
static char b2a_url [256]
 
static char base64 [64]
 
static char base64url [64]
 
static int dev_urandom_fd = -1
 
char escape_sequences []
 
static char escape_sequences_map []
 
static ast_mutex_t randomlock = AST_MUTEX_INIT_VALUE
 

Detailed Description

Utility functions.

Note
These are important for portability and security, so please use them in favour of other routines. Please consult the CODING GUIDELINES for more information.

Definition in file utils.c.

Macro Definition Documentation

◆ AST_API_MODULE [1/7]

#define AST_API_MODULE   /* ensure that inlinable API functions will be built in lock.h if required */

Definition at line 48 of file utils.c.

◆ AST_API_MODULE [2/7]

#define AST_API_MODULE   /* ensure that inlinable API functions will be built in this module if required */

Definition at line 48 of file utils.c.

◆ AST_API_MODULE [3/7]

#define AST_API_MODULE   /* ensure that inlinable API functions will be built in this module if required */

Definition at line 48 of file utils.c.

◆ AST_API_MODULE [4/7]

#define AST_API_MODULE   /* ensure that inlinable API functions will be built in this module if required */

Definition at line 48 of file utils.c.

◆ AST_API_MODULE [5/7]

#define AST_API_MODULE

Definition at line 48 of file utils.c.

◆ AST_API_MODULE [6/7]

#define AST_API_MODULE

Definition at line 48 of file utils.c.

◆ AST_API_MODULE [7/7]

#define AST_API_MODULE

Definition at line 48 of file utils.c.

◆ BASELINELEN

#define BASELINELEN   72

Line length for Base 64 encoded messages

Definition at line 573 of file utils.c.

◆ BASEMAXINLINE

#define BASEMAXINLINE   256

Buffer size for Base 64 attachment encoding

Definition at line 574 of file utils.c.

◆ ONE_MILLION

#define ONE_MILLION   1000000

Definition at line 2267 of file utils.c.

Function Documentation

◆ __ast_assert_failed()

void DO_CRASH_NORETURN __ast_assert_failed ( int  condition,
const char *  condition_str,
const char *  file,
int  line,
const char *  function 
)

Definition at line 2850 of file utils.c.

2851{
2852 /*
2853 * Attempt to put it into the logger, but hope that at least
2854 * someone saw the message on stderr ...
2855 */
2856 fprintf(stderr, "FRACK!, Failed assertion %s (%d) at line %d in %s of %s\n",
2857 condition_str, condition, line, function, file);
2858 ast_log(__LOG_ERROR, file, line, function, "FRACK!, Failed assertion %s (%d)\n",
2859 condition_str, condition);
2860
2861 /* Generate a backtrace for the assert */
2863
2864 /*
2865 * Give the logger a chance to get the message out, just in case
2866 * we abort(), or Asterisk crashes due to whatever problem just
2867 * happened after we exit ast_assert().
2868 */
2869 usleep(1);
2870 ast_do_crash();
2871}
#define ast_log
Definition astobj2.c:42
#define __LOG_ERROR
void ast_log_backtrace(void)
Log a backtrace of the current thread's execution stack to the Asterisk log.
Definition logger.c:2480
void DO_CRASH_NORETURN ast_do_crash(void)
Force a crash if DO_CRASH is defined.
Definition utils.c:2838

References __LOG_ERROR, ast_do_crash(), ast_log, and ast_log_backtrace().

Referenced by __ao2_container_clone(), __ao2_iterator_next(), __ao2_link(), __ao2_ref(), internal_ao2_traverse(), and log_bad_ao2().

◆ __ast_fd_set_flags()

int __ast_fd_set_flags ( int  fd,
int  flags,
enum ast_fd_flag_operation  op,
const char *  file,
int  lineno,
const char *  function 
)

Definition at line 3184 of file utils.c.

3186{
3187 int f;
3188
3189 f = fcntl(fd, F_GETFL);
3190 if (f == -1) {
3191 ast_log(__LOG_ERROR, file, lineno, function,
3192 "Failed to get fcntl() flags for file descriptor: %s\n", strerror(errno));
3193 return -1;
3194 }
3195
3196 switch (op) {
3197 case AST_FD_FLAG_SET:
3198 if ((f & flags) == flags) {
3199 /* There is nothing to set */
3200 return 0;
3201 }
3202 f |= flags;
3203 break;
3204 case AST_FD_FLAG_CLEAR:
3205 if (!(f & flags)) {
3206 /* There is nothing to clear */
3207 return 0;
3208 }
3209 f &= ~flags;
3210 break;
3211 default:
3212 ast_assert(0);
3213 break;
3214 }
3215
3216 f = fcntl(fd, F_SETFL, f);
3217 if (f == -1) {
3218 ast_log(__LOG_ERROR, file, lineno, function,
3219 "Failed to set fcntl() flags for file descriptor: %s\n", strerror(errno));
3220 return -1;
3221 }
3222
3223 return 0;
3224}
int errno
#define ast_assert(a)
Definition utils.h:779
@ AST_FD_FLAG_SET
Definition utils.h:1062
@ AST_FD_FLAG_CLEAR
Definition utils.h:1063

References __LOG_ERROR, ast_assert, AST_FD_FLAG_CLEAR, AST_FD_FLAG_SET, ast_log, and errno.

◆ ast_background_stacksize()

int ast_background_stacksize ( void  )

Definition at line 1650 of file utils.c.

1651{
1652#if !defined(LOW_MEMORY)
1653 return AST_STACKSIZE;
1654#else
1655 return AST_STACKSIZE_LOW;
1656#endif
1657}
#define AST_STACKSIZE
Definition utils.h:605
#define AST_STACKSIZE_LOW
Definition utils.h:606

References AST_STACKSIZE, and AST_STACKSIZE_LOW.

◆ ast_base64_encode_file()

int ast_base64_encode_file ( FILE *  inputfile,
FILE *  outputfile,
const char *  endl 
)

Performs a base 64 encode algorithm on the contents of a File.

Parameters
inputfileA FILE handle to the input file to be encoded. Must be readable. This handle is not automatically closed.
outputfileA FILE handle to the output file to receive the base 64 encoded contents of the input file, identified by filename.
endlThe line ending to use (e.g. either "\n" or "\r\n")
Returns
zero on success, -1 on error.

Definition at line 646 of file utils.c.

647{
648 static const unsigned char dtable[] = { 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K',
649 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f',
650 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z', '0',
651 '1', '2', '3', '4', '5', '6', '7', '8', '9', '+', '/'};
652 int i, hiteof = 0;
653 struct baseio bio;
654
655 memset(&bio, 0, sizeof(bio));
656 bio.iocp = BASEMAXINLINE;
657
658 while (!hiteof){
659 unsigned char igroup[3], ogroup[4];
660 int c, n;
661
662 memset(igroup, 0, sizeof(igroup));
663
664 for (n = 0; n < 3; n++) {
665 if ((c = inchar(&bio, inputfile)) == EOF) {
666 hiteof = 1;
667 break;
668 }
669
670 igroup[n] = (unsigned char) c;
671 }
672
673 if (n > 0) {
674 ogroup[0]= dtable[igroup[0] >> 2];
675 ogroup[1]= dtable[((igroup[0] & 3) << 4) | (igroup[1] >> 4)];
676 ogroup[2]= dtable[((igroup[1] & 0xF) << 2) | (igroup[2] >> 6)];
677 ogroup[3]= dtable[igroup[2] & 0x3F];
678
679 if (n < 3) {
680 ogroup[3] = '=';
681
682 if (n < 2) {
683 ogroup[2] = '=';
684 }
685 }
686
687 for (i = 0; i < 4; i++) {
688 ochar(&bio, ogroup[i], outputfile, endl);
689 }
690 }
691 }
692
693 if (fputs(endl, outputfile) == EOF) {
694 return 0;
695 }
696
697 return 1;
698}
Structure used for base64 encoding.
Definition utils.c:577
static struct test_val c
static int inchar(struct baseio *bio, FILE *fi)
utility used by base_encode()
Definition utils.c:613
#define BASEMAXINLINE
Definition utils.c:574
static int ochar(struct baseio *bio, int c, FILE *so, const char *endl)
utility used by base_encode()
Definition utils.c:627

References BASEMAXINLINE, c, inchar(), baseio::iocp, and ochar().

Referenced by ast_base64_encode_file_path().

◆ ast_base64_encode_file_path()

int ast_base64_encode_file_path ( const char *  filename,
FILE *  outputfile,
const char *  endl 
)

Performs a base 64 encode algorithm on the contents of a File.

Parameters
filenameThe path to the file to be encoded. Must be readable, file is opened in read mode.
outputfileA FILE handle to the output file to receive the base 64 encoded contents of the input file, identified by filename.
endlThe line ending to use (e.g. either "\n" or "\r\n")
Returns
zero on success, -1 on error.

Definition at line 700 of file utils.c.

701{
702 FILE *fi;
703 int res;
704
705 if (!(fi = fopen(filename, "rb"))) {
706 ast_log(AST_LOG_WARNING, "Failed to open file: %s: %s\n", filename, strerror(errno));
707 return -1;
708 }
709
710 res = ast_base64_encode_file(fi, outputfile, endl);
711
712 fclose(fi);
713
714 return res;
715}
#define AST_LOG_WARNING
int ast_base64_encode_file(FILE *inputfile, FILE *outputfile, const char *endl)
Performs a base 64 encode algorithm on the contents of a File.
Definition utils.c:646

References ast_base64_encode_file(), ast_log, AST_LOG_WARNING, and errno.

Referenced by add_email_attachment(), and sendmail().

◆ ast_base64decode()

int ast_base64decode ( unsigned char *  dst,
const char *  src,
int  max 
)

decode BASE64 encoded text

Decode data from base64.

Definition at line 296 of file utils.c.

297{
298 int cnt = 0;
299 unsigned int byte = 0;
300 unsigned int bits = 0;
301 while(*src && *src != '=' && (cnt < max)) {
302 /* Shift in 6 bits of input */
303 byte <<= 6;
304 byte |= (b2a[(int)(*src)]) & 0x3f;
305 bits += 6;
306 src++;
307 /* If we have at least 8 bits left over, take that character
308 off the top */
309 if (bits >= 8) {
310 bits -= 8;
311 *dst = (byte >> bits) & 0xff;
312 dst++;
313 cnt++;
314 }
315 }
316 /* Don't worry about left over bits, they're extra anyway */
317 return cnt;
318}
#define max(a, b)
Definition f2c.h:198
static char b2a[256]
Definition utils.c:82

References b2a, and max.

Referenced by action_messagesend(), aes_helper(), ast_base64decode_string(), ast_check_signature(), ast_http_get_auth(), AST_TEST_DEFINE(), base64_helper(), crypto_init_keys(), custom_presence_callback(), presence_write(), and res_sdp_crypto_parse_offer().

◆ ast_base64decode_string()

char * ast_base64decode_string ( const char *  src)

Decode BASE64 encoded text and return the string.

Same as ast_base64decode, but does the math for you and returns a decoded string.

Definition at line 321 of file utils.c.

322{
323 size_t encoded_len;
324 size_t decoded_len;
325 int padding = 0;
326 unsigned char *decoded_string;
327
328 if (ast_strlen_zero(src)) {
329 return NULL;
330 }
331
332 encoded_len = strlen(src);
333 if (encoded_len > 2 && src[encoded_len - 1] == '=') {
334 padding++;
335 if (src[encoded_len - 2] == '=') {
336 padding++;
337 }
338 }
339
340 decoded_len = (encoded_len / 4 * 3) - padding;
341 decoded_string = ast_malloc(decoded_len + 1);
342 if (!decoded_string) {
343 return NULL;
344 }
345
346 ast_base64decode(decoded_string, src, decoded_len);
347 decoded_string[decoded_len] = '\0';
348
349 return (char *)decoded_string;
350}
#define ast_malloc(len)
A wrapper for malloc()
Definition astmm.h:191
#define NULL
Definition resample.c:96
static force_inline int attribute_pure ast_strlen_zero(const char *s)
Definition strings.h:65
int ast_base64decode(unsigned char *dst, const char *src, int max)
decode BASE64 encoded text
Definition utils.c:296

References ast_base64decode(), ast_malloc, ast_strlen_zero(), and NULL.

◆ ast_base64encode()

int ast_base64encode ( char *  dst,
const unsigned char *  src,
int  srclen,
int  max 
)

Encode data in base64.

Parameters
dstthe destination buffer
srcthe source data to be encoded
srclenthe number of bytes present in the source buffer
maxthe maximum number of bytes to write into the destination buffer, including the terminating NULL character.

Definition at line 404 of file utils.c.

405{
406 return ast_base64encode_full(dst, src, srclen, max, 0);
407}
int ast_base64encode_full(char *dst, const unsigned char *src, int srclen, int max, int linebreaks)
encode text to BASE64 coding
Definition utils.c:353

References ast_base64encode_full(), and max.

Referenced by aes_helper(), ast_base64encode_string(), ast_http_create_basic_auth_header(), ast_sign(), AST_TEST_DEFINE(), base64_helper(), build_secret(), crypto_init_keys(), presence_read(), websocket_client_create_key(), websocket_combine_key(), and xmpp_client_authenticate_sasl().

◆ ast_base64encode_full()

int ast_base64encode_full ( char *  dst,
const unsigned char *  src,
int  srclen,
int  max,
int  linebreaks 
)

encode text to BASE64 coding

Definition at line 353 of file utils.c.

354{
355 int cnt = 0;
356 int col = 0;
357 unsigned int byte = 0;
358 int bits = 0;
359 int cntin = 0;
360 /* Reserve space for null byte at end of string */
361 max--;
362 while ((cntin < srclen) && (cnt < max)) {
363 byte <<= 8;
364 byte |= *(src++);
365 bits += 8;
366 cntin++;
367 if ((bits == 24) && (cnt + 4 <= max)) {
368 *dst++ = base64[(byte >> 18) & 0x3f];
369 *dst++ = base64[(byte >> 12) & 0x3f];
370 *dst++ = base64[(byte >> 6) & 0x3f];
371 *dst++ = base64[byte & 0x3f];
372 cnt += 4;
373 col += 4;
374 bits = 0;
375 byte = 0;
376 }
377 if (linebreaks && (cnt < max) && (col == 64)) {
378 *dst++ = '\n';
379 cnt++;
380 col = 0;
381 }
382 }
383 if (bits && (cnt + 4 <= max)) {
384 /* Add one last character for the remaining bits,
385 padding the rest with 0 */
386 byte <<= 24 - bits;
387 *dst++ = base64[(byte >> 18) & 0x3f];
388 *dst++ = base64[(byte >> 12) & 0x3f];
389 if (bits == 16)
390 *dst++ = base64[(byte >> 6) & 0x3f];
391 else
392 *dst++ = '=';
393 *dst++ = '=';
394 cnt += 4;
395 }
396 if (linebreaks && (cnt < max)) {
397 *dst++ = '\n';
398 cnt++;
399 }
400 *dst = '\0';
401 return cnt;
402}
static char base64[64]
Definition utils.c:80

References base64, and max.

Referenced by ast_base64encode().

◆ ast_base64encode_string()

char * ast_base64encode_string ( const char *  src)

Encode to BASE64 and return encoded string.

Same as ast_base64encode, but does hte math for you and returns an encoded string.

Definition at line 410 of file utils.c.

411{
412 size_t encoded_len;
413 char *encoded_string;
414
415 if (ast_strlen_zero(src)) {
416 return NULL;
417 }
418
419 encoded_len = ((strlen(src) * 4 / 3 + 3) & ~3) + 1;
420 encoded_string = ast_calloc(1, encoded_len);
421
422 ast_base64encode(encoded_string, (const unsigned char *)src, strlen(src), encoded_len);
423
424 return encoded_string;
425}
#define ast_calloc(num, len)
A wrapper for calloc()
Definition astmm.h:202
int ast_base64encode(char *dst, const unsigned char *src, int srclen, int max)
Encode data in base64.
Definition utils.c:404

References ast_base64encode(), ast_calloc, ast_strlen_zero(), and NULL.

◆ ast_base64url_decode()

int ast_base64url_decode ( unsigned char *  dst,
const char *  src,
int  max 
)

Decode data from base64 URL.

Parameters
dstThe destination buffer
srcThe source buffer
maxThe 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 427 of file utils.c.

428{
429 int cnt = 0;
430 unsigned int byte = 0;
431 unsigned int bits = 0;
432
433 while (*src && (cnt < max)) {
434 byte <<= 6;
435 byte |= (b2a_url[(int)(*src)]) & 0x3f;
436 bits += 6;
437 src++;
438 if (bits >= 8) {
439 bits -= 8;
440 *dst = (byte >> bits) & 0xff;
441 dst++;
442 cnt++;
443 }
444 }
445 return cnt;
446}
static char b2a_url[256]
Definition utils.c:83

References b2a_url, and max.

Referenced by ast_base64url_decode_string().

◆ ast_base64url_decode_string()

char * ast_base64url_decode_string ( const char *  src)

Decode string from base64 URL.

Note
The returned string will need to be freed later
Parameters
srcThe source buffer
Return values
NULLon failure
Returns
Decoded string on success

Definition at line 448 of file utils.c.

449{
450 size_t decoded_len;
451 unsigned char *decoded_string;
452
453 if (ast_strlen_zero(src)) {
454 return NULL;
455 }
456
457 decoded_len = strlen(src) * 3 / 4;
458 decoded_string = ast_malloc(decoded_len + 1);
459 if (!decoded_string) {
460 return NULL;
461 }
462
463 ast_base64url_decode(decoded_string, src, decoded_len);
464 decoded_string[decoded_len] = '\0';
465
466 return (char *)decoded_string;
467}
int ast_base64url_decode(unsigned char *dst, const char *src, int max)
Decode data from base64 URL.
Definition utils.c:427

References ast_base64url_decode(), ast_malloc, ast_strlen_zero(), and NULL.

◆ ast_base64url_encode()

int ast_base64url_encode ( char *  dst,
const unsigned char *  src,
int  srclen,
int  max 
)

Encode data in base64 URL.

Parameters
dstThe destination buffer
srcThe source data to be encoded
srclenThe number of bytes present in the source buffer
maxThe maximum number of bytes to write into the destination buffer, including the terminating NULL character

Definition at line 516 of file utils.c.

517{
518 return ast_base64url_encode_full(dst, src, srclen, max, 0);
519}
int ast_base64url_encode_full(char *dst, const unsigned char *src, int srclen, int max, int linebreaks)
Same as ast_base64encode_full but for base64 URL.
Definition utils.c:469

References ast_base64url_encode_full(), and max.

Referenced by ast_base64url_encode_string().

◆ ast_base64url_encode_full()

int ast_base64url_encode_full ( char *  dst,
const unsigned char *  src,
int  srclen,
int  max,
int  linebreaks 
)

Same as ast_base64encode_full but for base64 URL.

Parameters
dstThe destination buffer
srcThe source buffer
srclenThe number of bytes present in the source buffer
maxThe maximum number of bytes to write into the destination buffer, including the terminating NULL character.
linebreaksSet to 1 if there should be linebreaks inserted in the result

Definition at line 469 of file utils.c.

470{
471 int cnt = 0;
472 int col = 0;
473 unsigned int byte = 0;
474 int bits = 0;
475 int cntin = 0;
476
477 max--;
478 while ((cntin < srclen) && (cnt < max)) {
479 byte <<= 8;
480 byte |= *(src++);
481 bits += 8;
482 cntin++;
483 if ((bits == 24) && (cnt + 4 <= max)) {
484 *dst++ = base64url[(byte >> 18) & 0x3f];
485 *dst++ = base64url[(byte >> 12) & 0x3f];
486 *dst++ = base64url[(byte >> 6) & 0x3f];
487 *dst++ = base64url[(byte) & 0x3f];
488 cnt += 4;
489 col += 4;
490 bits = 0;
491 byte = 0;
492 }
493 if (linebreaks && (cnt < max) && (col == 64)) {
494 *dst++ = '\n';
495 cnt++;
496 col = 0;
497 }
498 }
499 if (bits && (cnt + 4 <= max)) {
500 byte <<= 24 - bits;
501 *dst++ = base64url[(byte >> 18) & 0x3f];
502 *dst++ = base64url[(byte >> 12) & 0x3f];
503 if (bits == 16) {
504 *dst++ = base64url[(byte >> 6) & 0x3f];
505 }
506 cnt += 4;
507 }
508 if (linebreaks && (cnt < max)) {
509 *dst++ = '\n';
510 cnt++;
511 }
512 *dst = '\0';
513 return cnt;
514}
static char base64url[64]
Definition utils.c:81

References base64url, and max.

Referenced by ast_base64url_encode().

◆ ast_base64url_encode_string()

char * ast_base64url_encode_string ( const char *  src)

Encode string in base64 URL.

Note
The returned string will need to be freed later
Parameters
srcThe source data to be encoded
Return values
NULLon failure
Returns
Encoded string on success

Definition at line 521 of file utils.c.

522{
523 size_t encoded_len;
524 char *encoded_string;
525
526 if (ast_strlen_zero(src)) {
527 return NULL;
528 }
529
530 encoded_len = ((strlen(src) * 4 / 3 + 3) & ~3) + 1;
531 encoded_string = ast_malloc(encoded_len);
532
533 ast_base64url_encode(encoded_string, (const unsigned char *)src, strlen(src), encoded_len);
534
535 return encoded_string;
536}
int ast_base64url_encode(char *dst, const unsigned char *src, int srclen, int max)
Encode data in base64 URL.
Definition utils.c:516

References ast_base64url_encode(), ast_malloc, ast_strlen_zero(), and NULL.

◆ ast_build_string()

int ast_build_string ( char **  buffer,
size_t *  space,
const char *  fmt,
  ... 
)

Build a string in a buffer, designed to be called repeatedly.

Note
This method is not recommended. New code should use ast_str_*() instead.

This is a wrapper for snprintf, that properly handles the buffer pointer and buffer space available.

Parameters
buffercurrent position in buffer to place string into (will be updated on return)
spaceremaining space in buffer (will be updated on return)
fmtprintf-style format string
Return values
0on success
non-zeroon failure.

Definition at line 2201 of file utils.c.

2202{
2203 va_list ap;
2204 int result;
2205
2206 va_start(ap, fmt);
2207 result = ast_build_string_va(buffer, space, fmt, ap);
2208 va_end(ap);
2209
2210 return result;
2211}
static PGresult * result
Definition cel_pgsql.c:84
int ast_build_string_va(char **buffer, size_t *space, const char *fmt, va_list ap)
Build a string in a buffer, designed to be called repeatedly.
Definition utils.c:2182

References ast_build_string_va(), and result.

Referenced by ast_fax_caps_to_str(), generate_filenames_string(), handle_speechrecognize(), pp_each_extension_helper(), and pp_each_user_helper().

◆ ast_build_string_va()

int ast_build_string_va ( char **  buffer,
size_t *  space,
const char *  fmt,
va_list  ap 
)

Build a string in a buffer, designed to be called repeatedly.

This is a wrapper for snprintf, that properly handles the buffer pointer and buffer space available.

Return values
zeroon success.
non-zeroon failure.
Parameters
buffercurrent position in buffer to place string into (will be updated on return)
spaceremaining space in buffer (will be updated on return)
fmtprintf-style format string
apvarargs list of arguments for format

Definition at line 2182 of file utils.c.

2183{
2184 int result;
2185
2186 if (!buffer || !*buffer || !space || !*space)
2187 return -1;
2188
2189 result = vsnprintf(*buffer, *space, fmt, ap);
2190
2191 if (result < 0)
2192 return -1;
2193 else if (result > *space)
2194 result = *space;
2195
2196 *buffer += result;
2197 *space -= result;
2198 return 0;
2199}

References result.

Referenced by ast_build_string().

◆ ast_carefulwrite()

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.

Note
The code assumes that the file descriptor has NONBLOCK set, so there is only one system call made to do a write, unless we actually have a need to wait. This way, we get better performance. If the descriptor is blocking, all assumptions on the guaranteed detail do not apply anymore.

Definition at line 1805 of file utils.c.

1806{
1807 struct timeval start = ast_tvnow();
1808 int res = 0;
1809 int elapsed = 0;
1810
1811 while (len) {
1812 if (wait_for_output(fd, timeoutms - elapsed)) {
1813 return -1;
1814 }
1815
1816 res = write(fd, s, len);
1817
1818 if (res < 0 && errno != EAGAIN && errno != EINTR) {
1819 /* fatal error from write() */
1820 if (errno == EPIPE) {
1821#ifndef STANDALONE
1822 ast_debug(1, "write() failed due to reading end being closed: %s\n", strerror(errno));
1823#endif
1824 } else {
1825 ast_log(LOG_ERROR, "write() returned error: %s\n", strerror(errno));
1826 }
1827 return -1;
1828 }
1829
1830 if (res < 0) {
1831 /* It was an acceptable error */
1832 res = 0;
1833 }
1834
1835 /* Update how much data we have left to write */
1836 len -= res;
1837 s += res;
1838 res = 0;
1839
1840 elapsed = ast_tvdiff_ms(ast_tvnow(), start);
1841 if (elapsed >= timeoutms) {
1842 /* We've taken too long to write
1843 * This is only an error condition if we haven't finished writing. */
1844 res = len ? -1 : 0;
1845 break;
1846 }
1847 }
1848
1849 return res;
1850}
static int len(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t buflen)
#define ast_debug(level,...)
Log a DEBUG message.
#define LOG_ERROR
int64_t ast_tvdiff_ms(struct timeval end, struct timeval start)
Computes the difference (in milliseconds) between two struct timeval instances.
Definition time.h:107
struct timeval ast_tvnow(void)
Returns current timeval. Meant to replace calls to gettimeofday().
Definition time.h:159
static int wait_for_output(int fd, int timeoutms)
Definition utils.c:1752

References ast_debug, ast_log, ast_tvdiff_ms(), ast_tvnow(), errno, len(), LOG_ERROR, and wait_for_output().

Referenced by ast_agi_send(), ast_cli(), and cleanup_module().

◆ ast_check_command_in_path()

int ast_check_command_in_path ( const char *  cmd)

Test for the presence of an executable command in $PATH.

Parameters
cmdName of command to locate.
Return values
True(non-zero) if command is in $PATH.
False(zero) command not found.

Definition at line 3297 of file utils.c.

3298{
3299 char *token, *saveptr, *path = getenv("PATH");
3300 char filename[PATH_MAX];
3301 int len;
3302
3303 if (path == NULL) {
3304 return 0;
3305 }
3306
3307 path = ast_strdup(path);
3308 if (path == NULL) {
3309 return 0;
3310 }
3311
3312 token = strtok_r(path, ":", &saveptr);
3313 while (token != NULL) {
3314 len = snprintf(filename, sizeof(filename), "%s/%s", token, cmd);
3315 if (len < 0 || len >= sizeof(filename)) {
3316 ast_log(LOG_WARNING, "Path constructed with '%s' too long; skipping\n", token);
3317 continue;
3318 }
3319
3320 if (access(filename, X_OK) == 0) {
3321 ast_free(path);
3322 return 1;
3323 }
3324
3325 token = strtok_r(NULL, ":", &saveptr);
3326 }
3327 ast_free(path);
3328 return 0;
3329}
#define PATH_MAX
Definition asterisk.h:40
#define ast_free(a)
Definition astmm.h:180
#define ast_strdup(str)
A wrapper for strdup()
Definition astmm.h:241
#define LOG_WARNING

References ast_free, ast_log, ast_strdup, len(), LOG_WARNING, NULL, and PATH_MAX.

Referenced by AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), and AST_TEST_DEFINE().

◆ ast_check_ipv6()

int ast_check_ipv6 ( void  )

Test that an OS supports IPv6 Networking.

Since
13.14.0
Return values
True(non-zero) if the IPv6 supported.
False(zero) if the OS doesn't support IPv6.

Definition at line 2826 of file utils.c.

2827{
2828 int udp6_socket = socket(AF_INET6, SOCK_DGRAM, 0);
2829
2830 if (udp6_socket < 0) {
2831 return 0;
2832 }
2833
2834 close(udp6_socket);
2835 return 1;
2836}

Referenced by load_module(), and load_module().

◆ ast_compare_versions()

int ast_compare_versions ( const char *  version1,
const char *  version2 
)

Compare 2 major.minor.patch.extra version strings.

Since
13.7.0
Parameters
version1
version2
Return values
negativeif version 1 < version 2.
0if version 1 = version 2.
positiveif version 1 > version 2.

Definition at line 3158 of file utils.c.

3159{
3160 unsigned int major[2] = { 0 };
3161 unsigned int minor[2] = { 0 };
3162 unsigned int patch[2] = { 0 };
3163 unsigned int extra[2] = { 0 };
3164 int res;
3165
3166 sscanf(version1, "%u.%u.%u.%u", &major[0], &minor[0], &patch[0], &extra[0]);
3167 sscanf(version2, "%u.%u.%u.%u", &major[1], &minor[1], &patch[1], &extra[1]);
3168
3169 res = major[0] - major[1];
3170 if (res) {
3171 return res;
3172 }
3173 res = minor[0] - minor[1];
3174 if (res) {
3175 return res;
3176 }
3177 res = patch[0] - patch[1];
3178 if (res) {
3179 return res;
3180 }
3181 return extra[0] - extra[1];
3182}

Referenced by transport_apply().

◆ ast_do_crash()

void DO_CRASH_NORETURN ast_do_crash ( void  )

Force a crash if DO_CRASH is defined.

Note
If DO_CRASH is not defined then the function returns.

Definition at line 2838 of file utils.c.

2839{
2840#if defined(DO_CRASH)
2841 abort();
2842 /*
2843 * Just in case abort() doesn't work or something else super
2844 * silly, and for Qwell's amusement.
2845 */
2846 *((int *) 0) = 0;
2847#endif /* defined(DO_CRASH) */
2848}

Referenced by __ast_assert_failed().

◆ ast_eid_cmp()

int ast_eid_cmp ( const struct ast_eid eid1,
const struct ast_eid eid2 
)

◆ ast_eid_is_empty()

int ast_eid_is_empty ( const struct ast_eid eid)

Check if EID is empty.

Return values
1if the EID is empty
0otherwise
Since
13.12.0

Definition at line 3133 of file utils.c.

3134{
3135 struct ast_eid empty_eid;
3136
3137 memset(&empty_eid, 0, sizeof(empty_eid));
3138 return memcmp(eid, &empty_eid, sizeof(empty_eid)) ? 0 : 1;
3139}
static dundi_eid empty_eid
Definition pbx_dundi.c:223
An Entity ID is essentially a MAC address, brief and unique.
Definition utils.h:853
unsigned char eid[6]
Definition utils.h:854

References ast_eid::eid, and empty_eid.

Referenced by load_module(), load_module(), load_module(), and set_config().

◆ ast_eid_to_str()

char * ast_eid_to_str ( char *  s,
int  maxlen,
struct ast_eid eid 
)

Convert an EID to a string.

Since
1.6.1

Definition at line 2873 of file utils.c.

2874{
2875 int x;
2876 char *os = s;
2877 if (maxlen < 18) {
2878 if (s && (maxlen > 0)) {
2879 *s = '\0';
2880 }
2881 } else {
2882 for (x = 0; x < 5; x++) {
2883 sprintf(s, "%02hhx:", eid->eid[x]);
2884 s += 3;
2885 }
2886 sprintf(s, "%02hhx", eid->eid[5]);
2887 }
2888 return os;
2889}

References ast_eid::eid.

Referenced by app_send(), append_transaction(), ast_ari_asterisk_get_info(), ast_ari_asterisk_ping(), ast_set_default_eid(), ast_str_retrieve_variable(), AST_TEST_DEFINE(), asterisk_publication_send_refresh(), asterisk_publisher_devstate_cb(), asterisk_publisher_mwistate_cb(), bridges_scrape_cb(), build_peer(), build_transactions(), cache_lookup(), cache_lookup_internal(), channels_scrape_cb(), check_key(), complete_peer_helper(), cpg_deliver_cb(), 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_cache(), dundi_show_entityid(), dundi_show_hints(), dundi_show_peer(), dundi_show_peers(), dundi_show_requests(), endpoints_scrape_cb(), handle_command_response(), handle_show_settings(), populate_addr(), prometheus_config_post_apply(), publish_cluster_discovery_to_stasis_full(), publish_device_state_to_stasis(), publish_mwi_to_stasis(), publish_to_corosync(), register_request(), session_send_app_event(), session_send_or_queue(), update_key(), xmpp_pubsub_publish_device_state(), and xmpp_pubsub_publish_mwi().

◆ ast_enable_packet_fragmentation()

void ast_enable_packet_fragmentation ( int  sock)

Disable PMTU discovery on a socket.

Parameters
sockThe socket to manipulate

On Linux, UDP sockets default to sending packets with the Dont Fragment (DF) bit set. This is supposedly done to allow the application to do PMTU discovery, but Asterisk does not do this.

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 2503 of file utils.c.

2504{
2505#if defined(HAVE_IP_MTU_DISCOVER)
2506 int val = IP_PMTUDISC_DONT;
2507
2508 if (setsockopt(sock, IPPROTO_IP, IP_MTU_DISCOVER, &val, sizeof(val)))
2509 ast_log(LOG_WARNING, "Unable to disable PMTU discovery. Large UDP packets may fail to be delivered when sent from this socket.\n");
2510#endif /* HAVE_IP_MTU_DISCOVER */
2511}

References ast_log, and LOG_WARNING.

Referenced by ast_netsock_bindaddr().

◆ ast_escape()

char * ast_escape ( char *  dest,
const char *  s,
size_t  size,
const char *  to_escape 
)

Escape the 'to_escape' characters in the given string.

Note
The given output buffer will contain a truncated escaped version of the source string if the given buffer is not large enough.
Parameters
destthe escaped string
sthe source string to escape
sizeThe size of the destination buffer
to_escapean array of characters to escape
Returns
Pointer to the destination.

Definition at line 2068 of file utils.c.

2069{
2070 char *p;
2071 char *c;
2072
2073 if (!dest || !size) {
2074 return dest;
2075 }
2076 if (ast_strlen_zero(s)) {
2077 *dest = '\0';
2078 return dest;
2079 }
2080
2081 if (ast_strlen_zero(to_escape)) {
2082 ast_copy_string(dest, s, size);
2083 return dest;
2084 }
2085
2086 for (p = dest; *s && --size; ++s, ++p) {
2087 /* If in the list of characters to escape then escape it */
2088 if (strchr(to_escape, *s)) {
2089 if (!--size) {
2090 /* Not enough room left for the escape sequence. */
2091 break;
2092 }
2093
2094 /*
2095 * See if the character to escape is part of the standard escape
2096 * sequences. If so we'll have to use its mapped counterpart
2097 * otherwise just use the current character.
2098 */
2099 c = strchr(escape_sequences, *s);
2100 *p++ = '\\';
2102 } else {
2103 *p = *s;
2104 }
2105 }
2106 *p = '\0';
2107
2108 return dest;
2109}
void ast_copy_string(char *dst, const char *src, size_t size)
Size-limited null-terminating string copy.
Definition strings.h:425
char escape_sequences[]
Definition utils.c:2056
static char escape_sequences_map[]
Definition utils.c:2064

References ast_copy_string(), ast_strlen_zero(), c, escape_sequences, and escape_sequences_map.

Referenced by ast_escape_alloc().

◆ ast_escape_alloc()

char * ast_escape_alloc ( const char *  s,
const char *  to_escape 
)

Escape the 'to_escape' characters in the given string.

Note
Caller is responsible for freeing the returned string
Parameters
sthe source string to escape
to_escapean array of characters to escape
Returns
Pointer to the escaped string or NULL.

Definition at line 2166 of file utils.c.

2167{
2168 size_t size = 0;
2169 char *dest = escape_alloc(s, &size);
2170
2171 return ast_escape(dest, s, size, to_escape);
2172}
static char * escape_alloc(const char *s, size_t *size)
Definition utils.c:2152
char * ast_escape(char *dest, const char *s, size_t size, const char *to_escape)
Escape the 'to_escape' characters in the given string.
Definition utils.c:2068

References ast_escape(), and escape_alloc().

◆ ast_escape_c()

char * ast_escape_c ( char *  dest,
const char *  s,
size_t  size 
)

Escape standard 'C' sequences in the given string.

Note
The given output buffer will contain a truncated escaped version of the source string if the given buffer is not large enough.
Parameters
destthe escaped string
sthe source string to escape
sizeThe size of the destination buffer
Returns
Pointer to the escaped string.

Definition at line 2111 of file utils.c.

2112{
2113 /*
2114 * Note - This is an optimized version of ast_escape. When looking only
2115 * for escape_sequences a couple of checks used in the generic case can
2116 * be left out thus making it slightly more efficient.
2117 */
2118 char *p;
2119 char *c;
2120
2121 if (!dest || !size) {
2122 return dest;
2123 }
2124 if (ast_strlen_zero(s)) {
2125 *dest = '\0';
2126 return dest;
2127 }
2128
2129 for (p = dest; *s && --size; ++s, ++p) {
2130 /*
2131 * See if the character to escape is part of the standard escape
2132 * sequences. If so use its mapped counterpart.
2133 */
2134 c = strchr(escape_sequences, *s);
2135 if (c) {
2136 if (!--size) {
2137 /* Not enough room left for the escape sequence. */
2138 break;
2139 }
2140
2141 *p++ = '\\';
2143 } else {
2144 *p = *s;
2145 }
2146 }
2147 *p = '\0';
2148
2149 return dest;
2150}

References ast_strlen_zero(), c, escape_sequences, and escape_sequences_map.

Referenced by ast_escape_c_alloc().

◆ ast_escape_c_alloc()

char * ast_escape_c_alloc ( const char *  s)

Escape standard 'C' sequences in the given string.

Note
Caller is responsible for freeing the returned string
Parameters
sthe source string to escape
Returns
Pointer to the escaped string or NULL.

Definition at line 2174 of file utils.c.

2175{
2176 size_t size = 0;
2177 char *dest = escape_alloc(s, &size);
2178
2179 return ast_escape_c(dest, s, size);
2180}
char * ast_escape_c(char *dest, const char *s, size_t size)
Escape standard 'C' sequences in the given string.
Definition utils.c:2111

References ast_escape_c(), and escape_alloc().

Referenced by ast_manager_build_channel_state_string_prefix(), channel_new_callerid(), presence_state_to_ami(), and varset_to_ami().

◆ ast_escape_quoted()

char * ast_escape_quoted ( const char *  string,
char *  outbuf,
int  buflen 
)

Escape characters found in a quoted string.

Note
This function escapes quoted characters based on the 'qdtext' set of allowed characters from RFC 3261 section 25.1.
Parameters
stringstring to be escaped
outbufresulting escaped string
buflensize of output buffer
Returns
a pointer to the escaped string

Definition at line 815 of file utils.c.

816{
817 const char *ptr = string;
818 char *out = outbuf;
819 char *allow = "\t\v !"; /* allow LWS (minus \r and \n) and "!" */
820
821 while (*ptr && out - outbuf < buflen - 1) {
822 if (!(strchr(allow, *ptr))
823 && !(*ptr >= '#' && *ptr <= '[') /* %x23 - %x5b */
824 && !(*ptr >= ']' && *ptr <= '~') /* %x5d - %x7e */
825 && !((unsigned char) *ptr > 0x7f)) { /* UTF8-nonascii */
826
827 if (out - outbuf >= buflen - 2) {
828 break;
829 }
830 out += sprintf(out, "\\%c", (unsigned char) *ptr);
831 } else {
832 *out = *ptr;
833 out++;
834 }
835 ptr++;
836 }
837
838 if (buflen) {
839 *out = '\0';
840 }
841
842 return outbuf;
843}
const char * string
FILE * out
Definition utils/frame.c:33

References out, and string.

Referenced by ast_callerid_merge(), ast_sip_modify_id_header(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), channel_read_pjsip(), create_new_id_hdr(), print_escaped_uri(), and refer_send().

◆ ast_escape_semicolons()

char * ast_escape_semicolons ( const char *  string,
char *  outbuf,
int  buflen 
)

Escape semicolons found in a string.

Parameters
stringstring to be escaped
outbufresulting escaped string
buflensize of output buffer
Returns
a pointer to the escaped string

Definition at line 845 of file utils.c.

846{
847 const char *ptr = string;
848 char *out = outbuf;
849
850 if (string == NULL || outbuf == NULL) {
851 ast_assert(string != NULL && outbuf != NULL);
852 return NULL;
853 }
854
855 while (*ptr && out - outbuf < buflen - 1) {
856 if (*ptr == ';') {
857 if (out - outbuf >= buflen - 2) {
858 break;
859 }
860 strcpy(out, "\\;");
861 out += 2;
862 } else {
863 *out = *ptr;
864 out++;
865 }
866 ptr++;
867 }
868
869 if (buflen) {
870 *out = '\0';
871 }
872
873 return outbuf;
874}

References ast_assert, NULL, out, and string.

Referenced by ast_config_text_file_save2(), handle_cli_dialplan_save(), and test_semi().

◆ ast_false()

int ast_false ( const char *  val)

Make sure something is false. Determine if a string containing a boolean value is "false". This function checks to see whether a string passed to it is an indication of an "false" value. It checks to see if the string is "no", "false", "n", "f", "off" or "0".

Return values
-1if "true".
0otherwise, like NUL pointer.

Definition at line 2250 of file utils.c.

2251{
2252 if (ast_strlen_zero(s))
2253 return 0;
2254
2255 /* Determine if this is a false value */
2256 if (!strcasecmp(s, "no") ||
2257 !strcasecmp(s, "false") ||
2258 !strcasecmp(s, "n") ||
2259 !strcasecmp(s, "f") ||
2260 !strcasecmp(s, "0") ||
2261 !strcasecmp(s, "off"))
2262 return -1;
2263
2264 return 0;
2265}

References ast_strlen_zero().

Referenced by acf_faxopt_write(), acf_transaction_write(), action_updateconfig(), actual_load_config(), announce_user_count_all_handler(), aoc_cli_debug_enable(), bool_handler_fn(), boolflag_handler_fn(), build_peer(), build_peer(), build_user(), build_user(), check_debug(), dahdi_set_dnd(), dahdi_set_mwi(), find_realtime(), function_ooh323_write(), handle_queue_set_member_ringinuse(), hook_write(), init_acf_query(), load_config(), manager_mute_mixmonitor(), manager_queue_member_ringinuse(), parking_feature_flag_cfg(), parse_empty_options(), parse_playtone(), prack_handler(), process_config(), process_config(), process_dahdi(), read_pjproject_startup_options(), reload_config(), reload_single_member(), rt_handle_member_record(), rtp_reload(), run_agi(), set_config(), sla_build_trunk(), strings_to_mask(), and timers_handler().

◆ ast_file_is_readable()

int ast_file_is_readable ( const char *  filename)

Test that a file exists and is readable by the effective user.

Since
13.7.0
Parameters
filenameFile to test.
Return values
True(non-zero) if the file exists and is readable.
False(zero) if the file either doesn't exists or is not readable.

Definition at line 3141 of file utils.c.

3142{
3143#if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
3144#if defined(HAVE_EUIDACCESS) && !defined(HAVE_EACCESS)
3145#define eaccess euidaccess
3146#endif
3147 return eaccess(filename, R_OK) == 0;
3148#else
3149 int fd = open(filename, O_RDONLY | O_NONBLOCK);
3150 if (fd < 0) {
3151 return 0;
3152 }
3153 close(fd);
3154 return 1;
3155#endif
3156}
#define R_OK

References R_OK.

Referenced by add_email_attachment(), as_check_common_config(), ast_media_cache_retrieve(), ast_rtp_dtls_cfg_parse(), retrieve_cert_from_cache(), transport_tls_file_handler(), and vs_check_common_config().

◆ ast_format_duration_hh_mm_ss()

void ast_format_duration_hh_mm_ss ( int  duration,
char *  buf,
size_t  length 
)

Formats a duration into HH:MM:SS.

Since
12
Parameters
durationThe time (in seconds) to format
bufA buffer to hold the formatted string'
lengthThe size of the buffer

Definition at line 2331 of file utils.c.

2332{
2333 int durh, durm, durs;
2334 durh = duration / 3600;
2335 durm = (duration % 3600) / 60;
2336 durs = duration % 60;
2337 snprintf(buf, length, "%02d:%02d:%02d", durh, durm, durs);
2338}
char buf[BUFSIZE]
Definition eagi_proxy.c:66

References buf.

Referenced by cli_channel_print_body(), cli_channelstats_print_body(), handle_bridge_show_all(), handle_bridge_show_specific(), and stasis_show_topic().

◆ ast_get_tid()

int ast_get_tid ( void  )

Get current thread ID.

Returns
the ID if platform is supported, else -1

Definition at line 2786 of file utils.c.

2787{
2788 int ret = -1;
2789#if defined (__linux) && defined(SYS_gettid)
2790 ret = syscall(SYS_gettid); /* available since Linux 1.4.11 */
2791#elif defined(__sun)
2792 ret = pthread_self();
2793#elif defined(__APPLE__)
2794 ret = mach_thread_self();
2795 mach_port_deallocate(mach_task_self(), ret);
2796#elif defined(__FreeBSD__)
2797 long lwpid;
2798 thr_self(&lwpid);
2799 ret = lwpid;
2800#elif defined(__NetBSD__)
2801 ret = _lwp_self();
2802#elif defined(__OpenBSD__)
2803 ret = getthrid();
2804#endif
2805 return ret;
2806}

Referenced by __ao2_ref(), ast_hangup(), ast_register_thread(), dummy_start(), format_log_message_ap(), and internal_ao2_alloc().

◆ ast_get_time_t()

int ast_get_time_t ( const char *  src,
time_t *  dst,
time_t  _default,
int *  consumed 
)

get values from config variables.

Parse a time (integer) string.

Definition at line 2480 of file utils.c.

2481{
2482 long t;
2483 int scanned;
2484
2485 if (dst == NULL)
2486 return -1;
2487
2488 *dst = _default;
2489
2490 if (ast_strlen_zero(src))
2491 return -1;
2492
2493 /* only integer at the moment, but one day we could accept more formats */
2494 if (sscanf(src, "%30ld%n", &t, &scanned) == 1) {
2495 *dst = t;
2496 if (consumed)
2497 *consumed = scanned;
2498 return 0;
2499 } else
2500 return -1;
2501}

References ast_strlen_zero(), and NULL.

Referenced by cache_lookup_internal(), dundi_show_cache(), dundi_show_hints(), handle_saydatetime(), load_password(), play_message_datetime(), process_clearcache(), realtime_peer(), and sayunixtime_exec().

◆ ast_get_timeval()

int ast_get_timeval ( const char *  src,
struct timeval *  dst,
struct timeval  _default,
int *  consumed 
)

get values from config variables.

Parse a time (float) string.

Definition at line 2453 of file utils.c.

2454{
2455 long double dtv = 0.0;
2456 int scanned;
2457
2458 if (dst == NULL)
2459 return -1;
2460
2461 *dst = _default;
2462
2463 if (ast_strlen_zero(src))
2464 return -1;
2465
2466 /* only integer at the moment, but one day we could accept more formats */
2467 if (sscanf(src, "%30Lf%n", &dtv, &scanned) > 0) {
2468 dst->tv_sec = dtv;
2469 dst->tv_usec = (dtv - dst->tv_sec) * 1000000.0;
2470 if (consumed)
2471 *consumed = scanned;
2472 return 0;
2473 } else
2474 return -1;
2475}

References ast_strlen_zero(), and NULL.

Referenced by acf_strftime(), expiration_str2struct(), persistence_expires_str2struct(), and timeval_str2struct().

◆ ast_gethostbyname()

struct hostent * ast_gethostbyname ( const char *  host,
struct ast_hostent hp 
)

Re-entrant (thread safe) version of gethostbyname that replaces the standard gethostbyname (which is not thread safe)

Thread-safe gethostbyname function to use in Asterisk.

Definition at line 199 of file utils.c.

200{
201#ifndef HAVE_GETHOSTBYNAME_R_5
202 int res;
203#endif
204 int herrno;
205 int dots = 0;
206 const char *s;
207 struct hostent *result = NULL;
208 /* Although it is perfectly legitimate to lookup a pure integer, for
209 the sake of the sanity of people who like to name their peers as
210 integers, we break with tradition and refuse to look up a
211 pure integer */
212 s = host;
213 while (s && *s) {
214 if (*s == '.')
215 dots++;
216 else if (!isdigit(*s))
217 break;
218 s++;
219 }
220 if (!s || !*s) {
221 /* Forge a reply for IP's to avoid octal IP's being interpreted as octal */
222 if (dots != 3)
223 return NULL;
224 memset(hp, 0, sizeof(struct ast_hostent));
225 hp->hp.h_addrtype = AF_INET;
226 hp->hp.h_addr_list = (void *) hp->buf;
227 hp->hp.h_addr = hp->buf + sizeof(void *);
228 /* For AF_INET, this will always be 4 */
229 hp->hp.h_length = 4;
230 if (inet_pton(AF_INET, host, hp->hp.h_addr) > 0)
231 return &hp->hp;
232 return NULL;
233
234 }
235#ifdef HAVE_GETHOSTBYNAME_R_5
236 result = gethostbyname_r(host, &hp->hp, hp->buf, sizeof(hp->buf), &herrno);
237
238 if (!result || !hp->hp.h_addr_list || !hp->hp.h_addr_list[0])
239 return NULL;
240#else
241 res = gethostbyname_r(host, &hp->hp, hp->buf, sizeof(hp->buf), &result, &herrno);
242
243 if (res || !result || !hp->hp.h_addr_list || !hp->hp.h_addr_list[0])
244 return NULL;
245#endif
246 return &hp->hp;
247}
char buf[1024]
Definition utils.h:231
struct hostent hp
Definition utils.h:230

References ast_hostent::buf, ast_hostent::hp, NULL, and result.

◆ ast_inet_ntoa()

const char * ast_inet_ntoa ( struct in_addr  ia)

ast_inet_ntoa: Recursive thread safe replacement of inet_ntoa

thread-safe replacement for inet_ntoa().

Definition at line 962 of file utils.c.

963{
964 char *buf;
965
966 if (!(buf = ast_threadstorage_get(&inet_ntoa_buf, INET_ADDRSTRLEN)))
967 return "";
968
969 return inet_ntop(AF_INET, &ia, buf, INET_ADDRSTRLEN);
970}
void * ast_threadstorage_get(struct ast_threadstorage *ts, size_t init_size)
Retrieve thread storage.

References ast_threadstorage_get(), and buf.

Referenced by _stun_show_status(), ast_parse_arg(), create_client(), get_defaults(), get_to_address(), handle_cli_rtp_settings(), handle_error(), handle_stun_timeout(), iax_server(), parsing(), phoneprov_callback(), process_request(), reload_config(), rtp_reload(), score_address(), send_raw_client(), send_start_rtp(), send_trunk(), show_main_page(), start_rtp(), stun_monitor_request(), unistim_show_devices(), unistim_show_info(), and unistimsock_read().

◆ ast_join_delim()

void ast_join_delim ( char *  s,
size_t  len,
const char *const  w[],
unsigned int  size,
char  delim 
)

Join an array of strings into a single string.

Parameters
sthe resulting string buffer
lenthe length of the result buffer, s
wan array of strings to join.
sizethe number of elements to join
delimdelimiter between elements

This function will join all of the strings in the array 'w' into a single string. It will also place 'delim' in the result buffer in between each string from 'w'.

Since
12

Definition at line 2412 of file utils.c.

2413{
2414 int x, ofs = 0;
2415 const char *src;
2416
2417 /* Join words into a string */
2418 if (!s)
2419 return;
2420 for (x = 0; ofs < len && x < size && w[x] ; x++) {
2421 if (x > 0)
2422 s[ofs++] = delim;
2423 for (src = w[x]; *src && ofs < len; src++)
2424 s[ofs++] = *src;
2425 }
2426 if (ofs == len)
2427 ofs--;
2428 s[ofs] = '\0';
2429}

References len().

Referenced by ast_sip_auths_to_str().

◆ ast_md5_hash()

void ast_md5_hash ( char *  output,
const char *  input 
)

Produce 32 char MD5 hash of value.

Produces MD5 hash based on input string.

Definition at line 250 of file utils.c.

251{
252 struct MD5Context md5;
253 unsigned char digest[16];
254 char *ptr;
255 int x;
256
257 MD5Init(&md5);
258 MD5Update(&md5, (const unsigned char *) input, strlen(input));
259 MD5Final(digest, &md5);
260 ptr = output;
261 for (x = 0; x < 16; x++)
262 ptr += sprintf(ptr, "%02hhx", digest[x]);
263}
static int md5(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)
Definition func_md5.c:55
void MD5Update(struct MD5Context *context, unsigned char const *buf, unsigned len)
Definition md5.c:72
void MD5Init(struct MD5Context *context)
Definition md5.c:57
void MD5Final(unsigned char digest[MD5_DIGEST_LENGTH], struct MD5Context *context)
Definition md5.c:120

References md5(), MD5Final(), MD5Init(), and MD5Update().

Referenced by __init_manager(), ast_sip_location_create_contact(), AST_TEST_DEFINE(), auth_exec(), auth_http_callback(), build_nonce(), md5(), and permanent_uri_handler().

◆ ast_mkdir()

int ast_mkdir ( const char *  path,
int  mode 
)

Recursively create directory path.

Parameters
pathThe directory path to create
modeThe permissions with which to try to create the directory
Return values
0on success
Returns
error code otherwise

Creates a directory path, creating parent directories as needed.

Definition at line 2513 of file utils.c.

2514{
2515 char *ptr;
2516 int len = strlen(path), count = 0, x, piececount = 0;
2517 char *tmp = ast_strdupa(path);
2518 char **pieces;
2519 char *fullpath = ast_alloca(len + 1);
2520 int res = 0;
2521
2522 for (ptr = tmp; *ptr; ptr++) {
2523 if (*ptr == '/')
2524 count++;
2525 }
2526
2527 /* Count the components to the directory path */
2528 pieces = ast_alloca(count * sizeof(*pieces));
2529 for (ptr = tmp; *ptr; ptr++) {
2530 if (*ptr == '/') {
2531 *ptr = '\0';
2532 pieces[piececount++] = ptr + 1;
2533 }
2534 }
2535
2536 *fullpath = '\0';
2537 for (x = 0; x < piececount; x++) {
2538 /* This looks funky, but the buffer is always ideally-sized, so it's fine. */
2539 strcat(fullpath, "/");
2540 strcat(fullpath, pieces[x]);
2541 res = mkdir(fullpath, mode);
2542 if (res && errno != EEXIST)
2543 return errno;
2544 }
2545 return 0;
2546}
#define ast_alloca(size)
call __builtin_alloca to ensure we get gcc builtin semantics
Definition astmm.h:288
#define ast_strdupa(s)
duplicate a string in memory from the stack
Definition astmm.h:298

References ast_alloca, ast_strdupa, errno, and len().

Referenced by ast_file_fdtemp(), ast_logger_rotate_channel(), conf_rec_name(), conf_run(), create_destination_directory(), create_dirpath(), create_dirpath(), dictate_exec(), filename_parse(), filename_parse(), init_logger(), load_module(), reload_logger(), remove_from_queue(), setup_privacy_args(), sms_nextoutgoing(), sms_writefile(), test_vm_api_create_voicemail_folder(), testclient_exec(), testserver_exec(), and write_history().

◆ ast_parse_digest()

int ast_parse_digest ( const char *  digest,
struct ast_http_digest d,
int  request,
int  pedantic 
)

Parse digest authorization header.

Returns
Returns -1 if we have no auth or something wrong with digest.
Note
This function may be used for Digest request and response header. request arg is set to nonzero, if we parse Digest Request. pedantic arg can be set to nonzero if we need to do addition Digest check.

Definition at line 2672 of file utils.c.

2672 {
2673 char *c;
2674 struct ast_str *str = ast_str_create(16);
2675
2676 /* table of recognised keywords, and places where they should be copied */
2677 const struct x {
2678 const char *key;
2679 const ast_string_field *field;
2680 } *i, keys[] = {
2681 { "username=", &d->username },
2682 { "realm=", &d->realm },
2683 { "nonce=", &d->nonce },
2684 { "uri=", &d->uri },
2685 { "domain=", &d->domain },
2686 { "response=", &d->response },
2687 { "cnonce=", &d->cnonce },
2688 { "opaque=", &d->opaque },
2689 /* Special cases that cannot be directly copied */
2690 { "algorithm=", NULL },
2691 { "qop=", NULL },
2692 { "nc=", NULL },
2693 { NULL, 0 },
2694 };
2695
2696 if (ast_strlen_zero(digest) || !d || !str) {
2697 ast_free(str);
2698 return -1;
2699 }
2700
2701 ast_str_set(&str, 0, "%s", digest);
2702
2704
2705 if (strncasecmp(c, "Digest ", strlen("Digest "))) {
2706 ast_log(LOG_WARNING, "Missing Digest.\n");
2707 ast_free(str);
2708 return -1;
2709 }
2710 c += strlen("Digest ");
2711
2712 /* lookup for keys/value pair */
2713 while (c && *c && *(c = ast_skip_blanks(c))) {
2714 /* find key */
2715 for (i = keys; i->key != NULL; i++) {
2716 char *src, *separator;
2717 int unescape = 0;
2718 if (strncasecmp(c, i->key, strlen(i->key)) != 0) {
2719 continue;
2720 }
2721
2722 /* Found. Skip keyword, take text in quotes or up to the separator. */
2723 c += strlen(i->key);
2724 if (*c == '"') {
2725 src = ++c;
2726 separator = "\"";
2727 unescape = 1;
2728 } else {
2729 src = c;
2730 separator = ",";
2731 }
2732 strsep(&c, separator); /* clear separator and move ptr */
2733 if (unescape) {
2734 ast_unescape_c(src);
2735 }
2736 if (i->field) {
2737 ast_string_field_ptr_set(d, i->field, src);
2738 } else {
2739 /* Special cases that require additional processing */
2740 if (!strcasecmp(i->key, "algorithm=")) {
2741 if (strcasecmp(src, "MD5")) {
2742 ast_log(LOG_WARNING, "Digest algorithm: \"%s\" not supported.\n", src);
2743 ast_free(str);
2744 return -1;
2745 }
2746 } else if (!strcasecmp(i->key, "qop=") && !strcasecmp(src, "auth")) {
2747 d->qop = 1;
2748 } else if (!strcasecmp(i->key, "nc=")) {
2749 unsigned long u;
2750 if (sscanf(src, "%30lx", &u) != 1) {
2751 ast_log(LOG_WARNING, "Incorrect Digest nc value: \"%s\".\n", src);
2752 ast_free(str);
2753 return -1;
2754 }
2755 ast_string_field_set(d, nc, src);
2756 }
2757 }
2758 break;
2759 }
2760 if (i->key == NULL) { /* not found, try ',' */
2761 strsep(&c, ",");
2762 }
2763 }
2764 ast_free(str);
2765
2766 /* Digest checkout */
2767 if (ast_strlen_zero(d->realm) || ast_strlen_zero(d->nonce)) {
2768 /* "realm" and "nonce" MUST be always exist */
2769 return -1;
2770 }
2771
2772 if (!request) {
2773 /* Additional check for Digest response */
2774 if (ast_strlen_zero(d->username) || ast_strlen_zero(d->uri) || ast_strlen_zero(d->response)) {
2775 return -1;
2776 }
2777
2778 if (pedantic && d->qop && (ast_strlen_zero(d->cnonce) || ast_strlen_zero(d->nc))) {
2779 return -1;
2780 }
2781 }
2782
2783 return 0;
2784}
const char * str
Definition app_jack.c:150
char * strsep(char **str, const char *delims)
static int request(void *obj)
#define ast_string_field_set(x, field, data)
Set a field to a simple string value.
const char * ast_string_field
#define ast_string_field_ptr_set(x, ptr, data)
Set a field to a simple string value.
#define ast_str_create(init_len)
Create a malloc'ed dynamic length string.
Definition strings.h:659
int ast_str_set(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Set a dynamic string using variable arguments.
Definition strings.h:1113
char *attribute_pure ast_str_buffer(const struct ast_str *buf)
Returns the string buffer within the ast_str buf.
Definition strings.h:761
char *attribute_pure ast_skip_blanks(const char *str)
Gets a pointer to the first non-whitespace character in a string.
Definition strings.h:161
Support for dynamic strings.
Definition strings.h:623
static struct test_val d
char * ast_unescape_c(char *src)
Convert some C escape sequences.
Definition utils.c:2017

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(), c, d, LOG_WARNING, NULL, request(), str, and strsep().

Referenced by auth_http_callback().

◆ ast_process_quotes_and_slashes()

char * ast_process_quotes_and_slashes ( char *  start,
char  find,
char  replace_with 
)

Process a string to find and replace characters.

Parameters
startThe string to analyze
findThe character to find
replace_withThe character that will replace the one we are looking for

Definition at line 2386 of file utils.c.

2387{
2388 char *dataPut = start;
2389 int inEscape = 0;
2390 int inQuotes = 0;
2391
2392 for (; *start; start++) {
2393 if (inEscape) {
2394 *dataPut++ = *start; /* Always goes verbatim */
2395 inEscape = 0;
2396 } else {
2397 if (*start == '\\') {
2398 inEscape = 1; /* Do not copy \ into the data */
2399 } else if (*start == '\'') {
2400 inQuotes = 1 - inQuotes; /* Do not copy ' into the data */
2401 } else {
2402 /* Replace , with |, unless in quotes */
2403 *dataPut++ = inQuotes ? *start : ((*start == find) ? replace_with : *start);
2404 }
2405 }
2406 }
2407 if (start != dataPut)
2408 *dataPut = 0;
2409 return dataPut;
2410}

◆ ast_pthread_create_detached_stack()

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 1707 of file utils.c.

1710{
1711 unsigned char attr_destroy = 0;
1712 int res;
1713
1714 if (!attr) {
1715 attr = ast_alloca(sizeof(*attr));
1716 pthread_attr_init(attr);
1717 attr_destroy = 1;
1718 }
1719
1720 if ((errno = pthread_attr_setdetachstate(attr, PTHREAD_CREATE_DETACHED)))
1721 ast_log(LOG_WARNING, "pthread_attr_setdetachstate: %s\n", strerror(errno));
1722
1723 res = ast_pthread_create_stack(thread, attr, start_routine, data,
1724 stacksize, file, caller, line, start_fn);
1725
1726 if (attr_destroy)
1727 pthread_attr_destroy(attr);
1728
1729 return res;
1730}
pthread_t thread
Definition app_sla.c:335
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)
Definition utils.c:1659

References ast_alloca, ast_log, ast_pthread_create_stack(), thr_arg::data, errno, LOG_WARNING, thr_arg::start_routine, and thread.

◆ ast_pthread_create_stack()

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 1659 of file utils.c.

1662{
1663#if !defined(LOW_MEMORY)
1664 struct thr_arg *a;
1665#endif
1666
1667 if (!attr) {
1668 attr = ast_alloca(sizeof(*attr));
1669 pthread_attr_init(attr);
1670 }
1671
1672#if defined(__linux__) || defined(__FreeBSD__)
1673 /* On Linux and FreeBSD , pthread_attr_init() defaults to PTHREAD_EXPLICIT_SCHED,
1674 which is kind of useless. Change this here to
1675 PTHREAD_INHERIT_SCHED; that way the -p option to set realtime
1676 priority will propagate down to new threads by default.
1677 This does mean that callers cannot set a different priority using
1678 PTHREAD_EXPLICIT_SCHED in the attr argument; instead they must set
1679 the priority afterwards with pthread_setschedparam(). */
1680 if ((errno = pthread_attr_setinheritsched(attr, PTHREAD_INHERIT_SCHED)))
1681 ast_log(LOG_WARNING, "pthread_attr_setinheritsched: %s\n", strerror(errno));
1682#endif
1683
1684 if (!stacksize)
1685 stacksize = AST_STACKSIZE;
1686
1687 if ((errno = pthread_attr_setstacksize(attr, stacksize ? stacksize : AST_STACKSIZE)))
1688 ast_log(LOG_WARNING, "pthread_attr_setstacksize: %s\n", strerror(errno));
1689
1690#if !defined(LOW_MEMORY)
1691 if ((a = ast_malloc(sizeof(*a)))) {
1692 a->start_routine = start_routine;
1693 a->data = data;
1695 if (ast_asprintf(&a->name, "%-20s started at [%5d] %s %s()",
1696 start_fn, line, file, caller) < 0) {
1697 a->name = NULL;
1698 }
1699 data = a;
1700 }
1701#endif /* !LOW_MEMORY */
1702
1703 return pthread_create(thread, attr, start_routine, data); /* We're in ast_pthread_create, so it's okay */
1704}
#define ast_asprintf(ret, fmt,...)
A wrapper for asprintf()
Definition astmm.h:267
#define pthread_create
Definition lock.h:649
const char * name
void * data
Definition utils.c:1596
void *(* start_routine)(void *)
Definition utils.c:1595
static struct test_val a
static void * dummy_start(void *data)
Definition utils.c:1607

References a, ast_alloca, ast_asprintf, ast_log, ast_malloc, AST_STACKSIZE, thr_arg::data, dummy_start(), errno, LOG_WARNING, test_val::name, NULL, pthread_create, thr_arg::start_routine, and thread.

Referenced by ast_pthread_create_detached_stack().

◆ ast_random()

long int ast_random ( void  )

Definition at line 2346 of file utils.c.

2347{
2348 long int res;
2349
2350 if (dev_urandom_fd >= 0) {
2351 int read_res = read(dev_urandom_fd, &res, sizeof(res));
2352 if (read_res > 0) {
2353 long int rm = RAND_MAX;
2354 res = res < 0 ? ~res : res;
2355 rm++;
2356 return res % rm;
2357 }
2358 }
2359
2360 /* XXX - Thread safety really depends on the libc, not the OS.
2361 *
2362 * But... popular Linux libc's (uClibc, glibc, eglibc), all have a
2363 * somewhat thread safe random(3) (results are random, but not
2364 * reproducible). The libc's for other systems (BSD, et al.), not so
2365 * much.
2366 */
2367#ifdef linux
2368 res = random();
2369#else
2371 res = random();
2373#endif
2374 return res;
2375}
#define ast_mutex_unlock(a)
Definition lock.h:197
#define ast_mutex_lock(a)
Definition lock.h:196
static int dev_urandom_fd
Definition utils.c:972
static ast_mutex_t randomlock
Definition utils.c:2343

References ast_mutex_lock, ast_mutex_unlock, dev_urandom_fd, and randomlock.

Referenced by acf_rand_exec(), action_challenge(), agi_handle_command(), app_exec(), ast_generate_random_string(), ast_lock_path_lockfile(), ast_rtp_change_source(), ast_rtp_new(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), ast_udptl_new_with_bindaddr(), astobj2_test_1_helper(), auth_http_callback(), authenticate_request(), build_iv(), build_rand_pad(), calc_metric(), calc_rxstamp(), caldav_write_event(), create_channel_name(), create_local_sdp(), dns_srv_sort(), generate_parked_user(), generate_random_string(), generic_http_callback(), get_trans_id(), get_unused_callno(), handle_cli_sched_bench(), iax2_key_rotate(), jingle_add_ice_udp_candidates_to_transport(), jingle_alloc(), jingle_new(), load_module(), make_email_file(), mbl_new(), moh_files_alloc(), moh_files_next(), multicast_rtp_new(), ogg_vorbis_rewrite(), page_exec(), process_weights(), registry_authrequest(), reschedule_reinvite(), rtp_allocate_transport(), say_periodic_announcement(), sendmail(), sip_outbound_registration_perform(), socket_read(), sorcery_memory_cache_thrash_retrieve(), sorcery_memory_cache_thrash_update(), stun_req_id(), test_ao2_find_w_no_flags(), test_ao2_find_w_OBJ_KEY(), test_ao2_find_w_OBJ_PARTIAL_KEY(), test_ao2_find_w_OBJ_POINTER(), test_files_get_one(), try_firmware(), websocket_client_create_key(), and websocket_mask_payload().

◆ ast_regex_string_to_regex_pattern()

int ast_regex_string_to_regex_pattern ( const char *  regex_string,
struct ast_str **  regex_pattern 
)

Given a string regex_string in the form of "/regex/", convert it into the form of "regex".

This function will trim one leading / and one trailing / from a given input string ast_str regex_pattern must be preallocated before calling this function

Return values
0on success, non-zero on failure.
1if we only stripped a leading /
2if we only stripped a trailing /
3if we did not strip any / characters
Parameters
regex_stringthe string containing /regex/
regex_patternthe destination ast_str which will contain "regex" after execution

Definition at line 2213 of file utils.c.

2214{
2215 int regex_len = strlen(regex_string);
2216 int ret = 3;
2217
2218 /* Chop off the leading / if there is one */
2219 if ((regex_len >= 1) && (regex_string[0] == '/')) {
2220 ast_str_set(regex_pattern, 0, "%s", regex_string + 1);
2221 ret -= 2;
2222 }
2223
2224 /* Chop off the ending / if there is one */
2225 if ((regex_len > 1) && (regex_string[regex_len - 1] == '/')) {
2226 ast_str_truncate(*regex_pattern, -1);
2227 ret -= 1;
2228 }
2229
2230 return ret;
2231}
char * ast_str_truncate(struct ast_str *buf, ssize_t len)
Truncates the enclosed string to the given length.
Definition strings.h:786

References ast_str_set(), and ast_str_truncate().

Referenced by ast_manager_hangup_helper(), mwi_mailbox_delete(), and mwi_mailbox_get().

◆ ast_remaining_ms()

int ast_remaining_ms ( struct timeval  start,
int  max_ms 
)

Calculate remaining milliseconds given a starting timestamp and upper bound.

If the upper bound is negative, then this indicates that there is no upper bound on the amount of time to wait. This will result in a negative return.

Parameters
startWhen timing started being calculated
max_msThe maximum number of milliseconds to wait from start. May be negative.
Returns
The number of milliseconds left to wait for. May be negative.

Definition at line 2315 of file utils.c.

2316{
2317 int ms;
2318
2319 if (max_ms < 0) {
2320 ms = max_ms;
2321 } else {
2322 ms = max_ms - ast_tvdiff_ms(ast_tvnow(), start);
2323 if (ms < 0) {
2324 ms = 0;
2325 }
2326 }
2327
2328 return ms;
2329}

References ast_tvdiff_ms(), and ast_tvnow().

Referenced by __analog_ss_thread(), __ast_answer(), __ast_request_and_dial(), analog_ss_thread(), ast_iostream_write(), ast_recvtext(), ast_stun_request(), ast_waitfordigit_full(), disable_t38(), generic_fax_exec(), iostream_read(), parking_set_duration(), read_mf_digits(), read_sf_digits(), receivefax_t38_init(), record_exec(), safe_sleep_conditional(), scan_exec(), sendfax_t38_init(), SLEEP_SPINNER(), wait_exec(), wait_for_answer(), wait_for_answer(), wait_for_signal_or_hangup(), waitforcond_exec(), and waitforring_exec().

◆ ast_replace_subargument_delimiter()

void ast_replace_subargument_delimiter ( char *  s)

Replace '^' in a string with ','.

Parameters
sString within which to replace characters

Definition at line 2377 of file utils.c.

2378{
2379 for (; *s; s++) {
2380 if (*s == '^') {
2381 *s = ',';
2382 }
2383 }
2384}

Referenced by app_exec(), ast_bridge_set_after_go_on(), dial_exec_full(), originate_exec(), page_exec(), and queue_exec().

◆ ast_safe_mkdir()

int ast_safe_mkdir ( const char *  base_path,
const char *  path,
int  mode 
)

Recursively create directory path, but only if it resolves within the given base_path.

If base_path does not exist, it will not be created and this function returns EPERM.

Parameters
base_path
pathThe directory path to create
modeThe permissions with which to try to create the directory
Return values
0on success
Returns
an error code otherwise

Definition at line 2618 of file utils.c.

2619{
2620 RAII_VAR(char *, absolute_base_path, NULL, ast_std_free);
2621 RAII_VAR(char *, p, NULL, ast_free);
2622
2623 if (base_path == NULL || path == NULL) {
2624 errno = EFAULT;
2625 return errno;
2626 }
2627
2628 p = ast_strdup(path);
2629 if (p == NULL) {
2630 errno = ENOMEM;
2631 return errno;
2632 }
2633
2634 absolute_base_path = realpath(base_path, NULL);
2635 if (absolute_base_path == NULL) {
2636 return errno;
2637 }
2638
2639 return safe_mkdir(absolute_base_path, p, mode);
2640}
void ast_std_free(void *ptr)
Definition astmm.c:1734
static int safe_mkdir(const char *base_path, char *path, int mode)
Definition utils.c:2548
#define RAII_VAR(vartype, varname, initval, dtor)
Declare a variable that will call a destructor function when it goes out of scope.
Definition utils.h:981

References ast_free, ast_std_free(), ast_strdup, errno, NULL, RAII_VAR, and safe_mkdir().

Referenced by AST_TEST_DEFINE(), stasis_app_control_record(), and stasis_app_stored_recording_copy().

◆ ast_set_default_eid()

void ast_set_default_eid ( struct ast_eid eid)

Fill in an ast_eid with the default eid of this machine.

Since
1.6.1

Definition at line 3035 of file utils.c.

3036{
3037 int s;
3038 int i;
3039 struct ifreq *ifr;
3040 struct ifreq *ifrp;
3041 struct ifconf ifc;
3042 char *buf = NULL;
3043 char eid_str[20];
3044 int bufsz, num_interfaces;
3045 unsigned char empty_mac[6] = {0, 0, 0, 0, 0, 0};
3046 unsigned char full_mac[6] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
3047
3048 s = socket(AF_INET, SOCK_STREAM, 0);
3049 if (s < 0) {
3050 ast_log(LOG_WARNING, "Unable to open socket for seeding global EID. "
3051 "You will have to set it manually.\n");
3052 return;
3053 }
3054
3055 ifc.ifc_len = 0;
3056 ifc.ifc_buf = NULL;
3057 if (ioctl(s, SIOCGIFCONF, &ifc) || ifc.ifc_len <= 0) {
3058 ast_log(LOG_WARNING, "No ethernet interface found for seeding global EID. "
3059 "You will have to set it manually.\n");
3060 close(s);
3061 return;
3062 }
3063 bufsz = ifc.ifc_len;
3064
3065 if (!(buf = ast_malloc(bufsz))) {
3066 ast_log(LOG_WARNING, "Unable to allocate memory for seeding global EID. "
3067 "You will have to set it manually.\n");
3068 close(s);
3069 return;
3070 }
3071
3072 ifc.ifc_buf = buf;
3073 if (ioctl(s, SIOCGIFCONF, &ifc) < 0) {
3074 ast_log(LOG_WARNING, "Unable to retrieve ethernet interfaces for seeding global EID. "
3075 "You will have to set it manually.\n");
3076 ast_free(buf);
3077 close(s);
3078 return;
3079 }
3080
3081 ifrp = ifc.ifc_req;
3082 num_interfaces = ifc.ifc_len / sizeof(*ifr);
3083
3084 for (i = 0; i < num_interfaces; i++) {
3085 ifr = &ifrp[i];
3086 if (!ioctl(s, SIOCGIFHWADDR, ifr)) {
3087 unsigned char *hwaddr = (unsigned char *) ifr->ifr_hwaddr.sa_data;
3088
3089 if (!(memcmp(hwaddr, &empty_mac, 6) && memcmp(hwaddr, &full_mac, 6))) {
3090 continue;
3091 }
3092
3093 memcpy(eid, hwaddr, sizeof(*eid));
3094 ast_debug(1, "Seeding global EID '%s' from '%s' using 'siocgifhwaddr'\n",
3095 ast_eid_to_str(eid_str, sizeof(eid_str), eid), ifr->ifr_name);
3096 ast_free(buf);
3097 close(s);
3098 return;
3099 }
3100 }
3101
3102 ast_log(LOG_WARNING, "No ethernet interface found for seeding global EID. "
3103 "You will have to set it manually.\n");
3104 ast_free(buf);
3105 close(s);
3106
3107 return;
3108}
char * ast_eid_to_str(char *s, int maxlen, struct ast_eid *eid)
Convert an EID to a string.
Definition utils.c:2873

References ast_debug, ast_eid_to_str(), ast_free, ast_log, ast_malloc, buf, LOG_WARNING, and NULL.

Referenced by load_asterisk_conf().

◆ ast_sha1_hash()

void ast_sha1_hash ( char *  output,
const char *  input 
)

Produce 40 char SHA1 hash of value.

Produces SHA1 hash based on input string.

Definition at line 266 of file utils.c.

267{
268 struct SHA1Context sha;
269 char *ptr;
270 int x;
271 uint8_t Message_Digest[20];
272
273 SHA1Reset(&sha);
274
275 SHA1Input(&sha, (const unsigned char *) input, strlen(input));
276
277 SHA1Result(&sha, Message_Digest);
278 ptr = output;
279 for (x = 0; x < 20; x++)
280 ptr += sprintf(ptr, "%02hhx", Message_Digest[x]);
281}
int SHA1Result(SHA1Context *, uint8_t Message_Digest[SHA1HashSize])
SHA1Result Returns the resulting 160-bit digest.
Definition sha1.c:226
int SHA1Input(SHA1Context *, const uint8_t *bytes, unsigned int bytecount)
int SHA1Reset(SHA1Context *)
SHA1Reset.
Definition sha1.c:101

References SHA1Input(), SHA1Reset(), and SHA1Result().

Referenced by ast_tcptls_server_start(), AST_TEST_DEFINE(), ctx_populate(), handle_call_token(), media_cache_item_sync_to_astdb(), sha1(), xmpp_client_authenticate_digest(), and xmpp_component_authenticate().

◆ ast_sha1_hash_uint()

void ast_sha1_hash_uint ( uint8_t *  digest,
const char *  input 
)

Produce a 20 byte SHA1 hash of value.

Produces SHA1 hash based on input string, stored in uint8_t array.

Definition at line 284 of file utils.c.

285{
286 struct SHA1Context sha;
287
288 SHA1Reset(&sha);
289
290 SHA1Input(&sha, (const unsigned char *) input, strlen(input));
291
292 SHA1Result(&sha, digest);
293}

References SHA1Input(), SHA1Reset(), and SHA1Result().

Referenced by websocket_combine_key().

◆ ast_str_to_eid()

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

Return values
0success
non-zerofailure
Since
1.6.1

Definition at line 3111 of file utils.c.

3112{
3113 unsigned int eid_int[6];
3114 int x;
3115
3116 if (sscanf(s, "%2x:%2x:%2x:%2x:%2x:%2x", &eid_int[0], &eid_int[1], &eid_int[2],
3117 &eid_int[3], &eid_int[4], &eid_int[5]) != 6) {
3118 return -1;
3119 }
3120
3121 for (x = 0; x < 6; x++) {
3122 eid->eid[x] = eid_int[x];
3123 }
3124
3125 return 0;
3126}

References ast_eid::eid.

Referenced by asterisk_publication_devicestate_state_change(), asterisk_publication_mwi_state_change(), build_peer(), dundi_do_query(), load_asterisk_conf(), set_config(), and xmpp_pubsub_handle_event().

◆ ast_strip_quoted()

char * ast_strip_quoted ( char *  s,
const char *  beg_quotes,
const char *  end_quotes 
)

Strip leading/trailing whitespace and quotes from a string.

Parameters
sThe string to be stripped (will be modified).
beg_quotesThe list of possible beginning quote characters.
end_quotesThe list of matching ending quote characters.
Returns
The stripped string.

This functions strips all leading and trailing whitespace characters from the input string, and returns a pointer to the resulting string. The string is modified in place.

It can also remove beginning and ending quote (or quote-like) characters, in matching pairs. If the first character of the string matches any character in beg_quotes, and the last character of the string is the matching character in end_quotes, then they are removed from the string.

Examples:

ast_strip_quoted(buf, "\"", "\"");
ast_strip_quoted(buf, "'", "'");
ast_strip_quoted(buf, "[{(", "]})");
char * ast_strip_quoted(char *s, const char *beg_quotes, const char *end_quotes)
Strip leading/trailing whitespace and quotes from a string.
Definition utils.c:1852

Definition at line 1852 of file utils.c.

1853{
1854 char *e;
1855 const char *q;
1856
1857 s = ast_strip(s);
1858 if ((q = strchr(beg_quotes, *s)) && *q != '\0') {
1859 e = s + strlen(s) - 1;
1860 if (*e == *(end_quotes + (q - beg_quotes))) {
1861 s++;
1862 *e = '\0';
1863 }
1864 }
1865
1866 return s;
1867}
char * ast_strip(char *s)
Strip leading/trailing whitespace from a string.
Definition strings.h:223

References ast_strip().

Referenced by applicationmap_handler(), ast_callerid_parse(), ast_sip_validate_uri_length(), ast_strsep(), ast_strsep_quoted(), dialog_info_generate_body_content(), hfp_parse_clip(), iftime(), load_values_config(), load_values_config(), parse_cookies(), parse_dial_string(), pidf_allocate_body(), set_redirecting_reason(), and xpidf_allocate_body().

◆ ast_strsep()

char * ast_strsep ( char **  s,
const char  sep,
uint32_t  flags 
)

Act like strsep but ignore separators inside quotes.

Parameters
sPointer to address of the string to be processed. Will be modified and can't be constant.
sepA single character delimiter.
flagsControls post-processing of the result. AST_STRSEP_TRIM trims all leading and trailing whitespace from the result. If the result containes only whitespace, it'll be passed through unchanged. AST_STRSEP_STRIP does a trim then strips the outermost quotes. You may want to trim again after the strip. Just OR both the TRIM and STRIP flags. AST_STRSEP_UNESCAPE unescapes '\' sequences. AST_STRSEP_ALL does all of the above processing.
Returns
The next token or NULL if done or if there are more than 8 levels of nested quotes. If provided an empty string, will return the empty string.

This function acts like strsep with three exceptions... The separator is a single character instead of a string. Separators inside quotes are treated literally instead of like separators. You can elect to have leading and trailing whitespace and quotes stripped from the result and have '\' sequences unescaped.

Like strsep, ast_strsep maintains no internal state and you can call it recursively using different separators on the same storage.

Also like strsep, for consistent results, consecutive separators are not collapsed so you may get an empty string as a valid result.

Examples:

char *mystr = ast_strdupa("abc=def,ghi='zzz=yyy,456',jkl");
char *token, *token2, *token3;
while((token = ast_strsep(&mystr, ',', AST_STRSEP_STRIP))) {
// 1st token will be aaa=def
// 2nd token will be ghi='zzz=yyy,456'
while((token2 = ast_strsep(&token, '=', AST_STRSEP_STRIP))) {
// 1st token2 will be ghi
// 2nd token2 will be zzz=yyy,456
while((token3 = ast_strsep(&token2, ',', AST_STRSEP_STRIP))) {
// 1st token3 will be zzz=yyy
// 2nd token3 will be 456
// and so on
}
}
// 3rd token will be jkl
}
@ AST_STRSEP_STRIP
Definition strings.h:255
char * ast_strsep(char **s, const char sep, uint32_t flags)
Act like strsep but ignore separators inside quotes.
Definition utils.c:1869

Definition at line 1869 of file utils.c.

1870{
1871 char *st = *iss;
1872 char *is;
1873 int inquote = 0;
1874 int found = 0;
1875 char stack[8];
1876
1877 if (ast_strlen_zero(st)) {
1878 *iss = NULL;
1879 return st;
1880 }
1881
1882 memset(stack, 0, sizeof(stack));
1883
1884 for(is = st; *is; is++) {
1885 if (*is == '\\') {
1886 if (*++is != '\0') {
1887 is++;
1888 } else {
1889 break;
1890 }
1891 }
1892
1893 if (*is == '\'' || *is == '"') {
1894 if (*is == stack[inquote]) {
1895 stack[inquote--] = '\0';
1896 } else {
1897 if (++inquote >= sizeof(stack)) {
1898 return NULL;
1899 }
1900 stack[inquote] = *is;
1901 }
1902 }
1903
1904 if (*is == sep && !inquote) {
1905 *is = '\0';
1906 found = 1;
1907 *iss = is + 1;
1908 break;
1909 }
1910 }
1911 if (!found) {
1912 *iss = NULL;
1913 }
1914
1915 if (flags & AST_STRSEP_STRIP) {
1916 st = ast_strip_quoted(st, "'\"", "'\"");
1917 }
1918
1919 if (flags & AST_STRSEP_TRIM) {
1920 char *trimmed = ast_strip(st);
1921 if (!ast_strlen_zero(trimmed)) {
1922 st = trimmed;
1923 }
1924 }
1925
1926 if (flags & AST_STRSEP_UNESCAPE) {
1928 }
1929
1930 return st;
1931}
@ AST_STRSEP_TRIM
Definition strings.h:256
@ AST_STRSEP_UNESCAPE
Definition strings.h:257
void ast_unescape_quoted(char *quote_str)
Unescape quotes in a string.
Definition utils.c:876
char * ast_strip_quoted(char *s, const char *beg_quotes, const char *end_quotes)
Strip leading/trailing whitespace and quotes from a string.
Definition utils.c:1852

References ast_strip(), ast_strip_quoted(), ast_strlen_zero(), AST_STRSEP_STRIP, AST_STRSEP_TRIM, AST_STRSEP_UNESCAPE, ast_unescape_quoted(), and NULL.

Referenced by action_playback(), action_playback_and_continue(), angle_parser(), ast_app_getdata_terminator(), ast_sip_header_to_security_mechanism(), ast_sip_security_mechanism_vector_init(), ast_sip_str_to_security_mechanism(), AST_TEST_DEFINE(), does_category_match(), follow_redirect_methods_handler(), handle_incoming_request(), handle_updates(), originate_exec(), outbound_websocket_apply(), password_digest_handler(), pbx_builtin_background(), play_files_helper(), playback_exec(), reload_exec(), rfc3329_incoming_response(), session_register_apps(), speech_background(), try_calling(), validate_uri_parameters(), and wizard_apply_handler().

◆ ast_strsep_quoted()

char * ast_strsep_quoted ( char **  s,
const char  sep,
const char  quote,
uint32_t  flags 
)

Like ast_strsep() except you can specify a specific quote character.

Parameters
sPointer to address of the string to be processed. Will be modified and can't be constant.
sepA single character delimiter.
quoteThe quote character
flagsControls post-processing of the result. AST_STRSEP_TRIM trims all leading and trailing whitespace from the result. AST_STRSEP_STRIP does a trim then strips the outermost quotes. You may want to trim again after the strip. Just OR both the TRIM and STRIP flags. AST_STRSEP_UNESCAPE unescapes '\' sequences. AST_STRSEP_ALL does all of the above processing.
Returns
The next token or NULL if done or if there are more than 8 levels of nested quotes. If provided an empty string, will return the empty string.

Definition at line 1933 of file utils.c.

1934{
1935 char *st = *iss;
1936 char *is;
1937 int inquote = 0;
1938 int found = 0;
1939 char stack[8];
1940 const char qstr[] = { quote };
1941
1942 if (ast_strlen_zero(st)) {
1943 *iss = NULL;
1944 return st;
1945 }
1946
1947 memset(stack, 0, sizeof(stack));
1948
1949 for(is = st; *is; is++) {
1950 if (*is == '\\') {
1951 if (*++is != '\0') {
1952 is++;
1953 } else {
1954 break;
1955 }
1956 }
1957
1958 if (*is == quote) {
1959 if (*is == stack[inquote]) {
1960 stack[inquote--] = '\0';
1961 } else {
1962 if (++inquote >= sizeof(stack)) {
1963 return NULL;
1964 }
1965 stack[inquote] = *is;
1966 }
1967 }
1968
1969 if (*is == sep && !inquote) {
1970 *is = '\0';
1971 found = 1;
1972 *iss = is + 1;
1973 break;
1974 }
1975 }
1976 if (!found) {
1977 *iss = NULL;
1978 }
1979
1980 if (flags & AST_STRSEP_STRIP) {
1981 st = ast_strip_quoted(st, qstr, qstr);
1982 }
1983
1984 if (flags & AST_STRSEP_TRIM) {
1985 char *trimmed = ast_strip(st);
1986 if (!ast_strlen_zero(trimmed)) {
1987 st = trimmed;
1988 }
1989 }
1990
1991 if (flags & AST_STRSEP_UNESCAPE) {
1993 }
1994
1995 return st;
1996}
static int quote(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t len)

References ast_strip(), ast_strip_quoted(), ast_strlen_zero(), AST_STRSEP_STRIP, AST_STRSEP_TRIM, AST_STRSEP_UNESCAPE, ast_unescape_quoted(), NULL, and quote().

Referenced by AST_TEST_DEFINE(), and ast_variable_list_from_quoted_string().

◆ ast_thread_is_user_interface()

int ast_thread_is_user_interface ( void  )

Indicates whether the current thread is a user interface.

Return values
True(non-zero) if thread is a user interface.
False(zero) if thread is not a user interface.

Definition at line 3282 of file utils.c.

3283{
3284 int *thread_user_interface;
3285
3286 thread_user_interface = ast_threadstorage_get(
3287 &thread_user_interface_tl, sizeof(*thread_user_interface));
3288 if (thread_user_interface == NULL) {
3289 ast_log(LOG_ERROR, "Error checking thread's user interface status\n");
3290 /* On error, assume that we are not a user interface thread */
3291 return 0;
3292 }
3293
3294 return *thread_user_interface;
3295}

References ast_log, ast_threadstorage_get(), LOG_ERROR, and NULL.

Referenced by ast_autoservice_start(), and ast_autoservice_stop().

◆ ast_thread_user_interface_set()

int ast_thread_user_interface_set ( int  is_user_interface)

Set the current thread's user interface status.

Parameters
is_user_interfaceNon-zero to mark the thread as a user interface.
Return values
True(non-zero) if marking current thread failed.
False(zero) if successfuly marked current thread.

Definition at line 3267 of file utils.c.

3268{
3269 int *thread_user_interface;
3270
3271 thread_user_interface = ast_threadstorage_get(
3272 &thread_user_interface_tl, sizeof(*thread_user_interface));
3273 if (thread_user_interface == NULL) {
3274 ast_log(LOG_ERROR, "Error setting user interface status for current thread\n");
3275 return -1;
3276 }
3277
3278 *thread_user_interface = !!is_user_interface;
3279 return 0;
3280}

References ast_log, ast_threadstorage_get(), LOG_ERROR, and NULL.

Referenced by handle_tcptls_connection().

◆ AST_THREADSTORAGE_CUSTOM_SCOPE() [1/2]

AST_THREADSTORAGE_CUSTOM_SCOPE ( inet_ntoa_buf  ,
NULL  ,
ast_free_ptr  ,
static   
)

◆ AST_THREADSTORAGE_CUSTOM_SCOPE() [2/2]

AST_THREADSTORAGE_CUSTOM_SCOPE ( thread_user_interface_tl  ,
NULL  ,
ast_free_ptr  ,
static   
)

A thread local indicating whether the current thread is a user interface.

◆ ast_to_camel_case_delim()

char * ast_to_camel_case_delim ( const char *  s,
const char *  delim 
)

Attempts to convert the given string to camel case using the specified delimiter.

note - returned string needs to be freed

Parameters
sthe string to convert
delimdelimiter to parse out
Returns
The string converted to "CamelCase"
Since
12

Definition at line 2431 of file utils.c.

2432{
2433 char *res = ast_strdup(s);
2434 char *front, *back, *buf = res;
2435 int size;
2436
2437 front = strtok_r(buf, delim, &back);
2438
2439 while (front) {
2440 size = strlen(front);
2441 *front = toupper(*front);
2442 ast_copy_string(buf, front, size + 1);
2443 buf += size;
2444 front = strtok_r(NULL, delim, &back);
2445 }
2446
2447 return res;
2448}

References ast_copy_string(), ast_strdup, buf, and NULL.

◆ ast_true()

int ast_true ( const char *  val)

Make sure something is true. Determine if a string containing a boolean value is "true". This function checks to see whether a string passed to it is an indication of an "true" value. It checks to see if the string is "yes", "true", "y", "t", "on" or "1".

Return values
-1if "true".
0otherwise, like NULL pointer.

Definition at line 2233 of file utils.c.

2234{
2235 if (ast_strlen_zero(s))
2236 return 0;
2237
2238 /* Determine if this is a true value */
2239 if (!strcasecmp(s, "yes") ||
2240 !strcasecmp(s, "true") ||
2241 !strcasecmp(s, "y") ||
2242 !strcasecmp(s, "t") ||
2243 !strcasecmp(s, "1") ||
2244 !strcasecmp(s, "on"))
2245 return -1;
2246
2247 return 0;
2248}

References ast_strlen_zero().

Referenced by __ast_http_load(), __init_manager(), acf_curlopt_write(), acf_faxopt_write(), acf_transaction_write(), action_agent_logoff(), action_originate(), action_status(), action_updateconfig(), actual_load_config(), agent_login_channel_config(), analog_call(), announce_user_count_all_handler(), aoc_cli_debug_enable(), apply_general_options(), apply_option(), ast_ari_bridges_add_channel_cb(), ast_ari_bridges_record_cb(), ast_ari_channels_record_cb(), ast_ari_endpoints_refer_cb(), ast_ari_endpoints_refer_to_endpoint_cb(), ast_bridge_timelimit(), ast_jb_read_conf(), ast_rtp_dtls_cfg_parse(), AST_TEST_DEFINE(), ast_tls_read_conf(), autopause2int(), bool_handler_fn(), boolflag_handler_fn(), build_calendar(), build_device(), build_peer(), build_peer(), build_peer(), build_user(), build_user(), cdr_prop_write_callback(), check_debug(), client_bitfield_handler(), custom_bitfield_handler(), customopt_handler(), dahdi_set_dnd(), dahdi_set_mwi(), do_reload(), festival_exec(), func_channel_write_real(), func_mute_write(), func_write_attestation(), function_ooh323_write(), general_pretty_from_str(), geoloc_profile_write(), get_encrypt_methods(), global_bitfield_handler(), handle_exec(), handle_incoming_request(), handle_logger_chanloggroup_filter(), handle_logger_set_level(), handle_queue_set_member_ringinuse(), hook_write(), init_logger_chain(), internal_feature_write(), is_variable_true(), load_asterisk_conf(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config(), load_config_meetme(), load_module(), load_module(), load_module(), load_moh_classes(), load_odbc_config(), load_users(), loader_config_init(), manager_add_queue_member(), manager_change_priority_caller_on_queue(), manager_dialplan_extension_add(), manager_moduleload(), manager_mute_mixmonitor(), manager_mutestream(), manager_pause_queue_member(), manager_play_dtmf(), manager_queue_member_ringinuse(), manager_send_flash(), mbl_load_adapter(), mbl_load_device(), message_template_build(), moh_parse_options(), new_realtime_sqlite3_db(), odbc_load_module(), parse_config(), parse_config(), parse_empty_options(), parse_general_options(), parse_line(), parse_playtone(), pbx_load_config(), permit_dtmf_interrupt(), pjsip_acf_moh_passthrough_write(), pjsip_set_logger_verbose(), prack_handler(), process_dahdi(), process_echocancel(), process_my_load_module(), profile_set_param(), queue_rules_set_global_params(), queue_set_global_params(), queue_set_param(), realtime_directory(), reload(), reload_config(), reload_followme(), reload_module(), reload_single_member(), rt_handle_member_record(), rtp_reload(), run_agi(), sayunixtime_exec(), search_directory(), set_active(), set_config(), set_config(), set_config(), sla_load_config(), smdi_load(), sorcery_config_open(), sorcery_memory_cache_ami_stale_object(), sorcery_memory_cache_open(), speex_write(), stackpeek_read(), strings_to_mask(), tds_load_module(), timers_handler(), transport_tls_bool_handler(), websocket_attempted_cb(), xfer_set(), xmldoc_get_syntax_cmd(), xmldoc_get_syntax_config_object(), xmldoc_get_syntax_fun(), and xmldoc_get_syntax_manager().

◆ ast_tvadd()

struct timeval ast_tvadd ( struct timeval  a,
struct timeval  b 
)

Returns the sum of two timevals a + b.

Definition at line 2287 of file utils.c.

2288{
2289 /* consistency checks to guarantee usec in 0..999999 */
2290 a = tvfix(a);
2291 b = tvfix(b);
2292 a.tv_sec += b.tv_sec;
2293 a.tv_usec += b.tv_usec;
2294 if (a.tv_usec >= ONE_MILLION) {
2295 a.tv_sec++;
2296 a.tv_usec -= ONE_MILLION;
2297 }
2298 return a;
2299}
static struct test_val b
#define ONE_MILLION
Definition utils.c:2267
static struct timeval tvfix(struct timeval a)
Definition utils.c:2272

References a, b, ONE_MILLION, and tvfix().

◆ ast_tvsub()

struct timeval ast_tvsub ( struct timeval  a,
struct timeval  b 
)

Returns the difference of two timevals a - b.

Definition at line 2301 of file utils.c.

2302{
2303 /* consistency checks to guarantee usec in 0..999999 */
2304 a = tvfix(a);
2305 b = tvfix(b);
2306 a.tv_sec -= b.tv_sec;
2307 a.tv_usec -= b.tv_usec;
2308 if (a.tv_usec < 0) {
2309 a.tv_sec-- ;
2310 a.tv_usec += ONE_MILLION;
2311 }
2312 return a;
2313}

References a, b, ONE_MILLION, and tvfix().

◆ ast_unescape_c()

char * ast_unescape_c ( char *  s)

Convert some C escape sequences.

(\b\f\n\r\t) 

into the equivalent characters. The string to be converted (will be modified).

Returns
The converted string.

Definition at line 2017 of file utils.c.

2018{
2019 char c, *ret, *dst;
2020
2021 if (src == NULL)
2022 return NULL;
2023 for (ret = dst = src; (c = *src++); *dst++ = c ) {
2024 if (c != '\\')
2025 continue; /* copy char at the end of the loop */
2026 switch ((c = *src++)) {
2027 case '\0': /* special, trailing '\' */
2028 c = '\\';
2029 break;
2030 case 'b': /* backspace */
2031 c = '\b';
2032 break;
2033 case 'f': /* form feed */
2034 c = '\f';
2035 break;
2036 case 'n':
2037 c = '\n';
2038 break;
2039 case 'r':
2040 c = '\r';
2041 break;
2042 case 't':
2043 c = '\t';
2044 break;
2045 }
2046 /* default, use the char literally */
2047 }
2048 *dst = '\0';
2049 return ret;
2050}

References c, and NULL.

Referenced by ast_parse_digest().

◆ ast_unescape_quoted()

void ast_unescape_quoted ( char *  quote_str)

Unescape quotes in a string.

Parameters
quote_strThe string with quotes to be unescaped
Note
This function mutates the passed-in string.

Definition at line 876 of file utils.c.

877{
878 int esc_pos;
879 int unesc_pos;
880 int quote_str_len = strlen(quote_str);
881
882 for (esc_pos = 0, unesc_pos = 0;
883 esc_pos < quote_str_len;
884 esc_pos++, unesc_pos++) {
885 if (quote_str[esc_pos] == '\\') {
886 /* at least one more char and current is \\ */
887 esc_pos++;
888 if (esc_pos >= quote_str_len) {
889 break;
890 }
891 }
892
893 quote_str[unesc_pos] = quote_str[esc_pos];
894 }
895 quote_str[unesc_pos] = '\0';
896}

Referenced by ast_callerid_parse(), ast_strsep(), ast_strsep_quoted(), AST_TEST_DEFINE(), and AST_TEST_DEFINE().

◆ ast_unescape_semicolon()

char * ast_unescape_semicolon ( char *  s)

Strip backslash for "escaped" semicolons, the string to be stripped (will be modified).

Returns
The stripped string.

Definition at line 1998 of file utils.c.

1999{
2000 char *e;
2001 char *work = s;
2002
2003 while ((e = strchr(work, ';'))) {
2004 if ((e > work) && (*(e-1) == '\\')) {
2005 memmove(e - 1, e, strlen(e) + 1);
2006 work = e;
2007 } else {
2008 work = e + 1;
2009 }
2010 }
2011
2012 return s;
2013}

◆ ast_uri_decode()

void ast_uri_decode ( char *  s,
struct ast_flags  spec 
)

Decode URI, URN, URL (overwrite string)

Note
The ast_uri_http_legacy decode spec flag will cause this function to decode '+' as ' '.
Parameters
sstring to be decoded
specflags describing how the decoding should be performed

Definition at line 760 of file utils.c.

761{
762 char *o;
763 unsigned int tmp;
764
765 for (o = s; *s; s++, o++) {
766 if (ast_test_flag(&spec, AST_URI_LEGACY_SPACE) && *s == '+') {
767 /* legacy mode, decode '+' as space */
768 *o = ' ';
769 } else if (*s == '%' && s[1] != '\0' && s[2] != '\0' && sscanf(s + 1, "%2x", &tmp) == 1) {
770 /* have '%', two chars and correct parsing */
771 *o = tmp;
772 s += 2; /* Will be incremented once more when we break out */
773 } else /* all other cases, just copy */
774 *o = *s;
775 }
776 *o = '\0';
777}
#define ast_test_flag(p, flag)
Definition utils.h:64
#define AST_URI_LEGACY_SPACE
Definition utils.h:388

References ast_test_flag, and AST_URI_LEGACY_SPACE.

Referenced by acf_curl_helper(), ast_ari_invoke(), ast_http_parse_post_form(), AST_TEST_DEFINE(), config_curl(), handle_uri(), realtime_curl(), realtime_multi_curl(), and uridecode().

◆ ast_uri_encode()

char * ast_uri_encode ( const char *  string,
char *  outbuf,
int  buflen,
struct ast_flags  spec 
)

Turn text string to URI-encoded XX version.

This function encodes characters according to the rules presented in RFC 2396 and/or RFC 3261 section 19.1.2 and section 25.1.

Outbuf needs to have more memory allocated than the instring to have room for the expansion. Every byte that is converted is replaced by three ASCII characters.

Parameters
stringstring to be converted
outbufresulting encoded string
buflensize of output buffer
specflags describing how the encoding should be performed
Returns
a pointer to the uri encoded string

Definition at line 721 of file utils.c.

722{
723 const char *ptr = string; /* Start with the string */
724 char *out = outbuf;
725 const char *mark = "-_.!~*'()"; /* no encode set, RFC 2396 section 2.3, RFC 3261 sec 25 */
726 const char *user_unreserved = "&=+$,;?/"; /* user-unreserved set, RFC 3261 sec 25 */
727
728 while (*ptr && out - outbuf < buflen - 1) {
729 if (ast_test_flag(&spec, AST_URI_LEGACY_SPACE) && *ptr == ' ') {
730 /* for legacy encoding, encode spaces as '+' */
731 *out = '+';
732 out++;
733 } else if (!(ast_test_flag(&spec, AST_URI_MARK)
734 && strchr(mark, *ptr))
736 && ((*ptr >= '0' && *ptr <= '9')
737 || (*ptr >= 'A' && *ptr <= 'Z')
738 || (*ptr >= 'a' && *ptr <= 'z')))
740 && strchr(user_unreserved, *ptr))) {
741
742 if (out - outbuf >= buflen - 3) {
743 break;
744 }
745 out += sprintf(out, "%%%02hhX", (unsigned char) *ptr);
746 } else {
747 *out = *ptr; /* Continue copying the string */
748 out++;
749 }
750 ptr++;
751 }
752
753 if (buflen) {
754 *out = '\0';
755 }
756
757 return outbuf;
758}
#define AST_URI_MARK
Definition utils.h:386
#define AST_URI_SIP_USER_UNRESERVED
Definition utils.h:390
#define AST_URI_ALPHANUM
Definition utils.h:385

References ast_test_flag, AST_URI_ALPHANUM, AST_URI_LEGACY_SPACE, AST_URI_MARK, AST_URI_SIP_USER_UNRESERVED, out, and string.

Referenced by ast_ari_bridges_record(), ast_ari_channels_record(), AST_TEST_DEFINE(), config_curl(), destroy_curl(), launch_asyncagi(), realtime_curl(), realtime_multi_curl(), require_curl(), store_curl(), update2_curl(), update_curl(), and uriencode().

◆ ast_uri_verify_encoded()

int ast_uri_verify_encoded ( const char *  string)

Verify if a string is valid as a URI component.

This function checks if the string either doesn't need encoding or is already properly URI encoded. Valid characters are 'a-zA-Z0-9.+_-' and 'xx' escape sequences.

Parameters
stringString to be checked
Return values
1if the string is valid
0if the string is not valid

Definition at line 779 of file utils.c.

780{
781 const char *ptr = string;
782 size_t length;
783 char *endl;
784
785 if (!string) {
786 return 0;
787 }
788
789 length = strlen(string);
790 endl = (char *)string + length;
791
792 while (*ptr) {
793 if (*ptr == '%') {
794 unsigned int tmp;
795 /* Make sure there are at least 2 characters left to decode */
796 if (ptr + 2 >= endl) {
797 return 0;
798 }
799 /* Try to parse the next two characters as hex */
800 if (sscanf(ptr + 1, "%2x", &tmp) != 1) {
801 return 0;
802 }
803 /* All good, move past the '%' and the two hex digits */
804 ptr += 3;
805 } else if (!isalnum((unsigned char ) *ptr) && !strchr("-_.+", *ptr)) {
806 return 0;
807 } else {
808 ptr++;
809 }
810 }
811
812 return 1; /* all characters are valid */
813}

References string.

Referenced by validate_uri_parameters().

◆ ast_utils_init()

int ast_utils_init ( void  )

Definition at line 2651 of file utils.c.

2652{
2653 dev_urandom_fd = open("/dev/urandom", O_RDONLY);
2654 base64_init();
2655#ifdef DEBUG_THREADS
2656#if !defined(LOW_MEMORY)
2657 ast_cli_register_multiple(utils_cli, ARRAY_LEN(utils_cli));
2658#endif
2659#endif
2661 return 0;
2662}
int ast_register_cleanup(void(*func)(void))
Register a function to be executed before Asterisk gracefully exits.
Definition clicompat.c:19
#define ast_cli_register_multiple(e, len)
Register multiple commands.
Definition cli.h:265
static void utils_shutdown(void)
Definition utils.c:2642
static void base64_init(void)
Definition utils.c:538
#define ARRAY_LEN(a)
Definition utils.h:706

References ARRAY_LEN, ast_cli_register_multiple, ast_register_cleanup(), base64_init(), dev_urandom_fd, and utils_shutdown().

Referenced by asterisk_daemon().

◆ ast_utils_which()

char * ast_utils_which ( const char *  binary,
char *  fullpath,
size_t  fullpath_size 
)

Resolve a binary to a full pathname.

Parameters
binaryName of the executable to resolve
fullpathBuffer to hold the complete pathname
fullpath_sizeSize of fullpath
Return values
NULLbinary was not found or the environment variable PATH is not set
Returns
fullpath

Definition at line 2808 of file utils.c.

2809{
2810 const char *envPATH = getenv("PATH");
2811 char *tpath, *path;
2812 struct stat unused;
2813 if (!envPATH) {
2814 return NULL;
2815 }
2816 tpath = ast_strdupa(envPATH);
2817 while ((path = strsep(&tpath, ":"))) {
2818 snprintf(fullpath, fullpath_size, "%s/%s", path, binary);
2819 if (!stat(fullpath, &unused)) {
2820 return fullpath;
2821 }
2822 }
2823 return NULL;
2824}

References ast_strdupa, NULL, and strsep().

◆ ast_wait_for_input()

int ast_wait_for_input ( int  fd,
int  ms 
)

Definition at line 1732 of file utils.c.

1733{
1734 struct pollfd pfd[1];
1735
1736 memset(pfd, 0, sizeof(pfd));
1737 pfd[0].fd = fd;
1738 pfd[0].events = POLLIN | POLLPRI;
1739 return ast_poll(pfd, 1, ms);
1740}
#define ast_poll(a, b, c)
Definition poll-compat.h:88

References ast_poll.

Referenced by action_waitevent(), ast_audiosocket_receive_frame_with_hangup(), ast_iostream_wait_for_input(), ast_iostream_write(), ast_tcptls_server_root(), dahdi_test_timer(), get_input(), iostream_read(), moh_class_destructor(), session_read(), and unbound_resolver_thread().

◆ ast_wait_for_output()

int ast_wait_for_output ( int  fd,
int  ms 
)

Definition at line 1742 of file utils.c.

1743{
1744 struct pollfd pfd[1];
1745
1746 memset(pfd, 0, sizeof(pfd));
1747 pfd[0].fd = fd;
1748 pfd[0].events = POLLOUT;
1749 return ast_poll(pfd, 1, ms);
1750}

References ast_poll.

Referenced by ast_iostream_write(), iostream_read(), and socket_connect().

◆ ast_xml_escape()

int ast_xml_escape ( const char *  string,
char *  outbuf,
size_t  buflen 
)

Escape reserved characters for use in XML.

ast_xml_escape

If outbuf is too short, the output string will be truncated. Regardless, the output will always be null terminated.

Parameters
stringString to be converted
outbufResulting encoded string
buflenSize of output buffer
Return values
0for success
-1if buflen is too short.

Definition at line 898 of file utils.c.

899{
900 char *dst = outbuf;
901 char *end = outbuf + buflen - 1; /* save one for the null terminator */
902
903 /* Handle the case for the empty output buffer */
904 if (buflen == 0) {
905 return -1;
906 }
907
908 /* Escaping rules from http://www.w3.org/TR/REC-xml/#syntax */
909 /* This also prevents partial entities at the end of a string */
910 while (*string && dst < end) {
911 const char *entity = NULL;
912 int len = 0;
913
914 switch (*string) {
915 case '<':
916 entity = "&lt;";
917 len = 4;
918 break;
919 case '&':
920 entity = "&amp;";
921 len = 5;
922 break;
923 case '>':
924 /* necessary if ]]> is in the string; easier to escape them all */
925 entity = "&gt;";
926 len = 4;
927 break;
928 case '\'':
929 /* necessary in single-quoted strings; easier to escape them all */
930 entity = "&apos;";
931 len = 6;
932 break;
933 case '"':
934 /* necessary in double-quoted strings; easier to escape them all */
935 entity = "&quot;";
936 len = 6;
937 break;
938 default:
939 *dst++ = *string++;
940 break;
941 }
942
943 if (entity) {
944 ast_assert(len == strlen(entity));
945 if (end - dst < len) {
946 /* no room for the entity; stop */
947 break;
948 }
949 /* just checked for length; strcpy is fine */
950 strcpy(dst, entity);
951 dst += len;
952 ++string;
953 }
954 }
955 /* Write null terminator */
956 *dst = '\0';
957 /* If any chars are left in string, return failure */
958 return *string == '\0' ? 0 : -1;
959}
char * end
Definition eagi_proxy.c:73

References ast_assert, end, len(), NULL, and string.

Referenced by ast_http_create_response(), and test_xml().

◆ base64_init()

static void base64_init ( void  )
static

Definition at line 538 of file utils.c.

539{
540 int x;
541 memset(b2a, -1, sizeof(b2a));
542 memset(b2a_url, -1, sizeof(b2a_url));
543 /* Initialize base-64 Conversion table */
544 for (x = 0; x < 26; x++) {
545 /* A-Z */
546 base64[x] = 'A' + x;
547 base64url[x] = 'A' + x;
548 b2a['A' + x] = x;
549 b2a_url['A' + x] = x;
550 /* a-z */
551 base64[x + 26] = 'a' + x;
552 base64url[x + 26] = 'a' + x;
553 b2a['a' + x] = x + 26;
554 b2a_url['a' + x] = x + 26;
555 /* 0-9 */
556 if (x < 10) {
557 base64[x + 52] = '0' + x;
558 base64url[x + 52] = '0' + x;
559 b2a['0' + x] = x + 52;
560 b2a_url['0' + x] = x + 52;
561 }
562 }
563 base64[62] = '+';
564 base64[63] = '/';
565 base64url[62] = '-';
566 base64url[63] = '_';
567 b2a[(int)'+'] = 62;
568 b2a[(int)'/'] = 63;
569 b2a_url[(int)'-'] = 62;
570 b2a_url[(int)'_'] = 63;
571}

References b2a, b2a_url, base64, and base64url.

Referenced by ast_utils_init().

◆ dummy_start()

static void * dummy_start ( void *  data)
static

Definition at line 1607 of file utils.c.

1608{
1609 void *ret;
1610 struct thr_arg a = *((struct thr_arg *) data); /* make a local copy */
1611#ifdef DEBUG_THREADS
1612 struct thr_lock_info *lock_info;
1613 pthread_mutexattr_t mutex_attr;
1614
1615 if (!(lock_info = ast_threadstorage_get(&thread_lock_info, sizeof(*lock_info))))
1616 return NULL;
1617
1618 lock_info->thread_id = pthread_self();
1619 lock_info->lwp = ast_get_tid();
1620 lock_info->thread_name = ast_strdup(a.name);
1621
1622 pthread_mutexattr_init(&mutex_attr);
1623 pthread_mutexattr_settype(&mutex_attr, AST_MUTEX_KIND);
1624 pthread_mutex_init(&lock_info->lock, &mutex_attr);
1625 pthread_mutexattr_destroy(&mutex_attr);
1626
1627 pthread_mutex_lock(&lock_infos_lock.mutex); /* Intentionally not the wrapper */
1628 AST_LIST_INSERT_TAIL(&lock_infos, lock_info, entry);
1629 pthread_mutex_unlock(&lock_infos_lock.mutex); /* Intentionally not the wrapper */
1630#endif /* DEBUG_THREADS */
1631
1632 /* note that even though data->name is a pointer to allocated memory,
1633 we are not freeing it here because ast_register_thread is going to
1634 keep a copy of the pointer and then ast_unregister_thread will
1635 free the memory
1636 */
1637 ast_free(data);
1639 pthread_cleanup_push(ast_unregister_thread, (void *) pthread_self());
1640
1641 ret = a.start_routine(a.data);
1642
1643 pthread_cleanup_pop(1);
1644
1645 return ret;
1646}
static const struct ast_datastore_info lock_info
Definition func_lock.c:136
#define AST_LIST_INSERT_TAIL(head, elm, field)
Appends a list entry to the tail of a list.
#define pthread_mutex_lock
Definition lock.h:632
#define AST_MUTEX_KIND
Definition lock.h:84
#define pthread_mutex_unlock
Definition lock.h:633
#define pthread_mutex_init
Definition lock.h:635
int ast_get_tid(void)
Get current thread ID.
Definition utils.c:2786
void ast_register_thread(char *name)
Definition asterisk.c:422
void ast_unregister_thread(void *id)
Definition asterisk.c:438

References a, ast_free, ast_get_tid(), AST_LIST_INSERT_TAIL, AST_MUTEX_KIND, ast_register_thread(), ast_strdup, ast_threadstorage_get(), ast_unregister_thread(), thr_arg::data, lock_info, test_val::name, NULL, pthread_mutex_init, pthread_mutex_lock, and pthread_mutex_unlock.

Referenced by ast_pthread_create_stack().

◆ escape_alloc()

static char * escape_alloc ( const char *  s,
size_t *  size 
)
static

Definition at line 2152 of file utils.c.

2153{
2154 if (!s) {
2155 return NULL;
2156 }
2157
2158 /*
2159 * The result string needs to be twice the size of the given
2160 * string just in case every character in it needs to be escaped.
2161 */
2162 *size = strlen(s) * 2 + 1;
2163 return ast_malloc(*size);
2164}

References ast_malloc, and NULL.

Referenced by ast_escape_alloc(), and ast_escape_c_alloc().

◆ inbuf()

static int inbuf ( struct baseio bio,
FILE *  fi 
)
static

utility used by inchar(), for base_encode()

Definition at line 588 of file utils.c.

589{
590 int l;
591
592 if (bio->ateof) {
593 return 0;
594 }
595
596 if ((l = fread(bio->iobuf, 1, BASEMAXINLINE, fi)) != BASEMAXINLINE) {
597 bio->ateof = 1;
598 if (l == 0) {
599 /* Assume EOF */
600 return 0;
601 }
602 }
603
604 bio->iolen = l;
605 bio->iocp = 0;
606
607 return 1;
608}
int iolen
Definition utils.c:579
unsigned char iobuf[BASEMAXINLINE]
Definition utils.c:582
int ateof
Definition utils.c:581
int iocp
Definition utils.c:578

References baseio::ateof, BASEMAXINLINE, baseio::iobuf, baseio::iocp, and baseio::iolen.

Referenced by analys_(), ast_eivr_getvariable(), ast_eivr_setvariable(), find_sequence(), inchar(), lpfilt_(), netconsole(), preemp_(), term_color(), term_strip(), voicin_(), and vparms_().

◆ inchar()

static int inchar ( struct baseio bio,
FILE *  fi 
)
static

utility used by base_encode()

Definition at line 613 of file utils.c.

614{
615 if (bio->iocp >= bio->iolen) {
616 if (!inbuf(bio, fi)) {
617 return EOF;
618 }
619 }
620
621 return bio->iobuf[bio->iocp++];
622}
static int inbuf(struct baseio *bio, FILE *fi)
utility used by inchar(), for base_encode()
Definition utils.c:588

References inbuf(), baseio::iobuf, baseio::iocp, and baseio::iolen.

Referenced by ast_base64_encode_file().

◆ ochar()

static int ochar ( struct baseio bio,
int  c,
FILE *  so,
const char *  endl 
)
static

utility used by base_encode()

Definition at line 627 of file utils.c.

628{
629 if (bio->linelength >= BASELINELEN) {
630 if (fputs(endl, so) == EOF) {
631 return -1;
632 }
633
634 bio->linelength = 0;
635 }
636
637 if (putc(((unsigned char) c), so) == EOF) {
638 return -1;
639 }
640
641 bio->linelength++;
642
643 return 1;
644}
int linelength
Definition utils.c:580
#define BASELINELEN
Definition utils.c:573

References BASELINELEN, c, and baseio::linelength.

Referenced by ast_base64_encode_file().

◆ safe_mkdir()

static int safe_mkdir ( const char *  base_path,
char *  path,
int  mode 
)
static

Definition at line 2548 of file utils.c.

2549{
2550 RAII_VAR(char *, absolute_path, NULL, ast_std_free);
2551
2552 absolute_path = realpath(path, NULL);
2553
2554 if (absolute_path) {
2555 /* Path exists, but is it in the right place? */
2556 if (!ast_begins_with(absolute_path, base_path)) {
2557 return EPERM;
2558 }
2559
2560 /* It is in the right place! */
2561 return 0;
2562 } else {
2563 /* Path doesn't exist. */
2564
2565 /* The slash terminating the subpath we're checking */
2566 char *path_term = strchr(path, '/');
2567 /* True indicates the parent path is within base_path */
2568 int parent_is_safe = 0;
2569 int res;
2570
2571 while (path_term) {
2572 RAII_VAR(char *, absolute_subpath, NULL, ast_std_free);
2573
2574 /* Truncate the path one past the slash */
2575 char c = *(path_term + 1);
2576 *(path_term + 1) = '\0';
2577 absolute_subpath = realpath(path, NULL);
2578
2579 if (absolute_subpath) {
2580 /* Subpath exists, but is it safe? */
2581 parent_is_safe = ast_begins_with(
2582 absolute_subpath, base_path);
2583 } else if (parent_is_safe) {
2584 /* Subpath does not exist, but parent is safe
2585 * Create it */
2586 res = mkdir(path, mode);
2587 if (res != 0) {
2588 ast_assert(errno != EEXIST);
2589 return errno;
2590 }
2591 } else {
2592 /* Subpath did not exist, parent was not safe
2593 * Fail! */
2594 errno = EPERM;
2595 return errno;
2596 }
2597 /* Restore the path */
2598 *(path_term + 1) = c;
2599 /* Move on to the next slash */
2600 path_term = strchr(path_term + 1, '/');
2601 }
2602
2603 /* Now to build the final path, but only if it's safe */
2604 if (!parent_is_safe) {
2605 errno = EPERM;
2606 return errno;
2607 }
2608
2609 res = mkdir(path, mode);
2610 if (res != 0 && errno != EEXIST) {
2611 return errno;
2612 }
2613
2614 return 0;
2615 }
2616}
static int force_inline attribute_pure ast_begins_with(const char *str, const char *prefix)
Checks whether a string begins with another.
Definition strings.h:97

References ast_assert, ast_begins_with(), ast_std_free(), c, errno, NULL, and RAII_VAR.

Referenced by ast_safe_mkdir().

◆ tvfix()

static struct timeval tvfix ( struct timeval  a)
static

Definition at line 2272 of file utils.c.

2273{
2274 if (a.tv_usec >= ONE_MILLION) {
2275 ast_log(LOG_WARNING, "warning too large timestamp %ld.%ld\n",
2276 (long)a.tv_sec, (long int) a.tv_usec);
2277 a.tv_sec += a.tv_usec / ONE_MILLION;
2278 a.tv_usec %= ONE_MILLION;
2279 } else if (a.tv_usec < 0) {
2280 ast_log(LOG_WARNING, "warning negative timestamp %ld.%ld\n",
2281 (long)a.tv_sec, (long int) a.tv_usec);
2282 a.tv_usec = 0;
2283 }
2284 return a;
2285}

References a, ast_log, LOG_WARNING, and ONE_MILLION.

Referenced by ast_tvadd(), and ast_tvsub().

◆ utils_shutdown()

static void utils_shutdown ( void  )
static

Definition at line 2642 of file utils.c.

2643{
2644 close(dev_urandom_fd);
2645 dev_urandom_fd = -1;
2646#if defined(DEBUG_THREADS) && !defined(LOW_MEMORY)
2647 ast_cli_unregister_multiple(utils_cli, ARRAY_LEN(utils_cli));
2648#endif
2649}
void ast_cli_unregister_multiple(void)
Definition ael_main.c:408

References ARRAY_LEN, ast_cli_unregister_multiple(), and dev_urandom_fd.

Referenced by ast_utils_init().

◆ wait_for_output()

static int wait_for_output ( int  fd,
int  timeoutms 
)
static

Definition at line 1752 of file utils.c.

1753{
1754 struct pollfd pfd = {
1755 .fd = fd,
1756 .events = POLLOUT,
1757 };
1758 int res;
1759 struct timeval start = ast_tvnow();
1760 int elapsed = 0;
1761
1762 /* poll() until the fd is writable without blocking */
1763 while ((res = ast_poll(&pfd, 1, timeoutms - elapsed)) <= 0) {
1764 if (res == 0) {
1765 /* timed out. */
1766#ifndef STANDALONE
1767 ast_debug(1, "Timed out trying to write\n");
1768#endif
1769 return -1;
1770 } else if (res == -1) {
1771 /* poll() returned an error, check to see if it was fatal */
1772
1773 if (errno == EINTR || errno == EAGAIN) {
1774 elapsed = ast_tvdiff_ms(ast_tvnow(), start);
1775 if (elapsed >= timeoutms) {
1776 return -1;
1777 }
1778 /* This was an acceptable error, go back into poll() */
1779 continue;
1780 }
1781
1782 /* Fatal error, bail. */
1783 ast_log(LOG_ERROR, "poll returned error: %s\n", strerror(errno));
1784
1785 return -1;
1786 }
1787 elapsed = ast_tvdiff_ms(ast_tvnow(), start);
1788 if (elapsed >= timeoutms) {
1789 return -1;
1790 }
1791 }
1792
1793 return 0;
1794}

References ast_debug, ast_log, ast_poll, ast_tvdiff_ms(), ast_tvnow(), errno, and LOG_ERROR.

Referenced by ast_carefulwrite().

Variable Documentation

◆ ast_uri_http

const struct ast_flags ast_uri_http = {AST_URI_UNRESERVED}

◆ ast_uri_http_legacy

const struct ast_flags ast_uri_http_legacy = {AST_URI_LEGACY_SPACE | AST_URI_UNRESERVED}

◆ ast_uri_sip_user

const struct ast_flags ast_uri_sip_user = {AST_URI_UNRESERVED | AST_URI_SIP_USER_UNRESERVED}

Definition at line 719 of file utils.c.

Referenced by AST_TEST_DEFINE().

◆ b2a

char b2a[256]
static

Definition at line 82 of file utils.c.

Referenced by ast_base64decode(), and base64_init().

◆ b2a_url

char b2a_url[256]
static

Definition at line 83 of file utils.c.

Referenced by ast_base64url_decode(), and base64_init().

◆ base64

char base64[64]
static

◆ base64url

char base64url[64]
static

Definition at line 81 of file utils.c.

Referenced by ast_base64url_encode_full(), and base64_init().

◆ dev_urandom_fd

int dev_urandom_fd = -1
static

Definition at line 972 of file utils.c.

Referenced by ast_random(), ast_utils_init(), ast_uuid_init(), and utils_shutdown().

◆ escape_sequences

char escape_sequences[]
Initial value:
= {
'\a', '\b', '\f', '\n', '\r', '\t', '\v', '\\', '\'', '\"', '\?', '\0'
}

Definition at line 2056 of file utils.c.

2056 {
2057 '\a', '\b', '\f', '\n', '\r', '\t', '\v', '\\', '\'', '\"', '\?', '\0'
2058};

Referenced by ast_escape(), and ast_escape_c().

◆ escape_sequences_map

char escape_sequences_map[]
static
Initial value:
= {
'a', 'b', 'f', 'n', 'r', 't', 'v', '\\', '\'', '"', '?', '\0'
}

Definition at line 2064 of file utils.c.

2064 {
2065 'a', 'b', 'f', 'n', 'r', 't', 'v', '\\', '\'', '"', '?', '\0'
2066};

Referenced by ast_escape(), and ast_escape_c().

◆ randomlock

ast_mutex_t randomlock = AST_MUTEX_INIT_VALUE
static

Definition at line 2343 of file utils.c.

Referenced by ast_random().