chan_unistim channel driver for Asterisk More...

#include "asterisk.h"
#include <sys/stat.h>
#include <signal.h>
#include "asterisk/paths.h"
#include "asterisk/network.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/rtp_engine.h"
#include "asterisk/unaligned.h"
#include "asterisk/netsock2.h"
#include "asterisk/acl.h"
#include "asterisk/callerid.h"
#include "asterisk/cli.h"
#include "asterisk/app.h"
#include "asterisk/mwi.h"
#include "asterisk/musiconhold.h"
#include "asterisk/causes.h"
#include "asterisk/indications.h"
#include "asterisk/pickup.h"
#include "asterisk/astobj2.h"
#include "asterisk/astdb.h"
#include "asterisk/features_config.h"
#include "asterisk/bridge.h"
#include "asterisk/stasis_channels.h"
#include "asterisk/format_cache.h"

Include dependency graph for chan_unistim.c:

Go to the source code of this file.

Data Structures
struct	unistim_device
	A device containing one or more lines. More...

struct	unistim_languages

struct	unistim_line

struct	unistim_menu_item

struct	unistim_subchannel

struct	unistimsession

struct	ustm_lang_entry

struct	wsabuf

Macros
#define	AST_CONFIG_MAX_PATH 255

#define	BUFFSEND unsigned char buffsend[64] = { 0x00, 0x00, 0xaa, 0xbb, 0x02, 0x01 }

#define	DEBUG_TIMER dummy

#define	DEFAULT_CODEC 0x00

#define	DEFAULT_INTERDIGIT_TIMER 4000

#define	DEFAULTCALLERID "Unknown"

#define	DEFAULTCALLERNAME " "

#define	DEFAULTCONTEXT "default"

#define	DEFAULTHEIGHT 3

#define	DEVICE_NAME_LEN 16

#define	EXPNUM 24

#define	FAV_BLINK_FAST 0x20

#define	FAV_BLINK_SLOW 0x40

#define	FAV_ICON_BOX 0x3F

#define	FAV_ICON_CALL_CENTER 0x34

#define	FAV_ICON_CITY 0x31

#define	FAV_ICON_COMPUTER 0x38

#define	FAV_ICON_FAX 0x35

#define	FAV_ICON_FORWARD 0x39

#define	FAV_ICON_HEADPHONES 0x2E

#define	FAV_ICON_HEADPHONES_ONHOLD 0x2F

#define	FAV_ICON_HOME 0x30

#define	FAV_ICON_INBOX 0x3C

#define	FAV_ICON_LOCKED 0x3A

#define	FAV_ICON_MAILBOX 0x36

#define	FAV_ICON_MEETING 0x3E

#define	FAV_ICON_NONE 0x00

#define	FAV_ICON_OFFHOOK_BLACK 0x24

#define	FAV_ICON_OFFHOOK_WHITE 0x25

#define	FAV_ICON_ONHOLD_BLACK 0x26

#define	FAV_ICON_ONHOLD_WHITE 0x27

#define	FAV_ICON_ONHOOK_BLACK 0x20

#define	FAV_ICON_ONHOOK_WHITE 0x21

#define	FAV_ICON_OUTBOX 0x3D

#define	FAV_ICON_PAGER 0x33

#define	FAV_ICON_PHONE_BLACK 0x2A

#define	FAV_ICON_PHONE_WHITE 0x2B

#define	FAV_ICON_REFLECT 0x37

#define	FAV_ICON_SHARP 0x32

#define	FAV_ICON_SPEAKER_OFFHOOK_BLACK 0x28

#define	FAV_ICON_SPEAKER_OFFHOOK_WHITE 0x29

#define	FAV_ICON_SPEAKER_ONHOLD_BLACK 0x2C

#define	FAV_ICON_SPEAKER_ONHOLD_WHITE 0x2D

#define	FAV_ICON_SPEAKER_ONHOOK_BLACK 0x22

#define	FAV_ICON_SPEAKER_ONHOOK_WHITE 0x23

#define	FAV_ICON_TRASH 0x3B

#define	FAV_LINE_ICON FAV_ICON_ONHOOK_BLACK

#define	FAV_MAX_LENGTH 0x0A

#define	FAVNUM 6

#define	IDLE_WAIT 1000

#define	LED_BAR_OFF 0x00 /* bar off */

#define	LED_BAR_ON 0x01 /* bar on */

#define	LED_BAR_P2 0x02 /* bar 1s on/1s */

#define	LED_BAR_P3 0x03 /* bar 2.5s on/0.5s off */

#define	LED_BAR_P4 0x04 /* bar 0.6s on/0.3s off */

#define	LED_BAR_P5 0x05 /* bar 0.5s on/0.5s off */

#define	LED_BAR_P6 0x06 /* bar 2s on/0.5s off */

#define	LED_BAR_P7 0x07 /* bar off */

#define	LED_HEADPHONE_OFF 0x010

#define	LED_HEADPHONE_ON 0x011

#define	LED_MUTE_BLINK 0x1A

#define	LED_MUTE_OFF 0x018

#define	LED_MUTE_ON 0x019

#define	LED_SPEAKER_OFF 0x08

#define	LED_SPEAKER_ON 0x09

#define	MAX_BUF_NUMBER 150

#define	MAX_BUF_SIZE 64

#define	MAX_ENTRY_LOG 30

#define	MAX_SCREEN_NUMBER 15

#define	MONTH_LABEL_SIZE 3

#define	MUTE_OFF 0x00

#define	MUTE_ON 0xFF

#define	MUTE_ON_DISCRET 0xCE

#define	NB_MAX_RETRANSMIT 8

#define	OUTPUT_HANDSET 0xC0

#define	OUTPUT_HEADPHONE 0xC1

#define	OUTPUT_SPEAKER 0xC2

#define	RETRANSMIT_TIMER 2000

#define	SELECTCODEC_MAX_LENGTH 2

#define	SELECTCODEC_MSG "Codec number : .."

#define	SELECTCODEC_START_ENTRY_POS 15

#define	SELECTEXTENSION_MAX_LENGTH 10

#define	SELECTEXTENSION_MSG ".........."

#define	SELECTEXTENSION_START_ENTRY_POS 0

#define	SIZE_HEADER 6

#define	SIZE_MAC_ADDR 17

#define	SIZE_PAGE 4096

#define	STATUS_LENGTH_MAX 28

#define	SUB_REAL 0

#define	SUB_RING 1

#define	SUB_THREEWAY 2

#define	TEXT_INVERSE 0x25

#define	TEXT_LENGTH_MAX 24

#define	TEXT_LINE0 0x00

#define	TEXT_LINE1 0x20

#define	TEXT_LINE2 0x40

#define	TEXT_NORMAL 0x05

#define	TIMER_MWI 5000

#define	USTM_LANG_DIR "unistimLang"

#define	USTM_LOG_DIR "unistimHistory"

#define	VOLUME_INSANELY_LOUD 0x07

#define	VOLUME_LOW 0x01

#define	VOLUME_LOW_SPEAKER 0x03

#define	VOLUME_NORMAL 0x02

Enumerations
enum	autoprov_extn { EXTENSION_NONE = 0 , EXTENSION_ASK , EXTENSION_LINE , EXTENSION_TN }

enum	autoprovision { AUTOPROVISIONING_NO = 0 , AUTOPROVISIONING_YES , AUTOPROVISIONING_TN }

enum	charset { LANG_DEFAULT , ISO_8859_1 , ISO_8859_2 , ISO_8859_4 , ISO_8859_5 , ISO_2022_JP }

enum	handset_state { STATE_ONHOOK , STATE_OFFHOOK }

enum	phone_key { KEY_0 = 0x40 , KEY_1 = 0x41 , KEY_2 = 0x42 , KEY_3 = 0x43 , KEY_4 = 0x44 , KEY_5 = 0x45 , KEY_6 = 0x46 , KEY_7 = 0x47 , KEY_8 = 0x48 , KEY_9 = 0x49 , KEY_STAR = 0x4a , KEY_SHARP = 0x4b , KEY_UP = 0x4c , KEY_DOWN = 0x4d , KEY_RIGHT = 0x4e , KEY_LEFT = 0x4f , KEY_QUIT = 0x50 , KEY_COPY = 0x51 , KEY_FUNC1 = 0x54 , KEY_FUNC2 = 0x55 , KEY_FUNC3 = 0x56 , KEY_FUNC4 = 0x57 , KEY_ONHOLD = 0x5b , KEY_HANGUP = 0x5c , KEY_MUTE = 0x5d , KEY_HEADPHN = 0x5e , KEY_LOUDSPK = 0x5f , KEY_FAV0 = 0x60 , KEY_FAV1 = 0x61 , KEY_FAV2 = 0x62 , KEY_FAV3 = 0x63 , KEY_FAV4 = 0x64 , KEY_FAV5 = 0x65 , KEY_COMPUTR = 0x7b , KEY_CONF = 0x7c , KEY_SNDHIST = 0x7d , KEY_RCVHIST = 0x7e , KEY_INDEX = 0x7f }

enum	phone_state { STATE_INIT , STATE_AUTHDENY , STATE_MAINPAGE , STATE_EXTENSION , STATE_DIALPAGE , STATE_RINGING , STATE_CALL , STATE_SELECTOPTION , STATE_SELECTCODEC , STATE_SELECTLANGUAGE , STATE_CLEANING , STATE_HISTORY }

Functions
static void	__reg_module (void)

static void	__unreg_module (void)

struct ast_module *	AST_MODULE_SELF_SYM (void)

static int	attempt_transfer (struct unistim_subchannel p1, struct unistim_subchannel p2)

static struct unistim_device *	build_device (const char cat, const struct ast_variable v)

static void	change_callerid (struct unistimsession pte, int type, char callerid)

static void	change_favorite_icon (struct unistimsession *pte, unsigned char status)

static struct unistimsession *	channel_to_session (struct ast_channel *ast)

static void	check_send_queue (struct unistimsession *pte)

static void	close_call (struct unistimsession *pte)

static void	close_client (struct unistimsession *s)

static char *	control2str (int ind)

static struct unistimsession *	create_client (const struct sockaddr_in *addr_from)

static void	delete_device (struct unistim_device *d)

static void	discard_call (struct unistimsession *pte)

static void	display_last_error (const char *sz_msg)

static void *	do_monitor (void *data)

static void	dummy (char *unused,...)

static int	find_language (const char *)

static struct unistim_line *	find_line_by_number (struct unistim_device d, const char val)

static int	find_rtp_port (struct unistim_subchannel *s)

static struct unistim_subchannel *	find_subchannel_by_name (const char *dest)

static void	finish_bookmark (void)

static int	get_active_softkey (struct unistimsession *pte)

static int	get_avail_softkey (struct unistimsession pte, const char name)

static struct unistim_subchannel *	get_sub (struct unistim_device *device, int type)

static struct unistim_subchannel *	get_sub_holding (struct unistim_device *device, int type, int holding)

static unsigned int	get_tick_count (void)

static int	get_to_address (int fd, struct sockaddr_in *toAddr)

static void	handle_call_incoming (struct unistimsession *s)

static void	handle_call_outgoing (struct unistimsession *s)

static void	handle_dial_page (struct unistimsession *pte)

static void	handle_key_fav (struct unistimsession *pte, char keycode)

static void	handle_select_codec (struct unistimsession *)

static void	handle_select_language (struct unistimsession *)

static void	handle_select_option (struct unistimsession *pte)

static void	ignore_call (struct unistimsession *pte)

static void	in_band_indication (struct ast_channel ast, const struct ast_tone_zone tz, const char *indication)

static void	init_phone_step2 (struct unistimsession *pte)

static int	is_key_favorite (struct unistim_device *d, int fav)

static int	is_key_line (struct unistim_device *d, int fav)

static void	key_call (struct unistimsession *pte, char keycode)

static void	key_dial_page (struct unistimsession *pte, char keycode)

static void	key_favorite (struct unistimsession *, char)

static void	key_history (struct unistimsession *pte, char keycode)

static void	key_main_page (struct unistimsession *pte, char keycode)

static void	key_ringing (struct unistimsession *pte, char keycode)

static void	key_select_codec (struct unistimsession *pte, char keycode)

static void	key_select_extension (struct unistimsession *pte, char keycode)

static void	key_select_language (struct unistimsession *pte, char keycode)

static void	key_select_option (struct unistimsession *pte, char keycode)

static int	lang_cmp_fn (void obj, void arg, int flags)

static int	lang_hash_fn (const void *obj, const int flags)

static int	load_module (void)

static void	microphone_mute_toggle (struct unistimsession *pte)

static char	open_history (struct unistimsession pte, char way, FILE *f)

static int	parse_bookmark (const char text, struct unistim_device d)

static void	parsing (int size, unsigned char buf, struct unistimsession pte, struct sockaddr_in *addr_from)

static void	process_request (int size, unsigned char buf, struct unistimsession pte)

static const char *	ptestate_tostr (const int type)

static void	rcv_mac_addr (struct unistimsession pte, const unsigned char buf)

static void	rcv_resume_connection_with_server (struct unistimsession *pte)

static void	refresh_all_favorite (struct unistimsession *pte)

static int	register_extension (const struct unistimsession *pte)

static int	reload (void)

static int	reload_config (void)

static int	restart_monitor (void)

static void	send_blink_cursor (struct unistimsession *pte)

static void	send_callerid_screen (struct unistimsession , struct unistim_subchannel )

static void	send_charset_update (struct unistimsession *pte, int charset)

static void	send_client (int size, const unsigned char data, struct unistimsession pte)

static void	send_cursor_pos (struct unistimsession *pte, unsigned char pos)

static void	send_date_time (struct unistimsession *pte)

static void	send_date_time2 (struct unistimsession *pte)

static void	send_date_time3 (struct unistimsession *pte)

static void	send_dial_tone (struct unistimsession *pte)

static int	send_dtmf_tone (struct unistimsession *pte, char digit)

static void	send_end_call (struct unistimsession *pte)

static void	send_expansion_icon (unsigned char pos, unsigned char status, struct unistimsession *pte)

static void	send_expansion_next (struct unistimsession *pte)

static void	send_expansion_short (unsigned char pos, unsigned char status, struct unistimsession *pte)

static void	send_expansion_text (unsigned char pos, struct unistimsession pte, const char text)

static void	send_favorite (unsigned char pos, unsigned char status, struct unistimsession pte, const char text)

static void	send_favorite_selected (unsigned char status, struct unistimsession *pte)

static void	send_favorite_short (unsigned char pos, unsigned char status, struct unistimsession *pte)

static void	send_icon (unsigned char pos, unsigned char status, struct unistimsession *pte)

static void	send_idle_clock (struct unistimsession *pte)

static void	send_led_update (struct unistimsession *pte, unsigned char led)

static void	send_month_labels (struct unistimsession *pte, int month)

static void	send_mute (struct unistimsession *pte, unsigned char mute)

static void	send_no_ring (struct unistimsession *pte)

static void	send_ping (struct unistimsession *pte)

static void	send_raw_client (int size, const unsigned char data, struct sockaddr_in addr_to, const struct sockaddr_in *addr_ourip)

static int	send_retransmit (struct unistimsession *pte)

static void	send_ring (struct unistimsession *pte, signed char volume, signed char style)

static void	send_select_output (struct unistimsession *pte, unsigned char output, unsigned char volume, unsigned char mute)

static void	send_start_rtp (struct unistim_subchannel *)

static void	send_start_timer (struct unistimsession *pte)

static void	send_stop_timer (struct unistimsession *pte)

static void	send_text (unsigned char pos, unsigned char inverse, struct unistimsession pte, const char text)

static void	send_text_status (struct unistimsession pte, const char text)

static void	send_texttitle (struct unistimsession pte, const char text)

static void	send_tone (struct unistimsession *pte, uint16_t tone1, uint16_t tone2)

static void	set_ping_timer (struct unistimsession *pte)

static void	show_entry_history (struct unistimsession pte, FILE *f)

static void	show_extension_page (struct unistimsession *pte)

static void	show_history (struct unistimsession *pte, char way)

static void	show_main_page (struct unistimsession *pte)

static void	show_phone_number (struct unistimsession *pte)

static int	soft_key_visible (struct unistim_device *d, unsigned char num)

static void	start_rtp (struct unistim_subchannel *sub)

static void	sub_hold (struct unistimsession pte, struct unistim_subchannel sub)

static void	sub_start_silence (struct unistimsession pte, struct unistim_subchannel sub)

static void	sub_stop_silence (struct unistimsession pte, struct unistim_subchannel sub)

static void	sub_unhold (struct unistimsession pte, struct unistim_subchannel sub)

static const char *	subtype_tostr (const int type)

static void	swap_subs (struct unistim_subchannel a, struct unistim_subchannel b)

static void	transfer_call_step1 (struct unistimsession *pte)

static void	transfer_cancel_step2 (struct unistimsession *pte)

static struct unistim_subchannel *	unistim_alloc_sub (struct unistim_device *d, int x)

static int	unistim_answer (struct ast_channel *ast)

static int	unistim_call (struct ast_channel ast, const char dest, int timeout)

static char *	unistim_do_debug (struct ast_cli_entry e, int cmd, struct ast_cli_args a)

static int	unistim_do_senddigit (struct unistimsession *pte, char digit)

static int	unistim_fixup (struct ast_channel oldchan, struct ast_channel newchan)

static int	unistim_free_sub (struct unistim_subchannel *)

static enum ast_rtp_glue_result	unistim_get_rtp_peer (struct ast_channel chan, struct ast_rtp_instance *instance)

static int	unistim_hangup (struct ast_channel *ast)

static int	unistim_hangup_clean (struct ast_channel ast, struct unistim_subchannel sub)

static int	unistim_indicate (struct ast_channel ast, int ind, const void data, size_t datalen)

