chan_unistim.c File Reference

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/event.h"
#include "asterisk/rtp.h"
#include "asterisk/netsock.h"
#include "asterisk/acl.h"
#include "asterisk/callerid.h"
#include "asterisk/cli.h"
#include "asterisk/app.h"
#include "asterisk/musiconhold.h"
#include "asterisk/causes.h"
#include "asterisk/indications.h"

Include dependency graph for chan_unistim.c:

Go to the source code of this file.

Data Structures
struct	systemtime
struct	tone_zone_unistim
struct	unistim_device
	A device containing one or more lines. More...
struct	unistim_line
struct	unistim_subchannel
struct	unistimsession
struct	wsabuf
Defines
#define	AST_CONFIG_MAX_PATH   255
#define	BUFFSEND   unsigned char buffsend[64] = { 0x00, 0x00, 0xaa, 0xbb, 0x02, 0x01 }
#define	CAPABILITY   AST_FORMAT_ALAW | AST_FORMAT_ULAW
#define	DEBUG_TIMER   dummy
#define	DEFAULT_CODEC   0x00
#define	DEFAULTCALLERID   "Unknown"
#define	DEFAULTCALLERNAME   " "
#define	DEFAULTCONTEXT   "default"
#define	DEVICE_NAME_LEN   16
#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_MAX_LENGTH   0x0A
#define	IDLE_WAIT   1000
#define	MAX_BUF_NUMBER   50
#define	MAX_BUF_SIZE   64
#define	MAX_ENTRY_LOG   30
#define	MAX_SUBS   2
#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_THREEWAY   1
#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   10000
#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_DB, AUTOPROVISIONING_TN }
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_SELECTCODEC,   STATE_CLEANING, STATE_HISTORY }
Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	alloc_sub (struct unistim_line *l, int x)
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	cancel_dial (struct unistimsession *pte)
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	display_last_error (const char *sz_msg)
static void *	do_monitor (void *data)
static void	dummy (char *unused,...)
static struct unistim_subchannel *	find_subchannel_by_name (const char *dest)
static void	finish_bookmark (void)
static unsigned int	get_tick_count (void)
static int	get_to_address (int fd, struct sockaddr_in *toAddr)
static void	handle_dial_page (struct unistimsession *pte)
static void	HandleCallIncoming (struct unistimsession *s)
static void	HandleCallOutgoing (struct unistimsession *s)
static void	HandleSelectCodec (struct unistimsession *pte)
static void	IgnoreCall (struct unistimsession *pte)
static void	in_band_indication (struct ast_channel *ast, const struct tone_zone *tz, const char *indication)
static void	init_phone_step2 (struct unistimsession *pte)
static void	key_call (struct unistimsession *pte, char keycode)
static void	key_dial_page (struct unistimsession *pte, char keycode)
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	Keyfavorite (struct unistimsession *pte, char keycode)
static int	load_module (void)
static char	OpenHistory (struct unistimsession *pte, char way, FILE **f)
static int	ParseBookmark (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 void	rcv_mac_addr (struct unistimsession *pte, const unsigned char *buf)
static void	rcv_resume_connection_with_server (struct unistimsession *pte)
static int	ReformatNumber (char *number)
static void	refresh_all_favorite (struct unistimsession *pte)
static int	RegisterExtension (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_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_end_call (struct unistimsession *pte)
static void	send_favorite (unsigned char pos, unsigned char status, struct unistimsession *pte, const char *text)
static void	send_led_update (struct unistimsession *pte, unsigned char led)
static void	send_no_ring (struct unistimsession *pte)
static void	send_ping (struct unistimsession *pte)
static void	send_raw_client (int size, 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, char volume, char style)
static void	send_select_output (struct unistimsession *pte, unsigned char output, unsigned char volume, unsigned char mute)
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	SendDialTone (struct unistimsession *pte)
static void	Sendicon (unsigned char pos, unsigned char status, struct unistimsession *pte)
static void	set_ping_timer (struct unistimsession *pte)
static void	show_entry_history (struct unistimsession *pte, FILE **f)
static void	show_history (struct unistimsession *pte, char way)
static void	show_main_page (struct unistimsession *pte)
static void	ShowExtensionPage (struct unistimsession *pte)
static void	start_rtp (struct unistim_subchannel *sub)
static void	swap_subs (struct unistim_line *p, int a, int b)
static void	TransferCallStep1 (struct unistimsession *pte)
static int	unalloc_sub (struct unistim_line *p, int x)
static int	unistim_answer (struct ast_channel *ast)
static int	unistim_call (struct ast_channel *ast, 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 enum ast_rtp_get_result	unistim_get_rtp_peer (struct ast_channel *chan, struct ast_rtp **rtp)
static enum ast_rtp_get_result	unistim_get_vrtp_peer (struct ast_channel *chan, struct ast_rtp **rtp)
static int	unistim_hangup (struct ast_channel *ast)
static int	unistim_indicate (struct ast_channel *ast, int ind, const void *data, size_t datalen)
static char *	unistim_info (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static struct ast_channel *	unistim_new (struct unistim_subchannel *sub, int state)
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
static struct ast_channel *	unistim_request (const char *type, int format, void *data, 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 unistimsession *s, 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 int	unistim_set_rtp_peer (struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp, struct ast_rtp *trtp, int codecs, int nat_active)
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_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	UnregisterExtension (const 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 = "a9c98e5d177805051735cb5b0b16b0a0" , .load = load_module, .unload = unload_module, .reload = reload, }
static struct sockaddr_in	address_from
static 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.
static ast_mutex_t	devicelock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP )
static struct unistim_device *	devices
	A device containing one or more lines.
static struct tone_zone_unistim	frequency []
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 = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP )
static const unsigned char	packet_rcv_discovery []
static const unsigned char	packet_recv_firm_version []
static const unsigned char	packet_recv_hangup []
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_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 unsigned char	packet_send_discovery_ack []
static const unsigned char	packet_send_end_call []
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 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_StartTimer []
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_dial_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
static struct sched_context *	sched
static ast_mutex_t	sessionlock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP )
static struct unistimsession *	sessions
static unsigned int	size_addr_from = sizeof(address_from)
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 = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP )
static int	unistim_reloading = 0
static struct ast_rtp_protocol	unistim_rtp
static struct ast_channel_tech	unistim_tech
static int	unistimdebug = 0
static int	unistimsock = -1
static int	usecnt = 0
static ast_mutex_t	usecnt_lock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP )

---

Detailed Description

chan_unistim channel driver for Asterisk

Author:

Cedric Hans <cedric.hans@mlkj.net>

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

Definition in file chan_unistim.c.

---

Define Documentation

#define AST_CONFIG_MAX_PATH   255

Definition at line 97 of file chan_unistim.c.

Referenced by OpenHistory(), and write_history().

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

Definition at line 667 of file chan_unistim.c.

Referenced by init_phone_step2(), rcv_mac_addr(), rcv_resume_connection_with_server(), send_blink_cursor(), send_cursor_pos(), send_date_time(), send_date_time2(), send_date_time3(), send_end_call(), send_favorite(), send_led_update(), send_no_ring(), send_ping(), send_ring(), send_select_output(), send_start_timer(), send_stop_timer(), send_text(), send_text_status(), send_texttitle(), send_tone(), Sendicon(), start_rtp(), and unistim_sp().

#define CAPABILITY   AST_FORMAT_ALAW | AST_FORMAT_ULAW

Beware, G729 and G723 are not supported by asterisk, except with the proper licence

Definition at line 74 of file chan_unistim.c.

Referenced by build_device(), unistim_new(), and unistim_request().

#define DEBUG_TIMER   dummy

Definition at line 202 of file chan_unistim.c.

Referenced by do_monitor(), and set_ping_timer().

#define DEFAULT_CODEC   0x00

Not used

Definition at line 94 of file chan_unistim.c.

Referenced by key_select_extension(), and unistim_register().

#define DEFAULTCALLERID   "Unknown"

Definition at line 77 of file chan_unistim.c.

Referenced by unistim_call().

#define DEFAULTCALLERNAME   " "

Definition at line 78 of file chan_unistim.c.

Referenced by unistim_call().

#define DEFAULTCONTEXT   "default"

Definition at line 76 of file chan_unistim.c.

Referenced by build_device().

#define DEVICE_NAME_LEN   16

Definition at line 96 of file chan_unistim.c.

#define FAV_BLINK_FAST   0x20

Definition at line 178 of file chan_unistim.c.

Referenced by unistim_call().

#define FAV_BLINK_SLOW   0x40

Definition at line 179 of file chan_unistim.c.

Referenced by show_main_page().

#define FAV_ICON_BOX   0x3F

Definition at line 176 of file chan_unistim.c.

#define FAV_ICON_CALL_CENTER   0x34

Definition at line 165 of file chan_unistim.c.

Referenced by show_main_page().

#define FAV_ICON_CITY   0x31

Definition at line 162 of file chan_unistim.c.

#define FAV_ICON_COMPUTER   0x38

Definition at line 169 of file chan_unistim.c.

#define FAV_ICON_FAX   0x35

Definition at line 166 of file chan_unistim.c.

#define FAV_ICON_FORWARD   0x39

Definition at line 170 of file chan_unistim.c.

#define FAV_ICON_HEADPHONES   0x2E

Definition at line 159 of file chan_unistim.c.

Referenced by send_select_output().

#define FAV_ICON_HEADPHONES_ONHOLD   0x2F

Definition at line 160 of file chan_unistim.c.

Referenced by refresh_all_favorite(), and send_select_output().

#define FAV_ICON_HOME   0x30

Definition at line 161 of file chan_unistim.c.

#define FAV_ICON_INBOX   0x3C

Definition at line 173 of file chan_unistim.c.

#define FAV_ICON_LOCKED   0x3A

Definition at line 171 of file chan_unistim.c.

#define FAV_ICON_MAILBOX   0x36

Definition at line 167 of file chan_unistim.c.

#define FAV_ICON_MEETING   0x3E

Definition at line 175 of file chan_unistim.c.

#define FAV_ICON_NONE   0x00

Definition at line 144 of file chan_unistim.c.

Referenced by close_client(), handle_dial_page(), key_main_page(), and unistim_call().

#define FAV_ICON_OFFHOOK_BLACK   0x24

Definition at line 149 of file chan_unistim.c.

Referenced by send_select_output().

#define FAV_ICON_OFFHOOK_WHITE   0x25

Definition at line 150 of file chan_unistim.c.

#define FAV_ICON_ONHOLD_BLACK   0x26

Definition at line 151 of file chan_unistim.c.

Referenced by send_select_output().

#define FAV_ICON_ONHOLD_WHITE   0x27

Definition at line 152 of file chan_unistim.c.

#define FAV_ICON_ONHOOK_BLACK   0x20

Definition at line 145 of file chan_unistim.c.

Referenced by build_device(), and show_main_page().

#define FAV_ICON_ONHOOK_WHITE   0x21

Definition at line 146 of file chan_unistim.c.

#define FAV_ICON_OUTBOX   0x3D

Definition at line 174 of file chan_unistim.c.

#define FAV_ICON_PAGER   0x33

Definition at line 164 of file chan_unistim.c.

#define FAV_ICON_PHONE_BLACK   0x2A

Definition at line 155 of file chan_unistim.c.

Referenced by handle_dial_page().

#define FAV_ICON_PHONE_WHITE   0x2B

Definition at line 156 of file chan_unistim.c.

#define FAV_ICON_REFLECT   0x37

Definition at line 168 of file chan_unistim.c.

Referenced by show_main_page().

#define FAV_ICON_SHARP   0x32

Definition at line 163 of file chan_unistim.c.

Referenced by ParseBookmark().

#define FAV_ICON_SPEAKER_OFFHOOK_BLACK   0x28

Definition at line 153 of file chan_unistim.c.

Referenced by send_select_output().

#define FAV_ICON_SPEAKER_OFFHOOK_WHITE   0x29

Definition at line 154 of file chan_unistim.c.

#define FAV_ICON_SPEAKER_ONHOLD_BLACK   0x2C

Definition at line 157 of file chan_unistim.c.

Referenced by send_select_output().

#define FAV_ICON_SPEAKER_ONHOLD_WHITE   0x2D

Definition at line 158 of file chan_unistim.c.

#define FAV_ICON_SPEAKER_ONHOOK_BLACK   0x22

Definition at line 147 of file chan_unistim.c.

Referenced by send_select_output(), and unistim_call().

#define FAV_ICON_SPEAKER_ONHOOK_WHITE   0x23

Definition at line 148 of file chan_unistim.c.

#define FAV_ICON_TRASH   0x3B

Definition at line 172 of file chan_unistim.c.

#define FAV_MAX_LENGTH   0x0A

Definition at line 181 of file chan_unistim.c.

Referenced by send_favorite().

#define IDLE_WAIT   1000

Nb of milliseconds waited when no events are scheduled

Definition at line 88 of file chan_unistim.c.

Referenced by do_monitor().

#define MAX_BUF_NUMBER   50

Number of slots for the transmit queue

Definition at line 84 of file chan_unistim.c.

Referenced by create_client(), and send_client().

#define MAX_BUF_SIZE   64

Size of the transmit buffer

Definition at line 82 of file chan_unistim.c.

#define MAX_ENTRY_LOG   30

Definition at line 98 of file chan_unistim.c.

Referenced by OpenHistory(), and write_history().

#define MAX_SUBS   2

Definition at line 102 of file chan_unistim.c.

#define MUTE_OFF   0x00

Definition at line 130 of file chan_unistim.c.

Referenced by build_device(), handle_dial_page(), HandleCallIncoming(), HandleCallOutgoing(), key_call(), key_dial_page(), key_main_page(), process_request(), and send_select_output().

#define MUTE_ON   0xFF

Definition at line 131 of file chan_unistim.c.

Referenced by key_call(), and send_select_output().

#define MUTE_ON_DISCRET   0xCE

Definition at line 132 of file chan_unistim.c.

Referenced by send_select_output(), and show_main_page().

#define NB_MAX_RETRANSMIT   8

Try x times before removing the phone

Definition at line 86 of file chan_unistim.c.

Referenced by reload_config(), and send_retransmit().

#define OUTPUT_HANDSET   0xC0

Definition at line 121 of file chan_unistim.c.

Referenced by build_device(), handle_dial_page(), HandleCallIncoming(), key_call(), key_dial_page(), key_main_page(), process_request(), and send_select_output().

#define OUTPUT_HEADPHONE   0xC1

Definition at line 122 of file chan_unistim.c.

Referenced by key_call(), key_dial_page(), key_main_page(), process_request(), and send_select_output().

#define OUTPUT_SPEAKER   0xC2

Definition at line 123 of file chan_unistim.c.

Referenced by handle_dial_page(), HandleCallIncoming(), key_call(), key_dial_page(), key_main_page(), and send_select_output().

#define RETRANSMIT_TIMER   2000

Wait x milliseconds before resending a packet

Definition at line 90 of file chan_unistim.c.

Referenced by create_client(), reload_config(), send_client(), and send_retransmit().

#define SELECTCODEC_MAX_LENGTH   2

Definition at line 2769 of file chan_unistim.c.

Referenced by key_select_codec().

#define SELECTCODEC_MSG   "Codec number : .."

Definition at line 2770 of file chan_unistim.c.

Referenced by HandleSelectCodec(), and key_select_codec().

#define SELECTCODEC_START_ENTRY_POS   15

Definition at line 2768 of file chan_unistim.c.

Referenced by HandleSelectCodec(), and key_select_codec().

#define SELECTEXTENSION_MAX_LENGTH   10

Definition at line 2846 of file chan_unistim.c.

Referenced by key_select_extension().

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

Definition at line 2847 of file chan_unistim.c.

Referenced by key_select_extension(), and ShowExtensionPage().

#define SELECTEXTENSION_START_ENTRY_POS   0

Definition at line 2845 of file chan_unistim.c.

Referenced by key_select_extension(), and ShowExtensionPage().

#define SIZE_HEADER   6

Definition at line 134 of file chan_unistim.c.

Referenced by init_phone_step2(), parsing(), process_request(), rcv_mac_addr(), rcv_resume_connection_with_server(), send_blink_cursor(), send_cursor_pos(), send_date_time(), send_date_time2(), send_date_time3(), send_end_call(), send_favorite(), send_led_update(), send_no_ring(), send_ping(), send_ring(), send_select_output(), send_start_timer(), send_stop_timer(), send_text(), send_text_status(), send_texttitle(), send_tone(), Sendicon(), start_rtp(), and unistim_sp().

#define SIZE_MAC_ADDR   17

Definition at line 135 of file chan_unistim.c.

#define SIZE_PAGE   4096

Definition at line 95 of file chan_unistim.c.

Referenced by load_module(), and unistimsock_read().

#define STATUS_LENGTH_MAX   28

Definition at line 142 of file chan_unistim.c.

Referenced by send_text_status(), and show_entry_history().

#define SUB_REAL   0

Definition at line 100 of file chan_unistim.c.

#define SUB_THREEWAY   1

Definition at line 101 of file chan_unistim.c.

#define TEXT_INVERSE   0x25

Definition at line 141 of file chan_unistim.c.

Referenced by HandleSelectCodec(), and key_select_codec().

#define TEXT_LENGTH_MAX   24

Definition at line 136 of file chan_unistim.c.

Referenced by change_callerid(), handle_dial_page(), key_history(), send_text(), show_entry_history(), show_main_page(), unistim_sendtext(), write_entry_history(), and write_history().

#define TEXT_LINE0   0x00

Definition at line 137 of file chan_unistim.c.

Referenced by handle_dial_page(), HandleCallOutgoing(), HandleSelectCodec(), init_phone_step2(), key_dial_page(), key_main_page(), key_select_extension(), show_entry_history(), show_main_page(), ShowExtensionPage(), unistim_call(), unistim_hangup(), and unistim_sendtext().

#define TEXT_LINE1   0x20

Definition at line 138 of file chan_unistim.c.

Referenced by handle_dial_page(), HandleCallOutgoing(), HandleSelectCodec(), init_phone_step2(), key_dial_page(), key_select_extension(), show_entry_history(), show_main_page(), ShowExtensionPage(), unistim_call(), unistim_hangup(), and unistim_sendtext().

#define TEXT_LINE2   0x40

Definition at line 139 of file chan_unistim.c.

Referenced by handle_dial_page(), HandleCallIncoming(), HandleCallOutgoing(), HandleSelectCodec(), init_phone_step2(), key_dial_page(), key_select_codec(), key_select_extension(), show_entry_history(), show_main_page(), ShowExtensionPage(), unistim_answer(), unistim_call(), unistim_hangup(), unistim_indicate(), and unistim_sendtext().

#define TEXT_NORMAL   0x05

Definition at line 140 of file chan_unistim.c.

Referenced by handle_dial_page(), HandleCallIncoming(), HandleCallOutgoing(), HandleSelectCodec(), init_phone_step2(), key_dial_page(), key_select_extension(), show_entry_history(), show_main_page(), ShowExtensionPage(), unistim_answer(), unistim_call(), unistim_hangup(), unistim_indicate(), and unistim_sendtext().

#define TIMER_MWI   10000

How often the mailbox is checked for new messages

Definition at line 92 of file chan_unistim.c.

Referenced by unistim_send_mwi_to_peer().

#define USTM_LOG_DIR   "unistimHistory"

Definition at line 79 of file chan_unistim.c.

Referenced by OpenHistory(), and write_history().

#define VOLUME_INSANELY_LOUD   0x07

Definition at line 128 of file chan_unistim.c.

#define VOLUME_LOW   0x01

Definition at line 125 of file chan_unistim.c.

Referenced by build_device(), and send_select_output().

#define VOLUME_LOW_SPEAKER   0x03

Definition at line 126 of file chan_unistim.c.

Referenced by send_select_output().

#define VOLUME_NORMAL   0x02

Definition at line 127 of file chan_unistim.c.

---

Enumeration Type Documentation

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 111 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
};

enum autoprovision

Enumerator:

AUTOPROVISIONING_NO
AUTOPROVISIONING_YES
AUTOPROVISIONING_DB
AUTOPROVISIONING_TN

Definition at line 104 of file chan_unistim.c.

                   {
   AUTOPROVISIONING_NO = 0,
   AUTOPROVISIONING_YES,
   AUTOPROVISIONING_DB,
   AUTOPROVISIONING_TN
};

enum handset_state

Enumerator:

STATE_ONHOOK
STATE_OFFHOOK

Definition at line 257 of file chan_unistim.c.

                   {
   STATE_ONHOOK,
   STATE_OFFHOOK,
};

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 262 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
};

enum phone_state

Enumerator:

STATE_INIT
STATE_AUTHDENY
STATE_MAINPAGE
STATE_EXTENSION
STATE_DIALPAGE
STATE_RINGING
STATE_CALL
STATE_SELECTCODEC
STATE_CLEANING
STATE_HISTORY

Definition at line 244 of file chan_unistim.c.

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

---

Function Documentation

static void __reg_module

(

void

)

[static]

Definition at line 5654 of file chan_unistim.c.

static void __unreg_module

(

void

)

[static]

Definition at line 5654 of file chan_unistim.c.

static int alloc_sub	(	struct unistim_line *	l,
		int	x
	)			[static]

Definition at line 1478 of file chan_unistim.c.

References ast_calloc, ast_mutex_init(), ast_verb, unistim_subchannel::lock, unistim_device::name, unistim_line::name, unistim_subchannel::parent, unistim_line::parent, unistim_line::subs, and unistim_subchannel::subtype.

Referenced by build_device(), HandleCallOutgoing(), and rcv_mac_addr().

{
   struct unistim_subchannel *sub;
   if (!(sub = ast_calloc(1, sizeof(*sub))))
      return 0;

   if (unistimdebug)
      ast_verb(3, "Allocating UNISTIM subchannel #%d on %s@%s ptr=%p\n", x, l->name, l->parent->name, sub);
   sub->parent = l;
   sub->subtype = x;
   l->subs[x] = sub;
   ast_mutex_init(&sub->lock);
   return 1;
}

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

Definition at line 1882 of file chan_unistim.c.

References ast_bridged_channel(), ast_cdr_append(), ast_channel_masquerade(), ast_log(), AST_SOFTHANGUP_DEV, ast_softhangup_nolock(), ast_channel::cdr, LOG_NOTICE, LOG_WARNING, and unistim_subchannel::owner.

Referenced by close_call().

{
   int res = 0;
   struct ast_channel
    *chana = NULL, *chanb = NULL, *bridgea = NULL, *bridgeb = NULL, *peera =
      NULL, *peerb = NULL, *peerc = NULL, *peerd = NULL;

   if (!p1->owner || !p2->owner) {
      ast_log(LOG_WARNING, "Transfer attempted without dual ownership?\n");
      return -1;
   }
   chana = p1->owner;
   chanb = p2->owner;
   bridgea = ast_bridged_channel(chana);
   bridgeb = ast_bridged_channel(chanb);

   if (bridgea) {
      peera = chana;
      peerb = chanb;
      peerc = bridgea;
      peerd = bridgeb;
   } else if (bridgeb) {
      peera = chanb;
      peerb = chana;
      peerc = bridgeb;
      peerd = bridgea;
   }

   if (peera && peerb && peerc && (peerb != peerc)) {
      /*ast_quiet_chan(peera);
         ast_quiet_chan(peerb);
         ast_quiet_chan(peerc);
         ast_quiet_chan(peerd); */

      if (peera->cdr && peerb->cdr) {
         peerb->cdr = ast_cdr_append(peerb->cdr, peera->cdr);
      } else if (peera->cdr) {
         peerb->cdr = peera->cdr;
      }
      peera->cdr = NULL;

      if (peerb->cdr && peerc->cdr) {
         peerb->cdr = ast_cdr_append(peerb->cdr, peerc->cdr);
      } else if (peerc->cdr) {
         peerb->cdr = peerc->cdr;
      }
      peerc->cdr = NULL;

      if (ast_channel_masquerade(peerb, peerc)) {
         ast_log(LOG_WARNING, "Failed to masquerade %s into %s\n", peerb->name,
               peerc->name);
         res = -1;
      }
      return res;
   } else {
      ast_log(LOG_NOTICE,
            "Transfer attempted with no appropriate bridged calls to transfer\n");
      if (chana)
         ast_softhangup_nolock(chana, AST_SOFTHANGUP_DEV);
      if (chanb)
         ast_softhangup_nolock(chanb, AST_SOFTHANGUP_DEV);
      return -1;
   }
   return 0;
}

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

Definition at line 4997 of file chan_unistim.c.

References unistim_line::accountcode, alloc_sub(), unistim_line::amaflags, ast_append_ha(), ast_calloc, ast_cdr_amaflags2int(), ast_copy_string(), ast_free, ast_get_group(), ast_get_indication_zone(), ast_localtime(), ast_log(), AST_MAX_EXTENSION, ast_mutex_destroy(), ast_mutex_init(), ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), ast_true(), ast_tvnow(), ast_verb, AUTOPROVISIONING_TN, unistim_line::callgroup, unistim_device::callhistory, CAPABILITY, unistim_line::capability, unistim_line::cid_num, unistim_line::context, context, unistim_device::contrast, unistim_device::country, dateformat, unistim_device::datetimeformat, DEFAULTCONTEXT, devicelock, display_last_error(), unistim_device::extension, EXTENSION_ASK, EXTENSION_LINE, EXTENSION_NONE, unistim_device::extension_number, EXTENSION_TN, FAV_ICON_ONHOOK_BLACK, unistim_line::fullname, unistim_device::ha, unistim_device::id, unistim_line::language, len(), linelabel, ast_variable::lineno, unistim_device::lines, unistim_line::lock, LOG_ERROR, LOG_WARNING, unistim_line::mailbox, unistim_device::maintext0, unistim_device::maintext1, unistim_device::maintext2, unistim_line::musicclass, unistim_device::mute, MUTE_OFF, unistim_line::name, ast_variable::name, unistim_device::name, unistim_device::nat, ast_variable::next, unistim_line::next, unistim_device::next, unistim_device::output, OUTPUT_HANDSET, unistim_line::parent, unistim_line::parkinglot, ParseBookmark(), unistim_line::pickupgroup, unistim_device::previous_output, unistim_device::ringstyle, unistim_device::ringvolume, unistim_device::rtp_method, unistim_device::rtp_port, unistim_device::softkeydevice, unistim_device::softkeyicon, unistim_device::softkeylabel, unistim_device::softkeylinepos, unistim_device::softkeynumber, unistim_device::sp, unistim_device::status_method, SUB_REAL, unistim_device::titledefault, ast_tm::tm_zone, unistim_device::to_delete, unistim_device::tz, unquote(), ast_variable::value, unistim_device::volume, and VOLUME_LOW.

Referenced by reload_config().

