octstr.c File Reference

#include <ctype.h>
#include <limits.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include "gwlib.h"
#include "gwlib/html-entities.def"

Go to the source code of this file.

Data Structures
struct	Octstr
struct	format

Macros
#define	VARGS(x)   (&x)
#define	VALPARM(y)   va_list *y
#define	VALST(z)   (*z)
#define	MAX_IMMUTABLES   1024
#define	CSTR_TO_LONG(ptr)   (((unsigned long) ptr) >> 2)
#define	H2B(a)
#define	seems_valid(ostr)   (seems_valid_real(ostr, __FILE__, __LINE__, __func__))
#define	LLinfo   info
#define	LLwarning   warning
#define	LLerror   error
#define	octstr_dump_LOGLEVEL(loglevel, ostr, level)
#define	ENTITY(a, b)
#define	ENTITY(a, b)   { a, b },

Functions
static void	seems_valid_real (const Octstr *ostr, const char *filename, long lineno, const char *function)
static void	octstr_grow (Octstr *ostr, long size)
static void	urlcode_init (void)
void	octstr_init (void)
void	octstr_shutdown (void)
Octstr *	octstr_create_real (const char *cstr, const char *file, long line, const char *func)
Octstr *	octstr_create_from_data_real (const char *data, long len, const char *file, long line, const char *func)
Octstr *	octstr_imm (const char *cstr)
void	octstr_destroy (Octstr *ostr)
void	octstr_destroy_item (void *os)
long	octstr_len (const Octstr *ostr)
Octstr *	octstr_copy_real (const Octstr *ostr, long from, long len, const char *file, long line, const char *func)
Octstr *	octstr_duplicate_real (const Octstr *ostr, const char *file, long line, const char *func)
Octstr *	octstr_cat (Octstr *ostr1, Octstr *ostr2)
int	octstr_get_char (const Octstr *ostr, long pos)
void	octstr_set_char (Octstr *ostr, long pos, int ch)
void	octstr_get_many_chars (char *buf, Octstr *ostr, long pos, long len)
char *	octstr_get_cstr_real (const Octstr *ostr, const char *file, long line, const char *func)
void	octstr_append_from_hex (Octstr *ostr, char *hex)
void	octstr_binary_to_hex (Octstr *ostr, int uppercase)
int	octstr_hex_to_binary (Octstr *ostr)
void	octstr_binary_to_base64 (Octstr *ostr)
void	octstr_base64_to_binary (Octstr *ostr)
long	octstr_parse_long (long *nump, Octstr *ostr, long pos, int base)
long	octstr_parse_double (double *nump, Octstr *ostr, long pos)
int	octstr_check_range (Octstr *ostr, long pos, long len, octstr_func_t filter)
void	octstr_convert_range (Octstr *ostr, long pos, long len, octstr_func_t map)
static int	make_printable (int c)
void	octstr_convert_printable (Octstr *ostr)
int	octstr_compare (const Octstr *ostr1, const Octstr *ostr2)
int	octstr_case_compare (const Octstr *os1, const Octstr *os2)
int	octstr_ncompare (const Octstr *ostr1, const Octstr *ostr2, long n)
int	octstr_str_compare (const Octstr *ostr, const char *str)
int	octstr_str_case_compare (const Octstr *ostr, const char *str)
int	octstr_str_ncompare (const Octstr *ostr, const char *str, long n)
long	octstr_search_char (const Octstr *ostr, int ch, long pos)
long	octstr_rsearch_char (const Octstr *ostr, int ch, long pos)
long	octstr_search_chars (const Octstr *ostr, const Octstr *chars, long pos)
long	octstr_search (const Octstr *haystack, const Octstr *needle, long pos)
long	octstr_case_search (const Octstr *haystack, const Octstr *needle, long pos)
long	octstr_case_nsearch (const Octstr *haystack, const Octstr *needle, long pos, long n)
long	octstr_str_search (const Octstr *haystack, const char *needle, long pos)
int	octstr_print (FILE *f, Octstr *ostr)
int	octstr_pretty_print (FILE *f, Octstr *ostr)
int	octstr_write_to_socket (int socket, Octstr *ostr)
long	octstr_write_data (Octstr *ostr, int fd, long from)
int	octstr_append_from_socket (Octstr *ostr, int socket)
void	octstr_insert (Octstr *ostr1, const Octstr *ostr2, long pos)
void	octstr_truncate (Octstr *ostr, int new_len)
void	octstr_strip_blanks (Octstr *text)
static int	iscrlf (unsigned char c)
void	octstr_strip_crlfs (Octstr *text)
void	octstr_strip_nonalphanums (Octstr *text)
void	octstr_shrink_blanks (Octstr *text)
void	octstr_insert_data (Octstr *ostr, long pos, const char *data, long len)
void	octstr_insert_char (Octstr *ostr, long pos, const char c)
void	octstr_append_data (Octstr *ostr, const char *data, long len)
void	octstr_append (Octstr *ostr1, const Octstr *ostr2)
void	octstr_append_cstr (Octstr *ostr, const char *cstr)
void	octstr_append_char (Octstr *ostr, int ch)
void	octstr_delete (Octstr *ostr1, long pos, long len)
Octstr *	octstr_read_file (const char *filename)
Octstr *	octstr_read_pipe (FILE *f)
List *	octstr_split_words (const Octstr *ostr)
List *	octstr_split (const Octstr *os, const Octstr *sep)
int	octstr_item_match (void *item, void *pattern)
int	octstr_item_case_match (void *item, void *pattern)
void	octstr_url_encode (Octstr *ostr)
int	octstr_url_decode (Octstr *ostr)
long	octstr_get_bits (Octstr *ostr, long bitpos, int numbits)
void	octstr_set_bits (Octstr *ostr, long bitpos, int numbits, unsigned long value)
void	octstr_append_uintvar (Octstr *ostr, unsigned long value)
long	octstr_extract_uintvar (Octstr *ostr, unsigned long *value, long pos)
void	octstr_append_decimal (Octstr *ostr, long value)
static void	octstr_dump_debug (const Octstr *ostr, int level)
void	octstr_dump_real (const Octstr *ostr, int level,...)
void	octstr_dump_short (Octstr *ostr, int level, const char *name)
static void	format_flags (struct format *format, const char **fmt)
static void	format_width (struct format *format, const char **fmt, VALPARM(args))
static void	format_prec (struct format *format, const char **fmt, VALPARM(args))
static void	format_type (struct format *format, const char **fmt)
static void	convert (Octstr *os, struct format *format, const char **fmt, VALPARM(args))
Octstr *	octstr_format (const char *fmt,...)
Octstr *	octstr_format_valist_real (const char *fmt, va_list args)
void	octstr_format_append (Octstr *os, const char *fmt,...)
unsigned long	octstr_hash_key (Octstr *ostr)
int	octstr_recode (Octstr *tocode, Octstr *fromcode, Octstr *orig)
void	octstr_strip_char (Octstr *text, char ch)
int	octstr_isnum (Octstr *ostr1)
void	octstr_replace (Octstr *haystack, Octstr *needle, Octstr *repl)
void	octstr_replace_first (Octstr *haystack, Octstr *needle, Octstr *repl)
int	octstr_symbolize (Octstr *ostr)
void	octstr_delete_matching (Octstr *haystack, Octstr *needle)
int	octstr_is_all_hex (Octstr *os)
void	octstr_convert_to_html_entities (Octstr *input)
static int	octstr_find_entity (Octstr *input, int startfind, int endfind)
void	octstr_convert_from_html_entities (Octstr *input)

Variables
static Octstr *	immutables [MAX_IMMUTABLES]
static Mutex	immutables_mutex
static int	immutables_init = 0
static char	is_safe [UCHAR_MAX+1]

Macro Definition Documentation

CSTR_TO_LONG

#define CSTR_TO_LONG

(

ptr

)

(((unsigned long) ptr) >> 2)

Definition at line 145 of file octstr.c.

Referenced by octstr_imm().

ENTITY [1/2]

#define ENTITY	(		a,
			b
	)

Value:

case a: \
    octstr_delete(input, i, 1); \
    octstr_insert(input, octstr_imm("&" b ";"), i); \
    i += sizeof(b); break;

ENTITY [2/2]

#define ENTITY	(		a,
			b
	)		{ a, b },

H2B

#define H2B

(

a

)

Value:

(a >= '0' && a <= '9' ? \
    a - '0' : (a >= 'a' && a <= 'f' ? \
        a - 'a' + 10 : (a >= 'A' && a <= 'F' ? a - 'A' + 10 : -1) \
        ) \
    )

Definition at line 151 of file octstr.c.

Referenced by octstr_url_decode().

LLerror

#define LLerror   error

Definition at line 2057 of file octstr.c.

LLinfo

#define LLinfo   info

Definition at line 2055 of file octstr.c.

LLwarning

#define LLwarning   warning

Definition at line 2056 of file octstr.c.

MAX_IMMUTABLES

#define MAX_IMMUTABLES   1024

Definition at line 131 of file octstr.c.

Referenced by octstr_imm(), and octstr_shutdown().

octstr_dump_LOGLEVEL

#define octstr_dump_LOGLEVEL	(		loglevel,
			ostr,
			level
	)

Definition at line 2059 of file octstr.c.

Referenced by octstr_dump_real().

seems_valid

#define seems_valid

(

ostr

)

(seems_valid_real(ostr, __FILE__, __LINE__, __func__))

Definition at line 169 of file octstr.c.

Referenced by octstr_append_from_hex(), octstr_append_from_socket(), octstr_base64_to_binary(), octstr_binary_to_base64(), octstr_binary_to_hex(), octstr_case_compare(), octstr_case_nsearch(), octstr_case_search(), octstr_cat(), octstr_check_range(), octstr_compare(), octstr_convert_range(), octstr_create_from_data_real(), octstr_delete(), octstr_delete_matching(), octstr_destroy(), octstr_dump_debug(), octstr_dump_short(), octstr_format_valist_real(), octstr_get_bits(), octstr_get_char(), octstr_get_many_chars(), octstr_grow(), octstr_hex_to_binary(), octstr_imm(), octstr_insert(), octstr_insert_char(), octstr_insert_data(), octstr_is_all_hex(), octstr_isnum(), octstr_len(), octstr_ncompare(), octstr_parse_double(), octstr_parse_long(), octstr_pretty_print(), octstr_print(), octstr_rsearch_char(), octstr_search(), octstr_search_char(), octstr_search_chars(), octstr_set_bits(), octstr_set_char(), octstr_shrink_blanks(), octstr_split_words(), octstr_str_case_compare(), octstr_str_compare(), octstr_str_ncompare(), octstr_str_search(), octstr_strip_blanks(), octstr_strip_char(), octstr_strip_crlfs(), octstr_strip_nonalphanums(), octstr_symbolize(), octstr_truncate(), octstr_url_decode(), octstr_url_encode(), octstr_write_data(), and octstr_write_to_socket().

VALPARM

#define VALPARM

(

y

)

va_list *y

Definition at line 90 of file octstr.c.

VALST

#define VALST

(

z

)

(*z)

Definition at line 91 of file octstr.c.

Referenced by convert(), format_prec(), and format_width().

VARGS

#define VARGS

(

x

)

(&x)

Definition at line 89 of file octstr.c.

Referenced by octstr_format_valist_real().

Function Documentation

convert()

static void convert ( Octstr *  os, struct format *  format, const char **  fmt, VALPARM(args)    )

static

Definition at line 2300 of file octstr.c.

References format::has_prec, format::min_width, format::minus, octstr_append(), octstr_append_data(), octstr_append_decimal(), octstr_binary_to_hex(), octstr_create, octstr_create_from_data, octstr_destroy(), octstr_duplicate, octstr_insert_data(), octstr_len(), octstr_truncate(), octstr_url_encode(), panic, format::prec, format::type, VALST, and format::zero.

Referenced by octstr_format_valist_real().

{
    Octstr *new;
    char *s, *pad;
    long long n;
    unsigned long long u;
    char tmpfmt[1024];
    char tmpbuf[1024];
    char c;
    void *p;

    new = NULL;

    switch (**fmt)
    {
    case 'c':
        c = va_arg(VALST(args), int);
        new = octstr_create_from_data(&c, 1);
        break;

    case 'd':
    case 'i':
        switch (format->type) {
        case 'L':
            n = va_arg(VALST(args), long long);
            break;
        case 'l':
            n = va_arg(VALST(args), long);
            break;
        case 'h':
            n = (short) va_arg(VALST(args), int);
            break;
        default:
            n = va_arg(VALST(args), int);
            break;
        }
        new = octstr_create("");
        octstr_append_decimal(new, n);
        break;

    case 'o':
    case 'u':
    case 'x':
    case 'X':
   switch (format->type) {
   case 'l':
      u = va_arg(VALST(args), unsigned long);
      break;
   case 'L':
      u = va_arg(VALST(args), unsigned long long);
      break;
   case 'h':
      u = (unsigned short) va_arg(VALST(args), unsigned int);
      break;
   default:
      u = va_arg(VALST(args), unsigned int);
      break;
   }
   tmpfmt[0] = '%';
    tmpfmt[1] = 'l';
    tmpfmt[2] = **fmt;
    tmpfmt[3] = '\0';
    sprintf(tmpbuf, tmpfmt, u);
        new = octstr_create(tmpbuf);
        break;

    case 'e':
    case 'f':
    case 'g':
        sprintf(tmpfmt, "%%");
        if (format->minus)
            strcat(tmpfmt, "-");
        if (format->zero)
            strcat(tmpfmt, "0");
        if (format->min_width > 0)
            sprintf(strchr(tmpfmt, '\0'),
                    "%ld", format->min_width);
        if (format->has_prec)
            sprintf(strchr(tmpfmt, '\0'),
                    ".%ld", format->prec);
        if (format->type != '\0')
            sprintf(strchr(tmpfmt, '\0'),
                    "%c", (int) format->type);
        sprintf(strchr(tmpfmt, '\0'), "%c", **fmt);
        snprintf(tmpbuf, sizeof(tmpbuf),
                 tmpfmt, va_arg(VALST(args), double));
        new = octstr_create(tmpbuf);
        break;

    case 's':
        s = va_arg(VALST(args), char *);
        if (format->has_prec && format->prec < (long) strlen(s))
            n = format->prec;
        else
            n = (long) strlen(s);
        new = octstr_create_from_data(s, n);
        break;

    case 'p':
        p = va_arg(VALST(args), void *);
    sprintf(tmpfmt, "%p", p);
    new = octstr_create(tmpfmt);
    break;

    case 'S':
        new = octstr_duplicate(va_arg(VALST(args), Octstr *));
        if (!new)
            new = octstr_create("(null)");
        if (format->has_prec)
            octstr_truncate(new, format->prec);
        break;

    case 'E':
        new = octstr_duplicate(va_arg(VALST(args), Octstr *));
        if (!new)
            new = octstr_create("(null)");
        octstr_url_encode(new);
        /*
         * note: we use blind truncate - encoded character can get cut half-way.
         */
        if (format->has_prec)
            octstr_truncate(new, format->prec);
        break;

    case 'H':
        new = octstr_duplicate(va_arg(VALST(args), Octstr *));
        if (!new)
            new = octstr_create("(null)");
        /* upper case */
        octstr_binary_to_hex(new, 1);
        if (format->has_prec)
            octstr_truncate(new, (format->prec % 2 ? format->prec - 1 : format->prec));
        break;

    case '%':
        new = octstr_create("%");
        break;

    default:
        panic(0, "octstr_format format string syntax error.");
    }

    if (format->zero)
        pad = "0";
    else
        pad = " ";

    if (format->minus) {
        while (format->min_width > octstr_len(new))
            octstr_append_data(new, pad, 1);
    } else {
        while (format->min_width > octstr_len(new))
            octstr_insert_data(new, 0, pad, 1);
    }

    octstr_append(os, new);
    octstr_destroy(new);

    if (**fmt != '\0')
        ++(*fmt);
}

format_flags()

static void format_flags ( struct format *  format, const char **  fmt  )

static

Definition at line 2215 of file octstr.c.

References format::minus, and format::zero.

Referenced by octstr_format_valist_real().

{
    int done;

    done = 0;
    do
    {
        switch (**fmt) {
        case '-':
            format->minus = 1;
            break;

        case '0':
            format->zero = 1;
            break;

        default:
            done = 1;
        }

        if (!done)
            ++(*fmt);
    } while (!done);
}

format_prec()

static void format_prec ( struct format *  format, const char **  fmt, VALPARM(args)    )

static

Definition at line 2259 of file octstr.c.

References format::has_prec, format::prec, and VALST.

Referenced by octstr_format_valist_real().

{
    char *end;

    if (**fmt != '.')
        return;
    ++(*fmt);
    if (**fmt == '*')
    {
        format->has_prec = 1;
        format->prec = va_arg(VALST(args), int);
        ++(*fmt);
    } else if (isdigit(**(const unsigned char **) fmt))
    {
        format->has_prec = 1;
        format->prec = strtol(*fmt, &end, 10);
        *fmt = end;
        /* XXX error checking is missing from here */
    }
}

format_type()

static void format_type ( struct format *  format, const char **  fmt  )

static

Definition at line 2282 of file octstr.c.

References format::type.

Referenced by octstr_format_valist_real().

{
    switch (**fmt) {
    case 'h':
        format->type = **fmt;
        ++(*fmt);
        break;
    case 'l':
        if (*(*fmt + 1) == 'l'){
           format->type = 'L';
           ++(*fmt);
        } else format->type = **fmt;
        ++(*fmt);
        break;
    }
}

format_width()

static void format_width ( struct format *  format, const char **  fmt, VALPARM(args)    )

static

Definition at line 2241 of file octstr.c.

References format::min_width, and VALST.

Referenced by octstr_format_valist_real().

{
    char *end;

    if (**fmt == '*')
    {
        format->min_width = va_arg(VALST(args), int);
        ++(*fmt);
    } else if (isdigit(**(const unsigned char **) fmt))
    {
        format->min_width = strtol(*fmt, &end, 10);
        *fmt = end;
        /* XXX error checking is missing from here */
    }
}

iscrlf()

static int iscrlf ( unsigned char  c )

static

Definition at line 1373 of file octstr.c.

Referenced by octstr_strip_crlfs().

{
    return c == '\n' || c == '\r';
}

make_printable()

static int make_printable ( int  c )

inlinestatic

Definition at line 858 of file octstr.c.

Referenced by octstr_convert_printable().

{
    return isprint(c) ? c : '.';    
}

octstr_append()

void octstr_append	(	Octstr *	ostr1,
		const Octstr *	ostr2
	)

Definition at line 1504 of file octstr.c.

References gw_assert(), Octstr::len, and octstr_insert().