static struct unistim_line *	unistim_line_alloc (void)

static void	unistim_line_copy (struct unistim_line dst, struct unistim_line src)

static struct unistim_line *	unistim_line_destroy (struct unistim_line *l)

static struct ast_channel *	unistim_new (struct unistim_subchannel sub, int state, const struct ast_assigned_ids assignedids, const struct ast_channel *requestor)

static struct ast_frame *	unistim_read (struct ast_channel *ast)

static int	unistim_register (struct unistimsession *s)

static char *	unistim_reload (struct ast_cli_entry e, int cmd, struct ast_cli_args a)
	— unistim_reload: Force reload of module from cli — Runs in the asterisk main thread, so don't do anything useful but setting a flag and waiting for do_monitor to do the job in our thread More...

static struct ast_channel *	unistim_request (const char type, struct ast_format_cap cap, const struct ast_assigned_ids assignedids, const struct ast_channel requestor, const char dest, int cause)

static struct ast_frame *	unistim_rtp_read (const struct ast_channel ast, const struct unistim_subchannel sub)

static int	unistim_send_mwi_to_peer (struct unistim_line *peer, unsigned int tick)

static int	unistim_senddigit_begin (struct ast_channel *ast, char digit)

static int	unistim_senddigit_end (struct ast_channel *ast, char digit, unsigned int duration)

static int	unistim_sendtext (struct ast_channel ast, const char text)

static void	unistim_set_owner (struct unistim_subchannel sub, struct ast_channel chan)

static int	unistim_set_rtp_peer (struct ast_channel chan, struct ast_rtp_instance rtp, struct ast_rtp_instance vrtp, struct ast_rtp_instance trtp, const struct ast_format_cap *codecs, int nat_active)

static char *	unistim_show_devices (struct ast_cli_entry e, int cmd, struct ast_cli_args a)

static char *	unistim_show_info (struct ast_cli_entry e, int cmd, struct ast_cli_args a)

static char *	unistim_sp (struct ast_cli_entry e, int cmd, struct ast_cli_args a)

static void *	unistim_ss (void *data)

static int	unistim_unalloc_sub (struct unistim_device d, struct unistim_subchannel sub)

static int	unistim_write (struct ast_channel ast, struct ast_frame frame)

static int	unistimsock_read (int id, int fd, short events, void ignore)

static int	unload_module (void)

static void	unquote (char out, const char src, int maxlen)

static int	unregister_extension (const struct unistimsession *pte)

static const char *	ustmtext (const char str, struct unistimsession pte)

static int	write_entry_history (struct unistimsession pte, FILE f, char c, char *line1)

static int	write_history (struct unistimsession *pte, char way, char ismissed)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "UNISTIM Protocol (USTM)" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, }

static const struct ast_module_info *	ast_module_info = &__mod_info

static enum autoprovision	autoprovisioning = AUTOPROVISIONING_NO

static unsigned char *	buff

static const char	channel_type [] = "USTM"

static struct ast_jb_conf	default_jbconf
	Global jitterbuffer configuration - by default, jb is disabled. More...

static ast_mutex_t	devicelock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static struct unistim_device *	devices = NULL

static const float	dtmf_col [] = { 1209, 1336, 1477, 1633 }

static const int	dtmf_row [] = { 697, 770, 852, 941 }

struct ast_format_cap *	global_cap

static struct ast_jb_conf	global_jbconf

static struct io_context *	io

static pthread_t	monitor_thread = AST_PTHREADT_NULL

static ast_mutex_t	monlock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static unsigned char	monthlabels []

static struct unistim_languages	options_languages []

static struct unistim_menu_item	options_menu []

static const unsigned char	packet_rcv_discovery []

static const unsigned char	packet_recv_expansion_pressed_key []

static const unsigned char	packet_recv_firm_version []

static const unsigned char	packet_recv_hangup []

static const unsigned char	packet_recv_it_type []

static const unsigned char	packet_recv_mac_addr []

static const unsigned char	packet_recv_pick_up []

static const unsigned char	packet_recv_pressed_key []

static const unsigned char	packet_recv_r2 [] = { 0x00, 0x00, 0x00, 0x13, 0x96, 0x03, 0x03 }

static const unsigned char	packet_recv_resume_connection_with_server []

static const unsigned char	packet_send_arrow [] = { 0x17, 0x04, 0x04, 0x00 }

static const unsigned char	packet_send_blink_cursor [] = { 0x17, 0x04, 0x10, 0x86 }

static const unsigned char	packet_send_call []

static const unsigned char	packet_send_charset_iso_2022_jp []

static const unsigned char	packet_send_charset_iso_8859_1 []

static const unsigned char	packet_send_charset_iso_8859_2 []

static const unsigned char	packet_send_charset_iso_8859_4 []

static const unsigned char	packet_send_charset_iso_8859_5 []

static const unsigned char	packet_send_Contrast []

static const unsigned char	packet_send_date_time []

static const unsigned char	packet_send_date_time2 []

static const unsigned char	packet_send_date_time3 []

static const unsigned char	packet_send_discovery_ack []

static const unsigned char	packet_send_end_call []

static const unsigned char	packet_send_expansion_icon [] = { 0x09, 0x06, 0x59, 0x05, 0x47, 0x20 }

static const unsigned char	packet_send_expansion_next [] = { 0x09, 0x03, 0x17 }

static const unsigned char	packet_send_expansion_text []

static const unsigned char	packet_send_favorite []

static const unsigned char	packet_send_icon [] = { 0x17, 0x05, 0x14, 0x00, 0x25 }

static const unsigned char	packet_send_jitter_buffer_conf []

static const unsigned char	packet_send_led_update [] = { 0x19, 0x04, 0x00, 0x00 }

static unsigned char	packet_send_monthlabels_download []

static const unsigned char	packet_send_mute [] = { 0x16, 0x05, 0x04, 0x00, 0x00 }

static const unsigned char	packet_send_no_ring []

static const unsigned char	packet_send_open_audio_stream_rx []

static const unsigned char	packet_send_open_audio_stream_rx3 []

static const unsigned char	packet_send_open_audio_stream_tx []

static const unsigned char	packet_send_open_audio_stream_tx3 []

static unsigned char	packet_send_ping []

static const unsigned char	packet_send_query_basic_manager_04 [] = { 0x1a, 0x04, 0x01, 0x04 }

static const unsigned char	packet_send_query_basic_manager_10 [] = { 0x1a, 0x04, 0x01, 0x10 }

static const unsigned char	packet_send_query_mac_address [] = { 0x1a, 0x04, 0x01, 0x08 }

static const unsigned char	packet_send_ring []

static const unsigned char	packet_send_rtp_packet_size []

static const unsigned char	packet_send_S1 [] = { 0x1a, 0x07, 0x07, 0x00, 0x00, 0x00, 0x13 }

static const unsigned char	packet_send_s4 []

static const unsigned char	packet_send_S7 [] = { 0x17, 0x06, 0x0f, 0x30, 0x07, 0x07 }

static const unsigned char	packet_send_s9 []

static const unsigned char	packet_send_select_output []

static const unsigned char	packet_send_set_pos_cursor []

static const unsigned char	packet_send_start_timer []

static const unsigned char	packet_send_status []

static const unsigned char	packet_send_status2 []

static const unsigned char	packet_send_stop_timer [] = { 0x17, 0x05, 0x0b, 0x02, 0x00 }

static const unsigned char	packet_send_stream_based_tone_dual_freq []

static const unsigned char	packet_send_stream_based_tone_off []

static const unsigned char	packet_send_stream_based_tone_on []

static const unsigned char	packet_send_stream_based_tone_single_freq []

static const unsigned char	packet_send_text []

static const unsigned char	packet_send_title []

static struct sockaddr_in	public_ip = { 0, }

struct {
unsigned int cos

unsigned int cos_audio

unsigned int tos

unsigned int tos_audio

}	qos = { 0, 0, 0, 0 }

static struct ast_sched_context *	sched

static ast_mutex_t	sessionlock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static struct unistimsession *	sessions = NULL

static const char	tdesc [] = "UNISTIM Channel Driver"

static struct ast_cli_entry	unistim_cli []

static int	unistim_keepalive

static int	unistim_port

static ast_mutex_t	unistim_reload_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static int	unistim_reloading = 0

static struct ast_rtp_glue	unistim_rtp_glue

static struct ast_channel_tech	unistim_tech

static int	unistimdebug = 0

static int	unistimsock = -1

static char	ustm_strcopy [1024]

Detailed Description

chan_unistim channel driver for Asterisk

Author: Cedric Hans cedri.nosp@m.c.ha.nosp@m.ns@ml.nosp@m.kj.n.nosp@m.et

Unistim (Unified Networks IP Stimulus) channel driver for Nortel i2002, i2004 and i2050

Definition in file chan_unistim.c.

Macro Definition Documentation

◆ AST_CONFIG_MAX_PATH

#define AST_CONFIG_MAX_PATH 255

Definition at line 113 of file chan_unistim.c.

◆ BUFFSEND

#define BUFFSEND unsigned char buffsend[64] = { 0x00, 0x00, 0xaa, 0xbb, 0x02, 0x01 }

Definition at line 704 of file chan_unistim.c.

◆ DEBUG_TIMER

#define DEBUG_TIMER dummy

Definition at line 241 of file chan_unistim.c.

◆ DEFAULT_CODEC

#define DEFAULT_CODEC 0x00

Not used

Definition at line 110 of file chan_unistim.c.

◆ DEFAULT_INTERDIGIT_TIMER

#define DEFAULT_INTERDIGIT_TIMER 4000

Timeout value for entered number being dialed

Definition at line 107 of file chan_unistim.c.

◆ DEFAULTCALLERID

#define DEFAULTCALLERID "Unknown"

Definition at line 84 of file chan_unistim.c.

◆ DEFAULTCALLERNAME

#define DEFAULTCALLERNAME " "

Definition at line 85 of file chan_unistim.c.

◆ DEFAULTCONTEXT

#define DEFAULTCONTEXT "default"

Definition at line 83 of file chan_unistim.c.

◆ DEFAULTHEIGHT

#define DEFAULTHEIGHT 3

Definition at line 86 of file chan_unistim.c.

◆ DEVICE_NAME_LEN

#define DEVICE_NAME_LEN 16

Definition at line 112 of file chan_unistim.c.

◆ EXPNUM

#define EXPNUM 24

Definition at line 217 of file chan_unistim.c.

◆ FAV_BLINK_FAST

#define FAV_BLINK_FAST 0x20

Definition at line 211 of file chan_unistim.c.

◆ FAV_BLINK_SLOW

#define FAV_BLINK_SLOW 0x40

Definition at line 212 of file chan_unistim.c.

◆ FAV_ICON_BOX

#define FAV_ICON_BOX 0x3F

Definition at line 209 of file chan_unistim.c.

◆ FAV_ICON_CALL_CENTER

#define FAV_ICON_CALL_CENTER 0x34

Definition at line 198 of file chan_unistim.c.

◆ FAV_ICON_CITY

#define FAV_ICON_CITY 0x31

Definition at line 195 of file chan_unistim.c.

◆ FAV_ICON_COMPUTER

#define FAV_ICON_COMPUTER 0x38

Definition at line 202 of file chan_unistim.c.

◆ FAV_ICON_FAX

#define FAV_ICON_FAX 0x35

Definition at line 199 of file chan_unistim.c.

◆ FAV_ICON_FORWARD

#define FAV_ICON_FORWARD 0x39

Definition at line 203 of file chan_unistim.c.

◆ FAV_ICON_HEADPHONES

#define FAV_ICON_HEADPHONES 0x2E

Definition at line 192 of file chan_unistim.c.

◆ FAV_ICON_HEADPHONES_ONHOLD

#define FAV_ICON_HEADPHONES_ONHOLD 0x2F

Definition at line 193 of file chan_unistim.c.

◆ FAV_ICON_HOME

#define FAV_ICON_HOME 0x30

Definition at line 194 of file chan_unistim.c.

◆ FAV_ICON_INBOX

#define FAV_ICON_INBOX 0x3C

Definition at line 206 of file chan_unistim.c.

◆ FAV_ICON_LOCKED

#define FAV_ICON_LOCKED 0x3A

Definition at line 204 of file chan_unistim.c.

◆ FAV_ICON_MAILBOX

#define FAV_ICON_MAILBOX 0x36

Definition at line 200 of file chan_unistim.c.

◆ FAV_ICON_MEETING

#define FAV_ICON_MEETING 0x3E

Definition at line 208 of file chan_unistim.c.

◆ FAV_ICON_NONE

#define FAV_ICON_NONE 0x00

Definition at line 177 of file chan_unistim.c.

◆ FAV_ICON_OFFHOOK_BLACK

#define FAV_ICON_OFFHOOK_BLACK 0x24

Definition at line 182 of file chan_unistim.c.

◆ FAV_ICON_OFFHOOK_WHITE

#define FAV_ICON_OFFHOOK_WHITE 0x25

Definition at line 183 of file chan_unistim.c.

◆ FAV_ICON_ONHOLD_BLACK

#define FAV_ICON_ONHOLD_BLACK 0x26

Definition at line 184 of file chan_unistim.c.

◆ FAV_ICON_ONHOLD_WHITE

#define FAV_ICON_ONHOLD_WHITE 0x27

Definition at line 185 of file chan_unistim.c.

◆ FAV_ICON_ONHOOK_BLACK

#define FAV_ICON_ONHOOK_BLACK 0x20

Definition at line 178 of file chan_unistim.c.

◆ FAV_ICON_ONHOOK_WHITE

#define FAV_ICON_ONHOOK_WHITE 0x21

Definition at line 179 of file chan_unistim.c.

◆ FAV_ICON_OUTBOX

#define FAV_ICON_OUTBOX 0x3D

Definition at line 207 of file chan_unistim.c.

◆ FAV_ICON_PAGER

#define FAV_ICON_PAGER 0x33

Definition at line 197 of file chan_unistim.c.

◆ FAV_ICON_PHONE_BLACK

#define FAV_ICON_PHONE_BLACK 0x2A

Definition at line 188 of file chan_unistim.c.

◆ FAV_ICON_PHONE_WHITE

#define FAV_ICON_PHONE_WHITE 0x2B

Definition at line 189 of file chan_unistim.c.

◆ FAV_ICON_REFLECT

#define FAV_ICON_REFLECT 0x37

Definition at line 201 of file chan_unistim.c.

◆ FAV_ICON_SHARP

#define FAV_ICON_SHARP 0x32

Definition at line 196 of file chan_unistim.c.

◆ FAV_ICON_SPEAKER_OFFHOOK_BLACK

#define FAV_ICON_SPEAKER_OFFHOOK_BLACK 0x28

Definition at line 186 of file chan_unistim.c.

◆ FAV_ICON_SPEAKER_OFFHOOK_WHITE

#define FAV_ICON_SPEAKER_OFFHOOK_WHITE 0x29

Definition at line 187 of file chan_unistim.c.

◆ FAV_ICON_SPEAKER_ONHOLD_BLACK

#define FAV_ICON_SPEAKER_ONHOLD_BLACK 0x2C

Definition at line 190 of file chan_unistim.c.

◆ FAV_ICON_SPEAKER_ONHOLD_WHITE

#define FAV_ICON_SPEAKER_ONHOLD_WHITE 0x2D

Definition at line 191 of file chan_unistim.c.

◆ FAV_ICON_SPEAKER_ONHOOK_BLACK

#define FAV_ICON_SPEAKER_ONHOOK_BLACK 0x22

Definition at line 180 of file chan_unistim.c.

◆ FAV_ICON_SPEAKER_ONHOOK_WHITE

#define FAV_ICON_SPEAKER_ONHOOK_WHITE 0x23

Definition at line 181 of file chan_unistim.c.

◆ FAV_ICON_TRASH

#define FAV_ICON_TRASH 0x3B

Definition at line 205 of file chan_unistim.c.

◆ FAV_LINE_ICON

#define FAV_LINE_ICON FAV_ICON_ONHOOK_BLACK

Definition at line 218 of file chan_unistim.c.

◆ FAV_MAX_LENGTH

#define FAV_MAX_LENGTH 0x0A

Definition at line 214 of file chan_unistim.c.

◆ FAVNUM

#define FAVNUM 6

Definition at line 216 of file chan_unistim.c.

◆ IDLE_WAIT

#define IDLE_WAIT 1000

Nb of milliseconds waited when no events are scheduled

Definition at line 101 of file chan_unistim.c.

◆ LED_BAR_OFF

#define LED_BAR_OFF 0x00 /* bar off */

Definition at line 151 of file chan_unistim.c.

◆ LED_BAR_ON

#define LED_BAR_ON 0x01 /* bar on */

Definition at line 152 of file chan_unistim.c.

◆ LED_BAR_P2

#define LED_BAR_P2 0x02 /* bar 1s on/1s */

Definition at line 153 of file chan_unistim.c.

◆ LED_BAR_P3

#define LED_BAR_P3 0x03 /* bar 2.5s on/0.5s off */

Definition at line 154 of file chan_unistim.c.

◆ LED_BAR_P4

#define LED_BAR_P4 0x04 /* bar 0.6s on/0.3s off */

Definition at line 155 of file chan_unistim.c.

◆ LED_BAR_P5

#define LED_BAR_P5 0x05 /* bar 0.5s on/0.5s off */

Definition at line 156 of file chan_unistim.c.

◆ LED_BAR_P6

#define LED_BAR_P6 0x06 /* bar 2s on/0.5s off */

Definition at line 157 of file chan_unistim.c.

◆ LED_BAR_P7

#define LED_BAR_P7 0x07 /* bar off */

Definition at line 158 of file chan_unistim.c.

◆ LED_HEADPHONE_OFF