{
   struct unistim_device *d;
   struct unistim_line *l = NULL;
   int create = 1;
   int nbsoftkey, dateformat, timeformat, callhistory;
   char linelabel[AST_MAX_EXTENSION];
   char context[AST_MAX_EXTENSION];
   char ringvolume, ringstyle;

   /* 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;
         l = d->lines;
         break;
      }
      d = d->next;
   }
   ast_mutex_unlock(&devicelock);
   if (create) {
      if (!(d = ast_calloc(1, sizeof(*d))))
         return NULL;

      if (!(l = ast_calloc(1, sizeof(*l)))) {
         ast_free(d);
         return NULL;
      }
      ast_copy_string(d->name, cat, sizeof(d->name));
   }
   ast_copy_string(context, DEFAULTCONTEXT, sizeof(context));
   d->contrast = -1;
   d->output = OUTPUT_HANDSET;
   d->previous_output = OUTPUT_HANDSET;
   d->volume = VOLUME_LOW;
   d->mute = MUTE_OFF;
   linelabel[0] = '\0';
   dateformat = 1;
   timeformat = 1;
   ringvolume = 2;
   callhistory = 1;
   ringstyle = 3;
   nbsoftkey = 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"))
         d->ha = ast_append_ha(v->name, v->value, d->ha, NULL);
      else if (!strcasecmp(v->name, "context"))
         ast_copy_string(context, v->value, sizeof(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, "constrast must be beetween 0 and 15");
            d->contrast = 8;
         }
      } else if (!strcasecmp(v->name, "nat"))
         d->nat = 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, "callhistory"))
         callhistory = atoi(v->value);
      else if (!strcasecmp(v->name, "callerid")) {
         if (!strcasecmp(v->value, "asreceived"))
            l->cid_num[0] = '\0';
         else
            ast_copy_string(l->cid_num, v->value, sizeof(l->cid_num));
      } else if (!strcasecmp(v->name, "language"))
         ast_copy_string(l->language, v->value, sizeof(l->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(l->accountcode, v->value, sizeof(l->accountcode));
      else if (!strcasecmp(v->name, "amaflags")) {
         int y;
         y = ast_cdr_amaflags2int(v->value);
         if (y < 0)
            ast_log(LOG_WARNING, "Invalid AMA flags: %s at line %d\n", v->value,
                  v->lineno);
         else
            l->amaflags = y;
      } else if (!strcasecmp(v->name, "musiconhold"))
         ast_copy_string(l->musicclass, v->value, sizeof(l->musicclass));
      else if (!strcasecmp(v->name, "callgroup"))
         l->callgroup = ast_get_group(v->value);
      else if (!strcasecmp(v->name, "pickupgroup"))
         l->pickupgroup = ast_get_group(v->value);
      else if (!strcasecmp(v->name, "mailbox"))
         ast_copy_string(l->mailbox, v->value, sizeof(l->mailbox));
      else if (!strcasecmp(v->name, "parkinglot"))
         ast_copy_string(l->parkinglot, v->value, sizeof(l->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 (ParseBookmark(v->value, d))
               nbsoftkey++;
         }
      } else if (!strcasecmp(v->name, "line")) {
         int len = strlen(linelabel);

         if (nbsoftkey) {
            ast_log(LOG_WARNING,
                  "You must use bookmark AFTER line=>. Only one line is supported in this version\n");
            if (create) {
               ast_free(d);
               ast_free(l);
            }
            return NULL;
         }
         if (create) {
            ast_mutex_init(&l->lock);
         } else {
            d->to_delete = 0;
            /* 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->sp, 0, sizeof(d->sp));
         }
         ast_copy_string(l->name, v->value, sizeof(l->name));
         snprintf(l->fullname, sizeof(l->fullname), "USTM/%s@%s", l->name, d->name);
         d->softkeyicon[0] = FAV_ICON_ONHOOK_BLACK;
         if (!len)             /* label is undefined ? */
            ast_copy_string(d->softkeylabel[0], v->value, sizeof(d->softkeylabel[0]));
         else {
            if ((len > 2) && (linelabel[1] == '@')) {
               d->softkeylinepos = linelabel[0];
               if ((d->softkeylinepos >= '0') && (d->softkeylinepos <= '5')) {
                  d->softkeylinepos -= '0';
                  d->softkeyicon[0] = 0;
               } else {
                  ast_log(LOG_WARNING,
                        "Invalid position for linelabel : must be between 0 and 5\n");
                  d->softkeylinepos = 0;
               }
               ast_copy_string(d->softkeylabel[d->softkeylinepos], linelabel + 2,
                           sizeof(d->softkeylabel[d->softkeylinepos]));
               d->softkeyicon[d->softkeylinepos] = FAV_ICON_ONHOOK_BLACK;
            } else
               ast_copy_string(d->softkeylabel[0], linelabel,
                           sizeof(d->softkeylabel[0]));
         }
         nbsoftkey++;
         ast_copy_string(l->context, context, sizeof(l->context));
         if (!ast_strlen_zero(l->mailbox)) {
            if (unistimdebug)
               ast_verb(3, "Setting mailbox '%s' on %s@%s\n", l->mailbox, d->name, l->name);
         }

         l->capability = CAPABILITY;
         l->parent = d;

         if (create) {
            if (!alloc_sub(l, SUB_REAL)) {
               ast_mutex_destroy(&l->lock);
               ast_free(l);
               ast_free(d);
               return NULL;
            }
            l->next = d->lines;
            d->lines = l;
         }
      } else
         ast_log(LOG_WARNING, "Don't know keyword '%s' at line %d\n", v->name,
               v->lineno);
      v = v->next;
   }
   d->ringvolume = ringvolume;
   d->ringstyle = ringstyle;
   d->callhistory = callhistory;
   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 = 56 + (dateformat * 4);
   d->datetimeformat += timeformat;
   if (!d->lines) {
      ast_log(LOG_ERROR, "An Unistim device must have at least one line!\n");
      ast_mutex_destroy(&l->lock);
      ast_free(l);
      ast_free(d);
      return NULL;
   }
   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");
         ast_mutex_destroy(&l->lock);
         ast_free(l);
         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->maintext0))
      strcpy(d->maintext0, "Welcome");
   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)) {
         display_last_error("Error in ast_localtime()");
         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;
}

static void cancel_dial

(

struct unistimsession *

pte

)

[static]

Definition at line 1845 of file chan_unistim.c.

References unistimsession::device, unistim_device::missed_call, send_no_ring(), show_main_page(), and write_history().

Referenced by unistim_hangup().

{
   send_no_ring(pte);
   pte->device->missed_call++;
   write_history(pte, 'i', 1);
   show_main_page(pte);
   return;
}

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

Definition at line 1948 of file chan_unistim.c.

References ast_channel::data, unistimsession::device, unistim_device::lst_cid, unistim_device::lst_cnm, and TEXT_LENGTH_MAX.

Referenced by close_call(), and unistim_call().

{
   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);
}

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

Definition at line 1062 of file chan_unistim.c.

References unistimsession::device, unistim_device::next, send_favorite(), unistim_device::session, unistim_device::softkeyicon, unistim_device::softkeylabel, unistim_device::softkeylinepos, unistim_device::sp, unistimsession::state, and STATE_CLEANING.

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

{
   struct unistim_device *d = devices;
   int i;
   /* Update the current phone */
   if (pte->state != STATE_CLEANING)
      send_favorite(pte->device->softkeylinepos, status, pte,
                pte->device->softkeylabel[pte->device->softkeylinepos]);
   /* Notify other phones if we're in their bookmark */
   while (d) {
      for (i = 0; i < 6; 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;
   }
}

static struct unistimsession* channel_to_session

(

struct ast_channel *

ast

)

[static, read]

Definition at line 3618 of file chan_unistim.c.

References ast_log(), LOG_WARNING, unistim_line::parent, unistim_subchannel::parent, unistim_device::session, and ast_channel::tech_pvt.

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

{
   struct unistim_subchannel *sub;
   if (!ast) {
      ast_log(LOG_WARNING, "Unistim callback function called with a null channel\n");
      return NULL;
   }
   if (!ast->tech_pvt) {
      ast_log(LOG_WARNING, "Unistim callback function called without a tech_pvt\n");
      return NULL;
   }
   sub = ast->tech_pvt;

   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;
   }
   if (!sub->parent->parent->session) {
      ast_log(LOG_WARNING, "Unistim callback function called without a session\n");
      return NULL;
   }
   return sub->parent->parent->session;
}

static void check_send_queue

(

struct unistimsession *

pte

)

[static]

Definition at line 917 of file chan_unistim.c.

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

Referenced by parsing().

{
   /* Check if our send queue contained only one element */
   if (pte->last_buf_available == 1) {
      if (unistimdebug)
         ast_verb(6, "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(6, "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(6, "We still have packets in our send queue\n");
   return;
}

static void close_call

(

struct unistimsession *

pte

)

[static]

Definition at line 1967 of file chan_unistim.c.

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, unistim_device::lines, LOG_WARNING, unistim_device::missed_call, unistim_device::name, unistim_line::name, unistim_subchannel::owner, unistim_line::parent, unistim_subchannel::parent, unistim_device::redial_number, send_stop_timer(), show_main_page(), SUB_REAL, SUB_THREEWAY, unistim_line::subs, unistim_subchannel::subtype, and write_history().

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

{
   struct unistim_subchannel *sub;
   struct unistim_line *l = pte->device->lines;

   sub = pte->device->lines->subs[SUB_REAL];
   send_stop_timer(pte);
   if (sub->owner) {
      sub->alreadygone = 1;
      if (l->subs[SUB_THREEWAY]) {
         l->subs[SUB_THREEWAY]->alreadygone = 1;
         if (attempt_transfer(sub, l->subs[SUB_THREEWAY]) < 0)
            ast_verb(0, "attempt_transfer failed.\n");
      } else
         ast_queue_hangup(sub->owner);
   } else {
      if (l->subs[SUB_THREEWAY]) {
         if (l->subs[SUB_THREEWAY]->owner)
            ast_queue_hangup_with_cause(l->subs[SUB_THREEWAY]->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,
                  sub->parent->parent->name, sub->subtype);
   }
   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;
}

static void close_client

(

struct unistimsession *

s

)

[static]

Definition at line 1106 of file chan_unistim.c.

References AST_CAUSE_NETWORK_OUT_OF_ORDER, ast_free, 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::lines, unistimsession::lock, LOG_WARNING, unistimsession::next, unistim_subchannel::owner, unistim_device::session, sessionlock, unistimsession::state, STATE_CLEANING, SUB_REAL, unistim_line::subs, and UnregisterExtension().

Referenced by parsing(), and send_retransmit().

{
   struct unistim_subchannel *sub;
   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 lines %p sub %p\n",
                     s, s->device, s->device->lines,
                     s->device->lines->subs[SUB_REAL]);
         change_favorite_icon(s, FAV_ICON_NONE);
         sub = s->device->lines->subs[SUB_REAL];
         if (sub) {
            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
            ast_log(LOG_WARNING, "Freeing a client with no subchannel !\n");
         if (!ast_strlen_zero(s->device->extension_number))
            UnregisterExtension(s);
         cur->device->session = NULL;
      } 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;
}

static char* control2str

(

int

ind

)

[static]

Definition at line 4024 of file chan_unistim.c.

References AST_CONTROL_ANSWER, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, 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_TAKEOFFHOOK, and AST_CONTROL_WINK.

Referenced by unistim_indicate().

{
   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 -1:
      return "Stop tone";
   }
   return "UNKNOWN";
}

static struct unistimsession* create_client

(

const struct sockaddr_in *

addr_from

)

[static, read]

Definition at line 862 of file chan_unistim.c.

References ast_calloc, ast_inet_ntoa(), ast_mutex_init(), ast_mutex_lock(), ast_mutex_unlock(), ast_verb, unistimsession::buf, wsabuf::buf, get_tick_count(), get_to_address(), unistimsession::last_buf_available, unistimsession::last_seq_ack, unistimsession::lock, MAX_BUF_NUMBER, unistimsession::nb_retransmit, unistimsession::next, RETRANSMIT_TIMER, s, unistimsession::seq_phone, unistimsession::seq_server, sessionlock, unistimsession::sin, unistimsession::sout, unistimsession::state, STATE_INIT, unistimsession::tick_next_ping, unistimsession::timeout, and unistimsession::wsabufsend.

Referenced by parsing().

{
   int tmp;
   struct unistimsession *s;

   if (!(s = ast_calloc(1, sizeof(*s))))
      return NULL;

   memcpy(&s->sin, addr_from, sizeof(struct sockaddr_in));
   get_to_address(unistimsock, &s->sout);
   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->seq_phone = (short) 0x0000;
   s->seq_server = (short) 0x0000;
   s->last_seq_ack = (short) 0x000;
   s->last_buf_available = 0;
   s->nb_retransmit = 0;
   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;
}

static void display_last_error

(

const char *

sz_msg

)

[static]

Definition at line 717 of file chan_unistim.c.

References ast_log(), errno, and LOG_WARNING.

Referenced by build_device(), HandleCallOutgoing(), key_history(), OpenHistory(), send_raw_client(), show_entry_history(), write_entry_history(), and write_history().

{
   time_t cur_time;
   
   time(&cur_time);

   /* Display the error message */
   ast_log(LOG_WARNING, "%s %s : (%u) %s\n", ctime(&cur_time), sz_msg, errno,
         strerror(errno));
}

static void* do_monitor

(

void *

data

)

[static]

Definition at line 4508 of file chan_unistim.c.

References ast_io_add(), AST_IO_IN, ast_io_wait(), ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), ast_verb, DEBUG_TIMER, unistimsession::device, get_tick_count(), IDLE_WAIT, unistimsession::last_buf_available, unistim_device::lines, unistim_line::mailbox, unistimsession::next, unistim_line::nextmsgcheck, reload_config(), send_ping(), send_retransmit(), sessionlock, unistimsession::timeout, unistim_reload_lock, unistim_send_mwi_to_peer(), and unistimsock_read().

Referenced by restart_monitor().

{
   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) {
            if ((!ast_strlen_zero(cur->device->lines->mailbox)) &&
               ((tick >= cur->device->lines->nextmsgcheck))) {
               DEBUG_TIMER("Checking mailbox for MWI\n");
               unistim_send_mwi_to_peer(cur, tick);
               break;
            }
         }
         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;
}

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

Definition at line 183 of file chan_unistim.c.

Referenced by app_exec(), ast_fdisset(), check_user_full(), osp_finish(), osp_lookup(), osp_validate_token(), packsms16(), packsms7(), packsms8(), parse_args(), and transmit_request_with_auth().

{
   return;
}

static struct unistim_subchannel* find_subchannel_by_name

(

const char *

dest

)

[static, read]

Definition at line 4141 of file chan_unistim.c.

References ast_copy_string(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verb, devicelock, unistim_device::lines, LOG_NOTICE, LOG_WARNING, unistim_line::name, unistim_device::name, unistim_device::next, unistim_line::next, unistim_subchannel::ringstyle, unistim_subchannel::ringvolume, SUB_REAL, and unistim_line::subs.

Referenced by unistim_request(), and unistim_sp().

{
   struct unistim_line *l;
   struct unistim_device *d;
   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 */
         l = d->lines;
         while (l) {
            /* Search for the right line */
            if (!strcasecmp(l->name, line)) {
               l->subs[SUB_REAL]->ringvolume = -1;
               l->subs[SUB_REAL]->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 {
                        char ring_volume = -1;
                        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);
                        l->subs[SUB_REAL]->ringvolume = ring_volume;
                        l->subs[SUB_REAL]->ringstyle = ring_style;
                     }
                  }
               }
               ast_mutex_unlock(&devicelock);
               return l->subs[SUB_REAL];
            }
            l = l->next;
         }
      }
      d = d->next;
   }
   /* Device not found */
   ast_mutex_unlock(&devicelock);

   return NULL;
}

static void finish_bookmark

(

void

)

[static]

Definition at line 4972 of file chan_unistim.c.

References ast_log(), LOG_NOTICE, unistim_device::name, unistim_device::next, unistim_device::softkeydevice, unistim_device::softkeyicon, and unistim_device::sp.

Referenced by reload_config().

{
   struct unistim_device *d = devices;
   int i;
   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;
   }
}

static unsigned int get_tick_count

(

void

)

[static]

Definition at line 728 of file chan_unistim.c.

References ast_tvnow().

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

{
   struct timeval now = ast_tvnow();

   return (now.tv_sec * 1000) + (now.tv_usec / 1000);
}

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

Definition at line 829 of file chan_unistim.c.

References ast_log(), errno, len(), and LOG_WARNING.

Referenced by create_client().

{
#ifdef HAVE_PKTINFO
   int err;
   struct msghdr msg;
   struct {
      struct cmsghdr cm;
      int len;
      struct in_addr address;
   } ip_msg;

   /* Zero out the structures before we use them */
   /* This sets several key values to NULL */
   memset(&msg, 0, sizeof(msg));
   memset(&ip_msg, 0, sizeof(ip_msg));

   /* Initialize the message structure */
   msg.msg_control = &ip_msg;
   msg.msg_controllen = sizeof(ip_msg);
   /* Get info about the incoming packet */
   err = recvmsg(fd, &msg, MSG_PEEK);
   if (err == -1)
      ast_log(LOG_WARNING, "recvmsg returned an error: %s\n", strerror(errno));
   memcpy(&toAddr->sin_addr, &ip_msg.address, sizeof(struct in_addr));
   return err;
#else
   memcpy(&toAddr, &public_ip, sizeof(&toAddr));
   return 0;
#endif
}

static void handle_dial_page

(

struct unistimsession *

pte

)

[static]

Definition at line 2255 of file chan_unistim.c.

References ast_copy_string(), unistim_device::call_forward, change_favorite_icon(), unistimsession::device, FAV_ICON_NONE, FAV_ICON_PHONE_BLACK, unistim_device::missed_call, MUTE_OFF, unistim_device::output, OUTPUT_HANDSET, OUTPUT_SPEAKER, unistim_device::phone_number, unistim_device::receiver_state, send_blink_cursor(), send_cursor_pos(), send_led_update(), send_select_output(), send_text(), send_text_status(), SendDialTone(), Sendicon(), unistim_device::size_phone_number, unistimsession::state, STATE_DIALPAGE, STATE_ONHOOK, TEXT_LENGTH_MAX, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, and unistim_device::volume.

Referenced by key_main_page(), process_request(), and TransferCallStep1().

{
   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, "Enter forward");
      send_text_status(pte, "ForwardCancel BackSpcErase");
      if (pte->device->call_forward[1] != 0) {
         char tmp[TEXT_LENGTH_MAX + 1];

         ast_copy_string(pte->device->phone_number, pte->device->call_forward + 1,
                     sizeof(pte->device->phone_number));
         pte->device->size_phone_number = strlen(pte->device->phone_number);
         if (pte->device->size_phone_number > 15)
            pte->device->size_phone_number = 15;
         strcpy(tmp, "Number : ...............");
         memcpy(tmp + 9, pte->device->phone_number, pte->device->size_phone_number);
         send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmp);
         send_blink_cursor(pte);
         send_cursor_pos(pte,
                    (unsigned char) (TEXT_LINE2 + 0x09 +
                                 pte->device->size_phone_number));
         send_led_update(pte, 0);
         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);
      SendDialTone(pte);
      send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Enter the number to dial");
      send_text(TEXT_LINE1, TEXT_NORMAL, pte, "and press Call");
      send_text_status(pte, "Call   Redial BackSpcErase");
   }
   send_text(TEXT_LINE2, TEXT_NORMAL, pte, "Number : ...............");
   send_blink_cursor(pte);
   send_cursor_pos(pte, TEXT_LINE2 + 0x09);
   pte->device->size_phone_number = 0;
   pte->device->phone_number[0] = 0;
   change_favorite_icon(pte, FAV_ICON_PHONE_BLACK);
   Sendicon(TEXT_LINE0, FAV_ICON_NONE, pte);
   pte->device->missed_call = 0;
   send_led_update(pte, 0);
   return;
}

static void HandleCallIncoming

(

struct unistimsession *

s

)

[static]

Definition at line 2439 of file chan_unistim.c.

References AST_CONTROL_ANSWER, ast_log(), ast_queue_control(), ast_verb, unistimsession::device, unistim_device::lines, LOG_NOTICE, LOG_WARNING, unistim_device::missed_call, MUTE_OFF, unistim_line::name, unistim_device::name, unistim_device::output, OUTPUT_HANDSET, OUTPUT_SPEAKER, unistim_subchannel::owner, unistim_subchannel::parent, unistim_device::receiver_state, unistim_subchannel::rtp, send_no_ring(), send_select_output(), send_start_timer(), send_text(), send_text_status(), unistim_device::start_call_timestamp, start_rtp(), unistimsession::state, STATE_CALL, STATE_ONHOOK, SUB_REAL, unistim_line::subs, TEXT_LINE2, TEXT_NORMAL, unistim_device::volume, and write_history().

Referenced by key_ringing(), and process_request().

{
   struct unistim_subchannel *sub;
   s->state = STATE_CALL;
   s->device->missed_call = 0;
   send_no_ring(s);
   sub = s->device->lines->subs[SUB_REAL];
   if (!sub) {
      ast_log(LOG_NOTICE, "No available lines on: %s\n", s->device->name);
      return;
   } else 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);
   ast_queue_control(sub->owner, AST_CONTROL_ANSWER);
   send_text(TEXT_LINE2, TEXT_NORMAL, s, "is on-line");
   send_text_status(s, "Hangup Transf");
   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);
   s->device->start_call_timestamp = time(0);
   write_history(s, 'i', 0);
   return;
}

static void HandleCallOutgoing

(

struct unistimsession *

s

)

[static]

Definition at line 2350 of file chan_unistim.c.

References alloc_sub(), AST_CAUSE_SWITCH_CONGESTION, ast_channel_stop_silence_generator(), ast_debug, ast_hangup(), ast_log(), ast_pthread_create, ast_queue_hangup_with_cause(), AST_STATE_DOWN, ast_verb, unistimsession::device, display_last_error(), unistim_device::lines, LOG_NOTICE, LOG_WARNING, unistim_device::moh, MUTE_OFF, unistim_line::name, unistim_device::name, unistim_device::output, unistim_subchannel::owner, unistim_subchannel::parent, unistim_device::phone_number, unistim_subchannel::rtp, send_select_output(), send_text(), send_text_status(), send_tone(), unistim_device::silence_generator, start_rtp(), unistimsession::state, STATE_CALL, SUB_REAL, SUB_THREEWAY, unistim_line::subs, unistim_subchannel::subtype, swap_subs(), TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, unistim_new(), unistim_ss(), and unistim_device::volume.

Referenced by key_dial_page(), key_main_page(), and Keyfavorite().

{
   struct ast_channel *c;
   struct unistim_subchannel *sub;
   pthread_t t;
   s->state = STATE_CALL;
   sub = s->device->lines->subs[SUB_REAL];
   if (!sub) {
      ast_log(LOG_NOTICE, "No available lines on: %s\n", s->device->name);
      return;
   }
   if (!sub->owner) {            /* A call is already in progress ? */
      c = unistim_new(sub, AST_STATE_DOWN);   /* No, starting a new one */
      if (c) {
         /* Need to start RTP before calling ast_pbx_run */
         if (!sub->rtp)
            start_rtp(sub);
         send_select_output(s, s->device->output, s->device->volume, MUTE_OFF);
         send_text(TEXT_LINE0, TEXT_NORMAL, s, "Calling :");
         send_text(TEXT_LINE1, TEXT_NORMAL, s, s->device->phone_number);
         send_text(TEXT_LINE2, TEXT_NORMAL, s, "Dialing...");
         send_text_status(s, "Hangup");
         /* start switch */
         if (ast_pthread_create(&t, NULL, unistim_ss, c)) {
            display_last_error("Unable to create switch thread");
            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 {             /* We already have a call, so we switch in a threeway call */

      if (s->device->moh) {
         struct unistim_subchannel *subchannel;
         struct unistim_line *p = s->device->lines;
         subchannel = p->subs[SUB_REAL];

         if (!subchannel->owner) {
            ast_log(LOG_WARNING, "Unable to find subchannel for music on hold\n");
            return;
         }
         if (p->subs[SUB_THREEWAY]) {
            ast_log(LOG_WARNING,
                  "Can't transfer while an another transfer is taking place\n");
            return;
         }
         if (!alloc_sub(p, SUB_THREEWAY)) {
            ast_log(LOG_WARNING, "Unable to allocate three-way subchannel\n");
            return;
         }
         /* Stop the silence generator */
         if (s->device->silence_generator) {
            if (unistimdebug)
               ast_verb(0, "Stopping silence generator\n");
            ast_channel_stop_silence_generator(subchannel->owner,
                                       s->device->silence_generator);
            s->device->silence_generator = NULL;
         }
         send_tone(s, 0, 0);
         /* Make new channel */
         c = unistim_new(p->subs[SUB_THREEWAY], AST_STATE_DOWN);
         if (!c) {
            ast_log(LOG_WARNING, "Cannot allocate new structure on channel %p\n", p);
            return;
         }
         /* Swap things around between the three-way and real call */
         swap_subs(p, SUB_THREEWAY, SUB_REAL);
         send_select_output(s, s->device->output, s->device->volume, MUTE_OFF);
         send_text(TEXT_LINE0, TEXT_NORMAL, s, "Calling (pre-transfer)");
         send_text(TEXT_LINE1, TEXT_NORMAL, s, s->device->phone_number);
         send_text(TEXT_LINE2, TEXT_NORMAL, s, "Dialing...");
         send_text_status(s, "TransfrCancel");

         if (ast_pthread_create(&t, NULL, unistim_ss, p->subs[SUB_THREEWAY]->owner)) {
            ast_log(LOG_WARNING, "Unable to start simple switch on channel %p\n", p);
            ast_hangup(c);
            return;
         }
         if (unistimdebug)
            ast_verb(0, "Started three way call on channel %p (%s) subchan %d\n",
                p->subs[SUB_THREEWAY]->owner, p->subs[SUB_THREEWAY]->owner->name,
                p->subs[SUB_THREEWAY]->subtype);
      } else
         ast_debug(1, "Current sub [%s] already has owner\n", sub->owner->name);
   }
   return;
}

static void HandleSelectCodec

(

struct unistimsession *

pte

)

[static]

Definition at line 2771 of file chan_unistim.c.

References buf, 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, and TEXT_NORMAL.

Referenced by key_main_page().

{
   char buf[30], buf2[5];

   pte->state = STATE_SELECTCODEC;
   strcpy(buf, "Using codec ");
   sprintf(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, "Select BackSpcErase  Cancel");
   return;
}

static void IgnoreCall

(

struct unistimsession *

pte

)

[static]

Definition at line 2000 of file chan_unistim.c.

References send_no_ring().

Referenced by key_ringing().

{
   send_no_ring(pte);
   return;
}

static void in_band_indication	(	struct ast_channel *	ast,
		const struct tone_zone *	tz,
		const char *	indication
	)			[static]

Definition at line 4059 of file chan_unistim.c.

References ast_get_indication_tone(), ast_log(), ast_playtones_start(), tone_zone_sound::data, and LOG_WARNING.

Referenced by unistim_indicate().

{
   const struct tone_zone_sound *ts = NULL;

   ts = ast_get_indication_tone(tz, indication);

   if (ts && ts->data[0])
      ast_playtones_start(ast, 0, ts->data, 1);
   else
      ast_log(LOG_WARNING, "Unable to get indication tone for %s\n", indication);
}

static void init_phone_step2

(

struct unistimsession *

pte

)

[static]

Definition at line 3283 of file chan_unistim.c.

References ast_verb, AUTOPROVISIONING_TN, BUFFSEND, unistim_device::contrast, unistimsession::device, unistimsession::macaddr, refresh_all_favorite(), 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_main_page(), ShowExtensionPage(), SIZE_HEADER, unistimsession::state, STATE_MAINPAGE, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, and TEXT_NORMAL.

Referenced by process_request().

{
   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, 0);
   send_ping(pte);
   if (pte->state < STATE_MAINPAGE) {
      if (autoprovisioning == AUTOPROVISIONING_TN) {
         ShowExtensionPage(pte);
         return;
      } else {
         int i;
         char tmp[30];

         for (i = 1; i < 6; i++)
            send_favorite(i, 0, pte, "");
         send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Sorry, this phone is not");
         send_text(TEXT_LINE1, TEXT_NORMAL, pte, "registered in unistim.cfg");
         strcpy(tmp, "MAC = ");
         strcat(tmp, pte->macaddr);
         send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmp);
         send_text_status(pte, "");
         send_texttitle(pte, "UNISTIM for*");
         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;
}

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

Definition at line 2543 of file chan_unistim.c.

References ast_bridged_channel(), ast_log(), ast_moh_start(), ast_moh_stop(), close_call(), unistimsession::device, KEY_0, KEY_FUNC1, KEY_FUNC2, KEY_HANGUP, KEY_HEADPHN, KEY_LOUDSPK, KEY_MUTE, KEY_ONHOLD, KEY_SHARP, KEY_STAR, unistim_device::lines, LOG_WARNING, unistim_device::moh, unistim_line::musicclass, unistim_device::mute, MUTE_OFF, MUTE_ON, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, OUTPUT_SPEAKER, unistim_subchannel::owner, unistim_device::previous_output, send_select_output(), SUB_REAL, unistim_line::subs, TransferCallStep1(), unistim_do_senddigit(), and unistim_device::volume.

Referenced by process_request().

{
   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_HANGUP:
   case KEY_FUNC1:
      close_call(pte);
      break;
   case KEY_FUNC2:
      TransferCallStep1(pte);
      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_MUTE:
      if (!pte->device->moh) {
         if (pte->device->mute == MUTE_ON)
            send_select_output(pte, pte->device->output, pte->device->volume, MUTE_OFF);
         else
            send_select_output(pte, pte->device->output, pte->device->volume, MUTE_ON);
         break;
      }
   case KEY_ONHOLD:
      {
         struct unistim_subchannel *sub;
         struct ast_channel *bridgepeer = NULL;
         sub = pte->device->lines->subs[SUB_REAL];
         if (!sub->owner) {
            ast_log(LOG_WARNING, "Unable to find subchannel for music on hold\n");
            return;
         }
         if ((bridgepeer = ast_bridged_channel(sub->owner))) {
            if (pte->device->moh) {
               ast_moh_stop(bridgepeer);
               pte->device->moh = 0;
               send_select_output(pte, pte->device->output, pte->device->volume,
                            MUTE_OFF);
            } else {
               ast_moh_start(bridgepeer, pte->device->lines->musicclass, NULL);
               pte->device->moh = 1;
               send_select_output(pte, pte->device->output, pte->device->volume,
                            MUTE_ON);
            }
         } else
            ast_log(LOG_WARNING,
                  "Unable to find peer subchannel for music on hold\n");
         break;
      }
   }
   return;
}

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

Definition at line 2651 of file chan_unistim.c.

References ast_bridged_channel(), ast_channel_stop_silence_generator(), ast_copy_string(), ast_moh_stop(), ast_strlen_zero(), ast_verb, unistim_device::call_forward, unistimsession::device, HandleCallOutgoing(), KEY_0, 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, Keyfavorite(), unistim_device::lines, unistim_device::moh, MUTE_OFF, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, OUTPUT_SPEAKER, unistim_subchannel::owner, unistim_device::phone_number, unistim_device::previous_output, unistim_device::receiver_state, unistim_device::redial_number, send_blink_cursor(), send_cursor_pos(), send_select_output(), send_text(), send_text_status(), send_tone(), show_main_page(), unistim_device::silence_generator, unistim_device::size_phone_number, unistimsession::state, STATE_CALL, STATE_OFFHOOK, SUB_REAL, unistim_line::subs, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, and unistim_device::volume.

Referenced by key_main_page(), and process_request().

{
   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_0) && (keycode <= KEY_SHARP)) {
      char tmpbuf[] = "Number : ...............";
      int i = 0;

      if (pte->device->size_phone_number >= 15)
         return;
      if (pte->device->size_phone_number == 0)
         send_tone(pte, 0, 0);
      while (i < pte->device->size_phone_number) {
         tmpbuf[i + 9] = pte->device->phone_number[i];
         i++;
      }
      if (keycode == KEY_SHARP)
         keycode = '#';
      else if (keycode == KEY_STAR)
         keycode = '*';
      else
         keycode -= 0x10;
      tmpbuf[i + 9] = keycode;
      pte->device->phone_number[i] = keycode;
      pte->device->size_phone_number++;
      pte->device->phone_number[i + 1] = 0;
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmpbuf);
      send_blink_cursor(pte);
      send_cursor_pos(pte, (unsigned char) (TEXT_LINE2 + 0x0a + i));
      return;
   }
   if (keycode == KEY_FUNC4) {

      pte->device->size_phone_number = 0;
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, "Number : ...............");
      send_blink_cursor(pte);
      send_cursor_pos(pte, TEXT_LINE2 + 0x09);
      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';
         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:
      HandleCallOutgoing(pte);
      break;
   case KEY_HANGUP:
      if (pte->device->lines->subs[SUB_REAL]->owner) {
         /* Stop the silence generator */
         if (pte->device->silence_generator) {
            if (unistimdebug)
               ast_verb(0, "Stopping silence generator\n");
            ast_channel_stop_silence_generator(pte->device->lines->subs[SUB_REAL]->
                                       owner, pte->device->silence_generator);
            pte->device->silence_generator = NULL;
         }
         send_tone(pte, 0, 0);
         ast_moh_stop(ast_bridged_channel(pte->device->lines->subs[SUB_REAL]->owner));
         pte->device->moh = 0;
         pte->state = STATE_CALL;
         send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Dialing canceled,");
         send_text(TEXT_LINE1, TEXT_NORMAL, pte, "switching back to");
         send_text(TEXT_LINE2, TEXT_NORMAL, pte, "previous call.");
         send_text_status(pte, "Hangup Transf");
      } else
         show_main_page(pte);
      break;
   case KEY_FAV1:
   case KEY_FAV2:
   case KEY_FAV3:
   case KEY_FAV4:
   case KEY_FAV5:
      Keyfavorite(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;
}

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