Referenced by add_part_header(), add_wsp_get(), append_crlf(), assembly_sar_event(), at2_init_device(), at2_pdu_encode(), at2_pdu_extract(), at2_wait_modem_command(), build_request(), build_response(), catenate_msg(), cfg_get_group_checksum(), cgw_handle_op(), cgwop_tostr(), challenge(), charset_gsm_to_utf8(), charset_utf8_to_gsm(), concat_handling_check_and_handle(), concat_msgids(), conn_write(), conn_write_withlen(), convert(), dlr_spool_add(), dlr_spool_get(), dlr_spool_remove(), emi2_handle_smscreq(), emimsg_tostring(), encode_binary_data(), expand_file(), get_pattern(), get_x_kannel_from_xml(), http_header_pack(), http_header_split_auth_value(), http_send_reply(), httpd_serve(), main(), make_close_delimiter(), make_multipart_value(), make_part_delimiter(), make_start_delimiter(), make_url(), mime_decompile(), mime_entity_to_octstr(), mime_something_to_entity(), msg_to_cgwop(), msg_to_emimsg(), obey_request(), octstr_append_from_hex(), octstr_format_append(), octstr_recode(), oisd_send_delivery_request(), oisd_shrink_gsm7(), ota_pack_push_headers(), ota_tokenize_bookmarks(), ota_tokenize_settings(), pack_7bit(), pack_cache_control(), pack_md5(), pack_quoted_string(), pack_server_address(), pack_tpis(), packet_encode_message(), parse2trans(), pass_field_name(), pass_field_value(), proxy_unpack_credentials(), push_content_create(), radius_authenticate_pdu(), radius_type_convert(), read_body_until_eof(), read_chunked_body_data(), read_mime_headers(), read_some_headers(), recover_absolute_uri(), send_message(), set_cookies(), sms_split(), sms_to_client(), smsc2_status(), smsc_emi2_create(), soap_format_xml(), soap_msgdata_attribute(), soap_o2o_msgdata_attribute(), start_request(), unpack_cache_directive(), unpack_challenge(), unpack_credentials(), unpack_optional_q_value(), unpack_parameter(), unpack_warning_value(), urltrans_fill_escape_codes(), wap_map_url(), wml_charsets(), wsp_cap_pack_list(), wsp_pack_quoted_text(), wsp_pack_text(), wsp_pack_value(), xidris_send_sms(), and xmlrpc_print_array().

{
    gw_assert(ostr1 != NULL);
    octstr_insert(ostr1, ostr2, ostr1->len);
}

octstr_append_char()

void octstr_append_char	(	Octstr *	ostr,
		int	ch
	)

Definition at line 1517 of file octstr.c.

References gw_assert(), Octstr::len, and octstr_insert_data().

Referenced by add_wsp_disconnect(), add_wsp_get(), append_encoded_integer(), at2_convertpdu(), at2_decode7bituncompressed(), at2_encode7bituncompressed(), at2_encode8bituncompressed(), at2_format_address_field(), at2_init_device(), at2_pdu_decode_deliver_sm(), at2_pdu_decode_report_sm(), at2_pdu_encode(), cgw_handle_op(), cgwop_tostr(), charset_gsm_to_utf8(), charset_utf8_to_gsm(), convert_html_entity(), convert_q_value(), decode_binary_data(), emi2_handle_smscreq(), emimsg_tostring(), encode_binary_data(), get_pattern(), gsm2number(), html_to_sms(), http_header_split_auth_value(), httpsmsc_receiver(), main(), msg_to_emimsg(), oisd_expand_gsm7(), oisd_send_delivery_request(), oisd_send_response(), oisd_shrink_gsm7(), ota_tokenize_bookmarks(), ota_tokenize_settings(), output_char(), output_st_char(), output_variable(), pack_7bit(), pack_challenge(), pack_credentials(), pack_md5(), pack_parameter(), pack_quoted_string(), pack_range_value(), pack_server_address(), packet_encode_message(), parse2trans(), parse_value(), parse_variable(), prepend_catenation_udh(), proxy_unpack_credentials(), randomize(), recover_absolute_uri(), reply_known_capabilities(), set_cookies(), smasi_pdu_pack(), sms_to_client(), smsc_emi2_create(), soap_format_xml(), string_table_apply(), string_table_output(), tokenize_date(), unpack_cache_directive(), unpack_challenge(), unpack_credentials(), unpack_parameter(), unpack_range_value(), unpack_warning_value(), urltrans_fill_escape_codes(), wml_binary_output(), wml_charsets(), wsp_cap_pack_list(), wsp_pack_long_integer(), wsp_pack_quoted_text(), wsp_pack_retry_after(), wsp_pack_short_integer(), wsp_pack_text(), wsp_pack_value(), and wsp_unpack_version_value().

{
    unsigned char c = ch;

    gw_assert(ch >= 0);
    gw_assert(ch <= UCHAR_MAX);
    octstr_insert_data(ostr, ostr->len, &c, 1);
}

octstr_append_cstr()

void octstr_append_cstr	(	Octstr *	ostr,
		const char *	cstr
	)

Definition at line 1511 of file octstr.c.

References Octstr::len, and octstr_insert_data().

Referenced by add_content_transfer_encoding_type(), add_content_type(), append_uuid(), at2_extract_line(), at2_wait_modem_command(), bb_print_status(), boxc_status(), cfg_read(), clickatell_send_sms(), create_onetrans(), get_pattern(), http_header_get_content_type(), httpd_serve(), kannel_send_sms(), mime_entity_dump_real(), mime_something_to_entity(), octstr_append_decimal(), operation_name(), packet_extract(), parse_cookie(), radius_type_convert(), smasi_pdu_pack(), smsc2_status(), store_status(), url_pattern(), and urltrans_fill_escape_codes().

{
    octstr_insert_data(ostr, ostr->len, cstr, strlen(cstr));
}

octstr_append_data()

void octstr_append_data	(	Octstr *	ostr,
		const char *	data,
		long	len
	)

Definition at line 1497 of file octstr.c.

References gw_assert(), Octstr::len, and octstr_insert_data().

Referenced by add_wsp_connect(), append_integer(), at2_read_buffer(), charset_convert(), client_session(), conn_write_data(), conn_write_withlen(), convert(), gen_data(), get_pattern(), main(), octstr_append_from_socket(), octstr_append_uintvar(), octstr_format_valist_real(), octstr_read_pipe(), radius_authenticate_pdu(), read_data(), read_line(), send_post(), set_charset(), unlocked_read(), url_pattern(), and wap_msg_send().

{
    gw_assert(ostr != NULL);
    octstr_insert_data(ostr, ostr->len, data, len);
}

octstr_append_decimal()

void octstr_append_decimal	(	Octstr *	ostr,
		long	value
	)

Definition at line 1976 of file octstr.c.

References octstr_append_cstr().

Referenced by cgw_handle_op(), cgwop_create(), convert(), get_pattern(), msg_to_emimsg(), pack_server_address(), smsc_emi2_create(), unpack_parameter(), unpack_range_value(), urltrans_fill_escape_codes(), wsp_unpack_integer_value(), wsp_unpack_version_value(), and wsp_unpack_well_known_field().

{
    char tmp[128];

    sprintf(tmp, "%ld", value);
    octstr_append_cstr(ostr, tmp);
}

octstr_append_from_hex()

void octstr_append_from_hex	(	Octstr *	ostr,
		char *	hex
	)

Definition at line 451 of file octstr.c.

References gw_assert(), Octstr::immutable, octstr_append(), octstr_create, octstr_destroy(), octstr_hex_to_binary(), and seems_valid.

Referenced by cimd_submit_msg(), client_thread(), main(), ota_pack_push_headers(), ota_pack_udh(), ota_tokenize_bookmarks(), and ota_tokenize_settings().

{
    Octstr *output;
    
    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    
    output = octstr_create(hex);
    octstr_hex_to_binary(output);
    octstr_append(ostr, output);
    octstr_destroy(output);
}

octstr_append_from_socket()

int octstr_append_from_socket	(	Octstr *	ostr,
		int	socket
	)

Definition at line 1280 of file octstr.c.

References error(), gw_assert(), Octstr::immutable, octstr_append_data(), and seems_valid.

Referenced by cimd2_get_packet(), cimd2_receive_msg(), oisd_get_packet(), and oisd_receive_msg().

{
    unsigned char buf[4096];
    int len;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

again:
    len = recv(socket, buf, sizeof(buf), 0);
    if (len < 0 && errno == EINTR)
        goto again;

    if (len < 0) {
        error(errno, "Could not read from socket %d", socket);
        return -1;
    }

    octstr_append_data(ostr, buf, len);
    return len;
}

octstr_append_uintvar()

void octstr_append_uintvar	(	Octstr *	ostr,
		unsigned long	value
	)

Definition at line 1931 of file octstr.c.

References octstr_append_data(), and start.

Referenced by add_wsp_disconnect(), add_wsp_get(), ota_pack_push_headers(), output_variable(), pack_content_range(), pack_qvalue(), pack_range_value(), parse_attribute(), parse_element(), reply_known_capabilities(), simple_binary_output(), string_table_apply(), wml_binary_output(), wsp_cap_pack_list(), and wsp_pack_value().

{
    /* A uintvar is defined to be up to 32 bits large, so it will
     * fit in 5 octets. */
    unsigned char octets[5];
    int i;
    int start;

    /* Handle last byte separately; it has no continuation bit,
     * and must be encoded even if value is 0. */
    octets[4] = value & 0x7f;
    value >>= 7;

    for (i = 3; value > 0 && i >= 0; i--) {
        octets[i] = 0x80 | (value & 0x7f);
        value >>= 7;
    }
    start = i + 1;

    octstr_append_data(ostr, octets + start, 5 - start);
}

octstr_base64_to_binary()

void octstr_base64_to_binary

(

Octstr *

ostr

)

Definition at line 663 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, seems_valid, and warning().

Referenced by extract_base64(), pack_credentials(), pack_md5(), response(), and soap_msgdata_deps().

{
    long triplet;
    long pos, len;
    long to;
    int quadpos = 0;
    int warned = 0;
    unsigned char *data;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

    len = ostr->len;
    data = ostr->data;

    if (len == 0)
        return;

    to = 0;
    triplet = 0;
    quadpos = 0;
    for (pos = 0; pos < len; pos++) {
        int c = data[pos];
        int sixbits;

        if (c >= 'A' && c <= 'Z') {
            sixbits = c - 'A';
        } else if (c >= 'a' && c <= 'z') {
            sixbits = 26 + c - 'a';
        } else if (c >= '0' && c <= '9') {
            sixbits = 52 + c - '0';
        } else if (c == '+') {
            sixbits = 62;
        } else if (c == '/') {
            sixbits = 63;
        } else if (c == '=') {
            /* These can only occur at the end of encoded
             * text.  RFC 2045 says we can assume it really
             * is the end. */
            break;
        } else if (isspace(c)) {
            /* skip whitespace */
            continue;
        } else {
            if (!warned) {
                warning(0, "Unusual characters in base64 "
                        "encoded text.");
                warned = 1;
            }
            continue;
        }

        triplet = (triplet << 6) | sixbits;
        quadpos++;

        if (quadpos == 4) {
            data[to++] = (triplet >> 16) & 0xff;
            data[to++] = (triplet >> 8) & 0xff;
            data[to++] = triplet & 0xff;
            quadpos = 0;
        }
    }

    /* Deal with leftover octets */
    switch (quadpos) {
    case 0:
        break;
    case 3:  /* triplet has 18 bits, we want the first 16 */
        data[to++] = (triplet >> 10) & 0xff;
        data[to++] = (triplet >> 2) & 0xff;
        break;
    case 2:  /* triplet has 12 bits, we want the first 8 */
        data[to++] = (triplet >> 4) & 0xff;
        break;
    case 1:
        warning(0, "Bad padding in base64 encoded text.");
        break;
    }

    ostr->len = to;
    data[to] = '\0';

    seems_valid(ostr);
}

octstr_binary_to_base64()

void octstr_binary_to_base64

(

Octstr *

ostr

)

Definition at line 542 of file octstr.c.

References Octstr::data, from, gw_assert(), Octstr::immutable, Octstr::len, lines, octstr_grow(), octstr_imm(), octstr_insert(), and seems_valid.

Referenced by http_add_basic_auth(), proxy_add_authentication(), soap_o2o_msgdata_attribute(), transfer_encode(), unpack_credentials(), and wsp_unpack_well_known_field().

{
    static const unsigned char base64[64] =
        "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
    long triplets;
    long lines;
    long orig_len;
    unsigned char *data;
    long from, to;
    int left_on_line;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

    if (ostr->len == 0) {
        /* Always terminate with CR LF */
        octstr_insert(ostr, octstr_imm("\015\012"), 0);
        return;
    }

    /* The lines must be 76 characters each (or less), and each
     * triplet will expand to 4 characters, so we can fit 19
     * triplets on one line.  We need a CR LF after each line,
     * which will add 2 octets per 19 triplets (rounded up). */
    triplets = (ostr->len + 2) / 3;   /* round up */
    lines = (triplets + 18) / 19;

    octstr_grow(ostr, triplets * 4 + lines * 2);
    orig_len = ostr->len;
    data = ostr->data;

    ostr->len = triplets * 4 + lines * 2;
    data[ostr->len] = '\0';

    /* This function works back-to-front, so that encoded data will
     * not overwrite source data.
     * from points to the start of the last triplet (which may be
     * an odd-sized one), and to points to the start of where the
     * last quad should go.  */
    from = (triplets - 1) * 3;
    to = (triplets - 1) * 4 + (lines - 1) * 2;

    /* First write the CR LF after the last quad */
    data[to + 5] = 10;   /* LF */
    data[to + 4] = 13;   /* CR */
    left_on_line = triplets - ((lines - 1) * 19);

    /* base64 encoding is in 3-octet units.  To handle leftover
     * octets, conceptually we have to zero-pad up to the next
     * 6-bit unit, and pad with '=' characters for missing 6-bit
     * units.
     * We do it by first completing the first triplet with 
     * zero-octets, and after the loop replacing some of the
     * result characters with '=' characters.
     * There is enough room for this, because even with a 1 or 2
     * octet source string, space for four octets of output
     * will be reserved.
     */
    switch (orig_len % 3) {
    case 0:
        break;
    case 1:
        data[orig_len] = 0;
        data[orig_len + 1] = 0;
        break;
    case 2:
        data[orig_len + 1] = 0;
        break;
    }

    /* Now we only have perfect triplets. */
    while (from >= 0) {
        long whole_triplet;

        /* Add a newline, if necessary */
        if (left_on_line == 0) {
            to -= 2;
            data[to + 5] = 10;  /* LF */
            data[to + 4] = 13;  /* CR */
            left_on_line = 19;
        }

        whole_triplet = (data[from] << 16) |
                        (data[from + 1] << 8) |
                        data[from + 2];
        data[to + 3] = base64[whole_triplet % 64];
        data[to + 2] = base64[(whole_triplet >> 6) % 64];
        data[to + 1] = base64[(whole_triplet >> 12) % 64];
        data[to] = base64[(whole_triplet >> 18) % 64];

        to -= 4;
        from -= 3;
        left_on_line--;
    }

    gw_assert(left_on_line == 0);
    gw_assert(from == -3);
    gw_assert(to == -4);

    /* Insert padding characters in the last quad.  Remember that
     * there is a CR LF between the last quad and the end of the
     * string. */
    switch (orig_len % 3) {
    case 0:
        break;
    case 1:
        gw_assert(data[ostr->len - 3] == 'A');
        gw_assert(data[ostr->len - 4] == 'A');
        data[ostr->len - 3] = '=';
        data[ostr->len - 4] = '=';
        break;
    case 2:
        gw_assert(data[ostr->len - 3] == 'A');
        data[ostr->len - 3] = '=';
        break;
    }

    seems_valid(ostr);
}

octstr_binary_to_hex()

void octstr_binary_to_hex	(	Octstr *	ostr,
		int	uppercase
	)

Definition at line 465 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, octstr_grow(), and seems_valid.

Referenced by at2_scan_for_telnet_escapes(), bb_alog_sms(), convert(), dlr_spool_add(), dlr_spool_get(), get_pattern(), kannel_send_sms(), main(), make_emi60(), msg_to_cgwop(), msg_to_emimsg(), ota_pack_push_headers(), our_hash_func(), pack_7bit(), packet_add_hex_parm(), soap_msgdata_attribute(), and urltrans_fill_escape_codes().

{
    unsigned char *hexits;
    long i, tmp;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    if (ostr->len == 0)
        return;

    hexits = uppercase ? "0123456789ABCDEF" : "0123456789abcdef";
    octstr_grow(ostr, ostr->len * 2);

    /* In-place modification must be done back-to-front to avoid
     * overwriting the data while we read it.  Even the order of
     * the two assignments is important, to get i == 0 right. */
    for (i = ostr->len - 1; i >= 0; i--) {
        tmp = i << 1; /* tmp = i * 2; */
        ostr->data[tmp + 1] = hexits[ostr->data[i] & 0xf];
        ostr->data[tmp] = hexits[ostr->data[i] >> 4];
    }

    ostr->len = ostr->len * 2;
    ostr->data[ostr->len] = '\0';

    seems_valid(ostr);
}

octstr_case_compare()

int octstr_case_compare	(	const Octstr *	os1,
		const Octstr *	os2
	)

Definition at line 903 of file octstr.c.

References Octstr::data, Octstr::len, and seems_valid.

Referenced by brunet_parse_reply(), cfg_get_bool(), check_comparisons(), generic_receive_sms(), get_x_kannel_from_headers(), handle_transaction(), http_get_header_parameter(), http_header_pack(), http_header_value(), init_bearerbox(), init_smsbox(), init_wapbox(), kannel_parse_reply(), normalize_charset(), octstr_item_case_match(), octstr_recode(), ota_pack_push_headers(), ota_pack_udh(), pack_challenge(), pack_credentials(), pack_pragma(), pap_get_content(), parse_array_element(), parse_attribute(), parse_bearer(), parse_client_specifier(), parse_data_element(), parse_delivery_method(), parse_document(), parse_element(), parse_fault_element(), parse_member_element(), parse_methodcall_element(), parse_methodresponse_element(), parse_network(), parse_ota_syncsettings(), parse_param_element(), parse_params_element(), parse_priority(), parse_requirement(), parse_state(), parse_struct_element(), parse_value_element(), qualifiers(), select_bearer_network(), set_any_value(), smsbox_req_handle(), smsbox_sendota_post(), smsbox_sendsms_post(), smsbox_xmlrpc_post(), soap_msgdata_deps(), string_to_number(), string_to_versioned_number(), url_result_thread(), uses_gsm_msisdn_address(), uses_ipv4_address(), uses_ipv6_address(), wap_map_url(), wina_bearer_identifier(), and xidris_parse_reply().

{
    int c1, c2;
    long i, len;

    seems_valid(os1);
    seems_valid(os2);

    if (os1->len < os2->len)
        len = os1->len;
    else
        len = os2->len;

    if (len == 0) {
        if (os1->len == 0 && os2->len > 0)
            return -1;
        if (os1->len > 0 && os2->len == 0)
            return 1;
        return 0;
    }

    c1 = c2 = 0;
    for (i = 0; i < len; ++i) {
        c1 = toupper(os1->data[i]);
        c2 = toupper(os2->data[i]);
        if (c1 != c2)
            break;
    }

    if (i == len) {
        if (i == os1->len && i == os2->len)
            return 0;
        if (i == os1->len)
            return -1;
        return 1;
    } else {
        /*
        c1 = toupper(os1->data[i]);
        c2 = toupper(os2->data[i]);
        */
        if (c1 < c2)
            return -1;
        if (c1 == c2)
            return 0;
        return 1;
    }
}