#define LED_HEADPHONE_OFF 0x010

Definition at line 161 of file chan_unistim.c.

◆ LED_HEADPHONE_ON

#define LED_HEADPHONE_ON 0x011

Definition at line 162 of file chan_unistim.c.

◆ LED_MUTE_BLINK

#define LED_MUTE_BLINK 0x1A

Definition at line 165 of file chan_unistim.c.

◆ LED_MUTE_OFF

#define LED_MUTE_OFF 0x018

Definition at line 163 of file chan_unistim.c.

◆ LED_MUTE_ON

#define LED_MUTE_ON 0x019

Definition at line 164 of file chan_unistim.c.

◆ LED_SPEAKER_OFF

#define LED_SPEAKER_OFF 0x08

Definition at line 159 of file chan_unistim.c.

◆ LED_SPEAKER_ON

#define LED_SPEAKER_ON 0x09

Definition at line 160 of file chan_unistim.c.

◆ MAX_BUF_NUMBER

#define MAX_BUF_NUMBER 150

Number of slots for the transmit queue

Definition at line 93 of file chan_unistim.c.

◆ MAX_BUF_SIZE

#define MAX_BUF_SIZE 64

Size of the transmit buffer

Definition at line 91 of file chan_unistim.c.

◆ MAX_ENTRY_LOG

#define MAX_ENTRY_LOG 30

Definition at line 114 of file chan_unistim.c.

◆ MAX_SCREEN_NUMBER

#define MAX_SCREEN_NUMBER 15

Number of digits displayed on screen

Definition at line 95 of file chan_unistim.c.

◆ MONTH_LABEL_SIZE

#define MONTH_LABEL_SIZE 3

Length of month label size

Definition at line 97 of file chan_unistim.c.

◆ MUTE_OFF

#define MUTE_OFF 0x00

Definition at line 147 of file chan_unistim.c.

◆ MUTE_ON

#define MUTE_ON 0xFF

Definition at line 148 of file chan_unistim.c.

◆ MUTE_ON_DISCRET

#define MUTE_ON_DISCRET 0xCE

Definition at line 149 of file chan_unistim.c.

◆ NB_MAX_RETRANSMIT

#define NB_MAX_RETRANSMIT 8

Try x times before removing the phone

Definition at line 99 of file chan_unistim.c.

◆ OUTPUT_HANDSET

#define OUTPUT_HANDSET 0xC0

Definition at line 138 of file chan_unistim.c.

◆ OUTPUT_HEADPHONE

#define OUTPUT_HEADPHONE 0xC1

Definition at line 139 of file chan_unistim.c.

◆ OUTPUT_SPEAKER

#define OUTPUT_SPEAKER 0xC2

Definition at line 140 of file chan_unistim.c.

◆ RETRANSMIT_TIMER

#define RETRANSMIT_TIMER 2000

Wait x milliseconds before resending a packet

Definition at line 103 of file chan_unistim.c.

◆ SELECTCODEC_MAX_LENGTH

#define SELECTCODEC_MAX_LENGTH 2

Definition at line 3730 of file chan_unistim.c.

◆ SELECTCODEC_MSG

#define SELECTCODEC_MSG "Codec number : .."

Definition at line 3731 of file chan_unistim.c.

◆ SELECTCODEC_START_ENTRY_POS

#define SELECTCODEC_START_ENTRY_POS 15

Definition at line 3729 of file chan_unistim.c.

◆ SELECTEXTENSION_MAX_LENGTH

#define SELECTEXTENSION_MAX_LENGTH 10

Definition at line 3874 of file chan_unistim.c.

◆ SELECTEXTENSION_MSG

#define SELECTEXTENSION_MSG ".........."

Definition at line 3875 of file chan_unistim.c.

◆ SELECTEXTENSION_START_ENTRY_POS

#define SELECTEXTENSION_START_ENTRY_POS 0

Definition at line 3873 of file chan_unistim.c.

◆ SIZE_HEADER

#define SIZE_HEADER 6

Definition at line 167 of file chan_unistim.c.

◆ SIZE_MAC_ADDR

#define SIZE_MAC_ADDR 17

Definition at line 168 of file chan_unistim.c.

◆ SIZE_PAGE

#define SIZE_PAGE 4096

Definition at line 111 of file chan_unistim.c.

◆ STATUS_LENGTH_MAX

#define STATUS_LENGTH_MAX 28

Definition at line 175 of file chan_unistim.c.

◆ SUB_REAL

#define SUB_REAL 0

Definition at line 116 of file chan_unistim.c.

◆ SUB_RING

#define SUB_RING 1

Definition at line 117 of file chan_unistim.c.

◆ SUB_THREEWAY

#define SUB_THREEWAY 2

Definition at line 118 of file chan_unistim.c.

◆ TEXT_INVERSE

#define TEXT_INVERSE 0x25

Definition at line 174 of file chan_unistim.c.

◆ TEXT_LENGTH_MAX

#define TEXT_LENGTH_MAX 24

Definition at line 169 of file chan_unistim.c.

◆ TEXT_LINE0

#define TEXT_LINE0 0x00

Definition at line 170 of file chan_unistim.c.

◆ TEXT_LINE1

#define TEXT_LINE1 0x20

Definition at line 171 of file chan_unistim.c.

◆ TEXT_LINE2

#define TEXT_LINE2 0x40

Definition at line 172 of file chan_unistim.c.

◆ TEXT_NORMAL

#define TEXT_NORMAL 0x05

Definition at line 173 of file chan_unistim.c.

◆ TIMER_MWI

#define TIMER_MWI 5000

How often the mailbox is checked for new messages

Definition at line 105 of file chan_unistim.c.

◆ USTM_LANG_DIR

#define USTM_LANG_DIR "unistimLang"

Definition at line 88 of file chan_unistim.c.

◆ USTM_LOG_DIR

#define USTM_LOG_DIR "unistimHistory"

Definition at line 87 of file chan_unistim.c.

◆ VOLUME_INSANELY_LOUD

#define VOLUME_INSANELY_LOUD 0x07

Definition at line 145 of file chan_unistim.c.

◆ VOLUME_LOW

#define VOLUME_LOW 0x01

Definition at line 142 of file chan_unistim.c.

◆ VOLUME_LOW_SPEAKER

#define VOLUME_LOW_SPEAKER 0x03

Definition at line 143 of file chan_unistim.c.

◆ VOLUME_NORMAL

#define VOLUME_NORMAL 0x02

Definition at line 144 of file chan_unistim.c.

Enumeration Type Documentation

◆ autoprov_extn

enum autoprov_extn

Enumerator
EXTENSION_NONE	Do not create an extension into the default dialplan
EXTENSION_ASK	Prompt user for an extension number and register it
EXTENSION_LINE	Register an extension with the line=> value
EXTENSION_TN	Used with AUTOPROVISIONING_TN

Definition at line 128 of file chan_unistim.c.

                   {
    /*! Do not create an extension into the default dialplan */
    EXTENSION_NONE = 0,
    /*! Prompt user for an extension number and register it */
    EXTENSION_ASK,
    /*! Register an extension with the line=> value */
    EXTENSION_LINE,
    /*! Used with AUTOPROVISIONING_TN */
    EXTENSION_TN
};

◆ autoprovision

enum autoprovision

Enumerator
AUTOPROVISIONING_NO
AUTOPROVISIONING_YES
AUTOPROVISIONING_TN

Definition at line 122 of file chan_unistim.c.

                   {
    AUTOPROVISIONING_NO = 0,
    AUTOPROVISIONING_YES,
    AUTOPROVISIONING_TN
};

◆ charset

enum charset

Enumerator
LANG_DEFAULT
ISO_8859_1
ISO_8859_2
ISO_8859_4
ISO_8859_5
ISO_2022_JP

Definition at line 336 of file chan_unistim.c.

             {
    LANG_DEFAULT,
    ISO_8859_1,
    ISO_8859_2,
    ISO_8859_4,
    ISO_8859_5,
    ISO_2022_JP,
};

◆ handset_state

enum handset_state

Enumerator
STATE_ONHOOK
STATE_OFFHOOK

Definition at line 290 of file chan_unistim.c.

                   {
    STATE_ONHOOK,
    STATE_OFFHOOK,
};

◆ phone_key

enum phone_key

Enumerator
KEY_0
KEY_1
KEY_2
KEY_3
KEY_4
KEY_5
KEY_6
KEY_7
KEY_8
KEY_9
KEY_STAR
KEY_SHARP
KEY_UP
KEY_DOWN
KEY_RIGHT
KEY_LEFT
KEY_QUIT
KEY_COPY
KEY_FUNC1
KEY_FUNC2
KEY_FUNC3
KEY_FUNC4
KEY_ONHOLD
KEY_HANGUP
KEY_MUTE
KEY_HEADPHN
KEY_LOUDSPK
KEY_FAV0
KEY_FAV1
KEY_FAV2
KEY_FAV3
KEY_FAV4
KEY_FAV5
KEY_COMPUTR
KEY_CONF
KEY_SNDHIST
KEY_RCVHIST
KEY_INDEX

Definition at line 295 of file chan_unistim.c.

               {
    KEY_0 = 0x40,
    KEY_1 = 0x41,
    KEY_2 = 0x42,
    KEY_3 = 0x43,
    KEY_4 = 0x44,
    KEY_5 = 0x45,
    KEY_6 = 0x46,
    KEY_7 = 0x47,
    KEY_8 = 0x48,
    KEY_9 = 0x49,
    KEY_STAR = 0x4a,
    KEY_SHARP = 0x4b,
    KEY_UP = 0x4c,
    KEY_DOWN = 0x4d,
    KEY_RIGHT = 0x4e,
    KEY_LEFT = 0x4f,
    KEY_QUIT = 0x50,
    KEY_COPY = 0x51,
    KEY_FUNC1 = 0x54,
    KEY_FUNC2 = 0x55,
    KEY_FUNC3 = 0x56,
    KEY_FUNC4 = 0x57,
    KEY_ONHOLD = 0x5b,
    KEY_HANGUP = 0x5c,
    KEY_MUTE = 0x5d,
    KEY_HEADPHN = 0x5e,
    KEY_LOUDSPK = 0x5f,
    KEY_FAV0 = 0x60,
    KEY_FAV1 = 0x61,
    KEY_FAV2 = 0x62,
    KEY_FAV3 = 0x63,
    KEY_FAV4 = 0x64,
    KEY_FAV5 = 0x65,
    KEY_COMPUTR = 0x7b,
    KEY_CONF = 0x7c,
    KEY_SNDHIST = 0x7d,
    KEY_RCVHIST = 0x7e,
    KEY_INDEX = 0x7f
};

◆ phone_state

enum phone_state

Enumerator
STATE_INIT
STATE_AUTHDENY
STATE_MAINPAGE
STATE_EXTENSION
STATE_DIALPAGE
STATE_RINGING
STATE_CALL
STATE_SELECTOPTION
STATE_SELECTCODEC
STATE_SELECTLANGUAGE
STATE_CLEANING
STATE_HISTORY

Definition at line 275 of file chan_unistim.c.

                 {
    STATE_INIT,
    STATE_AUTHDENY,
    STATE_MAINPAGE,
    STATE_EXTENSION,
    STATE_DIALPAGE,
    STATE_RINGING,
    STATE_CALL,
    STATE_SELECTOPTION,
    STATE_SELECTCODEC,
    STATE_SELECTLANGUAGE,
    STATE_CLEANING,
    STATE_HISTORY
};

Function Documentation

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 7206 of file chan_unistim.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 7206 of file chan_unistim.c.

◆ AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM ( void )

Definition at line 7206 of file chan_unistim.c.

◆ attempt_transfer()

static int attempt_transfer	(	struct unistim_subchannel *	p1,
		struct unistim_subchannel *	p2
	)

static

Definition at line 2440 of file chan_unistim.c.

{
    RAII_VAR(struct ast_channel *, chana, NULL, ast_channel_unref);
    RAII_VAR(struct ast_channel *, chanb, NULL, ast_channel_unref);
 
    if (!p1->owner || !p2->owner) {
        ast_log(LOG_WARNING, "Transfer attempted without dual ownership?\n");
        return -1;
    }
    chana = ast_channel_ref(p1->owner);
    chanb = ast_channel_ref(p2->owner);
 
    switch (ast_bridge_transfer_attended(chana, chanb)) {
    case AST_BRIDGE_TRANSFER_INVALID:
        ast_log(LOG_WARNING, "Transfer failed. Invalid bridge setup\n");
        break;
    case AST_BRIDGE_TRANSFER_NOT_PERMITTED:
        ast_log(LOG_WARNING, "Transfer not permitted\n");
        break;
    case AST_BRIDGE_TRANSFER_FAIL:
        ast_log(LOG_WARNING, "Transfer encountered internal error\n");
        break;
    case AST_BRIDGE_TRANSFER_SUCCESS:
        return 0;
    }
 
    /* Control only reaches this point if transfer has failed */
    ast_softhangup_nolock(chana, AST_SOFTHANGUP_DEV);
    ast_softhangup_nolock(chanb, AST_SOFTHANGUP_DEV);
    return -1;
}

References ast_bridge_transfer_attended(), AST_BRIDGE_TRANSFER_FAIL, AST_BRIDGE_TRANSFER_INVALID, AST_BRIDGE_TRANSFER_NOT_PERMITTED, AST_BRIDGE_TRANSFER_SUCCESS, ast_channel_ref, ast_channel_unref, ast_log, AST_SOFTHANGUP_DEV, ast_softhangup_nolock(), LOG_WARNING, NULL, unistim_subchannel::owner, and RAII_VAR.

Referenced by close_call().

◆ build_device()

static struct unistim_device * build_device	(	const char *	cat,
		const struct ast_variable *	v
	)

static

Definition at line 6501 of file chan_unistim.c.

{
    struct unistim_device *d;
    struct unistim_line *l = NULL, *lt = NULL;
    int create = 1;
    int nbsoftkey, dateformat, timeformat, callhistory, sharpdial, linecnt;
    char linelabel[AST_MAX_EXTENSION];
    signed char ringvolume, ringstyle, cwvolume, cwstyle;
 
    /* First, we need to know if we already have this name in our list */
    /* Get a lock for the device chained list */
    ast_mutex_lock(&devicelock);
    d = devices;
    while (d) {
        if (!strcmp(d->name, cat)) {
            /* Yep, we alreay have this one */
            if (unistimsock < 0) {
                /* It's a dupe */
                ast_log(LOG_WARNING, "Duplicate entry found (%s), ignoring.\n", cat);
                ast_mutex_unlock(&devicelock);
                return NULL;
            }
            /* we're reloading right now */
            create = 0;
            break;
        }
        d = d->next;
    }
    ast_mutex_unlock(&devicelock);
    if (!(lt = ast_calloc(1, sizeof(*lt)))) {
        return NULL;
    }
    if (create) {
        if (!(d = ast_calloc(1, sizeof(*d)))) {
            return NULL;
        }
        ast_mutex_init(&d->lock);
        ast_copy_string(d->name, cat, sizeof(d->name));
 
        ast_copy_string(d->context, DEFAULTCONTEXT, sizeof(d->context));
        d->contrast = -1;
        d->output = OUTPUT_HANDSET;
        d->previous_output = OUTPUT_HANDSET;
        d->volume = VOLUME_LOW;
        d->microphone = MUTE_OFF;
        d->height = DEFAULTHEIGHT;
        d->selected = -1;
        d->interdigit_timer = DEFAULT_INTERDIGIT_TIMER;
    } else {
        /* Delete existing line information */
        AST_LIST_LOCK(&d->lines);
        AST_LIST_TRAVERSE_SAFE_BEGIN(&d->lines, l, list){
            AST_LIST_REMOVE_CURRENT(list);
            unistim_line_destroy(l);
        }
        AST_LIST_TRAVERSE_SAFE_END
        AST_LIST_UNLOCK(&d->lines);
 
        /* reset bookmarks */
        memset(d->softkeylabel, 0, sizeof(d->softkeylabel));
        memset(d->softkeynumber, 0, sizeof(d->softkeynumber));
        memset(d->softkeyicon, 0, sizeof(d->softkeyicon));
        memset(d->softkeydevice, 0, sizeof(d->softkeydevice));
        memset(d->ssub, 0, sizeof(d->ssub));
        memset(d->sline, 0, sizeof(d->sline));
        memset(d->sp, 0, sizeof(d->sp));
    }
    linelabel[0] = '\0';
    dateformat = 1;
    timeformat = 1;
    ringvolume = 2;
    cwvolume = 1;
    callhistory = 1;
    sharpdial = 0;
    ringstyle = 3;
    cwstyle = 2;
    nbsoftkey = 0;
    linecnt = 0;
    d->dtmfduration = 0;
    while (v) {
        if (!strcasecmp(v->name, "rtp_port")) {
            d->rtp_port = atoi(v->value);
        } else if (!strcasecmp(v->name, "rtp_method")) {
            d->rtp_method = atoi(v->value);
        } else if (!strcasecmp(v->name, "status_method")) {
            d->status_method = atoi(v->value);
        } else if (!strcasecmp(v->name, "device")) {
            ast_copy_string(d->id, v->value, sizeof(d->id));
        } else if (!strcasecmp(v->name, "tn")) {
            ast_copy_string(d->extension_number, v->value, sizeof(d->extension_number));
        } else if (!strcasecmp(v->name, "permit") || !strcasecmp(v->name, "deny")) {
            int acl_error = 0;
            d->ha = ast_append_ha(v->name, v->value, d->ha, &acl_error);
            if (acl_error) {
                ast_log(LOG_ERROR, "Invalid ACL '%s' specified for device '%s' on line %d. Deleting device\n",
                        v->value, cat, v->lineno);
                delete_device(d);
                return NULL;
            }
        } else if (!strcasecmp(v->name, "context")) {
            ast_copy_string(d->context, v->value, sizeof(d->context));
        } else if (!strcasecmp(v->name, "maintext0")) {
            unquote(d->maintext0, v->value, sizeof(d->maintext0) - 1);
        } else if (!strcasecmp(v->name, "maintext1")) {
            unquote(d->maintext1, v->value, sizeof(d->maintext1) - 1);
        } else if (!strcasecmp(v->name, "maintext2")) {
            unquote(d->maintext2, v->value, sizeof(d->maintext2) - 1);
        } else if (!strcasecmp(v->name, "titledefault")) {
            unquote(d->titledefault, v->value, sizeof(d->titledefault) - 1);
        } else if (!strcasecmp(v->name, "dateformat")) {
            dateformat = atoi(v->value);
        } else if (!strcasecmp(v->name, "timeformat")) {
            timeformat = atoi(v->value);
        } else if (!strcasecmp(v->name, "contrast")) {
            d->contrast = atoi(v->value);
            if ((d->contrast < 0) || (d->contrast > 15)) {
                ast_log(LOG_WARNING, "contrast must be beetween 0 and 15\n");
                d->contrast = 8;
            }
        } else if (!strcasecmp(v->name, "nat")) {
            d->nat = ast_true(v->value);
        } else if (!strcasecmp(v->name, "hasexp")) {
            d->hasexp = ast_true(v->value);
        } else if (!strcasecmp(v->name, "ringvolume")) {
            ringvolume = atoi(v->value);
        } else if (!strcasecmp(v->name, "ringstyle")) {
            ringstyle = atoi(v->value);
        } else if (!strcasecmp(v->name, "cwvolume")) {
            cwvolume = atoi(v->value);
        } else if (!strcasecmp(v->name, "cwstyle")) {
            cwstyle = atoi(v->value);
        } else if (!strcasecmp(v->name, "callhistory")) {
            callhistory = atoi(v->value);
        } else if (!strcasecmp(v->name, "sharpdial")) {
            sharpdial = ast_true(v->value) ? 1 : 0;
        } else if (!strcasecmp(v->name, "interdigit_timer")) {
            d->interdigit_timer = atoi(v->value);
        } else if (!strcasecmp(v->name, "dtmf_duration")) {
            d->dtmfduration = atoi(v->value);
            if (d->dtmfduration > 150) {
                d->dtmfduration = 150;
            }
        } else if (!strcasecmp(v->name, "callerid")) {
            if (!strcasecmp(v->value, "asreceived")) {
                lt->cid_num[0] = '\0';
            } else {
                ast_copy_string(lt->cid_num, v->value, sizeof(lt->cid_num));
            }
        } else if (!strcasecmp(v->name, "language")) {
            ast_copy_string(d->language, v->value, sizeof(d->language));
        } else if (!strcasecmp(v->name, "country")) {
            ast_copy_string(d->country, v->value, sizeof(d->country));
        } else if (!strcasecmp(v->name, "accountcode")) {
            ast_copy_string(lt->accountcode, v->value, sizeof(lt->accountcode));
        } else if (!strcasecmp(v->name, "amaflags")) {
            int y;
            y = ast_channel_string2amaflag(v->value);
            if (y < 0) {
                ast_log(LOG_WARNING, "Invalid AMA flags: %s at line %d\n", v->value,
                        v->lineno);
            } else {
                lt->amaflags = y;
            }
        } else if (!strcasecmp(v->name, "musiconhold")) {
            ast_copy_string(lt->musicclass, v->value, sizeof(lt->musicclass));
        } else if (!strcasecmp(v->name, "callgroup")) {
            lt->callgroup = ast_get_group(v->value);
        } else if (!strcasecmp(v->name, "pickupgroup")) {
            lt->pickupgroup = ast_get_group(v->value);
        } else if (!strcasecmp(v->name, "mailbox")) {
            ast_copy_string(lt->mailbox, v->value, sizeof(lt->mailbox));
        } else if (!strcasecmp(v->name, "parkinglot")) {
            ast_copy_string(lt->parkinglot, v->value, sizeof(lt->parkinglot));
        } else if (!strcasecmp(v->name, "linelabel")) {
            unquote(linelabel, v->value, sizeof(linelabel) - 1);
        } else if (!strcasecmp(v->name, "extension")) {
            if (!strcasecmp(v->value, "none")) {
                d->extension = EXTENSION_NONE;
            } else if (!strcasecmp(v->value, "ask")) {
                d->extension = EXTENSION_ASK;
            } else if (!strcasecmp(v->value, "line")) {
                d->extension = EXTENSION_LINE;
            } else {
                ast_log(LOG_WARNING, "Unknown extension option.\n");
            }
        } else if (!strcasecmp(v->name, "bookmark")) {
            if (nbsoftkey > 5) {
                ast_log(LOG_WARNING,
                        "More than 6 softkeys defined. Ignoring new entries.\n");
            } else {
                if (parse_bookmark(v->value, d)) {
                    nbsoftkey++;
                }
            }
        } else if (!strcasecmp(v->name, "line")) {
            int len = strlen(linelabel);
            int create_line = 0;
 
            l = find_line_by_number(d, v->value);
            if (!l) { /* If line still not exists */
                if (!(l = unistim_line_alloc())) {
                    ast_free(d);
                    ast_free(lt);
                    return NULL;
                }
                lt->cap = l->cap;
                memcpy(l, lt, sizeof(*l));
                ast_mutex_init(&l->lock);
                create_line = 1;
            }
            d->to_delete = 0;
 
            /* Set softkey info for new line*/
            d->sline[nbsoftkey] = l;
            d->softkeyicon[nbsoftkey] = FAV_LINE_ICON;
            if (!len) {       /* label is undefined ? */
                ast_copy_string(d->softkeylabel[nbsoftkey], v->value, sizeof(d->softkeylabel[nbsoftkey]));
            } else {
                int softkeylinepos = 0;
                if ((len > 2) && (linelabel[1] == '@')) {
                    softkeylinepos = linelabel[0];
                    if ((softkeylinepos >= '0') && (softkeylinepos <= '5')) {
                        softkeylinepos -= '0';
                        d->softkeyicon[nbsoftkey] = FAV_ICON_NONE;
                    } else {
                        ast_log(LOG_WARNING,
                                "Invalid position for linelabel : must be between 0 and 5\n");
                    }
                    ast_copy_string(d->softkeylabel[softkeylinepos], linelabel + 2,
                                    sizeof(d->softkeylabel[softkeylinepos]));
                    d->softkeyicon[softkeylinepos] = FAV_LINE_ICON;
                } else {
                    ast_copy_string(d->softkeylabel[nbsoftkey], linelabel,
                                    sizeof(d->softkeylabel[nbsoftkey]));
                }
            }
            nbsoftkey++;
 
            if (create_line) {
                ast_copy_string(l->name, v->value, sizeof(l->name));
                snprintf(l->fullname, sizeof(l->fullname), "USTM/%s@%s", l->name, d->name);
                if (!ast_strlen_zero(l->mailbox)) {
                    if (unistimdebug) {
                        ast_verb(3, "Setting mailbox '%s' on %s@%s\n", l->mailbox, d->name, l->name);
                    }
                }
                ast_format_cap_append_from_cap(l->cap, global_cap, AST_MEDIA_TYPE_UNKNOWN);
                l->parent = d;
                linecnt++;
                AST_LIST_LOCK(&d->lines);
                AST_LIST_INSERT_TAIL(&d->lines, l, list);
                AST_LIST_UNLOCK(&d->lines);
            }
        } else if (!strcasecmp(v->name, "height")) {
            /* Allow the user to lower the expected display lines on the phone
             * For example the Nortel i2001 and i2002 only have one ! */
            d->height = atoi(v->value);
        } else
            ast_log(LOG_WARNING, "Don't know keyword '%s' at line %d\n", v->name,
                    v->lineno);
        v = v->next;
    }
    ast_free(lt);
    if (linecnt == 0) {
        ast_log(LOG_ERROR, "An Unistim device must have at least one line!\n");
        ast_free(d);
        return NULL;
    }
    d->ringvolume = ringvolume;
    d->ringstyle = ringstyle;
    d->cwvolume = cwvolume;
    d->cwstyle = cwstyle;
    d->callhistory = callhistory;
    d->sharp_dial = sharpdial;
    d->tz = ast_get_indication_zone(d->country);
    if ((d->tz == NULL) && !ast_strlen_zero(d->country)) {
        ast_log(LOG_WARNING, "Country '%s' was not found in indications.conf\n",
                d->country);
    }
    d->datetimeformat = 48 + (dateformat * 4);
    d->datetimeformat += timeformat;
    if ((autoprovisioning == AUTOPROVISIONING_TN) &&
        (!ast_strlen_zero(d->extension_number))) {
        d->extension = EXTENSION_TN;
        if (!ast_strlen_zero(d->id)) {
            ast_log(LOG_WARNING,
                    "tn= and device= can't be used together. Ignoring device= entry\n");
        }
        d->id[0] = 'T';      /* magic : this is a tn entry */
        ast_copy_string((d->id) + 1, d->extension_number, sizeof(d->id) - 1);
        d->extension_number[0] = '\0';
    } else if (ast_strlen_zero(d->id)) {
        if (strcmp(d->name, "template")) {
            ast_log(LOG_ERROR, "You must specify the mac address with device=\n");
            if (d->tz) {
                d->tz = ast_tone_zone_unref(d->tz);
            }
            ast_free(d);
            return NULL;
        } else {
            strcpy(d->id, "000000000000");
        }
    }
    if (!d->rtp_port) {
        d->rtp_port = 10000;
    }
    if (d->contrast == -1) {
        d->contrast = 8;
    }
    if (ast_strlen_zero(d->maintext1)) {
        strcpy(d->maintext1, d->name);
    }
    if (ast_strlen_zero(d->titledefault)) {
        struct ast_tm tm = { 0, };
        struct timeval cur_time = ast_tvnow();
 
        if ((ast_localtime(&cur_time, &tm, 0)) == 0 || ast_strlen_zero(tm.tm_zone)) {
            ast_log(LOG_WARNING, "Error in ast_localtime()\n");
            ast_copy_string(d->titledefault, "UNISTIM for*", 12);
        } else {
            if (strlen(tm.tm_zone) < 4) {
                strcpy(d->titledefault, "TimeZone ");
                strcat(d->titledefault, tm.tm_zone);
            } else if (strlen(tm.tm_zone) < 9) {
                strcpy(d->titledefault, "TZ ");
                strcat(d->titledefault, tm.tm_zone);
            } else {
                ast_copy_string(d->titledefault, tm.tm_zone, 12);
            }
        }
    }
    /* Update the chained link if it's a new device */
    if (create) {
        ast_mutex_lock(&devicelock);
        d->next = devices;
        devices = d;
        ast_mutex_unlock(&devicelock);
        ast_verb(3, "Added device '%s'\n", d->name);
    } else {
        ast_verb(3, "Device '%s' reloaded\n", d->name);
    }
    return d;
}

References ast_append_ha(), ast_calloc, ast_channel_string2amaflag(), ast_copy_string(), ast_format_cap_append_from_cap(), ast_free, ast_get_group(), ast_get_indication_zone(), AST_LIST_INSERT_TAIL, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_localtime(), ast_log, AST_MAX_EXTENSION, AST_MEDIA_TYPE_UNKNOWN, ast_mutex_init, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), ast_tone_zone_unref(), ast_true(), ast_tvnow(), ast_verb, autoprovisioning, AUTOPROVISIONING_TN, unistim_line::cap, d, dateformat, DEFAULT_INTERDIGIT_TIMER, DEFAULTCONTEXT, DEFAULTHEIGHT, delete_device(), devicelock, devices, EXTENSION_ASK, EXTENSION_LINE, EXTENSION_NONE, EXTENSION_TN, FAV_ICON_NONE, FAV_LINE_ICON, find_line_by_number(), unistim_line::fullname, global_cap, len(), ast_variable::lineno, unistim_line::list, unistim_line::lock, LOG_ERROR, LOG_WARNING, unistim_line::mailbox, MUTE_OFF, unistim_line::name, ast_variable::name, test_val::name, ast_variable::next, test_val::next, NULL, OUTPUT_HANDSET, unistim_line::parent, parse_bookmark(), ast_tm::tm_zone, unistim_line_alloc(), unistim_line_destroy(), unistimdebug, unistimsock, unquote(), ast_variable::value, and VOLUME_LOW.

Referenced by reload_config().

◆ change_callerid()

void change_callerid	(	struct unistimsession *	pte,
		int	type,
		char *	callerid
	)

static

Definition at line 2472 of file chan_unistim.c.

{
    char *data;
    int size;
 
    if (type) {
        data = pte->device->lst_cnm;
    } else {
        data = pte->device->lst_cid;
    }
 
    /* This is very nearly strncpy(), except that the remaining buffer
     * is padded with ' ', instead of '\0' */
    memset(data, ' ', TEXT_LENGTH_MAX);
    size = strlen(callerid);
    if (size > TEXT_LENGTH_MAX) {
        size = TEXT_LENGTH_MAX;
    }
    memcpy(data, callerid, size);
}

References unistimsession::device, unistim_device::lst_cid, unistim_device::lst_cnm, TEXT_LENGTH_MAX, and type.

Referenced by close_call(), and send_callerid_screen().

◆ change_favorite_icon()

static void change_favorite_icon	(	struct unistimsession *	pte,
		unsigned char	status
	)

static

Definition at line 1418 of file chan_unistim.c.

{
    struct unistim_device *d = devices;
    int i;
    /* Update the current phone line softkey icon */
    if (pte->state != STATE_CLEANING) {
        int softkeylinepos = get_active_softkey(pte);
        if (softkeylinepos != -1) {
            send_favorite_short(softkeylinepos, status, pte);
        }
    }
    /* Notify other phones if we're in their bookmark */
    while (d) {
        for (i = 0; i < FAVNUM; i++) {
            if (d->sp[i] == pte->device) {  /* It's us ? */
                if (d->softkeyicon[i] != status) {      /* Avoid resending the same icon */
                    d->softkeyicon[i] = status;
                    if (d->session) {
                        send_favorite(i, status + 1, d->session, d->softkeylabel[i]);
                    }
                }
            }
        }
        d = d->next;
    }
}

References d, unistimsession::device, devices, FAVNUM, get_active_softkey(), test_val::next, send_favorite(), send_favorite_short(), unistimsession::state, STATE_CLEANING, and status.

Referenced by close_client(), handle_dial_page(), send_select_output(), show_main_page(), and unistim_call().

◆ channel_to_session()

static struct unistimsession * channel_to_session ( struct ast_channel * ast )

static

Definition at line 4794 of file chan_unistim.c.

{
    struct unistim_subchannel *sub;
    if (!ast) {
        ast_log(LOG_WARNING, "Unistim callback function called with a null channel\n");
        return NULL;
    }
    if (!ast_channel_tech_pvt(ast)) {
        ast_log(LOG_WARNING, "Unistim callback function called without a tech_pvt\n");
        return NULL;
    }
    sub = ast_channel_tech_pvt(ast);
 
    if (!sub->parent) {
        ast_log(LOG_WARNING, "Unistim callback function called without a line\n");
        return NULL;
    }
    if (!sub->parent->parent) {
        ast_log(LOG_WARNING, "Unistim callback function called without a device\n");
        return NULL;
    }
    ast_mutex_lock(&sub->parent->parent->lock);
    if (!sub->parent->parent->session) {
        ast_log(LOG_WARNING, "Unistim callback function called without a session\n");
        ast_mutex_unlock(&sub->parent->parent->lock);
        return NULL;
    }
    ast_mutex_unlock(&sub->parent->parent->lock);
    return sub->parent->parent->session;
}

References ast_channel_tech_pvt(), ast_log, ast_mutex_lock, ast_mutex_unlock, LOG_WARNING, NULL, and sub.

Referenced by unistim_answer(), unistim_call(), unistim_hangup(), unistim_indicate(), unistim_senddigit_begin(), unistim_senddigit_end(), and unistim_sendtext().

◆ check_send_queue()

static void check_send_queue ( struct unistimsession * pte )

static

Definition at line 1101 of file chan_unistim.c.

{
    /* Check if our send queue contained only one element */
    if (pte->last_buf_available == 1) {
        if (unistimdebug) {
            ast_verb(0, "Our single packet was ACKed.\n");
        }
        pte->last_buf_available--;
        set_ping_timer(pte);
        return;
    }
    /* Check if this ACK catch up our latest packet */
    else if (pte->last_seq_ack + 1 == pte->seq_server + 1) {
        if (unistimdebug) {
            ast_verb(0, "Our send queue is completely ACKed.\n");
        }
        pte->last_buf_available = 0;    /* Purge the send queue */
        set_ping_timer(pte);
        return;
    }
    if (unistimdebug) {
        ast_verb(0, "We still have packets in our send queue\n");
    }
    return;
}

References ast_verb, unistimsession::last_buf_available, unistimsession::last_seq_ack, unistimsession::seq_server, set_ping_timer(), and unistimdebug.

Referenced by parsing().

◆ close_call()

static void close_call ( struct unistimsession * pte )

static

Definition at line 2599 of file chan_unistim.c.

{
    struct unistim_subchannel *sub, *sub_transf;
 
    sub = get_sub(pte->device, SUB_REAL);
    sub_transf = get_sub(pte->device, SUB_THREEWAY);
    send_stop_timer(pte);
    if (!sub) {
        ast_log(LOG_WARNING, "Close call without sub\n");
        return;
    }
    send_favorite_short(sub->softkey, FAV_LINE_ICON, pte);
    if (sub->owner) {
        sub->alreadygone = 1;
        if (sub_transf) {
            sub_transf->alreadygone = 1;
            if (attempt_transfer(sub, sub_transf) < 0) {
                ast_verb(0, "attempt_transfer failed.\n");
            }
        } else {
            ast_queue_hangup(sub->owner);
        }
    } else {
        if (sub_transf) {
            if (sub_transf->owner) {
                ast_queue_hangup_with_cause(sub_transf->owner, AST_CAUSE_NORMAL_CLEARING);
            } else {
                ast_log(LOG_WARNING, "threeway sub without owner\n");
            }
        } else {
            ast_verb(0, "USTM(%s@%s-%d) channel already destroyed\n", sub->parent->name,
                        pte->device->name, sub->softkey);
        }
    }
    change_callerid(pte, 0, pte->device->redial_number);
    change_callerid(pte, 1, "");
    write_history(pte, 'o', pte->device->missed_call);
    pte->device->missed_call = 0;
    show_main_page(pte);
    return;
}

References unistim_subchannel::alreadygone, AST_CAUSE_NORMAL_CLEARING, ast_log, ast_queue_hangup(), ast_queue_hangup_with_cause(), ast_verb, attempt_transfer(), change_callerid(), unistimsession::device, FAV_LINE_ICON, get_sub(), LOG_WARNING, unistim_device::missed_call, unistim_device::name, unistim_subchannel::owner, unistim_device::redial_number, send_favorite_short(), send_stop_timer(), show_main_page(), sub, SUB_REAL, SUB_THREEWAY, and write_history().

Referenced by key_call(), process_request(), and unistim_hangup().

◆ close_client()

static void close_client ( struct unistimsession * s )

static

Definition at line 1470 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = NULL;
    struct unistimsession *cur, *prev = NULL;
    ast_mutex_lock(&sessionlock);
    cur = sessions;
    /* Looking for the session in the linked chain */
    while (cur) {
        if (cur == s) {
            break;
        }
        prev = cur;
        cur = cur->next;
    }
    if (cur) {                    /* Session found ? */
        if (cur->device) {        /* This session was registered ? */
            s->state = STATE_CLEANING;
            if (unistimdebug) {
                ast_verb(0, "close_client session %p device %p\n", s, s->device);
            }
            change_favorite_icon(s, FAV_ICON_NONE);
            ast_mutex_lock(&s->device->lock);
            AST_LIST_LOCK(&s->device->subs);
            AST_LIST_TRAVERSE_SAFE_BEGIN(&s->device->subs, sub, list) {
                if (!sub) {
                    continue;
                }
                if (sub->owner) {       /* Call in progress ? */
                    if (unistimdebug) {
                        ast_verb(0, "Aborting call\n");
                    }
                    ast_queue_hangup_with_cause(sub->owner, AST_CAUSE_NETWORK_OUT_OF_ORDER);
                } else {
                    if (unistimdebug) {
                        ast_debug(1, "Released sub %u of channel %s@%s\n", sub->subtype, sub->parent->name, s->device->name);
                    }
                    AST_LIST_REMOVE_CURRENT(list);
                    unistim_free_sub(sub);
                }
            }
            AST_LIST_TRAVERSE_SAFE_END;
            AST_LIST_UNLOCK(&s->device->subs);
 
            if (!ast_strlen_zero(s->device->extension_number)) {
                unregister_extension(s);
            }
            cur->device->session = NULL;
            ast_mutex_unlock(&s->device->lock);
        } else {
            if (unistimdebug) {
                ast_verb(0, "Freeing an unregistered client\n");
            }
        }
        if (prev) {
            prev->next = cur->next;
        } else {
            sessions = cur->next;
        }
        ast_mutex_destroy(&s->lock);
        ast_free(s);
    } else {
        ast_log(LOG_WARNING, "Trying to delete non-existent session %p?\n", s);
    }
    ast_mutex_unlock(&sessionlock);
    return;
}

References AST_CAUSE_NETWORK_OUT_OF_ORDER, ast_debug, ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_queue_hangup_with_cause(), ast_strlen_zero(), ast_verb, change_favorite_icon(), unistimsession::device, unistim_device::extension_number, FAV_ICON_NONE, unistim_device::lock, unistimsession::lock, LOG_WARNING, unistim_device::name, unistimsession::next, NULL, unistim_device::session, sessionlock, sessions, unistimsession::state, STATE_CLEANING, sub, unistim_device::subs, unistim_free_sub(), unistimdebug, and unregister_extension().

Referenced by parsing(), and send_retransmit().

◆ control2str()

static char * control2str ( int ind )

static

Definition at line 5279 of file chan_unistim.c.

{
    switch (ind) {
    case AST_CONTROL_HANGUP:
        return "Other end has hungup";
    case AST_CONTROL_RING:
        return "Local ring";
    case AST_CONTROL_RINGING:
        return "Remote end is ringing";
    case AST_CONTROL_ANSWER:
        return "Remote end has answered";
    case AST_CONTROL_BUSY:
        return "Remote end is busy";
    case AST_CONTROL_TAKEOFFHOOK:
        return "Make it go off hook";
    case AST_CONTROL_OFFHOOK:
        return "Line is off hook";
    case AST_CONTROL_CONGESTION:
        return "Congestion (circuits busy)";
    case AST_CONTROL_FLASH:
        return "Flash hook";
    case AST_CONTROL_WINK:
        return "Wink";
    case AST_CONTROL_OPTION:
        return "Set a low-level option";
    case AST_CONTROL_RADIO_KEY:
        return "Key Radio";
    case AST_CONTROL_RADIO_UNKEY:
        return "Un-Key Radio";
    case AST_CONTROL_CONNECTED_LINE:
        return "Remote end changed";
    case AST_CONTROL_SRCCHANGE:
        return "RTP source updated";
    case AST_CONTROL_SRCUPDATE:
        return "Source of media changed";
    case -1:
        return "Stop tone";
    }
    return "UNKNOWN";
}

References AST_CONTROL_ANSWER, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_CONNECTED_LINE, AST_CONTROL_FLASH, AST_CONTROL_HANGUP, AST_CONTROL_OFFHOOK, AST_CONTROL_OPTION, AST_CONTROL_RADIO_KEY, AST_CONTROL_RADIO_UNKEY, AST_CONTROL_RING, AST_CONTROL_RINGING, AST_CONTROL_SRCCHANGE, AST_CONTROL_SRCUPDATE, AST_CONTROL_TAKEOFFHOOK, and AST_CONTROL_WINK.

Referenced by unistim_indicate().

◆ create_client()

static struct unistimsession * create_client ( const struct sockaddr_in * addr_from )

static

Definition at line 1046 of file chan_unistim.c.

{
    int tmp;
    struct unistimsession *s;
 
    if (!(s = ast_calloc(1, sizeof(*s))))
        return NULL;
 
    memcpy(&s->sin, addr_from, sizeof(struct sockaddr_in));
    if (get_to_address(unistimsock, &s->sout) < 0) {
        ast_free(s);
        return NULL;
    }
    s->sout.sin_family = AF_INET;
    if (unistimdebug) {
        ast_verb(0, "Creating a new entry for the phone from %s received via server ip %s\n",
             ast_inet_ntoa(addr_from->sin_addr), ast_inet_ntoa(s->sout.sin_addr));
    }
    ast_mutex_init(&s->lock);
    ast_mutex_lock(&sessionlock);
    s->next = sessions;
    sessions = s;
 
    s->timeout = get_tick_count() + RETRANSMIT_TIMER;
    s->state = STATE_INIT;
    s->tick_next_ping = get_tick_count() + unistim_keepalive;
    /* Initialize struct wsabuf  */
    for (tmp = 0; tmp < MAX_BUF_NUMBER; tmp++) {
        s->wsabufsend[tmp].buf = s->buf[tmp];
    }
    ast_mutex_unlock(&sessionlock);
    return s;
}

References ast_calloc, ast_free, ast_inet_ntoa(), ast_mutex_init, ast_mutex_lock, ast_mutex_unlock, ast_verb, wsabuf::buf, unistimsession::buf, get_tick_count(), get_to_address(), unistimsession::lock, MAX_BUF_NUMBER, unistimsession::next, NULL, RETRANSMIT_TIMER, sessionlock, sessions, unistimsession::sin, unistimsession::sout, unistimsession::state, STATE_INIT, unistimsession::tick_next_ping, unistimsession::timeout, tmp(), unistim_keepalive, unistimdebug, unistimsock, and unistimsession::wsabufsend.

Referenced by parsing().

◆ delete_device()

static void delete_device ( struct unistim_device * d )

static

Definition at line 6422 of file chan_unistim.c.

{
    struct unistim_line *l;
    struct unistim_subchannel *sub;
    struct unistimsession *s;
 
    if (unistimdebug) {
        ast_verb(0, "Removing device '%s'\n", d->name);
    }
    AST_LIST_LOCK(&d->subs);
    AST_LIST_TRAVERSE_SAFE_BEGIN(&d->subs, sub, list){
        if (sub->subtype == SUB_REAL) {
            if (sub->owner) {
                ast_log(LOG_WARNING,
                        "Device '%s' was not deleted : a call is in progress. Try again later.\n",
                        d->name);
                AST_LIST_UNLOCK(&d->subs);
                return;
            }
        }
        if (sub->subtype == SUB_THREEWAY) {
            ast_log(LOG_WARNING,
                    "Device '%s' with threeway call subchannels allocated, aborting.\n",
                    d->name);
            AST_LIST_UNLOCK(&d->subs);
            return;
        }
        AST_LIST_REMOVE_CURRENT(list);
        ast_mutex_destroy(&sub->lock);
        ast_free(sub);
    }
    AST_LIST_TRAVERSE_SAFE_END
    AST_LIST_UNLOCK(&d->subs);
 
 
    AST_LIST_LOCK(&d->lines);
    AST_LIST_TRAVERSE_SAFE_BEGIN(&d->lines, l, list){
        AST_LIST_REMOVE_CURRENT(list);
        ast_mutex_destroy(&l->lock);
        unistim_line_destroy(l);
    }
    AST_LIST_TRAVERSE_SAFE_END
    AST_LIST_UNLOCK(&d->lines);
 
    if (d->session) {
        if (sessions == d->session) {
            sessions = d->session->next;
        } else {
            s = sessions;
            while (s) {
                if (s->next == d->session) {
                    s->next = d->session->next;
                    break;
                }
                s = s->next;
            }
        }
        ast_mutex_destroy(&d->session->lock);
        ast_free(d->session);
    }
    if (devices == d) {
        devices = d->next;
    } else {
        struct unistim_device *d2 = devices;
        while (d2) {
            if (d2->next == d) {
                d2->next = d->next;
                break;
            }
            d2 = d2->next;
        }
    }
    if (d->tz) {
        d->tz = ast_tone_zone_unref(d->tz);
    }
    ast_mutex_destroy(&d->lock);
    ast_free(d);
}

References ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, ast_mutex_destroy, ast_tone_zone_unref(), ast_verb, d, devices, unistim_line::lock, LOG_WARNING, test_val::name, unistim_device::next, unistimsession::next, test_val::next, sessions, sub, SUB_REAL, SUB_THREEWAY, unistim_line_destroy(), and unistimdebug.

Referenced by build_device(), and reload_config().

◆ discard_call()

static void discard_call ( struct unistimsession * pte )

static

Definition at line 2647 of file chan_unistim.c.

{
    struct unistim_subchannel* sub;
    sub = get_sub(pte->device, SUB_RING);
    if (!sub) {
        return;
    }
 
    ast_queue_hangup_with_cause(sub->owner, AST_CAUSE_NORMAL_CLEARING);
    return;
}

References AST_CAUSE_NORMAL_CLEARING, ast_queue_hangup_with_cause(), unistimsession::device, get_sub(), sub, and SUB_RING.

Referenced by key_ringing().

◆ display_last_error()

static void display_last_error ( const char * sz_msg )

static

Definition at line 889 of file chan_unistim.c.

{
    /* Display the error message */
    ast_log(LOG_WARNING, "%s : (%d) %s\n", sz_msg, errno, strerror(errno));
}

References ast_log, errno, and LOG_WARNING.

Referenced by key_history(), open_history(), send_raw_client(), show_entry_history(), write_entry_history(), and write_history().

◆ do_monitor()

static void * do_monitor ( void * data )

static

Definition at line 5835 of file chan_unistim.c.

{
    struct unistimsession *cur = NULL;
    unsigned int dw_timeout = 0;
    unsigned int tick;
    int res;
    int reloading;
 
    /* Add an I/O event to our UDP socket */
    if (unistimsock > -1) {
        ast_io_add(io, unistimsock, unistimsock_read, AST_IO_IN, NULL);
    }
    /* This thread monitors our UDP socket and timers */
    for (;;) {
        /* This loop is executed at least every IDLE_WAITus (1s) or every time a packet is received */
        /* Looking for the smallest time-out value */
        tick = get_tick_count();
        dw_timeout = UINT_MAX;
        ast_mutex_lock(&sessionlock);
        cur = sessions;
        DEBUG_TIMER("checking timeout for session %p with tick = %u\n", cur, tick);
        while (cur) {
            DEBUG_TIMER("checking timeout for session %p timeout = %u\n", cur,
                        cur->timeout);
            /* Check if we have miss something */
            if (cur->timeout <= tick) {
                DEBUG_TIMER("Event for session %p\n", cur);
                /* If the queue is empty, send a ping */
                if (cur->last_buf_available == 0) {
                    send_ping(cur);
                } else {
                    if (send_retransmit(cur)) {
                        DEBUG_TIMER("The chained link was modified, restarting...\n");
                        cur = sessions;
                        dw_timeout = UINT_MAX;
                        continue;
                    }
                }
            }
            if (dw_timeout > cur->timeout - tick) {
                dw_timeout = cur->timeout - tick;
            }
            /* Checking if the phone is logged on for a new MWI */
            if (cur->device) {
                struct unistim_line *l;
                AST_LIST_LOCK(&cur->device->lines);
                AST_LIST_TRAVERSE(&cur->device->lines, l, list) {
                    if ((!ast_strlen_zero(l->mailbox)) && (tick >= l->parent->nextmsgcheck)) {
                        DEBUG_TIMER("Checking mailbox for MWI\n");
                        unistim_send_mwi_to_peer(l, tick);
                        break;
                    }
                }
                AST_LIST_UNLOCK(&cur->device->lines);
                if (cur->device->nextdial && tick >= cur->device->nextdial) {
                    handle_call_outgoing(cur);
                    cur->device->nextdial = 0;
                }
            }
            cur = cur->next;
        }
        ast_mutex_unlock(&sessionlock);
        DEBUG_TIMER("Waiting for %dus\n", dw_timeout);
        res = dw_timeout;
        /* We should not wait more than IDLE_WAIT */
        if ((res < 0) || (res > IDLE_WAIT)) {
            res = IDLE_WAIT;
        }
        /* Wait for UDP messages for a maximum of res us */
        res = ast_io_wait(io, res);     /* This function will call unistimsock_read if a packet is received */
        /* Check for a reload request */
        ast_mutex_lock(&unistim_reload_lock);
        reloading = unistim_reloading;
        unistim_reloading = 0;
        ast_mutex_unlock(&unistim_reload_lock);
        if (reloading) {
            ast_verb(1, "Reloading unistim.conf...\n");
            reload_config();
        }
        pthread_testcancel();
    }
    /* Never reached */
    return NULL;
}

References ast_io_add(), AST_IO_IN, ast_io_wait(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_mutex_lock, ast_mutex_unlock, ast_strlen_zero(), ast_verb, DEBUG_TIMER, unistimsession::device, get_tick_count(), handle_call_outgoing(), IDLE_WAIT, io, unistimsession::last_buf_available, unistim_device::lines, unistim_line::list, unistim_line::mailbox, unistimsession::next, unistim_device::nextdial, unistim_device::nextmsgcheck, NULL, unistim_line::parent, reload_config(), send_ping(), send_retransmit(), sessionlock, sessions, unistimsession::timeout, unistim_reload_lock, unistim_reloading, unistim_send_mwi_to_peer(), unistimsock, and unistimsock_read().

Referenced by restart_monitor().

◆ dummy()

static void dummy	(	char *	unused,
			...
	)

static

Definition at line 220 of file chan_unistim.c.

{
    return;
}

Referenced by ast_fdisset(), cc_request_state_change(), custom_log(), manager_log(), ooh323c_call_thread(), ooh323c_cmd_thread(), ooh323c_stack_thread(), packsms16(), packsms7(), packsms8(), parse_args(), write_cdr(), and write_cel().

◆ find_language()

static int find_language ( const char * lang )

static

Definition at line 3807 of file chan_unistim.c.

{
    int i = 0;
    while (options_languages[i].lang_short != NULL) {
        if(!strcmp(options_languages[i].lang_short, lang)) {
            return i;
        }
        i++;
    }
    return 0;
}

References NULL, and options_languages.

Referenced by handle_select_language(), init_phone_step2(), reload_config(), send_charset_update(), and ustmtext().

◆ find_line_by_number()

static struct unistim_line * find_line_by_number	(	struct unistim_device *	d,
		const char *	val
	)

static

Definition at line 6408 of file chan_unistim.c.

                                                                                           {
    struct unistim_line *l, *ret = NULL;
 
    AST_LIST_LOCK(&d->lines);
    AST_LIST_TRAVERSE(&d->lines, l, list) {
        if (!strcmp(l->name, val)) {
            ret = l;
            break;
        }
    }
    AST_LIST_UNLOCK(&d->lines);
    return ret;
}

References AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, d, unistim_line::list, unistim_line::name, and NULL.

Referenced by build_device().

◆ find_rtp_port()

static int find_rtp_port ( struct unistim_subchannel * s )

static

Definition at line 2685 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = NULL;
    int rtp_start = s->parent->parent->rtp_port;
    struct ast_sockaddr us_tmp;
    struct sockaddr_in us = { 0, };
 
    AST_LIST_LOCK(&s->parent->parent->subs);
    AST_LIST_TRAVERSE(&s->parent->parent->subs, sub, list) {
        if (!sub) {
            continue;
        }
        if (sub->rtp) {
            ast_rtp_instance_get_remote_address(sub->rtp, &us_tmp);
            ast_sockaddr_to_sin(&us_tmp, &us);
            if (htons(us.sin_port)) {
                rtp_start = htons(us.sin_port) + 1;
                break;
            }
        }
    }
    AST_LIST_UNLOCK(&s->parent->parent->subs);
    return rtp_start;
}

References AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_rtp_instance_get_remote_address, ast_sockaddr_to_sin, NULL, unistim_subchannel::parent, unistim_line::parent, unistim_device::rtp_port, sub, and unistim_device::subs.

Referenced by start_rtp().

◆ find_subchannel_by_name()

static struct unistim_subchannel * find_subchannel_by_name ( const char * dest )

static

Definition at line 5421 of file chan_unistim.c.

{
    struct unistim_line *l;
    struct unistim_device *d;
    struct unistim_subchannel *sub = NULL;
    char line[256];
    char *at;
    char *device;
 
    ast_copy_string(line, dest, sizeof(line));
    at = strchr(line, '@');
    if (!at) {
        ast_log(LOG_NOTICE, "Device '%s' has no @ (at) sign!\n", dest);
        return NULL;
    }
    *at = '\0';
    at++;
    device = at;
    ast_mutex_lock(&devicelock);
    d = devices;
    at = strchr(device, '/');       /* Extra options ? */
    if (at) {
        *at = '\0';
    }
    while (d) {
        if (!strcasecmp(d->name, device)) {
            if (unistimdebug) {
                ast_verb(0, "Found device: %s\n", d->name);
            }
            /* Found the device */
            AST_LIST_LOCK(&d->lines);
            AST_LIST_TRAVERSE(&d->lines, l, list) {
                /* Search for the right line */
                if (!strcasecmp(l->name, line)) {
                    if (unistimdebug) {
                        ast_verb(0, "Found line: %s\n", l->name);
                    }
                    sub = get_sub(d, SUB_REAL);
                    if (!sub) {
                        sub = unistim_alloc_sub(d, SUB_REAL);
                    }
                    if (sub->owner) {
                        /* Allocate additional channel if asterisk channel already here */
                        sub = unistim_alloc_sub(d, SUB_REAL);
                        sub->holding = 1;
                    }
                    sub->ringvolume = -1;
                    sub->ringstyle = -1;
                    if (at) {       /* Other options ? */
                        at++;   /* Skip slash */
                        if (*at == 'r') {       /* distinctive ring */
                            at++;
                            if ((*at < '0') || (*at > '7')) { /* ring style */
                                ast_log(LOG_WARNING, "Invalid ring selection (%s)", at);
                            } else {
                                signed char ring_volume = -1;
                                signed char ring_style = *at - '0';
                                at++;
                                if ((*at >= '0') && (*at <= '3')) {      /* ring volume */
                                    ring_volume = *at - '0';
                                }
                                if (unistimdebug) {
                                    ast_verb(0, "Distinctive ring: style #%d volume %d\n",
                                         ring_style, ring_volume);
                                }
                                sub->ringvolume = ring_volume;
                                sub->ringstyle = ring_style;
                            }
                        }
                    }
                    sub->parent = l;
                    break;
                }
            }
            AST_LIST_UNLOCK(&d->lines);
            if (sub) {
                ast_mutex_unlock(&devicelock);
                return sub;
            }
        }
        d = d->next;
    }
    /* Device not found */
    ast_mutex_unlock(&devicelock);
 
    return NULL;
}

References ast_copy_string(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_verb, d, devicelock, devices, get_sub(), unistim_subchannel::list, LOG_NOTICE, LOG_WARNING, unistim_line::name, test_val::name, test_val::next, NULL, sub, SUB_REAL, unistim_alloc_sub(), and unistimdebug.

Referenced by unistim_request(), and unistim_sp().

◆ finish_bookmark()

static void finish_bookmark ( void )

static

Definition at line 6380 of file chan_unistim.c.

{
    struct unistim_device *d = devices;
    int i;
    ast_mutex_lock(&devicelock);
    while (d) {
        for (i = 0; i < 6; i++) {
            if (d->softkeyicon[i] == 1) {   /* Something for us */
                struct unistim_device *d2 = devices;
                while (d2) {
                    if (!strcmp(d->softkeydevice[i], d2->name)) {
                        d->sp[i] = d2;
                        d->softkeyicon[i] = 0;
                        break;
                    }
                    d2 = d2->next;
                }
                if (d->sp[i] == NULL) {
                    ast_log(LOG_NOTICE, "Bookmark entry with device %s not found\n",
                            d->softkeydevice[i]);
                }
            }
        }
        d = d->next;
    }
    ast_mutex_unlock(&devicelock);
}

References ast_log, ast_mutex_lock, ast_mutex_unlock, d, devicelock, devices, LOG_NOTICE, unistim_device::name, unistim_device::next, test_val::next, and NULL.

Referenced by reload_config().

◆ get_active_softkey()

static int get_active_softkey ( struct unistimsession * pte )

static

Definition at line 1380 of file chan_unistim.c.

{
    return pte->device->selected;
}

References unistimsession::device, and unistim_device::selected.

Referenced by change_favorite_icon().

◆ get_avail_softkey()

static int get_avail_softkey	(	struct unistimsession *	pte,
		const char *	name
	)

static

Definition at line 1385 of file chan_unistim.c.

{
    int i;
 
    if (!is_key_line(pte->device, pte->device->selected)) {
        pte->device->selected = -1;
    }
    for (i = 0; i < FAVNUM; i++) {
        if (pte->device->selected != -1 && pte->device->selected != i) {
            continue;
        }
        if (!soft_key_visible(pte->device, i)) {
            continue;
        }
        if (pte->device->ssub[i]) {
            continue;
        }
        if (is_key_line(pte->device, i)) {
            if (name && strcmp(name, pte->device->sline[i]->name)) {
                continue;
            }
            if (unistimdebug) {
                ast_verb(0, "Found softkey %d for device %s\n", i, name);
            }
            return i;
        }
    }
    return -1;
}

References ast_verb, unistimsession::device, FAVNUM, is_key_line(), unistim_line::name, name, unistim_device::selected, unistim_device::sline, soft_key_visible(), unistim_device::ssub, and unistimdebug.

Referenced by handle_call_outgoing(), key_main_page(), process_request(), and unistim_request().

◆ get_sub()

static struct unistim_subchannel * get_sub	(	struct unistim_device *	device,
		int	type
	)

static

Definition at line 2493 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = NULL;
 
    AST_LIST_LOCK(&device->subs);
    AST_LIST_TRAVERSE(&device->subs, sub, list) {
        if (!sub) {
            continue;
        }
        if (sub->subtype == type) {
            break;
        }
    }
    AST_LIST_UNLOCK(&device->subs);
 
    return sub;
}

References AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, unistim_subchannel::list, NULL, sub, unistim_device::subs, and type.

Referenced by close_call(), discard_call(), find_subchannel_by_name(), handle_call_incoming(), handle_call_outgoing(), key_call(), key_dial_page(), sub_unhold(), transfer_call_step1(), transfer_cancel_step2(), unistim_answer(), unistim_call(), unistim_do_senddigit(), unistim_hangup(), and unistim_request().

◆ get_sub_holding()

static struct unistim_subchannel * get_sub_holding	(	struct unistim_device *	device,
		int	type,
		int	holding
	)

static

Definition at line 2511 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = NULL;
 
    AST_LIST_LOCK(&device->subs);
    AST_LIST_TRAVERSE(&device->subs, sub, list) {
        if (!sub) {
            continue;
        }
        if (sub->subtype == type && sub->holding == holding) {
            break;
        }
    }
    AST_LIST_UNLOCK(&device->subs);
 
    return sub;
}

References AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, unistim_subchannel::holding, unistim_subchannel::list, NULL, sub, unistim_device::subs, and type.

Referenced by handle_key_fav().

◆ get_tick_count()

static unsigned int get_tick_count ( void )

static

Definition at line 895 of file chan_unistim.c.

{
    struct timeval now = ast_tvnow();
 
    return (now.tv_sec * 1000) + (now.tv_usec / 1000);
}

References ast_tvnow().

Referenced by create_client(), do_monitor(), key_dial_page(), send_client(), send_ping(), and send_retransmit().

◆ get_to_address()

static int get_to_address	(	int	fd,
		struct sockaddr_in *	toAddr
	)

static

Definition at line 1002 of file chan_unistim.c.

{
#ifdef HAVE_PKTINFO
    int err;
    char cmbuf[0x100];
    struct cmsghdr *cmsg;
    struct sockaddr_in peeraddr;
    struct in_addr addr;
    struct msghdr mh = {
        .msg_name = &peeraddr,
        .msg_namelen = sizeof(peeraddr),
        .msg_control = cmbuf,
        .msg_controllen = sizeof(cmbuf),
    };
    memset(&addr, 0, sizeof(addr));
    /* Get info about the incoming packet */
    err = recvmsg(fd, &mh, MSG_PEEK);
    if (err == -1) {
        ast_log(LOG_WARNING, "recvmsg returned an error: %s\n", strerror(errno));
        return err;
    }
    for(cmsg = CMSG_FIRSTHDR(&mh);
        cmsg != NULL;
        cmsg = CMSG_NXTHDR(&mh, cmsg))
    {
         if (cmsg->cmsg_level == IPPROTO_IP && cmsg->cmsg_type == IP_PKTINFO) {
            struct in_pktinfo *pkt = (struct in_pktinfo*)CMSG_DATA(cmsg);
            addr = pkt->ipi_addr;
            if (unistimdebug) {
                ast_verb(0, "message received on address %s\n", ast_inet_ntoa(addr));
            }
        }
    }
    memcpy(&toAddr->sin_addr, &addr, sizeof(struct in_addr));
    return err;
#else
    memcpy(toAddr, &public_ip, sizeof(*toAddr));
    return 0;
#endif
}

References ast_inet_ntoa(), ast_log, ast_verb, errno, LOG_WARNING, NULL, public_ip, and unistimdebug.

Referenced by create_client().

◆ handle_call_incoming()

static void handle_call_incoming ( struct unistimsession * s )

static

Definition at line 3262 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = NULL;
    int i;
 
    s->state = STATE_CALL;
    s->device->missed_call = 0;
    send_no_ring(s);
    sub = get_sub(s->device, SUB_RING); /* Put other SUB_REAL call on hold */
    if (!sub) {
        ast_log(LOG_WARNING, "No ringing lines on: %s\n", s->device->name);
        return;
    }
    /* Change icons for all ringing keys */
    for (i = 0; i < FAVNUM; i++) {
        if (!s->device->ssub[i]) { /* No sub assigned - skip */
            continue;
        }
        if (s->device->ssub[i]->subtype == SUB_REAL) {
            sub_hold(s, s->device->ssub[i]);
        }
        if (s->device->ssub[i] != sub) {
            continue;
        }
        if (sub->softkey == i) { /* If softkey assigned at this moment - do not erase */
            continue;
        }
        if (sub->softkey < 0) { /* If softkey not defined - first one used */
            sub->softkey = i;
            continue;
        }
        send_favorite_short(i, FAV_LINE_ICON, s);
        s->device->ssub[i] = NULL;
    }
    if (sub->softkey < 0) {
        ast_log(LOG_WARNING, "Can not assign softkey for incoming call on: %s\n", s->device->name);
        return;
    }
    send_favorite_short(sub->softkey, FAV_ICON_OFFHOOK_BLACK, s);
    sub->parent = s->device->sline[sub->softkey];
    sub->subtype = SUB_REAL;
    if (unistimdebug) {
        ast_verb(0, "Handle Call Incoming for %s@%s\n", sub->parent->name,
                    s->device->name);
    }
    start_rtp(sub);
    if (!sub->rtp) {
        ast_log(LOG_WARNING, "Unable to create channel for %s@%s\n", sub->parent->name, s->device->name);
        return;
    }
    if (sub->owner) {
        ast_queue_control(sub->owner, AST_CONTROL_ANSWER);
    }
    send_text(TEXT_LINE2, TEXT_NORMAL, s, ustmtext("is on-line", s));
    send_text_status(s, ustmtext("       Transf        Hangup", s));
    send_start_timer(s);
 
    if ((s->device->output == OUTPUT_HANDSET) &&
        (s->device->receiver_state == STATE_ONHOOK)) {
        send_select_output(s, OUTPUT_SPEAKER, s->device->volume, MUTE_OFF);
    } else {
        send_select_output(s, s->device->output, s->device->volume, MUTE_OFF);
    }
    write_history(s, 'i', 0);
    return;
}

References AST_CONTROL_ANSWER, ast_log, ast_queue_control(), ast_verb, unistimsession::device, FAV_ICON_OFFHOOK_BLACK, FAV_LINE_ICON, FAVNUM, get_sub(), LOG_WARNING, unistim_device::missed_call, MUTE_OFF, unistim_device::name, NULL, unistim_device::output, OUTPUT_HANDSET, OUTPUT_SPEAKER, unistim_device::receiver_state, send_favorite_short(), send_no_ring(), send_select_output(), send_start_timer(), send_text(), send_text_status(), unistim_device::sline, unistim_device::ssub, start_rtp(), unistimsession::state, STATE_CALL, STATE_ONHOOK, sub, sub_hold(), SUB_REAL, SUB_RING, unistim_subchannel::subtype, TEXT_LINE2, TEXT_NORMAL, unistimdebug, ustmtext(), unistim_device::volume, and write_history().

Referenced by handle_key_fav(), key_ringing(), and process_request().

◆ handle_call_outgoing()

static void handle_call_outgoing ( struct unistimsession * s )

static

Definition at line 3111 of file chan_unistim.c.

{
    struct ast_channel *c;
    struct unistim_subchannel *sub;
    int softkey;
 
    s->state = STATE_CALL;
 
    sub = get_sub(s->device, SUB_THREEWAY);
    if (sub) {
        /* If sub for threway call created than we use transfer behavior */
        struct unistim_subchannel *sub_trans = NULL;
        struct unistim_device *d = s->device;
 
        sub_trans = get_sub(d, SUB_REAL);
        if (sub_trans) {
            ast_log(LOG_WARNING, "Can't transfer while active subchannel exists!\n");
            return;
        }
        if (!sub->owner) {
            ast_log(LOG_WARNING, "Unable to find subchannel with music on hold\n");
            return;
        }
 
        sub_trans = unistim_alloc_sub(d, SUB_REAL);
        if (!sub_trans) {
            ast_log(LOG_WARNING, "Unable to allocate three-way subchannel\n");
            return;
        }
        sub_trans->parent = sub->parent;
        sub_stop_silence(s, sub);
        send_tone(s, 0, 0);
        /* Make new channel */
        c = unistim_new(sub_trans, AST_STATE_DOWN, NULL, NULL);
        if (!c) {
            ast_log(LOG_WARNING, "Cannot allocate new structure on channel %p\n", sub->parent);
            return;
        }
        /* Swap things around between the three-way and real call */
        swap_subs(sub, sub_trans);
        send_select_output(s, s->device->output, s->device->volume, MUTE_OFF);
        if (s->device->height == 1) {
            send_text(TEXT_LINE0, TEXT_NORMAL, s, s->device->phone_number);
        } else {
            send_text(TEXT_LINE0, TEXT_NORMAL, s, ustmtext("Calling (pre-transfer)", s));
            send_text(TEXT_LINE1, TEXT_NORMAL, s, s->device->phone_number);
            send_text(TEXT_LINE2, TEXT_NORMAL, s, ustmtext("Dialing...", s));
        }
        send_text_status(s, ustmtext("TransfrCancel", s));
 
        if (ast_pthread_create(&sub->ss_thread, NULL, unistim_ss, c)) {
            ast_log(LOG_WARNING, "Unable to start simple switch on channel %p\n", c);
            sub->ss_thread = AST_PTHREADT_NULL;
            ast_hangup(c);
            return;
        }
        if (unistimdebug) {
            ast_verb(0, "Started three way call on channel %p (%s) subchan %u\n",
                 sub_trans->owner, ast_channel_name(sub_trans->owner), sub_trans->subtype);
        }
        return;
    }
 
    softkey = get_avail_softkey(s, NULL);
    if (softkey == -1) {
        ast_log(LOG_WARNING, "Have no avail softkey for calling\n");
        return;
    }
    sub = get_sub(s->device, SUB_REAL);
    if (sub) { /* have already call assigned */
        sub_hold(s, sub); /* Need to put on hold */
    }
    if (!(sub = unistim_alloc_sub(s->device, SUB_REAL))) {
        ast_log(LOG_WARNING, "Unable to allocate subchannel!\n");
        return;
    }
    sub->parent = s->device->sline[softkey];
    s->device->ssub[softkey] = sub;
    sub->softkey = softkey;
 
    if (unistimdebug) {
        ast_verb(0, "Using softkey %d, line %p\n", sub->softkey, sub->parent);
    }
    send_favorite_short(sub->softkey, FAV_ICON_OFFHOOK_BLACK, s);
    s->device->selected = -1;
    if (!sub->owner) {            /* A call is already in progress ? */
        RAII_VAR(struct ast_features_pickup_config *, pickup_cfg, NULL, ao2_cleanup);
        const char *pickupexten;
 
        c = unistim_new(sub, AST_STATE_DOWN, NULL, NULL);   /* No, starting a new one */
        if (!sub->rtp) { /* Need to start RTP before calling ast_pbx_run */
            start_rtp(sub);
        }
        if (c) {
            ast_channel_lock(c);
            pickup_cfg = ast_get_chan_features_pickup_config(c);
            if (!pickup_cfg) {
                ast_log(LOG_ERROR, "Unable to retrieve pickup configuration options. Unable to detect call pickup extension\n");
                pickupexten = "";
            } else {
                pickupexten = ast_strdupa(pickup_cfg->pickupexten);
            }
            ast_channel_unlock(c);
        }
        if (c && !strcmp(s->device->phone_number, pickupexten)) {
            if (unistimdebug) {
                ast_verb(0, "Try to pickup in unistim_new\n");
            }
            send_text(TEXT_LINE0, TEXT_NORMAL, s, "");
            send_text_status(s, ustmtext("       Transf        Hangup", s));
            send_start_timer(s);
            if (ast_pickup_call(c)) {
                ast_log(LOG_NOTICE, "Nothing to pick up\n");
                ast_channel_hangupcause_set(c, AST_CAUSE_CALL_REJECTED);
            } else {
                ast_channel_hangupcause_set(c, AST_CAUSE_NORMAL_CLEARING);
            }
            ast_hangup(c);
            c = NULL;
                } else if (c) {
            send_select_output(s, s->device->output, s->device->volume, MUTE_OFF);
            send_tone(s, 0, 0); /* Dialing empty number should also stop dial tone */
            if (s->device->height == 1) {
                if (strlen(s->device->phone_number) > 0) {
                    send_text(TEXT_LINE0, TEXT_NORMAL, s, s->device->phone_number);
                } else {
                    send_text(TEXT_LINE0, TEXT_NORMAL, s, ustmtext("Calling...", s));
                }
            } else {
                send_text(TEXT_LINE0, TEXT_NORMAL, s, ustmtext("Calling :", s));
                send_text(TEXT_LINE1, TEXT_NORMAL, s, s->device->phone_number);
                send_text(TEXT_LINE2, TEXT_NORMAL, s, ustmtext("Dialing...", s));
            }
            send_text_status(s, ustmtext("                     Hangup", s));
 
            /* start switch */
            if (ast_pthread_create(&sub->ss_thread, NULL, unistim_ss, c)) {
                ast_log(LOG_WARNING, "Unable to create switch thread\n");
                sub->ss_thread = AST_PTHREADT_NULL;
                ast_queue_hangup_with_cause(c, AST_CAUSE_SWITCH_CONGESTION);
            }
        } else
            ast_log(LOG_WARNING, "Unable to create channel for %s@%s\n",
                    sub->parent->name, s->device->name);
    } else {
        ast_debug(1, "Current sub [%s] already has owner\n", ast_channel_name(sub->owner));
    }
    return;
}