Definition at line 3215 of file chan_unistim.c.

References ast_copy_string(), unistimsession::buff_entry, unistimsession::device, display_last_error(), f, KEY_DOWN, KEY_FUNC1, KEY_FUNC2, KEY_FUNC3, KEY_FUNC4, KEY_HANGUP, KEY_LEFT, key_main_page(), KEY_RCVHIST, KEY_RIGHT, KEY_SNDHIST, KEY_UP, unistim_device::lst_cid, OpenHistory(), unistim_device::redial_number, ReformatNumber(), show_entry_history(), show_history(), show_main_page(), and TEXT_LENGTH_MAX.

Referenced by process_request().

{
   FILE *f;
   char count;
   long offset;

   switch (keycode) {
   case KEY_UP:
   case KEY_LEFT:
   case KEY_FUNC1:
      if (pte->buff_entry[2] <= 1)
         return;
      pte->buff_entry[2]--;
      count = OpenHistory(pte, pte->buff_entry[0], &f);
      if (!count)
         return;
      offset = ((pte->buff_entry[2] - 1) * TEXT_LENGTH_MAX * 3);
      if (fseek(f, offset, SEEK_CUR)) {
         display_last_error("Unable to seek history entry.");
         fclose(f);
         return;
      }
      show_entry_history(pte, &f);
      break;
   case KEY_DOWN:
   case KEY_RIGHT:
   case KEY_FUNC2:
      if (pte->buff_entry[2] >= pte->buff_entry[1])
         return;
      pte->buff_entry[2]++;
      count = OpenHistory(pte, pte->buff_entry[0], &f);
      if (!count)
         return;
      offset = ((pte->buff_entry[2] - 1) * TEXT_LENGTH_MAX * 3);
      if (fseek(f, offset, SEEK_CUR)) {
         display_last_error("Unable to seek history entry.");
         fclose(f);
         return;
      }
      show_entry_history(pte, &f);
      break;
   case KEY_FUNC3:
      if (!ReformatNumber(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 KEY_FUNC4:
   case KEY_HANGUP:
      show_main_page(pte);
      break;
   case KEY_SNDHIST:
      if (pte->buff_entry[0] == 'i')
         show_history(pte, 'o');
      else
         show_main_page(pte);
      break;
   case KEY_RCVHIST:
      if (pte->buff_entry[0] == 'i')
         show_main_page(pte);
      else
         show_history(pte, 'i');
      break;
   }
   return;
}

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

Definition at line 3121 of file chan_unistim.c.

References ast_copy_string(), ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), unistimsession::buff_entry, unistim_device::call_forward, unistimsession::device, devicelock, unistim_device::extension, EXTENSION_ASK, unistim_device::extension_number, EXTENSION_TN, FAV_ICON_NONE, handle_dial_page(), HandleCallOutgoing(), HandleSelectCodec(), unistim_device::id, KEY_0, KEY_CONF, key_dial_page(), KEY_FAV0, KEY_FAV1, KEY_FAV2, KEY_FAV3, KEY_FAV4, KEY_FAV5, KEY_FUNC1, KEY_FUNC2, KEY_FUNC3, KEY_FUNC4, KEY_HEADPHN, KEY_LOUDSPK, KEY_RCVHIST, KEY_SHARP, KEY_SNDHIST, Keyfavorite(), unistim_device::missed_call, MUTE_OFF, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, OUTPUT_SPEAKER, unistim_device::phone_number, unistim_device::receiver_state, unistim_device::redial_number, send_select_output(), Sendicon(), unistim_device::session, show_history(), show_main_page(), ShowExtensionPage(), unistimsession::size_buff_entry, STATE_ONHOOK, TEXT_LINE0, UnregisterExtension(), and unistim_device::volume.

Referenced by key_history(), and process_request().

{
   if (pte->device->missed_call) {
      Sendicon(TEXT_LINE0, FAV_ICON_NONE, pte);
      pte->device->missed_call = 0;
   }
   if ((keycode >= KEY_0) && (keycode <= KEY_SHARP)) {
      handle_dial_page(pte);
      key_dial_page(pte, keycode);
      return;
   }
   switch (keycode) {
   case KEY_FUNC1:
      handle_dial_page(pte);
      break;
   case KEY_FUNC2:
      if (ast_strlen_zero(pte->device->redial_number))
         break;
      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);

      ast_copy_string(pte->device->phone_number, pte->device->redial_number,
                  sizeof(pte->device->phone_number));
      HandleCallOutgoing(pte);
      break;
   case KEY_FUNC3:
      if (!ast_strlen_zero(pte->device->call_forward)) {
         /* Cancel call forwarding */
         memmove(pte->device->call_forward + 1, pte->device->call_forward,
               sizeof(pte->device->call_forward));
         pte->device->call_forward[0] = '\0';
         Sendicon(TEXT_LINE0, FAV_ICON_NONE, pte);
         pte->device->output = OUTPUT_HANDSET;   /* Seems to be reseted somewhere */
         show_main_page(pte);
         break;
      }
      pte->device->call_forward[0] = -1;
      handle_dial_page(pte);
      break;
   case KEY_FUNC4:
      if (pte->device->extension == EXTENSION_ASK) {
         UnregisterExtension(pte);
         pte->device->extension_number[0] = '\0';
         ShowExtensionPage(pte);
      } else if (pte->device->extension == EXTENSION_TN) {
         ast_mutex_lock(&devicelock);
         strcpy(pte->device->id, pte->device->extension_number);
         pte->buff_entry[0] = '\0';
         pte->size_buff_entry = 0;
         pte->device->session = NULL;
         pte->device = NULL;
         ast_mutex_unlock(&devicelock);
         ShowExtensionPage(pte);
      }
      break;
   case KEY_FAV0:
      handle_dial_page(pte);
      break;
   case KEY_FAV1:
   case KEY_FAV2:
   case KEY_FAV3:
   case KEY_FAV4:
   case KEY_FAV5:
      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);
      Keyfavorite(pte, keycode);
      break;
   case KEY_CONF:
      HandleSelectCodec(pte);
      break;
   case KEY_LOUDSPK:
      send_select_output(pte, OUTPUT_SPEAKER, pte->device->volume, MUTE_OFF);
      handle_dial_page(pte);
      break;
   case KEY_HEADPHN:
      send_select_output(pte, OUTPUT_HEADPHONE, pte->device->volume, MUTE_OFF);
      handle_dial_page(pte);
      break;
   case KEY_SNDHIST:
      show_history(pte, 'o');
      break;
   case KEY_RCVHIST:
      show_history(pte, 'i');
      break;
   }
   return;
}

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

Definition at line 2614 of file chan_unistim.c.

References unistimsession::device, HandleCallIncoming(), IgnoreCall(), KEY_FAV0, KEY_FUNC1, KEY_FUNC4, KEY_HANGUP, and unistim_device::softkeylinepos.

Referenced by process_request().

{
   if (keycode == KEY_FAV0 + pte->device->softkeylinepos) {
      HandleCallIncoming(pte);
      return;
   }
   switch (keycode) {
   case KEY_HANGUP:
   case KEY_FUNC4:
      IgnoreCall(pte);
      break;
   case KEY_FUNC1:
      HandleCallIncoming(pte);
      break;
   }
   return;
}

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

Definition at line 2791 of file chan_unistim.c.

References unistimsession::buff_entry, unistim_device::codec_number, unistimsession::device, KEY_0, KEY_9, KEY_FUNC1, KEY_FUNC2, KEY_FUNC3, KEY_FUNC4, KEY_HANGUP, SELECTCODEC_MAX_LENGTH, SELECTCODEC_MSG, SELECTCODEC_START_ENTRY_POS, send_blink_cursor(), send_cursor_pos(), send_text(), show_main_page(), unistimsession::size_buff_entry, TEXT_INVERSE, and TEXT_LINE2.

Referenced by process_request().

{
   if (keycode == KEY_FUNC2) {
      if (pte->size_buff_entry <= 1)
         keycode = KEY_FUNC3;
      else {
         pte->size_buff_entry -= 2;
         keycode = pte->buff_entry[pte->size_buff_entry] + 0x10;
      }
   }
   if ((keycode >= KEY_0) && (keycode <= KEY_9)) {
      char tmpbuf[] = SELECTCODEC_MSG;
      int i = 0;

      if (pte->size_buff_entry >= SELECTCODEC_MAX_LENGTH)
         return;

      while (i < pte->size_buff_entry) {
         tmpbuf[i + SELECTCODEC_START_ENTRY_POS] = pte->buff_entry[i];
         i++;
      }
      tmpbuf[i + SELECTCODEC_START_ENTRY_POS] = keycode - 0x10;
      pte->buff_entry[i] = keycode - 0x10;
      pte->size_buff_entry++;
      send_text(TEXT_LINE2, TEXT_INVERSE, pte, tmpbuf);
      send_blink_cursor(pte);
      send_cursor_pos(pte,
                 (unsigned char) (TEXT_LINE2 + SELECTCODEC_START_ENTRY_POS + 1 + i));
      return;
   }

   switch (keycode) {
   case KEY_FUNC1:
      if (pte->size_buff_entry == 1)
         pte->device->codec_number = pte->buff_entry[0] - 48;
      else if (pte->size_buff_entry == 2)
         pte->device->codec_number =
            ((pte->buff_entry[0] - 48) * 10) + (pte->buff_entry[1] - 48);
      show_main_page(pte);
      break;
   case KEY_FUNC3:
      pte->size_buff_entry = 0;
      send_text(TEXT_LINE2, TEXT_INVERSE, pte, SELECTCODEC_MSG);
      send_blink_cursor(pte);
      send_cursor_pos(pte, TEXT_LINE2 + SELECTCODEC_START_ENTRY_POS);
      break;
   case KEY_HANGUP:
   case KEY_FUNC4:
      show_main_page(pte);
      break;
   }
   return;
}

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

Definition at line 2862 of file chan_unistim.c.

References ast_copy_string(), ast_mutex_lock(), ast_mutex_unlock(), AUTOPROVISIONING_TN, unistimsession::buff_entry, unistim_device::codec_number, DEFAULT_CODEC, unistimsession::device, devicelock, unistim_device::extension, unistim_device::extension_number, EXTENSION_TN, unistim_device::id, KEY_0, KEY_9, KEY_FUNC1, KEY_FUNC2, KEY_FUNC3, unistimsession::macaddr, unistim_device::missed_call, unistim_device::next, unistim_device::pos_fav, unistim_device::receiver_state, refresh_all_favorite(), RegisterExtension(), SELECTEXTENSION_MAX_LENGTH, SELECTEXTENSION_MSG, SELECTEXTENSION_START_ENTRY_POS, send_blink_cursor(), send_cursor_pos(), send_text(), unistim_device::session, show_main_page(), unistimsession::size_buff_entry, STATE_ONHOOK, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, and TEXT_NORMAL.

Referenced by process_request().

{
   if (keycode == KEY_FUNC2) {
      if (pte->size_buff_entry <= 1)
         keycode = KEY_FUNC3;
      else {
         pte->size_buff_entry -= 2;
         keycode = pte->buff_entry[pte->size_buff_entry] + 0x10;
      }
   }
   if ((keycode >= KEY_0) && (keycode <= KEY_9)) {
      char tmpbuf[] = SELECTEXTENSION_MSG;
      int i = 0;

      if (pte->size_buff_entry >= SELECTEXTENSION_MAX_LENGTH)
         return;

      while (i < pte->size_buff_entry) {
         tmpbuf[i + SELECTEXTENSION_START_ENTRY_POS] = pte->buff_entry[i];
         i++;
      }
      tmpbuf[i + SELECTEXTENSION_START_ENTRY_POS] = keycode - 0x10;
      pte->buff_entry[i] = keycode - 0x10;
      pte->size_buff_entry++;
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmpbuf);
      send_blink_cursor(pte);
      send_cursor_pos(pte,
                 (unsigned char) (TEXT_LINE2 + SELECTEXTENSION_START_ENTRY_POS + 1 +
                              i));
      return;
   }

   switch (keycode) {
   case KEY_FUNC1:
      if (pte->size_buff_entry < 1)
         return;
      if (autoprovisioning == AUTOPROVISIONING_TN) {
         struct unistim_device *d;

         /* First step : looking for this TN in our device list */
         ast_mutex_lock(&devicelock);
         d = devices;
         pte->buff_entry[pte->size_buff_entry] = '\0';
         while (d) {
            if (d->id[0] == 'T') {  /* It's a TN device ? */
               /* It's the TN we're looking for ? */
               if (!strcmp((d->id) + 1, pte->buff_entry)) {
                  pte->device = d;
                  d->session = pte;
                  d->codec_number = DEFAULT_CODEC;
                  d->pos_fav = 0;
                  d->missed_call = 0;
                  d->receiver_state = STATE_ONHOOK;
                  strcpy(d->id, pte->macaddr);
                  pte->device->extension_number[0] = 'T';
                  pte->device->extension = EXTENSION_TN;
                  ast_copy_string((pte->device->extension_number) + 1,
                              pte->buff_entry, pte->size_buff_entry + 1);
                  ast_mutex_unlock(&devicelock);
                  show_main_page(pte);
                  refresh_all_favorite(pte);
                  return;
               }
            }
            d = d->next;
         }
         ast_mutex_unlock(&devicelock);
         send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Invalid Terminal Number.");
         send_text(TEXT_LINE1, TEXT_NORMAL, pte, "Please try again :");
         send_cursor_pos(pte,
                    (unsigned char) (TEXT_LINE2 + SELECTEXTENSION_START_ENTRY_POS +
                                 pte->size_buff_entry));
         send_blink_cursor(pte);
      } else {
         ast_copy_string(pte->device->extension_number, pte->buff_entry,
                     pte->size_buff_entry + 1);
         if (RegisterExtension(pte)) {
            send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Invalid extension.");
            send_text(TEXT_LINE1, TEXT_NORMAL, pte, "Please try again :");
            send_cursor_pos(pte,
                       (unsigned char) (TEXT_LINE2 +
                                    SELECTEXTENSION_START_ENTRY_POS +
                                    pte->size_buff_entry));
            send_blink_cursor(pte);
         } else
            show_main_page(pte);
      }
      break;
   case KEY_FUNC3:
      pte->size_buff_entry = 0;
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, SELECTEXTENSION_MSG);
      send_blink_cursor(pte);
      send_cursor_pos(pte, TEXT_LINE2 + SELECTEXTENSION_START_ENTRY_POS);
      break;
   }
   return;
}

static void Keyfavorite	(	struct unistimsession *	pte,
		char	keycode
	)			[static]

Definition at line 2632 of file chan_unistim.c.

References ast_copy_string(), ast_log(), unistimsession::device, HandleCallOutgoing(), KEY_FAV0, KEY_FAV1, KEY_FAV5, LOG_WARNING, unistim_device::phone_number, unistim_device::softkeyicon, and unistim_device::softkeynumber.

Referenced by key_dial_page(), and key_main_page().

{
   int fav;

   if ((keycode < KEY_FAV1) && (keycode > KEY_FAV5)) {
      ast_log(LOG_WARNING, "It's not a favorite key\n");
      return;
   }
   if (keycode == KEY_FAV0)
      return;
   fav = keycode - KEY_FAV0;
   if (pte->device->softkeyicon[fav] == 0)
      return;
   ast_copy_string(pte->device->phone_number, pte->device->softkeynumber[fav],
               sizeof(pte->device->phone_number));
   HandleCallOutgoing(pte);
   return;
}

int load_module

(

void

)

[static]

XXX

Todo:

Leaking anything allocated by reload_config() ...

Definition at line 5564 of file chan_unistim.c.

References ARRAY_LEN, ast_channel_register(), ast_cli_register_multiple(), ast_free, ast_log(), ast_malloc, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_SUCCESS, ast_rtp_proto_register(), io_context_create(), io_context_destroy(), LOG_ERROR, reload_config(), restart_monitor(), sched_context_create(), sched_context_destroy(), and SIZE_PAGE.

{
   int res;

   if (!(buff = ast_malloc(SIZE_PAGE)))
      goto buff_failed;

   io = io_context_create();
   if (!io) {
      ast_log(LOG_ERROR, "Failed to allocate IO context\n");
      goto io_failed;
   }

   sched = sched_context_create();
   if (!sched) {
      ast_log(LOG_ERROR, "Failed to allocate scheduler context\n");
      goto sched_failed;
   }

   res = reload_config();
   if (res)
      return AST_MODULE_LOAD_DECLINE;

   /* Make sure we can register our unistim channel type */
   if (ast_channel_register(&unistim_tech)) {
      ast_log(LOG_ERROR, "Unable to register channel type '%s'\n", channel_type);
      goto chanreg_failed;
   } 

   ast_rtp_proto_register(&unistim_rtp);

   ast_cli_register_multiple(unistim_cli, ARRAY_LEN(unistim_cli));

   restart_monitor();

   return AST_MODULE_LOAD_SUCCESS;

chanreg_failed:
   /*! XXX \todo Leaking anything allocated by reload_config() ... */
   sched_context_destroy(sched);
   sched = NULL;
sched_failed:
   io_context_destroy(io);
   io = NULL;
io_failed:
   ast_free(buff);
   buff = NULL;
buff_failed:
   return AST_MODULE_LOAD_FAILURE;
}

static char OpenHistory	(	struct unistimsession *	pte,
		char	way,
		FILE **	f
	)			[static]

Definition at line 3027 of file chan_unistim.c.

References ast_config_AST_LOG_DIR, AST_CONFIG_MAX_PATH, ast_log(), unistimsession::device, display_last_error(), LOG_WARNING, MAX_ENTRY_LOG, unistim_device::name, and USTM_LOG_DIR.

Referenced by key_history(), and show_history().

{
   char tmp[AST_CONFIG_MAX_PATH];
   char count;

   snprintf(tmp, sizeof(tmp), "%s/%s/%s-%c.csv", ast_config_AST_LOG_DIR,
          USTM_LOG_DIR, pte->device->name, way);
   *f = fopen(tmp, "r");
   if (!*f) {
      display_last_error("Unable to open history file");
      return 0;
   }
   if (fread(&count, 1, 1, *f) != 1) {
      display_last_error("Unable to read history header - display.");
      fclose(*f);
      return 0;
   }
   if (count > MAX_ENTRY_LOG) {
      ast_log(LOG_WARNING, "Invalid count in history header of %s (%d max %d)\n", tmp,
            count, MAX_ENTRY_LOG);
      fclose(*f);
      return 0;
   }
   return count;
}

static int ParseBookmark	(	const char *	text,
		struct unistim_device *	d
	)			[static]

Definition at line 4891 of file chan_unistim.c.

References ast_copy_string(), ast_log(), ast_strlen_zero(), ast_verb, FAV_ICON_SHARP, len(), LOG_NOTICE, LOG_WARNING, unistim_device::softkeydevice, unistim_device::softkeyicon, unistim_device::softkeylabel, and unistim_device::softkeynumber.

Referenced by build_device().

{
   char line[256];
   char *at;
   char *number;
   char *icon;
   int p;
   int len = strlen(text);

   ast_copy_string(line, text, sizeof(line));
   /* Position specified ? */
   if ((len > 2) && (line[1] == '@')) {
      p = line[0];
      if ((p >= '0') && (p <= '5'))
         p -= '0';
      else {
         ast_log(LOG_WARNING,
               "Invalid position for bookmark : must be between 0 and 5\n");
         return 0;
      }
      if (d->softkeyicon[p] != 0) {
         ast_log(LOG_WARNING, "Invalid position %d for bookmark : already used\n:", p);
         return 0;
      }
      memmove(line, line + 2, sizeof(line));
   } else {
      /* No position specified, looking for a free slot */
      for (p = 0; p <= 5; p++) {
         if (!d->softkeyicon[p])
            break;
      }
      if (p > 5) {
         ast_log(LOG_WARNING, "No more free bookmark position\n");
         return 0;
      }
   }
   at = strchr(line, '@');
   if (!at) {
      ast_log(LOG_NOTICE, "Bookmark entry '%s' has no @ (at) sign!\n", text);
      return 0;
   }
   *at = '\0';
   at++;
   number = at;
   at = strchr(at, '@');
   if (ast_strlen_zero(number)) {
      ast_log(LOG_NOTICE, "Bookmark entry '%s' has no number\n", text);
      return 0;
   }
   if (ast_strlen_zero(line)) {
      ast_log(LOG_NOTICE, "Bookmark entry '%s' has no description\n", text);
      return 0;
   }

   at = strchr(number, '@');
   if (!at)
      d->softkeyicon[p] = FAV_ICON_SHARP;     /* default icon */
   else {
      *at = '\0';
      at++;
      icon = at;
      if (ast_strlen_zero(icon)) {
         ast_log(LOG_NOTICE, "Bookmark entry '%s' has no icon value\n", text);
         return 0;
      }
      if (strncmp(icon, "USTM/", 5))
         d->softkeyicon[p] = atoi(icon);
      else {
         d->softkeyicon[p] = 1;
         ast_copy_string(d->softkeydevice[p], icon + 5, sizeof(d->softkeydevice[p]));
      }
   }
   ast_copy_string(d->softkeylabel[p], line, sizeof(d->softkeylabel[p]));
   ast_copy_string(d->softkeynumber[p], number, sizeof(d->softkeynumber[p]));
   if (unistimdebug)
      ast_verb(0, "New bookmark at pos %d label='%s' number='%s' icon=%x\n",
               p, d->softkeylabel[p], d->softkeynumber[p], d->softkeyicon[p]);
   return 1;
}

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

Definition at line 3463 of file chan_unistim.c.

References ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verb, check_send_queue(), close_client(), create_client(), unistimsession::last_seq_ack, unistimsession::lock, LOG_NOTICE, LOG_WARNING, unistimsession::nb_retransmit, process_request(), send_raw_client(), send_retransmit(), seq, unistimsession::seq_phone, unistimsession::seq_server, SIZE_HEADER, unistimsession::sout, unistimsession::state, and STATE_INIT.

Referenced by unistimsock_read().

{
   unsigned short *sbuf = (unsigned short *) buf;
   unsigned short seq;
   char tmpbuf[255];

   strcpy(tmpbuf, ast_inet_ntoa(addr_from->sin_addr));

   if (size < 10) {
      if (size == 0) {
         ast_log(LOG_WARNING, "%s Read error\n", tmpbuf);
      } else {
         ast_log(LOG_NOTICE, "%s Packet too short - ignoring\n", tmpbuf);
      }
      return;
   }
   if (sbuf[0] == 0xffff) {   /* Starting with 0xffff ? *//* Yes, discovery packet ? */
      if (size != sizeof(packet_rcv_discovery)) {
         ast_log(LOG_NOTICE, "%s Invalid size of a discovery packet\n", tmpbuf);
      } else {
         if (memcmp(buf, packet_rcv_discovery, sizeof(packet_rcv_discovery)) == 0) {
            if (unistimdebug)
               ast_verb(0, "Discovery packet received - Sending Discovery ACK\n");
            if (pte) {        /* A session was already active for this IP ? */
               if (pte->state == STATE_INIT) { /* Yes, but it's a dupe */
                  if (unistimdebug)
                     ast_verb(1, "Duplicated Discovery packet\n");
                  send_raw_client(sizeof(packet_send_discovery_ack),
                             packet_send_discovery_ack, addr_from, &pte->sout);
                  pte->seq_phone = (short) 0x0000; /* reset sequence number */
               } else { /* No, probably a reboot, phone side */
                  close_client(pte);       /* Cleanup the previous session */
                  if (create_client(addr_from))
                     send_raw_client(sizeof(packet_send_discovery_ack),
                                packet_send_discovery_ack, addr_from, &pte->sout);
               }
            } else {
               /* Creating new entry in our phone list */
               if ((pte = create_client(addr_from)))
                  send_raw_client(sizeof(packet_send_discovery_ack),
                             packet_send_discovery_ack, addr_from, &pte->sout);
            }
            return;
         }
         ast_log(LOG_NOTICE, "%s Invalid discovery packet\n", tmpbuf);
      }
      return;
   }
   if (!pte) {
      if (unistimdebug)
         ast_verb(0, "%s Not a discovery packet from an unknown source : ignoring\n",
                  tmpbuf);
      return;
   }

   if (sbuf[0] != 0) {          /* Starting with something else than 0x0000 ? */
      ast_log(LOG_NOTICE, "Unknown packet received - ignoring\n");
      return;
   }
   if (buf[5] != 2) {
      ast_log(LOG_NOTICE, "%s Wrong direction : got 0x%.2x expected 0x02\n", tmpbuf,
            buf[5]);
      return;
   }
   seq = ntohs(sbuf[1]);
   if (buf[4] == 1) {
      ast_mutex_lock(&pte->lock);
      if (unistimdebug)
         ast_verb(6, "ACK received for packet #0x%.4x\n", seq);
      pte->nb_retransmit = 0;

      if ((pte->last_seq_ack) + 1 == seq) {
         pte->last_seq_ack++;
         check_send_queue(pte);
         ast_mutex_unlock(&pte->lock);
         return;
      }
      if (pte->last_seq_ack > seq) {
         if (pte->last_seq_ack == 0xffff) {
            ast_verb(0, "ACK at 0xffff, restarting counter.\n");
            pte->last_seq_ack = 0;
         } else
            ast_log(LOG_NOTICE,
                  "%s Warning : ACK received for an already ACKed packet : #0x%.4x we are at #0x%.4x\n",
                  tmpbuf, seq, pte->last_seq_ack);
         ast_mutex_unlock(&pte->lock);
         return;
      }
      if (pte->seq_server < seq) {
         ast_log(LOG_NOTICE,
               "%s Error : ACK received for a non-existent packet : #0x%.4x\n",
               tmpbuf, pte->seq_server);
         ast_mutex_unlock(&pte->lock);
         return;
      }
      if (unistimdebug)
         ast_verb(0, "%s ACK gap : Received ACK #0x%.4x, previous was #0x%.4x\n",
                  tmpbuf, seq, pte->last_seq_ack);
      pte->last_seq_ack = seq;
      check_send_queue(pte);
      ast_mutex_unlock(&pte->lock);
      return;
   }
   if (buf[4] == 2) {
      if (unistimdebug)
         ast_verb(0, "Request received\n");
      if (pte->seq_phone == seq) {
         /* Send ACK */
         buf[4] = 1;
         buf[5] = 1;
         send_raw_client(SIZE_HEADER, buf, addr_from, &pte->sout);
         pte->seq_phone++;

         process_request(size, buf, pte);
         return;
      }
      if (pte->seq_phone > seq) {
         ast_log(LOG_NOTICE,
               "%s Warning : received a retransmitted packet : #0x%.4x (we are at #0x%.4x)\n",
               tmpbuf, seq, pte->seq_phone);
         /* BUG ? pte->device->seq_phone = seq; */
         /* Send ACK */
         buf[4] = 1;
         buf[5] = 1;
         send_raw_client(SIZE_HEADER, buf, addr_from, &pte->sout);
         return;
      }
      ast_log(LOG_NOTICE,
            "%s Warning : we lost a packet : received #0x%.4x (we are at #0x%.4x)\n",
            tmpbuf, seq, pte->seq_phone);
      return;
   }
   if (buf[4] == 0) {
      ast_log(LOG_NOTICE, "%s Retransmit request for packet #0x%.4x\n", tmpbuf, seq);
      if (pte->last_seq_ack > seq) {
         ast_log(LOG_NOTICE,
               "%s Error : received a request for an already ACKed packet : #0x%.4x\n",
               tmpbuf, pte->last_seq_ack);
         return;
      }
      if (pte->seq_server < seq) {
         ast_log(LOG_NOTICE,
               "%s Error : received a request for a non-existent packet : #0x%.4x\n",
               tmpbuf, pte->seq_server);
         return;
      }
      send_retransmit(pte);
      return;
   }
   ast_log(LOG_NOTICE, "%s Unknown request : got 0x%.2x expected 0x00,0x01 or 0x02\n",
         tmpbuf, buf[4]);
   return;
}

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

Definition at line 3344 of file chan_unistim.c.

References ast_debug, ast_inet_ntoa(), ast_log(), ast_verb, close_call(), unistimsession::device, handle_dial_page(), HandleCallIncoming(), init_phone_step2(), key_call(), key_dial_page(), key_history(), key_main_page(), key_ringing(), key_select_codec(), key_select_extension(), unistim_device::lines, LOG_WARNING, MUTE_OFF, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, unistim_subchannel::owner, rcv_mac_addr(), rcv_resume_connection_with_server(), unistim_device::receiver_state, send_select_output(), show_main_page(), unistimsession::sin, SIZE_HEADER, unistimsession::state, STATE_AUTHDENY, STATE_CALL, STATE_DIALPAGE, STATE_EXTENSION, STATE_HISTORY, STATE_INIT, STATE_MAINPAGE, STATE_OFFHOOK, STATE_ONHOOK, STATE_RINGING, STATE_SELECTCODEC, SUB_REAL, unistim_line::subs, and unistim_device::volume.

Referenced by parsing().

{
   char tmpbuf[255];
   if (memcmp
      (buf + SIZE_HEADER, packet_recv_resume_connection_with_server,
       sizeof(packet_recv_resume_connection_with_server)) == 0) {
      rcv_resume_connection_with_server(pte);
      return;
   }
   if (memcmp(buf + SIZE_HEADER, packet_recv_firm_version, sizeof(packet_recv_firm_version)) ==
      0) {
      buf[size] = 0;
      if (unistimdebug)
         ast_verb(0, "Got the firmware version : '%s'\n", buf + 13);
      init_phone_step2(pte);
      return;
   }
   if (memcmp(buf + SIZE_HEADER, packet_recv_mac_addr, sizeof(packet_recv_mac_addr)) == 0) {
      rcv_mac_addr(pte, buf);
      return;
   }
   if (memcmp(buf + SIZE_HEADER, packet_recv_r2, sizeof(packet_recv_r2)) == 0) {
      if (unistimdebug)
         ast_verb(0, "R2 received\n");
      return;
   }

   if (pte->state < STATE_MAINPAGE) {
      if (unistimdebug)
         ast_verb(0, "Request not authorized in this state\n");
      return;
   }
   if (!memcmp(buf + SIZE_HEADER, packet_recv_pressed_key, sizeof(packet_recv_pressed_key))) {
      char keycode = buf[13];

      if (unistimdebug)
         ast_verb(0, "Key pressed : keycode = 0x%.2x - current state : %d\n", keycode,
                  pte->state);

      switch (pte->state) {
      case STATE_INIT:
         if (unistimdebug)
            ast_verb(0, "No keys allowed in the init state\n");
         break;
      case STATE_AUTHDENY:
         if (unistimdebug)
            ast_verb(0, "No keys allowed in authdeny state\n");
         break;
      case STATE_MAINPAGE:
         key_main_page(pte, keycode);
         break;
      case STATE_DIALPAGE:
         key_dial_page(pte, keycode);
         break;
      case STATE_RINGING:
         key_ringing(pte, keycode);
         break;
      case STATE_CALL:
         key_call(pte, keycode);
         break;
      case STATE_EXTENSION:
         key_select_extension(pte, keycode);
         break;
      case STATE_SELECTCODEC:
         key_select_codec(pte, keycode);
         break;
      case STATE_HISTORY:
         key_history(pte, keycode);
         break;
      default:
         ast_log(LOG_WARNING, "Key : Unknown state\n");
      }
      return;
   }
   if (memcmp(buf + SIZE_HEADER, packet_recv_pick_up, sizeof(packet_recv_pick_up)) == 0) {
      if (unistimdebug)
         ast_verb(0, "Handset off hook\n");
      if (!pte->device)        /* We are not yet registered (asking for a TN in AUTOPROVISIONING_TN) */
         return;
      pte->device->receiver_state = STATE_OFFHOOK;
      if (pte->device->output == OUTPUT_HEADPHONE)
         send_select_output(pte, OUTPUT_HEADPHONE, pte->device->volume, MUTE_OFF);
      else
         send_select_output(pte, OUTPUT_HANDSET, pte->device->volume, MUTE_OFF);
      if (pte->state == STATE_RINGING)
         HandleCallIncoming(pte);
      else if ((pte->state == STATE_DIALPAGE) || (pte->state == STATE_CALL))
         send_select_output(pte, OUTPUT_HANDSET, pte->device->volume, MUTE_OFF);
      else if (pte->state == STATE_EXTENSION) /* We must have a TN before calling */
         return;
      else {
         send_select_output(pte, OUTPUT_HANDSET, pte->device->volume, MUTE_OFF);
         handle_dial_page(pte);
      }
      return;
   }
   if (memcmp(buf + SIZE_HEADER, packet_recv_hangup, sizeof(packet_recv_hangup)) == 0) {
      if (unistimdebug)
         ast_verb(0, "Handset on hook\n");
      if (!pte->device)
         return;
      pte->device->receiver_state = STATE_ONHOOK;
      if (pte->state == STATE_CALL)
         close_call(pte);
      else if (pte->device->lines->subs[SUB_REAL]->owner)
         close_call(pte);
      else if (pte->state == STATE_EXTENSION)
         return;
      else
         show_main_page(pte);
      return;
   }
   strcpy(tmpbuf, ast_inet_ntoa(pte->sin.sin_addr));
   strcat(tmpbuf, " Unknown request packet\n");
   if (unistimdebug)
      ast_debug(1, "%s", tmpbuf);
   return;
}

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

Definition at line 1509 of file chan_unistim.c.

References alloc_sub(), ast_copy_string(), ast_free, ast_log(), ast_malloc, ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), ast_verb, AUTOPROVISIONING_DB, AUTOPROVISIONING_NO, AUTOPROVISIONING_TN, AUTOPROVISIONING_YES, BUFFSEND, unistimsession::device, devicelock, unistim_device::extension, EXTENSION_ASK, EXTENSION_LINE, EXTENSION_NONE, unistim_device::extension_number, EXTENSION_TN, unistim_line::fullname, unistim_device::id, unistim_device::lines, LOG_WARNING, unistimsession::macaddr, unistim_line::name, unistim_device::name, unistim_device::next, unistim_line::parent, unistim_device::receiver_state, RegisterExtension(), send_client(), send_date_time(), unistim_device::session, SIZE_HEADER, unistimsession::state, STATE_AUTHDENY, STATE_EXTENSION, STATE_MAINPAGE, STATE_ONHOOK, SUB_REAL, unistim_device::to_delete, and unistim_register().

Referenced by process_request().

{
   BUFFSEND;
   int tmp, i = 0;
   char addrmac[19];
   int res = 0;
   if (unistimdebug)
      ast_verb(0, "Mac Address received : ");
   for (tmp = 15; tmp < 15 + SIZE_HEADER; tmp++) {
      sprintf(&addrmac[i], "%.2x", (unsigned char) buf[tmp]);
      i += 2;
   }
   if (unistimdebug)
      ast_verb(0, "%s\n", addrmac);
   strcpy(pte->macaddr, addrmac);
   res = unistim_register(pte);
   if (!res) {
      switch (autoprovisioning) {
      case AUTOPROVISIONING_NO:
         ast_log(LOG_WARNING, "No entry found for this phone : %s\n", addrmac);
         pte->state = STATE_AUTHDENY;
         break;
      case AUTOPROVISIONING_YES:
         {
            struct unistim_device *d, *newd;
            struct unistim_line *newl;
            if (unistimdebug)
               ast_verb(0, "New phone, autoprovisioning on\n");
            /* First : locate the [template] section */
            ast_mutex_lock(&devicelock);
            d = devices;
            while (d) {
               if (!strcasecmp(d->name, "template")) {
                  /* Found, cloning this entry */
                  if (!(newd = ast_malloc(sizeof(*newd)))) {
                     ast_mutex_unlock(&devicelock);
                     return;
                  }

                  memcpy(newd, d, sizeof(*newd));
                  if (!(newl = ast_malloc(sizeof(*newl)))) {
                     ast_free(newd);
                     ast_mutex_unlock(&devicelock);
                     return;
                  }

                  memcpy(newl, d->lines, sizeof(*newl));
                  if (!alloc_sub(newl, SUB_REAL)) {
                     ast_free(newd);
                     ast_free(newl);
                     ast_mutex_unlock(&devicelock);
                     return;
                  }
                  /* Ok, now updating some fields */
                  ast_copy_string(newd->id, addrmac, sizeof(newd->id));
                  ast_copy_string(newd->name, addrmac, sizeof(newd->name));
                  if (newd->extension == EXTENSION_NONE)
                     newd->extension = EXTENSION_ASK;
                  newd->lines = newl;
                  newd->receiver_state = STATE_ONHOOK;
                  newd->session = pte;
                  newd->to_delete = -1;
                  pte->device = newd;
                  newd->next = NULL;
                  newl->parent = newd;
                  strcpy(newl->name, d->lines->name);
                  snprintf(d->lines->name, sizeof(d->lines->name), "%d",
                         atoi(d->lines->name) + 1);
                  snprintf(newl->fullname, sizeof(newl->fullname), "USTM/%s@%s",
                         newl->name, newd->name);
                  /* Go to the end of the linked chain */
                  while (d->next) {
                     d = d->next;
                  }
                  d->next = newd;
                  d = newd;
                  break;
               }
               d = d->next;
            }
            ast_mutex_unlock(&devicelock);
            if (!d) {
               ast_log(LOG_WARNING, "No entry [template] found in unistim.conf\n");
               pte->state = STATE_AUTHDENY;
            }
         }
         break;
      case AUTOPROVISIONING_TN:
         pte->state = STATE_AUTHDENY;
         break;
      case AUTOPROVISIONING_DB:
         ast_log(LOG_WARNING,
               "Autoprovisioning with database is not yet functional\n");
         break;
      default:
         ast_log(LOG_WARNING, "Internal error : unknown autoprovisioning value = %d\n",
               autoprovisioning);
      }
   }
   if (pte->state != STATE_AUTHDENY) {
      ast_verb(3, "Device '%s' successfuly registered\n", pte->device->name);
      switch (pte->device->extension) {
      case EXTENSION_NONE:
         pte->state = STATE_MAINPAGE;
         break;
      case EXTENSION_ASK:
         /* Checking if we already have an extension number */
         if (ast_strlen_zero(pte->device->extension_number))
            pte->state = STATE_EXTENSION;
         else {
            /* Yes, because of a phone reboot. We don't ask again for the TN */
            if (RegisterExtension(pte))
               pte->state = STATE_EXTENSION;
            else
               pte->state = STATE_MAINPAGE;
         }
         break;
      case EXTENSION_LINE:
         ast_copy_string(pte->device->extension_number, pte->device->lines->name,
                     sizeof(pte->device->extension_number));
         if (RegisterExtension(pte))
            pte->state = STATE_EXTENSION;
         else
            pte->state = STATE_MAINPAGE;
         break;
      case EXTENSION_TN:
         /* If we are here, it's because of a phone reboot */
         pte->state = STATE_MAINPAGE;
         break;
      default:
         ast_log(LOG_WARNING, "Internal error, extension value unknown : %d\n",
               pte->device->extension);
         pte->state = STATE_AUTHDENY;
         break;
      }
   }
   if (pte->state == STATE_EXTENSION) {
      if (pte->device->extension != EXTENSION_TN)
         pte->device->extension = EXTENSION_ASK;
      pte->device->extension_number[0] = '\0';
   }
   if (unistimdebug)
      ast_verb(0, "\nSending S1\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_S1, sizeof(packet_send_S1));
   send_client(SIZE_HEADER + sizeof(packet_send_S1), buffsend, pte);

   if (unistimdebug)
      ast_verb(0, "Sending query_basic_manager_04\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_query_basic_manager_04,
         sizeof(packet_send_query_basic_manager_04));
   send_client(SIZE_HEADER + sizeof(packet_send_query_basic_manager_04), buffsend, pte);

   if (unistimdebug)
      ast_verb(0, "Sending query_basic_manager_10\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_query_basic_manager_10,
         sizeof(packet_send_query_basic_manager_10));
   send_client(SIZE_HEADER + sizeof(packet_send_query_basic_manager_10), buffsend, pte);

   send_date_time(pte);
   return;
}

static void rcv_resume_connection_with_server

(

struct unistimsession *

pte

)

[static]

Definition at line 1438 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by process_request().

{
   BUFFSEND;
   if (unistimdebug) {
      ast_verb(0, "ResumeConnectionWithServer received\n");
      ast_verb(0, "Sending packet_send_query_mac_address\n");
   }
   memcpy(buffsend + SIZE_HEADER, packet_send_query_mac_address,
         sizeof(packet_send_query_mac_address));
   send_client(SIZE_HEADER + sizeof(packet_send_query_mac_address), buffsend, pte);
   return;
}

static int ReformatNumber

(

char *

number

)

[static]

Definition at line 2960 of file chan_unistim.c.

Referenced by key_history(), and show_entry_history().

{
   int pos = 0, i = 0, size = strlen(number);

   for (; i < size; i++) {
      if ((number[i] >= '0') && (number[i] <= '9')) {
         if (i == pos) {
            pos++;
            continue;
         }
         number[pos] = number[i];
         pos++;
      }
   }
   number[pos] = 0;
   return pos;
}

static void refresh_all_favorite

(

struct unistimsession *

pte

)

[static]

Definition at line 1042 of file chan_unistim.c.

References ast_verb, unistimsession::device, FAV_ICON_HEADPHONES_ONHOLD, send_favorite(), unistim_device::softkeyicon, unistim_device::softkeylabel, and unistim_device::softkeylinepos.

Referenced by init_phone_step2(), key_select_extension(), and reload_config().

{
   int i = 0;

   if (unistimdebug)
      ast_verb(0, "Refreshing all favorite\n");
   for (i = 0; i < 6; i++) {
      if ((pte->device->softkeyicon[i] <= FAV_ICON_HEADPHONES_ONHOLD) &&
         (pte->device->softkeylinepos != i))
         send_favorite((unsigned char) i, pte->device->softkeyicon[i] + 1, pte,
                   pte->device->softkeylabel[i]);
      else
         send_favorite((unsigned char) i, pte->device->softkeyicon[i], pte,
                   pte->device->softkeylabel[i]);

   }
}

static int RegisterExtension

(

const struct unistimsession *

pte

)

[static]

Definition at line 1085 of file chan_unistim.c.

References ast_add_extension(), ast_verb, unistim_line::context, unistimsession::device, unistim_device::extension_number, unistim_line::fullname, and unistim_device::lines.

Referenced by key_select_extension(), and rcv_mac_addr().

{
   if (unistimdebug)
      ast_verb(0, "Trying to register extension '%s' into context '%s' to %s\n",
               pte->device->extension_number, pte->device->lines->context,
               pte->device->lines->fullname);
   return ast_add_extension(pte->device->lines->context, 0,
                      pte->device->extension_number, 1, NULL, NULL, "Dial",
                      pte->device->lines->fullname, 0, "Unistim");
}

static int reload

(

void

)

[static]

reload: Part of Asterisk module interface ---

Definition at line 5644 of file chan_unistim.c.

References unistim_reload().

{
   unistim_reload(NULL, 0, NULL);
   return 0;
}

static int reload_config

(

void

)

[static]

Definition at line 5286 of file chan_unistim.c.

References ast_category_browse(), ast_config_destroy(), ast_config_load, ast_free, ast_gethostbyname(), ast_inet_ntoa(), ast_jb_read_conf(), ast_log(), ast_mutex_destroy(), ast_mutex_lock(), ast_mutex_unlock(), ast_netsock_set_qos(), ast_str2cos(), ast_str2tos(), ast_strlen_zero(), ast_variable_browse(), ast_verb, AUTOPROVISIONING_DB, AUTOPROVISIONING_NO, AUTOPROVISIONING_TN, AUTOPROVISIONING_YES, build_device(), config, unistimsession::device, devicelock, errno, finish_bookmark(), global_jbconf, hp, ast_variable::lineno, unistim_device::lines, unistimsession::lock, unistim_line::lock, unistim_subchannel::lock, LOG_ERROR, LOG_WARNING, MAX_SUBS, unistim_device::name, ast_variable::name, NB_MAX_RETRANSMIT, unistimsession::next, unistim_device::next, ast_variable::next, unistim_subchannel::owner, qos, refresh_all_favorite(), RETRANSMIT_TIMER, s, unistim_device::session, sessionlock, unistim_line::subs, unistim_device::to_delete, and ast_variable::value.

Referenced by do_monitor(), and load_module().

{
   struct ast_config *cfg;
   struct ast_variable *v;
   struct ast_hostent ahp;
   struct hostent *hp;
   struct sockaddr_in bindaddr = { 0, };
   char *config = "unistim.conf";
   char *cat;
   struct unistim_device *d;
   const int reuseFlag = 1;
   struct unistimsession *s;
   struct ast_flags config_flags = { 0, };

   cfg = ast_config_load(config, config_flags);
   /* We *must* have a config file otherwise stop immediately */
   if (!cfg) {
      ast_log(LOG_ERROR, "Unable to load config %s\n", config);
      return -1;
   }
   
   /* Copy the default jb config over global_jbconf */
   memcpy(&global_jbconf, &default_jbconf, sizeof(struct ast_jb_conf));

   unistim_keepalive = 120;
   unistim_port = 0;
   v = ast_variable_browse(cfg, "general");
   while (v) {
      /* handle jb conf */
      if (!ast_jb_read_conf(&global_jbconf, v->name, v->value))
         continue;   
   
      if (!strcasecmp(v->name, "keepalive"))
         unistim_keepalive = atoi(v->value);
      else if (!strcasecmp(v->name, "port"))
         unistim_port = atoi(v->value);
                else if (!strcasecmp(v->name, "tos")) {
                        if (ast_str2tos(v->value, &qos.tos))
                            ast_log(LOG_WARNING, "Invalid tos value at line %d, refer to QoS documentation\n", v->lineno);
                } else if (!strcasecmp(v->name, "tos_audio")) {
                        if (ast_str2tos(v->value, &qos.tos_audio))
                            ast_log(LOG_WARNING, "Invalid tos_audio value at line %d, refer to QoS documentation\n", v->lineno);
                } else if (!strcasecmp(v->name, "cos")) {
                        if (ast_str2cos(v->value, &qos.cos))
                            ast_log(LOG_WARNING, "Invalid cos value at line %d, refer to QoS documentation\n", v->lineno);
                } else if (!strcasecmp(v->name, "cos_audio")) {
                        if (ast_str2cos(v->value, &qos.cos_audio))
                            ast_log(LOG_WARNING, "Invalid cos_audio value at line %d, refer to QoS documentation\n", v->lineno);
      } else if (!strcasecmp(v->name, "autoprovisioning")) {
         if (!strcasecmp(v->value, "no"))
            autoprovisioning = AUTOPROVISIONING_NO;
         else if (!strcasecmp(v->value, "yes"))
            autoprovisioning = AUTOPROVISIONING_YES;
         else if (!strcasecmp(v->value, "db"))
            autoprovisioning = AUTOPROVISIONING_DB;
         else if (!strcasecmp(v->value, "tn"))
            autoprovisioning = AUTOPROVISIONING_TN;
         else
            ast_log(LOG_WARNING, "Unknown autoprovisioning option.\n");
      } else if (!strcasecmp(v->name, "public_ip")) {
         if (!ast_strlen_zero(v->value)) {
            if (!(hp = ast_gethostbyname(v->value, &ahp)))
               ast_log(LOG_WARNING, "Invalid address: %s\n", v->value);
            else {
               memcpy(&public_ip.sin_addr, hp->h_addr, sizeof(public_ip.sin_addr));
               public_ip.sin_family = AF_INET;
            }
         }
      }
      v = v->next;
   }
   if ((unistim_keepalive < 10) ||
      (unistim_keepalive >
       255 - (((NB_MAX_RETRANSMIT + 1) * RETRANSMIT_TIMER) / 1000))) {
      ast_log(LOG_ERROR, "keepalive is invalid in %s\n", config);
      ast_config_destroy(cfg);
      return -1;
   }
   packet_send_ping[4] =
      unistim_keepalive + (((NB_MAX_RETRANSMIT + 1) * RETRANSMIT_TIMER) / 1000);
   if ((unistim_port < 1) || (unistim_port > 65535)) {
      ast_log(LOG_ERROR, "port is not set or invalid in %s\n", config);
      ast_config_destroy(cfg);
      return -1;
   }
   unistim_keepalive *= 1000;

   ast_mutex_lock(&devicelock);
   d = devices;
   while (d) {
      if (d->to_delete >= 0)
         d->to_delete = 1;
      d = d->next;
   }
   ast_mutex_unlock(&devicelock);
   /* load the device sections */
   cat = ast_category_browse(cfg, NULL);
   while (cat) {
      if (strcasecmp(cat, "general")) {
         d = build_device(cat, ast_variable_browse(cfg, cat));
      }
      cat = ast_category_browse(cfg, cat);
   }
   ast_mutex_lock(&devicelock);
   d = devices;
   while (d) {
      if (d->to_delete) {
         int i;

         if (unistimdebug)
            ast_verb(0, "Removing device '%s'\n", d->name);
         if (!d->lines) {
            ast_log(LOG_ERROR, "Device '%s' without a line !, aborting\n", d->name);
            ast_config_destroy(cfg);
            return 0;
         }
         if (!d->lines->subs[0]) {
            ast_log(LOG_ERROR, "Device '%s' without a subchannel !, aborting\n",
                  d->name);
            ast_config_destroy(cfg);
            return 0;
         }
         if (d->lines->subs[0]->owner) {
            ast_log(LOG_WARNING,
                  "Device '%s' was not deleted : a call is in progress. Try again later.\n",
                  d->name);
            d = d->next;
            continue;
         }
         ast_mutex_destroy(&d->lines->subs[0]->lock);
         ast_free(d->lines->subs[0]);
         for (i = 1; i < MAX_SUBS; i++) {
            if (d->lines->subs[i]) {
               ast_log(LOG_WARNING,
                     "Device '%s' with threeway call subchannels allocated, aborting.\n",
                     d->name);
               break;
            }
         }
         if (i < MAX_SUBS) {
            d = d->next;
            continue;
         }
         ast_mutex_destroy(&d->lines->lock);
         ast_free(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;
            }
         }
         ast_free(d);
         d = devices;
         continue;
      }
      d = d->next;
   }
   finish_bookmark();
   ast_mutex_unlock(&devicelock);
   ast_config_destroy(cfg);
   ast_mutex_lock(&sessionlock);
   s = sessions;
   while (s) {
      if (s->device)
         refresh_all_favorite(s);
      s = s->next;
   }
   ast_mutex_unlock(&sessionlock);
   /* We don't recreate a socket when reloading (locks would be necessary). */
   if (unistimsock > -1)
      return 0;
   bindaddr.sin_addr.s_addr = INADDR_ANY;
   bindaddr.sin_port = htons(unistim_port);
   bindaddr.sin_family = AF_INET;
   unistimsock = socket(AF_INET, SOCK_DGRAM, 0);
   if (unistimsock < 0) {
      ast_log(LOG_WARNING, "Unable to create UNISTIM socket: %s\n", strerror(errno));
      return -1;
   }
#ifdef HAVE_PKTINFO
   {
      const int pktinfoFlag = 1;
      setsockopt(unistimsock, IPPROTO_IP, IP_PKTINFO, &pktinfoFlag,
               sizeof(pktinfoFlag));
   }
#else
   if (public_ip.sin_family == 0) {
      ast_log(LOG_WARNING,
            "Your OS does not support IP_PKTINFO, you must set public_ip.\n");
      unistimsock = -1;
      return -1;
   }
#endif
   setsockopt(unistimsock, SOL_SOCKET, SO_REUSEADDR, (const char *) &reuseFlag,
            sizeof(reuseFlag));
   if (bind(unistimsock, (struct sockaddr *) &bindaddr, sizeof(bindaddr)) < 0) {
      ast_log(LOG_WARNING, "Failed to bind to %s:%d: %s\n",
            ast_inet_ntoa(bindaddr.sin_addr), htons(bindaddr.sin_port),
            strerror(errno));
      close(unistimsock);
      unistimsock = -1;
   } else {
      ast_verb(2, "UNISTIM Listening on %s:%d\n", ast_inet_ntoa(bindaddr.sin_addr), htons(bindaddr.sin_port));
      ast_netsock_set_qos(unistimsock, qos.tos, qos.cos, "UNISTIM");
   }
   return 0;
}

static int restart_monitor

(

void

)

[static]

Definition at line 4584 of file chan_unistim.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pthread_create, AST_PTHREADT_NULL, AST_PTHREADT_STOP, do_monitor(), LOG_ERROR, LOG_WARNING, and monlock.

Referenced by load_module(), unistim_reload(), and unistim_request().

{
   pthread_attr_t attr;
   /* If we're supposed to be stopped -- stay stopped */
   if (monitor_thread == AST_PTHREADT_STOP)
      return 0;
   if (ast_mutex_lock(&monlock)) {
      ast_log(LOG_WARNING, "Unable to lock monitor\n");
      return -1;
   }
   if (monitor_thread == pthread_self()) {
      ast_mutex_unlock(&monlock);
      ast_log(LOG_WARNING, "Cannot kill myself\n");
      return -1;
   }
   if (monitor_thread != AST_PTHREADT_NULL) {
      /* Wake up the thread */
      pthread_kill(monitor_thread, SIGURG);
   } else {
      pthread_attr_init(&attr);
      pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
      /* Start a new monitor */
      if (ast_pthread_create(&monitor_thread, &attr, do_monitor, NULL) < 0) {
         ast_mutex_unlock(&monlock);
         ast_log(LOG_ERROR, "Unable to start monitor thread.\n");
         return -1;
      }
   }
   ast_mutex_unlock(&monlock);
   return 0;
}

static void send_blink_cursor

(

struct unistimsession *

pte

)

[static]

Definition at line 1415 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by handle_dial_page(), HandleSelectCodec(), key_dial_page(), key_select_codec(), key_select_extension(), and ShowExtensionPage().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending set blink\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_blink_cursor, sizeof(packet_send_blink_cursor));
   send_client(SIZE_HEADER + sizeof(packet_send_blink_cursor), buffsend, pte);
   return;
}

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

Definition at line 788 of file chan_unistim.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verb, wsabuf::buf, get_tick_count(), unistimsession::last_buf_available, wsabuf::len, unistimsession::lock, LOG_WARNING, MAX_BUF_NUMBER, RETRANSMIT_TIMER, send_raw_client(), unistimsession::seq_server, unistimsession::sin, unistimsession::sout, unistimsession::timeout, and unistimsession::wsabufsend.

Referenced by init_phone_step2(), rcv_mac_addr(), rcv_resume_connection_with_server(), send_blink_cursor(), send_cursor_pos(), send_date_time(), send_date_time2(), send_date_time3(), send_end_call(), send_favorite(), send_led_update(), send_no_ring(), send_ping(), send_ring(), send_select_output(), send_start_timer(), send_stop_timer(), send_text(), send_text_status(), send_texttitle(), send_tone(), Sendicon(), start_rtp(), and unistim_sp().

{
   unsigned int tick;
   int buf_pos;
   unsigned short *sdata = (unsigned short *) data;

   ast_mutex_lock(&pte->lock);
   buf_pos = pte->last_buf_available;

   if (buf_pos >= MAX_BUF_NUMBER) {
      ast_log(LOG_WARNING, "Error : send queue overflow\n");
      ast_mutex_unlock(&pte->lock);
      return;
   }
   sdata[1] = ntohs(++(pte->seq_server));
   pte->wsabufsend[buf_pos].len = size;
   memcpy(pte->wsabufsend[buf_pos].buf, data, size);

   tick = get_tick_count();
   pte->timeout = tick + RETRANSMIT_TIMER;

/*#ifdef DUMP_PACKET */
   if (unistimdebug)
      ast_verb(6, "Sending datas with seq #0x%.4x Using slot #%d :\n", pte->seq_server, buf_pos);
/*#endif */
   send_raw_client(pte->wsabufsend[buf_pos].len, pte->wsabufsend[buf_pos].buf, &(pte->sin),
              &(pte->sout));
   pte->last_buf_available++;
   ast_mutex_unlock(&pte->lock);
}

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

Definition at line 1426 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by handle_dial_page(), HandleSelectCodec(), key_dial_page(), key_select_codec(), key_select_extension(), and ShowExtensionPage().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending set cursor position\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_set_pos_cursor,
         sizeof(packet_send_set_pos_cursor));
   buffsend[11] = pos;
   send_client(SIZE_HEADER + sizeof(packet_send_set_pos_cursor), buffsend, pte);
   return;
}

static void send_date_time

(

struct unistimsession *

pte

)

[static]

Definition at line 1360 of file chan_unistim.c.

References ast_localtime(), ast_tvnow(), ast_verb, BUFFSEND, send_client(), SIZE_HEADER, ast_tm::tm_hour, ast_tm::tm_mday, ast_tm::tm_min, and ast_tm::tm_mon.

Referenced by rcv_mac_addr().

{
   BUFFSEND;
   struct timeval now = ast_tvnow();
   struct ast_tm atm = { 0, };

   if (unistimdebug)
      ast_verb(0, "Sending Time & Date\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_date_time, sizeof(packet_send_date_time));
   ast_localtime(&now, &atm, NULL);
   buffsend[10] = (unsigned char) atm.tm_mon + 1;
   buffsend[11] = (unsigned char) atm.tm_mday;
   buffsend[12] = (unsigned char) atm.tm_hour;
   buffsend[13] = (unsigned char) atm.tm_min;
   send_client(SIZE_HEADER + sizeof(packet_send_date_time), buffsend, pte);
}

static void send_date_time2

(

struct unistimsession *

pte

)

[static]

Definition at line 1377 of file chan_unistim.c.

References ast_localtime(), ast_tvnow(), ast_verb, BUFFSEND, unistim_device::datetimeformat, unistimsession::device, send_client(), SIZE_HEADER, ast_tm::tm_hour, ast_tm::tm_mday, ast_tm::tm_min, and ast_tm::tm_mon.

Referenced by init_phone_step2().

{
   BUFFSEND;
   struct timeval now = ast_tvnow();
   struct ast_tm atm = { 0, };

   if (unistimdebug)
      ast_verb(0, "Sending Time & Date #2\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_date_time2, sizeof(packet_send_date_time2));
   ast_localtime(&now, &atm, NULL);
   if (pte->device)
      buffsend[9] = pte->device->datetimeformat;
   else
      buffsend[9] = 61;
   buffsend[14] = (unsigned char) atm.tm_mon + 1;
   buffsend[15] = (unsigned char) atm.tm_mday;
   buffsend[16] = (unsigned char) atm.tm_hour;
   buffsend[17] = (unsigned char) atm.tm_min;
   send_client(SIZE_HEADER + sizeof(packet_send_date_time2), buffsend, pte);
}

static void send_date_time3

(

struct unistimsession *

pte

)

[static]

Definition at line 1398 of file chan_unistim.c.

References ast_localtime(), ast_tvnow(), ast_verb, BUFFSEND, send_client(), SIZE_HEADER, ast_tm::tm_hour, ast_tm::tm_mday, ast_tm::tm_min, and ast_tm::tm_mon.

Referenced by init_phone_step2().

{
   BUFFSEND;
   struct timeval now = ast_tvnow();
   struct ast_tm atm = { 0, };

   if (unistimdebug)
      ast_verb(0, "Sending Time & Date #3\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_date_time3, sizeof(packet_send_date_time3));
   ast_localtime(&now, &atm, NULL);
   buffsend[10] = (unsigned char) atm.tm_mon + 1;
   buffsend[11] = (unsigned char) atm.tm_mday;
   buffsend[12] = (unsigned char) atm.tm_hour;
   buffsend[13] = (unsigned char) atm.tm_min;
   send_client(SIZE_HEADER + sizeof(packet_send_date_time3), buffsend, pte);
}

static void send_end_call

(

struct unistimsession *

pte

)

[static]

Definition at line 897 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by unistim_hangup().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending end call\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_end_call, sizeof(packet_send_end_call));
   send_client(SIZE_HEADER + sizeof(packet_send_end_call), buffsend, pte);
}

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

Definition at line 1023 of file chan_unistim.c.

References ast_verb, BUFFSEND, FAV_MAX_LENGTH, send_client(), and SIZE_HEADER.

Referenced by change_favorite_icon(), init_phone_step2(), refresh_all_favorite(), show_main_page(), and unistim_sendtext().

{
   BUFFSEND;
   int i;

   if (unistimdebug)
      ast_verb(0, "Sending favorite pos %d with status 0x%.2x\n", pos, status);
   memcpy(buffsend + SIZE_HEADER, packet_send_favorite, sizeof(packet_send_favorite));
   buffsend[10] = pos;
   buffsend[24] = pos;
   buffsend[25] = status;
   i = strlen(text);
   if (i > FAV_MAX_LENGTH)
      i = FAV_MAX_LENGTH;
   memcpy(buffsend + FAV_MAX_LENGTH + 1, text, i);
   send_client(SIZE_HEADER + sizeof(packet_send_favorite), buffsend, pte);
}

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

Definition at line 1251 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by handle_dial_page(), init_phone_step2(), send_select_output(), and unistim_send_mwi_to_peer().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending led_update (%x)\n", led);
   memcpy(buffsend + SIZE_HEADER, packet_send_led_update, sizeof(packet_send_led_update));
   buffsend[9] = led;
   send_client(SIZE_HEADER + sizeof(packet_send_led_update), buffsend, pte);
}

static void send_no_ring

(

struct unistimsession *

pte

)

[static]

Definition at line 1336 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by cancel_dial(), HandleCallIncoming(), IgnoreCall(), init_phone_step2(), and unistim_hangup().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending no ring packet\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_no_ring, sizeof(packet_send_no_ring));
   send_client(SIZE_HEADER + sizeof(packet_send_no_ring), buffsend, pte);
}

static void send_ping

(

struct unistimsession *

pte

)

[static]

Definition at line 819 of file chan_unistim.c.

References ast_verb, BUFFSEND, get_tick_count(), send_client(), SIZE_HEADER, and unistimsession::tick_next_ping.

Referenced by do_monitor(), and init_phone_step2().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(6, "Sending ping\n");
   pte->tick_next_ping = get_tick_count() + unistim_keepalive;
   memcpy(buffsend + SIZE_HEADER, packet_send_ping, sizeof(packet_send_ping));
   send_client(SIZE_HEADER + sizeof(packet_send_ping), buffsend, pte);
}

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

Definition at line 736 of file chan_unistim.c.

References ast_inet_ntoa(), ast_verb, and display_last_error().

Referenced by parsing(), send_client(), and send_retransmit().

{
#ifdef HAVE_PKTINFO
   struct iovec msg_iov;
   struct msghdr msg;
   char buffer[CMSG_SPACE(sizeof(struct in_pktinfo))];
   struct cmsghdr *ip_msg = (struct cmsghdr *) buffer;
   struct in_pktinfo *pki = (struct in_pktinfo *) CMSG_DATA(ip_msg);

   msg_iov.iov_base = data;
   msg_iov.iov_len = size;

   msg.msg_name = addr_to;  /* optional address */
   msg.msg_namelen = sizeof(struct sockaddr_in);   /* size of address */
   msg.msg_iov = &msg_iov;  /* scatter/gather array */
   msg.msg_iovlen = 1;          /* # elements in msg_iov */
   msg.msg_control = ip_msg;       /* ancillary data */
   msg.msg_controllen = sizeof(buffer);    /* ancillary data buffer len */
   msg.msg_flags = 0;            /* flags on received message */

   ip_msg->cmsg_len = CMSG_LEN(sizeof(*pki));
   ip_msg->cmsg_level = IPPROTO_IP;
   ip_msg->cmsg_type = IP_PKTINFO;
   pki->ipi_ifindex = 0;      /* Interface index, 0 = use interface specified in routing table */
   pki->ipi_spec_dst.s_addr = addr_ourip->sin_addr.s_addr; /* Local address */
   /* pki->ipi_addr = ;   Header Destination address - ignored by kernel */

#ifdef DUMP_PACKET
   if (unistimdebug) {
      int tmp;
      char iabuf[INET_ADDRSTRLEN];
      char iabuf2[INET_ADDRSTRLEN];
      ast_verb(0, "\n**> From %s sending %d bytes to %s ***\n",
               ast_inet_ntoa(addr_ourip->sin_addr), (int) size,
               ast_inet_ntoa(addr_to->sin_addr));
      for (tmp = 0; tmp < size; tmp++)
         ast_verb(0, "%.2x ", (unsigned char) data[tmp]);
      ast_verb(0, "\n******************************************\n");

   }
#endif

   if (sendmsg(unistimsock, &msg, 0) == -1)
      display_last_error("Error sending datas");
#else
   if (sendto(unistimsock, data, size, 0, (struct sockaddr *) addr_to, sizeof(*addr_to))
      == -1)
      display_last_error("Error sending datas");
#endif
}

static int send_retransmit

(

struct unistimsession *

pte

)

[static]

Definition at line 1156 of file chan_unistim.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verb, wsabuf::buf, close_client(), get_tick_count(), unistimsession::last_buf_available, unistimsession::last_seq_ack, wsabuf::len, unistimsession::lock, LOG_WARNING, NB_MAX_RETRANSMIT, unistimsession::nb_retransmit, RETRANSMIT_TIMER, send_raw_client(), seq, unistimsession::seq_server, unistimsession::sin, unistimsession::sout, unistimsession::timeout, and unistimsession::wsabufsend.

Referenced by do_monitor(), and parsing().

{
   int i;

   ast_mutex_lock(&pte->lock);
   if (++pte->nb_retransmit >= NB_MAX_RETRANSMIT) {
      if (unistimdebug)
         ast_verb(0, "Too many retransmit - freeing client\n");
      ast_mutex_unlock(&pte->lock);
      close_client(pte);
      return 1;
   }
   pte->timeout = get_tick_count() + RETRANSMIT_TIMER;

   for (i = pte->last_buf_available - (pte->seq_server - pte->last_seq_ack);
       i < pte->last_buf_available; i++) {
      if (i < 0) {
         ast_log(LOG_WARNING,
               "Asked to retransmit an ACKed slot ! last_buf_available=%d, seq_server = #0x%.4x last_seq_ack = #0x%.4x\n",
               pte->last_buf_available, pte->seq_server, pte->last_seq_ack);
         continue;
      }

      if (unistimdebug) {
         unsigned short *sbuf = (unsigned short *) pte->wsabufsend[i].buf;
         unsigned short seq;

         seq = ntohs(sbuf[1]);
         ast_verb(0, "Retransmit slot #%d (seq=#0x%.4x), last ack was #0x%.4x\n", i,
                  seq, pte->last_seq_ack);
      }
      send_raw_client(pte->wsabufsend[i].len, pte->wsabufsend[i].buf, &pte->sin,
                 &pte->sout);
   }
   ast_mutex_unlock(&pte->lock);
   return 0;
}

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

Definition at line 1325 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by unistim_call().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending ring packet\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_ring, sizeof(packet_send_ring));
   buffsend[24] = style + 0x10;
   buffsend[29] = volume * 0x10;
   send_client(SIZE_HEADER + sizeof(packet_send_ring), buffsend, pte);
}

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

Definition at line 1265 of file chan_unistim.c.

References ast_log(), ast_verb, BUFFSEND, change_favorite_icon(), unistimsession::device, FAV_ICON_HEADPHONES, FAV_ICON_HEADPHONES_ONHOLD, FAV_ICON_OFFHOOK_BLACK, FAV_ICON_ONHOLD_BLACK, FAV_ICON_SPEAKER_OFFHOOK_BLACK, FAV_ICON_SPEAKER_ONHOLD_BLACK, FAV_ICON_SPEAKER_ONHOOK_BLACK, LOG_WARNING, unistim_device::mute, MUTE_OFF, MUTE_ON, MUTE_ON_DISCRET, unistim_device::output, OUTPUT_HANDSET, OUTPUT_HEADPHONE, OUTPUT_SPEAKER, unistim_device::previous_output, unistim_device::receiver_state, send_client(), send_led_update(), SIZE_HEADER, STATE_OFFHOOK, VOLUME_LOW, and VOLUME_LOW_SPEAKER.

Referenced by handle_dial_page(), HandleCallIncoming(), HandleCallOutgoing(), key_call(), key_dial_page(), key_main_page(), process_request(), and show_main_page().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending select output packet output=%x volume=%x mute=%x\n", output,
               volume, mute);
   memcpy(buffsend + SIZE_HEADER, packet_send_select_output,
         sizeof(packet_send_select_output));
   buffsend[9] = output;
   if (output == OUTPUT_SPEAKER)
      volume = VOLUME_LOW_SPEAKER;
   else
      volume = VOLUME_LOW;
   buffsend[10] = volume;
   if (mute == MUTE_ON_DISCRET)
      buffsend[11] = MUTE_ON;
   else
      buffsend[11] = mute;
   send_client(SIZE_HEADER + sizeof(packet_send_select_output), buffsend, pte);
   if (mute == MUTE_OFF)
      send_led_update(pte, 0x18);
   else if (mute == MUTE_ON)
      send_led_update(pte, 0x19);
   pte->device->mute = mute;
   if (output == OUTPUT_HANDSET) {
      if (mute == MUTE_ON)
         change_favorite_icon(pte, FAV_ICON_ONHOLD_BLACK);
      else
         change_favorite_icon(pte, FAV_ICON_OFFHOOK_BLACK);
      send_led_update(pte, 0x08);
      send_led_update(pte, 0x10);
   } else if (output == OUTPUT_HEADPHONE) {
      if (mute == MUTE_ON)
         change_favorite_icon(pte, FAV_ICON_HEADPHONES_ONHOLD);
      else
         change_favorite_icon(pte, FAV_ICON_HEADPHONES);
      send_led_update(pte, 0x08);
      send_led_update(pte, 0x11);
   } else if (output == OUTPUT_SPEAKER) {
      send_led_update(pte, 0x10);
      send_led_update(pte, 0x09);
      if (pte->device->receiver_state == STATE_OFFHOOK) {
         if (mute == MUTE_ON)
            change_favorite_icon(pte, FAV_ICON_SPEAKER_ONHOLD_BLACK);
         else
            change_favorite_icon(pte, FAV_ICON_SPEAKER_ONHOOK_BLACK);
      } else {
         if (mute == MUTE_ON)
            change_favorite_icon(pte, FAV_ICON_SPEAKER_ONHOLD_BLACK);
         else
            change_favorite_icon(pte, FAV_ICON_SPEAKER_OFFHOOK_BLACK);
      }
   } else
      ast_log(LOG_WARNING, "Invalid ouput (%d)\n", output);
   if (output != pte->device->output)
      pte->device->previous_output = pte->device->output;
   pte->device->output = output;
}

static void send_start_timer

(

struct unistimsession *

pte

)

[static]

Definition at line 940 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by HandleCallIncoming(), and unistim_answer().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending start timer\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_StartTimer, sizeof(packet_send_StartTimer));
   send_client(SIZE_HEADER + sizeof(packet_send_StartTimer), buffsend, pte);
}

static void send_stop_timer

(

struct unistimsession *

pte

)

[static]

Definition at line 949 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by close_call().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending stop timer\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_stop_timer, sizeof(packet_send_stop_timer));
   send_client(SIZE_HEADER + sizeof(packet_send_stop_timer), buffsend, pte);
}

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

Definition at line 1196 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), SIZE_HEADER, and TEXT_LENGTH_MAX.

Referenced by handle_dial_page(), HandleCallIncoming(), HandleCallOutgoing(), HandleSelectCodec(), init_phone_step2(), key_dial_page(), key_select_codec(), key_select_extension(), show_entry_history(), show_main_page(), ShowExtensionPage(), unistim_answer(), unistim_call(), unistim_hangup(), unistim_indicate(), and unistim_sendtext().

{
   int i;
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending text at pos %d, inverse flag %d\n", pos, inverse);
   memcpy(buffsend + SIZE_HEADER, packet_send_text, sizeof(packet_send_text));
   buffsend[10] = pos;
   buffsend[11] = inverse;
   i = strlen(text);
   if (i > TEXT_LENGTH_MAX)
      i = TEXT_LENGTH_MAX;
   memcpy(buffsend + 12, text, i);
   send_client(SIZE_HEADER + sizeof(packet_send_text), buffsend, pte);
}

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

Definition at line 1213 of file chan_unistim.c.

References ast_verb, BUFFSEND, unistimsession::device, send_client(), SIZE_HEADER, STATUS_LENGTH_MAX, and unistim_device::status_method.

Referenced by handle_dial_page(), HandleCallIncoming(), HandleCallOutgoing(), HandleSelectCodec(), init_phone_step2(), key_dial_page(), show_entry_history(), show_main_page(), ShowExtensionPage(), unistim_answer(), unistim_call(), and unistim_hangup().

{
   BUFFSEND;
   int i;
   if (unistimdebug)
      ast_verb(0, "Sending status text\n");
   if (pte->device) {
      if (pte->device->status_method == 1) {  /* For new firmware and i2050 soft phone */
         int n = strlen(text);
         /* Must send individual button separately */
         int j;
         for (i = 0, j = 0; i < 4; i++, j += 7) {
            int pos = 0x08 + (i * 0x20);
            memcpy(buffsend + SIZE_HEADER, packet_send_status2,
                  sizeof(packet_send_status2));

            buffsend[9] = pos;
            memcpy(buffsend + 10, (j < n) ? (text + j) : "       ", 7);
            send_client(SIZE_HEADER + sizeof(packet_send_status2), buffsend, pte);
         }
         return;
      }
   }


   memcpy(buffsend + SIZE_HEADER, packet_send_status, sizeof(packet_send_status));
   i = strlen(text);
   if (i > STATUS_LENGTH_MAX)
      i = STATUS_LENGTH_MAX;
   memcpy(buffsend + 10, text, i);
   send_client(SIZE_HEADER + sizeof(packet_send_status), buffsend, pte);

}

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

Definition at line 1345 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by init_phone_step2(), show_entry_history(), and show_main_page().

{
   BUFFSEND;
   int i;
   if (unistimdebug)
      ast_verb(0, "Sending title text\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_title, sizeof(packet_send_title));
   i = strlen(text);
   if (i > 12)
      i = 12;
   memcpy(buffsend + 10, text, i);
   send_client(SIZE_HEADER + sizeof(packet_send_title), buffsend, pte);

}

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

Definition at line 969 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by HandleCallOutgoing(), key_dial_page(), SendDialTone(), show_main_page(), unistim_do_senddigit(), unistim_senddigit_end(), and unistim_ss().

{
   BUFFSEND;
   if (!tone1) {
      if (unistimdebug)
         ast_verb(0, "Sending Stream Based Tone Off\n");
      memcpy(buffsend + SIZE_HEADER, packet_send_stream_based_tone_off,
            sizeof(packet_send_stream_based_tone_off));
      send_client(SIZE_HEADER + sizeof(packet_send_stream_based_tone_off), buffsend, pte);
      return;
   }
   /* Since most of the world use a continuous tone, it's useless
      if (unistimdebug)
      ast_verb(0, "Sending Stream Based Tone Cadence Download\n");
      memcpy (buffsend + SIZE_HEADER, packet_send_StreamBasedToneCad, sizeof (packet_send_StreamBasedToneCad));
      send_client (SIZE_HEADER + sizeof (packet_send_StreamBasedToneCad), buffsend, pte); */
   if (unistimdebug)
      ast_verb(0, "Sending Stream Based Tone Frequency Component List Download %d %d\n", tone1, tone2);
   tone1 *= 8;
   if (!tone2) {
      memcpy(buffsend + SIZE_HEADER, packet_send_stream_based_tone_single_freq,
            sizeof(packet_send_stream_based_tone_single_freq));
      buffsend[10] = (tone1 & 0xff00) >> 8;
      buffsend[11] = (tone1 & 0x00ff);
      send_client(SIZE_HEADER + sizeof(packet_send_stream_based_tone_single_freq), buffsend,
               pte);
   } else {
      tone2 *= 8;
      memcpy(buffsend + SIZE_HEADER, packet_send_stream_based_tone_dial_freq,
            sizeof(packet_send_stream_based_tone_dial_freq));
      buffsend[10] = (tone1 & 0xff00) >> 8;
      buffsend[11] = (tone1 & 0x00ff);
      buffsend[12] = (tone2 & 0xff00) >> 8;
      buffsend[13] = (tone2 & 0x00ff);
      send_client(SIZE_HEADER + sizeof(packet_send_stream_based_tone_dial_freq), buffsend,
               pte);
   }

   if (unistimdebug)
      ast_verb(0, "Sending Stream Based Tone On\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_stream_based_tone_on,
         sizeof(packet_send_stream_based_tone_on));
   send_client(SIZE_HEADER + sizeof(packet_send_stream_based_tone_on), buffsend, pte);
}

static void SendDialTone

(

struct unistimsession *

pte

)

[static]

Definition at line 2226 of file chan_unistim.c.

References ast_strlen_zero(), ast_verb, tone_zone_unistim::country, country, unistim_device::country, unistimsession::device, and send_tone().

Referenced by handle_dial_page().

{
   int i;
   /* No country defined ? Using US tone */
   if (ast_strlen_zero(pte->device->country)) {
      if (unistimdebug)
         ast_verb(0, "No country defined, using US tone\n");
      send_tone(pte, 350, 440);
      return;
   }
   if (strlen(pte->device->country) != 2) {
      if (unistimdebug)
         ast_verb(0, "Country code != 2 char, using US tone\n");
      send_tone(pte, 350, 440);
      return;
   }
   i = 0;
   while (frequency[i].freq1) {
      if ((frequency[i].country[0] == pte->device->country[0]) &&
         (frequency[i].country[1] == pte->device->country[1])) {
         if (unistimdebug)
            ast_verb(0, "Country code found (%s), freq1=%d freq2=%d\n",
                     frequency[i].country, frequency[i].freq1, frequency[i].freq2);
         send_tone(pte, frequency[i].freq1, frequency[i].freq2);
      }
      i++;
   }
}

static void Sendicon	(	unsigned char	pos,
		unsigned char	status,
		struct unistimsession *	pte
	)			[static]

Definition at line 958 of file chan_unistim.c.

References ast_verb, BUFFSEND, send_client(), and SIZE_HEADER.

Referenced by handle_dial_page(), key_main_page(), show_main_page(), and unistim_call().

{
   BUFFSEND;
   if (unistimdebug)
      ast_verb(0, "Sending icon pos %d with status 0x%.2x\n", pos, status);
   memcpy(buffsend + SIZE_HEADER, packet_send_icon, sizeof(packet_send_icon));
   buffsend[9] = pos;
   buffsend[10] = status;
   send_client(SIZE_HEADER + sizeof(packet_send_icon), buffsend, pte);
}

static void set_ping_timer

(

struct unistimsession *

pte

)

[static]

Definition at line 906 of file chan_unistim.c.

References DEBUG_TIMER, unistimsession::tick_next_ping, and unistimsession::timeout.

Referenced by check_send_queue().

{
   unsigned int tick = 0;  /* XXX what is this for, anyways */

   pte->timeout = pte->tick_next_ping;
   DEBUG_TIMER("tick = %u next ping at %u tick\n", tick, pte->timeout);
   return;
}

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

Definition at line 2978 of file chan_unistim.c.

References ast_copy_string(), unistimsession::buff_entry, unistimsession::device, display_last_error(), unistim_device::lst_cid, ReformatNumber(), send_text(), send_text_status(), send_texttitle(), status, STATUS_LENGTH_MAX, TEXT_LENGTH_MAX, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, and TEXT_NORMAL.

Referenced by key_history(), and show_history().

{
   char line[TEXT_LENGTH_MAX + 1], status[STATUS_LENGTH_MAX + 1], func1[10], func2[10],
      func3[10];

   if (fread(line, TEXT_LENGTH_MAX, 1, *f) != 1) {
      display_last_error("Can't read history date entry");
      fclose(*f);
      return;
   }
   line[sizeof(line) - 1] = '\0';
   send_text(TEXT_LINE0, TEXT_NORMAL, pte, line);
   if (fread(line, TEXT_LENGTH_MAX, 1, *f) != 1) {
      display_last_error("Can't read callerid entry");
      fclose(*f);
      return;
   }
   line[sizeof(line) - 1] = '\0';
   ast_copy_string(pte->device->lst_cid, line, sizeof(pte->device->lst_cid));
   send_text(TEXT_LINE1, TEXT_NORMAL, pte, line);
   if (fread(line, TEXT_LENGTH_MAX, 1, *f) != 1) {
      display_last_error("Can't read callername entry");
      fclose(*f);
      return;
   }
   line[sizeof(line) - 1] = '\0';
   send_text(TEXT_LINE2, TEXT_NORMAL, pte, line);
   fclose(*f);

   snprintf(line, sizeof(line), "Call %03d/%03d", pte->buff_entry[2],
          pte->buff_entry[1]);
   send_texttitle(pte, line);

   if (pte->buff_entry[2] == 1)
      strcpy(func1, "       ");
   else
      strcpy(func1, "Prvious");
   if (pte->buff_entry[2] >= pte->buff_entry[1])
      strcpy(func2, "       ");
   else
      strcpy(func2, "Next   ");
   if (ReformatNumber(pte->device->lst_cid))
      strcpy(func3, "Redial ");
   else
      strcpy(func3, "       ");
   snprintf(status, sizeof(status), "%s%s%sCancel", func1, func2, func3);
   send_text_status(pte, status);
}

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

Definition at line 3053 of file chan_unistim.c.

References unistimsession::buff_entry, unistim_device::callhistory, unistimsession::device, f, OpenHistory(), show_entry_history(), unistimsession::state, and STATE_HISTORY.

Referenced by key_history(), and key_main_page().

{
   FILE *f;
   char count;

   if (!pte->device)
      return;
   if (!pte->device->callhistory)
      return;
   count = OpenHistory(pte, way, &f);
   if (!count)
      return;
   pte->buff_entry[0] = way;
   pte->buff_entry[1] = count;
   pte->buff_entry[2] = 1;
   show_entry_history(pte, &f);
   pte->state = STATE_HISTORY;
}

static void show_main_page

(

struct unistimsession *

pte

)

[static]

Definition at line 3072 of file chan_unistim.c.

References ast_inet_ntoa(), ast_strlen_zero(), unistim_device::call_forward, change_favorite_icon(), unistimsession::device, unistim_device::extension, EXTENSION_ASK, unistim_device::extension_number, EXTENSION_TN, FAV_BLINK_SLOW, FAV_ICON_CALL_CENTER, FAV_ICON_ONHOOK_BLACK, FAV_ICON_REFLECT, unistim_line::lastmsgssent, unistim_device::lines, unistim_device::maintext0, unistim_device::maintext1, unistim_device::maintext2, unistim_device::missed_call, MUTE_ON_DISCRET, unistim_device::output, send_favorite(), send_select_output(), send_text(), send_text_status(), send_texttitle(), send_tone(), Sendicon(), ShowExtensionPage(), unistimsession::sin, unistim_device::softkeylabel, unistim_device::softkeylinepos, unistimsession::state, STATE_MAINPAGE, TEXT_LENGTH_MAX, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, unistim_device::titledefault, and unistim_device::volume.

Referenced by cancel_dial(), close_call(), init_phone_step2(), key_dial_page(), key_history(), key_main_page(), key_select_codec(), key_select_extension(), and process_request().

{
   char tmpbuf[TEXT_LENGTH_MAX + 1];


   if ((pte->device->extension == EXTENSION_ASK) &&
      (ast_strlen_zero(pte->device->extension_number))) {
      ShowExtensionPage(pte);
      return;
   }

   pte->state = STATE_MAINPAGE;

   send_tone(pte, 0, 0);
   send_select_output(pte, pte->device->output, pte->device->volume, MUTE_ON_DISCRET);
   pte->device->lines->lastmsgssent = 0;
   send_favorite(pte->device->softkeylinepos, FAV_ICON_ONHOOK_BLACK, pte,
             pte->device->softkeylabel[pte->device->softkeylinepos]);
   if (!ast_strlen_zero(pte->device->call_forward)) {
      send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Call forwarded to :");
      send_text(TEXT_LINE1, TEXT_NORMAL, pte, pte->device->call_forward);
      Sendicon(TEXT_LINE0, FAV_ICON_REFLECT + FAV_BLINK_SLOW, pte);
      send_text_status(pte, "Dial   Redial NoForwd");
   } else {
      if ((pte->device->extension == EXTENSION_ASK) ||
         (pte->device->extension == EXTENSION_TN))
         send_text_status(pte, "Dial   Redial ForwardUnregis");
      else
         send_text_status(pte, "Dial   Redial Forward");

      send_text(TEXT_LINE1, TEXT_NORMAL, pte, pte->device->maintext1);
      if (pte->device->missed_call == 0)
         send_text(TEXT_LINE0, TEXT_NORMAL, pte, pte->device->maintext0);
      else {
         sprintf(tmpbuf, "%d unanswered call(s)", pte->device->missed_call);
         send_text(TEXT_LINE0, TEXT_NORMAL, pte, tmpbuf);
         Sendicon(TEXT_LINE0, FAV_ICON_CALL_CENTER + FAV_BLINK_SLOW, pte);
      }
   }
   if (ast_strlen_zero(pte->device->maintext2)) {
      strcpy(tmpbuf, "IP : ");
      strcat(tmpbuf, ast_inet_ntoa(pte->sin.sin_addr));
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmpbuf);
   } else
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, pte->device->maintext2);
   send_texttitle(pte, pte->device->titledefault);
   change_favorite_icon(pte, FAV_ICON_ONHOOK_BLACK);
}

static void ShowExtensionPage

(

struct unistimsession *

pte

)

[static]

Definition at line 2848 of file chan_unistim.c.

References SELECTEXTENSION_MSG, SELECTEXTENSION_START_ENTRY_POS, send_blink_cursor(), send_cursor_pos(), send_text(), send_text_status(), unistimsession::size_buff_entry, unistimsession::state, STATE_EXTENSION, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, and TEXT_NORMAL.

Referenced by init_phone_step2(), key_main_page(), and show_main_page().