octstr_case_nsearch()

long octstr_case_nsearch	(	const Octstr *	haystack,
		const Octstr *	needle,
		long	pos,
		long	n
	)

Definition at line 1129 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by check_control_content_type_header(), check_data_content_type_header(), check_data_x_wap_application_id_header(), drop_extension_headers(), drop_optional_header(), pass_extension_headers(), and pass_optional_header().

{
    long i, j;
    int c1, c2;

    seems_valid(haystack);
    seems_valid(needle);
    gw_assert(pos >= 0);

    /* Always "find" an empty string */
    if (needle->len == 0)
        return 0;

    for (i = pos; i <= haystack->len - needle->len && i < n; ++i) {
        for (j = 0; j < needle->len && j < n; ++j) {
            c1 = toupper(haystack->data[i + j]);
            c2 = toupper(needle->data[j]);
            if (c1 != c2)
                break;
        }
        if (j == needle->len)
            return i;
    }

    return -1;
}

octstr_case_search()

long octstr_case_search	(	const Octstr *	haystack,
		const Octstr *	needle,
		long	pos
	)

Definition at line 1102 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by check_control_content_type_header(), drop_extension_headers(), get_mime_boundary(), http_something_accepted(), parse_appid_header(), parse_url(), strip_prefix_and_suffix(), and type_is().

{
    long i, j;
    int c1, c2;

    seems_valid(haystack);
    seems_valid(needle);
    gw_assert(pos >= 0);

    /* Always "find" an empty string */
    if (needle->len == 0)
        return 0;

    for (i = pos; i <= haystack->len - needle->len; ++i) {
    for (j = 0; j < needle->len; ++j) {
        c1 = toupper(haystack->data[i + j]);
        c2 = toupper(needle->data[j]);
        if (c1 != c2)
            break;
    }
    if (j == needle->len)
        return i;
    }

    return -1;    
}

octstr_cat()

Octstr* octstr_cat	(	Octstr *	ostr1,
		Octstr *	ostr2
	)

Definition at line 383 of file octstr.c.

References Octstr::data, Octstr::len, octstr_create, seems_valid, and Octstr::size.

Referenced by msg_to_pdu().

{
    Octstr *ostr;

    seems_valid(ostr1);
    seems_valid(ostr2);

    ostr = octstr_create("");
    ostr->len = ostr1->len + ostr2->len;
    ostr->size = ostr->len + 1;
    ostr->data = gw_malloc(ostr->size);

    if (ostr1->len > 0)
        memcpy(ostr->data, ostr1->data, ostr1->len);
    if (ostr2->len > 0)
        memcpy(ostr->data + ostr1->len, ostr2->data, ostr2->len);
    ostr->data[ostr->len] = '\0';

    seems_valid(ostr);
    return ostr;
}

octstr_check_range()

int octstr_check_range	(	Octstr *	ostr,
		long	pos,
		long	len,
		octstr_func_t	filter
	)

Definition at line 814 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by convert_addr_from_pdu(), get_originator_type(), handle_dlr(), handle_pdu(), is_token(), msg_to_cgwop(), msg_to_emimsg(), msg_to_pdu(), octstr_hex_to_binary(), octstr_symbolize(), oisd_send_delivery_request(), pack_parameter(), packet_add_address_parm(), packet_check(), packet_check_header(), packet_check_parameter(), packet_encode_message(), parm_valid_address(), and run_batch().

{
    long end = pos + len;

    seems_valid(ostr);
    gw_assert(len >= 0);

    if (pos >= ostr->len)
        return 1;
    if (end > ostr->len)
        end = ostr->len;

    for ( ; pos < end; pos++) {
        if (!filter(ostr->data[pos]))
            return 0;
    }

    return 1;
}

octstr_compare()

int octstr_compare	(	const Octstr *	ostr1,
		const Octstr *	ostr2
	)

Definition at line 871 of file octstr.c.

References Octstr::data, Octstr::len, and seems_valid.

Referenced by add_connection_header(), add_content_transfer_encoding_type(), add_content_type(), add_delimiter(), add_push_application_id(), at2_read_modems(), at2_read_pending_incoming_messages(), at2_send_one_message(), authorise_username(), boxc_receiver(), brunet_receive_sms(), cgw_read_op(), cgwop_get(), charset_to_utf8(), check_comparisons(), check_do_elements(), check_login(), check_reversible(), cid_matches(), clickatell_parse_body(), client_thread(), cmp_conn_grp_checksum(), cmp_conn_grp_id(), cmp_rout_grp_checksum(), cmp_route(), content_transformable(), dlr_init(), dlr_mem_entry_match(), find_receiver_box(), generic_receive_sms(), handle_dlr(), have_cookie(), httpd_check_authorization(), init_bearerbox(), init_smsbox(), init_wapbox(), ip_allowed_by_ppg(), ip_allowed_by_user(), item_has_key(), kannel_receive_sms(), main(), meta_data_merge(), mime_something_to_entity(), msg_to_bb(), my_cmp(), my_sort_cmp(), name(), obey_request_thread(), octstr_cmp_cb(), octstr_item_match(), octstr_sort_cb(), ota_tokenize_settings(), pack_appid_list(), packet_encode_message(), pap_convert_content(), pap_request_thread(), parse2trans(), parse_address_value(), parse_attr_value(), parse_attribute(), parse_bad_message_response_value(), parse_code(), parse_document(), parse_element(), parse_pap_value(), parse_progress_note_value(), parse_push_message_value(), parse_push_response_value(), parse_quality_of_service_value(), parse_response_result_value(), parse_url(), password_matches(), proxy_used_for_host(), push_has_pi_push_id(), radius_authenticate_pdu(), remember_receiver(), return_reply(), sendsms_thread(), session_has_addr(), session_has_pi_client_address(), set_any_value(), set_attribute_value(), smsbox_req_sendota(), smsc2_add_smsc(), smsc2_find(), smsc2_restart_smsc(), smsc_at2_create(), smsc_open(), smscconn_create(), soap_get_index(), soap_server(), start_fetch(), string_table_add(), string_table_apply(), string_table_sort_list(), test_header_combine(), transfer_encode(), udp_addwdp(), udp_receiver(), udpc_find_mapping(), update_table(), update_tables(), urltrans_find_username(), user_find_by_username(), wap_event_accept_or_create(), wap_map_user(), wildcarded_ip_found(), wsp_cap_get_data(), wsp_encoding_string_to_version(), and xidris_receive_sms().

{
    int ret;
    long len;

    seems_valid(ostr1);
    seems_valid(ostr2);

    if (ostr1->len < ostr2->len)
        len = ostr1->len;
    else
        len = ostr2->len;

    if (len == 0) {
    if (ostr1->len == 0 && ostr2->len > 0)
        return -1;
    if (ostr1->len > 0 && ostr2->len == 0)
        return 1;
        return 0;
    }

    ret = memcmp(ostr1->data, ostr2->data, len);
    if (ret == 0) {
        if (ostr1->len < ostr2->len)
            ret = -1;
        else if (ostr1->len > ostr2->len)
            ret = 1;
    }
    return ret;
}

octstr_convert_from_html_entities()

void octstr_convert_from_html_entities

(

Octstr *

input

)

Definition at line 2804 of file octstr.c.

References octstr_copy, octstr_delete(), octstr_destroy(), octstr_find_entity(), octstr_insert_char(), and octstr_search_char().

{
    int startpos = 0, endpos;
    int entity;
    Octstr *match;

    while ((startpos = octstr_search_char(input, '&', startpos)) != -1) {
        endpos = octstr_search_char(input, ';', startpos + 1);
        if (endpos >= 0) {
            match = octstr_copy(input, startpos + 1, endpos - startpos - 1);
            entity = octstr_find_entity(match, 0, 0);
            if (entity >= 0) {
                octstr_delete(input, startpos, endpos - startpos + 1);
                octstr_insert_char(input, startpos, entity);
            }
            octstr_destroy(match);
        }
        startpos++;
    }
}

octstr_convert_printable()

void octstr_convert_printable

(

Octstr *

ostr

)

Definition at line 864 of file octstr.c.

References Octstr::len, make_printable(), and octstr_convert_range().

Referenced by bb_alog_sms(), and get_pattern().

{
    octstr_convert_range(ostr, 0, ostr->len, make_printable);
}

octstr_convert_range()

void octstr_convert_range	(	Octstr *	ostr,
		long	pos,
		long	len,
		octstr_func_t	map
	)

Definition at line 836 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, and seems_valid.

Referenced by check_variable_syntax(), octstr_convert_printable(), parse_charset(), and parse_constant().

{
    long end = pos + len;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    gw_assert(len >= 0);

    if (pos >= ostr->len)
        return;
    if (end > ostr->len)
        end = ostr->len;

    for ( ; pos < end; pos++) {
        ostr->data[pos] = map(ostr->data[pos]);
    }

    seems_valid(ostr);
}

octstr_convert_to_html_entities()

void octstr_convert_to_html_entities

(

Octstr *

input

)

Definition at line 2738 of file octstr.c.

References octstr_get_char(), and octstr_len().

Referenced by soap_msgdata_attribute(), soap_o2o_msgdata_attribute(), and xmlrpc_scalar_print().

{
    int i;

    for (i = 0; i < octstr_len(input); ++i) {
        switch (octstr_get_char(input, i)) {
#define ENTITY(a,b) \
    case a: \
    octstr_delete(input, i, 1); \
    octstr_insert(input, octstr_imm("&" b ";"), i); \
    i += sizeof(b); break;
#include "gwlib/html-entities.def"
#undef ENTITY
        }
    }
}

octstr_copy_real()