References ao2_cleanup, AST_CAUSE_CALL_REJECTED, AST_CAUSE_NORMAL_CLEARING, AST_CAUSE_SWITCH_CONGESTION, ast_channel_hangupcause_set(), ast_channel_lock, ast_channel_name(), ast_channel_unlock, ast_debug, ast_get_chan_features_pickup_config(), ast_hangup(), ast_log, ast_pickup_call(), ast_pthread_create, AST_PTHREADT_NULL, ast_queue_hangup_with_cause(), AST_STATE_DOWN, ast_strdupa, ast_verb, c, d, unistimsession::device, FAV_ICON_OFFHOOK_BLACK, get_avail_softkey(), get_sub(), unistim_device::height, LOG_ERROR, LOG_NOTICE, LOG_WARNING, MUTE_OFF, unistim_device::name, NULL, unistim_device::output, unistim_subchannel::owner, unistim_subchannel::parent, unistim_device::phone_number, RAII_VAR, unistim_device::selected, send_favorite_short(), send_select_output(), send_start_timer(), send_text(), send_text_status(), send_tone(), unistim_device::sline, unistim_subchannel::softkey, unistim_device::ssub, start_rtp(), unistimsession::state, STATE_CALL, sub, sub_hold(), SUB_REAL, sub_stop_silence(), SUB_THREEWAY, unistim_subchannel::subtype, swap_subs(), TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, unistim_alloc_sub(), unistim_new(), unistim_ss(), unistimdebug, ustmtext(), and unistim_device::volume.

Referenced by do_monitor(), key_dial_page(), key_favorite(), and key_main_page().

◆ handle_dial_page()

static void handle_dial_page ( struct unistimsession * pte )

static

Definition at line 2983 of file chan_unistim.c.

{
    pte->state = STATE_DIALPAGE;
    if (pte->device->call_forward[0] == -1) {
        send_text(TEXT_LINE0, TEXT_NORMAL, pte, "");
        send_text(TEXT_LINE1, TEXT_NORMAL, pte, ustmtext("Enter forward", pte));
        send_text_status(pte, ustmtext("Fwd    Cancel BackSp Erase", pte));
        if (pte->device->call_forward[1] != 0) {
            ast_copy_string(pte->device->phone_number, pte->device->call_forward + 1,
                            sizeof(pte->device->phone_number));
            show_phone_number(pte);
            send_led_update(pte, LED_BAR_OFF);
            return;
        }
    } else {
        if ((pte->device->output == OUTPUT_HANDSET) &&
            (pte->device->receiver_state == STATE_ONHOOK)) {
            send_select_output(pte, OUTPUT_SPEAKER, pte->device->volume, MUTE_OFF);
        } else {
            send_select_output(pte, pte->device->output, pte->device->volume, MUTE_OFF);
        }
        send_dial_tone(pte);
 
        if (pte->device->height > 1) {
            send_text(TEXT_LINE0, TEXT_NORMAL, pte, ustmtext("Enter the number to dial", pte));
            send_text(TEXT_LINE1, TEXT_NORMAL, pte, ustmtext("and press Call", pte));
        }
        if (ast_strlen_zero(pte->device->redial_number)) {
            send_text_status(pte, ustmtext("Call          BackSp Erase", pte));
        } else {
            send_text_status(pte, ustmtext("Call   Redial BackSp Erase", pte));
        }
    }
 
    pte->device->size_phone_number = 0;
    pte->device->phone_number[0] = 0;
    show_phone_number(pte);
    change_favorite_icon(pte, FAV_ICON_PHONE_BLACK);
    send_icon(TEXT_LINE0, FAV_ICON_NONE, pte);
    pte->device->missed_call = 0;
    send_led_update(pte, LED_BAR_OFF);
    pte->device->lastmsgssent = -1;
    return;
}

References ast_copy_string(), ast_strlen_zero(), unistim_device::call_forward, change_favorite_icon(), unistimsession::device, FAV_ICON_NONE, FAV_ICON_PHONE_BLACK, unistim_device::height, unistim_device::lastmsgssent, LED_BAR_OFF, unistim_device::missed_call, MUTE_OFF, unistim_device::output, OUTPUT_HANDSET, OUTPUT_SPEAKER, unistim_device::phone_number, unistim_device::receiver_state, unistim_device::redial_number, send_dial_tone(), send_icon(), send_led_update(), send_select_output(), send_text(), send_text_status(), show_phone_number(), unistim_device::size_phone_number, unistimsession::state, STATE_DIALPAGE, STATE_ONHOOK, TEXT_LINE0, TEXT_LINE1, TEXT_NORMAL, ustmtext(), and unistim_device::volume.

Referenced by handle_key_fav(), key_main_page(), process_request(), and transfer_call_step1().

◆ handle_key_fav()

static void handle_key_fav	(	struct unistimsession *	pte,
		char	keycode
	)

static

Definition at line 3380 of file chan_unistim.c.

{
    int keynum = keycode - KEY_FAV0;
    struct unistim_subchannel *sub, *sub_key = NULL;
    sub = get_sub_holding(pte->device, SUB_REAL, 0);
 
    /* Make an action on selected favorite key */
    if (!pte->device->ssub[keynum]) { /* Key have no assigned call */
        sub = get_sub_holding(pte->device, SUB_REAL, 0);
        send_favorite_selected(FAV_LINE_ICON, pte);
        if (is_key_line(pte->device, keynum)) {
            if (unistimdebug) {
                ast_verb(0, "Handle line w/o sub - dialpage\n");
            }
            pte->device->selected = keynum;
            sub_hold(pte, sub); /* Put active call on hold */
            send_stop_timer(pte);
            handle_dial_page(pte);
        } else if (is_key_favorite(pte->device, keynum)) {
            /* Put active call on hold in handle_call_outgoing function, after preparation and
             checking if lines available for calling */
            if (unistimdebug) {
                ast_verb(0, "Handle favorite w/o sub - dialing\n");
            }
            if ((pte->device->output == OUTPUT_HANDSET) &&
                (pte->device->receiver_state == STATE_ONHOOK)) {
                send_select_output(pte, OUTPUT_SPEAKER, pte->device->volume, MUTE_OFF);
            } else {
                send_select_output(pte, pte->device->output, pte->device->volume, MUTE_OFF);
            }
            key_favorite(pte, keycode);
        }
    } else {
        sub_key = pte->device->ssub[keynum];
        /* Favicon have assigned sub, activate it and put current on hold */
        if (sub_key->subtype == SUB_REAL && !sub_key->holding) {
            sub_hold(pte, sub_key);
            show_main_page(pte);
        } else if (sub_key->subtype == SUB_REAL && sub_key->holding) {
            /* We are going to unhold line (we should put active line on hold, of any) */
            if (pte->state == STATE_DIALPAGE){
                send_tone(pte, 0, 0);
            }
            sub_hold(pte, sub);
            send_callerid_screen(pte, sub_key);
            sub_unhold(pte, sub_key);
            pte->state = STATE_CALL;
        } else if (sub_key->subtype == SUB_RING) {
            sub_hold(pte, sub);
            sub_key->softkey = keynum;
            handle_call_incoming(pte);
        }
    }
}

References ast_verb, unistimsession::device, FAV_LINE_ICON, get_sub_holding(), handle_call_incoming(), handle_dial_page(), unistim_subchannel::holding, is_key_favorite(), is_key_line(), KEY_FAV0, key_favorite(), MUTE_OFF, NULL, unistim_device::output, OUTPUT_HANDSET, OUTPUT_SPEAKER, unistim_device::receiver_state, unistim_device::selected, send_callerid_screen(), send_favorite_selected(), send_select_output(), send_stop_timer(), send_tone(), show_main_page(), unistim_subchannel::softkey, unistim_device::ssub, unistimsession::state, STATE_CALL, STATE_DIALPAGE, STATE_ONHOOK, sub, sub_hold(), SUB_REAL, SUB_RING, sub_unhold(), unistim_subchannel::subtype, unistimdebug, and unistim_device::volume.

Referenced by key_call(), key_dial_page(), key_main_page(), and key_ringing().

◆ handle_select_codec()

static void handle_select_codec ( struct unistimsession * pte )

static

Definition at line 3732 of file chan_unistim.c.

{
    char buf[30], buf2[6];
 
    pte->state = STATE_SELECTCODEC;
    ast_copy_string(buf, ustmtext("Using codec", pte), sizeof(buf));
    snprintf(buf2, sizeof(buf2), " %d", pte->device->codec_number);
    strcat(buf, buf2);
    strcat(buf, " (G711u=0,");
 
    send_text(TEXT_LINE0, TEXT_NORMAL, pte, buf);
    send_text(TEXT_LINE1, TEXT_NORMAL, pte, "G723=4,G711a=8,G729A=18)");
    send_text(TEXT_LINE2, TEXT_INVERSE, pte, SELECTCODEC_MSG);
    send_blink_cursor(pte);
    send_cursor_pos(pte, TEXT_LINE2 + SELECTCODEC_START_ENTRY_POS);
    pte->size_buff_entry = 0;
    send_text_status(pte, ustmtext("Select BackSp Erase  Cancel", pte));
    return;
}

References ast_copy_string(), buf, buf2, unistim_device::codec_number, unistimsession::device, SELECTCODEC_MSG, SELECTCODEC_START_ENTRY_POS, send_blink_cursor(), send_cursor_pos(), send_text(), send_text_status(), unistimsession::size_buff_entry, unistimsession::state, STATE_SELECTCODEC, TEXT_INVERSE, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, and ustmtext().

◆ handle_select_language()

static void handle_select_language ( struct unistimsession * pte )

static

Definition at line 3819 of file chan_unistim.c.

{
    char tmp_language[40];
    struct unistim_languages lang;
 
    if (pte->state != STATE_SELECTLANGUAGE) {
        pte->state = STATE_SELECTLANGUAGE;
        pte->size_buff_entry = 1;
        pte->buff_entry[0] = find_language(pte->device->language);
    }
    lang = options_languages[(int)pte->buff_entry[0]];
    ast_copy_string(tmp_language, pte->device->language, sizeof(tmp_language));
    ast_copy_string(pte->device->language, lang.lang_short, sizeof(pte->device->language));
    send_charset_update(pte, lang.encoding);
    send_text(TEXT_LINE0, TEXT_NORMAL, pte, ustmtext(lang.label, pte));
 
    ast_copy_string(pte->device->language, tmp_language, sizeof(pte->device->language));
    lang = options_languages[find_language(pte->device->language)];
    send_charset_update(pte, lang.encoding);
    send_text_status(pte, ustmtext("Select               Cancel", pte));
    return;
}

References ast_copy_string(), unistimsession::buff_entry, unistimsession::device, unistim_languages::encoding, find_language(), unistim_languages::label, unistim_languages::lang_short, unistim_device::language, options_languages, send_charset_update(), send_text(), send_text_status(), unistimsession::size_buff_entry, unistimsession::state, STATE_SELECTLANGUAGE, TEXT_LINE0, TEXT_NORMAL, and ustmtext().

Referenced by key_select_language().

◆ handle_select_option()

static void handle_select_option ( struct unistimsession * pte )

static

Definition at line 3687 of file chan_unistim.c.

{
    char tmp[128];
 
    if (pte->state != STATE_SELECTOPTION) {
        pte->state = STATE_SELECTOPTION;
        pte->size_buff_entry = 1;
        pte->buff_entry[0] = 0; /* Position in menu */
    }
    snprintf(tmp, sizeof(tmp), "%d. %s", pte->buff_entry[0] + 1, ustmtext(options_menu[(int)pte->buff_entry[0]].label, pte));
    send_text(TEXT_LINE0, TEXT_NORMAL, pte, tmp);
    send_text_status(pte, ustmtext("Select               Cancel", pte));
    return;
}

References unistimsession::buff_entry, unistim_menu_item::label, options_menu, send_text(), send_text_status(), unistimsession::size_buff_entry, unistimsession::state, STATE_SELECTOPTION, TEXT_LINE0, TEXT_NORMAL, tmp(), and ustmtext().

Referenced by key_main_page(), key_select_language(), and key_select_option().

◆ ignore_call()

static void ignore_call ( struct unistimsession * pte )

static

Definition at line 2641 of file chan_unistim.c.

{
    send_no_ring(pte);
    return;
}

References send_no_ring().

Referenced by key_ringing().

◆ in_band_indication()

static void in_band_indication	(	struct ast_channel *	ast,
		const struct ast_tone_zone *	tz,
		const char *	indication
	)

static

Definition at line 5320 of file chan_unistim.c.

{
    struct ast_tone_zone_sound *ts = NULL;
 
    if ((ts = ast_get_indication_tone(tz, indication))) {
        ast_playtones_start(ast, 0, ts->data, 1);
        ts = ast_tone_zone_sound_unref(ts);
    } else {
        ast_log(LOG_WARNING, "Unable to get indication tone for %s\n", indication);
    }
}

References ast_get_indication_tone(), ast_log, ast_playtones_start(), ast_tone_zone_sound_unref(), ast_tone_zone_sound::data, LOG_WARNING, NULL, and tz.

Referenced by unistim_indicate().

◆ init_phone_step2()

static void init_phone_step2 ( struct unistimsession * pte )

static

Definition at line 4381 of file chan_unistim.c.

{
    BUFFSEND;
    if (unistimdebug) {
        ast_verb(0, "Sending S4\n");
    }
    memcpy(buffsend + SIZE_HEADER, packet_send_s4, sizeof(packet_send_s4));
    send_client(SIZE_HEADER + sizeof(packet_send_s4), buffsend, pte);
    send_date_time2(pte);
    send_date_time3(pte);
    if (unistimdebug) {
        ast_verb(0, "Sending S7\n");
    }
    memcpy(buffsend + SIZE_HEADER, packet_send_S7, sizeof(packet_send_S7));
    send_client(SIZE_HEADER + sizeof(packet_send_S7), buffsend, pte);
    if (unistimdebug) {
        ast_verb(0, "Sending Contrast\n");
    }
    memcpy(buffsend + SIZE_HEADER, packet_send_Contrast, sizeof(packet_send_Contrast));
    if (pte->device != NULL) {
        buffsend[9] = pte->device->contrast;
    }
    send_client(SIZE_HEADER + sizeof(packet_send_Contrast), buffsend, pte);
 
    if (unistimdebug) {
        ast_verb(0, "Sending S9\n");
    }
    memcpy(buffsend + SIZE_HEADER, packet_send_s9, sizeof(packet_send_s9));
    send_client(SIZE_HEADER + sizeof(packet_send_s9), buffsend, pte);
    send_no_ring(pte);
 
    if (unistimdebug) {
        ast_verb(0, "Sending S7\n");
    }
    memcpy(buffsend + SIZE_HEADER, packet_send_S7, sizeof(packet_send_S7));
    send_client(SIZE_HEADER + sizeof(packet_send_S7), buffsend, pte);
    send_led_update(pte, LED_BAR_OFF);
    send_ping(pte);
    if (unistimdebug) {
        ast_verb(0, "Sending init language\n");
    }
    if (pte->device) {
        send_charset_update(pte, options_languages[find_language(pte->device->language)].encoding);
    }
    if (pte->state < STATE_MAINPAGE) {
        if (autoprovisioning == AUTOPROVISIONING_TN) {
            show_extension_page(pte);
            return;
        } else {
            int i;
            char tmp[30];
 
            for (i = 1; i < FAVNUM; i++) {
                send_favorite(i, 0, pte, "");
            }
            send_text(TEXT_LINE0, TEXT_NORMAL, pte, ustmtext("Phone is not registered", pte));
            send_text(TEXT_LINE1, TEXT_NORMAL, pte, ustmtext("in unistim.conf", pte));
            strcpy(tmp, "MAC = ");
            strcat(tmp, pte->macaddr);
            send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmp);
            send_text_status(pte, "");
            send_texttitle(pte, ustmtext("UNISTIM for*", pte));
            return;
        }
    }
    show_main_page(pte);
    refresh_all_favorite(pte);
    if (unistimdebug) {
        ast_verb(0, "Sending arrow\n");
    }
    memcpy(buffsend + SIZE_HEADER, packet_send_arrow, sizeof(packet_send_arrow));
    send_client(SIZE_HEADER + sizeof(packet_send_arrow), buffsend, pte);
    return;
}