{
   pte->state = STATE_EXTENSION;

   send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Please enter a Terminal");
   send_text(TEXT_LINE1, TEXT_NORMAL, pte, "Number (TN) :");
   send_text(TEXT_LINE2, TEXT_NORMAL, pte, SELECTEXTENSION_MSG);
   send_blink_cursor(pte);
   send_cursor_pos(pte, TEXT_LINE2 + SELECTEXTENSION_START_ENTRY_POS);
   send_text_status(pte, "Enter  BackSpcErase");
   pte->size_buff_entry = 0;
   return;
}

static void start_rtp

(

struct unistim_subchannel *

sub

)

[static]

Definition at line 2027 of file chan_unistim.c.

References ast_best_codec(), AST_FORMAT_ALAW, AST_FORMAT_G723_1, AST_FORMAT_G729A, AST_FORMAT_ULAW, ast_getformatname(), ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_rtcp_fd(), ast_rtp_fd(), ast_rtp_get_us(), ast_rtp_lookup_code(), ast_rtp_new_with_bindaddr(), ast_rtp_set_peer(), ast_rtp_setnat(), ast_rtp_setqos(), ast_verb, BUFFSEND, errno, ast_channel::fds, unistim_subchannel::lock, LOG_WARNING, unistim_device::nat, ast_channel::nativeformats, unistim_subchannel::owner, unistim_line::parent, unistim_subchannel::parent, qos, ast_channel::readformat, unistim_subchannel::rtp, unistim_device::rtp_method, unistim_device::rtp_port, send_client(), unistim_device::session, unistimsession::sin, SIZE_HEADER, unistimsession::sout, and ast_channel::writeformat.

Referenced by HandleCallIncoming(), HandleCallOutgoing(), and unistim_answer().

{
   BUFFSEND;
   struct sockaddr_in us;
   struct sockaddr_in public;
   struct sockaddr_in sin;
   int codec;
   struct sockaddr_in sout;

   /* Sanity checks */
   if (!sub) {
      ast_log(LOG_WARNING, "start_rtp with a null subchannel !\n");
      return;
   }
   if (!sub->parent) {
      ast_log(LOG_WARNING, "start_rtp with a null line !\n");
      return;
   }
   if (!sub->parent->parent) {
      ast_log(LOG_WARNING, "start_rtp with a null device !\n");
      return;
   }
   if (!sub->parent->parent->session) {
      ast_log(LOG_WARNING, "start_rtp with a null session !\n");
      return;
   }
   sout = sub->parent->parent->session->sout;

   ast_mutex_lock(&sub->lock);
   /* Allocate the RTP */
   if (unistimdebug)
      ast_verb(0, "Starting RTP. Bind on %s\n", ast_inet_ntoa(sout.sin_addr));
   sub->rtp = ast_rtp_new_with_bindaddr(sched, io, 1, 0, sout.sin_addr);
   if (!sub->rtp) {
      ast_log(LOG_WARNING, "Unable to create RTP session: %s binaddr=%s\n",
            strerror(errno), ast_inet_ntoa(sout.sin_addr));
      ast_mutex_unlock(&sub->lock);
      return;
   }
   if (sub->rtp && sub->owner) {
      sub->owner->fds[0] = ast_rtp_fd(sub->rtp);
      sub->owner->fds[1] = ast_rtcp_fd(sub->rtp);
   }
   if (sub->rtp) {
      ast_rtp_setqos(sub->rtp, qos.tos_audio, qos.cos_audio, "UNISTIM RTP");
      ast_rtp_setnat(sub->rtp, sub->parent->parent->nat);
   }

   /* Create the RTP connection */
   ast_rtp_get_us(sub->rtp, &us);
   sin.sin_family = AF_INET;
   /* Setting up RTP for our side */
   memcpy(&sin.sin_addr, &sub->parent->parent->session->sin.sin_addr,
         sizeof(sin.sin_addr));
   sin.sin_port = htons(sub->parent->parent->rtp_port);
   ast_rtp_set_peer(sub->rtp, &sin);
   if (!(sub->owner->nativeformats & sub->owner->readformat)) {
      int fmt;
      fmt = ast_best_codec(sub->owner->nativeformats);
      ast_log(LOG_WARNING,
            "Our read/writeformat has been changed to something incompatible : %s (%d), using %s (%d) best codec from %d\n",
            ast_getformatname(sub->owner->readformat),
            sub->owner->readformat, ast_getformatname(fmt), fmt,
            sub->owner->nativeformats);
      sub->owner->readformat = fmt;
      sub->owner->writeformat = fmt;
   }
   codec = ast_rtp_lookup_code(sub->rtp, 1, sub->owner->readformat);
   /* Setting up RTP of the phone */
   if (public_ip.sin_family == 0)  /* NAT IP override ?   */
      memcpy(&public, &us, sizeof(public));   /* No defined, using IP from recvmsg  */
   else
      memcpy(&public, &public_ip, sizeof(public));    /* override  */
   if (unistimdebug) {
      ast_verb(0, "RTP started : Our IP/port is : %s:%hd with codec %s (%d)\n",
          ast_inet_ntoa(us.sin_addr),
          htons(us.sin_port), ast_getformatname(sub->owner->readformat),
          sub->owner->readformat);
      ast_verb(0, "Starting phone RTP stack. Our public IP is %s\n",
               ast_inet_ntoa(public.sin_addr));
   }
   if ((sub->owner->readformat == AST_FORMAT_ULAW) ||
      (sub->owner->readformat == AST_FORMAT_ALAW)) {
      if (unistimdebug)
         ast_verb(0, "Sending packet_send_rtp_packet_size for codec %d\n", codec);
      memcpy(buffsend + SIZE_HEADER, packet_send_rtp_packet_size,
            sizeof(packet_send_rtp_packet_size));
      buffsend[10] = codec;
      send_client(SIZE_HEADER + sizeof(packet_send_rtp_packet_size), buffsend,
               sub->parent->parent->session);
   }
   if (unistimdebug)
      ast_verb(0, "Sending Jitter Buffer Parameters Configuration\n");
   memcpy(buffsend + SIZE_HEADER, packet_send_jitter_buffer_conf,
         sizeof(packet_send_jitter_buffer_conf));
   send_client(SIZE_HEADER + sizeof(packet_send_jitter_buffer_conf), buffsend,
            sub->parent->parent->session);
   if (sub->parent->parent->rtp_method != 0) {
      uint16_t rtcpsin_port = htons(us.sin_port) + 1; /* RTCP port is RTP + 1 */

      if (unistimdebug)
         ast_verb(0, "Sending OpenAudioStreamTX using method #%d\n",
                  sub->parent->parent->rtp_method);
      if (sub->parent->parent->rtp_method == 3)
         memcpy(buffsend + SIZE_HEADER, packet_send_open_audio_stream_tx3,
               sizeof(packet_send_open_audio_stream_tx3));
      else
         memcpy(buffsend + SIZE_HEADER, packet_send_open_audio_stream_tx,
               sizeof(packet_send_open_audio_stream_tx));
      if (sub->parent->parent->rtp_method != 2) {
         memcpy(buffsend + 28, &public.sin_addr, sizeof(public.sin_addr));
         buffsend[20] = (htons(sin.sin_port) & 0xff00) >> 8;
         buffsend[21] = (htons(sin.sin_port) & 0x00ff);
         buffsend[23] = (rtcpsin_port & 0x00ff);
         buffsend[22] = (rtcpsin_port & 0xff00) >> 8;
         buffsend[25] = (us.sin_port & 0xff00) >> 8;
         buffsend[24] = (us.sin_port & 0x00ff);
         buffsend[27] = (rtcpsin_port & 0x00ff);
         buffsend[26] = (rtcpsin_port & 0xff00) >> 8;
      } else {
         memcpy(buffsend + 23, &public.sin_addr, sizeof(public.sin_addr));
         buffsend[15] = (htons(sin.sin_port) & 0xff00) >> 8;
         buffsend[16] = (htons(sin.sin_port) & 0x00ff);
         buffsend[20] = (us.sin_port & 0xff00) >> 8;
         buffsend[19] = (us.sin_port & 0x00ff);
         buffsend[11] = codec;
      }
      buffsend[12] = codec;
      send_client(SIZE_HEADER + sizeof(packet_send_open_audio_stream_tx), buffsend,
               sub->parent->parent->session);

      if (unistimdebug)
         ast_verb(0, "Sending OpenAudioStreamRX\n");
      if (sub->parent->parent->rtp_method == 3)
         memcpy(buffsend + SIZE_HEADER, packet_send_open_audio_stream_rx3,
               sizeof(packet_send_open_audio_stream_rx3));
      else
         memcpy(buffsend + SIZE_HEADER, packet_send_open_audio_stream_rx,
               sizeof(packet_send_open_audio_stream_rx));
      if (sub->parent->parent->rtp_method != 2) {
         memcpy(buffsend + 28, &public.sin_addr, sizeof(public.sin_addr));
         buffsend[20] = (htons(sin.sin_port) & 0xff00) >> 8;
         buffsend[21] = (htons(sin.sin_port) & 0x00ff);
         buffsend[23] = (rtcpsin_port & 0x00ff);
         buffsend[22] = (rtcpsin_port & 0xff00) >> 8;
         buffsend[25] = (us.sin_port & 0xff00) >> 8;
         buffsend[24] = (us.sin_port & 0x00ff);
         buffsend[27] = (rtcpsin_port & 0x00ff);
         buffsend[26] = (rtcpsin_port & 0xff00) >> 8;
      } else {
         memcpy(buffsend + 23, &public.sin_addr, sizeof(public.sin_addr));
         buffsend[15] = (htons(sin.sin_port) & 0xff00) >> 8;
         buffsend[16] = (htons(sin.sin_port) & 0x00ff);
         buffsend[20] = (us.sin_port & 0xff00) >> 8;
         buffsend[19] = (us.sin_port & 0x00ff);
         buffsend[12] = codec;
      }
      buffsend[11] = codec;
      send_client(SIZE_HEADER + sizeof(packet_send_open_audio_stream_rx), buffsend,
               sub->parent->parent->session);
   } else {
      uint16_t rtcpsin_port = htons(us.sin_port) + 1; /* RTCP port is RTP + 1 */

      if (unistimdebug)
         ast_verb(0, "Sending packet_send_call default method\n");

      memcpy(buffsend + SIZE_HEADER, packet_send_call, sizeof(packet_send_call));
      memcpy(buffsend + 53, &public.sin_addr, sizeof(public.sin_addr));
      /* Destination port when sending RTP */
      buffsend[49] = (us.sin_port & 0x00ff);
      buffsend[50] = (us.sin_port & 0xff00) >> 8;
      /* Destination port when sending RTCP */
      buffsend[52] = (rtcpsin_port & 0x00ff);
      buffsend[51] = (rtcpsin_port & 0xff00) >> 8;
      /* Codec */
      buffsend[40] = codec;
      buffsend[41] = codec;
      if (sub->owner->readformat == AST_FORMAT_ULAW)
         buffsend[42] = 1;       /* 1 = 20ms (160 bytes), 2 = 40ms (320 bytes) */
      else if (sub->owner->readformat == AST_FORMAT_ALAW)
         buffsend[42] = 1;       /* 1 = 20ms (160 bytes), 2 = 40ms (320 bytes) */
      else if (sub->owner->readformat == AST_FORMAT_G723_1)
         buffsend[42] = 2;       /* 1 = 30ms (24 bytes), 2 = 60 ms (48 bytes) */
      else if (sub->owner->readformat == AST_FORMAT_G729A)
         buffsend[42] = 2;       /* 1 = 10ms (10 bytes), 2 = 20ms (20 bytes) */
      else
         ast_log(LOG_WARNING, "Unsupported codec %s (%d) !\n",
               ast_getformatname(sub->owner->readformat), sub->owner->readformat);
      /* Source port for transmit RTP and Destination port for receiving RTP */
      buffsend[45] = (htons(sin.sin_port) & 0xff00) >> 8;
      buffsend[46] = (htons(sin.sin_port) & 0x00ff);
      buffsend[47] = (rtcpsin_port & 0xff00) >> 8;
      buffsend[48] = (rtcpsin_port & 0x00ff);
      send_client(SIZE_HEADER + sizeof(packet_send_call), buffsend,
               sub->parent->parent->session);
   }
   ast_mutex_unlock(&sub->lock);
}

static void swap_subs	(	struct unistim_line *	p,
		int	a,
		int	b
	)			[static]

Definition at line 1854 of file chan_unistim.c.

References ast_log(), ast_verb, ast_channel::fds, LOG_WARNING, unistim_subchannel::owner, unistim_subchannel::rtp, and unistim_line::subs.

Referenced by HandleCallOutgoing(), and unistim_hangup().

{
/*  struct ast_channel *towner; */
   struct ast_rtp *rtp;
   int fds;

   if (unistimdebug)
      ast_verb(0, "Swapping %d and %d\n", a, b);

   if ((!p->subs[a]->owner) || (!p->subs[b]->owner)) {
      ast_log(LOG_WARNING,
            "Attempted to swap subchannels with a null owner : sub #%d=%p sub #%d=%p\n",
            a, p->subs[a]->owner, b, p->subs[b]->owner);
      return;
   }
   rtp = p->subs[a]->rtp;
   p->subs[a]->rtp = p->subs[b]->rtp;
   p->subs[b]->rtp = rtp;

   fds = p->subs[a]->owner->fds[0];
   p->subs[a]->owner->fds[0] = p->subs[b]->owner->fds[0];
   p->subs[b]->owner->fds[0] = fds;

   fds = p->subs[a]->owner->fds[1];
   p->subs[a]->owner->fds[1] = p->subs[b]->owner->fds[1];
   p->subs[b]->owner->fds[1] = fds;
}

static void TransferCallStep1

(

struct unistimsession *

pte

)

[static]

Definition at line 2304 of file chan_unistim.c.

References ast_bridged_channel(), AST_CAUSE_NORMAL_CLEARING, ast_channel_start_silence_generator(), ast_log(), ast_moh_start(), ast_queue_hangup_with_cause(), ast_verb, unistimsession::device, handle_dial_page(), unistim_device::lines, LOG_WARNING, unistim_device::moh, unistim_line::musicclass, unistim_subchannel::owner, unistim_device::silence_generator, SUB_REAL, SUB_THREEWAY, and unistim_line::subs.

Referenced by key_call().

{
   struct unistim_subchannel *sub;
   struct unistim_line *p = pte->device->lines;

   sub = p->subs[SUB_REAL];

   if (!sub->owner) {
      ast_log(LOG_WARNING, "Unable to find subchannel for music on hold\n");
      return;
   }
   if (p->subs[SUB_THREEWAY]) {
      if (unistimdebug)
         ast_verb(0, "Transfer canceled, hangup our threeway channel\n");
      if (p->subs[SUB_THREEWAY]->owner)
         ast_queue_hangup_with_cause(p->subs[SUB_THREEWAY]->owner, AST_CAUSE_NORMAL_CLEARING);
      else
         ast_log(LOG_WARNING, "Canceling a threeway channel without owner\n");
      return;
   }
   /* Start music on hold if appropriate */
   if (pte->device->moh)
      ast_log(LOG_WARNING, "Transfer with peer already listening music on hold\n");
   else {
      if (ast_bridged_channel(p->subs[SUB_REAL]->owner)) {
         ast_moh_start(ast_bridged_channel(p->subs[SUB_REAL]->owner),
                    pte->device->lines->musicclass, NULL);
         pte->device->moh = 1;
      } else {
         ast_log(LOG_WARNING, "Unable to find peer subchannel for music on hold\n");
         return;
      }
   }
   /* Silence our channel */
   if (!pte->device->silence_generator) {
      pte->device->silence_generator =
         ast_channel_start_silence_generator(p->subs[SUB_REAL]->owner);
      if (pte->device->silence_generator == NULL)
         ast_log(LOG_WARNING, "Unable to start a silence generator.\n");
      else if (unistimdebug)
         ast_verb(0, "Starting silence generator\n");
   }
   handle_dial_page(pte);
}

static int unalloc_sub	(	struct unistim_line *	p,
		int	x
	)			[static]

Definition at line 1493 of file chan_unistim.c.

References ast_debug, ast_free, ast_log(), ast_mutex_destroy(), unistim_line::lock, LOG_WARNING, unistim_device::name, unistim_line::name, unistim_line::parent, and unistim_line::subs.

Referenced by unistim_hangup().

{
   if (!x) {
      ast_log(LOG_WARNING, "Trying to unalloc the real channel %s@%s?!?\n", p->name,
            p->parent->name);
      return -1;
   }
   if (unistimdebug)
      ast_debug(1, "Released sub %d of channel %s@%s\n", x, p->name,
            p->parent->name);
   ast_mutex_destroy(&p->lock);
   ast_free(p->subs[x]);
   p->subs[x] = 0;
   return 0;
}

static int unistim_answer

(

struct ast_channel *

ast

)

[static]

Definition at line 3814 of file chan_unistim.c.

References ast_channel::_state, ast_log(), ast_setstate(), AST_STATE_UP, ast_verb, channel_to_session(), LOG_WARNING, unistim_device::name, unistim_line::name, unistim_line::parent, unistim_subchannel::parent, unistim_subchannel::rtp, s, send_start_timer(), send_text(), send_text_status(), unistim_device::session, start_rtp(), SUB_THREEWAY, unistim_line::subs, unistim_subchannel::subtype, ast_channel::tech_pvt, TEXT_LINE2, and TEXT_NORMAL.

{
   int res = 0;
   struct unistim_subchannel *sub;
   struct unistim_line *l;
   struct unistimsession *s;

   s = channel_to_session(ast);
   if (!s) {
      ast_log(LOG_WARNING, "unistim_answer on a disconnected device ?\n");
      return -1;
   }
   sub = ast->tech_pvt;
   l = sub->parent;

   if ((!sub->rtp) && (!l->subs[SUB_THREEWAY]))
      start_rtp(sub);
   if (unistimdebug)
      ast_verb(0, "unistim_answer(%s) on %s@%s-%d\n", ast->name, l->name,
               l->parent->name, sub->subtype);
   send_text(TEXT_LINE2, TEXT_NORMAL, l->parent->session, "is now on-line");
   if (l->subs[SUB_THREEWAY])
      send_text_status(l->parent->session, "Transf Cancel");
   else
      send_text_status(l->parent->session, "Hangup Transf");
   send_start_timer(l->parent->session);
   if (ast->_state != AST_STATE_UP)
      ast_setstate(ast, AST_STATE_UP);
   return res;
}

static int unistim_call	(	struct ast_channel *	ast,
		char *	dest,
		int	timeout
	)			[static]

Definition at line 3648 of file chan_unistim.c.

References ast_channel::_state, AST_CONTROL_RINGING, ast_log(), ast_queue_control(), ast_setstate(), AST_STATE_DOWN, AST_STATE_RESERVED, AST_STATE_RINGING, ast_verb, change_callerid(), change_favorite_icon(), channel_to_session(), ast_channel::cid, ast_callerid::cid_name, ast_callerid::cid_num, DEFAULTCALLERID, DEFAULTCALLERNAME, unistimsession::device, FAV_BLINK_FAST, FAV_ICON_NONE, FAV_ICON_SPEAKER_ONHOOK_BLACK, LOG_ERROR, LOG_WARNING, unistim_subchannel::owner, unistim_device::ringstyle, unistim_subchannel::ringstyle, unistim_subchannel::ringvolume, unistim_device::ringvolume, send_ring(), send_text(), send_text_status(), Sendicon(), unistimsession::state, STATE_RINGING, ast_channel::tech_pvt, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, and TEXT_NORMAL.

{
   int res = 0;
   struct unistim_subchannel *sub;
   struct unistimsession *session;

   session = channel_to_session(ast);
   if (!session) {
      ast_log(LOG_ERROR, "Device not registered, cannot call %s\n", dest);
      return -1;
   }

   sub = ast->tech_pvt;
   if ((ast->_state != AST_STATE_DOWN) && (ast->_state != AST_STATE_RESERVED)) {
      ast_log(LOG_WARNING, "unistim_call called on %s, neither down nor reserved\n",
            ast->name);
      return -1;
   }

   if (unistimdebug)
      ast_verb(3, "unistim_call(%s)\n", ast->name);

   session->state = STATE_RINGING;
   Sendicon(TEXT_LINE0, FAV_ICON_NONE, session);

   if (sub->owner) {
      if (sub->owner->cid.cid_num) {
         send_text(TEXT_LINE1, TEXT_NORMAL, session, sub->owner->cid.cid_num);
         change_callerid(session, 0, sub->owner->cid.cid_num);
      } else {
         send_text(TEXT_LINE1, TEXT_NORMAL, session, DEFAULTCALLERID);
         change_callerid(session, 0, DEFAULTCALLERID);
      }
      if (sub->owner->cid.cid_name) {
         send_text(TEXT_LINE0, TEXT_NORMAL, session, sub->owner->cid.cid_name);
         change_callerid(session, 1, sub->owner->cid.cid_name);
      } else {
         send_text(TEXT_LINE0, TEXT_NORMAL, session, DEFAULTCALLERNAME);
         change_callerid(session, 1, DEFAULTCALLERNAME);
      }
   }
   send_text(TEXT_LINE2, TEXT_NORMAL, session, "is calling you.");
   send_text_status(session, "Accept          Ignore");

   if (sub->ringstyle == -1)
      send_ring(session, session->device->ringvolume, session->device->ringstyle);
   else {
      if (sub->ringvolume == -1)
         send_ring(session, session->device->ringvolume, sub->ringstyle);
      else
         send_ring(session, sub->ringvolume, sub->ringstyle);
   }
   change_favorite_icon(session, FAV_ICON_SPEAKER_ONHOOK_BLACK + FAV_BLINK_FAST);

   ast_setstate(ast, AST_STATE_RINGING);
   ast_queue_control(ast, AST_CONTROL_RINGING);
   return res;
}

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

Definition at line 4802 of file chan_unistim.c.

References ast_cli_args::argc, ast_cli_entry::args, ast_cli_args::argv, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, and ast_cli_entry::usage.

{
   switch (cmd) {
   case CLI_INIT:
      e->command = "unistim set debug {on|off}";
      e->usage =
         "Usage: unistim set debug\n" 
         "       Display debug messages.\n";
      return NULL;

   case CLI_GENERATE:
      return NULL;   /* no completion */
   }

   if (a->argc != e->args)
      return CLI_SHOWUSAGE;

   if (!strcasecmp(a->argv[3], "on")) {
      unistimdebug = 1;
      ast_cli(a->fd, "UNISTIM Debugging Enabled\n");
   } else if (!strcasecmp(a->argv[3], "off")) {
      unistimdebug = 0;
      ast_cli(a->fd, "UNISTIM Debugging Disabled\n");
   } else
      return CLI_SHOWUSAGE;

   return CLI_SUCCESS;
}

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

Definition at line 2471 of file chan_unistim.c.

References unistim_subchannel::alreadygone, AST_FRAME_DTMF, ast_log(), ast_queue_frame(), ast_verb, unistimsession::device, ast_frame::frametype, unistim_device::lines, LOG_WARNING, unistim_subchannel::owner, send_tone(), SUB_REAL, and unistim_line::subs.

Referenced by key_call(), and unistim_senddigit_begin().

{
   struct ast_frame f = { .frametype = AST_FRAME_DTMF, .subclass = digit, .src = "unistim" };
   struct unistim_subchannel *sub;
   sub = pte->device->lines->subs[SUB_REAL];
   if (!sub->owner || sub->alreadygone) {
      ast_log(LOG_WARNING, "Unable to find subchannel in dtmf senddigit\n");
      return -1;
   }

   /* Send DTMF indication _before_ playing sounds */
   ast_queue_frame(sub->owner, &f);

   if (unistimdebug)
      ast_verb(0, "Send Digit %c\n", digit);
   switch (digit) {
   case '0':
      send_tone(pte, 941, 1336);
      break;
   case '1':
      send_tone(pte, 697, 1209);
      break;
   case '2':
      send_tone(pte, 697, 1336);
      break;
   case '3':
      send_tone(pte, 697, 1477);
      break;
   case '4':
      send_tone(pte, 770, 1209);
      break;
   case '5':
      send_tone(pte, 770, 1336);
      break;
   case '6':
      send_tone(pte, 770, 1477);
      break;
   case '7':
      send_tone(pte, 852, 1209);
      break;
   case '8':
      send_tone(pte, 852, 1336);
      break;
   case '9':
      send_tone(pte, 852, 1477);
      break;
   case 'A':
      send_tone(pte, 697, 1633);
      break;
   case 'B':
      send_tone(pte, 770, 1633);
      break;
   case 'C':
      send_tone(pte, 852, 1633);
      break;
   case 'D':
      send_tone(pte, 941, 1633);
      break;
   case '*':
      send_tone(pte, 941, 1209);
      break;
   case '#':
      send_tone(pte, 941, 1477);
      break;
   default:
      send_tone(pte, 500, 2000);
   }
   usleep(150000);          /* XXX Less than perfect, blocking an important thread is not a good idea */
   send_tone(pte, 0, 0);
   return 0;
}

static int unistim_fixup	(	struct ast_channel *	oldchan,
		struct ast_channel *	newchan
	)			[static]

Definition at line 4000 of file chan_unistim.c.

References ast_debug, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), unistim_subchannel::lock, LOG_WARNING, unistim_device::name, unistim_line::name, unistim_subchannel::owner, unistim_line::parent, unistim_subchannel::parent, unistim_subchannel::subtype, and ast_channel::tech_pvt.

{
   struct unistim_subchannel *p = newchan->tech_pvt;
   struct unistim_line *l = p->parent;

   ast_mutex_lock(&p->lock);

   ast_debug(1, "New owner for channel USTM/%s@%s-%d is %s\n", l->name,
         l->parent->name, p->subtype, newchan->name);

   if (p->owner != oldchan) {
      ast_log(LOG_WARNING, "old channel wasn't %s (%p) but was %s (%p)\n",
            oldchan->name, oldchan, p->owner->name, p->owner);
      return -1;
   }

   p->owner = newchan;

   ast_mutex_unlock(&p->lock);

   return 0;

}

static enum ast_rtp_get_result unistim_get_rtp_peer	(	struct ast_channel *	chan,
		struct ast_rtp **	rtp
	)			[static]

Definition at line 5522 of file chan_unistim.c.

References AST_RTP_GET_FAILED, AST_RTP_TRY_NATIVE, ast_verb, unistim_subchannel::rtp, and ast_channel::tech_pvt.

{
   struct unistim_subchannel *sub;
   enum ast_rtp_get_result res = AST_RTP_GET_FAILED;

   if (unistimdebug)
      ast_verb(0, "unistim_get_rtp_peer called\n");
      
   sub = chan->tech_pvt;
   if (sub && sub->rtp) {
      *rtp = sub->rtp;
      res = AST_RTP_TRY_NATIVE;
   }

   return res;
}

static enum ast_rtp_get_result unistim_get_vrtp_peer	(	struct ast_channel *	chan,
		struct ast_rtp **	rtp
	)			[static]

Definition at line 5516 of file chan_unistim.c.

References AST_RTP_TRY_NATIVE.

{
   return AST_RTP_TRY_NATIVE;
}

static int unistim_hangup

(

struct ast_channel *

ast

)

[static]

Definition at line 3708 of file chan_unistim.c.

References unistim_subchannel::alreadygone, ast_bridged_channel(), ast_channel_stop_silence_generator(), ast_debug, ast_log(), ast_moh_stop(), ast_mutex_lock(), ast_mutex_unlock(), ast_rtp_destroy(), ast_verb, cancel_dial(), channel_to_session(), close_call(), unistimsession::device, unistim_subchannel::lock, LOG_WARNING, unistim_device::moh, unistim_device::name, unistim_line::name, unistim_subchannel::owner, unistim_line::parent, unistim_subchannel::parent, unistim_subchannel::rtp, s, send_end_call(), send_no_ring(), send_text(), send_text_status(), unistim_device::silence_generator, unistimsession::state, STATE_CALL, STATE_RINGING, SUB_REAL, SUB_THREEWAY, unistim_line::subs, unistim_subchannel::subtype, swap_subs(), ast_channel::tech_pvt, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, TEXT_NORMAL, and unalloc_sub().

{
   struct unistim_subchannel *sub;
   struct unistim_line *l;
   struct unistimsession *s;

   s = channel_to_session(ast);
   sub = ast->tech_pvt;
   if (!s) {
      ast_debug(1, "Asked to hangup channel not connected\n");
      ast_mutex_lock(&sub->lock);
      sub->owner = NULL;
      ast->tech_pvt = NULL;
      sub->alreadygone = 0;
      ast_mutex_unlock(&sub->lock);
      if (sub->rtp) {
         if (unistimdebug)
            ast_verb(0, "Destroying RTP session\n");
         ast_rtp_destroy(sub->rtp);
         sub->rtp = NULL;
      }
      return 0;
   }
   l = sub->parent;
   if (unistimdebug)
      ast_verb(0, "unistim_hangup(%s) on %s@%s\n", ast->name, l->name, l->parent->name);

   if ((l->subs[SUB_THREEWAY]) && (sub->subtype == SUB_REAL)) {
      if (unistimdebug)
         ast_verb(0, "Real call disconnected while talking to threeway\n");
      sub->owner = NULL;
      ast->tech_pvt = NULL;
      return 0;
   }
   if ((l->subs[SUB_REAL]->owner) && (sub->subtype == SUB_THREEWAY) &&
      (sub->alreadygone == 0)) {
      if (unistimdebug)
         ast_verb(0, "threeway call disconnected, switching to real call\n");
      send_text(TEXT_LINE0, TEXT_NORMAL, s, "Three way call canceled,");
      send_text(TEXT_LINE1, TEXT_NORMAL, s, "switching back to");
      send_text(TEXT_LINE2, TEXT_NORMAL, s, "previous call.");
      send_text_status(s, "Hangup Transf");
      ast_moh_stop(ast_bridged_channel(l->subs[SUB_REAL]->owner));
      swap_subs(l, SUB_THREEWAY, SUB_REAL);
      l->parent->moh = 0;
      ast_mutex_lock(&sub->lock);
      sub->owner = NULL;
      ast->tech_pvt = NULL;
      ast_mutex_unlock(&sub->lock);
      unalloc_sub(l, SUB_THREEWAY);
      return 0;
   }
   ast_mutex_lock(&sub->lock);
   sub->owner = NULL;
   ast->tech_pvt = NULL;
   sub->alreadygone = 0;
   ast_mutex_unlock(&sub->lock);
   if (!s) {
      if (unistimdebug)
         ast_verb(0, "Asked to hangup channel not connected (no session)\n");
      if (sub->rtp) {
         if (unistimdebug)
            ast_verb(0, "Destroying RTP session\n");
         ast_rtp_destroy(sub->rtp);
         sub->rtp = NULL;
      }
      return 0;
   }
   if (sub->subtype == SUB_REAL) {
      /* Stop the silence generator */
      if (s->device->silence_generator) {
         if (unistimdebug)
            ast_verb(0, "Stopping silence generator\n");
         if (sub->owner)
            ast_channel_stop_silence_generator(sub->owner,
                                       s->device->silence_generator);
         else
            ast_log(LOG_WARNING,
                  "Trying to stop silence generator on a null channel !\n");
         s->device->silence_generator = NULL;
      }
   }
   l->parent->moh = 0;
   send_no_ring(s);
   send_end_call(s);
   if (sub->rtp) {
      if (unistimdebug)
         ast_verb(0, "Destroying RTP session\n");
      ast_rtp_destroy(sub->rtp);
      sub->rtp = NULL;
   } else if (unistimdebug)
      ast_verb(0, "No RTP session to destroy\n");
   if (l->subs[SUB_THREEWAY]) {
      if (unistimdebug)
         ast_verb(0, "Cleaning other subchannels\n");
      unalloc_sub(l, SUB_THREEWAY);
   }
   if (s->state == STATE_RINGING)
      cancel_dial(s);
   else if (s->state == STATE_CALL)
      close_call(s);

   return 0;
}

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

Definition at line 4072 of file chan_unistim.c.

References ast_channel::_state, unistim_subchannel::alreadygone, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_HOLD, AST_CONTROL_PROCEEDING, AST_CONTROL_PROGRESS, AST_CONTROL_RINGING, AST_CONTROL_SRCUPDATE, AST_CONTROL_UNHOLD, ast_log(), ast_moh_start(), ast_moh_stop(), ast_playtones_stop(), AST_STATE_UP, ast_verb, channel_to_session(), control2str(), unistimsession::device, in_band_indication(), LOG_WARNING, unistim_device::missed_call, unistim_line::parent, unistim_subchannel::parent, s, send_text(), ast_channel::tech_pvt, TEXT_LINE2, TEXT_NORMAL, and unistim_device::tz.

{
   struct unistim_subchannel *sub;
   struct unistim_line *l;
   struct unistimsession *s;

   if (unistimdebug) {
      ast_verb(3, "Asked to indicate '%s' condition on channel %s\n",
               control2str(ind), ast->name);
   }

   s = channel_to_session(ast);
   if (!s)
      return -1;

   sub = ast->tech_pvt;
   l = sub->parent;

   switch (ind) {
   case AST_CONTROL_RINGING:
      if (ast->_state != AST_STATE_UP) {
         send_text(TEXT_LINE2, TEXT_NORMAL, s, "Ringing...");
         in_band_indication(ast, l->parent->tz, "ring");
         s->device->missed_call = -1;
         break;
      }
      return -1;
   case AST_CONTROL_BUSY:
      if (ast->_state != AST_STATE_UP) {
         sub->alreadygone = 1;
         send_text(TEXT_LINE2, TEXT_NORMAL, s, "Busy");
         in_band_indication(ast, l->parent->tz, "busy");
         s->device->missed_call = -1;
         break;
      }
      return -1;
   case AST_CONTROL_CONGESTION:
      if (ast->_state != AST_STATE_UP) {
         sub->alreadygone = 1;
         send_text(TEXT_LINE2, TEXT_NORMAL, s, "Congestion");
         in_band_indication(ast, l->parent->tz, "congestion");
         s->device->missed_call = -1;
         break;
      }
      return -1;
   case AST_CONTROL_HOLD:
      ast_moh_start(ast, data, NULL);
      break;
   case AST_CONTROL_UNHOLD:
      ast_moh_stop(ast);
      break;
   case AST_CONTROL_PROGRESS:
   case AST_CONTROL_SRCUPDATE:
      break;
   case -1:
      ast_playtones_stop(ast);
      s->device->missed_call = 0;
      break;
   case AST_CONTROL_PROCEEDING:
      break;
   default:
      ast_log(LOG_WARNING, "Don't know how to indicate condition %d\n", ind);
      return -1;
   }

   return 0;
}

static char* unistim_info	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)			[static]

Definition at line 4672 of file chan_unistim.c.

References ast_channel::_bridge, unistim_subchannel::alreadygone, ast_cli_args::argc, ast_cli_entry::args, ast_cli(), ast_inet_ntoa(), ast_mutex_lock(), ast_mutex_unlock(), unistim_line::capability, unistim_line::cid_num, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, unistimsession::device, unistim_line::exten, ast_cli_args::fd, unistim_line::fullname, unistim_device::ha, unistim_device::id, unistim_device::lines, unistimsession::macaddr, MAX_SUBS, unistim_line::name, unistim_device::name, unistimsession::next, unistim_device::next, unistim_line::next, unistim_subchannel::owner, unistim_subchannel::parent, unistim_line::parent, unistim_subchannel::rtp, s, unistim_device::session, sessionlock, unistimsession::sin, unistimsession::state, unistim_line::subs, unistim_subchannel::subtype, unistimsession::timeout, and ast_cli_entry::usage.

{
   struct unistim_device *device = devices;
   struct unistim_line *line;
   struct unistim_subchannel *sub;
   struct unistimsession *s;
   int i;
   struct ast_channel *tmp;

   switch (cmd) {
   case CLI_INIT:
      e->command = "unistim info";
      e->usage =
         "Usage: unistim info\n" 
         "       Dump internal structures.\n";
      return NULL;

   case CLI_GENERATE:
      return NULL;   /* no completion */
   }

   if (a->argc != e->args)
      return CLI_SHOWUSAGE;

   ast_cli(a->fd, "Dumping internal structures :\ndevice\n->line\n-->sub\n");
   while (device) {
      ast_cli(a->fd, "\nname=%s id=%s line=%p ha=%p sess=%p device=%p\n",
            device->name, device->id, device->lines, device->ha, device->session,
            device);
      line = device->lines;
      while (line) {
         ast_cli(a->fd,
               "->name=%s fullname=%s exten=%s callid=%s cap=%d device=%p line=%p\n",
               line->name, line->fullname, line->exten, line->cid_num,
               line->capability, line->parent, line);
         for (i = 0; i < MAX_SUBS; i++) {
            sub = line->subs[i];
            if (!sub)
               continue;
            if (!sub->owner)
               tmp = (void *) -42;
            else
               tmp = sub->owner->_bridge;
            if (sub->subtype != i)
               ast_cli(a->fd, "Warning ! subchannel->subs[%d] have a subtype=%d\n", i,
                     sub->subtype);
            ast_cli(a->fd,
                  "-->subtype=%d chan=%p rtp=%p bridge=%p line=%p alreadygone=%d\n",
                  sub->subtype, sub->owner, sub->rtp, tmp, sub->parent,
                  sub->alreadygone);
         }
         line = line->next;
      }
      device = device->next;
   }
   ast_cli(a->fd, "\nSessions:\n");
   ast_mutex_lock(&sessionlock);
   s = sessions;
   while (s) {
      ast_cli(a->fd,
            "sin=%s timeout=%u state=%d macaddr=%s device=%p session=%p\n",
            ast_inet_ntoa(s->sin.sin_addr), s->timeout, s->state, s->macaddr,
            s->device, s);
      s = s->next;
   }
   ast_mutex_unlock(&sessionlock);

   return CLI_SUCCESS;
}

static struct ast_channel * unistim_new	(	struct unistim_subchannel *	sub,
		int	state
	)			[static, read]

Protos

Definition at line 4421 of file chan_unistim.c.

References unistim_line::accountcode, ast_channel::adsicpe, unistim_line::amaflags, AST_ADSI_UNAVAILABLE, ast_best_codec(), ast_callerid_parse(), ast_channel_alloc, ast_free, ast_hangup(), ast_jb_configure(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pbx_start(), ast_rtcp_fd(), ast_rtp_fd(), ast_setstate(), AST_STATE_DOWN, AST_STATE_RING, ast_strdup, ast_string_field_build, ast_string_field_set, ast_strlen_zero(), ast_update_use_count(), ast_verb, unistim_device::call_forward, unistim_line::callgroup, ast_channel::callgroup, CAPABILITY, unistim_line::capability, ast_channel::cid, ast_callerid::cid_name, ast_callerid::cid_num, unistim_line::cid_num, unistim_line::context, unistim_line::exten, ast_channel::fds, unistim_line::fullname, global_jbconf, language, unistim_line::language, LOG_WARNING, unistim_device::name, unistim_line::name, name, ast_channel::nativeformats, unistim_line::parent, unistim_subchannel::parent, unistim_line::pickupgroup, ast_channel::pickupgroup, ast_channel::priority, ast_channel::rawreadformat, ast_channel::rawwriteformat, ast_channel::readformat, ast_channel::rings, ast_channel::tech, ast_channel::tech_pvt, usecnt_lock, and ast_channel::writeformat.

Referenced by HandleCallOutgoing(), and unistim_request().

{
   struct ast_channel *tmp;
   struct unistim_line *l;
   int fmt;

   if (!sub) {
      ast_log(LOG_WARNING, "subchannel null in unistim_new\n");
      return NULL;
   }
   if (!sub->parent) {
      ast_log(LOG_WARNING, "no line for subchannel %p\n", sub);
      return NULL;
   }
   l = sub->parent;
   tmp = ast_channel_alloc(1, state, l->cid_num, NULL, l->accountcode, l->exten, 
      l->context, l->amaflags, "%s-%08x", l->fullname, (int) (long) sub);
   if (unistimdebug)
      ast_verb(0, "unistim_new sub=%d (%p) chan=%p\n", sub->subtype, sub, tmp);
   if (!tmp) {
      ast_log(LOG_WARNING, "Unable to allocate channel structure\n");
      return NULL;
   }

   tmp->nativeformats = l->capability;
   if (!tmp->nativeformats)
      tmp->nativeformats = CAPABILITY;
   fmt = ast_best_codec(tmp->nativeformats);
   if (unistimdebug)
      ast_verb(0, "Best codec = %d from nativeformats %d (line cap=%d global=%d)\n", fmt,
          tmp->nativeformats, l->capability, CAPABILITY);
   ast_string_field_build(tmp, name, "USTM/%s@%s-%d", l->name, l->parent->name,
                     sub->subtype);
   if ((sub->rtp) && (sub->subtype == 0)) {
      if (unistimdebug)
         ast_verb(0, "New unistim channel with a previous rtp handle ?\n");
      tmp->fds[0] = ast_rtp_fd(sub->rtp);
      tmp->fds[1] = ast_rtcp_fd(sub->rtp);
   }
   if (sub->rtp)
      ast_jb_configure(tmp, &global_jbconf);
      
/*      tmp->type = type; */
   ast_setstate(tmp, state);
   if (state == AST_STATE_RING)
      tmp->rings = 1;
   tmp->adsicpe = AST_ADSI_UNAVAILABLE;
   tmp->writeformat = fmt;
   tmp->rawwriteformat = fmt;
   tmp->readformat = fmt;
   tmp->rawreadformat = fmt;
   tmp->tech_pvt = sub;
   tmp->tech = &unistim_tech;
   if (!ast_strlen_zero(l->language))
      ast_string_field_set(tmp, language, l->language);
   sub->owner = tmp;
   ast_mutex_lock(&usecnt_lock);
   usecnt++;
   ast_mutex_unlock(&usecnt_lock);
   ast_update_use_count();
   tmp->callgroup = l->callgroup;
   tmp->pickupgroup = l->pickupgroup;
   ast_string_field_set(tmp, call_forward, l->parent->call_forward);
   if (!ast_strlen_zero(l->cid_num)) {
      char *name, *loc, *instr;
      instr = ast_strdup(l->cid_num);
      if (instr) {
         ast_callerid_parse(instr, &name, &loc);
         tmp->cid.cid_num = ast_strdup(loc);
         tmp->cid.cid_name = ast_strdup(name);
         ast_free(instr);
      }
   }
   tmp->priority = 1;
   if (state != AST_STATE_DOWN) {
      if (unistimdebug)
         ast_verb(0, "Starting pbx in unistim_new\n");
      if (ast_pbx_start(tmp)) {
         ast_log(LOG_WARNING, "Unable to start PBX on %s\n", tmp->name);
         ast_hangup(tmp);
         tmp = NULL;
      }
   }

   return tmp;
}

static struct ast_frame * unistim_read

(

struct ast_channel *

ast

)

[static, read]

Definition at line 3952 of file chan_unistim.c.

References ast_mutex_lock(), ast_mutex_unlock(), unistim_subchannel::lock, ast_channel::tech_pvt, and unistim_rtp_read().

{
   struct ast_frame *fr;
   struct unistim_subchannel *sub = ast->tech_pvt;

   ast_mutex_lock(&sub->lock);
   fr = unistim_rtp_read(ast, sub);
   ast_mutex_unlock(&sub->lock);

   return fr;
}

static int unistim_register

(

struct unistimsession *

s

)

[static]

Definition at line 1451 of file chan_unistim.c.

References ast_mutex_lock(), ast_mutex_unlock(), unistim_device::codec_number, DEFAULT_CODEC, unistimsession::device, devicelock, unistim_device::id, unistimsession::macaddr, unistim_device::missed_call, unistim_device::next, unistim_device::pos_fav, unistim_device::receiver_state, unistim_device::session, and STATE_ONHOOK.

Referenced by rcv_mac_addr().

{
   struct unistim_device *d;

   ast_mutex_lock(&devicelock);
   d = devices;
   while (d) {
      if (!strcasecmp(s->macaddr, d->id)) {
         /* XXX Deal with IP authentication */
         s->device = d;
         d->session = s;
         d->codec_number = DEFAULT_CODEC;
         d->pos_fav = 0;
         d->missed_call = 0;
         d->receiver_state = STATE_ONHOOK;
         break;
      }
      d = d->next;
   }
   ast_mutex_unlock(&devicelock);

   if (!d)
      return 0;

   return 1;
}

static char* unistim_reload	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)			[static]

--- 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

Definition at line 4835 of file chan_unistim.c.

References ast_cli_args::argc, ast_cli_entry::args, ast_mutex_lock(), ast_mutex_unlock(), ast_verb, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, restart_monitor(), unistim_reload_lock, and ast_cli_entry::usage.

Referenced by reload().

{
   switch (cmd) {
   case CLI_INIT:
      e->command = "unistim reload";
      e->usage =
         "Usage: unistim reload\n" 
         "       Reloads UNISTIM configuration from unistim.conf\n";
      return NULL;

   case CLI_GENERATE:
      return NULL;   /* no completion */
   }

   if (e && a && a->argc != e->args)
      return CLI_SHOWUSAGE;

   if (unistimdebug)
      ast_verb(0, "reload unistim\n");

   ast_mutex_lock(&unistim_reload_lock);
   if (!unistim_reloading)
      unistim_reloading = 1;
   ast_mutex_unlock(&unistim_reload_lock);

   restart_monitor();

   return CLI_SUCCESS;
}

static struct ast_channel * unistim_request	(	const char *	type,
		int	format,
		void *	data,
		int *	cause
	)			[static, read]

Definition at line 4618 of file chan_unistim.c.

References AST_CAUSE_BUSY, AST_CAUSE_CONGESTION, ast_copy_string(), ast_getformatname(), ast_log(), AST_STATE_DOWN, ast_strlen_zero(), ast_verb, unistim_line::capability, CAPABILITY, find_subchannel_by_name(), LOG_NOTICE, LOG_WARNING, unistim_subchannel::owner, unistim_subchannel::parent, restart_monitor(), and unistim_new().

{
   int oldformat;
   struct unistim_subchannel *sub;
   struct ast_channel *tmpc = NULL;
   char tmp[256];
   char *dest = data;

   oldformat = format;
   format &= CAPABILITY;
   ast_log(LOG_NOTICE,
         "Asked to get a channel of format %s while capability is %d result : %s (%d) \n",
         ast_getformatname(oldformat), CAPABILITY, ast_getformatname(format), format);
   if (!format) {
      ast_log(LOG_NOTICE,
            "Asked to get a channel of unsupported format %s while capability is %s\n",
            ast_getformatname(oldformat), ast_getformatname(CAPABILITY));
      return NULL;
   }

   ast_copy_string(tmp, dest, sizeof(tmp));
   if (ast_strlen_zero(tmp)) {
      ast_log(LOG_NOTICE, "Unistim channels require a device\n");
      return NULL;
   }

   sub = find_subchannel_by_name(tmp);
   if (!sub) {
      ast_log(LOG_NOTICE, "No available lines on: %s\n", dest);
      *cause = AST_CAUSE_CONGESTION;
      return NULL;
   }

   ast_verb(3, "unistim_request(%s)\n", tmp);
   /* Busy ? */
   if (sub->owner) {
      if (unistimdebug)
         ast_verb(0, "Can't create channel : Busy !\n");
      *cause = AST_CAUSE_BUSY;
      return NULL;
   }
   sub->parent->capability = format;
   tmpc = unistim_new(sub, AST_STATE_DOWN);
   if (!tmpc)
      ast_log(LOG_WARNING, "Unable to make channel for '%s'\n", tmp);
   if (unistimdebug)
      ast_verb(0, "unistim_request owner = %p\n", sub->owner);
   restart_monitor();

   /* and finish */
   return tmpc;
}

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

Definition at line 3904 of file chan_unistim.c.

References ast_debug, AST_FRAME_VOICE, ast_getformatname(), ast_log(), ast_null_frame, ast_rtcp_read(), ast_rtp_read(), ast_set_read_format(), ast_set_write_format(), f, ast_channel::fdno, ast_frame::frametype, LOG_WARNING, ast_channel::nativeformats, unistim_subchannel::owner, ast_channel::readformat, unistim_subchannel::rtp, ast_frame::subclass, unistim_subchannel::subtype, and ast_channel::writeformat.

Referenced by unistim_read().

{
   /* Retrieve audio/etc from channel.  Assumes sub->lock is already held. */
   struct ast_frame *f;

   if (!ast) {
      ast_log(LOG_WARNING, "Channel NULL while reading\n");
      return &ast_null_frame;
   }

   if (!sub->rtp) {
      ast_log(LOG_WARNING, "RTP handle NULL while reading on subchannel %d\n",
            sub->subtype);
      return &ast_null_frame;
   }

   switch (ast->fdno) {
   case 0:
      f = ast_rtp_read(sub->rtp);     /* RTP Audio */
      break;
   case 1:
      f = ast_rtcp_read(sub->rtp);    /* RTCP Control Channel */
      break;
   default:
      f = &ast_null_frame;
   }

   if (sub->owner) {
      /* We already hold the channel lock */
      if (f->frametype == AST_FRAME_VOICE) {
         if (f->subclass != sub->owner->nativeformats) {
            ast_debug(1,
                  "Oooh, format changed from %s (%d) to %s (%d)\n",
                  ast_getformatname(sub->owner->nativeformats),
                  sub->owner->nativeformats, ast_getformatname(f->subclass),
                  f->subclass);

            sub->owner->nativeformats = f->subclass;
            ast_set_read_format(sub->owner, sub->owner->readformat);
            ast_set_write_format(sub->owner, sub->owner->writeformat);
         }
      }
   }

   return f;
}

static int unistim_send_mwi_to_peer	(	struct unistimsession *	s,
		unsigned int	tick
	)			[static]

Definition at line 4378 of file chan_unistim.c.

References ast_app_has_voicemail(), ast_event_destroy(), ast_event_get_cached(), ast_event_get_ie_uint(), AST_EVENT_IE_CONTEXT, AST_EVENT_IE_END, AST_EVENT_IE_MAILBOX, AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_STR, AST_EVENT_MWI, ast_strdupa, ast_strlen_zero(), context, unistimsession::device, unistim_line::lastmsgssent, unistim_device::lines, unistim_line::mailbox, mailbox, unistim_line::nextmsgcheck, send_led_update(), strsep(), and TIMER_MWI.

Referenced by do_monitor().

{
   struct ast_event *event;
   int new;
   char *mailbox, *context;
   struct unistim_line *peer = s->device->lines;

   context = mailbox = ast_strdupa(peer->mailbox);
   strsep(&context, "@");
   if (ast_strlen_zero(context))
      context = "default";

   event = ast_event_get_cached(AST_EVENT_MWI,
      AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, mailbox,
      AST_EVENT_IE_CONTEXT, AST_EVENT_IE_PLTYPE_STR, context,
      AST_EVENT_IE_END);

   if (event) {
      new = ast_event_get_ie_uint(event, AST_EVENT_IE_NEWMSGS);
      ast_event_destroy(event);
   } else { /* Fall back on checking the mailbox directly */
      new = ast_app_has_voicemail(peer->mailbox, "INBOX");
   }

   peer->nextmsgcheck = tick + TIMER_MWI;

   /* Return now if it's the same thing we told them last time */
   if (new == peer->lastmsgssent) {
      return 0;
   }

   peer->lastmsgssent = new;
   if (new == 0) {
      send_led_update(s, 0);
   } else {
      send_led_update(s, 1);
   }

   return 0;
}

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

Definition at line 4208 of file chan_unistim.c.

References channel_to_session(), and unistim_do_senddigit().

{
   struct unistimsession *pte = channel_to_session(ast);

   if (!pte)
      return -1;

   return unistim_do_senddigit(pte, digit);
}

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

Definition at line 4218 of file chan_unistim.c.

References unistim_subchannel::alreadygone, AST_FRAME_DTMF, ast_log(), ast_queue_frame(), ast_verb, channel_to_session(), unistimsession::device, ast_frame::frametype, unistim_device::lines, LOG_WARNING, unistim_subchannel::owner, send_tone(), ast_frame::src, SUB_REAL, ast_frame::subclass, and unistim_line::subs.

{
   struct unistimsession *pte = channel_to_session(ast);
   struct ast_frame f = { 0, };
   struct unistim_subchannel *sub;

   sub = pte->device->lines->subs[SUB_REAL];

   if (!sub->owner || sub->alreadygone) {
      ast_log(LOG_WARNING, "Unable to find subchannel in dtmf senddigit_end\n");
      return -1;
   }

   if (unistimdebug)
      ast_verb(0, "Send Digit off %c\n", digit);

   if (!pte)
      return -1;

   send_tone(pte, 0, 0);
   f.frametype = AST_FRAME_DTMF;
   f.subclass = digit;
   f.src = "unistim";
   ast_queue_frame(sub->owner, &f);

   return 0;
}

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

Definition at line 4248 of file chan_unistim.c.

References ast_log(), ast_verb, channel_to_session(), unistimsession::device, LOG_WARNING, send_favorite(), send_text(), unistim_device::softkeyicon, unistim_device::softkeylabel, unistim_device::softkeynumber, TEXT_LENGTH_MAX, TEXT_LINE0, TEXT_LINE1, TEXT_LINE2, and TEXT_NORMAL.

{
   struct unistimsession *pte = channel_to_session(ast);
   int size;
   char tmp[TEXT_LENGTH_MAX + 1];

   if (unistimdebug)
      ast_verb(0, "unistim_sendtext called\n");

   if (!text) {
      ast_log(LOG_WARNING, "unistim_sendtext called with a null text\n");
      return 1;
   }

   size = strlen(text);
   if (text[0] == '@') {
      int pos = 0, i = 1, tok = 0, sz = 0;
      char label[11];
      char number[16];
      char icon = '\0';
      char cur = '\0';

      memset(label, 0, 11);
      memset(number, 0, 16);
      while (text[i]) {
         cur = text[i++];
         switch (tok) {
         case 0:
            if ((cur < '0') && (cur > '5')) {
               ast_log(LOG_WARNING,
                     "sendtext failed : position must be a number beetween 0 and 5\n");
               return 1;
            }
            pos = cur - '0';
            tok = 1;
            continue;
         case 1:
            if (cur != '@') {
               ast_log(LOG_WARNING, "sendtext failed : invalid position\n");
               return 1;
            }
            tok = 2;
            continue;
         case 2:
            if ((cur < '3') && (cur > '6')) {
               ast_log(LOG_WARNING,
                     "sendtext failed : icon must be a number beetween 32 and 63 (first digit invalid)\n");
               return 1;
            }
            icon = (cur - '0') * 10;
            tok = 3;
            continue;
         case 3:
            if ((cur < '0') && (cur > '9')) {
               ast_log(LOG_WARNING,
                     "sendtext failed : icon must be a number beetween 32 and 63 (second digit invalid)\n");
               return 1;
            }
            icon += (cur - '0');
            tok = 4;
            continue;
         case 4:
            if (cur != '@') {
               ast_log(LOG_WARNING,
                     "sendtext failed : icon must be a number beetween 32 and 63 (too many digits)\n");
               return 1;
            }
            tok = 5;
            continue;
         case 5:
            if (cur == '@') {
               tok = 6;
               sz = 0;
               continue;
            }
            if (sz > 10)
               continue;
            label[sz] = cur;
            sz++;
            continue;
         case 6:
            if (sz > 15) {
               ast_log(LOG_WARNING,
                     "sendtext failed : extension too long = %d (15 car max)\n",
                     sz);
               return 1;
            }
            number[sz] = cur;
            sz++;
            continue;
         }
      }
      if (tok != 6) {
         ast_log(LOG_WARNING, "sendtext failed : incomplet command\n");
         return 1;
      }
      if (!pte->device) {
         ast_log(LOG_WARNING, "sendtext failed : no device ?\n");
         return 1;
      }
      strcpy(pte->device->softkeylabel[pos], label);
      strcpy(pte->device->softkeynumber[pos], number);
      pte->device->softkeyicon[pos] = icon;
      send_favorite(pos, icon, pte, label);
      return 0;
   }

   if (size <= TEXT_LENGTH_MAX * 2) {
      send_text(TEXT_LINE0, TEXT_NORMAL, pte, "Message :");
      send_text(TEXT_LINE1, TEXT_NORMAL, pte, text);
      if (size <= TEXT_LENGTH_MAX) {
         send_text(TEXT_LINE2, TEXT_NORMAL, pte, "");
         return 0;
      }
      memcpy(tmp, text + TEXT_LENGTH_MAX, TEXT_LENGTH_MAX);
      tmp[sizeof(tmp) - 1] = '\0';
      send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmp);
      return 0;
   }
   send_text(TEXT_LINE0, TEXT_NORMAL, pte, text);
   memcpy(tmp, text + TEXT_LENGTH_MAX, TEXT_LENGTH_MAX);
   tmp[sizeof(tmp) - 1] = '\0';
   send_text(TEXT_LINE1, TEXT_NORMAL, pte, tmp);
   memcpy(tmp, text + TEXT_LENGTH_MAX * 2, TEXT_LENGTH_MAX);
   tmp[sizeof(tmp) - 1] = '\0';
   send_text(TEXT_LINE2, TEXT_NORMAL, pte, tmp);
   return 0;
}

static int unistim_set_rtp_peer	(	struct ast_channel *	chan,
		struct ast_rtp *	rtp,
		struct ast_rtp *	vrtp,
		struct ast_rtp *	trtp,
		int	codecs,
		int	nat_active
	)			[static]

Definition at line 5540 of file chan_unistim.c.

References ast_verb, and ast_channel::tech_pvt.

{
   struct unistim_subchannel *sub;

   if (unistimdebug)
      ast_verb(0, "unistim_set_rtp_peer called\n");

   sub = chan->tech_pvt;

   if (sub)
      return 0;

   return -1;
}

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

Definition at line 4742 of file chan_unistim.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), ast_copy_string(), BUFFSEND, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, find_subchannel_by_name(), len(), unistim_line::parent, unistim_subchannel::parent, send_client(), unistim_device::session, SIZE_HEADER, and ast_cli_entry::usage.