Octstr* octstr_copy_real	(	const Octstr *	ostr,
		long	from,
		long	len,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 351 of file octstr.c.

References Octstr::data, file, from, gw_assert(), Octstr::len, octstr_create, octstr_create_from_data_trace, and seems_valid_real().

Referenced by http_header_find_first_real().

{
    if (ostr == NULL)
        return octstr_create("");

    seems_valid_real(ostr, file, line, func);
    gw_assert(from >= 0);
    gw_assert(len >= 0);

    if (from >= ostr->len)
        return octstr_create("");

    if (len > ostr->len - from)
        len = ostr->len - from;

    return octstr_create_from_data_trace(ostr->data + from, len, file,
                                         line, func);
}

octstr_create_from_data_real()

Octstr* octstr_create_from_data_real	(	const char *	data,
		long	len,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 250 of file octstr.c.

References Octstr::data, file, gw_assert(), Octstr::immutable, Octstr::len, seems_valid, and Octstr::size.

{
    Octstr *ostr;

    gw_assert(len >= 0);
    if (data == NULL)
        gw_assert(len == 0);

    /* if gw_assert is disabled just return NULL
     * and caller will check for NULL or just crash.
     */
    if (len < 0 || (data == NULL && len != 0))
        return NULL;

    ostr = gw_malloc_trace(sizeof(*ostr), file, line, func);
    if (len == 0) {
        ostr->len = 0;
        ostr->size = 0;
        ostr->data = NULL;
    } else {
        ostr->len = len;
        ostr->size = len + 1;
        ostr->data = gw_malloc_trace(ostr->size, file, line, func);
        memcpy(ostr->data, data, len);
        ostr->data[len] = '\0';
    }
    ostr->immutable = 0;
    seems_valid(ostr);
    return ostr;
}

octstr_create_real()

Octstr* octstr_create_real	(	const char *	cstr,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 243 of file octstr.c.

References file, gw_assert(), and octstr_create_from_data_trace.

{
    gw_assert(cstr != NULL);
    return octstr_create_from_data_trace(cstr, strlen(cstr), file, line, func);
}

octstr_delete()

void octstr_delete	(	Octstr *	ostr1,
		long	pos,
		long	len
	)

Definition at line 1527 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, and seems_valid.

Referenced by at2_detect_modem_type(), at2_format_address_field(), at2_init_device(), at2_pdu_encode(), at2_scan_for_telnet_escapes(), catenate_msg(), cgw_decode_msg(), cgw_encode_msg(), charset_gsm_to_latin1(), check_data_content_type_header(), check_data_x_wap_application_id_header(), client_read_status(), compare_octstr_sequence(), concat_handling_check_and_handle(), conn_read_line(), convert_addr_from_pdu(), convert_cimd2_to_gsm(), data_sm_to_msg(), decode_binary_data(), dlr_find(), drop_character(), drop_extension_headers(), drop_header_true(), drop_separator(), eat_char(), eat_checksum(), eat_number(), eat_string_parm(), emi2_handle_smscreq(), encode_binary_data(), escape_data(), expand_file(), extract_msgdata_part(), find_translation(), fix_boundary_element(), get_originator_type(), get_start_param(), handle_operation(), handle_two_terminators(), http_header_get_content_type(), http_remove_hop_headers(), httpd_serve(), main(), meta_data_pack(), mime_something_to_entity(), msg_to_emimsg(), msg_to_pdu(), octstr_convert_from_html_entities(), octstr_delete_matching(), octstr_drop_leading_blanks(), octstr_drop_trailing_zeros(), octstr_replace(), octstr_replace_first(), octstr_shrink_blanks(), octstr_split_by_pos(), octstr_strip_blanks(), octstr_strip_char(), octstr_strip_crlfs(), octstr_strip_nonalphanums(), oisd_shrink_gsm7(), pack_7bit(), pack_cache_control(), pack_challenge(), pack_known_header(), pack_parameter(), pack_quoted_string(), packet_extract(), packet_set_checksum(), parse_address(), parse_appid_header(), parse_attr_value(), parse_attribute(), parse_body_part(), parse_data(), parse_entities(), parse_epilogue(), parse_get_rest(), parse_ppg_specifier(), parse_preamble(), parse_url_value(), parse_value(), pass_data_headers(), pass_extension_headers(), pass_optional_header(), pdu_to_msg(), radius_authenticate_pdu(), radius_pdu_pack(), read_line(), remove_crs(), remove_long(), remove_prefix(), replace_octstr_char(), response(), send_message(), set_charset(), skip_tail(), soap_parse_dlr(), soap_parse_mo(), split_headers(), string_table_apply(), strip_keyword(), strip_prefix_and_suffix(), unescape_data(), unlocked_read(), unlocked_write(), unpack_broken_parameters(), unpack_credentials(), unpack_datagram(), unpack_warning_value(), wap_map_url(), write_data(), wsp_pack_list(), wsp_strip_parameters(), wsp_unpack_well_known_field(), and wtp_unpack_wdp_datagram().

{
    seems_valid(ostr1);
    gw_assert(!ostr1->immutable);

    if (pos > ostr1->len)
        pos = ostr1->len;
    if (pos + len > ostr1->len)
        len = ostr1->len - pos;
    if (len > 0) {
        memmove(ostr1->data + pos, ostr1->data + pos + len,
                ostr1->len - pos - len);
        ostr1->len -= len;
        ostr1->data[ostr1->len] = '\0';
    }

    seems_valid(ostr1);
}

octstr_delete_matching()

void octstr_delete_matching	(	Octstr *	haystack,
		Octstr *	needle
	)

Definition at line 2702 of file octstr.c.

References gw_assert(), Octstr::immutable, octstr_delete(), octstr_len(), octstr_search(), and seems_valid.

Referenced by push_content_create().

{
    int p = 0;
    long len;

    seems_valid(haystack);
    seems_valid(needle);
    gw_assert(!haystack->immutable);
    len = octstr_len(needle);

    while ((p = octstr_search(haystack, needle, p)) != -1) {
        octstr_delete(haystack, p, len);
    }
}

octstr_destroy()

void octstr_destroy

(

Octstr *

ostr

)

Definition at line 324 of file octstr.c.

References Octstr::data, Octstr::immutable, and seems_valid.

Referenced by accept_boxc(), accept_escaped(), accept_smpp(), add_client_sdu_size(), add_crs(), add_group(), add_msg_cb(), add_msisdn(), add_push_flag(), add_via(), add_wsp_get(), add_x_wap_tod(), ap_destroy(), at2_close_device(), at2_detect_modem_type(), at2_device_thread(), at2_extract_line(), at2_flush_buffer(), at2_init_device(), at2_pdu_decode_deliver_sm(), at2_pdu_decode_report_sm(), at2_pdu_encode(), at2_pdu_extract(), at2_read_pending_incoming_messages(), at2_scan_for_telnet_escapes(), at2_send_one_message(), at2_set_message_storage(), at2_wait_line(), at2_wait_modem_command(), attribute_destroy(), bb_alog_shutdown(), bb_alog_sms(), bb_print_status(), bb_smscconn_send_failed(), bb_smscconn_sent(), bearerbox_address_destroy(), bearerbox_to_smpp(), boxc_cleanup(), boxc_destroy(), boxc_receiver(), boxc_route_msg_to_smsc(), boxc_sent_pop(), boxc_sent_push(), boxc_status(), brunet_parse_body(), brunet_receive_sms(), brunet_send_sms(), catenate_msg(), cfg_destroy(), cfg_dump(), cfg_get_bool(), cfg_get_group_checksum(), cfg_get_integer(), cfg_get_list(), cfg_read(), cfgloc_destroy(), cgw_handle_op(), cgw_listener(), cgw_read_op(), cgw_sender(), cgwop_create(), cgwop_destroy(), cgwop_send(), challenge(), charset_gsm_to_utf8(), charset_utf8_to_gsm(), check_application_headers(), check_comparisons(), check_data_content_type_header(), check_data_x_wap_application_id_header(), check_do_elements(), check_login(), check_multipart(), check_reversible(), check_variable_name(), check_variable_syntax(), check_x_wap_application_id_header(), cid_matches(), cimd2_accept_delivery_report_message(), cimd2_accept_message(), cimd2_destroy(), cimd2_request(), cimd2_submit_msg(), clickatell_parse_body(), clickatell_receive_sms(), clickatell_send_sms(), client_destroy(), client_is_persistent(), client_read_status(), client_shutdown(), client_thread(), cmp_conn_grp_checksum(), cmp_conn_grp_id(), cmp_rout_grp_checksum(), concat_handling_check_and_handle(), concat_handling_clear_old_parts(), config_reload(), conn_destroy(), conn_pool_get(), conndata_destroy(), content_transformable(), convert(), convert_content(), convert_wml_to_wmlc(), cookie_destroy(), create_dlr_from_msg(), create_onetrans(), create_oneuser(), date_parse_http(), decode_binary_data(), deconvert_content(), deduce_body_state(), delayed_http_reply(), deliver_to_bearerbox_real(), destroy_concatMsg(), destroy_group(), destroy_onetrans(), destroy_oneuser(), dispatch(), dlr_add(), dlr_find(), dlr_init(), dlr_spool_add(), dlr_spool_get(), dlr_spool_remove(), dlr_spool_shutdown(), do_queue_cleanup(), eat_int_parm(), eat_string_parm(), emi2_handle_smscreq(), emi2_listener(), emi2_receiver(), emi2_sender(), emimsg_destroy(), emimsg_send(), emimsg_tostring(), encode_binary_data(), entity_destroy(), eq_destroy_event(), expand_file(), extract_msgdata_part_by_coding(), fake_listener(), fieldmap_destroy(), fill_message(), find_charset_encoding(), find_translation(), fix_boundary_element(), flag_date_length(), for_each_file(), generic_init(), generic_parse_reply(), generic_receive_sms(), generic_send_sms(), get_and_set_debugs(), get_data(), get_msg_filename(), get_pattern(), get_x_kannel_from_headers(), get_x_kannel_from_xml(), grp_dump(), handle_connect_reply(), handle_dlr(), handle_enquire(), handle_get_reply(), handle_login(), handle_operation(), handle_pdu(), handle_push_message(), handle_split(), handle_submit(), handle_transaction(), hash_destroy(), http_accept_request(), http_add_basic_auth(), http_close_proxy(), http_destroy_cgiargs(), http_get_header_parameter(), http_header_add_element(), http_header_combine(), http_header_mark_transformation(), http_header_pack(), http_header_remove_all(), http_header_split_auth_value(), http_header_value(), http_queue_thread(), http_remove_hop_headers(), http_send_reply(), http_something_accepted(), http_thread(), http_urlparse_destroy(), httpadmin_run(), httpadmin_start(), httpadmin_stop(), httpd_emu(), httpd_serve(), httpsmsc_receiver(), httpsmsc_send_cb(), init_bearerbox(), init_reroute(), init_smppbox(), init_smsbox(), init_smsbox_routes(), init_smsc_routes(), init_sqlbox(), init_wapbox(), io_thread(), ip_allowed_by_user(), item_destroy(), kannel_parse_reply(), kannel_receive_sms(), kannel_send_sms(), kill_kannel(), main(), main_connection_loop(), make_reply_headers(), md5digest(), meta_data_destroy(), meta_data_merge(), meta_data_pack(), meta_data_set_values(), meta_data_unpack(), mime_entity_body(), mime_entity_destroy(), mime_entity_dump_real(), mime_entity_set_body(), mime_entity_to_octstr(), mime_multipart_start_elem(), mime_something_to_entity(), msg_cb(), msg_to_bb(), msg_to_cgwop(), msg_to_emimsg(), msg_to_pdu(), normalize_charset(), normalize_number(), numhash_create(), obey_request(), obey_request_thread(), octstr_append_from_hex(), octstr_convert_from_html_entities(), octstr_destroy_item(), octstr_format_append(), octstr_read_file(), octstr_read_pipe(), octstr_recode(), ois_open_receiver(), oisd_accept_delivery_report_message(), oisd_destroy(), oisd_request(), oisd_shrink_gsm7(), oisd_submit_msg(), open_send_connection(), ota_compile(), ota_pack_message(), ota_pack_push_headers(), ota_tokenize_bookmarks(), ota_tokenize_settings(), pack_7bit(), pack_accept(), pack_accept_charset(), pack_accept_language(), pack_appid_list(), pack_cache_control(), pack_challenge(), pack_content_disposition(), pack_content_range(), pack_credentials(), pack_md5(), pack_pragma(), pack_range_value(), pack_server_address(), pack_warning(), packet_add_hex_parm(), packet_add_int_parm(), packet_add_parm(), packet_check_can_receive(), packet_destroy(), packet_display_error(), packet_encode_message(), packet_get_hex_parm(), packet_get_int_parm(), pap_convert_content(), pap_get_content(), pap_request_thread(), parm_destroy(), parse_address(), parse_address_value(), parse_appid_header(), parse_array_element(), parse_attr_value(), parse_attribute(), parse_body_part(), parse_cdata(), parse_cgivars(), parse_charset(), parse_client_specifier(), parse_code(), parse_constant(), parse_data(), parse_data_element(), parse_document(), parse_element(), parse_entities(), parse_fault_element(), parse_inline_string(), parse_member_element(), parse_methodcall_element(), parse_methodresponse_element(), parse_ota_syncsettings(), parse_param_element(), parse_params_element(), parse_preamble(), parse_push_message_value(), parse_push_response_value(), parse_request_line(), parse_st_octet_string(), parse_struct_element(), parse_text(), parse_url_value(), parse_uuid(), parse_value(), parse_value_element(), parse_variable(), parse_xml_tag(), pass_extension_headers(), pass_field_name(), pass_field_value(), pass_optional_header(), pattern_list_matches_ip(), pattern_route_destroy(), port_add(), port_get_fdset(), port_get_request(), port_put_request(), port_remove(), port_set_timeout(), prepend_char(), proxy_add_authentication(), proxy_thread(), proxy_unpack_credentials(), push_content_create(), push_headers_create(), radius_acct_init(), radius_acct_shutdown(), radius_authenticate_pdu(), radius_pdu_pack(), radius_pdu_unpack(), radius_type_convert(), read_body_until_eof(), read_body_with_length(), read_chunked_body_crlf(), read_chunked_body_data(), read_chunked_body_len(), read_from_bearerbox_real(), read_from_box(), read_mime_headers(), read_msg(), read_pdu(), read_ppg_config(), read_some_headers(), receive_push_reply(), receive_reply(), receive_request(), receive_smpp_thread(), recover_absolute_uri(), report_versions(), response(), return_replies_thread(), return_reply(), route_incoming_to_boxc(), route_incoming_to_smsc(), run_batch(), run_requests(), run_smsbox(), sar_info_destroy(), sardata_destroy(), sema_encode_msg(), sema_msg_session_mt(), send_bad_message_response(), send_enquire_link(), send_file(), send_gnack(), send_invoke_connect(), send_invoke_disconnect(), send_invoke_get(), send_logoff(), send_message(), send_messages(), send_msg(), send_pdu(), send_post(), send_push_response(), send_request(), send_smpp_thread(), send_to_pi(), send_udp(), send_unbind(), sendsms_thread(), server(), server_destroy(), server_thread(), set_addr_tuple(), set_bearer_defaults(), set_charset(), set_dlr_mask(), set_group_name(), set_network_defaults(), set_referer_url(), shutdown_cb(), si_compile(), simple_binary_destroy(), sl_compile(), smasi_destroy(), smasi_pdu_pack(), smasi_pdu_unpack(), smpp_destroy(), smpp_emu(), smpp_emu_handle_pdu(), smpp_emu_reader(), smpp_emu_writer(), smpp_pdu_dump_line(), smpp_pdu_init(), smpp_pdu_pack(), smpp_pdu_read_len(), smpp_tlv_add_constant(), smpp_tlv_destroy(), smpp_tlv_get_by_tag(), sms_msgdata_len(), sms_split(), sms_to_client(), smsbox_req_handle(), smsbox_req_sendota(), smsbox_restart(), smsbox_sendota_post(), smsbox_sendsms_post(), smsbox_start(), smsbox_thread(), smsbox_xmlrpc_post(), smsboxc_run(), smsc2_add_smsc(), smsc2_cleanup(), smsc2_restart_smsc(), smsc2_start(), smsc_cgw_create(), smsc_emi2_create(), smsc_emu_submit_ack(), smsc_fake_create(), smsc_http_create(), smsc_open(), smsc_smpp_create(), smsc_soap_create(), smscconn_create(), smscconn_destroy(), smscconn_reconfig(), soap_create_map(), soap_destroy_map(), soap_fetch_xml_data(), soap_format_xml(), soap_map_xml_data(), soap_parse_dlr(), soap_parse_mo(), socket_shutdown(), split_headers(), start_fetch(), start_push(), start_request(), status_cb(), store_dumper(), store_file_load(), store_spool_save(), store_spool_shutdown(), store_to_dict(), string_table_add(), string_table_apply(), string_table_collect_strings(), string_table_destroy(), string_table_proposal_destroy(), string_table_sort_list(), tcpip_connect_nb_to_server_with_port(), tcpip_connect_to_server_with_port(), tell_fatal_error(), tokenize_date(), transform_message(), type_is(), udp_addwdp(), udp_addwdp_from_client(), udp_addwdp_from_server(), udp_die(), udp_receiver(), udp_start(), udpc_create(), udpc_destroy(), unpack_cache_directive(), unpack_challenge(), unpack_credentials(), unpack_datagram(), unpack_optional_q_value(), unpack_parameter(), unpack_range_value(), unpack_warning_value(), update_table(), update_tables(), url_pattern(), url_result_thread(), urltrans_fill_escape_codes(), wait_for_ack(), wait_for_client(), wap_addr_destroy(), wap_map_destroy(), wap_map_url(), wap_msg_recv(), wap_msg_send(), wap_push_ppg_pushuser_authenticate(), wap_push_ppg_shutdown(), wap_user_map_destroy(), wml_binary_destroy(), wrapper_sender(), write_msg(), write_to_bearerbox_real(), wsp_cap_destroy(), wsp_headers_pack(), wsp_pack_list(), wsp_pack_retry_after(), wsp_pack_separate_content_type(), wsp_unpack_app_header(), wsp_unpack_well_known_field(), wtp_tpi_destroy(), wtp_unpack_wdp_datagram(), xidris_parse_reply(), xidris_receive_sms(), xidris_send_sms(), xml_error(), xmlrpc_call_destroy(), xmlrpc_call_print(), xmlrpc_doc_destroy(), xmlrpc_doc_print(), xmlrpc_doc_send(), xmlrpc_fault_destroy(), xmlrpc_member_destroy(), xmlrpc_print_array(), xmlrpc_print_struct(), xmlrpc_response_print(), xmlrpc_scalar_destroy(), xmlrpc_scalar_print(), and xmlrpc_value_print().

{
    if (ostr != NULL) {
        seems_valid(ostr);
    if (!ostr->immutable) {
            gw_free(ostr->data);
            gw_free(ostr);
        }
    }
}

octstr_destroy_item()

void octstr_destroy_item

(

void *

os

)

Definition at line 336 of file octstr.c.

References octstr_destroy().

Referenced by add_group(), at2_detect_modem_type(), at2_device_thread(), at2_init_device(), cfg_read(), check_do_elements(), client_is_persistent(), client_thread(), concat_handling_clear_old_parts(), config_reload(), create_group(), create_onetrans(), destroy_onetrans(), do_dump(), do_queue_cleanup(), expand_file(), find_translation(), get_pattern(), handle_submit(), http_close_proxy(), http_destroy_headers(), init_bearerbox(), init_reroute(), init_smsbox(), init_smsbox_routes(), init_smsc_routes(), main(), meta_data_merge(), meta_data_pack(), meta_data_set_value(), meta_data_set_values(), meta_data_unpack(), mime_entity_destroy(), msg_to_pdu(), pack_cache_control(), pack_known_header(), parse_request_line(), pattern_list_matches_ip(), prefix_allowed(), randomize(), response(), run_smsbox(), smpp_pdu_init(), smpp_tlv_add_constant(), smsbox_req_handle(), smsc_soap_create(), smscconn_destroy(), soap_create_map(), soap_fetch_xml_data(), soap_map_xml_data(), soap_release_dependences(), store_file_for_each_message(), store_file_load(), urltrans_fill_escape_codes(), wap_appl_shutdown(), wap_push_ppg_pushuser_list_add(), wap_push_ppg_pushuser_search_ip_from_wildcarded_list(), wildcarded_ip_found(), and xmlrpc_print_struct().

{
    octstr_destroy(os);
}

octstr_dump_debug()

static void octstr_dump_debug ( const Octstr *  ostr, int  level  )

static

Definition at line 1990 of file octstr.c.

References debug(), octstr_get_char(), octstr_len(), and seems_valid.

Referenced by octstr_dump_real().

{
    unsigned char *p, *d, buf[1024], charbuf[256];
    long pos;
    const int octets_per_line = 16;
    int c, this_line_begins_at;
    
    if (ostr == NULL)
        return;

    seems_valid(ostr);

    debug("gwlib.octstr", 0, "%*sOctet string at %p:", level, "",
          (void *) ostr);
    debug("gwlib.octstr", 0, "%*s  len:  %lu", level, "",
          (unsigned long) ostr->len);
    debug("gwlib.octstr", 0, "%*s  size: %lu", level, "",
          (unsigned long) ostr->size);
    debug("gwlib.octstr", 0, "%*s  immutable: %d", level, "",
          ostr->immutable);

    buf[0] = '\0';
    p = buf;
    d = charbuf;
    this_line_begins_at = 0;
    for (pos = 0; pos < octstr_len(ostr); ) {
        c = octstr_get_char(ostr, pos);
        sprintf(p, "%02x ", c);
        p = strchr(p, '\0');
        if (isprint(c))
            *d++ = c;
        else
            *d++ = '.';
        ++pos;
        if (pos - this_line_begins_at == octets_per_line) {
            *d = '\0';
            debug("gwlib.octstr", 0, "%*s  data: %s  %s", level, "",
                  buf, charbuf);
            buf[0] = '\0';
            charbuf[0] = '\0';
            p = buf;
            d = charbuf;
            this_line_begins_at = pos;
        }
    }
    if (pos - this_line_begins_at > 0) {
        *d = '\0';
        debug("gwlib.octstr", 0, "%*s  data: %-*.*s  %s", level, "",
              octets_per_line*3,
              octets_per_line*3, buf, charbuf);
    }

    debug("gwlib.octstr", 0, "%*sOctet string dump ends.", level, "");
}

octstr_dump_real()

void octstr_dump_real	(	const Octstr *	ostr,
		int	level,
			...
	)

Definition at line 2115 of file octstr.c.

References error(), GW_DEBUG, GW_ERROR, GW_INFO, GW_WARNING, info(), octstr_dump_debug(), octstr_dump_LOGLEVEL, and warning().

{
    va_list p;
    unsigned int loglevel;
    
    va_start(p, level);
    loglevel = va_arg(p, unsigned int);
    va_end(p);
    
    switch (loglevel) {
        case GW_DEBUG:
            octstr_dump_debug(ostr, level);
            break;
        case GW_INFO:
            octstr_dump_LOGLEVEL(info, ostr, level);
            break;
        case GW_WARNING:
            octstr_dump_LOGLEVEL(warning, ostr, level);
            break;
        case GW_ERROR:
            octstr_dump_LOGLEVEL(error, ostr, level);
            break;
        default:
            octstr_dump_debug(ostr, level);
            break;
    }
}                             

octstr_dump_short()

void octstr_dump_short	(	Octstr *	ostr,
		int	level,
		const char *	name
	)

Definition at line 2144 of file octstr.c.

References Octstr::data, debug(), Octstr::len, name, octstr_dump, and seems_valid.

Referenced by main(), and radius_pdu_unpack().

{
    char buf[100];
    char *p;
    long i;
    int c;

    if (ostr == NULL) {
        debug("gwlib.octstr", 0, "%*s%s: NULL", level, "", name);
        return;
    }

    seems_valid(ostr);

    if (ostr->len < 20) {
        p = buf;
        for (i = 0; i < ostr->len; i++) {
            c = ostr->data[i];
            if (c == '\n') {
                *p++ = '\\';
                *p++ = 'n';
            } else if (!isprint(c)) {
                break;
            } else if (c == '"') {
                *p++ = '\\';
                *p++ = '"';
            } else if (c == '\\') {
                *p++ = '\\';
                *p++ = '\\';
            } else {
                *p++ = c;
            }
        }
        if (i == ostr->len) {
            *p++ = 0;
            /* We got through the loop without hitting nonprintable
             * characters. */
            debug("gwlib.octstr", 0, "%*s%s: \"%s\"", level, "", name, buf);
            return;
        }
    }

    debug("gwlib.octstr", 0, "%*s%s:", level, "", name);
    octstr_dump(ostr, level + 1);
}

octstr_duplicate_real()

Octstr* octstr_duplicate_real	(	const Octstr *	ostr,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 373 of file octstr.c.

References Octstr::data, file, Octstr::len, octstr_create_from_data_trace, and seems_valid_real().

{
    if (ostr == NULL)
        return NULL;
    seems_valid_real(ostr, file, line, func);
    return octstr_create_from_data_trace(ostr->data, ostr->len, file, line, func);
}

octstr_extract_uintvar()

long octstr_extract_uintvar	(	Octstr *	ostr,
		unsigned long *	value,
		long	pos
	)

Definition at line 1954 of file octstr.c.

References octstr_get_char().

Referenced by is_default_cap(), parse_get_uintvar(), sanitize_capabilities(), wsp_cap_get_client_sdu(), wsp_cap_get_server_sdu(), and wsp_cap_unpack_list().

{
    int c;
    int count;
    unsigned long ui;

    ui = 0;
    for (count = 0; count < 5; count++) {
        c = octstr_get_char(ostr, pos + count);
        if (c < 0)
            return -1;
        ui = (ui << 7) | (c & 0x7f);
        if (!(c & 0x80)) {
            *value = ui;
            return pos + count + 1;
        }
    }

    return -1;
}

octstr_find_entity()

static int octstr_find_entity ( Octstr *  input, int  startfind, int  endfind  )

static

Definition at line 2760 of file octstr.c.

References octstr_str_compare().

Referenced by octstr_convert_from_html_entities().

{
#define ENTITY(a,b) { a, b },
    struct entity_struct {
        int entity;
        char *entity_str;
    };
    const struct entity_struct entities[] = {
#include "html-entities.def"
        { -1, "" } /* pivot */
    };
#undef ENTITY
    int center;         /* position in table that we are about to compare */
    int matchresult;    /* result of match agains found entity name. indicates less, equal or greater */

    if (endfind == 0) {
        /* when calling this function we do not (nor even want to) know the
         * sizeof(entities). Hence this check. */
        endfind = (sizeof(entities) / sizeof(struct entity_struct)) - 1;
    }
    center = startfind + ((endfind - startfind) / 2);
    matchresult = octstr_str_compare(input, entities[center].entity_str);
    if (matchresult == 0) {
        return entities[center].entity;
    }
    if (endfind - startfind <= 1) {
        /* we are at the end of our results */
        return -1;
    }
    if  (matchresult < 0) {
        /* keep searching in first part of the table */
        return octstr_find_entity(input, startfind, center);
    } else {
        /* keep searching in last part of the table */
        return octstr_find_entity(input, center, endfind);
    }
}

octstr_format()

Octstr* octstr_format	(	const char *	fmt,
			...
	)

Definition at line 2464 of file octstr.c.

References octstr_format_valist.

Referenced by add_client_sdu_size(), add_crs(), add_msg_cb(), add_push_application_id(), add_push_flag(), add_via(), add_wsp_get(), at2_init_device(), at2_pdu_decode_report_sm(), at2_send_one_message(), at2_set_message_storage(), at2_write_line(), bb_print_status(), bearerbox_to_smpp(), boxc_route_msg_to_smsc(), boxc_status(), brunet_send_sms(), build_request(), challenge(), check_multipart(), check_x_wap_application_id_header(), clickatell_send_sms(), client_thread(), concat_handling_check_and_handle(), config_reload(), conn_pool_key(), convert_charset(), create_dlr_from_msg(), create_onetrans(), date_create_iso(), dlr_find(), dlr_spool_add(), dlr_spool_get(), dlr_spool_remove(), eat_string_parm(), emimsg_tostring(), error_converting(), error_requesting(), error_requesting_back(), fix_boundary_element(), flag_date_length(), for_each_file(), generic_send_sms(), get_msg_filename(), get_originator_type(), get_ton_npi_value(), handle_dlr(), handle_pdu(), handle_submit_sm(), headers_acceptable(), http_add_basic_auth(), http_header_add(), http_header_mark_transformation(), http_send_reply(), httpd_add_smsc(), httpd_loglevel(), httpd_remove_message(), httpd_remove_smsc(), httpd_restart_smsc(), httpd_serve(), httpd_stop_smsc(), init_configuration(), kannel_send_sms(), kill_kannel(), main(), make_multipart_value(), msg_to_emimsg(), msg_to_pdu(), obey_request(), open_send_connection(), pap_request_thread(), parse_appid_header(), parse_array(), parse_array_element(), parse_code(), parse_constant(), parse_data(), parse_data_element(), parse_document(), parse_fault(), parse_fault_element(), parse_inline_string(), parse_member(), parse_member_element(), parse_methodcall(), parse_methodcall_element(), parse_methodresponse(), parse_methodresponse_element(), parse_param(), parse_param_element(), parse_params(), parse_params_element(), parse_struct(), parse_struct_element(), parse_value(), parse_value_element(), parse_xml_tag(), port_key(), prepend_char(), proxy_add_authentication(), push_content_create(), radius_type_convert(), read_ppg_config(), route_incoming_to_boxc(), send_bad_message_response(), send_messages(), send_push_response(), send_smpp_thread(), set_bearer_defaults(), set_network_defaults(), set_time(), smpp_emu_writer(), smpp_pdu_init(), smpp_tlv_get_by_tag(), smsbox_req_sendota(), smsbox_sendota_post(), smsbox_xmlrpc_post(), smsc2_status(), smsc_at2_create(), smsc_cgw_create(), smsc_cimd2_create(), smsc_emi2_create(), smsc_fake_create(), smsc_http_create(), smsc_loopback_create(), smsc_oisd_create(), smsc_smpp_create(), smsc_soap_create(), soap_bouyg_validity_attribute(), soap_o2o_msgdata_attribute(), soap_o2o_validity30_attribute(), soap_rand_attribute(), soap_send(), soap_write_date(), store_file_init(), store_spool_save(), tell_fatal_error(), tell_ppg_name(), type_is(), unpack_datagram(), version_report_string(), wap_event_accept_or_create(), wap_push_ppg_pushuser_authenticate(), xidris_send_sms(), xml_error(), xmlrpc_call_print(), xmlrpc_doc_print(), xmlrpc_fault_print(), xmlrpc_print_array(), xmlrpc_print_struct(), xmlrpc_response_print(), xmlrpc_scalar_print(), and xmlrpc_value_print().

{
    Octstr *os;
    va_list args;

    va_start(args, fmt);
    os = octstr_format_valist(fmt, args);
    va_end(args);
    return os;
}

octstr_format_append()

void octstr_format_append	(	Octstr *	os,
		const char *	fmt,
			...
	)

Definition at line 2507 of file octstr.c.

References octstr_append(), octstr_destroy(), and octstr_format_valist.

Referenced by add_delimiter(), boxc_status(), brunet_send_sms(), build_request(), challenge(), clickatell_send_sms(), concat_handling_clear_old_parts(), create_onetrans(), fix_boundary_element(), get_pattern(), http_cgivar_dump_into(), http_send_reply(), httpd_serve(), kannel_send_sms(), main(), make_close_delimiter(), make_part_delimiter(), meta_data_pack(), ota_pack_message(), ota_pack_push_headers(), ota_tokenize_bookmarks(), ota_tokenize_settings(), pack_appid_list(), pack_udhdata(), parse_inline_string(), prepend_catenation_udh(), randomize(), recover_absolute_uri(), send_bad_message_response(), send_packet(), send_push_response(), simple_binary_output(), smpp_pdu_dump_line(), smsbox_req_handle(), smsc2_status(), status_cb(), tell_fatal_error(), url_pattern(), urltrans_fill_escape_codes(), xidris_send_sms(), xmlrpc_call_print(), xmlrpc_print_array(), and xmlrpc_print_struct().

{
    Octstr *temp;
    va_list args;

    va_start(args, fmt);
    temp = octstr_format_valist(fmt, args);
    va_end(args);
    octstr_append(os, temp);
    octstr_destroy(temp);
}

octstr_format_valist_real()

Octstr* octstr_format_valist_real	(	const char *	fmt,
		va_list	args
	)

Definition at line 2476 of file octstr.c.

References convert(), format_flags(), format_prec(), format_type(), format_width(), gw_assert(), octstr_append_data(), octstr_create, seems_valid, and VARGS.

{
    Octstr *os;
    size_t n;

    os = octstr_create("");

    while (*fmt != '\0') {
        struct format format = { 0, };

        n = strcspn(fmt, "%");
        octstr_append_data(os, fmt, n);
        fmt += n;

        gw_assert(*fmt == '%' || *fmt == '\0');
        if (*fmt == '\0')
            continue;

        ++fmt;
        format_flags(&format, &fmt);
        format_width(&format, &fmt, VARGS(args));
        format_prec(&format, &fmt, VARGS(args));
        format_type(&format, &fmt);
        convert(os, &format, &fmt, VARGS(args));
    }

    seems_valid(os);
    return os;
}

octstr_get_bits()

long octstr_get_bits	(	Octstr *	ostr,
		long	bitpos,
		int	numbits
	)

Definition at line 1803 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by deduce_tid(), get_tid(), unpack_ack(), unpack_tpis(), wtp_type(), and wtp_unpack_wdp_datagram().

{
    long pos;
    long result;
    int mask;
    int shiftwidth;

    seems_valid(ostr);
    gw_assert(bitpos >= 0);
    gw_assert(numbits <= 32);
    gw_assert(numbits >= 0);

    pos = bitpos / 8;
    bitpos = bitpos % 8;

    /* This also takes care of the len == 0 case */
    if (pos >= ostr->len)
        return 0;

    mask = (1 << numbits) - 1;

    /* It's easy if the range fits in one octet */
    if (bitpos + numbits <= 8) {
        /* shiftwidth is the number of bits to ignore on the right.
         * bitpos 0 is the leftmost bit. */
        shiftwidth = 8 - (bitpos + numbits);
        return (ostr->data[pos] >> shiftwidth) & mask;
    }

    /* Otherwise... */
    result = 0;
    while (bitpos + numbits > 8) {
        result = (result << 8) | ostr->data[pos];
        numbits -= (8 - bitpos);
        bitpos = 0;
        pos++;
        if (pos >= ostr->len)
            return (result << numbits) & mask;
    }

    gw_assert(bitpos == 0);
    result <<= numbits;
    result |= ostr->data[pos] >> (8 - numbits);
    return result & mask;
}

octstr_get_char()

int octstr_get_char	(	const Octstr *	ostr,
		long	pos
	)

Definition at line 406 of file octstr.c.

References Octstr::data, Octstr::len, and seems_valid.

Referenced by accept_escaped(), accept_safe(), add_crs(), at2_convertpdu(), at2_decode7bituncompressed(), at2_encode7bituncompressed(), at2_encode8bituncompressed(), at2_extract_line(), at2_format_address_field(), at2_pdu_decode(), at2_pdu_decode_deliver_sm(), at2_pdu_decode_report_sm(), at2_pdu_extract(), at2_scan_for_telnet_escapes(), calculate_checksum(), catenate_msg(), cfg_read(), charset_gsm_to_latin1(), charset_gsm_to_nrc_iso_21_german(), charset_gsm_to_utf8(), charset_gsm_truncate(), charset_latin1_to_gsm(), charset_nrc_iso_21_german_to_gsm(), charset_utf8_to_gsm(), check_multipart(), check_variable_syntax(), client_session(), concat_handling_check_and_handle(), concatenated_message(), conn_read_line(), convert_addr_from_pdu(), convert_cimd2_to_gsm(), convert_gsm_to_cimd2(), convert_html_entity(), create_peek_window(), data_sm_to_msg(), date_parse_http(), decode_bearer_indication(), decode_binary_data(), decode_integer(), drop_extension_headers(), eat_char(), eat_checksum(), emi2_handle_smscreq(), encode_binary_data(), escape_data(), escape_fragment(), expand_file(), extract_msgdata_part(), fix_boundary_element(), generic_receive_sms(), get_fields(), get_mime_boundary(), get_originator_type(), get_pattern(), get_start_param(), get_variable(), get_varint(), get_wtp_pdu_type(), gsm2number(), handle_connect_reply(), handle_get_reply(), handle_operation(), html_to_sms(), http_get_header_parameter(), http_header_get_content_type(), http_header_quoted_string_len(), http_header_split_auth_value(), http_header_split_value(), httpd_serve(), is_default_cap(), issafe(), kannel_receive_sms(), main(), mime_something_to_entity(), msg_to_emimsg(), msg_to_pdu(), octstr_convert_to_html_entities(), octstr_drop_leading_blanks(), octstr_drop_trailing_zeros(), octstr_dump_debug(), octstr_extract_uintvar(), octstr_is_all_hex(), octstr_isnum(), octstr_search_chars(), octstr_shrink_blanks(), octstr_strip_blanks(), octstr_strip_char(), octstr_strip_crlfs(), octstr_strip_nonalphanums(), oisd_accept_delivery_report_message(), oisd_accept_message(), oisd_expand_gsm7_to_bits(), oisd_request(), oisd_shrink_gsm7(), pack_7bit(), pack_cache_control(), pack_challenge(), pack_content_range(), pack_credentials(), pack_if_range(), pack_quoted_string(), pack_range(), pack_range_value(), pack_warning(), packet_check_header(), packet_check_parameter(), packet_extract(), packet_parse_header(), packet_set_checksum(), parse_address(), parse_constant(), parse_date(), parse_dom_fragment(), parse_escaped_value(), parse_field_name(), parse_field_value(), parse_get_char(), parse_global_phone_number(), parse_http_version(), parse_ipv4(), parse_ipv4_fragment(), parse_ipv6(), parse_ipv6_fragment(), parse_msg_to_rawmessage(), parse_peek_char(), parse_ppg_specifier(), parse_qualifier_keyword(), parse_qualifier_value(), parse_qvalue(), parse_st_octet_string(), parse_terminator(), parse_transport_padding(), parse_type(), parse_value(), parse_variable(), pass_extension_headers(), pass_field_name(), pass_field_value(), pattern_matches_ip(), pdu_to_msg(), qualifiers(), radius_type_convert(), read_mime_headers(), read_some_headers(), recover_absolute_uri(), remove_crs(), resend_sar_result(), sanitize_capabilities(), send_packet(), set_tid(), set_tid_new(), skip_html_tag(), smsbox_req_handle(), soap_fetch_xml_data(), soap_format_xml(), split_headers(), string_table_apply(), strip_keyword(), tokenize_date(), unescape_data(), unpack_datagram(), unpack_parameter(), unpack_warning_value(), urltrans_fill_escape_codes(), wait_for_ack(), wap_map_url(), wap_msg_send(), wsp_cap_get_method_mor(), wsp_cap_get_push_mor(), wsp_cap_pack_list(), wsp_cap_unpack_list(), wsp_pack_integer_string(), wsp_pack_retry_after(), wsp_pack_text(), wsp_pack_version_value(), wsp_strip_parameters(), and wtp_unpack_wdp_datagram().

{
    seems_valid(ostr);
    if (pos >= ostr->len || pos < 0)
        return -1;
    return ostr->data[pos];
}

octstr_get_cstr_real()

char* octstr_get_cstr_real	(	const Octstr *	ostr,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 439 of file octstr.c.

References Octstr::data, file, Octstr::len, and seems_valid_real().

{
    if (!ostr)
        return "(null)";
    seems_valid_real(ostr, file, line, func);
    if (ostr->len == 0)
        return "";
    return ostr->data;
}

octstr_get_many_chars()

void octstr_get_many_chars	(	char *	buf,
		Octstr *	ostr,
		long	pos,
		long	len
	)

Definition at line 425 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by cimd_submit_msg(), compare_octstr_sequence(), conn_read_withlen(), convert_html_entity(), html_comment_begins(), packet_extract(), parse_integer(), parse_msg_to_rawmessage(), read_msg(), smpp_pdu_read_len(), wap_msg_recv(), and write_data().

{
    gw_assert(buf != NULL);
    seems_valid(ostr);

    if (pos >= ostr->len)
        return;
    if (pos + len > ostr->len)
        len = ostr->len - pos;
    if (len > 0)
        memcpy(buf, ostr->data + pos, len);
}

octstr_grow()

static void octstr_grow ( Octstr *  ostr, long  size  )

static

Definition at line 181 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, seems_valid, size, and Octstr::size.

Referenced by octstr_binary_to_base64(), octstr_binary_to_hex(), octstr_insert(), octstr_insert_char(), octstr_insert_data(), octstr_set_bits(), and octstr_symbolize().

{
    gw_assert(!ostr->immutable);
    seems_valid(ostr);
    gw_assert(size >= 0);

    size++;   /* make room for the invisible terminating NUL */

    if (size > ostr->size) {
        /* always reallocate in 1kB chunks */
        size += 1024 - (size % 1024);
        ostr->data = gw_realloc(ostr->data, size);
        ostr->size = size;
    }
}

octstr_hash_key()

unsigned long octstr_hash_key

(

Octstr *

ostr

)

Definition at line 2523 of file octstr.c.

References octstr_get_cstr, and octstr_len().

Referenced by dlr_spool_add(), dlr_spool_get(), dlr_spool_remove(), key_to_index(), and store_spool_save().

{
    unsigned long b    = 378551;
    unsigned long a    = 63689;
    unsigned long hash = 0;
    unsigned long i    = 0;
    unsigned long len = octstr_len(ostr);
    const char *str = octstr_get_cstr(ostr);

    for(i = 0; i < len; str++, i++) {
        hash = hash*a+(*str);
        a = a*b;
    }

    return (hash & 0x7FFFFFFF);
}

octstr_hex_to_binary()

int octstr_hex_to_binary

(

Octstr *

ostr

)

Definition at line 494 of file octstr.c.

References Octstr::data, gw_assert(), gw_isxdigit(), Octstr::immutable, Octstr::len, octstr_check_range(), and seems_valid.

Referenced by accept_escaped(), at2_pdu_extract(), decode_binary_data(), get_x_kannel_from_headers(), get_x_kannel_from_xml(), handle_operation(), main(), octstr_append_from_hex(), packet_get_hex_parm(), push_content_create(), and soap_msgdata_deps().

{
    long len, i;
    unsigned char *p;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

    if (ostr->len == 0)
        return 0;

    /* Check if it's in the right format */
    if (!octstr_check_range(ostr, 0, ostr->len, gw_isxdigit))
        return -1;

    len = ostr->len;

    /* Convert ascii data to binary values */
    for (i = 0, p = ostr->data; i < len; i++, p++) {
        if (*p >= '0' && *p <= '9')
            *p -= '0';
        else if (*p >= 'a' && *p <= 'f')
            *p = *p - 'a' + 10;
        else if (*p >= 'A' && *p <= 'F')
            *p = *p - 'A' + 10;
        else {
            /* isxdigit checked the whole string, so we should
             * not be able to get here. */
            gw_assert(0);
            *p = 0;
        }
    }

    /* De-hexing will compress data by factor of 2 */
    len = ostr->len / 2;

    for (i = 0; i < len; i++) {
        ostr->data[i] = ostr->data[i * 2] * 16 | ostr->data[i * 2 + 1];
    }

    ostr->len = len;
    ostr->data[len] = '\0';

    seems_valid(ostr);
    return 0;
}

octstr_imm()

Octstr* octstr_imm

(

const char *

cstr

)

Definition at line 283 of file octstr.c.

References CSTR_TO_LONG, Octstr::data, gw_assert(), Octstr::immutable, immutables, immutables_init, immutables_mutex, Octstr::len, MAX_IMMUTABLES, mutex_lock, mutex_unlock, panic, seems_valid, and Octstr::size.

Referenced by add_connection_header(), add_content_transfer_encoding_type(), add_content_type(), add_delimiter(), add_group(), add_push_application_id(), add_via(), append_crlf(), at2_check_sms_memory(), at2_detect_modem_type(), at2_extract_line(), at2_init_device(), at2_pdu_extract(), at2_read_modems(), at2_send_one_message(), at2_wait_modem_command(), authorise_user(), bb_alog_sms(), bb_reload_smsc_groups(), bearerbox_to_smpp(), bearerbox_to_smsbox(), bearerbox_to_sql(), brunet_parse_body(), brunet_parse_reply(), brunet_send_sms(), build_request(), build_response(), cfg_get_bool(), cfg_read(), cgw_decode_msg(), cgw_encode_msg(), cgw_handle_op(), cgw_read_op(), cgwop_create(), cgwop_tostr(), challenge(), charset_to_utf8(), check_config(), check_control_content_type_header(), check_control_headers(), check_login(), cid_matches(), clickatell_parse_body(), clickatell_parse_reply(), clickatell_send_sms(), client_is_persistent(), client_thread(), cmp_conn_grp_id(), concat_msgids(), config_reload(), conn_pool_key(), connect_denied(), construct_linear_table(), construct_numbered_table(), content_transformable(), convert_addr_from_pdu(), core_is_allowed_in_group(), create_dlr_from_msg(), create_onetrans(), create_oneuser(), describe_code(), dlr_db_fields_create(), dlr_find(), dlr_init(), dlr_init_spool(), drop_extension_headers(), drop_optional_header(), escape_fragment(), expand_file(), find_charset_encoding(), fix_boundary_element(), generic_get_field_map(), generic_init(), generic_receive_sms(), get_data(), get_mime_boundary(), get_start_param(), get_x_kannel_from_headers(), handle_dlr(), handle_pdu(), handle_transaction(), http_add_basic_auth(), http_header_get_content_type(), http_header_pack(), httpadmin_start(), httpd_serve(), init_batch(), init_bearerbox(), init_configuration(), init_reroute(), init_smppbox(), init_smsbox(), init_smsbox_routes(), init_smsc_routes(), init_sqlbox(), init_wapbox(), ip_allowed_by_ppg(), ip_allowed_by_user(), kannel_parse_reply(), kannel_receive_sms(), kannel_send_sms(), main(), make_multipart_value(), make_url(), mime_decompile(), mime_entity_dump_real(), mime_entity_to_octstr(), mime_multipart_start_elem(), mime_something_to_entity(), msg_to_bb(), msg_to_cgwop(), msg_to_pdu(), name(), normalize_charset(), obey_request(), obey_request_thread(), octstr_binary_to_base64(), octstr_recode(), open_send_connection(), ota_pack_message(), ota_pack_push_headers(), ota_pack_udh(), ota_tokenize_bookmarks(), ota_tokenize_settings(), pack_appid_list(), pack_cache_control(), pack_challenge(), pack_content_range(), pack_credentials(), pack_pragma(), pack_range(), packet_encode_message(), pap_convert_content(), pap_get_content(), pap_request_thread(), parse2trans(), parse_address_value(), parse_appid_header(), parse_array_element(), parse_attr_value(), parse_attribute(), parse_bad_message_response_value(), parse_bearer(), parse_client_specifier(), parse_data_element(), parse_date(), parse_delivery_method(), parse_document(), parse_element(), parse_entities(), parse_fault_element(), parse_http_version(), parse_member_element(), parse_methodcall_element(), parse_methodresponse_element(), parse_network(), parse_ota_syncsettings(), parse_pap_value(), parse_param_element(), parse_params_element(), parse_priority(), parse_progress_note_value(), parse_push_message_value(), parse_push_response_value(), parse_quality_of_service_value(), parse_requirement(), parse_response_result_value(), parse_state(), parse_struct_element(), parse_url(), parse_url_value(), parse_value_element(), pass_data_headers(), pass_extension_headers(), pattern_list_matches_ip(), prefix_allowed(), prepend_crlf(), proxy_add_authentication(), push_content_create(), qualifiers(), radius_acct_init(), read_ppg_config(), read_test_ppg_config(), reply(), response(), return_reply(), select_bearer_network(), server(), set_addr_tuple(), set_any_value(), set_attribute_value(), set_dlr_mask(), set_dlr_url(), set_smsbox_id(), set_smsc_id(), skip_html_comment(), smpp_pdu_init(), smpp_tlv_get_by_name(), smpp_tlv_get_by_tag(), smppbox_is_allowed_in_group(), sms_to_client(), smsbox_req_handle(), smsbox_req_sendota(), smsbox_sendota_post(), smsbox_sendsms_post(), smsbox_start(), smsbox_to_bearerbox(), smsbox_xmlrpc_post(), smsc2_add_smsc(), smsc2_graceful_restart(), smsc2_restart_smsc(), smsc2_start(), smsc2_status(), smsc_at2_create(), smsc_cgw_create(), smsc_cimd2_create(), smsc_emi2_create(), smsc_fake_create(), smsc_http_create(), smsc_oisd_create(), smsc_open(), smsc_smpp_create(), smsc_soap_create(), smscconn_create(), smscconn_instances(), soap_create_map(), soap_fetch_xml_data(), soap_map_xml_data(), soap_msgdata_deps(), soap_parse_dlr(), soap_read_response(), soap_release_dependences(), soap_server(), sql_list(), sql_single(), sqlbox_is_allowed_in_group(), start_fetch(), start_request(), status_cb(), test_header_combine(), transfer_encode(), type_is(), udp_start(), unpack_challenge(), unpack_optional_q_value(), unpack_parameter(), update_table(), update_tables(), url_result_thread(), urltrans_add_cfg(), urltrans_fill_escape_codes(), uses_gsm_msisdn_address(), uses_ipv4_address(), uses_ipv6_address(), wap_event_accept_or_create(), wap_map_url_config(), wap_map_url_config_device_home(), wapbox_start(), wildcarded_ip_found(), wina_bearer_identifier(), wml_charsets(), wsp_encoding_string_to_version(), xidris_parse_reply(), xidris_receive_sms(), xidris_send_sms(), xml_error(), and xmlrpc_fault_print().

{
    Octstr *os;
    long i, index;
    unsigned char *data;

    gw_assert(immutables_init);
    gw_assert(cstr != NULL);

    index = CSTR_TO_LONG(cstr) % MAX_IMMUTABLES;
    data = (unsigned char *) cstr;

    mutex_lock(&immutables_mutex);
    i = index;
    for (; ; ) {
    if (immutables[i] == NULL || immutables[i]->data == data)
            break;
        i = (i + 1) % MAX_IMMUTABLES;
        if (i == index)
            panic(0, "Too many immutable strings.");
    }
    os = immutables[i];
    if (os == NULL) {
    /*
     * Can't use octstr_create() because it copies the string,
     * which would break our hashing.
     */
    os = gw_malloc(sizeof(*os));
        os->data = data;
        os->len = strlen(data);
        os->size = os->len + 1;
        os->immutable = 1;
    immutables[i] = os;
    seems_valid(os);
    }
    mutex_unlock(&immutables_mutex);

    return os;
}

octstr_init()

void octstr_init

(

void

)

Definition at line 218 of file octstr.c.

References immutables_init, immutables_mutex, mutex_init_static, and urlcode_init().

Referenced by gwlib_init().

{
    urlcode_init();
    mutex_init_static(&immutables_mutex);
    immutables_init = 1;
}

octstr_insert()

void octstr_insert	(	Octstr *	ostr1,
		const Octstr *	ostr2,
		long	pos
	)

Definition at line 1303 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, octstr_grow(), and seems_valid.

Referenced by accept_escaped(), add_crs(), append_string(), cgw_decode_msg(), cgw_encode_msg(), decode_binary_data(), escape_data(), flag_date_length(), http_add_basic_auth(), init_smsbox_routes(), init_smsc_routes(), main(), msg_to_pdu(), octstr_append(), octstr_binary_to_base64(), octstr_replace(), octstr_replace_first(), output_octet_string(), output_st_octet_string(), pack_challenge(), packet_add_parm(), parse_entities(), parse_inline_string(), parse_st_octet_string(), prefix_allowed(), prepend_char(), prepend_crlf(), proxy_add_authentication(), radius_authenticate_pdu(), radius_pdu_pack(), recover_absolute_uri(), replace_octstr_char(), smasi_pdu_pack(), smpp_pdu_pack(), sms_split(), string_table_apply(), string_table_output(), unpack_parameter(), wml_binary_output(), and xmlrpc_doc_print().

{
    if (ostr2 == NULL)
        return;

    seems_valid(ostr1);
    seems_valid(ostr2);
    gw_assert(pos <= ostr1->len);
    gw_assert(!ostr1->immutable);

    if (ostr2->len == 0)
        return;

    octstr_grow(ostr1, ostr1->len + ostr2->len);
    memmove(ostr1->data + pos + ostr2->len, ostr1->data + pos,
            ostr1->len - pos);
    memcpy(ostr1->data + pos, ostr2->data, ostr2->len);
    ostr1->len += ostr2->len;
    ostr1->data[ostr1->len] = '\0';

    seems_valid(ostr1);
}

octstr_insert_char()

void octstr_insert_char	(	Octstr *	ostr,
		long	pos,
		const char	c
	)

Definition at line 1481 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, octstr_grow(), and seems_valid.

Referenced by convert_addr_from_pdu(), init_smsbox_routes(), init_smsc_routes(), and octstr_convert_from_html_entities().

{
    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    gw_assert(pos <= ostr->len);
    
    octstr_grow(ostr, ostr->len + 1);
    if (ostr->len > pos)
        memmove(ostr->data + pos + 1, ostr->data + pos, ostr->len - pos);
    memcpy(ostr->data + pos, &c, 1);
    ostr->len += 1;
    ostr->data[ostr->len] = '\0';
    
    seems_valid(ostr);
}

octstr_insert_data()

void octstr_insert_data	(	Octstr *	ostr,
		long	pos,
		const char *	data,
		long	len
	)

Definition at line 1461 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, octstr_grow(), and seems_valid.

Referenced by bb_smscconn_send_failed(), bb_smscconn_sent(), cgw_encode_msg(), charset_latin1_to_gsm(), compare_octstr_sequence(), convert(), convert_gsm_to_cimd2(), http_header_split_auth_value(), line_append_hex_IA5(), msg_to_emimsg(), normalize_number(), octstr_append_char(), octstr_append_cstr(), octstr_append_data(), octstr_read_file(), octstr_symbolize(), pack_into_push_datagram(), pack_into_result_datagram(), packet_add_parm(), packet_set_checksum(), sema_encode_msg(), sema_msg_session_mt(), unescape_data(), unpack_credentials(), unpack_warning_value(), write_msg(), and wsp_pack_long_integer().

{
    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    gw_assert(pos <= ostr->len);

    if (len == 0)
        return;

    octstr_grow(ostr, ostr->len + len);
    if (ostr->len > pos) {  /* only if neccessary*/
        memmove(ostr->data + pos + len, ostr->data + pos, ostr->len - pos);
    }
    memcpy(ostr->data + pos, data, len);
    ostr->len += len;
    ostr->data[ostr->len] = '\0';

    seems_valid(ostr);
}

octstr_is_all_hex()

int octstr_is_all_hex

(

Octstr *

os

)

Definition at line 2717 of file octstr.c.

References gw_isxdigit(), octstr_get_char(), octstr_len(), and seems_valid.

Referenced by main(), and push_content_create().

{
    long len, i;
    int ch;

    seems_valid(os);
    len = octstr_len(os);
    for (i = 0; i < len; ++i) {
        ch = octstr_get_char(os, i);
        if (!gw_isxdigit(ch))
            return 0;
    }

    return 1;
}

octstr_isnum()

int octstr_isnum

(

Octstr *

ostr1

)

Definition at line 2634 of file octstr.c.

References octstr_get_char(), octstr_len(), seems_valid, and start.

{
    int start = 0;
    char c;

    seems_valid(ostr1);
    while (start < octstr_len(ostr1)) {
        c = octstr_get_char(ostr1, start);
        if (!isdigit(c) && (c!='+'))
            return 0;
        start++;
    }
    return 1;
}

octstr_item_case_match()

int octstr_item_case_match	(	void *	item,
		void *	pattern
	)

Definition at line 1667 of file octstr.c.

References octstr_case_compare().

Referenced by client_is_persistent().

{
    return octstr_case_compare(item, pattern) == 0;
}

octstr_item_match()

int octstr_item_match	(	void *	item,
		void *	pattern
	)

Definition at line 1661 of file octstr.c.

References octstr_compare().

Referenced by at2_detect_modem_type(), at2_init_device(), cfg_read(), check_allowed_translation(), smsbox_req_handle(), and smscconn_usable().

{
    return octstr_compare(item, pattern) == 0;
}

octstr_len()

long octstr_len

(

const Octstr *

ostr

)

Definition at line 342 of file octstr.c.

References Octstr::len, and seems_valid.

Referenced by add_crs(), add_msisdn(), add_network_info(), add_wsp_get(), append_string(), at2_check_sms_memory(), at2_convertpdu(), at2_decode7bituncompressed(), at2_detect_modem_type(), at2_encode7bituncompressed(), at2_encode8bituncompressed(), at2_extract_line(), at2_format_address_field(), at2_init_device(), at2_login_device(), at2_pdu_decode_deliver_sm(), at2_pdu_encode(), at2_pdu_extract(), at2_read_modems(), at2_scan_for_telnet_escapes(), at2_send_one_message(), at2_write_line(), bb_alog_sms(), bearerbox_to_smpp(), begin_sar_result(), brunet_parse_body(), brunet_send_sms(), calculate_checksum(), catenate_msg(), cfg_read(), cgw_encode_msg(), cgw_read_op(), charset_convert(), charset_from_utf8(), charset_gsm_to_latin1(), charset_gsm_to_nrc_iso_21_german(), charset_gsm_to_utf8(), charset_gsm_truncate(), charset_latin1_to_gsm(), charset_nrc_iso_21_german_to_gsm(), charset_processing(), charset_to_utf8(), charset_utf8_to_gsm(), check_data_content_type_header(), check_data_x_wap_application_id_header(), check_multipart(), check_variable_syntax(), cid_matches(), cimd2_accept_message(), cimd_submit_msg(), clickatell_receive_sms(), clickatell_send_sms(), client_session(), compare_octstr_sequence(), concat_handling_check_and_handle(), conn_read_line(), conn_read_packet(), conn_write_withlen(), convert(), convert_addr_from_pdu(), convert_cimd2_to_gsm(), convert_content(), convert_gsm_to_cimd2(), convert_wmlscript_to_wmlscriptc(), copy_until_assign(), count_occurences(), data_sm_to_msg(), date_parse_http(), date_parse_iso(), decode_binary_data(), decode_integer(), deconvert_content(), deliver_after_test_cleared(), deliver_before_test_cleared(), dlr_add(), dlr_find(), dlr_mem_entry_match(), dlr_spool_add(), eat_checksum(), eat_int_parm(), eat_string_parm(), emi2_handle_smscreq(), emimsg_tostring(), encode_binary_data(), error_from_network_error_code(), escape_data(), escape_fragment(), expand_file(), extract_msgdata_part(), extract_msgdata_part_by_coding(), fields_to_dcs(), fill_message(), find_charset_encoding(), find_translation(), fix_boundary_element(), flag_date_length(), generic_receive_sms(), get_fields(), get_header_value(), get_mime_boundary(), get_msg_filename(), get_pattern(), get_start_param(), get_variable(), get_x_kannel_from_xml(), gsm2number(), handle_dlr(), handle_operation(), handle_pdu(), html_to_sms(), http_accept_request(), http_get_header_parameter(), http_header_add_element(), http_header_find_first_real(), http_header_get(), http_header_get_content_type(), http_header_mark_transformation(), http_header_pack(), http_header_quoted_string_len(), http_header_split_auth_value(), http_header_split_value(), http_header_value(), http_send_reply(), http_use_proxy(), httpd_remove_message(), httpd_serve(), init_bearerbox(), init_smsbox_routes(), init_smsc_routes(), is_allowed_ip(), is_default_cap(), is_token(), kannel_receive_sms(), kannel_send_sms(), line_append_hex_IA5(), main(), main_loop(), make_emi31(), md5(), meta_data_merge(), meta_data_pack(), meta_data_unpack(), mime_decompile(), mime_entity_dump_real(), mime_parse(), mime_something_to_entity(), msg_to_cgwop(), msg_to_emimsg(), msg_to_pdu(), normalize_charset(), normalize_number(), numhash_get_key(), obey_request(), obey_request_thread(), octstr_convert_to_html_entities(), octstr_delete_matching(), octstr_drop_trailing_zeros(), octstr_dump_debug(), octstr_hash_key(), octstr_is_all_hex(), octstr_isnum(), octstr_read_file(), octstr_replace(), octstr_replace_first(), octstr_search_chars(), octstr_shrink_blanks(), octstr_split(), octstr_strip_blanks(), octstr_strip_char(), octstr_strip_crlfs(), octstr_strip_nonalphanums(), ois_adjust_sm_text(), ois_append_msisdn(), ois_append_sm_text(), ois_append_submission_options(), oisd_accept_message(), oisd_expand_gsm7(), oisd_expand_gsm7_to_bits(), oisd_send_delivery_request(), oisd_shrink_gsm7(), open_send_connection(), ota_compile(), ota_pack_push_headers(), our_hash_func(), output_octet_string(), output_st_octet_string(), pack_7bit(), pack_cache_control(), pack_challenge(), pack_content_range(), pack_credentials(), pack_known_header(), pack_md5(), pack_parameter(), pack_quoted_string(), pack_range(), pack_server_address(), pack_tpis(), pack_warning(), packet_add_address_parm(), packet_add_parm(), packet_check(), packet_check_header(), packet_encode_message(), packet_extract(), packet_set_checksum(), packet_set_data_size(), pap_compile(), pap_request_thread(), parm_parse(), parm_valid_address(), parse_address(), parse_appid_header(), parse_array_element(), parse_attr_value(), parse_attribute(), parse_cgivars(), parse_charset(), parse_close_delimiter(), parse_constant(), parse_context_create(), parse_data(), parse_data_element(), parse_document(), parse_element(), parse_epilogue(), parse_fault_element(), parse_field_name(), parse_field_value(), parse_get_seperated_block(), parse_http_version(), parse_integer(), parse_member_element(), parse_methodcall_element(), parse_methodresponse_element(), parse_msg_to_rawmessage(), parse_ota_syncsettings(), parse_param_element(), parse_params_element(), parse_st_octet_string(), parse_struct_element(), parse_tail(), parse_text(), parse_url(), parse_url_value(), parse_value(), parse_value_element(), parse_variable(), parse_xml_tag(), pass_data_headers(), pass_field_name(), pass_field_value(), pass_optional_header(), pattern_matches_ip(), pdu_to_msg(), prepend_catenation_udh(), radius_authenticate_pdu(), radius_pdu_pack(), radius_pdu_unpack(), read_line(), read_mime_headers(), read_msg(), read_some_headers(), receive_push_reply(), remove_crs(), remove_prefix(), replace_octstr_char(), response(), return_reply(), route_incoming_to_boxc(), run_batch(), sanitize_capabilities(), sema_encode_msg(), sema_msg_session_mt(), sema_receive_msg(), sema_submit_msg(), send_bad_message_response(), send_file(), send_message(), send_packet(), send_post(), send_request(), set_charset(), set_dlr_mask(), set_zero(), si_compile(), simple_binary_output(), skip_html_comment(), skip_html_tag(), skip_tail(), sl_compile(), smpp_pdu_pack(), smpp_pdu_unpack(), sms_charset_processing(), sms_msgdata_len(), sms_split(), sms_to_client(), smsbox_req_handle(), smsbox_req_sendota(), smsbox_req_sendsms(), smsbox_sendota_post(), smsbox_sendsms_post(), smsc_at2_create(), smsc_cimd2_create(), smsc_emi2_create(), smsc_smpp_create(), soap_fetch_xml_data(), soap_format_xml(), soap_o2o_msgdata_attribute(), soap_read_date(), split_headers(), sql_list(), sql_single(), start_fetch(), start_push(), store_file_init(), store_file_load(), store_spool_save(), string_table_add(), string_table_add_many(), string_table_apply(), string_table_collect_strings(), string_table_output(), strip_prefix_and_suffix(), timestamp_to_minutes(), tokenize_date(), truncated_datagram(), udp_get_ip(), udp_get_port(), udp_sendto(), unescape_data(), unlocked_inbuf_len(), unlocked_outbuf_len(), unlocked_write(), unpack_broken_parameters(), unpack_credentials(), unpack_datagram(), unpack_new_headers(), unpack_parameter(), unpack_warning_value(), url_result_thread(), urltrans_fill_escape_codes(), urltrans_get_pattern(), wap_map_url(), wap_msg_recv(), wml_binary_output(), wml_compile(), write_data(), write_msg(), wsp_cap_pack_list(), wsp_cap_unpack_list(), wsp_headers_unpack(), wsp_pack_integer_string(), wsp_pack_list(), wsp_pack_long_integer(), wsp_pack_value(), wsp_pack_version_value(), wsp_strip_parameters(), wsp_unpack_well_known_field(), wtp_unpack_wdp_datagram(), xidris_send_sms(), and xmlrpc_doc_parse().

{
    if (ostr == NULL)
        return 0;
    seems_valid(ostr);
    return ostr->len;
}

octstr_ncompare()

int octstr_ncompare	(	const Octstr *	ostr1,
		const Octstr *	ostr2,
		long	n
	)

Definition at line 952 of file octstr.c.

References Octstr::data, Octstr::len, and seems_valid.

Referenced by compare_octstr_sequence(), get_msg_filename(), http_header_get_content_type(), kannel_parse_reply(), pack_content_range(), pack_range(), packet_encode_message(), parse_attribute(), parse_close_delimiter(), parse_http_version(), remove_prefix(), and response().

{
    long len;

    seems_valid(ostr1);
    seems_valid(ostr2);

    if ((ostr1->len < ostr2->len) && (ostr1->len < n))
        len = ostr1->len;
    else if ((ostr2->len < ostr1->len) && (ostr2->len < n))
        len = ostr2->len;
    else
        len = n;

    if (len == 0)
        return 0;

    return memcmp(ostr1->data, ostr2->data, len);
}

octstr_parse_double()

long octstr_parse_double	(	double *	nump,
		Octstr *	ostr,
		long	pos
	)

Definition at line 782 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, number, and seems_valid.

Referenced by parse_value_element(), and smscconn_create().

{
    /* strtod wants a char *, and we have to compare the result to
     * an unsigned char *.  The easiest way to avoid warnings without
     * introducing typecasts is to use two variables. */
    char *endptr;
    unsigned char *endpos;
    double number;

    seems_valid(ostr);
    gw_assert(nump != NULL);

    if (pos >= ostr->len) {
        errno = EINVAL;
        return -1;
    }

    errno = 0;
    number = strtod(ostr->data + pos, &endptr);
    endpos = endptr;
    if (errno == ERANGE)
        return -1;
    if (endpos == ostr->data + pos) {
        errno = EINVAL;
        return -1;
    }

    *nump = number;
    return endpos - ostr->data;
}

octstr_parse_long()

long octstr_parse_long	(	long *	nump,
		Octstr *	ostr,
		long	pos,
		int	base
	)

Definition at line 749 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, number, and seems_valid.

Referenced by at2_check_sms_memory(), at2_pdu_extract(), at2_read_pending_incoming_messages(), at2_wait_modem_command(), cfg_get_integer(), cgw_handle_op(), client_read_status(), convert_html_entity(), date_item_compare(), date_parse_http(), deduce_body_state(), eat_number(), eq_round_trip_time(), get_fields(), handle_operation(), init_bearerbox(), init_smsbox(), init_wapbox(), main(), pack_content_range(), pack_parameter(), pack_range_value(), pack_warning(), packet_check_parameter(), packet_get_int_parm(), packet_get_parm(), packet_parse_header(), parse_code(), parse_date(), parse_url(), parse_value_element(), pdu_to_msg(), read_chunked_body_len(), remove_long(), set_dlr_mask(), smsc_open(), soap_read_date(), wap_push_ppg_pushuser_authenticate(), and wsp_pack_version_value().

{
    /* strtol wants a char *, and we have to compare the result to
     * an unsigned char *.  The easiest way to avoid warnings without
     * introducing typecasts is to use two variables. */
    char *endptr;
    unsigned char *endpos;
    long number;

    seems_valid(ostr);
    gw_assert(nump != NULL);
    gw_assert(base == 0 || (base >= 2 && base <= 36));

    if (pos >= ostr->len) {
        errno = EINVAL;
        return -1;
    }

    errno = 0;
    number = strtol(ostr->data + pos, &endptr, base);
    endpos = endptr;
    if (errno == ERANGE)
        return -1;
    if (endpos == ostr->data + pos) {
        errno = EINVAL;
        return -1;
    }

    *nump = number;
    return endpos - ostr->data;
}

octstr_pretty_print()

int octstr_pretty_print	(	FILE *	f,
		Octstr *	ostr
	)

Definition at line 1206 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by main().

{
    unsigned char *p;
    long i;

    gw_assert(f != NULL);
    seems_valid(ostr);

    p = ostr->data;
    for (i = 0; i < ostr->len; ++i, ++p) {
        if (isprint(*p))
            fprintf(f, "%c", *p);
        else
            fprintf(f, "\\x%02x", *p);
    }
    if (ferror(f))
        return -1;
    return 0;
}

octstr_print()

int octstr_print	(	FILE *	f,
		Octstr *	ostr
	)

Definition at line 1191 of file octstr.c.

References Octstr::data, error(), gw_assert(), Octstr::len, and seems_valid.

Referenced by client_thread(), main(), and write_msg().

{
    gw_assert(f != NULL);
    seems_valid(ostr);

    if (ostr->len == 0)
        return 0;
    if (fwrite(ostr->data, ostr->len, 1, f) != 1) {
        error(errno, "Couldn't write all of octet string to file.");
        return -1;
    }
    return 0;
}

octstr_read_file()

Octstr* octstr_read_file

(

const char *

filename

)

Definition at line 1548 of file octstr.c.

References error(), filename, gw_assert(), octstr_create, octstr_destroy(), octstr_insert_data(), and octstr_len().

Referenced by check_reversible(), dispatch(), expand_file(), get_msg_surrogate(), init_batch(), main(), obey_request(), post_content_create(), push_content_create(), send_file(), smsc_soap_create(), status_cb(), and store_file_load().

{
    FILE *f;
    Octstr *os;
    char buf[4096];
    long n;

    gw_assert(filename != NULL);

    f = fopen(filename, "r");
    if (f == NULL) {
        error(errno, "fopen failed: couldn't open `%s'", filename);
        return NULL;
    }

    os = octstr_create("");
    if (os == NULL)
        goto error;

    while ((n = fread(buf, 1, sizeof(buf), f)) > 0)
        octstr_insert_data(os, octstr_len(os), buf, n);

    (void) fclose(f);
    return os;

error:
    (void) fclose(f);
    octstr_destroy(os);
    return NULL;
}

octstr_read_pipe()

Octstr* octstr_read_pipe

(

FILE *

f

)

Definition at line 1580 of file octstr.c.

References error(), gw_assert(), octstr_append_data(), octstr_create, and octstr_destroy().

Referenced by obey_request().

{
    Octstr *os;
    char buf[4096];

    gw_assert(f != NULL);

    os = octstr_create("");
    if (os == NULL)
        goto error;

    while (fgets(buf, sizeof(buf), f) != NULL)
        octstr_append_data(os, buf, strlen(buf));

    return os;

error:
    octstr_destroy(os);
    return NULL;
}

octstr_recode()

int octstr_recode	(	Octstr *	tocode,
		Octstr *	fromcode,
		Octstr *	orig
	)

Definition at line 2576 of file octstr.c.

References charset_from_utf8(), charset_to_utf8(), octstr_append(), octstr_case_compare(), octstr_destroy(), octstr_duplicate, octstr_imm(), and octstr_truncate().

Referenced by bearerbox_to_smpp(), and obey_request_thread().

{
    Octstr *octstr_utf8 = NULL;
    Octstr *octstr_final = NULL;
    int resultcode = 0;
    
    if (octstr_case_compare(tocode, fromcode) == 0) {
    goto cleanup_and_exit;
    }

    if ((octstr_case_compare(fromcode, octstr_imm ("UTF-8")) != 0) &&
    (octstr_case_compare(fromcode, octstr_imm ("UTF8")) != 0)) {
    if (charset_to_utf8(orig, &octstr_utf8, fromcode) < 0) {
        resultcode = -1;
        goto cleanup_and_exit;
    }
    } else {
    octstr_utf8 = octstr_duplicate(orig);
    }

    if ((octstr_case_compare(tocode, octstr_imm ("UTF-8")) != 0) &&
    (octstr_case_compare(tocode, octstr_imm ("UTF8")) != 0)) {
    if (charset_from_utf8(octstr_utf8, &octstr_final, tocode) < 0) {
        resultcode = -1;
        goto cleanup_and_exit;
    }
    } else {
    octstr_final = octstr_duplicate(octstr_utf8);
    }

    octstr_truncate(orig, 0);
    octstr_append(orig, octstr_final);

 cleanup_and_exit:
    octstr_destroy (octstr_utf8);
    octstr_destroy (octstr_final);

    return resultcode;
}

octstr_replace()

void octstr_replace	(	Octstr *	haystack,
		Octstr *	needle,
		Octstr *	repl
	)

Definition at line 2649 of file octstr.c.

References octstr_delete(), octstr_insert(), octstr_len(), and octstr_search().

Referenced by brunet_send_sms(), clickatell_send_sms(), main(), msg_to_pdu(), and xml_error().

{
    int p = 0;
    long len, repl_len;

    len = octstr_len(needle);
    repl_len = octstr_len(repl);

    while ((p = octstr_search(haystack, needle, p)) != -1) {
        octstr_delete(haystack, p, len);
        octstr_insert(haystack, repl, p);
        p += repl_len;
    }
}

octstr_replace_first()

void octstr_replace_first	(	Octstr *	haystack,
		Octstr *	needle,
		Octstr *	repl
	)

Definition at line 2664 of file octstr.c.

References octstr_delete(), octstr_insert(), octstr_len(), and octstr_search().

{
    int p = 0;
    long len, repl_len;

    len = octstr_len(needle);
    repl_len = octstr_len(repl);

    p = octstr_search(haystack, needle, p);
    if (p != -1) {
        octstr_delete(haystack, p, len);
        octstr_insert(haystack, repl, p);
    }
}

octstr_rsearch_char()

long octstr_rsearch_char	(	const Octstr *	ostr,
		int	ch,
		long	pos
	)

Definition at line 1031 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

{
    long i;

    seems_valid(ostr);
    gw_assert(ch >= 0);
    gw_assert(ch <= UCHAR_MAX);
    gw_assert(pos >= 0);

    if (pos >= ostr->len)
        return -1;

    for (i = pos; i >= 0; i--) {
        if (ostr->data[i] == ch)
            return i;
    }

    return -1;
}

octstr_search()

long octstr_search	(	const Octstr *	haystack,
		const Octstr *	needle,
		long	pos
	)

Definition at line 1070 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, octstr_search_char(), and seems_valid.

Referenced by at2_check_sms_memory(), at2_detect_modem_type(), at2_extract_line(), at2_pdu_extract(), at2_wait_modem_command(), bearerbox_to_smpp(), brunet_send_sms(), cfg_read(), cgw_decode_msg(), check_control_content_type_header(), check_data_content_type_header(), check_data_x_wap_application_id_header(), convert_addr_from_pdu(), count_occurences(), dlr_mem_entry_match(), drop_optional_header(), eat_string_parm(), find_charset_encoding(), get_msg_filename(), handle_dlr(), hash_cmp(), httpd_serve(), octstr_delete_matching(), octstr_replace(), octstr_replace_first(), octstr_split(), parse_appid_header(), parse_attr_value(), parse_body_part(), parse_entities(), parse_get_seperated_block(), parse_preamble(), parse_url_value(), parse_xml_tag(), pass_extension_headers(), pass_optional_header(), return_reply(), set_charset(), skip_html_comment(), string_table_apply(), and wap_push_ppg_pushuser_search_ip_from_wildcarded_list().

{
    int first;

    seems_valid(haystack);
    seems_valid(needle);
    gw_assert(pos >= 0);

    /* Always "find" an empty string */
    if (needle->len == 0)
        return 0;

    if (needle->len == 1)
        return octstr_search_char(haystack, needle->data[0], pos);

    /* For each occurrence of needle's first character in ostr,
     * check if the rest of needle follows.  Stop if there are no
     * more occurrences, or if the rest of needle can't possibly
     * fit in the haystack. */
    first = needle->data[0];
    pos = octstr_search_char(haystack, first, pos);
    while (pos >= 0 && haystack->len - pos >= needle->len) {
        if (memcmp(haystack->data + pos,
                   needle->data, needle->len) == 0)
            return pos;
        pos = octstr_search_char(haystack, first, pos + 1);
    }

    return -1;
}

octstr_search_char()

long octstr_search_char	(	const Octstr *	ostr,
		int	ch,
		long	pos
	)

Definition at line 1012 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, and seems_valid.

Referenced by at2_detect_modem_type(), at2_extract_line(), at2_init_device(), at2_read_pending_incoming_messages(), at2_scan_for_telnet_escapes(), cfg_read(), cgw_encode_msg(), cgw_read_op(), check_reversible(), check_variable_syntax(), client_read_status(), conn_read_line(), conn_read_packet(), copy_until_assign(), copy_until_coma(), copy_until_nul(), date_parse_http(), date_parse_iso(), decode_type(), eat_string_parm(), emi2_handle_smscreq(), extract_msgdata_part(), find_translation(), generic_init(), get_fields(), get_header_value(), get_variable(), handle_dlr(), header_is_called(), http_accept_request(), http_get_header_parameter(), http_header_get(), http_header_get_content_type(), http_header_value(), httpd_serve(), msg_to_bb(), octstr_convert_from_html_entities(), octstr_search(), octstr_search_chars(), octstr_str_search(), pack_credentials(), packet_check(), packet_extract(), packet_get_parm(), pap_compile(), parm_parse(), parse_address(), parse_attr_value(), parse_cgivars(), parse_charset(), parse_data(), parse_element(), parse_get_line(), parse_get_nul_string(), parse_st_octet_string(), parse_url(), read_line(), set_charset(), skip_html_tag(), skip_tail(), skip_until_after_colon(), soap_parse_dlr(), soap_parse_mo(), urltrans_fill_escape_codes(), wap_push_ppg_pushuser_search_ip_from_wildcarded_list(), wml_compile(), wrapper_sender(), wsp_cap_pack_list(), wsp_cap_unpack_list(), and wsp_strip_parameters().

{
    unsigned char *p;

    seems_valid(ostr);
    gw_assert(ch >= 0);
    gw_assert(ch <= UCHAR_MAX);
    gw_assert(pos >= 0);

    if (pos >= ostr->len)
        return -1;

    p = memchr(ostr->data + pos, ch, ostr->len - pos);
    if (!p)
        return -1;
    return p - ostr->data;
}

octstr_search_chars()

long octstr_search_chars	(	const Octstr *	ostr,
		const Octstr *	chars,
		long	pos
	)

Definition at line 1052 of file octstr.c.

References gw_assert(), octstr_get_char(), octstr_len(), octstr_search_char(), and seems_valid.

Referenced by smsbox_req_handle().

{
    long i, j;

    seems_valid(ostr);
    seems_valid(chars);
    gw_assert(pos >= 0);

    for (i = 0; i < octstr_len(chars); i++) {
    j = octstr_search_char(ostr, octstr_get_char(chars, i), pos);
    if (j != -1)
        return j;
    }

    return -1;
}

octstr_set_bits()

void octstr_set_bits	(	Octstr *	ostr,
		long	bitpos,
		int	numbits,
		unsigned long	value
	)

Definition at line 1849 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, maxlen, octstr_grow(), and seems_valid.

Referenced by pack_server_address(), pack_tpis(), sanitize_capabilities(), set_user_ack(), tokenize_date(), and wtp_pack_set_rid().

{
    long pos;
    unsigned long mask;
    int shiftwidth;
    int bits;
    int maxlen;
    int c;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    gw_assert(bitpos >= 0);
    gw_assert(numbits <= 32);
    gw_assert(numbits >= 0);

    maxlen = (bitpos + numbits + 7) / 8;
    if (maxlen > ostr->len) {
        octstr_grow(ostr, maxlen);
        /* Make sure the new octets start out with value 0 */
        for (pos = ostr->len; pos < maxlen; pos++) {
            ostr->data[pos] = 0;
        }
        ostr->len = maxlen;
        ostr->data[maxlen] = 0;
    }

    mask = (1 << numbits) - 1;
    /* mask is also the largest value that fits */
    gw_assert(value <= mask);

    pos = bitpos / 8;
    bitpos = bitpos % 8;

    /* Does the range fit in one octet? */
    if (bitpos + numbits <= 8) {
        /* shiftwidth is the number of bits to ignore on the right.
         * bitpos 0 is the leftmost bit. */
        shiftwidth = 8 - (bitpos + numbits);
        /* Extract the bits we don't want to affect */
        c = ostr->data[pos] & ~(mask << shiftwidth);
        c |= value << shiftwidth;
        gw_assert(pos < ostr->len);
        ostr->data[pos] = c;
        return;
    }

    /* Otherwise... */
    /* If speed is a problem here, we could have separate cases for
     * the first octet (which may have bitpos > 0), and the rest,
     * which don't. */
    while (bitpos + numbits > 8) {
        /* We want this many bits from the value */
        bits = 8 - bitpos;
        /* There are this many bits to their right in the value */
        shiftwidth = numbits - bits;
        /* Construct a mask for "bits" bits on the far right */
        mask = (1 << bits) - 1;
        /* Get the bits we want */
        c = (value >> shiftwidth) & mask;
        /* Merge them with the bits that are already there */
        gw_assert(pos < ostr->len);
        ostr->data[pos] = (ostr->data[pos] & ~mask) | c;
        numbits -= (8 - bitpos);
        bitpos = 0;
        pos++;
    }

    gw_assert(bitpos == 0);
    gw_assert(pos < ostr->len);
    /* Set remaining bits.  This is just like the single-octet case
     * before the loop, except that we know bitpos is 0. */
    mask = (1 << numbits) - 1;
    shiftwidth = 8 - numbits;
    c = ostr->data[pos] & ~(mask << shiftwidth);
    c |= value << shiftwidth;
    ostr->data[pos] = c;

    seems_valid(ostr);
}

octstr_set_char()

void octstr_set_char	(	Octstr *	ostr,
		long	pos,
		int	ch
	)

Definition at line 415 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, and seems_valid.

Referenced by at2_extract_line(), charset_gsm_to_latin1(), charset_gsm_to_nrc_iso_21_german(), charset_latin1_to_gsm(), charset_nrc_iso_21_german_to_gsm(), concat_handling_check_and_handle(), convert_cimd2_to_gsm(), convert_gsm_to_cimd2(), octstr_shrink_blanks(), pack_7bit(), packet_set_data_size(), packet_set_sequence(), parse_url(), prepend_catenation_udh(), set_tid(), set_tid_new(), set_zero(), unpack_broken_parameters(), wap_msg_send(), and wtp_invoke_create().

{
    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    if (pos < ostr->len)
        ostr->data[pos] = ch;
    seems_valid(ostr);
}

octstr_shrink_blanks()

void octstr_shrink_blanks

(

Octstr *

text

)

Definition at line 1433 of file octstr.c.

References gw_assert(), octstr_delete(), octstr_get_char(), octstr_len(), octstr_set_char(), seems_valid, and text.

Referenced by html_to_sms(), ota_compile(), parse_text(), string_table_collect_strings(), and xmlrpc_doc_parse().

{
    int i, j, end;

    seems_valid(text);
    gw_assert(!text->immutable);

    end = octstr_len(text);

    /* Shrink white spaces to one  */
    for (i = 0; i < end; i++) {
        if (isspace(octstr_get_char(text, i))) {
            /* Change the remaining space into single space. */
            if (octstr_get_char(text, i) != ' ')
                octstr_set_char(text, i, ' ');

            j = i = i + 1;
            while (isspace(octstr_get_char(text, j)))
                j ++;
            if (j - i > 0)
                octstr_delete(text, i, j - i);
        }
    }

    seems_valid(text);
}

octstr_shutdown()

void octstr_shutdown

(

void

)

Definition at line 226 of file octstr.c.

References debug(), immutables, immutables_mutex, MAX_IMMUTABLES, and mutex_destroy().

Referenced by gwlib_shutdown().

{
    long i, n;

    n = 0;
    for (i = 0; i < MAX_IMMUTABLES; ++i) {
        if (immutables[i] != NULL) {
        gw_free(immutables[i]);
            ++n;
        }
    }
    if(n>0)
        debug("gwlib.octstr", 0, "Immutable octet strings: %ld.", n);
    mutex_destroy(&immutables_mutex);
}

octstr_split()

List* octstr_split	(	const Octstr *	os,
		const Octstr *	sep
	)

Definition at line 1640 of file octstr.c.

References gwlist_append(), gwlist_create, octstr_copy, octstr_len(), and octstr_search().

Referenced by at2_detect_modem_type(), at2_init_device(), brunet_parse_body(), client_is_persistent(), create_onetrans(), expand_file(), init_batch(), init_reroute(), init_smsbox_routes(), init_smsc_routes(), main(), msg_to_pdu(), pattern_list_matches_ip(), prefix_allowed(), response(), smpp_pdu_init(), smsc_soap_create(), soap_create_map(), soap_fetch_xml_data(), soap_map_xml_data(), soap_release_dependences(), udp_start(), wap_push_ppg_pushuser_search_ip_from_wildcarded_list(), and wildcarded_ip_found().

{
    List *list;
    long next, pos, seplen;
    
    list = gwlist_create();
    pos = 0;
    seplen = octstr_len(sep);

    while ((next = octstr_search(os, sep, pos)) >= 0) {
        gwlist_append(list, octstr_copy(os, pos, next - pos));
        pos = next + seplen;
    }
    
    if (pos < octstr_len(os))
        gwlist_append(list, octstr_copy(os, pos, octstr_len(os)));
    
    return list;
}

octstr_split_words()

List* octstr_split_words

(

const Octstr *

ostr

)

Definition at line 1602 of file octstr.c.

References Octstr::data, gwlist_append(), gwlist_create, octstr_create_from_data, seems_valid, and start.

Referenced by brunet_parse_body(), cfg_get_list(), clickatell_parse_body(), find_translation(), get_pattern(), parse_request_line(), randomize(), smsbox_req_handle(), soap_create_map(), soap_release_dependences(), string_table_collect_words(), urltrans_fill_escape_codes(), and wrapper_sender().

{
    unsigned char *p;
    List *list;
    Octstr *word;
    long i, start, end;

    seems_valid(ostr);

    list = gwlist_create();

    p = ostr->data;
    i = 0;
    for (; ; ) {
        while (i < ostr->len && isspace(*p)) {
            ++p;
            ++i;
        }
        start = i;

        while (i < ostr->len && !isspace(*p)) {
            ++p;
            ++i;
        }
        end = i;

        if (start == end)
            break;

        word = octstr_create_from_data(ostr->data + start,
                                       end - start);
        gwlist_append(list, word);
    }

    return list;
}

octstr_str_case_compare()

int octstr_str_case_compare	(	const Octstr *	ostr,
		const char *	str
	)

Definition at line 986 of file octstr.c.

References Octstr::data, and seems_valid.

Referenced by convert_addr_from_pdu(), get_x_kannel_from_xml(), meta_data_get_value(), meta_data_get_values(), meta_data_remove_value(), meta_data_set_value(), meta_data_set_values(), msg_to_pdu(), and smpp_pdu_init().

{
    seems_valid(ostr);

    if (str == NULL)
        return -1;
    if (ostr->data == NULL)
       return strcasecmp("", str);

    return strcasecmp(ostr->data, str);
}

octstr_str_compare()

int octstr_str_compare	(	const Octstr *	ostr,
		const char *	str
	)

Definition at line 973 of file octstr.c.

References Octstr::data, and seems_valid.

Referenced by at2_open_device1(), check_variable_syntax(), convert_content(), create_onetrans(), date_parse_http(), deconvert_content(), deduce_body_state(), get_qvalue(), handle_login(), http_accept_request(), http_cgi_variable(), http_name2method(), httpd_serve(), numhash_create(), octstr_find_entity(), parse_attribute(), parse_charset(), pdu_to_msg(), smsc_at2_create(), soap_create_map(), soap_fetch_xml_data(), soap_get_index(), soap_lookup_function(), soap_map_xml_data(), soap_release_dependences(), start_fetch(), store_init(), and wsp_pack_application_header().

{
    seems_valid(ostr);

    if (str == NULL)
        return -1;
    if (ostr->data == NULL)
    return strcmp("", str);

    return strcmp(ostr->data, str);
}

octstr_str_ncompare()

int octstr_str_ncompare	(	const Octstr *	ostr,
		const char *	str,
		long	n
	)

Definition at line 999 of file octstr.c.

References Octstr::data, and seems_valid.

Referenced by cid_matches().

{
    seems_valid(ostr);

    if (str == NULL)
        return -1;
    if (ostr->data == NULL)
        return 1; /* str grater */

    return strncmp(ostr->data, str, n);
}

octstr_str_search()

long octstr_str_search	(	const Octstr *	haystack,
		const char *	needle,
		long	pos
	)

Definition at line 1157 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::len, octstr_search_char(), and seems_valid.

{
    int first;
    int needle_len;

    seems_valid(haystack);
    gw_assert(pos >= 0);

    /* Always "find" an empty string */
    if (needle == NULL || needle[0] == '\0')
        return 0;

    needle_len = strlen(needle);

    if (needle_len == 1)
        return octstr_search_char(haystack, needle[0], pos);

    /* For each occurrence of needle's first character in ostr,
     * check if the rest of needle follows.  Stop if there are no
     * more occurrences, or if the rest of needle can't possibly
     * fit in the haystack. */
    first = needle[0];
    pos = octstr_search_char(haystack, first, pos);
    while (pos >= 0 && haystack->len - pos >= needle_len) {
        if (memcmp(haystack->data + pos,
                   needle, needle_len) == 0)
            return pos;
        pos = octstr_search_char(haystack, first, pos + 1);
    }

    return -1;
}

octstr_strip_blanks()

void octstr_strip_blanks

(

Octstr *

text

)

Definition at line 1346 of file octstr.c.

References gw_assert(), octstr_delete(), octstr_get_char(), octstr_len(), seems_valid, start, and text.

Referenced by at2_extract_line(), at2_format_address_field(), cfg_read(), deduce_body_state(), find_charset_encoding(), get_header_value(), get_x_kannel_from_headers(), get_x_kannel_from_xml(), handle_dlr(), handle_transaction(), html_to_sms(), http_add_basic_auth(), http_get_header_parameter(), http_header_add_element(), http_header_find_first_real(), http_header_get(), http_header_get_content_type(), http_header_value(), init_reroute(), init_smsbox_routes(), init_smsc_routes(), ota_compile(), pack_challenge(), pack_credentials(), pack_known_header(), pap_compile(), parm_parse(), parse_text(), parse_value(), parse_xml_tag(), proxy_add_authentication(), response(), si_compile(), sl_compile(), smsbox_sendota_post(), smsbox_sendsms_post(), soap_map_xml_data(), soap_release_dependences(), string_table_collect_strings(), transform_message(), url_result_thread(), wml_compile(), wsp_pack_separate_content_type(), wsp_strip_parameters(), and xmlrpc_doc_parse().

{
    int start = 0, end, len = 0;

    seems_valid(text);
    gw_assert(!text->immutable);

    /* Remove white space from the beginning of the text */
    while (isspace(octstr_get_char(text, start)) && 
       start <= octstr_len(text))
        start ++;

    if (start > 0)
        octstr_delete(text, 0, start);

    /* and from the end. */

    if ((len = octstr_len(text)) > 0) {
        end = len = len - 1;
        while (isspace(octstr_get_char(text, end)) && end >= 0)
            end--;
        octstr_delete(text, end + 1, len - end);
    }

    seems_valid(text);
}

octstr_strip_char()

void octstr_strip_char	(	Octstr *	text,
		char	ch
	)

Definition at line 2616 of file octstr.c.

References gw_assert(), octstr_delete(), octstr_get_char(), octstr_len(), seems_valid, start, and text.

{
    int start = 0;

    seems_valid(text);
    gw_assert(!text->immutable);

    /* Remove char from the beginning of the text */
    while ((ch == octstr_get_char(text, start)) &&
           start <= octstr_len(text))
        start ++;

    if (start > 0)
        octstr_delete(text, 0, start);

    seems_valid(text);
}

octstr_strip_crlfs()

void octstr_strip_crlfs

(

Octstr *

text

)

Definition at line 1378 of file octstr.c.

References gw_assert(), iscrlf(), octstr_delete(), octstr_get_char(), octstr_len(), seems_valid, start, and text.

Referenced by init_batch(), main(), parse_get_line(), parse_xml_tag(), and soap_release_dependences().

{
    int start = 0, end, len = 0;

    seems_valid(text);
    gw_assert(!text->immutable);

    /* Remove white space from the beginning of the text */
    while (iscrlf(octstr_get_char(text, start)) && 
       start <= octstr_len(text))
        start ++;

    if (start > 0)
        octstr_delete(text, 0, start);

    /* and from the end. */

    if ((len = octstr_len(text)) > 0) {
        end = len = len - 1;
        while (iscrlf(octstr_get_char(text, end)) && end >= 0)
            end--;
        octstr_delete(text, end + 1, len - end);
    }

    seems_valid(text);
}

octstr_strip_nonalphanums()

void octstr_strip_nonalphanums

(

Octstr *

text

)

Definition at line 1405 of file octstr.c.

References gw_assert(), octstr_delete(), octstr_get_char(), octstr_len(), seems_valid, start, and text.

Referenced by string_table_collect_strings().

{
    int start = 0, end, len = 0;

    seems_valid(text);
    gw_assert(!text->immutable);

    /* Remove white space from the beginning of the text */
    while (!isalnum(octstr_get_char(text, start)) && 
       start <= octstr_len(text))
        start ++;

    if (start > 0)
        octstr_delete(text, 0, start);

    /* and from the end. */

    if ((len = octstr_len(text)) > 0) {
        end = len = len - 1;
        while (!isalnum(octstr_get_char(text, end)) && end >= 0)
            end--;
        octstr_delete(text, end + 1, len - end);
    }

    seems_valid(text);
}

octstr_symbolize()

int octstr_symbolize

(

Octstr *

ostr

)

Definition at line 2679 of file octstr.c.

References gw_assert(), gw_isxdigit(), Octstr::immutable, Octstr::len, octstr_check_range(), octstr_grow(), octstr_insert_data(), and seems_valid.

{
    long len, i;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

    if (ostr->len == 0)
        return 0;

    /* Check if it's in the right format */
    if (!octstr_check_range(ostr, 0, ostr->len, gw_isxdigit))
        return -1;

    len = ostr->len + (ostr->len/2);
    octstr_grow(ostr, ostr->len * 2);

    for (i = 0; i < len; i += 3)
        octstr_insert_data(ostr, i, "%", 1);

    return 1;
}

octstr_truncate()

void octstr_truncate	(	Octstr *	ostr,
		int	new_len
	)

Definition at line 1327 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, Octstr::len, and seems_valid.

Referenced by at2_detect_modem_type(), at2_init_device(), at2_pdu_extract(), charset_convert(), charset_gsm_to_utf8(), charset_gsm_truncate(), charset_utf8_to_gsm(), check_variable_syntax(), client_read_status(), convert(), emi2_handle_smscreq(), get_x_kannel_from_xml(), http_accept_request(), http_header_get_content_type(), msg_to_emimsg(), octstr_recode(), packet_encode_message(), parse_charset(), parse_st_octet_string(), parse_value(), parse_variable(), send_file(), smsc_cimd2_create(), string_table_apply(), strip_prefix_and_suffix(), and url_pattern().

{
    if (ostr == NULL)
        return;
        
    seems_valid(ostr);
    gw_assert(!ostr->immutable);
    gw_assert(new_len >= 0);

    if (new_len >= ostr->len)
        return;

    ostr->len = new_len;
    ostr->data[new_len] = '\0';

    seems_valid(ostr);
}

octstr_url_decode()

int octstr_url_decode

(

Octstr *

ostr

)

Definition at line 1746 of file octstr.c.

References code, Octstr::data, gw_assert(), H2B, Octstr::immutable, Octstr::len, seems_valid, and warning().

Referenced by brunet_send_sms(), charset_processing(), get_x_kannel_from_headers(), get_x_kannel_from_xml(), meta_data_unpack(), msg_to_bb(), parse_cgivars(), parse_url(), soap_parse_dlr(), soap_parse_mo(), start_request(), and xidris_send_sms().

{
    unsigned char *string;
    unsigned char *dptr;
    int code, code2, ret = 0;

    if (ostr == NULL)
        return 0;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

    if (ostr->len == 0)
        return 0;

    string = ostr->data;
    dptr = ostr->data;

    do {
        if (*string == '%') {
            if (*(string + 1) == '\0' || *(string + 2) == '\0') {
                warning(0, "octstr_url_decode: corrupted end-of-string <%s>", string);
                ret = -1;
                break;
            }

            code = H2B(*(string + 1));
            code2 = H2B(*(string + 2));

            if (code == -1 || code2 == -1) {
                warning(0, "octstr_url_decode: garbage detected (%c%c%c) skipping.",
                            *string, *(string + 1), *(string + 2));
                *dptr++ = *string++;
                *dptr++ = *string++;
                *dptr++ = *string++;
                ret = -1;
                continue;
            }

            *dptr++ = code << 4 | code2;
            string += 3;
        }
        else if (*string == '+') {
            *dptr++ = ' ';
            string++;
        } else
            *dptr++ = *string++;
    } while (*string);  /* we stop here because it terimates encoded string */

    *dptr = '\0';
    ostr->len = (dptr - ostr->data);

    seems_valid(ostr);
    return ret;
}

octstr_url_encode()

void octstr_url_encode

(

Octstr *

ostr

)

Definition at line 1673 of file octstr.c.

References Octstr::data, gw_assert(), Octstr::immutable, is_safe, Octstr::len, seems_valid, and Octstr::size.

Referenced by convert(), main(), obey_request(), sms_to_client(), and urltrans_fill_escape_codes().

{
    long i, n, len = 0;
    int all_safe;
    unsigned char c, *str, *str2, *res, *hexits;

    if (ostr == NULL)
        return;

    seems_valid(ostr);
    gw_assert(!ostr->immutable);

    if (ostr->len == 0)
        return;

    /* calculate new length */
    for (i = n = 0, str = ostr->data, all_safe = 1; i < ostr->len; i++) {
        c = *str++;
    
        if (c == ' ') {
            all_safe = 0;
            continue;
        }

        if (!is_safe[c]) {
        n++;
            all_safe = 0;
        }
     }

    if (all_safe) /* we are done, all chars are safe */
       return;

    hexits = "0123456789ABCDEF";

    /*
     * no need to reallocate if n == 0, so we make replace in place.
     * NOTE: we don't do if (xxx) ... else ... because conditional jump
     * is not so fast as just compare (alex).
     */
    res = str2 = (n ? gw_malloc((len = ostr->len + 2 * n + 1)) : ostr->data);

    for (i = 0, str = ostr->data; i < ostr->len; i++) {
        c = *str++;

        if (c == ' ') {
            *str2++ = '+';
            continue;
        }

        if (!is_safe[c]) {
            *str2++ = '%';
            *str2++ = hexits[c >> 4 & 0xf];
            *str2++ = hexits[c & 0xf];
            continue;
        }

        *str2++ = c;
    }
    *str2 = 0;
    
    /* we made replace in place */
    if (n) {
        gw_free(ostr->data);
        ostr->data = res;
        ostr->size = len;
        ostr->len = len - 1;
    }

    seems_valid(ostr);
}

octstr_write_data()

long octstr_write_data	(	Octstr *	ostr,
		int	fd,
		long	from
	)

Definition at line 1255 of file octstr.c.

References Octstr::data, error(), from, gw_assert(), Octstr::len, and seems_valid.

Referenced by unlocked_write().

{
    long ret;

    gw_assert(fd >= 0);
    gw_assert(from >= 0);
    seems_valid(ostr);

    if (from >= ostr->len)
        return 0;

    ret = write(fd, ostr->data + from, ostr->len - from);

    if (ret < 0) {
        if (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK)
            return 0;
        error(errno, "Error writing %ld octets to fd %d:",
              ostr->len - from, fd);
        return -1;
    }

    return ret;
}

octstr_write_to_socket()

int octstr_write_to_socket	(	int	socket,
		Octstr *	ostr
	)

Definition at line 1227 of file octstr.c.

References Octstr::data, error(), gw_assert(), Octstr::len, and seems_valid.

Referenced by cimd2_request(), cimd2_send_response(), oisd_request(), and oisd_send_response().

{
    long len;
    unsigned char *data;
    int ret;

    gw_assert(socket >= 0);
    seems_valid(ostr);

    data = ostr->data;
    len = ostr->len;
    while (len > 0) {
        ret = write(socket, data, len);
        if (ret == -1) {
            if (errno != EINTR) {
                error(errno, "Writing to socket failed");
                return -1;
            }
        } else {
            /* ret may be less than len */
            len -= ret;
            data += ret;
        }
    }
    return 0;
}

seems_valid_real()

static void seems_valid_real ( const Octstr *  ostr, const char *  filename, long  lineno, const char *  function  )

static

Definition at line 2545 of file octstr.c.

References Octstr::data, filename, gw_assert(), gw_assert_place, Octstr::immutable, immutables_init, Octstr::len, and Octstr::size.

Referenced by octstr_copy_real(), octstr_duplicate_real(), and octstr_get_cstr_real().

{
    gw_assert(immutables_init);
    gw_assert_place(ostr != NULL,
                    filename, lineno, function);
    gw_assert_allocated(ostr,
                        filename, lineno, function);
    gw_assert_place(ostr->len >= 0,
                    filename, lineno, function);
    gw_assert_place(ostr->size >= 0,
                    filename, lineno, function);
    if (ostr->size == 0) {
        gw_assert_place(ostr->len == 0,
                        filename, lineno, function);
        gw_assert_place(ostr->data == NULL,
                        filename, lineno, function);
    } else {
        gw_assert_place(ostr->len + 1 <= ostr->size,
                        filename, lineno, function);
        gw_assert_place(ostr->data != NULL,
                        filename, lineno, function);
    if (!ostr->immutable)
            gw_assert_allocated(ostr->data,
                                filename, lineno, function);
        gw_assert_place(ostr->data[ostr->len] == '\0',
                        filename, lineno, function);
    }
}

urlcode_init()

static void urlcode_init ( void  )

static

Definition at line 206 of file octstr.c.

References is_safe.

Referenced by octstr_init().

{
    int i;

    unsigned char *safe = " ABCDEFGHIJKLMNOPQRSTUVWXYZ"
                          "abcdefghijklmnopqrstuvwxyz"
                          "0123456789-_.~";
    for (i = 0; safe[i] != '\0'; ++i)
        is_safe[safe[i]] = 1;
}

Variable Documentation

immutables

Octstr* immutables[MAX_IMMUTABLES]

static

Definition at line 133 of file octstr.c.

Referenced by octstr_imm(), and octstr_shutdown().

immutables_init

int immutables_init = 0

static

Definition at line 135 of file octstr.c.

Referenced by octstr_imm(), octstr_init(), and seems_valid_real().

immutables_mutex

Mutex immutables_mutex

static

Definition at line 134 of file octstr.c.

Referenced by octstr_imm(), octstr_init(), and octstr_shutdown().

is_safe

char is_safe[UCHAR_MAX+1]

static

Definition at line 137 of file octstr.c.

Referenced by octstr_url_encode(), and urlcode_init().