References ast_verb, autoprovisioning, AUTOPROVISIONING_TN, BUFFSEND, unistim_device::contrast, unistimsession::device, unistim_languages::encoding, FAVNUM, find_language(), unistim_device::language, LED_BAR_OFF, unistimsession::macaddr, NULL, options_languages, packet_send_arrow, packet_send_Contrast, packet_send_s4, packet_send_S7, packet_send_s9, refresh_all_favorite(), send_charset_update(), send_client(), send_date_time2(), send_date_time3(), send_favorite(), send_led_update(), send_no_ring(), send_ping(), send_text(), send_text_status(), send_texttitle(), show_extension_page(), show_main_page(), SIZE_HEADER, unistimsession::state, STATE_MAINPAGE, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, tmp(), unistimdebug, and ustmtext().

Referenced by process_request().

◆ is_key_favorite()

static int is_key_favorite	(	struct unistim_device *	d,
		int	fav
	)

static

Definition at line 1352 of file chan_unistim.c.

{
    if ((fav < 0) || (fav >= FAVNUM)) {
        return 0;
    }
    if (d->sline[fav]) {
        return 0;
    }
    if (d->softkeynumber[fav][0] == '\0') {
        return 0;
    }
    return 1;
}

References d, and FAVNUM.

Referenced by handle_key_fav(), is_key_line(), and key_favorite().

◆ is_key_line()

static int is_key_line	(	struct unistim_device *	d,
		int	fav
	)

static

Definition at line 1366 of file chan_unistim.c.

{
    if ((fav < 0) || (fav >= FAVNUM)) {
        return 0;
    }
    if (!d->sline[fav]) {
        return 0;
    }
    if (is_key_favorite(d, fav)) {
        return 0;
    }
    return 1;
}

References d, FAVNUM, and is_key_favorite().

Referenced by get_avail_softkey(), handle_key_fav(), unistim_call(), and unistim_hangup().

◆ key_call()

static void key_call	(	struct unistimsession *	pte,
		char	keycode
	)

static

Definition at line 3435 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = get_sub(pte->device, SUB_REAL);
    struct unistim_subchannel *sub_3way = get_sub(pte->device, SUB_THREEWAY);
 
    if (!sub) {
        return;
    }
    if ((keycode >= KEY_0) && (keycode <= KEY_SHARP)) {
        if (keycode == KEY_SHARP) {
            keycode = '#';
        } else if (keycode == KEY_STAR) {
            keycode = '*';
        } else {
            keycode -= 0x10;
        }
        unistim_do_senddigit(pte, keycode);
        return;
    }
    switch (keycode) {
    case KEY_FUNC1:
        if (sub->owner && ast_channel_state(sub->owner) == AST_STATE_UP) {
            if (sub_3way) {
                close_call(pte);
            }
        }
        break;
    case KEY_FUNC2:
        if (sub_3way) {
            transfer_cancel_step2(pte);
        } else if (ast_channel_state(sub->owner) == AST_STATE_UP) {
            transfer_call_step1(pte);
        }
        break;
    case KEY_HANGUP:
    case KEY_FUNC4:
        if (!sub_3way) {
            close_call(pte);
        }
        break;
    case KEY_FAV0:
    case KEY_FAV1:
    case KEY_FAV2:
    case KEY_FAV3:
    case KEY_FAV4:
    case KEY_FAV5:
        handle_key_fav(pte, keycode);
        break;
    case KEY_HEADPHN:
        if (pte->device->output == OUTPUT_HEADPHONE) {
            send_select_output(pte, OUTPUT_HANDSET, pte->device->volume, MUTE_OFF);
        } else {
            send_select_output(pte, OUTPUT_HEADPHONE, pte->device->volume, MUTE_OFF);
        }
        break;
    case KEY_LOUDSPK:
        if (pte->device->output != OUTPUT_SPEAKER)
            send_select_output(pte, OUTPUT_SPEAKER, pte->device->volume, MUTE_OFF);
        else
            send_select_output(pte, pte->device->previous_output, pte->device->volume,
                             MUTE_OFF);
        break;
    case KEY_ONHOLD:
        if (!sub) {
            if(pte->device->ssub[pte->device->selected]) {
                sub = pte->device->ssub[pte->device->selected];
            } else {
                break;
            }
        }
        if (sub->holding) {
            sub_unhold(pte, sub);
        } else {
            sub_hold(pte, sub);
        }
        break;
    }
    return;
}

References AST_STATE_UP, close_call(), unistimsession::device, get_sub(), handle_key_fav(), KEY_0, KEY_FAV0, KEY_FAV1, KEY_FAV2, KEY_FAV3, KEY_FAV4, KEY_FAV5, KEY_FUNC1, KEY_FUNC2, KEY_FUNC4, KEY_HANGUP, KEY_HEADPHN, KEY_LOUDSPK, KEY_ONHOLD, KEY_SHARP, KEY_STAR, MUTE_OFF, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, OUTPUT_SPEAKER, unistim_device::previous_output, unistim_device::selected, send_select_output(), unistim_device::ssub, sub, sub_hold(), SUB_REAL, SUB_THREEWAY, sub_unhold(), transfer_call_step1(), transfer_cancel_step2(), unistim_do_senddigit(), and unistim_device::volume.

Referenced by process_request().

◆ key_dial_page()

static void key_dial_page	(	struct unistimsession *	pte,
		char	keycode
	)

static

Definition at line 3561 of file chan_unistim.c.

{
    struct unistim_subchannel *sub = get_sub(pte->device, SUB_THREEWAY);
 
    pte->device->nextdial = 0;
    if (keycode == KEY_FUNC3) {
        if (pte->device->size_phone_number <= 1) {
            keycode = KEY_FUNC4;
        } else {
            pte->device->size_phone_number -= 2;
            keycode = pte->device->phone_number[pte->device->size_phone_number] + 0x10;
        }
    }
    if (keycode == KEY_SHARP && pte->device->sharp_dial == 1) {
        keycode = KEY_FUNC1;
    }
    if ((keycode >= KEY_0) && (keycode <= KEY_SHARP)) {
        int i = pte->device->size_phone_number;
 
        if (pte->device->size_phone_number == 0) {
            send_tone(pte, 0, 0);
        }
        if (keycode == KEY_SHARP) {
            keycode = '#';
        } else if (keycode == KEY_STAR) {
            keycode = '*';
        } else {
            keycode -= 0x10;
        }
        pte->device->phone_number[i] = keycode;
        pte->device->size_phone_number++;
        pte->device->phone_number[i + 1] = 0;
        show_phone_number(pte);
 
        if (ast_exists_extension(NULL, pte->device->context, pte->device->phone_number, 1, NULL) &&
            !ast_matchmore_extension(NULL, pte->device->context, pte->device->phone_number, 1, NULL)) {
            keycode = KEY_FUNC1;
        } else {
            if (pte->device->interdigit_timer) {
                pte->device->nextdial = get_tick_count() + pte->device->interdigit_timer;
            }
        }
    }
    if (keycode == KEY_FUNC4) {
        pte->device->size_phone_number = 0;
        show_phone_number(pte);
        return;
    }
 
    if (pte->device->call_forward[0] == -1) {
        if (keycode == KEY_FUNC1) {
            ast_copy_string(pte->device->call_forward, pte->device->phone_number,
                            sizeof(pte->device->call_forward));
            show_main_page(pte);
        } else if ((keycode == KEY_FUNC2) || (keycode == KEY_HANGUP)) {
            pte->device->call_forward[0] = '\0';
            send_led_update(pte, LED_SPEAKER_OFF);
            send_led_update(pte, LED_HEADPHONE_OFF);
            show_main_page(pte);
        }
        return;
    }
    switch (keycode) {
    case KEY_FUNC2:
        if (ast_strlen_zero(pte->device->redial_number)) {
            break;
        }
        ast_copy_string(pte->device->phone_number, pte->device->redial_number,
                        sizeof(pte->device->phone_number));
    case KEY_FUNC1:
        handle_call_outgoing(pte);
        break;
    case KEY_HANGUP:
        if (sub && sub->owner) {
            sub_stop_silence(pte, sub);
            send_tone(pte, 0, 0);
            ast_queue_unhold(sub->owner);
            sub->moh = 0;
            sub->subtype = SUB_REAL;
            pte->state = STATE_CALL;
 
            send_text_status(pte, ustmtext("       Transf        Hangup", pte));
            send_callerid_screen(pte, sub);
        } else {
            send_led_update(pte, LED_SPEAKER_OFF);
            send_led_update(pte, LED_HEADPHONE_OFF);
            show_main_page(pte);
        }
        break;
    case KEY_FAV0:
    case KEY_FAV1:
    case KEY_FAV2:
    case KEY_FAV3:
    case KEY_FAV4:
    case KEY_FAV5:
        send_favorite_selected(FAV_LINE_ICON, pte);
        pte->device->selected = -1;
        handle_key_fav(pte, keycode);
        break;
    case KEY_LOUDSPK:
        if (pte->device->output == OUTPUT_SPEAKER) {
            if (pte->device->receiver_state == STATE_OFFHOOK) {
                send_select_output(pte, pte->device->previous_output, pte->device->volume,
                                 MUTE_OFF);
            } else {
                show_main_page(pte);
            }
        } else {
            send_select_output(pte, OUTPUT_SPEAKER, pte->device->volume, MUTE_OFF);
        }
        break;
    case KEY_HEADPHN:
        if (pte->device->output == OUTPUT_HEADPHONE) {
            if (pte->device->receiver_state == STATE_OFFHOOK) {
                send_select_output(pte, OUTPUT_HANDSET, pte->device->volume, MUTE_OFF);
            } else {
                show_main_page(pte);
            }
        } else {
            send_select_output(pte, OUTPUT_HEADPHONE, pte->device->volume, MUTE_OFF);
        }
        break;
    }
    return;
}

References ast_copy_string(), ast_exists_extension(), ast_matchmore_extension(), ast_queue_unhold(), ast_strlen_zero(), unistim_device::call_forward, unistim_device::context, unistimsession::device, FAV_LINE_ICON, get_sub(), get_tick_count(), handle_call_outgoing(), handle_key_fav(), unistim_device::interdigit_timer, KEY_0, KEY_FAV0, KEY_FAV1, KEY_FAV2, KEY_FAV3, KEY_FAV4, KEY_FAV5, KEY_FUNC1, KEY_FUNC2, KEY_FUNC3, KEY_FUNC4, KEY_HANGUP, KEY_HEADPHN, KEY_LOUDSPK, KEY_SHARP, KEY_STAR, LED_HEADPHONE_OFF, LED_SPEAKER_OFF, MUTE_OFF, unistim_device::nextdial, NULL, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, OUTPUT_SPEAKER, unistim_device::phone_number, unistim_device::previous_output, unistim_device::receiver_state, unistim_device::redial_number, unistim_device::selected, send_callerid_screen(), send_favorite_selected(), send_led_update(), send_select_output(), send_text_status(), send_tone(), unistim_device::sharp_dial, show_main_page(), show_phone_number(), unistim_device::size_phone_number, unistimsession::state, STATE_CALL, STATE_OFFHOOK, sub, SUB_REAL, sub_stop_silence(), SUB_THREEWAY, ustmtext(), and unistim_device::volume.

Referenced by key_main_page(), and process_request().

◆ key_favorite()

static void key_favorite	(	struct unistimsession *	pte,
		char	keycode
	)

static

Definition at line 3548 of file chan_unistim.c.

{
    int fav = keycode - KEY_FAV0;
    if (!is_key_favorite(pte->device, fav)) {
        ast_log(LOG_WARNING, "It's not a favorite key\n");
        return;
    }
    ast_copy_string(pte->device->phone_number, pte->device->softkeynumber[fav],
                    sizeof(pte->device->phone_number));
    handle_call_outgoing(pte);
    return;
}

References ast_copy_string(), ast_log, unistimsession::device, handle_call_outgoing(), is_key_favorite(), KEY_FAV0, LOG_WARNING, unistim_device::phone_number, and unistim_device::softkeynumber.

Referenced by handle_key_fav().

◆ key_history()

static void key_history	(	struct unistimsession *	pte,
		char	keycode
	)

static

Definition at line 4294 of file chan_unistim.c.

{
    FILE *f;
    char count;
    long offset;
    int flag = 0;
 
    switch (keycode) {
    case KEY_LEFT:
        if (pte->device->height == 1) {
            if (pte->buff_entry[3] <= 1) {
                return;
            }
            pte->buff_entry[3]--;
            flag = 1;
            break;
        }
    case KEY_UP:
    case KEY_FUNC1:
        if (pte->buff_entry[2] <= 1) {
            return;
        }
        pte->buff_entry[2]--;
        flag = 1;
        break;
    case KEY_RIGHT:
        if (pte->device->height == 1) {
            if (pte->buff_entry[3] == 3) {
                return;
            }
            pte->buff_entry[3]++;
            flag = 1;
            break;
        }
    case KEY_DOWN:
    case KEY_FUNC2:
        if (pte->buff_entry[2] >= pte->buff_entry[1]) {
            return;
        }
        pte->buff_entry[2]++;
        flag = 1;
        break;
    case KEY_FUNC3:
        if (ast_strlen_zero(pte->device->lst_cid)) {
            break;
        }
        ast_copy_string(pte->device->redial_number, pte->device->lst_cid,
                        sizeof(pte->device->redial_number));
        key_main_page(pte, KEY_FUNC2);
        break;
    case 

Data Structures

Macros

Enumerations

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ AST_CONFIG_MAX_PATH

◆ BUFFSEND

◆ DEBUG_TIMER

◆ DEFAULT_CODEC

◆ DEFAULT_INTERDIGIT_TIMER

◆ DEFAULTCALLERID

◆ DEFAULTCALLERNAME

◆ DEFAULTCONTEXT

◆ DEFAULTHEIGHT

◆ DEVICE_NAME_LEN

◆ EXPNUM

◆ FAV_BLINK_FAST

◆ FAV_BLINK_SLOW

◆ FAV_ICON_BOX

◆ FAV_ICON_CALL_CENTER

◆ FAV_ICON_CITY

◆ FAV_ICON_COMPUTER

◆ FAV_ICON_FAX

◆ FAV_ICON_FORWARD

◆ FAV_ICON_HEADPHONES

◆ FAV_ICON_HEADPHONES_ONHOLD

◆ FAV_ICON_HOME

◆ FAV_ICON_INBOX

◆ FAV_ICON_LOCKED

◆ FAV_ICON_MAILBOX

◆ FAV_ICON_MEETING

◆ FAV_ICON_NONE

◆ FAV_ICON_OFFHOOK_BLACK

◆ FAV_ICON_OFFHOOK_WHITE

◆ FAV_ICON_ONHOLD_BLACK

◆ FAV_ICON_ONHOLD_WHITE

◆ FAV_ICON_ONHOOK_BLACK

◆ FAV_ICON_ONHOOK_WHITE

◆ FAV_ICON_OUTBOX

◆ FAV_ICON_PAGER

◆ FAV_ICON_PHONE_BLACK

◆ FAV_ICON_PHONE_WHITE

◆ FAV_ICON_REFLECT

◆ FAV_ICON_SHARP

◆ FAV_ICON_SPEAKER_OFFHOOK_BLACK

◆ FAV_ICON_SPEAKER_OFFHOOK_WHITE

◆ FAV_ICON_SPEAKER_ONHOLD_BLACK

◆ FAV_ICON_SPEAKER_ONHOLD_WHITE

◆ FAV_ICON_SPEAKER_ONHOOK_BLACK

◆ FAV_ICON_SPEAKER_ONHOOK_WHITE

◆ FAV_ICON_TRASH

◆ FAV_LINE_ICON

◆ FAV_MAX_LENGTH

◆ FAVNUM

◆ IDLE_WAIT

◆ LED_BAR_OFF

◆ LED_BAR_ON

◆ LED_BAR_P2

◆ LED_BAR_P3

◆ LED_BAR_P4

◆ LED_BAR_P5

◆ LED_BAR_P6

◆ LED_BAR_P7

◆ LED_HEADPHONE_OFF

◆ LED_HEADPHONE_ON

◆ LED_MUTE_BLINK

◆ LED_MUTE_OFF

◆ LED_MUTE_ON

◆ LED_SPEAKER_OFF

◆ LED_SPEAKER_ON

◆ MAX_BUF_NUMBER

◆ MAX_BUF_SIZE

◆ MAX_ENTRY_LOG

◆ MAX_SCREEN_NUMBER

◆ MONTH_LABEL_SIZE

◆ MUTE_OFF

◆ MUTE_ON

◆ MUTE_ON_DISCRET