{
   BUFFSEND;
   struct unistim_subchannel *sub;
   int i, j = 0, len;
   unsigned char c, cc;
   char tmp[256];

   switch (cmd) {
   case CLI_INIT:
      e->command = "unistim sp";
      e->usage =
         "Usage: unistim sp USTM/line@name hexa\n"
         "       unistim sp USTM/1000@hans 19040004\n";
      return NULL;

   case CLI_GENERATE:
      return NULL;   /* no completion */
   }
   
   if (a->argc < 4)
      return CLI_SHOWUSAGE;

   if (strlen(a->argv[2]) < 9)
      return CLI_SHOWUSAGE;

   len = strlen(a->argv[3]);
   if (len % 2)
      return CLI_SHOWUSAGE;

   ast_copy_string(tmp, a->argv[2] + 5, sizeof(tmp));
   sub = find_subchannel_by_name(tmp);
   if (!sub) {
      ast_cli(a->fd, "Can't find '%s'\n", tmp);
      return CLI_SUCCESS;
   }
   if (!sub->parent->parent->session) {
      ast_cli(a->fd, "'%s' is not connected\n", tmp);
      return CLI_SUCCESS;
   }
   ast_cli(a->fd, "Sending '%s' to %s (%p)\n", a->argv[3], tmp, sub->parent->parent->session);
   for (i = 0; i < len; i++) {
      c = a->argv[3][i];
      if (c >= 'a')
         c -= 'a' - 10;
      else
         c -= '0';
      i++;
      cc = a->argv[3][i];
      if (cc >= 'a')
         cc -= 'a' - 10;
      else
         cc -= '0';
      tmp[j++] = (c << 4) | cc;
   }
   memcpy(buffsend + SIZE_HEADER, tmp, j);
   send_client(SIZE_HEADER + j, buffsend, sub->parent->parent->session);
   return CLI_SUCCESS;
}

static void* unistim_ss

(

void *

data

)

[static]

Definition at line 2006 of file chan_unistim.c.

References ast_copy_string(), ast_log(), ast_pbx_run(), ast_setstate(), AST_STATE_RING, ast_verb, chan, unistimsession::device, ast_channel::exten, LOG_WARNING, unistim_device::name, unistim_line::name, unistim_line::parent, unistim_subchannel::parent, unistim_device::phone_number, unistim_device::redial_number, s, send_tone(), unistim_device::session, unistim_subchannel::subtype, and ast_channel::tech_pvt.

Referenced by HandleCallOutgoing().

{
   struct ast_channel *chan = data;
   struct unistim_subchannel *sub = chan->tech_pvt;
   struct unistim_line *l = sub->parent;
   struct unistimsession *s = l->parent->session;
   int res;

   ast_verb(3, "Starting switch on '%s@%s-%d' to %s\n", l->name, l->parent->name, sub->subtype, s->device->phone_number);
   ast_copy_string(chan->exten, s->device->phone_number, sizeof(chan->exten));
   ast_copy_string(s->device->redial_number, s->device->phone_number,
               sizeof(s->device->redial_number));
   ast_setstate(chan, AST_STATE_RING);
   res = ast_pbx_run(chan);
   if (res) {
      ast_log(LOG_WARNING, "PBX exited non-zero\n");
      send_tone(s, 1000, 0);;
   }
   return NULL;
}

static int unistim_write	(	struct ast_channel *	ast,
		struct ast_frame *	frame
	)			[static]

Definition at line 3964 of file chan_unistim.c.

References AST_FRAME_IMAGE, AST_FRAME_VOICE, ast_getformatname(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_rtp_write(), ast_frame::frametype, unistim_subchannel::lock, LOG_WARNING, ast_channel::nativeformats, ast_channel::readformat, unistim_subchannel::rtp, ast_frame::subclass, ast_channel::tech_pvt, and ast_channel::writeformat.

{
   struct unistim_subchannel *sub = ast->tech_pvt;
   int res = 0;

   if (frame->frametype != AST_FRAME_VOICE) {
      if (frame->frametype == AST_FRAME_IMAGE)
         return 0;
      else {
         ast_log(LOG_WARNING, "Can't send %d type frames with unistim_write\n",
               frame->frametype);
         return 0;
      }
   } else {
      if (!(frame->subclass & ast->nativeformats)) {
         ast_log(LOG_WARNING,
               "Asked to transmit frame type %s (%d), while native formats is %s (%d) (read/write = %s (%d)/%d)\n",
               ast_getformatname(frame->subclass), frame->subclass,
               ast_getformatname(ast->nativeformats), ast->nativeformats,
               ast_getformatname(ast->readformat), ast->readformat,
               ast->writeformat);
         return -1;
      }
   }

   if (sub) {
      ast_mutex_lock(&sub->lock);
      if (sub->rtp) {
         res = ast_rtp_write(sub->rtp, frame);
      }
      ast_mutex_unlock(&sub->lock);
   }

   return res;
}

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

Definition at line 3847 of file chan_unistim.c.

References ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verb, errno, LOG_NOTICE, LOG_WARNING, unistimsession::next, parsing(), sessionlock, unistimsession::sin, and SIZE_PAGE.

Referenced by do_monitor().

{
   struct sockaddr_in addr_from = { 0, };
   struct unistimsession *cur = NULL;
   int found = 0;
   int tmp = 0;
   int dw_num_bytes_rcvd;
#ifdef DUMP_PACKET
   int dw_num_bytes_rcvdd;
   char iabuf[INET_ADDRSTRLEN];
#endif

   dw_num_bytes_rcvd =
      recvfrom(unistimsock, buff, SIZE_PAGE, 0, (struct sockaddr *) &addr_from,
             &size_addr_from);
   if (dw_num_bytes_rcvd == -1) {
      if (errno == EAGAIN)
         ast_log(LOG_NOTICE, "UNISTIM: Received packet with bad UDP checksum\n");
      else if (errno != ECONNREFUSED)
         ast_log(LOG_WARNING, "Recv error %d (%s)\n", errno, strerror(errno));
      return 1;
   }

   /* Looking in the phone list if we already have a registration for him */
   ast_mutex_lock(&sessionlock);
   cur = sessions;
   while (cur) {
      if (cur->sin.sin_addr.s_addr == addr_from.sin_addr.s_addr) {
         found = 1;
         break;
      }
      tmp++;
      cur = cur->next;
   }
   ast_mutex_unlock(&sessionlock);

#ifdef DUMP_PACKET
   if (unistimdebug)
      ast_verb(0, "\n*** Dump %d bytes from %s - phone_table[%d] ***\n",
               dw_num_bytes_rcvd, ast_inet_ntoa(addr_from.sin_addr), tmp);
   for (dw_num_bytes_rcvdd = 0; dw_num_bytes_rcvdd < dw_num_bytes_rcvd;
       dw_num_bytes_rcvdd++)
      ast_verb(0, "%.2x ", (unsigned char) buff[dw_num_bytes_rcvdd]);
   ast_verb(0, "\n******************************************\n");
#endif

   if (!found) {
      if (unistimdebug)
         ast_verb(0, "Received a packet from an unknown source\n");
      parsing(dw_num_bytes_rcvd, buff, NULL, (struct sockaddr_in *) &addr_from);

   } else
      parsing(dw_num_bytes_rcvd, buff, cur, (struct sockaddr_in *) &addr_from);

   return 1;
}

static int unload_module

(

void

)

[static]

Definition at line 5615 of file chan_unistim.c.

References ARRAY_LEN, ast_channel_unregister(), ast_cli_unregister_multiple(), ast_free, ast_mutex_lock(), ast_mutex_unlock(), AST_PTHREADT_NULL, AST_PTHREADT_STOP, ast_rtp_proto_unregister(), monlock, and sched_context_destroy().

{
   /* First, take us out of the channel loop */
   if (sched)
      sched_context_destroy(sched);

   ast_cli_unregister_multiple(unistim_cli, ARRAY_LEN(unistim_cli));

   ast_channel_unregister(&unistim_tech);
   ast_rtp_proto_unregister(&unistim_rtp);

   ast_mutex_lock(&monlock);
   if (monitor_thread && (monitor_thread != AST_PTHREADT_STOP) && (monitor_thread != AST_PTHREADT_NULL)) {
      pthread_cancel(monitor_thread);
      pthread_kill(monitor_thread, SIGURG);
      pthread_join(monitor_thread, NULL);
   }
   monitor_thread = AST_PTHREADT_STOP;
   ast_mutex_unlock(&monlock);

   if (buff)
      ast_free(buff);
   if (unistimsock > -1)
      close(unistimsock);

   return 0;
}

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

Definition at line 4872 of file chan_unistim.c.

References len().

Referenced by build_device().

{
   int len = strlen(src);
   if (!len)
      return;
   if ((len > 1) && src[0] == '\"') {
      /* This is a quoted string */
      src++;
      /* Don't take more than what's there */
      len--;
      if (maxlen > len - 1)
         maxlen = len - 1;
      memcpy(out, src, maxlen);
      ((char *) out)[maxlen] = '\0';
   } else
      memcpy(out, src, maxlen);
   return;
}

static int UnregisterExtension

(

const struct unistimsession *

pte

)

[static]

Definition at line 1096 of file chan_unistim.c.

References ast_context_remove_extension(), ast_verb, unistim_line::context, unistimsession::device, unistim_device::extension_number, and unistim_device::lines.

Referenced by close_client(), and key_main_page().

{
   if (unistimdebug)
      ast_verb(0, "Trying to unregister extension '%s' context '%s'\n",
               pte->device->extension_number, pte->device->lines->context);
   return ast_context_remove_extension(pte->device->lines->context,
                              pte->device->extension_number, 1, "Unistim");
}

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

Definition at line 1671 of file chan_unistim.c.

References unistimsession::device, display_last_error(), unistim_device::lst_cid, unistim_device::lst_cnm, and TEXT_LENGTH_MAX.

Referenced by write_history().

{
   if (fwrite(&c, 1, 1, f) != 1) {
      display_last_error("Unable to write history log header.");
      return -1;
   }
   if (fwrite(line1, TEXT_LENGTH_MAX, 1, f) != 1) {
      display_last_error("Unable to write history entry - date.");
      return -1;
   }
   if (fwrite(pte->device->lst_cid, TEXT_LENGTH_MAX, 1, f) != 1) {
      display_last_error("Unable to write history entry - callerid.");
      return -1;
   }
   if (fwrite(pte->device->lst_cnm, TEXT_LENGTH_MAX, 1, f) != 1) {
      display_last_error("Unable to write history entry - callername.");
      return -1;
   }
   return 0;
}

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

Definition at line 1692 of file chan_unistim.c.

References ast_config_AST_LOG_DIR, AST_CONFIG_MAX_PATH, ast_free, ast_localtime(), ast_log(), ast_malloc, ast_mkdir(), ast_tvnow(), unistim_device::callhistory, unistimsession::device, display_last_error(), errno, f, LOG_WARNING, MAX_ENTRY_LOG, unistim_device::name, TEXT_LENGTH_MAX, ast_tm::tm_hour, ast_tm::tm_mday, ast_tm::tm_min, ast_tm::tm_mon, ast_tm::tm_sec, ast_tm::tm_year, USTM_LOG_DIR, and write_entry_history().

Referenced by cancel_dial(), close_call(), and HandleCallIncoming().

{
   char tmp[AST_CONFIG_MAX_PATH], tmp2[AST_CONFIG_MAX_PATH];
   char line1[TEXT_LENGTH_MAX + 1];
   char count = 0, *histbuf;
   int size;
   FILE *f, *f2;
   struct timeval now = ast_tvnow();
   struct ast_tm atm = { 0, };

   if (!pte->device)
      return -1;
   if (!pte->device->callhistory)
      return 0;
   if (strchr(pte->device->name, '/') || (pte->device->name[0] == '.')) {
      ast_log(LOG_WARNING, "Account code '%s' insecure for writing file\n",
            pte->device->name);
      return -1;
   }

   snprintf(tmp, sizeof(tmp), "%s/%s", ast_config_AST_LOG_DIR, USTM_LOG_DIR);
   if (ast_mkdir(tmp, 0770)) {
      if (errno != EEXIST) {
         display_last_error("Unable to create directory for history");
         return -1;
      }
   }

   ast_localtime(&now, &atm, NULL);
   if (ismissed) {
      if (way == 'i')
         strcpy(tmp2, "Miss");
      else
         strcpy(tmp2, "Fail");
   } else
      strcpy(tmp2, "Answ");
   snprintf(line1, sizeof(line1), "%04d/%02d/%02d %02d:%02d:%02d %s",
          atm.tm_year + 1900, atm.tm_mon + 1, atm.tm_mday, atm.tm_hour,
          atm.tm_min, atm.tm_sec, tmp2);

   snprintf(tmp, sizeof(tmp), "%s/%s/%s-%c.csv", ast_config_AST_LOG_DIR,
          USTM_LOG_DIR, pte->device->name, way);
   if ((f = fopen(tmp, "r"))) {
      struct stat bufstat;

      if (stat(tmp, &bufstat)) {
         display_last_error("Unable to stat history log.");
         fclose(f);
         return -1;
      }
      size = 1 + (MAX_ENTRY_LOG * TEXT_LENGTH_MAX * 3);
      if (bufstat.st_size != size) {
         ast_log(LOG_WARNING,
               "History file %s has an incorrect size (%d instead of %d). It will be replaced by a new one.",
               tmp, (int) bufstat.st_size, size);
         fclose(f);
         f = NULL;
         count = 1;
      }
   }

   /* If we can't open the log file, we create a brand new one */
   if (!f) {
      char c = 1;
      int i;

      if ((errno != ENOENT) && (count == 0)) {
         display_last_error("Unable to open history log.");
         return -1;
      }
      f = fopen(tmp, "w");
      if (!f) {
         display_last_error("Unable to create history log.");
         return -1;
      }
      if (write_entry_history(pte, f, c, line1)) {
         fclose(f);
         return -1;
      }
      memset(line1, ' ', TEXT_LENGTH_MAX);
      for (i = 3; i < MAX_ENTRY_LOG * 3; i++) {
         if (fwrite(line1, TEXT_LENGTH_MAX, 1, f) != 1) {
            display_last_error("Unable to write history entry - stuffing.");
            fclose(f);
            return -1;
         }
      }
      if (fclose(f))
         display_last_error("Unable to close history - creation.");
      return 0;
   }
   /* We can open the log file, we create a temporary one, we add our entry and copy the rest */
   if (fread(&count, 1, 1, f) != 1) {
      display_last_error("Unable to read history header.");
      fclose(f);
      return -1;
   }
   if (count > MAX_ENTRY_LOG) {
      ast_log(LOG_WARNING, "Invalid count in history header of %s (%d max %d)\n", tmp,
            count, MAX_ENTRY_LOG);
      fclose(f);
      return -1;
   }
   snprintf(tmp2, sizeof(tmp2), "%s/%s/%s-%c.csv.tmp", ast_config_AST_LOG_DIR,
          USTM_LOG_DIR, pte->device->name, way);
   if (!(f2 = fopen(tmp2, "w"))) {
      display_last_error("Unable to create temporary history log.");
      fclose(f);
      return -1;
   }

   if (++count > MAX_ENTRY_LOG)
      count = MAX_ENTRY_LOG;

   if (write_entry_history(pte, f2, count, line1)) {
      fclose(f);
      fclose(f2);
      return -1;
   }

   size = (MAX_ENTRY_LOG - 1) * TEXT_LENGTH_MAX * 3;
   if (!(histbuf = ast_malloc(size))) {
      fclose(f);
      fclose(f2);
      return -1;
   }

   if (fread(histbuf, size, 1, f) != 1) {
      ast_free(histbuf);
      fclose(f);
      fclose(f2);
      display_last_error("Unable to read previous history entries.");
      return -1;
   }
   if (fwrite(histbuf, size, 1, f2) != 1) {
      ast_free(histbuf);
      fclose(f);
      fclose(f2);
      display_last_error("Unable to write previous history entries.");
      return -1;
   }
   ast_free(histbuf);
   if (fclose(f))
      display_last_error("Unable to close history log.");
   if (fclose(f2))
      display_last_error("Unable to close temporary history log.");
   if (unlink(tmp))
      display_last_error("Unable to remove old history log.");
   if (rename(tmp2, tmp))
      display_last_error("Unable to rename new history log.");
   return 0;
}

---

Variable Documentation

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 = "a9c98e5d177805051735cb5b0b16b0a0" , .load = load_module, .unload = unload_module, .reload = reload, } [static]

Definition at line 5654 of file chan_unistim.c.

struct sockaddr_in address_from [static]

give the IP address for the last packet received

Definition at line 221 of file chan_unistim.c.

struct ast_module_info* ast_module_info = &__mod_info [static]

Definition at line 5654 of file chan_unistim.c.

enum autoprovision autoprovisioning = AUTOPROVISIONING_NO [static]

Definition at line 206 of file chan_unistim.c.

unsigned char* buff [static]

Receive buffer address

Definition at line 225 of file chan_unistim.c.

Referenced by clean_up_bc(), init_bc(), isdn_port_info(), moh_class_destructor(), setup_bc(), socket_receive_file_to_buff(), stack_init(), and te_lib_init().

const char channel_type[] = "USTM" [static]

Definition at line 670 of file chan_unistim.c.

unsigned int cos

Definition at line 213 of file chan_unistim.c.

unsigned int cos_audio

Definition at line 214 of file chan_unistim.c.

struct ast_jb_conf default_jbconf [static]

Global jitterbuffer configuration - by default, jb is disabled.

Definition at line 189 of file chan_unistim.c.

ast_mutex_t devicelock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP ) [static]

Protect the device list

Definition at line 242 of file chan_unistim.c.

Referenced by build_device(), find_subchannel_by_name(), key_main_page(), key_select_extension(), rcv_mac_addr(), reload_config(), and unistim_register().

struct unistim_device * devices [static]

A device containing one or more lines.

struct tone_zone_unistim frequency[] [static]

Definition at line 309 of file chan_unistim.c.

struct ast_jb_conf global_jbconf [static]

Definition at line 196 of file chan_unistim.c.

Referenced by reload_config(), and unistim_new().

struct io_context* io [static]

Definition at line 217 of file chan_unistim.c.

pthread_t monitor_thread = AST_PTHREADT_NULL [static]

This is the thread for the monitor which checks for input on the channels which are not currently in use.

Definition at line 234 of file chan_unistim.c.

ast_mutex_t monlock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP ) [static]

Protect the monitoring thread, so only one process can kill or start it, and not when it's doing something critical.

Definition at line 238 of file chan_unistim.c.

Referenced by restart_monitor(), and unload_module().

const unsigned char packet_rcv_discovery[] [static]

Initial value:

   { 0xff, 0xff, 0xff, 0xff, 0x02, 0x02, 0xff, 0xff, 0xff, 0xff, 0x9e, 0x03, 0x08 }

Definition at line 503 of file chan_unistim.c.

const unsigned char packet_recv_firm_version[] [static]

Initial value:

   { 0x00, 0x00, 0x00, 0x13, 0x9a, 0x0a, 0x02 }

Definition at line 508 of file chan_unistim.c.

const unsigned char packet_recv_hangup[] [static]

Initial value:

   { 0x00, 0x00, 0x00, 0x13, 0x99, 0x03, 0x03 }

Definition at line 514 of file chan_unistim.c.

const unsigned char packet_recv_mac_addr[] [static]

Initial value:

   { 0xff, 0xff, 0xff, 0xff, 0x9a, 0x0d, 0x07   }

Definition at line 521 of file chan_unistim.c.

const unsigned char packet_recv_pick_up[] [static]

Initial value:

   { 0x00, 0x00, 0x00, 0x13, 0x99, 0x03, 0x04 }

Definition at line 512 of file chan_unistim.c.

const unsigned char packet_recv_pressed_key[] [static]

Initial value:

   { 0x00, 0x00, 0x00, 0x13, 0x99, 0x04, 0x00 }

Definition at line 510 of file chan_unistim.c.

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

Definition at line 516 of file chan_unistim.c.

const unsigned char packet_recv_resume_connection_with_server[] [static]

Initial value:

   { 0xff, 0xff, 0xff, 0xff, 0x9e, 0x03, 0x08 }

TransportAdapter

Definition at line 519 of file chan_unistim.c.

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

Definition at line 616 of file chan_unistim.c.

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

Definition at line 617 of file chan_unistim.c.

const unsigned char packet_send_call[] [static]

Definition at line 544 of file chan_unistim.c.

const unsigned char packet_send_Contrast[] [static]

Initial value:

   { 0x17, 0x04, 0x24,  0x08 }

Definition at line 621 of file chan_unistim.c.

const unsigned char packet_send_date_time[] [static]

Definition at line 528 of file chan_unistim.c.

const unsigned char packet_send_date_time2[] [static]

Initial value:

 { 0x17, 0x04, 0x17, 0x3d, 0x11, 0x09, 0x02, 0x0a,  0x05,   
   0x06,  0x07,  0x08, 0x32
}

Definition at line 618 of file chan_unistim.c.

const unsigned char packet_send_date_time3[] [static]

Initial value:

   { 0x11, 0x09, 0x02, 0x02,  0x05,  0x06,  0x07,
 0x08, 0x32
}

Definition at line 524 of file chan_unistim.c.

unsigned char packet_send_discovery_ack[] [static]

Initial value:

   { 0x00, 0x00,  0x00, 0x00, 0x00, 0x01 }

Definition at line 505 of file chan_unistim.c.

const unsigned char packet_send_end_call[] [static]

Initial value:

   { 0x16, 0x06, 0x32, 0xdf, 0x00, 0xff, 0x16, 0x05, 0x31, 0x00, 0x00, 0x19, 0x04, 0x00,
0x10, 0x19, 0x04, 0x00, 0x18, 0x16, 0x05,
   0x04, 0x00, 0x00, 0x16, 0x04, 0x37, 0x10
}

Definition at line 572 of file chan_unistim.c.

const unsigned char packet_send_favorite[] [static]

Initial value:

   { 0x17, 0x0f, 0x19, 0x10,  0x01,  0x20, 0x20, 0x20, 0x20, 0x20, 0x20,
0x20, 0x20, 0x20, 0x20,  0x19,
   0x05, 0x0f,  0x01,  0x00
}

Definition at line 634 of file chan_unistim.c.

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

Definition at line 627 of file chan_unistim.c.

const unsigned char packet_send_jitter_buffer_conf[] [static]

Initial value:

   { 0x16, 0x0e, 0x3a, 0x00,  0x02,  0x04, 0x00, 0x00,
 0x3e, 0x80,
   0x00, 0x00,  0x3e, 0x80
}

Definition at line 582 of file chan_unistim.c.

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

Definition at line 657 of file chan_unistim.c.

const unsigned char packet_send_no_ring[] [static]

Initial value:

   { 0x16, 0x04, 0x1a, 0x00, 0x16, 0x04, 0x11, 0x00 }

Definition at line 535 of file chan_unistim.c.

const unsigned char packet_send_open_audio_stream_rx[] [static]

Initial value:

   { 0x16, 0x1a, 0x30, 0x00, 0xff,  0x00, 0x00, 0x01, 0x00, 0xb8, 0xb8, 0x0e,
0x0e, 0x01,  0x14, 0x50, 0x00,
   0x00,  0x14, 0x50, 0x00, 0x00,  0x0a, 0x93, 0x69, 0x05
}

Definition at line 591 of file chan_unistim.c.

const unsigned char packet_send_open_audio_stream_rx3[] [static]

Definition at line 602 of file chan_unistim.c.

const unsigned char packet_send_open_audio_stream_tx[] [static]

Initial value:

   { 0x16, 0x1a, 0x30, 0xff, 0x00, 0x00,  0x00, 0x01, 0x00, 0xb8, 0xb8, 0x0e,
0x0e, 0x01,  0x14, 0x50,
   0x00, 0x00,  0x14, 0x50, 0x00, 0x00,  0x0a, 0x93, 0x69, 0x05
}

Definition at line 596 of file chan_unistim.c.

const unsigned char packet_send_open_audio_stream_tx3[] [static]

Definition at line 609 of file chan_unistim.c.

unsigned char packet_send_ping[] [static]

Initial value:

   { 0x1e, 0x05, 0x12, 0x00,  0x78 }

Definition at line 664 of file chan_unistim.c.

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

Definition at line 659 of file chan_unistim.c.

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

Definition at line 661 of file chan_unistim.c.

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

Definition at line 660 of file chan_unistim.c.

const unsigned char packet_send_ring[] [static]

Initial value:

   { 0x16, 0x06, 0x32, 0xdf, 0x00, 0xff, 0x16, 0x05, 0x1c, 0x00, 0x00, 0x16,
   0x04, 0x1a, 0x01, 0x16, 0x05, 0x12, 0x13  , 0x18, 0x16, 0x04, 0x18,     
   0x20, 0x16, 0x04, 0x10, 0x00
}

Definition at line 567 of file chan_unistim.c.

const unsigned char packet_send_rtp_packet_size[] [static]

Initial value:

   { 0x16, 0x08, 0x38, 0x00, 0x00, 0xe0, 0x00, 0xa0 }

Definition at line 580 of file chan_unistim.c.

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

Definition at line 662 of file chan_unistim.c.

const unsigned char packet_send_s4[] [static]

Definition at line 537 of file chan_unistim.c.

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

Definition at line 628 of file chan_unistim.c.

const unsigned char packet_send_s9[] [static]

Initial value:

   { 0x16, 0x06, 0x32, 0xdf, 0x00, 0xff, 0x19, 0x04, 0x00, 0x10, 0x16, 0x05, 0x1c, 0x00,
0x00 }

Definition at line 577 of file chan_unistim.c.

const unsigned char packet_send_select_output[] [static]

Initial value:

   { 0x16, 0x06, 0x32, 0xc0, 0x01, 0x00 }

Definition at line 565 of file chan_unistim.c.

const unsigned char packet_send_set_pos_cursor[] [static]

Initial value:

   { 0x17, 0x06, 0x10, 0x81, 0x04,  0x20 }

Definition at line 629 of file chan_unistim.c.

const unsigned char packet_send_StartTimer[] [static]

Initial value:

   { 0x17, 0x05, 0x0b, 0x05, 0x00, 0x17, 0x08, 0x16,  0x44, 0x75, 0x72, 0xe9,
0x65 }

Definition at line 623 of file chan_unistim.c.

const unsigned char packet_send_status[] [static]

Initial value:

   { 0x17, 0x20, 0x19, 0x08,  0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20,
0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20,
   0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20    
}

Definition at line 648 of file chan_unistim.c.

const unsigned char packet_send_status2[] [static]

Initial value:

   { 0x17, 0x0b, 0x19,  0x00,  0x20, 0x20, 0x20, 0x20,
0x20, 0x20, 0x20   }

Definition at line 653 of file chan_unistim.c.

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

Definition at line 626 of file chan_unistim.c.

const unsigned char packet_send_stream_based_tone_dial_freq[] [static]

Initial value:

   { 0x16, 0x08, 0x1d, 0x00, 0x01, 0xb8, 0x01, 0x5e }

Definition at line 563 of file chan_unistim.c.

const unsigned char packet_send_stream_based_tone_off[] [static]

Initial value:

   { 0x16, 0x05, 0x1c, 0x00, 0x00 }

Definition at line 553 of file chan_unistim.c.

const unsigned char packet_send_stream_based_tone_on[] [static]

Initial value:

   { 0x16, 0x06, 0x1b, 0x00, 0x00, 0x05 }

Definition at line 559 of file chan_unistim.c.

const unsigned char packet_send_stream_based_tone_single_freq[] [static]

Initial value:

   { 0x16, 0x06, 0x1d, 0x00, 0x01, 0xb8 }

Definition at line 561 of file chan_unistim.c.

const unsigned char packet_send_text[] [static]

Definition at line 642 of file chan_unistim.c.

const unsigned char packet_send_title[] [static]

Initial value:

   { 0x17, 0x10, 0x19, 0x02,  0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20,
0x20, 0x20, 0x20, 0x20   }

Definition at line 639 of file chan_unistim.c.

struct sockaddr_in public_ip = { 0, } [static]

Definition at line 219 of file chan_unistim.c.

struct { ... } qos [static]

Referenced by reload_config(), and start_rtp().

struct sched_context* sched [static]

Definition at line 218 of file chan_unistim.c.

ast_mutex_t sessionlock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP ) [static]

Protect the session list

Definition at line 240 of file chan_unistim.c.

Referenced by close_client(), create_client(), do_monitor(), reload_config(), unistim_info(), and unistimsock_read().

struct unistimsession * sessions [static]

unsigned int size_addr_from = sizeof(address_from) [static]

size of the sockaddr_in (in WSARecvFrom)

Definition at line 223 of file chan_unistim.c.

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

Definition at line 669 of file chan_unistim.c.

unsigned int tos

Definition at line 211 of file chan_unistim.c.

unsigned int tos_audio

Definition at line 212 of file chan_unistim.c.

struct ast_cli_entry unistim_cli[] [static]

Definition at line 4865 of file chan_unistim.c.

int unistim_keepalive [static]

Definition at line 207 of file chan_unistim.c.

int unistim_port [static]

Definition at line 205 of file chan_unistim.c.

ast_mutex_t unistim_reload_lock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP ) [static]

Definition at line 227 of file chan_unistim.c.

Referenced by do_monitor(), and unistim_reload().

int unistim_reloading = 0 [static]

Definition at line 226 of file chan_unistim.c.

struct ast_rtp_protocol unistim_rtp [static]

Definition at line 5556 of file chan_unistim.c.

struct ast_channel_tech unistim_tech [static]

Definition at line 698 of file chan_unistim.c.

int unistimdebug = 0 [static]

Enable verbose output. can also be set with the CLI

Definition at line 204 of file chan_unistim.c.

int unistimsock = -1 [static]

Definition at line 208 of file chan_unistim.c.

int usecnt = 0 [static]

Definition at line 229 of file chan_unistim.c.

ast_mutex_t usecnt_lock = ((ast_mutex_t) PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP ) [static]

Definition at line 228 of file chan_unistim.c.

Referenced by unistim_new().