No OneTemporary
Actions

Size

50 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/sipsimple/core.pxd b/sipsimple/core.pxd
	index 702e8aa2..331c107a 100644
	--- a/sipsimple/core.pxd
	+++ b/sipsimple/core.pxd
	@@ -1,1004 +1,1005 @@
	# Copyright (C) 2008-2009 AG Projects. See LICENSE for details.
	#

	cdef extern from *:
	ctypedef char char_ptr_const "const char "
	enum:
	PJ_SVN_REV "PJ_SVN_REVISION"

	# system imports

	cdef extern from "stdlib.h":
	void *malloc(int size)
	void free(void *ptr)

	cdef extern from "string.h":
	void memcpy(void s1, void *s2, int n)

	cdef extern from "sys/errno.h":
	enum:
	EADDRINUSE
	EBADF

	# Python C imports

	cdef extern from "Python.h":
	void Py_INCREF(object obj)
	void Py_DECREF(object obj)
	object PyString_FromStringAndSize(char *v, int len)
	char* PyString_AsString(object string) except NULL

	# PJSIP imports

	cdef extern from "pjlib.h":

	# constants
	enum:
	PJ_ERR_MSG_SIZE
	enum:
	PJ_ERRNO_START_SYS
	PJ_EBUG
	PJ_ETOOMANY
	enum:
	PJ_MAX_OBJ_NAME

	# init / shutdown
	int pj_init()
	void pj_shutdown()

	# version
	char *pj_get_version()

	# string
	struct pj_str_t:
	char *ptr
	int slen

	# errors
	pj_str_t pj_strerror(int statcode, char *buf, int bufsize)

	# logging
	enum:
	PJ_LOG_MAX_LEVEL
	enum pj_log_decoration:
	PJ_LOG_HAS_YEAR
	PJ_LOG_HAS_MONTH
	PJ_LOG_HAS_DAY_OF_MON
	PJ_LOG_HAS_TIME
	PJ_LOG_HAS_MICRO_SEC
	PJ_LOG_HAS_SENDER
	void pj_log_set_decor(int decor)
	int pj_log_get_level()
	void pj_log_set_level(int level)
	void pj_log_set_log_func(void func(int level, char_ptr_const data, int len))

	# memory management
	struct pj_pool_t
	struct pj_pool_factory_policy:
	pass
	pj_pool_factory_policy pj_pool_factory_default_policy
	struct pj_pool_factory:
	pass
	struct pj_caching_pool:
	pj_pool_factory factory
	void pj_caching_pool_init(pj_caching_pool ch_pool, pj_pool_factory_policy policy, int max_capacity)
	void pj_caching_pool_destroy(pj_caching_pool *ch_pool)
	void pj_pool_alloc(pj_pool_t pool, int size)
	pj_str_t pj_strdup2_with_null(pj_pool_t pool, pj_str_t dst, char src)

	# threads
	enum:
	PJ_THREAD_DESC_SIZE
	struct pj_mutex_t
	struct pj_thread_t
	int pj_mutex_create_simple(pj_pool_t pool, char name, pj_mutex_t **mutex)
	int pj_mutex_lock(pj_mutex_t *mutex)
	int pj_mutex_unlock(pj_mutex_t *mutex)
	int pj_mutex_destroy(pj_mutex_t *mutex)
	int pj_thread_is_registered()
	int pj_thread_register(char thread_name, long thread_desc, pj_thread_t **thread)

	# sockets
	enum:
	PJ_INET6_ADDRSTRLEN
	struct pj_ioqueue_t
	struct pj_addr_hdr:
	unsigned int sa_family
	struct pj_sockaddr:
	pj_addr_hdr addr
	struct pj_sockaddr_in:
	pass
	int pj_AF_INET()
	int pj_AF_INET6()
	int pj_sockaddr_in_init(pj_sockaddr_in addr, pj_str_t cp, int port)
	int pj_sockaddr_get_port(pj_sockaddr *addr)
	char pj_sockaddr_print(pj_sockaddr addr, char *buf, int size, unsigned int flags)
	int pj_sockaddr_has_addr(pj_sockaddr *addr)
	int pj_sockaddr_init(int af, pj_sockaddr addr, pj_str_t cp, unsigned int port)
	int pj_inet_pton(int af, pj_str_t src, void dst)

	# dns
	struct pj_dns_resolver

	# time
	struct pj_time_val:
	long sec
	long msec
	void pj_gettimeofday(pj_time_val *tv)

	# timers
	struct pj_timer_heap_t
	struct pj_timer_entry:
	void *user_data
	int id
	pj_timer_entry pj_timer_entry_init(pj_timer_entry entry, int id, void *user_data,
	void cb(pj_timer_heap_t timer_heap, pj_timer_entry entry) with gil)

	# lists
	struct pj_list:
	void *prev
	void *next
	void pj_list_insert_after(pj_list pos, pj_list node)

	# random
	void pj_srand(unsigned int seed)

	# maths
	struct pj_math_stat:
	int n
	int max
	int min
	int last
	int mean

	cdef extern from "pjlib-util.h":

	# init
	int pjlib_util_init()

	cdef extern from "pjnath.h":

	# init
	int pjnath_init()

	# STUN
	enum:
	PJ_STUN_PORT
	struct pj_stun_config:
	pass
	struct pj_stun_sock_cfg:
	pj_sockaddr bound_addr
	void pj_stun_config_init(pj_stun_config cfg, pj_pool_factory factory, unsigned int options,
	pj_ioqueue_t ioqueue, pj_timer_heap_t timer_heap)

	# NAT detection
	struct pj_stun_nat_detect_result:
	int status
	char *status_text
	char *nat_type_name
	ctypedef pj_stun_nat_detect_result pj_stun_nat_detect_result_ptr_const "const pj_stun_nat_detect_result "
	int pj_stun_detect_nat_type(pj_sockaddr_in server, pj_stun_config stun_cfg, void *user_data,
	void pj_stun_nat_detect_cb(void *user_data,
	pj_stun_nat_detect_result_ptr_const res) with gil)

	# ICE
	struct pj_ice_strans_cfg_stun:
	pj_stun_sock_cfg cfg
	pj_str_t server
	unsigned int port
	struct pj_ice_strans_cfg:
	int af
	pj_stun_config stun_cfg
	pj_ice_strans_cfg_stun stun
	enum pj_ice_strans_op:
	PJ_ICE_STRANS_OP_INIT
	PJ_ICE_STRANS_OP_NEGOTIATION
	void pj_ice_strans_cfg_default(pj_ice_strans_cfg *cfg)

	cdef extern from "pjmedia.h":

	# codec manager
	struct pjmedia_codec_mgr
	enum:
	PJMEDIA_CODEC_MGR_MAX_CODECS
	struct pjmedia_codec_info:
	pj_str_t encoding_name
	unsigned int clock_rate
	int pjmedia_codec_mgr_enum_codecs(pjmedia_codec_mgr mgr, unsigned int count,
	pjmedia_codec_info info, unsigned int prio)
	int pjmedia_codec_mgr_set_codec_priority(pjmedia_codec_mgr mgr, pj_str_t codec_id, unsigned int prio)

	# endpoint
	struct pjmedia_endpt
	int pjmedia_endpt_create(pj_pool_factory pf, pj_ioqueue_t ioqueue, int worker_cnt, pjmedia_endpt **p_endpt)
	int pjmedia_endpt_destroy(pjmedia_endpt *endpt)
	pj_ioqueue_t pjmedia_endpt_get_ioqueue(pjmedia_endpt endpt)
	pjmedia_codec_mgr pjmedia_endpt_get_codec_mgr(pjmedia_endpt endpt)

	# codecs
	int pjmedia_codec_g711_init(pjmedia_endpt *endpt)
	int pjmedia_codec_g711_deinit()

	# sound devices
	struct pjmedia_snd_dev_info:
	char *name
	int input_count
	int output_count
	struct pjmedia_snd_stream_info:
	int play_id
	int rec_id
	struct pjmedia_snd_stream
	ctypedef pjmedia_snd_dev_info pjmedia_snd_dev_info_ptr_const "const pjmedia_snd_dev_info "
	int pjmedia_snd_get_dev_count()
	pjmedia_snd_dev_info_ptr_const pjmedia_snd_get_dev_info(int index)
	int pjmedia_snd_stream_get_info(pjmedia_snd_stream strm, pjmedia_snd_stream_info pi)

	# sound port
	struct pjmedia_port
	struct pjmedia_snd_port
	int pjmedia_snd_port_create(pj_pool_t *pool, int rec_id, int play_id, int clock_rate, int channel_count,
	int samples_per_frame, int bits_per_sample, int options, pjmedia_snd_port **p_port)
	int pjmedia_snd_port_connect(pjmedia_snd_port snd_port, pjmedia_port port)
	int pjmedia_snd_port_disconnect(pjmedia_snd_port *snd_port)
	int pjmedia_snd_port_set_ec(pjmedia_snd_port snd_port, pj_pool_t pool, unsigned int tail_ms, int options)
	int pjmedia_snd_port_destroy(pjmedia_snd_port *snd_port)
	pjmedia_snd_stream pjmedia_snd_port_get_snd_stream(pjmedia_snd_port snd_port)
	int pjmedia_null_port_create(pj_pool_t *pool, unsigned int sampling_rate, unsigned int channel_count,
	unsigned int samples_per_frame, unsigned int bits_per_sample, pjmedia_port **p_port)

	# master port
	struct pjmedia_master_port
	int pjmedia_master_port_create(pj_pool_t pool, pjmedia_port u_port, pjmedia_port *d_port,
	unsigned int options, pjmedia_master_port **p_m)
	int pjmedia_master_port_start(pjmedia_master_port *m)
	int pjmedia_master_port_destroy(pjmedia_master_port *m, int destroy_ports)

	# conference bridge
	enum pjmedia_conf_option:
	PJMEDIA_CONF_NO_DEVICE
	struct pjmedia_conf
	int pjmedia_conf_create(pj_pool_t *pool, int max_slots, int sampling_rate, int channel_count,
	int samples_per_frame, int bits_per_sample, int options, pjmedia_conf **p_conf)
	int pjmedia_conf_destroy(pjmedia_conf *conf)
	pjmedia_port pjmedia_conf_get_master_port(pjmedia_conf conf)
	int pjmedia_conf_add_port(pjmedia_conf conf, pj_pool_t pool, pjmedia_port *strm_port,
	pj_str_t name, unsigned int p_slot)
	int pjmedia_conf_remove_port(pjmedia_conf *conf, unsigned int slot)
	int pjmedia_conf_connect_port(pjmedia_conf *conf, unsigned int src_slot, unsigned int sink_slot, int level)
	int pjmedia_conf_disconnect_port(pjmedia_conf *conf, unsigned int src_slot, unsigned int sink_slot)
	int pjmedia_conf_adjust_rx_level(pjmedia_conf *conf, unsigned slot, int adj_level)

	# sdp
	enum:
	PJMEDIA_MAX_SDP_FMT
	enum:
	PJMEDIA_MAX_SDP_ATTR
	enum:
	PJMEDIA_MAX_SDP_MEDIA
	struct pjmedia_sdp_attr:
	pj_str_t name
	pj_str_t value
	struct pjmedia_sdp_conn:
	pj_str_t net_type
	pj_str_t addr_type
	pj_str_t addr
	struct pjmedia_sdp_media_desc:
	pj_str_t media
	unsigned int port
	unsigned int port_count
	pj_str_t transport
	unsigned int fmt_count
	pj_str_t fmt[PJMEDIA_MAX_SDP_FMT]
	struct pjmedia_sdp_media:
	pjmedia_sdp_media_desc desc
	pj_str_t info
	pjmedia_sdp_conn *conn
	unsigned int attr_count
	pjmedia_sdp_attr *attr[PJMEDIA_MAX_SDP_ATTR]
	struct pjmedia_sdp_session_origin:
	pj_str_t user
	unsigned int id
	unsigned int version
	pj_str_t net_type
	pj_str_t addr_type
	pj_str_t addr
	struct pjmedia_sdp_session_time:
	unsigned int start
	unsigned int stop
	struct pjmedia_sdp_session:
	pjmedia_sdp_session_origin origin
	pj_str_t name
	pj_str_t info
	pjmedia_sdp_conn *conn
	pjmedia_sdp_session_time time
	unsigned int attr_count
	pjmedia_sdp_attr *attr[PJMEDIA_MAX_SDP_ATTR]
	unsigned int media_count
	pjmedia_sdp_media *media[PJMEDIA_MAX_SDP_MEDIA]
	ctypedef pjmedia_sdp_session pjmedia_sdp_session_ptr_const "const pjmedia_sdp_session "
	pjmedia_sdp_media pjmedia_sdp_media_clone(pj_pool_t pool, pjmedia_sdp_media *rhs)

	# sdp negotiation

	enum pjmedia_sdp_neg_state:
	PJMEDIA_SDP_NEG_STATE_NULL
	PJMEDIA_SDP_NEG_STATE_LOCAL_OFFER
	PJMEDIA_SDP_NEG_STATE_REMOTE_OFFER
	PJMEDIA_SDP_NEG_STATE_WAIT_NEGO
	PJMEDIA_SDP_NEG_STATE_DONE
	struct pjmedia_sdp_neg
	int pjmedia_sdp_neg_get_neg_remote(pjmedia_sdp_neg neg, pjmedia_sdp_session_ptr_const remote)
	int pjmedia_sdp_neg_get_neg_local(pjmedia_sdp_neg neg, pjmedia_sdp_session_ptr_const local)
	int pjmedia_sdp_neg_get_active_remote(pjmedia_sdp_neg neg, pjmedia_sdp_session_ptr_const remote)
	int pjmedia_sdp_neg_get_active_local(pjmedia_sdp_neg neg, pjmedia_sdp_session_ptr_const local)
	pjmedia_sdp_neg_state pjmedia_sdp_neg_get_state(pjmedia_sdp_neg *neg)
	char *pjmedia_sdp_neg_state_str(pjmedia_sdp_neg_state state)

	# transport
	enum pjmedia_transport_type:
	PJMEDIA_TRANSPORT_TYPE_ICE
	struct pjmedia_sock_info:
	pj_sockaddr rtp_addr_name
	struct pjmedia_transport:
	char *name
	pjmedia_transport_type type
	enum pjmedia_transport_type:
	PJMEDIA_TRANSPORT_TYPE_SRTP
	struct pjmedia_transport_specific_info:
	pjmedia_transport_type type
	char *buffer
	struct pjmedia_transport_info:
	pjmedia_sock_info sock_info
	pj_sockaddr src_rtp_name
	int specific_info_cnt
	pjmedia_transport_specific_info *spc_info
	struct pjmedia_srtp_info:
	int active
	void pjmedia_transport_info_init(pjmedia_transport_info *info)
	int pjmedia_transport_udp_create3(pjmedia_endpt endpt, int af, char name, pj_str_t *addr, int port,
	unsigned int options, pjmedia_transport **p_tp)
	int pjmedia_transport_get_info(pjmedia_transport tp, pjmedia_transport_info info)
	int pjmedia_transport_close(pjmedia_transport *tp)
	int pjmedia_transport_media_create(pjmedia_transport tp, pj_pool_t sdp_pool, unsigned int options,
	pjmedia_sdp_session *rem_sdp, unsigned int media_index)
	int pjmedia_transport_encode_sdp(pjmedia_transport tp, pj_pool_t sdp_pool, pjmedia_sdp_session *sdp,
	pjmedia_sdp_session *rem_sdp, unsigned int media_index)
	int pjmedia_transport_media_start(pjmedia_transport tp, pj_pool_t tmp_pool, pjmedia_sdp_session *sdp_local,
	pjmedia_sdp_session *sdp_remote, unsigned int media_index)
	int pjmedia_transport_media_stop(pjmedia_transport *tp)
	int pjmedia_endpt_create_sdp(pjmedia_endpt endpt, pj_pool_t pool, unsigned int stream_cnt,
	pjmedia_sock_info sock_info, pjmedia_sdp_session *p_sdp)

	# SRTP
	enum pjmedia_srtp_use:
	PJMEDIA_SRTP_MANDATORY
	struct pjmedia_srtp_setting:
	pjmedia_srtp_use use
	void pjmedia_srtp_setting_default(pjmedia_srtp_setting *opt)
	int pjmedia_transport_srtp_create(pjmedia_endpt endpt, pjmedia_transport tp,
	pjmedia_srtp_setting opt, pjmedia_transport *p_tp)

	# ICE
	struct pjmedia_ice_cb:
	void on_ice_complete(pjmedia_transport *tp, pj_ice_strans_op op, int status) with gil
	int pjmedia_ice_create2(pjmedia_endpt endpt, char name, unsigned int comp_cnt, pj_ice_strans_cfg *cfg,
	pjmedia_ice_cb cb, unsigned int options, pjmedia_transport *p_tp)

	# stream
	enum pjmedia_dir:
	PJMEDIA_DIR_ENCODING
	PJMEDIA_DIR_DECODING
	struct pjmedia_codec_param_setting:
	unsigned int vad
	struct pjmedia_codec_param:
	pjmedia_codec_param_setting setting
	struct pjmedia_stream_info:
	pjmedia_codec_info fmt
	pjmedia_codec_param *param
	struct pjmedia_rtcp_stream_stat_loss_type:
	unsigned int burst
	unsigned int random
	struct pjmedia_rtcp_stream_stat:
	unsigned int pkt
	unsigned int bytes
	unsigned int discard
	unsigned int loss
	unsigned int reorder
	unsigned int dup
	pj_math_stat loss_period
	pjmedia_rtcp_stream_stat_loss_type loss_type
	pj_math_stat jitter
	struct pjmedia_rtcp_stat:
	pjmedia_rtcp_stream_stat tx
	pjmedia_rtcp_stream_stat rx
	pj_math_stat rtt
	struct pjmedia_stream
	int pjmedia_stream_info_from_sdp(pjmedia_stream_info si, pj_pool_t pool, pjmedia_endpt *endpt,
	pjmedia_sdp_session local, pjmedia_sdp_session remote, unsigned int stream_idx)
	int pjmedia_stream_create(pjmedia_endpt endpt, pj_pool_t pool, pjmedia_stream_info *info,
	pjmedia_transport tp, void user_data, pjmedia_stream **p_stream)
	int pjmedia_stream_destroy(pjmedia_stream *stream)
	int pjmedia_stream_get_port(pjmedia_stream stream, pjmedia_port *p_port)
	int pjmedia_stream_start(pjmedia_stream *stream)
	int pjmedia_stream_dial_dtmf(pjmedia_stream stream, pj_str_t ascii_digit)
	int pjmedia_stream_set_dtmf_callback(pjmedia_stream *stream,
	void cb(pjmedia_stream stream, void user_data, int digit) with gil,
	void *user_data)
	int pjmedia_stream_pause(pjmedia_stream *stream, pjmedia_dir dir)
	int pjmedia_stream_resume(pjmedia_stream *stream, pjmedia_dir dir)
	int pjmedia_stream_get_stat(pjmedia_stream stream, pjmedia_rtcp_stat stat)

	# wav player
	enum:
	PJMEDIA_FILE_NO_LOOP
	int pjmedia_port_destroy(pjmedia_port *port)
	int pjmedia_wav_player_port_create(pj_pool_t pool, char filename, unsigned int ptime, unsigned int flags,
	unsigned int buff_size, pjmedia_port **p_port)
	int pjmedia_wav_player_set_eof_cb(pjmedia_port port, void user_data,
	int cb(pjmedia_port port, void usr_data) with gil)
	int pjmedia_wav_player_port_set_pos(pjmedia_port *port, unsigned int offset)

	# wav recorder
	enum pjmedia_file_writer_option:
	PJMEDIA_FILE_WRITE_PCM
	int pjmedia_wav_writer_port_create(pj_pool_t pool, char filename, unsigned int clock_rate,
	unsigned int channel_count, unsigned int samples_per_frame,
	unsigned int bits_per_sample, unsigned int flags, int buff_size,
	pjmedia_port **p_port)

	# tone generator
	enum:
	PJMEDIA_TONEGEN_MAX_DIGITS
	struct pjmedia_tone_desc:
	short freq1
	short freq2
	short on_msec
	short off_msec
	short volume
	short flags
	struct pjmedia_tone_digit:
	char digit
	short on_msec
	short off_msec
	short volume
	int pjmedia_tonegen_create(pj_pool_t *pool, unsigned int clock_rate, unsigned int channel_count,
	unsigned int samples_per_frame, unsigned int bits_per_sample,
	unsigned int options, pjmedia_port **p_port)
	int pjmedia_tonegen_play(pjmedia_port tonegen, unsigned int count, pjmedia_tone_desc tones, unsigned int options)
	int pjmedia_tonegen_play_digits(pjmedia_port *tonegen, unsigned int count,
	pjmedia_tone_digit *digits, unsigned int options)
	int pjmedia_tonegen_stop(pjmedia_port *tonegen)

	cdef extern from "pjmedia-codec.h":

	# codecs
	enum:
	PJMEDIA_SPEEX_NO_UWB
	PJMEDIA_SPEEX_NO_WB
	int pjmedia_codec_gsm_init(pjmedia_endpt *endpt)
	int pjmedia_codec_gsm_deinit()
	int pjmedia_codec_g722_init(pjmedia_endpt *endpt)
	int pjmedia_codec_g722_deinit()
	int pjmedia_codec_ilbc_init(pjmedia_endpt *endpt, int mode)
	int pjmedia_codec_ilbc_deinit()
	int pjmedia_codec_speex_init(pjmedia_endpt *endpt, int options, int quality, int complexity)
	int pjmedia_codec_speex_deinit()

	cdef extern from "pjsip.h":

	# messages
	enum pjsip_status_code:
	PJSIP_SC_TSX_TIMEOUT
	PJSIP_SC_TSX_TRANSPORT_ERROR
	struct pjsip_transport
	enum pjsip_uri_context_e:
	PJSIP_URI_IN_CONTACT_HDR
	struct pjsip_param:
	pj_str_t name
	pj_str_t value
	struct pjsip_uri
	struct pjsip_sip_uri:
	pj_str_t user
	pj_str_t passwd
	pj_str_t host
	int port
	pj_str_t user_param
	pj_str_t method_param
	pj_str_t transport_param
	int ttl_param
	int lr_param
	pj_str_t maddr_param
	pjsip_param other_param
	pjsip_param header_param
	struct pjsip_name_addr:
	pj_str_t display
	pjsip_uri *uri
	struct pjsip_media_type:
	pj_str_t type
	pj_str_t subtype
	pj_str_t param
	enum pjsip_method_e:
	PJSIP_CANCEL_METHOD
	PJSIP_OTHER_METHOD
	struct pjsip_method:
	pjsip_method_e id
	pj_str_t name
	struct pjsip_host_port:
	pj_str_t host
	int port
	enum pjsip_hdr_e:
	PJSIP_H_VIA
	PJSIP_H_CALL_ID
	PJSIP_H_CSEQ
	PJSIP_H_EXPIRES
	struct pjsip_hdr:
	pjsip_hdr_e type
	pj_str_t name
	ctypedef pjsip_hdr pjsip_hdr_ptr_const "const pjsip_hdr"
	struct pjsip_generic_array_hdr:
	unsigned int count
	pj_str_t *values
	struct pjsip_generic_string_hdr:
	pj_str_t hvalue
	struct pjsip_cid_hdr:
	pj_str_t id
	struct pjsip_contact_hdr:
	int star
	pjsip_uri *uri
	int q1000
	int expires
	pjsip_param other_param
	struct pjsip_clen_hdr:
	int len
	struct pjsip_ctype_hdr:
	pjsip_media_type media
	struct pjsip_cseq_hdr:
	int cseq
	pjsip_method method
	struct pjsip_generic_int_hdr:
	int ivalue
	struct pjsip_fromto_hdr:
	pjsip_uri *uri
	pj_str_t tag
	pjsip_param other_param
	struct pjsip_routing_hdr:
	pjsip_name_addr name_addr
	pjsip_param other_param
	ctypedef pjsip_routing_hdr pjsip_route_hdr
	struct pjsip_retry_after_hdr:
	int ivalue
	pjsip_param param
	pj_str_t comment
	struct pjsip_via_hdr:
	pj_str_t transport
	pjsip_host_port sent_by
	int ttl_param
	int rport_param
	pj_str_t maddr_param
	pj_str_t recvd_param
	pj_str_t branch_param
	pjsip_param other_param
	pj_str_t comment
	enum:
	PJSIP_MAX_ACCEPT_COUNT
	struct pjsip_msg_body:
	pjsip_media_type content_type
	void *data
	unsigned int len
	struct pjsip_request_line:
	pjsip_method method
	pjsip_uri *uri
	struct pjsip_status_line:
	int code
	pj_str_t reason
	union pjsip_msg_line:
	pjsip_request_line req
	pjsip_status_line status
	enum pjsip_msg_type_e:
	PJSIP_REQUEST_MSG
	PJSIP_RESPONSE_MSG
	struct pjsip_msg:
	pjsip_msg_type_e type
	pjsip_msg_line line
	pjsip_hdr hdr
	pjsip_msg_body *body
	struct pjsip_buffer:
	char *start
	char *cur
	struct pjsip_tx_data_tp_info:
	char *dst_name
	int dst_port
	pjsip_transport *transport
	struct pjsip_tx_data:
	pjsip_msg *msg
	pj_pool_t *pool
	pjsip_buffer buf
	pjsip_tx_data_tp_info tp_info
	struct pjsip_rx_data_tp_info:
	pj_pool_t *pool
	pjsip_transport *transport
	struct pjsip_rx_data_pkt_info:
	pj_time_val timestamp
	char *packet
	int len
	char *src_name
	int src_port
	struct pjsip_rx_data_msg_info:
	pjsip_msg *msg
	pjsip_name_addr *from_hdr "from"
	pjsip_fromto_hdr *to_hdr "to"
	pjsip_via_hdr *via
	struct pjsip_rx_data:
	pjsip_rx_data_pkt_info pkt_info
	pjsip_rx_data_tp_info tp_info
	pjsip_rx_data_msg_info msg_info
	void pjsip_hdr_clone(pj_pool_t pool, void *hdr)
	void pjsip_msg_add_hdr(pjsip_msg msg, pjsip_hdr hdr)
	void pjsip_msg_find_hdr(pjsip_msg msg, pjsip_hdr_e type, void *start)
	void pjsip_msg_find_hdr_by_name(pjsip_msg msg, pj_str_t name, void start)
	pjsip_generic_string_hdr pjsip_generic_string_hdr_create(pj_pool_t pool, pj_str_t hname, pj_str_t hvalue)
	pjsip_contact_hdr pjsip_contact_hdr_create(pj_pool_t pool)
	pjsip_msg_body pjsip_msg_body_create(pj_pool_t pool, pj_str_t type, pj_str_t subtype, pj_str_t *text)
	pjsip_route_hdr pjsip_route_hdr_init(pj_pool_t pool, void *mem)
	void pjsip_sip_uri_init(pjsip_sip_uri *url, int secure)
	int pjsip_tx_data_dec_ref(pjsip_tx_data *tdata)
	void pjsip_tx_data_add_ref(pjsip_tx_data *tdata)
	pj_str_t pjsip_uri_get_scheme(pjsip_uri uri)
	void pjsip_uri_get_uri(pjsip_uri uri)
	int pjsip_uri_print(pjsip_uri_context_e context, void uri, char buf, unsigned int size)
	int PJSIP_URI_SCHEME_IS_SIP(pjsip_sip_uri *uri)
	enum:
	PJSIP_PARSE_URI_AS_NAMEADDR
	pjsip_uri pjsip_parse_uri(pj_pool_t pool, char *buf, unsigned int size, unsigned int options)
	void pjsip_method_init_np(pjsip_method m, pj_str_t str)
	pj_str_t *pjsip_get_status_text(int status_code)

	# module
	enum pjsip_module_priority:
	PJSIP_MOD_PRIORITY_APPLICATION
	PJSIP_MOD_PRIORITY_DIALOG_USAGE
	PJSIP_MOD_PRIORITY_TRANSPORT_LAYER
	struct pjsip_event
	struct pjsip_transaction
	struct pjsip_module:
	pj_str_t name
	int id
	int priority
	int on_rx_request(pjsip_rx_data *rdata) with gil
	int on_rx_response(pjsip_rx_data *rdata) with gil
	int on_tx_request(pjsip_tx_data *tdata) with gil
	int on_tx_response(pjsip_tx_data *tdata) with gil
	void on_tsx_state(pjsip_transaction tsx, pjsip_event event) with gil

	# endpoint
	struct pjsip_endpoint
	int pjsip_endpt_create(pj_pool_factory pf, char name, pjsip_endpoint **endpt)
	void pjsip_endpt_destroy(pjsip_endpoint *endpt)
	pj_pool_t pjsip_endpt_create_pool(pjsip_endpoint endpt, char *pool_name, int initial, int increment)
	void pjsip_endpt_release_pool(pjsip_endpoint endpt, pj_pool_t pool)
	int pjsip_endpt_handle_events(pjsip_endpoint endpt, pj_time_val max_timeout) nogil
	int pjsip_endpt_register_module(pjsip_endpoint endpt, pjsip_module module)
	int pjsip_endpt_schedule_timer(pjsip_endpoint endpt, pj_timer_entry entry, pj_time_val *delay)
	void pjsip_endpt_cancel_timer(pjsip_endpoint endpt, pj_timer_entry entry)
	enum:
	PJSIP_H_ACCEPT
	PJSIP_H_ALLOW
	PJSIP_H_SUPPORTED
	pjsip_hdr_ptr_const pjsip_endpt_get_capability(pjsip_endpoint endpt, int htype, pj_str_t hname)
	int pjsip_endpt_add_capability(pjsip_endpoint endpt, pjsip_module mod, int htype,
	pj_str_t hname, unsigned count, pj_str_t tags)
	int pjsip_endpt_create_response(pjsip_endpoint endpt, pjsip_rx_data rdata,
	int st_code, pj_str_t st_text, pjsip_tx_data *p_tdata)
	int pjsip_endpt_send_response2(pjsip_endpoint endpt, pjsip_rx_data rdata,
	pjsip_tx_data tdata, void token, void *cb)
	int pjsip_endpt_create_request(pjsip_endpoint endpt, pjsip_method method, pj_str_t target, pj_str_t frm,
	pj_str_t to, pj_str_t contact, pj_str_t *call_id,
	int cseq,pj_str_t text, pjsip_tx_data *p_tdata)
	pj_timer_heap_t pjsip_endpt_get_timer_heap(pjsip_endpoint endpt)
	int pjsip_endpt_create_resolver(pjsip_endpoint endpt, pj_dns_resolver *p_resv)
	int pjsip_endpt_set_resolver(pjsip_endpoint endpt, pj_dns_resolver resv)

	# transports
	enum pjsip_ssl_method:
	PJSIP_SSL_UNSPECIFIED_METHOD
	PJSIP_TLSV1_METHOD
	PJSIP_SSLV2_METHOD
	PJSIP_SSLV3_METHOD
	PJSIP_SSLV23_METHOD
	struct pjsip_transport:
	char *type_name
	pjsip_host_port local_name
	struct pjsip_tpfactory:
	pjsip_host_port addr_name
	int destroy(pjsip_tpfactory *factory)
	struct pjsip_tls_setting:
	pj_str_t ca_list_file
	pj_str_t cert_file
	pj_str_t privkey_file
	int method
	int verify_server
	pj_time_val timeout
	enum pjsip_tpselector_type:
	PJSIP_TPSELECTOR_TRANSPORT
	union pjsip_tpselector_u:
	pjsip_transport *transport
	struct pjsip_tpselector:
	pjsip_tpselector_type type
	pjsip_tpselector_u u
	int pjsip_transport_shutdown(pjsip_transport *tp)
	int pjsip_udp_transport_start(pjsip_endpoint endpt, pj_sockaddr_in local, pjsip_host_port *a_name,
	unsigned int async_cnt, pjsip_transport **p_transport)
	int pjsip_tcp_transport_start2(pjsip_endpoint endpt, pj_sockaddr_in local, pjsip_host_port *a_name,
	unsigned int async_cnt, pjsip_tpfactory **p_tpfactory)
	int pjsip_tls_transport_start(pjsip_endpoint endpt, pjsip_tls_setting opt, pj_sockaddr_in *local,
	pjsip_host_port a_name, unsigned async_cnt, pjsip_tpfactory *p_factory)
	void pjsip_tls_setting_default(pjsip_tls_setting *tls_opt)
	int pjsip_transport_shutdown(pjsip_transport *tp)

	# transaction layer
	enum pjsip_role_e:
	PJSIP_ROLE_UAC
	PJSIP_ROLE_UAS
	enum pjsip_tsx_state_e:
	PJSIP_TSX_STATE_PROCEEDING
	PJSIP_TSX_STATE_COMPLETED
	PJSIP_TSX_STATE_TERMINATED
	struct pjsip_transaction:
	int status_code
	pj_str_t status_text
	pjsip_role_e role
	pjsip_tx_data *last_tx
	pjsip_tsx_state_e state
	void **mod_data
	pjsip_method method
	int pjsip_tsx_layer_init_module(pjsip_endpoint *endpt)
	int pjsip_tsx_create_key(pj_pool_t pool, pj_str_t key, pjsip_role_e role,
	pjsip_method method, pjsip_rx_data rdata)
	pjsip_transaction pjsip_tsx_layer_find_tsx(pj_str_t key, int lock)
	int pjsip_tsx_create_uac(pjsip_module tsx_user, pjsip_tx_data tdata, pjsip_transaction **p_tsx)
	int pjsip_tsx_terminate(pjsip_transaction *tsx, int code)
	int pjsip_tsx_send_msg(pjsip_transaction tsx, pjsip_tx_data tdata)

	# event
	enum pjsip_event_id_e:
	PJSIP_EVENT_TSX_STATE
	PJSIP_EVENT_RX_MSG
	PJSIP_EVENT_TX_MSG
	PJSIP_EVENT_TRANSPORT_ERROR
	PJSIP_EVENT_TIMER
	union pjsip_event_body_tsx_state_src:
	pjsip_rx_data *rdata
	pjsip_tx_data *tdata
	struct pjsip_event_body_tsx_state:
	pjsip_event_body_tsx_state_src src
	pjsip_transaction *tsx
	pjsip_event_id_e type
	struct pjsip_event_body_rx_msg:
	pjsip_rx_data *rdata
	union pjsip_event_body:
	pjsip_event_body_tsx_state tsx_state
	pjsip_event_body_rx_msg rx_msg
	struct pjsip_event:
	pjsip_event_id_e type
	pjsip_event_body body
	int pjsip_endpt_send_request(pjsip_endpoint endpt, pjsip_tx_data tdata, int timeout,
	void token, void cb(void token, pjsip_event *e) with gil)

	# auth
	enum:
	PJSIP_EFAILEDCREDENTIAL
	enum pjsip_cred_data_type:
	PJSIP_CRED_DATA_PLAIN_PASSWD
	struct pjsip_cred_info:
	pj_str_t realm
	pj_str_t scheme
	pj_str_t username
	pjsip_cred_data_type data_type
	pj_str_t data
	struct pjsip_auth_clt_sess:
	pass
	int pjsip_auth_clt_init(pjsip_auth_clt_sess sess, pjsip_endpoint endpt, pj_pool_t *pool, unsigned int options)
	int pjsip_auth_clt_set_credentials(pjsip_auth_clt_sess sess, int cred_cnt, pjsip_cred_info c)
	int pjsip_auth_clt_reinit_req(pjsip_auth_clt_sess sess, pjsip_rx_data rdata,
	pjsip_tx_data old_request, pjsip_tx_data *new_request)

	# dialog layer
	ctypedef pjsip_module pjsip_user_agent
	struct pjsip_dlg_party:
	pjsip_contact_hdr *contact
	struct pjsip_dialog:
	pjsip_auth_clt_sess auth_sess
	pjsip_cid_hdr *call_id
	pj_pool_t *pool
	pjsip_dlg_party local
	struct pjsip_ua_init_param:
	pjsip_dialog on_dlg_forked(pjsip_dialog first_set, pjsip_rx_data *res)
	int pjsip_ua_init_module(pjsip_endpoint endpt, pjsip_ua_init_param prm)
	pjsip_user_agent *pjsip_ua_instance()
	int pjsip_dlg_create_uac(pjsip_user_agent ua, pj_str_t local_uri, pj_str_t *local_contact_uri,
	pj_str_t remote_uri, pj_str_t target, pjsip_dialog **p_dlg)
	int pjsip_dlg_set_route_set(pjsip_dialog dlg, pjsip_route_hdr route_set)
	int pjsip_dlg_create_uas(pjsip_user_agent ua, pjsip_rx_data rdata, pj_str_t contact, pjsip_dialog *p_dlg)
	int pjsip_dlg_terminate(pjsip_dialog *dlg)
	int pjsip_dlg_set_transport(pjsip_dialog dlg, pjsip_tpselector sel)

	cdef extern from "pjsip_simple.h":

	# subscribe / notify
	enum:
	PJSIP_EVSUB_NO_EVENT_ID
	struct pjsip_evsub
	struct pjsip_evsub_user:
	void on_evsub_state(pjsip_evsub sub, pjsip_event event) with gil
	void on_tsx_state(pjsip_evsub sub, pjsip_transaction tsx, pjsip_event *event) with gil
	void on_rx_notify(pjsip_evsub sub, pjsip_rx_data rdata, int *p_st_code,
	pj_str_t *p_st_text,pjsip_hdr res_hdr, pjsip_msg_body **p_body) with gil
	void on_client_refresh(pjsip_evsub *sub) with gil
	int pjsip_evsub_init_module(pjsip_endpoint *endpt)
	int pjsip_evsub_register_pkg(pjsip_module pkg_mod, pj_str_t event_name,
	unsigned int expires, unsigned int accept_cnt, pj_str_t *accept)
	int pjsip_evsub_create_uac(pjsip_dialog dlg, pjsip_evsub_user user_cb,
	pj_str_t event, int option, pjsip_evsub *p_evsub)
	int pjsip_evsub_initiate(pjsip_evsub sub, void method, unsigned int expires, pjsip_tx_data **p_tdata)
	int pjsip_evsub_send_request(pjsip_evsub sub, pjsip_tx_data tdata)
	int pjsip_evsub_terminate(pjsip_evsub *sub, int notify)
	char pjsip_evsub_get_state_name(pjsip_evsub sub)
	void pjsip_evsub_set_mod_data(pjsip_evsub sub, int mod_id, void data)
	void pjsip_evsub_get_mod_data(pjsip_evsub sub, int mod_id)
	pjsip_hdr pjsip_evsub_get_allow_events_hdr(pjsip_module m)

	cdef extern from "pjsip_ua.h":

	# 100rel / PRACK
	int pjsip_100rel_init_module(pjsip_endpoint *endpt)

	# invite sessions
	enum pjsip_inv_option:
	PJSIP_INV_SUPPORT_100REL
	PJSIP_INV_IGNORE_MISSING_ACK
	enum pjsip_inv_state:
	PJSIP_INV_STATE_INCOMING
	PJSIP_INV_STATE_CONFIRMED
	struct pjsip_inv_session:
	pjsip_inv_state state
	void **mod_data
	pjmedia_sdp_neg *neg
	int cause
	pj_str_t cause_text
	int cancelling
	pjsip_transaction *invite_tsx
	struct pjsip_inv_callback:
	void on_state_changed(pjsip_inv_session inv, pjsip_event e) with gil
	void on_new_session(pjsip_inv_session inv, pjsip_event e) with gil
	void on_tsx_state_changed(pjsip_inv_session inv, pjsip_transaction tsx, pjsip_event *e) with gil
	void on_rx_offer(pjsip_inv_session inv, pjmedia_sdp_session offer) with gil
	#void on_create_offer(pjsip_inv_session inv, pjmedia_sdp_session *p_offer)
	void on_media_update(pjsip_inv_session *inv, int status) with gil
	#void on_send_ack(pjsip_inv_session inv, pjsip_rx_data rdata)
	void on_rx_reinvite(pjsip_inv_session inv, pjmedia_sdp_session_ptr_const offer, pjsip_rx_data rdata) with gil
	int pjsip_inv_usage_init(pjsip_endpoint endpt, pjsip_inv_callback cb)
	int pjsip_inv_terminate(pjsip_inv_session *inv, int st_code, int notify)
	int pjsip_inv_end_session(pjsip_inv_session inv, int st_code, pj_str_t st_text, pjsip_tx_data **p_tdata)
	int pjsip_inv_send_msg(pjsip_inv_session inv, pjsip_tx_data tdata)
	int pjsip_inv_verify_request(pjsip_rx_data rdata, unsigned int options, pjmedia_sdp_session *sdp,
	pjsip_dialog dlg, pjsip_endpoint endpt, pjsip_tx_data **tdata)
	int pjsip_inv_create_uas(pjsip_dialog dlg, pjsip_rx_data rdata, pjmedia_sdp_session *local_sdp,
	unsigned int options, pjsip_inv_session **p_inv)
	int pjsip_inv_initial_answer(pjsip_inv_session inv, pjsip_rx_data rdata, int st_code,
	pj_str_t st_text, pjmedia_sdp_session sdp, pjsip_tx_data **p_tdata)
	int pjsip_inv_answer(pjsip_inv_session inv, int st_code, pj_str_t st_text,
	pjmedia_sdp_session local_sdp, pjsip_tx_data *p_tdata)
	int pjsip_inv_create_uac(pjsip_dialog dlg, pjmedia_sdp_session local_sdp,
	unsigned int options, pjsip_inv_session **p_inv)
	int pjsip_inv_invite(pjsip_inv_session inv, pjsip_tx_data *p_tdata)
	char *pjsip_inv_state_name(pjsip_inv_state state)
	int pjsip_inv_reinvite(pjsip_inv_session inv, pj_str_t new_contact,
	pjmedia_sdp_session new_offer, pjsip_tx_data *p_tdata)

	# declarations

	# core.lib

	cdef class PJLIB
	cdef class PJCachingPool
	cdef class PJSIPEndpoint
	cdef class PJMEDIAEndpoint

	# core.sound

	cdef class PJMEDIAConferenceBridge
	cdef class RecordingWaveFile
	cdef class WaveFile
	cdef int cb_play_wav_eof(pjmedia_port port, void user_data) with gil
	cdef void cb_play_wav_restart(pj_timer_heap_t timer_heap, pj_timer_entry entry) with gil

	# core.util

	+cdef class frozendict
	cdef class PJSTR
	cdef int _str_to_pj_str(object string, pj_str_t *pj_str) except -1
	cdef object _pj_str_to_str(pj_str_t pj_str)
	cdef object _pj_status_to_str(int status)
	cdef object _pj_status_to_def(int status)
	cdef dict _pjsip_param_to_dict(pjsip_param *param_list)
	cdef int _rdata_info_to_dict(pjsip_rx_data *rdata, dict info_dict) except -1
	cdef int _is_valid_ip(int af, object ip) except -1
	cdef int _get_ip_version(object ip) except -1
	cdef int _add_headers_to_tdata(pjsip_tx_data *tdata, dict headers) except -1

	# core.helper

	cdef class Route
	cdef class Credentials
	cdef class SIPURI
	cdef SIPURI _make_SIPURI(pjsip_uri *base_uri, int is_named)
	cdef SIPURI _parse_SIPURI(object uri_str)

	# core.ua

	cdef class PJSIPThread
	cdef class PJSIPUA
	cdef int _PJSIPUA_cb_rx_request(pjsip_rx_data *rdata) with gil
	cdef void _cb_detect_nat_type(void *user_data, pj_stun_nat_detect_result_ptr_const res) with gil
	cdef int _cb_trace_rx(pjsip_rx_data *rdata) with gil
	cdef int _cb_trace_tx(pjsip_tx_data *tdata) with gil
	cdef int _cb_add_user_agent_hdr(pjsip_tx_data *tdata) with gil
	cdef int _cb_add_server_hdr(pjsip_tx_data *tdata) with gil
	cdef PJSIPUA _get_ua()

	# core.event

	cdef struct _core_event
	cdef struct _post_handler
	cdef int _event_queue_append(_core_event *event)
	cdef void _cb_log(int level, char_ptr_const data, int len)
	cdef int _add_event(object event_name, dict params) except -1
	cdef list _get_clear_event_queue()
	cdef int _add_post_handler(int func(object obj) except -1, object obj) except -1
	cdef int _handle_post_queue(PJSIPUA ua) except -1

	# core.request

	cdef class Request
	cdef void _Request_cb_tsx_state(pjsip_transaction tsx, pjsip_event event) with gil
	cdef void _Request_cb_timer(pj_timer_heap_t timer_heap, pj_timer_entry entry) with gil

	# core.subscription

	cdef class Subscription
	cdef void _Subscription_cb_state(pjsip_evsub sub, pjsip_event event) with gil
	cdef void _Subscription_cb_notify(pjsip_evsub sub, pjsip_rx_data rdata, int *p_st_code,
	pj_str_t *p_st_text, pjsip_hdr res_hdr, pjsip_msg_body **p_body) with gil
	cdef void _Subscription_cb_refresh(pjsip_evsub *sub) with gil

	# core.invitation

	cdef class Invitation
	cdef void _Invitation_cb_state(pjsip_inv_session inv, pjsip_event e) with gil
	cdef void _Invitation_cb_sdp_done(pjsip_inv_session *inv, int status) with gil
	cdef void _Invitation_cb_rx_reinvite(pjsip_inv_session *inv,
	pjmedia_sdp_session_ptr_const offer, pjsip_rx_data *rdata) with gil
	cdef void _Invitation_cb_tsx_state_changed(pjsip_inv_session inv, pjsip_transaction tsx, pjsip_event *e) with gil
	cdef void _Invitation_cb_new(pjsip_inv_session inv, pjsip_event e) with gil
	cdef int _Invitation_cb_fail_post(object obj) except -1
	cdef void _Request_cb_disconnect_timer(pj_timer_heap_t timer_heap, pj_timer_entry entry) with gil

	# core.sdp

	cdef class SDPSession
	cdef class SDPMedia
	cdef class SDPConnection
	cdef class SDPAttribute
	cdef SDPSession _make_SDPSession(pjmedia_sdp_session_ptr_const pj_session)
	cdef SDPMedia _make_SDPMedia(pjmedia_sdp_media *pj_media)
	cdef SDPConnection _make_SDPConnection(pjmedia_sdp_conn *pj_conn)
	cdef SDPAttribute _make_SDPAttribute(pjmedia_sdp_attr *pj_attr)

	# core.mediatransport

	cdef class RTPTransport
	cdef class AudioTransport
	cdef void _RTPTransport_cb_ice_complete(pjmedia_transport *tp, pj_ice_strans_op op, int status) with gil
	cdef void _AudioTransport_cb_dtmf(pjmedia_stream stream, void user_data, int digit) with gil
	cdef void _AudioTransport_cb_check_rtp(pj_timer_heap_t timer_heap, pj_timer_entry entry) with gil
	cdef dict _pj_math_stat_to_dict(pj_math_stat *stat)
	cdef dict _pjmedia_rtcp_stream_stat_to_dict(pjmedia_rtcp_stream_stat *stream_stat)
	diff --git a/sipsimple/core.util.pxi b/sipsimple/core.util.pxi
	index 5a00781a..41d1cfe9 100644
	--- a/sipsimple/core.util.pxi
	+++ b/sipsimple/core.util.pxi
	@@ -1,206 +1,269 @@
	# Copyright (C) 2008-2009 AG Projects. See LICENSE for details.
	#

	# python imports

	import re

	# classes

	cdef class PJSTR:
	cdef pj_str_t pj_str
	cdef object str

	def __cinit__(self, str):
	self.str = str
	_str_to_pj_str(str, &self.pj_str)

	def __str__(self):
	return self.str


	cdef class SIPStatusMessages:
	cdef object _default_status

	def __cinit__(self, args, *kwargs):
	self._default_status = _pj_str_to_str(pjsip_get_status_text(0)[0])

	def __getitem__(self, int val):
	cdef object _status
	_status = _pj_str_to_str(pjsip_get_status_text(val)[0])
	if _status == self._default_status:
	raise IndexError("Unknown SIP response code: %d" % val)
	return _status


	+cdef class frozendict:
	+ cdef int initialized
	+ cdef dict dict
	+ cdef long hash
	+ def __cinit__(self, args, *kw):
	+ self.dict = dict()
	+ self.initialized = 0
	+ def __init__(self, args, *kw):
	+ if not self.initialized:
	+ self.dict = dict(args, *kw)
	+ self.initialized = 1
	+ self.hash = hash(tuple(self.dict.iteritems()))
	+ def __repr__(self):
	+ return "frozendict(%r)" % self.dict
	+ def __len__(self):
	+ return self.dict.__len__()
	+ def __hash__(self):
	+ return self.hash
	+ def __iter__(self):
	+ return self.dict.__iter__()
	+ def __cmp__(self, frozendict other):
	+ return self.dict.__cmp__(other.dict)
	+ def __richcmp__(frozendict self, other, op):
	+ if isinstance(other, frozendict):
	+ other = (<frozendict>other).dict
	+ if op == 0:
	+ return self.dict.__cmp__(other) < 0
	+ elif op == 1:
	+ return self.dict.__cmp__(other) <= 0
	+ elif op == 2:
	+ return self.dict.__eq__(other)
	+ elif op == 3:
	+ return self.dict.__ne__(other)
	+ elif op == 4:
	+ return self.dict.__cmp__(other) > 0
	+ elif op == 5:
	+ return self.dict.__cmp__(other) >= 0
	+ else:
	+ return NotImplemented
	+ def __contains__(self, item):
	+ return self.dict.__contains__(item)
	+ def __getitem__(self, key):
	+ return self.dict.__getitem__(key)
	+ def copy(self):
	+ return self
	+ def get(self, *args):
	+ return self.dict.get(*args)
	+ def has_key(self, key):
	+ return self.dict.has_key(key)
	+ def items(self):
	+ return self.dict.items()
	+ def iteritems(self):
	+ return self.dict.iteritems()
	+ def iterkeys(self):
	+ return self.dict.iterkeys()
	+ def itervalues(self):
	+ return self.dict.itervalues()
	+ def keys(self):
	+ return self.dict.keys()
	+ def values(self):
	+ return self.dict.values()
	+
	+
	# functions

	cdef int _str_to_pj_str(object string, pj_str_t *pj_str) except -1:
	pj_str.ptr = PyString_AsString(string)
	pj_str.slen = len(string)

	cdef object _pj_str_to_str(pj_str_t pj_str):
	return PyString_FromStringAndSize(pj_str.ptr, pj_str.slen)

	cdef object _pj_status_to_str(int status):
	cdef char buf[PJ_ERR_MSG_SIZE]
	return _pj_str_to_str(pj_strerror(status, buf, PJ_ERR_MSG_SIZE))

	cdef object _pj_status_to_def(int status):
	return _re_pj_status_str_def.match(_pj_status_to_str(status)).group(1)

	cdef dict _pjsip_param_to_dict(pjsip_param *param_list):
	cdef pjsip_param *param
	cdef dict retval = {}
	param = <pjsip_param > (<pj_list > param_list).next
	while param != param_list:
	if param.value.slen == 0:
	retval[_pj_str_to_str(param.name)] = None
	else:
	retval[_pj_str_to_str(param.name)] = _pj_str_to_str(param.value)
	param = <pjsip_param > (<pj_list > param).next
	return retval

	cdef int _rdata_info_to_dict(pjsip_rx_data *rdata, dict info_dict) except -1:
	cdef pjsip_msg_body *body
	cdef pjsip_hdr *hdr
	cdef object hdr_name
	cdef int i
	cdef pjsip_generic_array_hdr *array_hdr
	cdef pjsip_generic_string_hdr *string_hdr
	cdef pjsip_contact_hdr *contact_hdr
	cdef pjsip_clen_hdr *clen_hdr
	cdef pjsip_ctype_hdr *ctype_hdr
	cdef pjsip_cseq_hdr *cseq_hdr
	cdef pjsip_generic_int_hdr *int_hdr
	cdef pjsip_fromto_hdr *fromto_hdr
	cdef pjsip_routing_hdr *routing_hdr
	cdef pjsip_retry_after_hdr *retry_after_hdr
	cdef pjsip_via_hdr *via_hdr
	cdef object hdr_data, hdr_multi
	cdef dict headers = {}
	info_dict["headers"] = headers
	hdr = <pjsip_hdr > (<pj_list > &rdata.msg_info.msg.hdr).next
	while hdr != &rdata.msg_info.msg.hdr:
	hdr_data = None
	hdr_multi = False
	hdr_name = _pj_str_to_str(hdr.name)
	if hdr_name in ["Accept", "Allow", "Require", "Supported", "Unsupported"]:
	array_hdr = <pjsip_generic_array_hdr *> hdr
	hdr_data = []
	for i from 0 <= i < array_hdr.count:
	hdr_data.append(_pj_str_to_str(array_hdr.values[i]))
	elif hdr_name == "Contact":
	hdr_multi = True
	contact_hdr = <pjsip_contact_hdr *> hdr
	hdr_data = (contact_hdr.star and None or _make_SIPURI(contact_hdr.uri, 1),
	_pjsip_param_to_dict(&contact_hdr.other_param))
	if contact_hdr.q1000 != 0:
	hdr_data[1]["q"] = contact_hdr.q1000 / 1000.0
	if contact_hdr.expires != -1:
	hdr_data[1]["expires"] = contact_hdr.expires
	elif hdr_name == "Content-Length":
	clen_hdr = <pjsip_clen_hdr *> hdr
	hdr_data = clen_hdr.len
	elif hdr_name == "Content-Type":
	ctype_hdr = <pjsip_ctype_hdr *> hdr
	hdr_data = ("%s/%s" % (_pj_str_to_str(ctype_hdr.media.type),
	_pj_str_to_str(ctype_hdr.media.subtype)),
	_pj_str_to_str(ctype_hdr.media.param))
	elif hdr_name == "CSeq":
	cseq_hdr = <pjsip_cseq_hdr *> hdr
	hdr_data = (cseq_hdr.cseq, _pj_str_to_str(cseq_hdr.method.name))
	elif hdr_name in ["Expires", "Max-Forwards", "Min-Expires"]:
	int_hdr = <pjsip_generic_int_hdr *> hdr
	hdr_data = int_hdr.ivalue
	elif hdr_name in ["From", "To"]:
	fromto_hdr = <pjsip_fromto_hdr *> hdr
	hdr_data = (_make_SIPURI(fromto_hdr.uri, 1), _pj_str_to_str(fromto_hdr.tag),
	_pjsip_param_to_dict(&fromto_hdr.other_param))
	elif hdr_name in ["Record-Route", "Route"]:
	hdr_multi = True
	routing_hdr = <pjsip_routing_hdr *> hdr
	hdr_data = (_make_SIPURI(<pjsip_uri *> &routing_hdr.name_addr, 1),
	_pjsip_param_to_dict(&routing_hdr.other_param))
	elif hdr_name == "Retry-After":
	retry_after_hdr = <pjsip_retry_after_hdr *> hdr
	hdr_data = (retry_after_hdr.ivalue, _pj_str_to_str(retry_after_hdr.comment),
	_pjsip_param_to_dict(&retry_after_hdr.param))
	elif hdr_name == "Via":
	hdr_multi = True
	via_hdr = <pjsip_via_hdr *> hdr
	hdr_data = (_pj_str_to_str(via_hdr.transport), _pj_str_to_str(via_hdr.sent_by.host), via_hdr.sent_by.port,
	_pj_str_to_str(via_hdr.comment), _pjsip_param_to_dict(&via_hdr.other_param))
	if via_hdr.ttl_param != -1:
	hdr_data[4]["ttl"] = via_hdr.ttl_param
	if via_hdr.rport_param != -1:
	hdr_data[4]["rport"] = via_hdr.rport_param
	if via_hdr.maddr_param.slen > 0:
	hdr_data[4]["maddr"] = _pj_str_to_str(via_hdr.maddr_param)
	if via_hdr.recvd_param.slen > 0:
	hdr_data[4]["recvd"] = _pj_str_to_str(via_hdr.recvd_param)
	if via_hdr.branch_param.slen > 0:
	hdr_data[4]["branch"] = _pj_str_to_str(via_hdr.branch_param)
	# skip the following headers:
	elif hdr_name not in ["Authorization", "Proxy-Authenticate", "Proxy-Authorization", "WWW-Authenticate"]:
	string_hdr = <pjsip_generic_string_hdr *> hdr
	hdr_data = _pj_str_to_str(string_hdr.hvalue)
	if hdr_name == "Warning":
	hdr_data = _re_warning_hdr.match(hdr_data)
	if hdr_data is not None:
	hdr_data = hdr_data.groups()
	hdr_data = (int(hdr_data[0]), hdr_data[1], hdr_data[2])
	if hdr_data is not None:
	if hdr_multi:
	headers.setdefault(hdr_name, []).append(hdr_data)
	else:
	if hdr_name not in headers:
	headers[hdr_name] = hdr_data
	hdr = <pjsip_hdr > (<pj_list > hdr).next
	body = rdata.msg_info.msg.body
	if body == NULL:
	info_dict["body"] = None
	else:
	info_dict["body"] = PyString_FromStringAndSize(<char *> body.data, body.len)
	if rdata.msg_info.msg.type == PJSIP_REQUEST_MSG:
	info_dict["method"] = _pj_str_to_str(rdata.msg_info.msg.line.req.method.name)
	info_dict["request_uri"] = _make_SIPURI(rdata.msg_info.msg.line.req.uri, 0)
	else:
	info_dict["code"] = rdata.msg_info.msg.line.status.code
	info_dict["reason"] = _pj_str_to_str(rdata.msg_info.msg.line.status.reason)
	return 0

	cdef int _is_valid_ip(int af, object ip) except -1:
	cdef char buf[16]
	cdef pj_str_t src
	cdef int status
	_str_to_pj_str(ip, &src)
	status = pj_inet_pton(af, &src, buf)
	if status == 0:
	return 1
	else:
	return 0

	cdef int _get_ip_version(object ip) except -1:
	if _is_valid_ip(pj_AF_INET(), ip):
	return pj_AF_INET()
	elif _is_valid_ip(pj_AF_INET6(), ip):
	return pj_AF_INET()
	else:
	return 0

	cdef int _add_headers_to_tdata(pjsip_tx_data *tdata, dict headers) except -1:
	cdef object name, value
	cdef pj_str_t name_pj, value_pj
	cdef pjsip_hdr *hdr
	for name, value in headers.iteritems():
	_str_to_pj_str(name, &name_pj)
	_str_to_pj_str(value, &value_pj)
	hdr = <pjsip_hdr *> pjsip_generic_string_hdr_create(tdata.pool, &name_pj, &value_pj)
	pjsip_msg_add_hdr(tdata.msg, hdr)

	# globals

	cdef object _re_pj_status_str_def = re.compile("^.$(.)$$")
	cdef object _re_warning_hdr = re.compile('([0-9]{3}) (.?) "(.?)"')
	sip_status_messages = SIPStatusMessages()

File Metadata

Mime Type: text/x-diff
Expires: Sat, Dec 28, 6:32 PM (1 d, 5 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3454336
Default Alt Text: (50 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions