chan_mobile.c File Reference

Bluetooth Mobile Device channel driver. More...

#include "asterisk.h"
#include <pthread.h>
#include <signal.h>
#include <bluetooth/bluetooth.h>
#include <bluetooth/hci.h>
#include <bluetooth/hci_lib.h>
#include <bluetooth/sdp.h>
#include <bluetooth/sdp_lib.h>
#include <bluetooth/rfcomm.h>
#include <bluetooth/sco.h>
#include <bluetooth/l2cap.h>
#include "asterisk/compat.h"
#include "asterisk/lock.h"
#include "asterisk/callerid.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/logger.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/options.h"
#include "asterisk/utils.h"
#include "asterisk/linkedlists.h"
#include "asterisk/cli.h"
#include "asterisk/devicestate.h"
#include "asterisk/causes.h"
#include "asterisk/dsp.h"
#include "asterisk/app.h"
#include "asterisk/manager.h"
#include "asterisk/io.h"
#include "asterisk/smoother.h"
#include "asterisk/format_cache.h"

Include dependency graph for chan_mobile.c:

Go to the source code of this file.

Data Structures
struct	adapter_pvt
struct	adapters
struct	cidinfo
struct	devices
struct	hfp_ag
	This struct holds HFP features the AG supports. More...
struct	hfp_cind
	This struct holds mappings for indications. More...
struct	hfp_hf
	This struct holds HFP features that we support. More...
struct	hfp_pvt
	This struct holds state information about the current hfp connection. More...
struct	mbl_pvt
struct	mbl_pvt::msg_queue
struct	msg_queue_entry

Macros
#define	CHANNEL_FRAME_SIZE   320
#define	DEVICE_FRAME_FORMAT   ast_format_slin
#define	DEVICE_FRAME_SIZE   48
#define	FORMAT1   "%-15.15s %-17.17s %-5.5s %-15.15s %-9.9s %-10.10s %-3.3s\n"
#define	FORMAT1   "%-17.17s %-30.30s %-6.6s %-7.7s %-4.4s\n"
#define	FORMAT2   "%-17.17s %-30.30s %-6.6s %-7.7s %d\n"
#define	HFP_AG_CONTROL   (1 << 7)
#define	HFP_AG_CW   (1 << 0)
#define	HFP_AG_ECNR   (1 << 1)
#define	HFP_AG_ERRORS   (1 << 8)
#define	HFP_AG_REJECT   (1 << 5)
#define	HFP_AG_RING   (1 << 3)
#define	HFP_AG_STATUS   (1 << 6)
#define	HFP_AG_TAG   (1 << 4)
#define	HFP_AG_VOICE   (1 << 2)
#define	HFP_CIND_BATTCHG   7
#define	HFP_CIND_CALL   2
#define	HFP_CIND_CALL_ACTIVE   1
#define	HFP_CIND_CALL_NONE   0
#define	HFP_CIND_CALLHELD   4
#define	HFP_CIND_CALLSETUP   3
#define	HFP_CIND_CALLSETUP_ALERTING   3
#define	HFP_CIND_CALLSETUP_INCOMING   1
#define	HFP_CIND_CALLSETUP_NONE   0
#define	HFP_CIND_CALLSETUP_OUTGOING   2
#define	HFP_CIND_NONE   0
#define	HFP_CIND_ROAM   6
#define	HFP_CIND_SERVICE   1
#define	HFP_CIND_SERVICE_AVAILABLE   1
#define	HFP_CIND_SERVICE_NONE   0
#define	HFP_CIND_SIGNAL   5
#define	HFP_CIND_UNKNOWN   -1
#define	HFP_HF_CID   (1 << 2)
#define	HFP_HF_CONTROL   (1 << 6)
#define	HFP_HF_CW   (1 << 1)
#define	HFP_HF_ECNR   (1 << 0)
#define	HFP_HF_STATUS   (1 << 5)
#define	HFP_HF_VOICE   (1 << 3)
#define	HFP_HF_VOLUME   (1 << 4)
#define	MBL_CONFIG   "chan_mobile.conf"
#define	MBL_CONFIG_OLD   "mobile.conf"
#define	rfcomm_read_debug(c)

Enumerations
enum	at_message_t {   AT_PARSE_ERROR = -2, AT_READ_ERROR = -1, AT_UNKNOWN = 0, AT_OK,   AT_ERROR, AT_RING, AT_BRSF, AT_CIND,   AT_CIEV, AT_CLIP, AT_CMTI, AT_CMGR,   AT_SMS_PROMPT, AT_CMS_ERROR, AT_A, AT_D,   AT_CHUP, AT_CKPD, AT_CMGS, AT_VGM,   AT_VGS, AT_VTS, AT_CMGF, AT_CNMI,   AT_CMER, AT_CIND_TEST, AT_CUSD, AT_BUSY,   AT_NO_DIALTONE, AT_NO_CARRIER, AT_ECAM }
enum	mbl_type { MBL_TYPE_PHONE, MBL_TYPE_HEADSET }

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static int	at_match_prefix (char *buf, char *prefix)
	Match the given buffer with the given prefix. More...
static const char *	at_msg2str (at_message_t msg)
	Get the string representation of the given AT message. More...
static at_message_t	at_read_full (int rsock, char *buf, size_t count)
	Read an AT message and clasify it. More...
static int	check_unloading ()
	Check if the module is unloading. More...
static void	do_alignment_detection (struct mbl_pvt *pvt, char *buf, int buflen)
static void *	do_discovery (void *data)
static void *	do_monitor_headset (void *data)
static void *	do_monitor_phone (void *data)
static void *	do_sco_listen (void *data)
	Service new and existing SCO connections. This thread accepts new sco connections and handles audio data. There is one do_sco_listen thread for each adapter. More...
static char *	handle_cli_mobile_cusd (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_mobile_rfcomm (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_mobile_search (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	handle_cli_mobile_show_devices (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int	handle_response_brsf (struct mbl_pvt *pvt, char *buf)
	Handle the BRSF response. More...
static int	handle_response_busy (struct mbl_pvt *pvt)
	Handle BUSY messages. More...
static int	handle_response_ciev (struct mbl_pvt *pvt, char *buf)
	Handle AT+CIEV messages. More...
static int	handle_response_cind (struct mbl_pvt *pvt, char *buf)
	Handle the CIND response. More...
static int	handle_response_clip (struct mbl_pvt *pvt, char *buf)
	Handle AT+CLIP messages. More...
static int	handle_response_cmgr (struct mbl_pvt *pvt, char *buf)
	Handle AT+CMGR messages. More...
static int	handle_response_cmti (struct mbl_pvt *pvt, char *buf)
	Handle AT+CMTI messages. More...
static int	handle_response_cusd (struct mbl_pvt *pvt, char *buf)
	Handle CUSD messages. More...
static int	handle_response_error (struct mbl_pvt *pvt, char *buf)
	Handle ERROR AT messages. More...
static int	handle_response_no_carrier (struct mbl_pvt *pvt, char *buf)
	Handle NO CARRIER messages. More...
static int	handle_response_no_dialtone (struct mbl_pvt *pvt, char *buf)
	Handle NO DIALTONE messages. More...
static int	handle_response_ok (struct mbl_pvt *pvt, char *buf)
	Handle OK AT messages. More...
static int	handle_response_ring (struct mbl_pvt *pvt, char *buf)
	Handle RING messages. More...
static int	handle_sms_prompt (struct mbl_pvt *pvt, char *buf)
	Send an SMS message from the queue. More...
static int	headset_send_ring (const void *data)
static int	hfp_brsf2int (struct hfp_hf *hf)
	Convert a hfp_hf struct to a BRSF int. More...
static struct hfp_ag *	hfp_int2brsf (int brsf, struct hfp_ag *ag)
	Convert a BRSF int to an hfp_ag struct. More...
static int	hfp_parse_brsf (struct hfp_pvt *hfp, const char *buf)
	Parse BRSF data. More...
static int	hfp_parse_ciev (struct hfp_pvt *hfp, char *buf, int *value)
	Parse a CIEV event. More...
static int	hfp_parse_cind (struct hfp_pvt *hfp, char *buf)
	Read the result of the AT+CIND? command. More...
static int	hfp_parse_cind_indicator (struct hfp_pvt *hfp, int group, char *indicator)
	Parse and store the given indicator. More...
static int	hfp_parse_cind_test (struct hfp_pvt *hfp, char *buf)
	Parse the result of the AT+CIND=? command. More...
static struct cidinfo	hfp_parse_clip (struct hfp_pvt *hfp, char *buf)
	Parse a CLIP event. More...
static int	hfp_parse_cmgr (struct hfp_pvt *hfp, char *buf, char **from_number, char **text)
	Parse a CMGR message. More...
static int	hfp_parse_cmti (struct hfp_pvt *hfp, char *buf)
	Parse a CMTI notification. More...
static char *	hfp_parse_cusd (struct hfp_pvt *hfp, char *buf)
	Parse a CUSD answer. More...
static int	hfp_parse_ecav (struct hfp_pvt *hfp, char *buf)
	Parse a ECAV event. More...
static int	hfp_send_ata (struct hfp_pvt *hfp)
	Send ATA. More...
static int	hfp_send_atd (struct hfp_pvt *hfp, const char *number)
	Send ATD. More...
static int	hfp_send_brsf (struct hfp_pvt *hfp, struct hfp_hf *brsf)
	Send a BRSF request. More...
static int	hfp_send_chup (struct hfp_pvt *hfp)
	Send AT+CHUP. More...
static int	hfp_send_cind (struct hfp_pvt *hfp)
	Send the CIND read command. More...
static int	hfp_send_cind_test (struct hfp_pvt *hfp)
	Send the CIND test command. More...
static int	hfp_send_clip (struct hfp_pvt *hfp, int status)
	Enable or disable calling line identification. More...
static int	hfp_send_cmer (struct hfp_pvt *hfp, int status)
	Enable or disable indicator events reporting. More...
static int	hfp_send_cmgf (struct hfp_pvt *hfp, int mode)
	Set the SMS mode. More...
static int	hfp_send_cmgr (struct hfp_pvt *hfp, int index)
	Read an SMS message. More...
static int	hfp_send_cmgs (struct hfp_pvt *hfp, const char *number)
	Start sending an SMS message. More...
static int	hfp_send_cnmi (struct hfp_pvt *hfp)
	Setup SMS new message indication. More...
static int	hfp_send_cusd (struct hfp_pvt *hfp, const char *code)
	Send CUSD. More...
static int	hfp_send_dtmf (struct hfp_pvt *hfp, char digit)
	Send a DTMF command. More...
static int	hfp_send_ecam (struct hfp_pvt *hfp)
	Enable Sony Erricson extensions / indications. More...
static int	hfp_send_sms_text (struct hfp_pvt *hfp, const char *message)
	Send the text of an SMS message. More...
static int	hfp_send_vgs (struct hfp_pvt *hfp, int value)
	Send the current speaker gain level. More...
static int	hsp_send_error (int rsock)
	Send an ERROR AT response. More...
static int	hsp_send_ok (int rsock)
	Send an OK AT response. More...
static int	hsp_send_ring (int rsock)
	Send a RING unsolicited AT response. More...
static int	hsp_send_vgm (int rsock, int gain)
	Send a microphone gain unsolicited AT response. More...
static int	hsp_send_vgs (int rsock, int gain)
	Send a speaker gain unsolicited AT response. More...
static int	load_module (void)
static int	mbl_answer (struct ast_channel *ast)
static int	mbl_ast_hangup (struct mbl_pvt *pvt)
static int	mbl_call (struct ast_channel *ast, const char *dest, int timeout)
static int	mbl_devicestate (const char *data)
static int	mbl_digit_end (struct ast_channel *ast, char digit, unsigned int duration)
static int	mbl_fixup (struct ast_channel *oldchan, struct ast_channel *newchan)
static int	mbl_hangup (struct ast_channel *ast)
static int	mbl_has_service (struct mbl_pvt *pvt)
	Check if a mobile device has service. More...
static struct adapter_pvt *	mbl_load_adapter (struct ast_config *cfg, const char *cat)
	Load an adapter from the configuration file. More...
static int	mbl_load_config (void)
static struct mbl_pvt *	mbl_load_device (struct ast_config *cfg, const char *cat)
	Load a device from the configuration file. More...
static struct ast_channel *	mbl_new (int state, struct mbl_pvt *pvt, struct cidinfo *cidinfo, const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor)
static int	mbl_queue_control (struct mbl_pvt *pvt, enum ast_control_frame_type control)
static int	mbl_queue_hangup (struct mbl_pvt *pvt)
static struct ast_frame *	mbl_read (struct ast_channel *ast)
static struct ast_channel *	mbl_request (const char *type, struct ast_format_cap *cap, const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor, const char *data, int *cause)
static int	mbl_sendsms_exec (struct ast_channel *ast, const char *data)
static int	mbl_status_exec (struct ast_channel *ast, const char *data)
static int	mbl_write (struct ast_channel *ast, struct ast_frame *frame)
static void	msg_queue_flush (struct mbl_pvt *pvt)
	Remove all itmes from the queue and free them. More...
static void	msg_queue_free_and_pop (struct mbl_pvt *pvt)
	Remove an item from the front of the queue, and free it. More...
static struct msg_queue_entry *	msg_queue_head (struct mbl_pvt *pvt)
	Get the head of a queue. More...
static struct msg_queue_entry *	msg_queue_pop (struct mbl_pvt *pvt)
	Remove an item from the front of the queue. More...
static int	msg_queue_push (struct mbl_pvt *pvt, at_message_t expect, at_message_t response_to)
	Add an item to the back of the queue. More...
static int	msg_queue_push_data (struct mbl_pvt *pvt, at_message_t expect, at_message_t response_to, void *data)
	Add an item to the back of the queue with data. More...
static int	parse_next_token (char string[], const int start, const char delim)
	Terminate current token and return an index to start of the next token. More...
static void	rfcomm_append_buf (char **buf, size_t count, size_t *in_count, char c)
	Append the given character to the given buffer and increase the in_count. More...
static int	rfcomm_connect (bdaddr_t src, bdaddr_t dst, int remote_channel)
static ssize_t	rfcomm_read (int rsock, char *buf, size_t count)
	Read one Hayes AT message from an rfcomm socket. More...
static int	rfcomm_read_and_append_char (int rsock, char **buf, size_t count, size_t *in_count, char *result, char expected)
	Read a character from the given stream and append it to the given buffer if it matches the expected character. More...
static int	rfcomm_read_and_expect_char (int rsock, char *result, char expected)
	Read a character from the given stream and check if it matches what we expected. More...
static int	rfcomm_read_cmgr (int rsock, char **buf, size_t count, size_t *in_count)
	Read the remainder of a +CMGR message. More...
static int	rfcomm_read_command (int rsock, char **buf, size_t count, size_t *in_count)
	Read the remainder of an AT command. More...
static int	rfcomm_read_result (int rsock, char **buf, size_t count, size_t *in_count)
	Read and AT result code. More...
static int	rfcomm_read_sms_prompt (int rsock, char **buf, size_t count, size_t *in_count)
	Read the remainder of an AT SMS prompt. More...
static int	rfcomm_read_until_crlf (int rsock, char **buf, size_t count, size_t *in_count)
	Read until. More...
static int	rfcomm_read_until_ok (int rsock, char **buf, size_t count, size_t *in_count)
	Read until a. More...
static int	rfcomm_wait (int rsock, int *ms)
	Wait for activity on an rfcomm socket. More...
static int	rfcomm_write (int rsock, char *buf)
	Write to an rfcomm socket. More...
static int	rfcomm_write_full (int rsock, char *buf, size_t count)
	Write to an rfcomm socket. More...
static int	sco_accept (int *id, int fd, short events, void *data)
	Accept SCO connections. This function is an ast_io callback function used to accept incoming sco audio connections. More...
static int	sco_bind (struct adapter_pvt *adapter)
	Bind an SCO listener socket for the given adapter. More...
static int	sco_connect (bdaddr_t src, bdaddr_t dst)
static int	sco_write (int s, char *buf, int len)
static sdp_session_t *	sdp_register (void)
static int	sdp_search (char *addr, int profile)
static void	set_unloading ()
	Set the unloading flag. More...
static int	start_monitor (struct mbl_pvt *pvt)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Bluetooth Mobile Device Channel Driver" , .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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DRIVER, }
static struct adapters	adapters = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }
static char *	app_mblsendsms = "MobileSendSMS"
static char *	app_mblstatus = "MobileStatus"
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct devices	devices = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }
static int	discovery_interval = 60
static pthread_t	discovery_thread = AST_PTHREADT_NULL
static struct hfp_hf	hfp_our_brsf
static struct ast_cli_entry	mbl_cli []
static struct ast_channel_tech	mbl_tech
static char *	mblsendsms_desc
static char *	mblsendsms_synopsis = "MobileSendSMS(Device,Dest,Message)"
static char *	mblstatus_desc
static char *	mblstatus_synopsis = "MobileStatus(Device,Variable)"
static sdp_session_t *	sdp_session
static ast_mutex_t	unload_mutex = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static int	unloading_flag = 0

Detailed Description

Bluetooth Mobile Device channel driver.

Author

Dave Bowerman david.nosp@m..bow.nosp@m.erman.nosp@m.@gma.nosp@m.il.co.nosp@m.m

Definition in file chan_mobile.c.

Macro Definition Documentation

CHANNEL_FRAME_SIZE

#define CHANNEL_FRAME_SIZE   320

Definition at line 83 of file chan_mobile.c.

Referenced by mbl_load_device(), and mbl_new().

DEVICE_FRAME_FORMAT

#define DEVICE_FRAME_FORMAT   ast_format_slin

Definition at line 82 of file chan_mobile.c.

Referenced by load_module(), mbl_new(), mbl_read(), and mbl_request().

DEVICE_FRAME_SIZE

#define DEVICE_FRAME_SIZE   48

Definition at line 81 of file chan_mobile.c.

Referenced by mbl_load_device(), mbl_new(), and mbl_read().

FORMAT1 [1/2]

#define FORMAT1   "%-15.15s %-17.17s %-5.5s %-15.15s %-9.9s %-10.10s %-3.3s\n"

Referenced by handle_cli_mobile_search(), and handle_cli_mobile_show_devices().

FORMAT1 [2/2]

#define FORMAT1   "%-17.17s %-30.30s %-6.6s %-7.7s %-4.4s\n"

FORMAT2

#define FORMAT2   "%-17.17s %-30.30s %-6.6s %-7.7s %d\n"

Referenced by handle_cli_mobile_search(), hash_ao2_destroy(), and rb_ao2_destroy().

HFP_AG_CONTROL

#define HFP_AG_CONTROL   (1 << 7)

Definition at line 272 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_CW

#define HFP_AG_CW   (1 << 0)

Definition at line 265 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_ECNR

#define HFP_AG_ECNR   (1 << 1)

Definition at line 266 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_ERRORS

#define HFP_AG_ERRORS   (1 << 8)

Definition at line 273 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_REJECT

#define HFP_AG_REJECT   (1 << 5)

Definition at line 270 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_RING

#define HFP_AG_RING   (1 << 3)

Definition at line 268 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_STATUS

#define HFP_AG_STATUS   (1 << 6)

Definition at line 271 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_TAG

#define HFP_AG_TAG   (1 << 4)

Definition at line 269 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_AG_VOICE

#define HFP_AG_VOICE   (1 << 2)

Definition at line 267 of file chan_mobile.c.

Referenced by hfp_int2brsf().

HFP_CIND_BATTCHG

#define HFP_CIND_BATTCHG   7

Definition at line 283 of file chan_mobile.c.

Referenced by hfp_parse_cind_test().

HFP_CIND_CALL

#define HFP_CIND_CALL   2

Definition at line 278 of file chan_mobile.c.

Referenced by handle_response_ciev(), and hfp_parse_cind_test().

HFP_CIND_CALL_ACTIVE

#define HFP_CIND_CALL_ACTIVE   1

Definition at line 287 of file chan_mobile.c.

Referenced by handle_response_ciev().

HFP_CIND_CALL_NONE

#define HFP_CIND_CALL_NONE   0

Definition at line 286 of file chan_mobile.c.

Referenced by handle_response_ciev().

HFP_CIND_CALLHELD

#define HFP_CIND_CALLHELD   4

Definition at line 280 of file chan_mobile.c.

Referenced by hfp_parse_cind_test().

HFP_CIND_CALLSETUP

#define HFP_CIND_CALLSETUP   3

Definition at line 279 of file chan_mobile.c.

Referenced by handle_response_ciev(), and hfp_parse_cind_test().

HFP_CIND_CALLSETUP_ALERTING

#define HFP_CIND_CALLSETUP_ALERTING   3

Definition at line 293 of file chan_mobile.c.

Referenced by handle_response_ciev().

HFP_CIND_CALLSETUP_INCOMING

#define HFP_CIND_CALLSETUP_INCOMING   1

Definition at line 291 of file chan_mobile.c.

Referenced by handle_response_ciev().

HFP_CIND_CALLSETUP_NONE

#define HFP_CIND_CALLSETUP_NONE   0

Definition at line 290 of file chan_mobile.c.

Referenced by handle_response_ciev().

HFP_CIND_CALLSETUP_OUTGOING

#define HFP_CIND_CALLSETUP_OUTGOING   2

Definition at line 292 of file chan_mobile.c.

Referenced by handle_response_ciev().

HFP_CIND_NONE

#define HFP_CIND_NONE   0

Definition at line 276 of file chan_mobile.c.

Referenced by handle_response_ciev(), and hfp_parse_ciev().

HFP_CIND_ROAM

#define HFP_CIND_ROAM   6

Definition at line 282 of file chan_mobile.c.

Referenced by hfp_parse_cind_test().

HFP_CIND_SERVICE

#define HFP_CIND_SERVICE   1

Definition at line 277 of file chan_mobile.c.

Referenced by hfp_parse_cind_test().

HFP_CIND_SERVICE_AVAILABLE

#define HFP_CIND_SERVICE_AVAILABLE   1

Definition at line 297 of file chan_mobile.c.

Referenced by mbl_has_service().

HFP_CIND_SERVICE_NONE

#define HFP_CIND_SERVICE_NONE   0

Definition at line 296 of file chan_mobile.c.

HFP_CIND_SIGNAL

#define HFP_CIND_SIGNAL   5

Definition at line 281 of file chan_mobile.c.

Referenced by hfp_parse_cind_test().

HFP_CIND_UNKNOWN

#define HFP_CIND_UNKNOWN   -1

Definition at line 275 of file chan_mobile.c.

Referenced by hfp_parse_cind_test().

HFP_HF_CID

#define HFP_HF_CID   (1 << 2)

Definition at line 259 of file chan_mobile.c.

Referenced by hfp_brsf2int().

HFP_HF_CONTROL

#define HFP_HF_CONTROL   (1 << 6)

Definition at line 263 of file chan_mobile.c.

Referenced by hfp_brsf2int().

HFP_HF_CW

#define HFP_HF_CW   (1 << 1)

Definition at line 258 of file chan_mobile.c.

Referenced by hfp_brsf2int().

HFP_HF_ECNR

#define HFP_HF_ECNR   (1 << 0)

Definition at line 257 of file chan_mobile.c.

Referenced by hfp_brsf2int().

HFP_HF_STATUS

#define HFP_HF_STATUS   (1 << 5)

Definition at line 262 of file chan_mobile.c.

Referenced by hfp_brsf2int().

HFP_HF_VOICE

#define HFP_HF_VOICE   (1 << 3)

Definition at line 260 of file chan_mobile.c.

Referenced by hfp_brsf2int().

HFP_HF_VOLUME

#define HFP_HF_VOLUME   (1 << 4)

Definition at line 261 of file chan_mobile.c.

Referenced by hfp_brsf2int().

MBL_CONFIG

#define MBL_CONFIG   "chan_mobile.conf"

Definition at line 78 of file chan_mobile.c.

Referenced by load_module(), and mbl_load_config().

MBL_CONFIG_OLD

#define MBL_CONFIG_OLD   "mobile.conf"

Definition at line 79 of file chan_mobile.c.

Referenced by mbl_load_config().

rfcomm_read_debug

#define rfcomm_read_debug

(

c

)

Definition at line 1501 of file chan_mobile.c.

Referenced by rfcomm_read_and_expect_char(), rfcomm_read_command(), and rfcomm_read_until_crlf().

Enumeration Type Documentation

at_message_t

enum at_message_t

Enumerator
AT_PARSE_ERROR
AT_READ_ERROR
AT_UNKNOWN
AT_OK
AT_ERROR
AT_RING
AT_BRSF
AT_CIND
AT_CIEV
AT_CLIP
AT_CMTI
AT_CMGR
AT_SMS_PROMPT
AT_CMS_ERROR
AT_A
AT_D
AT_CHUP
AT_CKPD
AT_CMGS
AT_VGM
AT_VGS
AT_VTS
AT_CMGF
AT_CNMI
AT_CMER
AT_CIND_TEST
AT_CUSD
AT_BUSY
AT_NO_DIALTONE
AT_NO_CARRIER
AT_ECAM

Definition at line 419 of file chan_mobile.c.

 {
 /* errors */
 AT_PARSE_ERROR = -2,
 AT_READ_ERROR = -1,
 AT_UNKNOWN = 0,
 /* at responses */
 AT_OK,
 AT_ERROR,
 AT_RING,
 AT_BRSF,
 AT_CIND,
 AT_CIEV,
 AT_CLIP,
 AT_CMTI,
 AT_CMGR,
 AT_SMS_PROMPT,
 AT_CMS_ERROR,
 /* at commands */
 AT_A,
 AT_D,
 AT_CHUP,
 AT_CKPD,
 AT_CMGS,
 AT_VGM,
 AT_VGS,
 AT_VTS,
 AT_CMGF,
 AT_CNMI,
 AT_CMER,
 AT_CIND_TEST,
 AT_CUSD,
 AT_BUSY,
 AT_NO_DIALTONE,
 AT_NO_CARRIER,
 AT_ECAM,
} at_message_t;

mbl_type

enum mbl_type

Enumerator
MBL_TYPE_PHONE
MBL_TYPE_HEADSET

Definition at line 94 of file chan_mobile.c.

 {
 MBL_TYPE_PHONE,
 MBL_TYPE_HEADSET
};

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 4838 of file chan_mobile.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 4838 of file chan_mobile.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 4838 of file chan_mobile.c.

at_match_prefix()

static int at_match_prefix ( char *  buf, char *  prefix  )

static

Match the given buffer with the given prefix.

Parameters

buf	the buffer to match
prefix	the prefix to match

Definition at line 2003 of file chan_mobile.c.

Referenced by at_read_full().

{
 return !strncmp(buf, prefix, strlen(prefix));
}

at_msg2str()

static const char * at_msg2str ( at_message_t  msg )

inlinestatic

Get the string representation of the given AT message.

Parameters

msg	the message to process

Returns

a string describing the given message

Definition at line 2076 of file chan_mobile.c.

References AT_A, AT_BRSF, AT_BUSY, AT_CHUP, AT_CIEV, AT_CIND, AT_CIND_TEST, AT_CKPD, AT_CLIP, AT_CMER, AT_CMGF, AT_CMGR, AT_CMGS, AT_CMS_ERROR, AT_CMTI, AT_CNMI, AT_CUSD, AT_D, AT_ECAM, AT_ERROR, AT_NO_CARRIER, AT_NO_DIALTONE, AT_OK, AT_PARSE_ERROR, AT_READ_ERROR, AT_RING, AT_SMS_PROMPT, AT_UNKNOWN, AT_VGM, AT_VGS, and AT_VTS.

Referenced by do_monitor_headset(), do_monitor_phone(), handle_response_brsf(), handle_response_cind(), handle_response_error(), and handle_response_ok().

{
 switch (msg) {
 /* errors */
 case AT_PARSE_ERROR:
 return "PARSE ERROR";
 case AT_READ_ERROR:
 return "READ ERROR";
 default:
 case AT_UNKNOWN:
 return "UNKNOWN";
 /* at responses */
 case AT_OK:
 return "OK";
 case AT_ERROR:
 return "ERROR";
 case AT_RING:
 return "RING";
 case AT_BRSF:
 return "AT+BRSF";
 case AT_CIND:
 return "AT+CIND";
 case AT_CIEV:
 return "AT+CIEV";
 case AT_CLIP:
 return "AT+CLIP";
 case AT_CMTI:
 return "AT+CMTI";
 case AT_CMGR:
 return "AT+CMGR";
 case AT_SMS_PROMPT:
 return "SMS PROMPT";
 case AT_CMS_ERROR:
 return "+CMS ERROR";
 case AT_BUSY:
 return "BUSY";
 case AT_NO_DIALTONE:
 return "NO DIALTONE";
 case AT_NO_CARRIER:
 return "NO CARRIER";
 /* at commands */
 case AT_A:
 return "ATA";
 case AT_D:
 return "ATD";
 case AT_CHUP:
 return "AT+CHUP";
 case AT_CKPD:
 return "AT+CKPD";
 case AT_CMGS:
 return "AT+CMGS";
 case AT_VGM:
 return "AT+VGM";
 case AT_VGS:
 return "AT+VGS";
 case AT_VTS:
 return "AT+VTS";
 case AT_CMGF:
 return "AT+CMGF";
 case AT_CNMI:
 return "AT+CNMI";
 case AT_CMER:
 return "AT+CMER";
 case AT_CIND_TEST:
 return "AT+CIND=?";
 case AT_CUSD:
 return "AT+CUSD";
 case AT_ECAM:
 return "AT*ECAM";
 }
}

at_read_full()

static at_message_t at_read_full ( int  rsock, char *  buf, size_t  count  )

static

Read an AT message and clasify it.

Parameters

rsock	an rfcomm socket
buf	the buffer to store the result in
count	the size of the buffer or the maximum number of characters to read

Returns

the type of message received, in addition buf will contain the message received and will be null terminated

See also

at_read()

Definition at line 2017 of file chan_mobile.c.

References AT_BRSF, AT_BUSY, AT_CIEV, AT_CIND, AT_CKPD, AT_CLIP, AT_CMGR, AT_CMS_ERROR, AT_CMTI, AT_CUSD, AT_ECAM, AT_ERROR, at_match_prefix(), AT_NO_CARRIER, AT_NO_DIALTONE, AT_OK, AT_RING, AT_SMS_PROMPT, AT_UNKNOWN, AT_VGM, AT_VGS, and rfcomm_read().

Referenced by do_monitor_headset(), and do_monitor_phone().

{
 ssize_t s;
 if ((s = rfcomm_read(rsock, buf, count - 1)) < 1)
 return s;
 buf[s] = '\0';

 if (!strcmp("OK", buf)) {
 return AT_OK;
 } else if (!strcmp("ERROR", buf)) {
 return AT_ERROR;
 } else if (!strcmp("RING", buf)) {
 return AT_RING;
 } else if (!strcmp("AT+CKPD=200", buf)) {
 return AT_CKPD;
 } else if (!strcmp("> ", buf)) {
 return AT_SMS_PROMPT;
 } else if (at_match_prefix(buf, "+CMTI:")) {
 return AT_CMTI;
 } else if (at_match_prefix(buf, "+CIEV:")) {
 return AT_CIEV;
 } else if (at_match_prefix(buf, "+BRSF:")) {
 return AT_BRSF;
 } else if (at_match_prefix(buf, "+CIND:")) {
 return AT_CIND;
 } else if (at_match_prefix(buf, "+CLIP:")) {
 return AT_CLIP;
 } else if (at_match_prefix(buf, "+CMGR:")) {
 return AT_CMGR;
 } else if (at_match_prefix(buf, "+VGM:")) {
 return AT_VGM;
 } else if (at_match_prefix(buf, "+VGS:")) {
 return AT_VGS;
 } else if (at_match_prefix(buf, "+CMS ERROR:")) {
 return AT_CMS_ERROR;
 } else if (at_match_prefix(buf, "AT+VGM=")) {
 return AT_VGM;
 } else if (at_match_prefix(buf, "AT+VGS=")) {
 return AT_VGS;
 } else if (at_match_prefix(buf, "+CUSD:")) {
 return AT_CUSD;
 } else if (at_match_prefix(buf, "BUSY")) {
 return AT_BUSY;
 } else if (at_match_prefix(buf, "NO DIALTONE")) {
 return AT_NO_DIALTONE;
 } else if (at_match_prefix(buf, "NO CARRIER")) {
 return AT_NO_CARRIER;
 } else if (at_match_prefix(buf, "*ECAV:")) {
 return AT_ECAM;
 } else {
 return AT_UNKNOWN;
 }
}

check_unloading()

static int check_unloading ( )

inlinestatic

Check if the module is unloading.

Return values

0	not unloading
1	unloading

Definition at line 4682 of file chan_mobile.c.

References ast_mutex_lock, ast_mutex_unlock, unload_mutex, and unloading_flag.

Referenced by do_discovery(), do_monitor_headset(), do_monitor_phone(), and do_sco_listen().

{
 int res;
 ast_mutex_lock(&unload_mutex);
 res = unloading_flag;
 ast_mutex_unlock(&unload_mutex);

 return res;
}

do_alignment_detection()

static void do_alignment_detection ( struct mbl_pvt *  pvt, char *  buf, int  buflen  )

static

Definition at line 1281 of file chan_mobile.c.

References a, abs, mbl_pvt::alignment_count, mbl_pvt::alignment_detection_triggered, mbl_pvt::alignment_samples, ast_debug, and mbl_pvt::do_alignment_detection.

Referenced by mbl_read().

{

 int i;
 short a, *s;
 char *p;

 if (pvt->alignment_detection_triggered) {
 for (i=buflen, p=buf+buflen-1; i>0; i--, p--)
 *p = *(p-1);
 *(p+1) = 0;
 return;
 }

 if (pvt->alignment_count < 4) {
 s = (short *)buf;
 for (i=0, a=0; i<buflen/2; i++) {
 a += *s++;
 a /= i+1;
 }
 pvt->alignment_samples[pvt->alignment_count++] = a;
 return;
 }

 ast_debug(1, "Alignment Detection result is [%-d %-d %-d %-d]\n", pvt->alignment_samples[0], pvt->alignment_samples[1], pvt->alignment_samples[2], pvt->alignment_samples[3]);

 a = abs(pvt->alignment_samples[1]) + abs(pvt->alignment_samples[2]) + abs(pvt->alignment_samples[3]);
 a /= 3;
 if (a > 100) {
 pvt->alignment_detection_triggered = 1;
 ast_debug(1, "Alignment Detection Triggered.\n");
 } else
 pvt->do_alignment_detection = 0;

}

do_discovery()

static void* do_discovery ( void *  data )

static

Definition at line 4282 of file chan_mobile.c.

References mbl_pvt::adapter, adapter_pvt::addr, mbl_pvt::addr, ast_mutex_lock, ast_mutex_unlock, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_verb, check_unloading(), mbl_pvt::connected, discovery_interval, EVENT_FLAG_SYSTEM, adapter_pvt::id, mbl_pvt::id, adapter_pvt::inuse, mbl_pvt::lock, manager_event, NULL, rfcomm_connect(), mbl_pvt::rfcomm_port, mbl_pvt::rfcomm_socket, and start_monitor().

Referenced by load_module().

{

 struct adapter_pvt *adapter;
 struct mbl_pvt *pvt;

 while (!check_unloading()) {
 AST_RWLIST_RDLOCK(&adapters);
 AST_RWLIST_TRAVERSE(&adapters, adapter, entry) {
 if (!adapter->inuse) {
 AST_RWLIST_RDLOCK(&devices);
 AST_RWLIST_TRAVERSE(&devices, pvt, entry) {
 ast_mutex_lock(&pvt->lock);
 if (!adapter->inuse && !pvt->connected && !strcmp(adapter->id, pvt->adapter->id)) {
 if ((pvt->rfcomm_socket = rfcomm_connect(adapter->addr, pvt->addr, pvt->rfcomm_port)) > -1) {
 if (start_monitor(pvt)) {
 pvt->connected = 1;
 adapter->inuse = 1;
 manager_event(EVENT_FLAG_SYSTEM, "MobileStatus", "Status: Connect\r\nDevice: %s\r\n", pvt->id);
 ast_verb(3, "Bluetooth Device %s has connected, initializing...\n", pvt->id);
 }
 }
 }
 ast_mutex_unlock(&pvt->lock);
 }
 AST_RWLIST_UNLOCK(&devices);
 }
 }
 AST_RWLIST_UNLOCK(&adapters);


 /* Go to sleep (only if we are not unloading) */
 if (!check_unloading())
 sleep(discovery_interval);
 }

 return NULL;
}

do_monitor_headset()

static void* do_monitor_headset ( void *  data )

static

Definition at line 4119 of file chan_mobile.c.

References mbl_pvt::adapter, adapter_pvt::addr, mbl_pvt::addr, mbl_pvt::answered, ast_channel_exten_set(), ast_channel_set_fd(), AST_CONTROL_ANSWER, ast_debug, ast_hangup(), ast_log, ast_mutex_lock, ast_mutex_unlock, ast_pbx_start(), ast_sched_runq(), ast_sched_wait(), AST_STATE_UP, ast_verb, AT_CKPD, at_msg2str(), at_read_full(), AT_VGM, AT_VGS, buf, check_unloading(), mbl_pvt::connected, errno, EVENT_FLAG_SYSTEM, hsp_send_error(), hsp_send_ok(), hsp_send_vgm(), hsp_send_vgs(), mbl_pvt::id, mbl_pvt::incoming, adapter_pvt::inuse, mbl_pvt::lock, LOG_ERROR, manager_event, mbl_new(), mbl_queue_control(), mbl_queue_hangup(), mbl_pvt::needring, NULL, mbl_pvt::outgoing, mbl_pvt::owner, mbl_pvt::rfcomm_socket, rfcomm_wait(), mbl_pvt::sched, sco_connect(), and mbl_pvt::sco_socket.

Referenced by start_monitor().

{

 struct mbl_pvt *pvt = (struct mbl_pvt *)data;
 char buf[256];
 int t;
 at_message_t at_msg;
 struct ast_channel *chan = NULL;

 ast_verb(3, "Bluetooth Device %s initialised and ready.\n", pvt->id);

 while (!check_unloading()) {

 t = ast_sched_wait(pvt->sched);
 if (t == -1) {
 t = 6000;
 }

 ast_sched_runq(pvt->sched);

 if (rfcomm_wait(pvt->rfcomm_socket, &t) == 0)
 continue;

 if ((at_msg = at_read_full(pvt->rfcomm_socket, buf, sizeof(buf))) < 0) {
 ast_debug(1, "[%s] error reading from device: %s (%d)\n", pvt->id, strerror(errno), errno);
 goto e_cleanup;
 }
 ast_debug(1, "[%s] %s\n", pvt->id, buf);

 switch (at_msg) {
 case AT_VGS:
 case AT_VGM:
 /* XXX volume change requested, we will just
 * pretend to do something with it */
 if (hsp_send_ok(pvt->rfcomm_socket)) {
 ast_debug(1, "[%s] error sending AT message 'OK'\n", pvt->id);
 goto e_cleanup;
 }
 break;
 case AT_CKPD:
 ast_mutex_lock(&pvt->lock);
 if (pvt->outgoing) {
 pvt->needring = 0;
 hsp_send_ok(pvt->rfcomm_socket);
 if (pvt->answered) {
 /* we have an answered call up to the
 * HS, he wants to hangup */
 mbl_queue_hangup(pvt);
 } else {
 /* we have an outgoing call to the HS,
 * he wants to answer */
 if ((pvt->sco_socket = sco_connect(pvt->adapter->addr, pvt->addr)) == -1) {
 ast_log(LOG_ERROR, "[%s] unable to create audio connection\n", pvt->id);
 mbl_queue_hangup(pvt);
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }

 ast_channel_set_fd(pvt->owner, 0, pvt->sco_socket);

 mbl_queue_control(pvt, AST_CONTROL_ANSWER);
 pvt->answered = 1;

 if (hsp_send_vgs(pvt->rfcomm_socket, 13) || hsp_send_vgm(pvt->rfcomm_socket, 13)) {
 ast_debug(1, "[%s] error sending VGS/VGM\n", pvt->id);
 mbl_queue_hangup(pvt);
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 }
 } else if (pvt->incoming) {
 /* we have an incoming call from the
 * HS, he wants to hang up */
 mbl_queue_hangup(pvt);
 } else {
 /* no call is up, HS wants to dial */
 hsp_send_ok(pvt->rfcomm_socket);

 if ((pvt->sco_socket = sco_connect(pvt->adapter->addr, pvt->addr)) == -1) {
 ast_log(LOG_ERROR, "[%s] unable to create audio connection\n", pvt->id);
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }

 pvt->incoming = 1;

 if (!(chan = mbl_new(AST_STATE_UP, pvt, NULL, NULL, NULL))) {
 ast_log(LOG_ERROR, "[%s] unable to allocate channel for incoming call\n", pvt->id);
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }

 ast_channel_set_fd(chan, 0, pvt->sco_socket);

 ast_channel_exten_set(chan, "s");
 if (ast_pbx_start(chan)) {
 ast_log(LOG_ERROR, "[%s] unable to start pbx on incoming call\n", pvt->id);
 ast_hangup(chan);
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 default:
 ast_debug(1, "[%s] received unknown AT command: %s (%s)\n", pvt->id, buf, at_msg2str(at_msg));
 if (hsp_send_error(pvt->rfcomm_socket)) {
 ast_debug(1, "[%s] error sending AT message 'ERROR'\n", pvt->id);
 goto e_cleanup;
 }
 break;
 }
 }

e_cleanup:
 ast_mutex_lock(&pvt->lock);
 if (pvt->owner) {
 ast_debug(1, "[%s] device disconnected, hanging up owner\n", pvt->id);
 mbl_queue_hangup(pvt);
 }


 close(pvt->rfcomm_socket);
 close(pvt->sco_socket);
 pvt->sco_socket = -1;

 pvt->connected = 0;

 pvt->needring = 0;
 pvt->outgoing = 0;
 pvt->incoming = 0;

 pvt->adapter->inuse = 0;
 ast_mutex_unlock(&pvt->lock);

 manager_event(EVENT_FLAG_SYSTEM, "MobileStatus", "Status: Disconnect\r\nDevice: %s\r\n", pvt->id);
 ast_verb(3, "Bluetooth Device %s has disconnected\n", pvt->id);

 return NULL;

}

do_monitor_phone()

static void* do_monitor_phone ( void *  data )

static

Definition at line 3870 of file chan_mobile.c.

References mbl_pvt::adapter, ast_debug, ast_mutex_lock, ast_mutex_unlock, ast_verb, AT_BRSF, AT_BUSY, AT_CIEV, AT_CIND, AT_CIND_TEST, AT_CLIP, AT_CMER, AT_CMGR, AT_CMS_ERROR, AT_CMTI, AT_CUSD, AT_ECAM, AT_ERROR, at_msg2str(), AT_NO_CARRIER, AT_NO_DIALTONE, AT_OK, AT_PARSE_ERROR, AT_READ_ERROR, at_read_full(), AT_RING, AT_SMS_PROMPT, AT_UNKNOWN, mbl_pvt::blackberry, buf, check_unloading(), mbl_pvt::connected, adapter_pvt::entry, errno, EVENT_FLAG_SYSTEM, msg_queue_entry::expected, handle_response_brsf(), handle_response_busy(), handle_response_ciev(), handle_response_cind(), handle_response_clip(), handle_response_cmgr(), handle_response_cmti(), handle_response_cusd(), handle_response_error(), handle_response_no_carrier(), handle_response_no_dialtone(), handle_response_ok(), handle_response_ring(), handle_sms_prompt(), mbl_pvt::hfp, hfp_parse_ecav(), hfp_send_brsf(), mbl_pvt::id, hfp_pvt::initialized, adapter_pvt::inuse, mbl_pvt::lock, manager_event, mbl_queue_hangup(), msg_queue_flush(), msg_queue_head(), msg_queue_push(), mbl_pvt::needchup, NULL, mbl_pvt::owner, hfp_pvt::owner, msg_queue_entry::response_to, mbl_pvt::rfcomm_socket, rfcomm_wait(), hfp_pvt::rsock, mbl_pvt::sco_socket, and mbl_pvt::timeout.

Referenced by start_monitor().

{
 struct mbl_pvt *pvt = (struct mbl_pvt *)data;
 struct hfp_pvt *hfp = pvt->hfp;
 char buf[350];
 int t;
 at_message_t at_msg;
 struct msg_queue_entry *entry;

 /* Note: At one point the initialization procedure was neatly contained
 * in the hfp_init() function, but that initialization method did not
 * work with non standard devices. As a result, the initialization
 * procedure is not spread throughout the event handling loop.
 */

 /* start initialization with the BRSF request */
 ast_mutex_lock(&pvt->lock);
 pvt->timeout = 10000;
 if (hfp_send_brsf(hfp, &hfp_our_brsf) || msg_queue_push(pvt, AT_BRSF, AT_BRSF)) {
 ast_debug(1, "[%s] error sending BRSF\n", hfp->owner->id);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);

 while (!check_unloading()) {
 ast_mutex_lock(&pvt->lock);
 t = pvt->timeout;
 ast_mutex_unlock(&pvt->lock);

 if (!rfcomm_wait(pvt->rfcomm_socket, &t)) {
 ast_debug(1, "[%s] timeout waiting for rfcomm data, disconnecting\n", pvt->id);
 ast_mutex_lock(&pvt->lock);
 if (!hfp->initialized) {
 if ((entry = msg_queue_head(pvt))) {
 switch (entry->response_to) {
 case AT_CIND_TEST:
 if (pvt->blackberry)
 ast_debug(1, "[%s] timeout during CIND test\n", hfp->owner->id);
 else
 ast_debug(1, "[%s] timeout during CIND test, try setting 'blackberry=yes'\n", hfp->owner->id);
 break;
 case AT_CMER:
 if (pvt->blackberry)
 ast_debug(1, "[%s] timeout after sending CMER, try setting 'blackberry=no'\n", hfp->owner->id);
 else
 ast_debug(1, "[%s] timeout after sending CMER\n", hfp->owner->id);
 break;
 default:
 ast_debug(1, "[%s] timeout while waiting for %s in response to %s\n", pvt->id, at_msg2str(entry->expected), at_msg2str(entry->response_to));
 break;
 }
 }
 }
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }

 if ((at_msg = at_read_full(hfp->rsock, buf, sizeof(buf))) < 0) {
 ast_debug(1, "[%s] error reading from device: %s (%d)\n", pvt->id, strerror(errno), errno);
 break;
 }

 ast_debug(1, "[%s] read %s\n", pvt->id, buf);

 switch (at_msg) {
 case AT_BRSF:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_brsf(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CIND:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_cind(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_OK:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_ok(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CMS_ERROR:
 case AT_ERROR:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_error(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_RING:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_ring(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CIEV:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_ciev(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CLIP:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_clip(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CMTI:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_cmti(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CMGR:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_cmgr(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_SMS_PROMPT:
 ast_mutex_lock(&pvt->lock);
 if (handle_sms_prompt(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_CUSD:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_cusd(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_BUSY:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_busy(pvt)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_NO_DIALTONE:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_no_dialtone(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_NO_CARRIER:
 ast_mutex_lock(&pvt->lock);
 if (handle_response_no_carrier(pvt, buf)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_ECAM:
 ast_mutex_lock(&pvt->lock);
 if (hfp_parse_ecav(hfp, buf) == 7) {
 if (handle_response_busy(pvt)) {
 ast_mutex_unlock(&pvt->lock);
 goto e_cleanup;
 }
 }
 ast_mutex_unlock(&pvt->lock);
 break;
 case AT_UNKNOWN:
 ast_debug(1, "[%s] ignoring unknown message: %s\n", pvt->id, buf);
 break;
 case AT_PARSE_ERROR:
 ast_debug(1, "[%s] error parsing message\n", pvt->id);
 goto e_cleanup;
 case AT_READ_ERROR:
 ast_debug(1, "[%s] error reading from device: %s (%d)\n", pvt->id, strerror(errno), errno);
 goto e_cleanup;
 default:
 break;
 }
 }

e_cleanup:

 if (!hfp->initialized)
 ast_verb(3, "Error initializing Bluetooth device %s.\n", pvt->id);

 ast_mutex_lock(&pvt->lock);
 if (pvt->owner) {
 ast_debug(1, "[%s] device disconnected, hanging up owner\n", pvt->id);
 pvt->needchup = 0;
 mbl_queue_hangup(pvt);
 }

 close(pvt->rfcomm_socket);
 close(pvt->sco_socket);
 pvt->sco_socket = -1;

 msg_queue_flush(pvt);

 pvt->connected = 0;
 hfp->initialized = 0;

 pvt->adapter->inuse = 0;
 ast_mutex_unlock(&pvt->lock);

 ast_verb(3, "Bluetooth Device %s has disconnected.\n", pvt->id);
 manager_event(EVENT_FLAG_SYSTEM, "MobileStatus", "Status: Disconnect\r\nDevice: %s\r\n", pvt->id);

 return NULL;
}

do_sco_listen()

static void * do_sco_listen ( void *  data )

static

Service new and existing SCO connections. This thread accepts new sco connections and handles audio data. There is one do_sco_listen thread for each adapter.

Definition at line 4326 of file chan_mobile.c.

References adapter_pvt::accept_io, ast_io_wait(), ast_log, check_unloading(), adapter_pvt::id, adapter_pvt::io, LOG_ERROR, and NULL.

Referenced by mbl_load_adapter().

{
 struct adapter_pvt *adapter = (struct adapter_pvt *) data;

 while (!check_unloading()) {
 /* check for new sco connections */
 if (ast_io_wait(adapter->accept_io, 0) == -1) {
 /* handle errors */
 ast_log(LOG_ERROR, "ast_io_wait() failed for adapter %s\n", adapter->id);
 break;
 }

 /* handle audio data */
 if (ast_io_wait(adapter->io, 1) == -1) {
 ast_log(LOG_ERROR, "ast_io_wait() failed for audio on adapter %s\n", adapter->id);
 break;
 }
 }

 return NULL;
}

handle_cli_mobile_cusd()

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

static

Definition at line 659 of file chan_mobile.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), ast_mutex_lock, ast_mutex_unlock, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AT_CUSD, AT_OK, buf, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, mbl_pvt::connected, ast_cli_args::fd, mbl_pvt::hfp, hfp_send_cusd(), mbl_pvt::id, mbl_pvt::lock, msg_queue_push(), NULL, and ast_cli_entry::usage.

{
 char buf[128];
 struct mbl_pvt *pvt = NULL;

 switch (cmd) {
 case CLI_INIT:
 e->command = "mobile cusd";
 e->usage =
 "Usage: mobile cusd <device ID> <command>\n"
 " Send cusd <command> to the rfcomm port on the device\n"
 " with the specified <device ID>.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

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

 AST_RWLIST_RDLOCK(&devices);
 AST_RWLIST_TRAVERSE(&devices, pvt, entry) {
 if (!strcmp(pvt->id, a->argv[2]))
 break;
 }
 AST_RWLIST_UNLOCK(&devices);

 if (!pvt) {
 ast_cli(a->fd, "Device %s not found.\n", a->argv[2]);
 goto e_return;
 }

 ast_mutex_lock(&pvt->lock);
 if (!pvt->connected) {
 ast_cli(a->fd, "Device %s not connected.\n", a->argv[2]);
 goto e_unlock_pvt;
 }

 snprintf(buf, sizeof(buf), "%s", a->argv[3]);
 if (hfp_send_cusd(pvt->hfp, buf) || msg_queue_push(pvt, AT_OK, AT_CUSD)) {
 ast_cli(a->fd, "[%s] error sending CUSD\n", pvt->id);
 goto e_unlock_pvt;
 }

e_unlock_pvt:
 ast_mutex_unlock(&pvt->lock);
e_return:
 return CLI_SUCCESS;
}

handle_cli_mobile_rfcomm()

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

static

Definition at line 611 of file chan_mobile.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), ast_mutex_lock, ast_mutex_unlock, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AT_OK, AT_UNKNOWN, buf, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, mbl_pvt::connected, ast_cli_args::fd, mbl_pvt::id, mbl_pvt::lock, msg_queue_push(), NULL, mbl_pvt::rfcomm_socket, rfcomm_write(), and ast_cli_entry::usage.

{
 char buf[128];
 struct mbl_pvt *pvt = NULL;

 switch (cmd) {
 case CLI_INIT:
 e->command = "mobile rfcomm";
 e->usage =
 "Usage: mobile rfcomm <device ID> <command>\n"
 " Send <command> to the rfcomm port on the device\n"
 " with the specified <device ID>.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

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

 AST_RWLIST_RDLOCK(&devices);
 AST_RWLIST_TRAVERSE(&devices, pvt, entry) {
 if (!strcmp(pvt->id, a->argv[2]))
 break;
 }
 AST_RWLIST_UNLOCK(&devices);

 if (!pvt) {
 ast_cli(a->fd, "Device %s not found.\n", a->argv[2]);
 goto e_return;
 }

 ast_mutex_lock(&pvt->lock);
 if (!pvt->connected) {
 ast_cli(a->fd, "Device %s not connected.\n", a->argv[2]);
 goto e_unlock_pvt;
 }

 snprintf(buf, sizeof(buf), "%s\r", a->argv[3]);
 rfcomm_write(pvt->rfcomm_socket, buf);
 msg_queue_push(pvt, AT_OK, AT_UNKNOWN);

e_unlock_pvt:
 ast_mutex_unlock(&pvt->lock);
e_return:
 return CLI_SUCCESS;
}

handle_cli_mobile_search()

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

static

Definition at line 541 of file chan_mobile.c.

References adapter_pvt::addr, ast_cli_args::argc, ast_alloca, ast_cli(), AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, adapter_pvt::dev_id, ast_cli_args::fd, FORMAT1, FORMAT2, adapter_pvt::hci_socket, adapter_pvt::inuse, len(), name, NULL, sdp_search(), and ast_cli_entry::usage.

{
 struct adapter_pvt *adapter;
 inquiry_info *ii = NULL;
 int max_rsp, num_rsp;
 int len, flags;
 int i, phport, hsport;
 char addr[19] = {0};
 char name[31] = {0};

#define FORMAT1 "%-17.17s %-30.30s %-6.6s %-7.7s %-4.4s\n"
#define FORMAT2 "%-17.17s %-30.30s %-6.6s %-7.7s %d\n"

 switch (cmd) {
 case CLI_INIT:
 e->command = "mobile search";
 e->usage =
 "Usage: mobile search\n"
 " Searches for Bluetooth Cell / Mobile devices in range.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

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

 /* find a free adapter */
 AST_RWLIST_RDLOCK(&adapters);
 AST_RWLIST_TRAVERSE(&adapters, adapter, entry) {
 if (!adapter->inuse)
 break;
 }
 AST_RWLIST_UNLOCK(&adapters);

 if (!adapter) {
 ast_cli(a->fd, "All Bluetooth adapters are in use at this time.\n");
 return CLI_SUCCESS;
 }

 len = 8;
 max_rsp = 255;
 flags = IREQ_CACHE_FLUSH;

 ii = ast_alloca(max_rsp * sizeof(inquiry_info));
 num_rsp = hci_inquiry(adapter->dev_id, len, max_rsp, NULL, &ii, flags);
 if (num_rsp > 0) {
 ast_cli(a->fd, FORMAT1, "Address", "Name", "Usable", "Type", "Port");
 for (i = 0; i < num_rsp; i++) {
 ba2str(&(ii + i)->bdaddr, addr);
 name[0] = 0x00;
 if (hci_read_remote_name(adapter->hci_socket, &(ii + i)->bdaddr, sizeof(name) - 1, name, 0) < 0)
 strcpy(name, "[unknown]");
 phport = sdp_search(addr, HANDSFREE_AGW_PROFILE_ID);
 if (!phport)
 hsport = sdp_search(addr, HEADSET_PROFILE_ID);
 else
 hsport = 0;
 ast_cli(a->fd, FORMAT2, addr, name, (phport > 0 || hsport > 0) ? "Yes" : "No",
 (phport > 0) ? "Phone" : "Headset", (phport > 0) ? phport : hsport);
 }
 } else
 ast_cli(a->fd, "No Bluetooth Cell / Mobile devices found.\n");

#undef FORMAT1
#undef FORMAT2

 return CLI_SUCCESS;
}

handle_cli_mobile_show_devices()

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

static

Definition at line 495 of file chan_mobile.c.

References mbl_pvt::adapter, mbl_pvt::addr, ast_cli_args::argc, ast_cli(), ast_mutex_lock, ast_mutex_unlock, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, mbl_pvt::connected, ast_cli_args::fd, FORMAT1, mbl_pvt::group, mbl_pvt::has_sms, adapter_pvt::id, mbl_pvt::id, mbl_pvt::incoming_sms, mbl_pvt::lock, mbl_has_service(), NULL, mbl_pvt::outgoing_sms, mbl_pvt::owner, and ast_cli_entry::usage.

{
 struct mbl_pvt *pvt;
 char bdaddr[18];
 char group[6];

#define FORMAT1 "%-15.15s %-17.17s %-5.5s %-15.15s %-9.9s %-10.10s %-3.3s\n"

 switch (cmd) {
 case CLI_INIT:
 e->command = "mobile show devices";
 e->usage =
 "Usage: mobile show devices\n"
 " Shows the state of Bluetooth Cell / Mobile devices.\n";
 return NULL;
 case CLI_GENERATE:
 return NULL;
 }

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

 ast_cli(a->fd, FORMAT1, "ID", "Address", "Group", "Adapter", "Connected", "State", "SMS");
 AST_RWLIST_RDLOCK(&devices);
 AST_RWLIST_TRAVERSE(&devices, pvt, entry) {
 ast_mutex_lock(&pvt->lock);
 ba2str(&pvt->addr, bdaddr);
 snprintf(group, sizeof(group), "%d", pvt->group);
 ast_cli(a->fd, FORMAT1,
 pvt->id,
 bdaddr,
 group,
 pvt->adapter->id,
 pvt->connected ? "Yes" : "No",
 (!pvt->connected) ? "None" : (pvt->owner) ? "Busy" : (pvt->outgoing_sms || pvt->incoming_sms) ? "SMS" : (mbl_has_service(pvt)) ? "Free" : "No Service",
 (pvt->has_sms) ? "Yes" : "No"
 );
 ast_mutex_unlock(&pvt->lock);
 }
 AST_RWLIST_UNLOCK(&devices);

#undef FORMAT1

 return CLI_SUCCESS;
}

handle_response_brsf()

static int handle_response_brsf ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle the BRSF response.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3196 of file chan_mobile.c.

References ast_debug, AT_BRSF, at_msg2str(), AT_OK, adapter_pvt::entry, msg_queue_entry::expected, mbl_pvt::hfp, hfp_parse_brsf(), mbl_pvt::id, msg_queue_free_and_pop(), msg_queue_head(), and msg_queue_push().

Referenced by do_monitor_phone().

{
 struct msg_queue_entry *entry;
 if ((entry = msg_queue_head(pvt)) && entry->expected == AT_BRSF) {
 if (hfp_parse_brsf(pvt->hfp, buf)) {
 ast_debug(1, "[%s] error parsing BRSF\n", pvt->id);
 goto e_return;
 }

 if (msg_queue_push(pvt, AT_OK, AT_BRSF)) {
 ast_debug(1, "[%s] error handling BRSF\n", pvt->id);
 goto e_return;
 }

 msg_queue_free_and_pop(pvt);
 } else if (entry) {
 ast_debug(1, "[%s] received unexpected AT message 'BRSF' when expecting %s, ignoring\n", pvt->id, at_msg2str(entry->expected));
 } else {
 ast_debug(1, "[%s] received unexpected AT message 'BRSF'\n", pvt->id);
 }

 return 0;

e_return:
 msg_queue_free_and_pop(pvt);
 return -1;
}

handle_response_busy()

static int handle_response_busy ( struct mbl_pvt *  pvt )

static

Handle BUSY messages.

Parameters

pvt	a mbl_pvt structure

Return values

0	success
-1	error

Definition at line 3831 of file chan_mobile.c.

References AST_CAUSE_USER_BUSY, AST_CONTROL_BUSY, mbl_pvt::hangupcause, mbl_queue_control(), and mbl_pvt::needchup.

Referenced by do_monitor_phone(), and handle_response_ciev().

{
 pvt->hangupcause = AST_CAUSE_USER_BUSY;
 pvt->needchup = 1;
 mbl_queue_control(pvt, AST_CONTROL_BUSY);
 return 0;
}

handle_response_ciev()

static int handle_response_ciev ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle AT+CIEV messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3559 of file chan_mobile.c.

References mbl_pvt::answered, AST_CONTROL_ANSWER, AST_CONTROL_RINGING, ast_debug, ast_log, ast_setstate(), AST_STATE_UP, ast_verb, hfp_cind::call, hfp_pvt::cind_map, hfp_pvt::cind_state, handle_response_busy(), mbl_pvt::hfp, HFP_CIND_CALL, HFP_CIND_CALL_ACTIVE, HFP_CIND_CALL_NONE, HFP_CIND_CALLSETUP, HFP_CIND_CALLSETUP_ALERTING, HFP_CIND_CALLSETUP_INCOMING, HFP_CIND_CALLSETUP_NONE, HFP_CIND_CALLSETUP_OUTGOING, HFP_CIND_NONE, hfp_parse_ciev(), mbl_pvt::id, mbl_pvt::incoming, LOG_ERROR, mbl_queue_control(), mbl_queue_hangup(), mbl_pvt::needcallerid, mbl_pvt::needchup, mbl_pvt::outgoing, mbl_pvt::owner, and hfp_pvt::sent_alerting.

Referenced by do_monitor_phone().

{
 int i;
 switch (hfp_parse_ciev(pvt->hfp, buf, &i)) {
 case HFP_CIND_CALL:
 switch (i) {
 case HFP_CIND_CALL_NONE:
 ast_debug(1, "[%s] line disconnected\n", pvt->id);
 if (pvt->owner) {
 ast_debug(1, "[%s] hanging up owner\n", pvt->id);
 if (mbl_queue_hangup(pvt)) {
 ast_log(LOG_ERROR, "[%s] error queueing hangup, disconnectiong...\n", pvt->id);
 return -1;
 }
 }
 pvt->needchup = 0;
 pvt->needcallerid = 0;
 pvt->incoming = 0;
 pvt->outgoing = 0;
 break;
 case HFP_CIND_CALL_ACTIVE:
 if (pvt->outgoing) {
 ast_debug(1, "[%s] remote end answered\n", pvt->id);
 mbl_queue_control(pvt, AST_CONTROL_ANSWER);
 } else if (pvt->incoming && pvt->answered) {
 ast_setstate(pvt->owner, AST_STATE_UP);
 } else if (pvt->incoming) {
 /* user answered from handset, disconnecting */
 ast_verb(3, "[%s] user answered bluetooth device from handset, disconnecting\n", pvt->id);
 mbl_queue_hangup(pvt);
 return -1;
 }
 break;
 }
 break;

 case HFP_CIND_CALLSETUP:
 switch (i) {
 case HFP_CIND_CALLSETUP_NONE:
 if (pvt->hfp->cind_state[pvt->hfp->cind_map.call] != HFP_CIND_CALL_ACTIVE) {
 if (pvt->owner) {
 if (pvt->hfp->sent_alerting == 1) {
 handle_response_busy(pvt);
 }
 if (mbl_queue_hangup(pvt)) {
 ast_log(LOG_ERROR, "[%s] error queueing hangup, disconnectiong...\n", pvt->id);
 return -1;
 }
 }
 pvt->needchup = 0;
 pvt->needcallerid = 0;
 pvt->incoming = 0;
 pvt->outgoing = 0;
 }
 break;
 case HFP_CIND_CALLSETUP_INCOMING:
 ast_debug(1, "[%s] incoming call, waiting for caller id\n", pvt->id);
 pvt->needcallerid = 1;
 pvt->incoming = 1;
 break;
 case HFP_CIND_CALLSETUP_OUTGOING:
 if (pvt->outgoing) {
 pvt->hfp->sent_alerting = 0;
 ast_debug(1, "[%s] outgoing call\n", pvt->id);
 } else {
 ast_verb(3, "[%s] user dialed from handset, disconnecting\n", pvt->id);
 return -1;
 }
 break;
 case HFP_CIND_CALLSETUP_ALERTING:
 if (pvt->outgoing) {
 ast_debug(1, "[%s] remote alerting\n", pvt->id);
 mbl_queue_control(pvt, AST_CONTROL_RINGING);
 pvt->hfp->sent_alerting = 1;
 }
 break;
 }
 break;
 case HFP_CIND_NONE:
 ast_debug(1, "[%s] error parsing CIND: %s\n", pvt->id, buf);
 break;
 }
 return 0;
}

handle_response_cind()

static int handle_response_cind ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle the CIND response.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3231 of file chan_mobile.c.

References ast_debug, AT_CIND, AT_CIND_TEST, at_msg2str(), AT_OK, adapter_pvt::entry, msg_queue_entry::expected, mbl_pvt::hfp, hfp_parse_cind(), hfp_parse_cind_test(), mbl_pvt::id, msg_queue_free_and_pop(), msg_queue_head(), msg_queue_push(), and msg_queue_entry::response_to.

Referenced by do_monitor_phone().

{
 struct msg_queue_entry *entry;
 if ((entry = msg_queue_head(pvt)) && entry->expected == AT_CIND) {
 switch (entry->response_to) {
 case AT_CIND_TEST:
 if (hfp_parse_cind_test(pvt->hfp, buf) || msg_queue_push(pvt, AT_OK, AT_CIND_TEST)) {
 ast_debug(1, "[%s] error performing CIND test\n", pvt->id);
 goto e_return;
 }
 break;
 case AT_CIND:
 if (hfp_parse_cind(pvt->hfp, buf) || msg_queue_push(pvt, AT_OK, AT_CIND)) {
 ast_debug(1, "[%s] error getting CIND state\n", pvt->id);
 goto e_return;
 }
 break;
 default:
 ast_debug(1, "[%s] error getting CIND state\n", pvt->id);
 goto e_return;
 }
 msg_queue_free_and_pop(pvt);
 } else if (entry) {
 ast_debug(1, "[%s] received unexpected AT message 'CIND' when expecting %s, ignoring\n", pvt->id, at_msg2str(entry->expected));
 } else {
 ast_debug(1, "[%s] received unexpected AT message 'CIND'\n", pvt->id);
 }

 return 0;

e_return:
 msg_queue_free_and_pop(pvt);
 return -1;
}

handle_response_clip()

static int handle_response_clip ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle AT+CLIP messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3651 of file chan_mobile.c.

References ast_log, ast_pbx_start(), AST_STATE_RING, AT_CHUP, AT_CLIP, AT_OK, msg_queue_entry::expected, mbl_pvt::hfp, hfp_parse_clip(), hfp_send_chup(), mbl_pvt::id, LOG_ERROR, mbl_ast_hangup(), mbl_new(), msg_queue_free_and_pop(), msg_queue_head(), msg_queue_push(), mbl_pvt::needcallerid, mbl_pvt::needchup, and NULL.

Referenced by do_monitor_phone().

{
 struct msg_queue_entry *msg;
 struct ast_channel *chan;
 struct cidinfo cidinfo;

 if ((msg = msg_queue_head(pvt)) && msg->expected == AT_CLIP) {
 msg_queue_free_and_pop(pvt);

 pvt->needcallerid = 0;
 cidinfo = hfp_parse_clip(pvt->hfp, buf);

 if (!(chan = mbl_new(AST_STATE_RING, pvt, &cidinfo, NULL, NULL))) {
 ast_log(LOG_ERROR, "[%s] unable to allocate channel for incoming call\n", pvt->id);
 hfp_send_chup(pvt->hfp);
 msg_queue_push(pvt, AT_OK, AT_CHUP);
 return -1;
 }

 /* from this point on, we need to send a chup in the event of a
 * hangup */
 pvt->needchup = 1;

 if (ast_pbx_start(chan)) {
 ast_log(LOG_ERROR, "[%s] unable to start pbx on incoming call\n", pvt->id);
 mbl_ast_hangup(pvt);
 return -1;
 }
 }

 return 0;
}

handle_response_cmgr()

static int handle_response_cmgr ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle AT+CMGR messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3735 of file chan_mobile.c.

References ast_channel_exten_set(), ast_debug, ast_log, ast_pbx_start(), AST_STATE_DOWN, AT_CMGR, msg_queue_entry::expected, mbl_pvt::hfp, hfp_parse_cmgr(), mbl_pvt::id, mbl_pvt::incoming_sms, LOG_ERROR, mbl_ast_hangup(), mbl_new(), msg_queue_free_and_pop(), msg_queue_head(), NULL, pbx_builtin_setvar_helper(), and text.

Referenced by do_monitor_phone().

{
 char *from_number = NULL, *text = NULL;
 struct ast_channel *chan;
 struct msg_queue_entry *msg;

 if ((msg = msg_queue_head(pvt)) && msg->expected == AT_CMGR) {
 msg_queue_free_and_pop(pvt);

 if (hfp_parse_cmgr(pvt->hfp, buf, &from_number, &text)) {
 ast_debug(1, "[%s] error parsing sms message, disconnecting\n", pvt->id);
 return -1;
 }

 ast_debug(1, "[%s] successfully read sms message\n", pvt->id);
 pvt->incoming_sms = 0;

 /* XXX this channel probably does not need to be associated with this pvt */
 if (!(chan = mbl_new(AST_STATE_DOWN, pvt, NULL, NULL, NULL))) {
 ast_debug(1, "[%s] error creating sms message channel, disconnecting\n", pvt->id);
 return -1;
 }

 ast_channel_exten_set(chan, "sms");
 pbx_builtin_setvar_helper(chan, "SMSSRC", from_number);
 pbx_builtin_setvar_helper(chan, "SMSTXT", text);

 if (ast_pbx_start(chan)) {
 ast_log(LOG_ERROR, "[%s] unable to start pbx on incoming sms\n", pvt->id);
 mbl_ast_hangup(pvt);
 }
 } else {
 ast_debug(1, "[%s] got unexpected +CMGR message, ignoring\n", pvt->id);
 }

 return 0;
}

handle_response_cmti()

static int handle_response_cmti ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle AT+CMTI messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3708 of file chan_mobile.c.

References ast_debug, AT_CMGR, mbl_pvt::hfp, hfp_parse_cmti(), hfp_send_cmgr(), mbl_pvt::id, mbl_pvt::incoming_sms, and msg_queue_push().

Referenced by do_monitor_phone().

{
 int index = hfp_parse_cmti(pvt->hfp, buf);
 if (index > 0) {
 ast_debug(1, "[%s] incoming sms message\n", pvt->id);

 if (hfp_send_cmgr(pvt->hfp, index)
 || msg_queue_push(pvt, AT_CMGR, AT_CMGR)) {
 ast_debug(1, "[%s] error sending CMGR to retrieve SMS message\n", pvt->id);
 return -1;
 }

 pvt->incoming_sms = 1;
 return 0;
 } else {
 ast_debug(1, "[%s] error parsing incoming sms message alert, disconnecting\n", pvt->id);
 return -1;
 }
}

handle_response_cusd()

static int handle_response_cusd ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle CUSD messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3811 of file chan_mobile.c.

References ast_verb, mbl_pvt::hfp, hfp_parse_cusd(), and mbl_pvt::id.

Referenced by do_monitor_phone().

{
 char *cusd;

 if (!(cusd = hfp_parse_cusd(pvt->hfp, buf))) {
 ast_verb(0, "[%s] error parsing CUSD: %s\n", pvt->id, buf);
 return 0;
 }

 ast_verb(0, "[%s] CUSD response: %s\n", pvt->id, cusd);

 return 0;
}

handle_response_error()

static int handle_response_error ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle ERROR AT messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3442 of file chan_mobile.c.

References AST_CONTROL_CONGESTION, ast_debug, ast_verb, AT_A, AT_BRSF, AT_CHUP, AT_CIND, AT_CIND_TEST, AT_CLIP, AT_CMER, AT_CMGF, AT_CMGR, AT_CMGS, AT_CMS_ERROR, AT_CNMI, AT_CUSD, AT_D, AT_ECAM, AT_ERROR, at_msg2str(), AT_OK, AT_SMS_PROMPT, AT_UNKNOWN, AT_VGS, AT_VTS, adapter_pvt::entry, msg_queue_entry::expected, mbl_pvt::has_sms, mbl_pvt::hfp, hfp_send_cmgf(), hfp_send_vgs(), mbl_pvt::id, mbl_pvt::incoming_sms, hfp_pvt::initialized, mbl_queue_control(), mbl_queue_hangup(), msg_queue_free_and_pop(), msg_queue_head(), msg_queue_push(), mbl_pvt::needchup, mbl_pvt::outgoing_sms, msg_queue_entry::response_to, and mbl_pvt::timeout.

Referenced by do_monitor_phone().

{
 struct msg_queue_entry *entry;
 if ((entry = msg_queue_head(pvt))
 && (entry->expected == AT_OK
 || entry->expected == AT_ERROR
 || entry->expected == AT_CMS_ERROR
 || entry->expected == AT_CMGR
 || entry->expected == AT_SMS_PROMPT)) {
 switch (entry->response_to) {

 /* initialization stuff */
 case AT_BRSF:
 ast_debug(1, "[%s] error reading BSRF\n", pvt->id);
 goto e_return;
 case AT_CIND_TEST:
 ast_debug(1, "[%s] error during CIND test\n", pvt->id);
 goto e_return;
 case AT_CIND:
 ast_debug(1, "[%s] error requesting CIND state\n", pvt->id);
 goto e_return;
 case AT_CMER:
 ast_debug(1, "[%s] error during CMER request\n", pvt->id);
 goto e_return;
 case AT_CLIP:
 ast_debug(1, "[%s] error enabling calling line indication\n", pvt->id);
 goto e_return;
 case AT_VGS:
 ast_debug(1, "[%s] volume level synchronization failed\n", pvt->id);

 /* this is not a fatal error, let's continue with initialization */

 /* set the SMS operating mode to text mode */
 if (hfp_send_cmgf(pvt->hfp, 1) || msg_queue_push(pvt, AT_OK, AT_CMGF)) {
 ast_debug(1, "[%s] error setting CMGF\n", pvt->id);
 goto e_return;
 }
 break;
 case AT_CMGF:
 pvt->has_sms = 0;
 ast_debug(1, "[%s] error setting CMGF\n", pvt->id);
 ast_debug(1, "[%s] no SMS support\n", pvt->id);
 break;
 case AT_CNMI:
 pvt->has_sms = 0;
 ast_debug(1, "[%s] error setting CNMI\n", pvt->id);
 ast_debug(1, "[%s] no SMS support\n", pvt->id);
 break;
 case AT_ECAM:
 ast_debug(1, "[%s] Mobile does not support Sony Ericsson extensions\n", pvt->id);

 /* this is not a fatal error, let's continue with the initialization */

 if (hfp_send_vgs(pvt->hfp, 15) || msg_queue_push(pvt, AT_OK, AT_VGS)) {
 ast_debug(1, "[%s] error synchronizing gain settings\n", pvt->id);
 goto e_return;
 }

 pvt->timeout = -1;
 pvt->hfp->initialized = 1;
 ast_verb(3, "Bluetooth Device %s initialized and ready.\n", pvt->id);

 break;
 /* end initialization stuff */

 case AT_A:
 ast_debug(1, "[%s] answer failed\n", pvt->id);
 mbl_queue_hangup(pvt);
 break;
 case AT_D:
 ast_debug(1, "[%s] dial failed\n", pvt->id);
 pvt->needchup = 0;
 mbl_queue_control(pvt, AST_CONTROL_CONGESTION);
 break;
 case AT_CHUP:
 ast_debug(1, "[%s] error sending hangup, disconnecting\n", pvt->id);
 goto e_return;
 case AT_CMGR:
 ast_debug(1, "[%s] error reading sms message\n", pvt->id);
 pvt->incoming_sms = 0;
 break;
 case AT_CMGS:
 ast_debug(1, "[%s] error sending sms message\n", pvt->id);
 pvt->outgoing_sms = 0;
 break;
 case AT_VTS:
 ast_debug(1, "[%s] error sending digit\n", pvt->id);
 break;
 case AT_CUSD:
 ast_verb(0, "[%s] error sending CUSD command\n", pvt->id);
 break;
 case AT_UNKNOWN:
 default:
 ast_debug(1, "[%s] received ERROR for unhandled request: %s\n", pvt->id, at_msg2str(entry->response_to));
 break;
 }
 msg_queue_free_and_pop(pvt);
 } else if (entry) {
 ast_debug(1, "[%s] received AT message 'ERROR' when expecting %s, ignoring\n", pvt->id, at_msg2str(entry->expected));
 } else {
 ast_debug(1, "[%s] received unexpected AT message 'ERROR'\n", pvt->id);
 }

 return 0;

e_return:
 msg_queue_free_and_pop(pvt);
 return -1;
}

handle_response_no_carrier()

static int handle_response_no_carrier ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle NO CARRIER messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3861 of file chan_mobile.c.

References AST_CONTROL_CONGESTION, ast_verb, mbl_pvt::id, mbl_queue_control(), and mbl_pvt::needchup.

Referenced by do_monitor_phone().

{
 ast_verb(1, "[%s] mobile reports NO CARRIER\n", pvt->id);
 pvt->needchup = 1;
 mbl_queue_control(pvt, AST_CONTROL_CONGESTION);
 return 0;
}

handle_response_no_dialtone()

static int handle_response_no_dialtone ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle NO DIALTONE messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3846 of file chan_mobile.c.

References AST_CONTROL_CONGESTION, ast_verb, mbl_pvt::id, mbl_queue_control(), and mbl_pvt::needchup.

Referenced by do_monitor_phone().

{
 ast_verb(1, "[%s] mobile reports NO DIALTONE\n", pvt->id);
 pvt->needchup = 1;
 mbl_queue_control(pvt, AST_CONTROL_CONGESTION);
 return 0;
}

handle_response_ok()

static int handle_response_ok ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle OK AT messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3273 of file chan_mobile.c.

References AST_CONTROL_PROGRESS, ast_debug, ast_verb, AT_A, AT_BRSF, AT_CHUP, AT_CIND, AT_CIND_TEST, AT_CLIP, AT_CMER, AT_CMGF, AT_CMGS, AT_CNMI, AT_CUSD, AT_D, AT_ECAM, at_msg2str(), AT_OK, AT_UNKNOWN, AT_VGS, AT_VTS, mbl_pvt::blackberry, hfp_cind::call, hfp_cind::callsetup, hfp_pvt::cind_map, hfp_pvt::cind_state, adapter_pvt::entry, msg_queue_entry::expected, mbl_pvt::has_sms, mbl_pvt::hfp, hfp_send_cind(), hfp_send_cind_test(), hfp_send_clip(), hfp_send_cmer(), hfp_send_cmgf(), hfp_send_cnmi(), hfp_send_ecam(), hfp_send_vgs(), mbl_pvt::id, hfp_pvt::initialized, mbl_queue_control(), msg_queue_free_and_pop(), msg_queue_head(), msg_queue_push(), mbl_pvt::needchup, mbl_pvt::outgoing, mbl_pvt::outgoing_sms, msg_queue_entry::response_to, hfp_cind::service, and mbl_pvt::timeout.

Referenced by do_monitor_phone().

{
 struct msg_queue_entry *entry;
 if ((entry = msg_queue_head(pvt)) && entry->expected == AT_OK) {
 switch (entry->response_to) {

 /* initialization stuff */
 case AT_BRSF:
 ast_debug(1, "[%s] BSRF sent successfully\n", pvt->id);

 /* If this is a blackberry do CMER now, otherwise
 * continue with CIND as normal. */
 if (pvt->blackberry) {
 if (hfp_send_cmer(pvt->hfp, 1) || msg_queue_push(pvt, AT_OK, AT_CMER)) {
 ast_debug(1, "[%s] error sending CMER\n", pvt->id);
 goto e_return;
 }
 } else {
 if (hfp_send_cind_test(pvt->hfp) || msg_queue_push(pvt, AT_CIND, AT_CIND_TEST)) {
 ast_debug(1, "[%s] error sending CIND test\n", pvt->id);
 goto e_return;
 }
 }
 break;
 case AT_CIND_TEST:
 ast_debug(1, "[%s] CIND test sent successfully\n", pvt->id);

 ast_debug(2, "[%s] call: %d\n", pvt->id, pvt->hfp->cind_map.call);
 ast_debug(2, "[%s] callsetup: %d\n", pvt->id, pvt->hfp->cind_map.callsetup);
 ast_debug(2, "[%s] service: %d\n", pvt->id, pvt->hfp->cind_map.service);

 if (hfp_send_cind(pvt->hfp) || msg_queue_push(pvt, AT_CIND, AT_CIND)) {
 ast_debug(1, "[%s] error requesting CIND state\n", pvt->id);
 goto e_return;
 }
 break;
 case AT_CIND:
 ast_debug(1, "[%s] CIND sent successfully\n", pvt->id);

 /* check if a call is active */
 if (pvt->hfp->cind_state[pvt->hfp->cind_map.call]) {
 ast_verb(3, "Bluetooth Device %s has a call in progress - delaying connection.\n", pvt->id);
 goto e_return;
 }

 /* If this is NOT a blackberry proceed with CMER,
 * otherwise send CLIP. */
 if (!pvt->blackberry) {
 if (hfp_send_cmer(pvt->hfp, 1) || msg_queue_push(pvt, AT_OK, AT_CMER)) {
 ast_debug(1, "[%s] error sending CMER\n", pvt->id);
 goto e_return;
 }
 } else {
 if (hfp_send_clip(pvt->hfp, 1) || msg_queue_push(pvt, AT_OK, AT_CLIP)) {
 ast_debug(1, "[%s] error enabling calling line notification\n", pvt->id);
 goto e_return;
 }
 }
 break;
 case AT_CMER:
 ast_debug(1, "[%s] CMER sent successfully\n", pvt->id);

 /* If this is a blackberry proceed with the CIND test,
 * otherwise send CLIP. */
 if (pvt->blackberry) {
 if (hfp_send_cind_test(pvt->hfp) || msg_queue_push(pvt, AT_CIND, AT_CIND_TEST)) {
 ast_debug(1, "[%s] error sending CIND test\n", pvt->id);
 goto e_return;
 }
 } else {
 if (hfp_send_clip(pvt->hfp, 1) || msg_queue_push(pvt, AT_OK, AT_CLIP)) {
 ast_debug(1, "[%s] error enabling calling line notification\n", pvt->id);
 goto e_return;
 }
 }
 break;
 case AT_CLIP:
 ast_debug(1, "[%s] caling line indication enabled\n", pvt->id);
 if (hfp_send_ecam(pvt->hfp) || msg_queue_push(pvt, AT_OK, AT_ECAM)) {
 ast_debug(1, "[%s] error enabling Sony Ericsson call monitoring extensions\n", pvt->id);
 goto e_return;
 }

 break;
 case AT_ECAM:
 ast_debug(1, "[%s] Sony Ericsson call monitoring is active on device\n", pvt->id);
 if (hfp_send_vgs(pvt->hfp, 15) || msg_queue_push(pvt, AT_OK, AT_VGS)) {
 ast_debug(1, "[%s] error synchronizing gain settings\n", pvt->id);
 goto e_return;
 }

 pvt->timeout = -1;
 pvt->hfp->initialized = 1;
 ast_verb(3, "Bluetooth Device %s initialized and ready.\n", pvt->id);

 break;
 case AT_VGS:
 ast_debug(1, "[%s] volume level synchronization successful\n", pvt->id);

 /* set the SMS operating mode to text mode */
 if (pvt->has_sms) {
 if (hfp_send_cmgf(pvt->hfp, 1) || msg_queue_push(pvt, AT_OK, AT_CMGF)) {
 ast_debug(1, "[%s] error setting CMGF\n", pvt->id);
 goto e_return;
 }
 }
 break;
 case AT_CMGF:
 ast_debug(1, "[%s] sms text mode enabled\n", pvt->id);
 /* turn on SMS new message indication */
 if (hfp_send_cnmi(pvt->hfp) || msg_queue_push(pvt, AT_OK, AT_CNMI)) {
 ast_debug(1, "[%s] error setting CNMI\n", pvt->id);
 goto e_return;
 }
 break;
 case AT_CNMI:
 ast_debug(1, "[%s] sms new message indication enabled\n", pvt->id);
 pvt->has_sms = 1;
 break;
 /* end initialization stuff */

 case AT_A:
 ast_debug(1, "[%s] answer sent successfully\n", pvt->id);
 pvt->needchup = 1;
 break;
 case AT_D:
 ast_debug(1, "[%s] dial sent successfully\n", pvt->id);
 pvt->needchup = 1;
 pvt->outgoing = 1;
 mbl_queue_control(pvt, AST_CONTROL_PROGRESS);
 break;
 case AT_CHUP:
 ast_debug(1, "[%s] successful hangup\n", pvt->id);
 break;
 case AT_CMGS:
 ast_debug(1, "[%s] successfully sent sms message\n", pvt->id);
 pvt->outgoing_sms = 0;
 break;
 case AT_VTS:
 ast_debug(1, "[%s] digit sent successfully\n", pvt->id);
 break;
 case AT_CUSD:
 ast_debug(1, "[%s] CUSD code sent successfully\n", pvt->id);
 break;
 case AT_UNKNOWN:
 default:
 ast_debug(1, "[%s] received OK for unhandled request: %s\n", pvt->id, at_msg2str(entry->response_to));
 break;
 }
 msg_queue_free_and_pop(pvt);
 } else if (entry) {
 ast_debug(1, "[%s] received AT message 'OK' when expecting %s, ignoring\n", pvt->id, at_msg2str(entry->expected));
 } else {
 ast_debug(1, "[%s] received unexpected AT message 'OK'\n", pvt->id);
 }
 return 0;

e_return:
 msg_queue_free_and_pop(pvt);
 return -1;
}

handle_response_ring()

static int handle_response_ring ( struct mbl_pvt *  pvt, char *  buf  )

static

Handle RING messages.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3691 of file chan_mobile.c.

References ast_debug, AT_CLIP, AT_UNKNOWN, mbl_pvt::id, msg_queue_push(), and mbl_pvt::needcallerid.

Referenced by do_monitor_phone().

{
 if (pvt->needcallerid) {
 ast_debug(1, "[%s] got ring while waiting for caller id\n", pvt->id);
 return msg_queue_push(pvt, AT_CLIP, AT_UNKNOWN);
 } else {
 return 0;
 }
}

handle_sms_prompt()

static int handle_sms_prompt ( struct mbl_pvt *  pvt, char *  buf  )

static

Send an SMS message from the queue.

Parameters

pvt	a mbl_pvt structure
buf	a null terminated buffer containing an AT message

Return values

0	success
-1	error

Definition at line 3780 of file chan_mobile.c.

References ast_debug, AT_CMGS, AT_OK, AT_SMS_PROMPT, msg_queue_entry::data, msg_queue_entry::expected, mbl_pvt::hfp, hfp_send_sms_text(), mbl_pvt::id, msg_queue_free_and_pop(), msg_queue_head(), and msg_queue_push().

Referenced by do_monitor_phone().

{
 struct msg_queue_entry *msg;
 if (!(msg = msg_queue_head(pvt))) {
 ast_debug(1, "[%s] error, got sms prompt with no pending sms messages\n", pvt->id);
 return 0;
 }

 if (msg->expected != AT_SMS_PROMPT) {
 ast_debug(1, "[%s] error, got sms prompt but no pending sms messages\n", pvt->id);
 return 0;
 }

 if (hfp_send_sms_text(pvt->hfp, msg->data)
 || msg_queue_push(pvt, AT_OK, AT_CMGS)) {
 msg_queue_free_and_pop(pvt);
 ast_debug(1, "[%s] error sending sms message\n", pvt->id);
 return 0;
 }

 msg_queue_free_and_pop(pvt);
 return 0;
}

headset_send_ring()

static int headset_send_ring ( const void *  data )

static

Definition at line 4102 of file chan_mobile.c.

References ast_debug, ast_mutex_lock, ast_mutex_unlock, hsp_send_ring(), mbl_pvt::id, mbl_pvt::lock, mbl_pvt::needring, and mbl_pvt::rfcomm_socket.

Referenced by mbl_call().

{
 struct mbl_pvt *pvt = (struct mbl_pvt *) data;
 ast_mutex_lock(&pvt->lock);
 if (!pvt->needring) {
 ast_mutex_unlock(&pvt->lock);
 return 0;
 }
 ast_mutex_unlock(&pvt->lock);

 if (hsp_send_ring(pvt->rfcomm_socket)) {
 ast_debug(1, "[%s] error sending RING\n", pvt->id);
 return 0;
 }
 return 1;
}

hfp_brsf2int()

static int hfp_brsf2int ( struct hfp_hf *  hf )

static

Convert a hfp_hf struct to a BRSF int.

Parameters

hf	an hfp_hf brsf object

Returns

an integer representing the given brsf struct

Definition at line 2468 of file chan_mobile.c.

References hfp_hf::cid, hfp_hf::control, hfp_hf::cw, hfp_hf::ecnr, HFP_HF_CID, HFP_HF_CONTROL, HFP_HF_CW, HFP_HF_ECNR, HFP_HF_STATUS, HFP_HF_VOICE, HFP_HF_VOLUME, hfp_hf::status, hfp_hf::voice, and hfp_hf::volume.

Referenced by hfp_send_brsf().

{
 int brsf = 0;

 brsf |= hf->ecnr ? HFP_HF_ECNR : 0;
 brsf |= hf->cw ? HFP_HF_CW : 0;
 brsf |= hf->cid ? HFP_HF_CID : 0;
 brsf |= hf->voice ? HFP_HF_VOICE : 0;
 brsf |= hf->volume ? HFP_HF_VOLUME : 0;
 brsf |= hf->status ? HFP_HF_STATUS : 0;
 brsf |= hf->control ? HFP_HF_CONTROL : 0;

 return brsf;
}

hfp_int2brsf()

static struct hfp_ag * hfp_int2brsf ( int  brsf, struct hfp_ag *  ag  )

static

Convert a BRSF int to an hfp_ag struct.

Parameters

brsf	a brsf integer
ag	a AG (hfp_ag) brsf object

Returns

a pointer to the given hfp_ag object populated with the values from the given brsf integer

Definition at line 2490 of file chan_mobile.c.

References hfp_ag::control, hfp_ag::cw, hfp_ag::ecnr, hfp_ag::errors, HFP_AG_CONTROL, HFP_AG_CW, HFP_AG_ECNR, HFP_AG_ERRORS, HFP_AG_REJECT, HFP_AG_RING, HFP_AG_STATUS, HFP_AG_TAG, HFP_AG_VOICE, hfp_ag::reject, hfp_ag::ring, hfp_ag::status, hfp_ag::tag, and hfp_ag::voice.

Referenced by hfp_parse_brsf().

{
 ag->cw = brsf & HFP_AG_CW ? 1 : 0;
 ag->ecnr = brsf & HFP_AG_ECNR ? 1 : 0;
 ag->voice = brsf & HFP_AG_VOICE ? 1 : 0;
 ag->ring = brsf & HFP_AG_RING ? 1 : 0;
 ag->tag = brsf & HFP_AG_TAG ? 1 : 0;
 ag->reject = brsf & HFP_AG_REJECT ? 1 : 0;
 ag->status = brsf & HFP_AG_STATUS ? 1 : 0;
 ag->control = brsf & HFP_AG_CONTROL ? 1 : 0;
 ag->errors = brsf & HFP_AG_ERRORS ? 1 : 0;

 return ag;
}

hfp_parse_brsf()

static int hfp_parse_brsf ( struct hfp_pvt *  hfp, const char *  buf  )

static

Parse BRSF data.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Definition at line 2724 of file chan_mobile.c.

References hfp_pvt::brsf, and hfp_int2brsf().

Referenced by handle_response_brsf().

{
 int brsf;

 if (!sscanf(buf, "+BRSF:%d", &brsf))
 return -1;

 hfp_int2brsf(brsf, &hfp->brsf);

 return 0;
}

hfp_parse_ciev()

static int hfp_parse_ciev ( struct hfp_pvt *  hfp, char *  buf, int *  value  )

static

Parse a CIEV event.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)
value	a pointer to an int to store the event value in (can be NULL)

Returns

0 on error (parse error, or unknown event) or a HFP_CIND_* value on success

Definition at line 2195 of file chan_mobile.c.

References ARRAY_LEN, ast_debug, hfp_pvt::cind_index, hfp_pvt::cind_state, HFP_CIND_NONE, mbl_pvt::id, hfp_pvt::owner, and value.

Referenced by handle_response_ciev().

{
 int i, v;
 if (!value)
 value = &v;

 if (!sscanf(buf, "+CIEV: %d,%d", &i, value)) {
 ast_debug(2, "[%s] error parsing CIEV event '%s'\n", hfp->owner->id, buf);
 return HFP_CIND_NONE;
 }

 if (i >= ARRAY_LEN(hfp->cind_state)) {
 ast_debug(2, "[%s] CIEV event index too high (%s)\n", hfp->owner->id, buf);
 return HFP_CIND_NONE;
 }

 hfp->cind_state[i] = *value;
 return hfp->cind_index[i];
}

hfp_parse_cind()

static int hfp_parse_cind ( struct hfp_pvt *  hfp, char *  buf  )

static

Read the result of the AT+CIND? command.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Note

hfp_send_cind_test() and hfp_parse_cind_test() should be called at least once before this function is called.

Definition at line 2768 of file chan_mobile.c.

References hfp_parse_cind_indicator(), indicator, NULL, and state.

Referenced by handle_response_cind().

{
 int i, state, group;
 size_t s;
 char *indicator = NULL;

 /* parse current state of all of our indicators. The list is in the
 * following format:
 * +CIND: 1,0,2,0,0,0,0
 */
 group = 0;
 state = 0;
 s = strlen(buf);
 for (i = 0; i < s; i++) {
 switch (state) {
 case 0: /* search for start of the status indicators (a space) */
 if (buf[i] == ' ') {
 group++;
 state++;
 }
 break;
 case 1: /* mark this indicator */
 indicator = &buf[i];
 state++;
 break;
 case 2: /* search for the start of the next indicator (a comma) */
 if (buf[i] == ',') {
 buf[i] = '\0';

 hfp_parse_cind_indicator(hfp, group, indicator);

 group++;
 state = 1;
 }
 break;
 }
 }

 /* store the last indicator */
 if (state == 2)
 hfp_parse_cind_indicator(hfp, group, indicator);

 return 0;
}

hfp_parse_cind_indicator()

static int hfp_parse_cind_indicator ( struct hfp_pvt *  hfp, int  group, char *  indicator  )

static

Parse and store the given indicator.

Parameters

hfp	an hfp_pvt struct
group	the indicator group
indicator	the indicator to parse

Definition at line 2742 of file chan_mobile.c.

References ARRAY_LEN, ast_debug, hfp_pvt::cind_state, and value.

Referenced by hfp_parse_cind().

{
 int value;

 /* store the current indicator */
 if (group >= ARRAY_LEN(hfp->cind_state)) {
 ast_debug(1, "ignoring CIND state '%s' for group %d, we only support up to %d indicators\n", indicator, group, (int) sizeof(hfp->cind_state));
 return -1;
 }

 if (!sscanf(indicator, "%d", &value)) {
 ast_debug(1, "error parsing CIND state '%s' for group %d\n", indicator, group);
 return -1;
 }

 hfp->cind_state[group] = value;
 return 0;
}

hfp_parse_cind_test()

static int hfp_parse_cind_test ( struct hfp_pvt *  hfp, char *  buf  )

static

Parse the result of the AT+CIND=? command.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Definition at line 2818 of file chan_mobile.c.

References ast_debug, hfp_cind::battchg, hfp_cind::call, hfp_cind::callheld, hfp_cind::callsetup, hfp_pvt::cind_index, hfp_pvt::cind_map, HFP_CIND_BATTCHG, HFP_CIND_CALL, HFP_CIND_CALLHELD, HFP_CIND_CALLSETUP, HFP_CIND_ROAM, HFP_CIND_SERVICE, HFP_CIND_SIGNAL, HFP_CIND_UNKNOWN, indicator, mbl_pvt::no_callsetup, hfp_pvt::nocallsetup, NULL, hfp_pvt::owner, hfp_cind::roam, hfp_cind::service, hfp_cind::signal, and state.

Referenced by handle_response_cind().

{
 int i, state, group;
 size_t s;
 char *indicator = NULL;

 hfp->nocallsetup = 1;

 /* parse the indications list. It is in the follwing format:
 * +CIND: ("ind1",(0-1)),("ind2",(0-5))
 */
 group = 0;
 state = 0;
 s = strlen(buf);
 for (i = 0; i < s; i++) {
 switch (state) {
 case 0: /* search for start of indicator block */
 if (buf[i] == '(') {
 group++;
 state++;
 }
 break;
 case 1: /* search for '"' in indicator block */
 if (buf[i] == '"') {
 state++;
 }
 break;
 case 2: /* mark the start of the indicator name */
 indicator = &buf[i];
 state++;
 break;
 case 3: /* look for the end of the indicator name */
 if (buf[i] == '"') {
 buf[i] = '\0';
 state++;
 }
 break;
 case 4: /* find the start of the value range */
 if (buf[i] == '(') {
 state++;
 }
 break;
 case 5: /* mark the start of the value range */
 state++;
 break;
 case 6: /* find the end of the value range */
 if (buf[i] == ')') {
 buf[i] = '\0';
 state++;
 }
 break;
 case 7: /* process the values we found */
 if (group < sizeof(hfp->cind_index)) {
 if (!strcmp(indicator, "service")) {
 hfp->cind_map.service = group;
 hfp->cind_index[group] = HFP_CIND_SERVICE;
 } else if (!strcmp(indicator, "call")) {
 hfp->cind_map.call = group;
 hfp->cind_index[group] = HFP_CIND_CALL;
 } else if (!strcmp(indicator, "callsetup")) {
 hfp->nocallsetup = 0;
 hfp->cind_map.callsetup = group;
 hfp->cind_index[group] = HFP_CIND_CALLSETUP;
 } else if (!strcmp(indicator, "call_setup")) { /* non standard call setup identifier */
 hfp->nocallsetup = 0;
 hfp->cind_map.callsetup = group;
 hfp->cind_index[group] = HFP_CIND_CALLSETUP;
 } else if (!strcmp(indicator, "callheld")) {
 hfp->cind_map.callheld = group;
 hfp->cind_index[group] = HFP_CIND_CALLHELD;
 } else if (!strcmp(indicator, "signal")) {
 hfp->cind_map.signal = group;
 hfp->cind_index[group] = HFP_CIND_SIGNAL;
 } else if (!strcmp(indicator, "roam")) {
 hfp->cind_map.roam = group;
 hfp->cind_index[group] = HFP_CIND_ROAM;
 } else if (!strcmp(indicator, "battchg")) {
 hfp->cind_map.battchg = group;
 hfp->cind_index[group] = HFP_CIND_BATTCHG;
 } else {
 hfp->cind_index[group] = HFP_CIND_UNKNOWN;
 ast_debug(2, "ignoring unknown CIND indicator '%s'\n", indicator);
 }
 } else {
 ast_debug(1, "can't store indicator %d (%s), we only support up to %d indicators", group, indicator, (int) sizeof(hfp->cind_index));
 }

 state = 0;
 break;
 }
 }

 hfp->owner->no_callsetup = hfp->nocallsetup;

 return 0;
}

hfp_parse_clip()

static struct cidinfo hfp_parse_clip ( struct hfp_pvt *  hfp, char *  buf  )

static

Parse a CLIP event.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Note

buf will be modified when the CID string is parsed

Returns

a cidinfo structure pointing to the cnam and cnum data in buf. On parse errors, either or both pointers will point to null strings

Definition at line 2224 of file chan_mobile.c.

References ARRAY_LEN, ast_debug, ast_isphonenumber(), ast_strip_quoted(), buf, cidinfo::cnam, cidinfo::cnum, NULL, and parse_next_token().

Referenced by handle_response_clip().

{
 int i;
 int tokens[6];
 char *cnamtmp;
 char delim = ' '; /* First token terminates with space */
 int invalid = 0; /* Number of invalid chars in cnam */
 struct cidinfo cidinfo = { NULL, NULL };

 /* parse clip info in the following format:
 * +CLIP: "123456789",128,...
 */
 ast_debug(3, "[%s] hfp_parse_clip is processing \"%s\"\n", hfp->owner->id, buf);
 tokens[0] = 0; /* First token starts in position 0 */
 for (i = 1; i < ARRAY_LEN(tokens); i++) {
 tokens[i] = parse_next_token(buf, tokens[i - 1], delim);
 delim = ','; /* Subsequent tokens terminate with comma */
 }
 ast_debug(3, "[%s] hfp_parse_clip found tokens: 0=%s, 1=%s, 2=%s, 3=%s, 4=%s, 5=%s\n",
 hfp->owner->id, &buf[tokens[0]], &buf[tokens[1]], &buf[tokens[2]],
 &buf[tokens[3]], &buf[tokens[4]], &buf[tokens[5]]);

 /* Clean up cnum, and make sure it is legitimate since it is untrusted. */
 cidinfo.cnum = ast_strip_quoted(&buf[tokens[1]], "\"", "\"");
 if (!ast_isphonenumber(cidinfo.cnum)) {
 ast_debug(1, "[%s] hfp_parse_clip invalid cidinfo.cnum data \"%s\" - deleting\n",
 hfp->owner->id, cidinfo.cnum);
 cidinfo.cnum = "";
 }

 /*
 * Some docs say tokens 2 and 3 including the commas are optional.
 * If absent, that would move CNAM back to token 3.
 */
 cidinfo.cnam = &buf[tokens[5]]; /* Assume it's in token 5 */
 if (buf[tokens[5]] == '\0' && buf[tokens[4]] == '\0') {
 /* Tokens 4 and 5 are empty. See if token 3 looks like CNAM (starts with ") */
 i = tokens[3];
 while (buf[i] == ' ') { /* Find the first non-blank */
 i++;
 }
 if (buf[i] == '"') {
 /* Starts with quote. Use this for CNAM. */
 cidinfo.cnam = &buf[i];
 }
 }

 /* Clean up CNAM. */
 cidinfo.cnam = ast_strip_quoted(cidinfo.cnam, "\"", "\"");
 for (cnamtmp = cidinfo.cnam; *cnamtmp != '\0'; cnamtmp++) {
 if (!strchr("ABCDEFGHIJKLMNOPQRSTUVWXYZ 0123456789-,abcdefghijklmnopqrstuvwxyz_", *cnamtmp)) {
 *cnamtmp = '_'; /* Invalid. Replace with underscore. */
 invalid++;
 }
 }
 if (invalid) {
 ast_debug(2, "[%s] hfp_parse_clip replaced %d invalid byte(s) in cnam data\n",
 hfp->owner->id, invalid);
 }
 ast_debug(2, "[%s] hfp_parse_clip returns cnum=%s and cnam=%s\n",
 hfp->owner->id, cidinfo.cnum, cidinfo.cnam);

 return cidinfo;
}

hfp_parse_cmgr()

static int hfp_parse_cmgr ( struct hfp_pvt *  hfp, char *  buf, char **  from_number, char **  text  )

static

Parse a CMGR message.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)
from_number	a pointer to a char pointer which will store the from number
text	a pointer to a char pointer which will store the message text

Note

buf will be modified when the CMGR message is parsed

Return values

-1	parse error
0	success

Definition at line 2352 of file chan_mobile.c.

References state.

Referenced by handle_response_cmgr().

{
 int i, state;
 size_t s;

 /* parse cmgr info in the following format:
 * +CMGR: <msg status>,"+123456789",...\r\n
 * <message text>
 */
 state = 0;
 s = strlen(buf);
 for (i = 0; i < s && state != 6; i++) {
 switch (state) {
 case 0: /* search for start of the number section (,) */
 if (buf[i] == ',') {
 state++;
 }
 break;
 case 1: /* find the opening quote (") */
 if (buf[i] == '"') {
 state++;
 }
 break;
 case 2: /* mark the start of the number */
 if (from_number) {
 *from_number = &buf[i];
 state++;
 }
 /* fall through */
 case 3: /* search for the end of the number (") */
 if (buf[i] == '"') {
 buf[i] = '\0';
 state++;
 }
 break;
 case 4: /* search for the start of the message text (\n) */
 if (buf[i] == '\n') {
 state++;
 }
 break;
 case 5: /* mark the start of the message text */
 if (text) {
 *text = &buf[i];
 state++;
 }
 break;
 }
 }

 if (state != 6) {
 return -1;
 }

 return 0;
}

hfp_parse_cmti()

static int hfp_parse_cmti ( struct hfp_pvt *  hfp, char *  buf  )

static

Parse a CMTI notification.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Note

buf will be modified when the CMTI message is parsed

Returns

-1 on error (parse error) or the index of the new sms message

Definition at line 2326 of file chan_mobile.c.

References ast_debug, mbl_pvt::id, and hfp_pvt::owner.

Referenced by handle_response_cmti().

{
 int index = -1;

 /* parse cmti info in the following format:
 * +CMTI: <mem>,<index>
 */
 if (!sscanf(buf, "+CMTI: %*[^,],%d", &index)) {
 ast_debug(2, "[%s] error parsing CMTI event '%s'\n", hfp->owner->id, buf);
 return -1;
 }

 return index;
}

hfp_parse_cusd()

static char * hfp_parse_cusd ( struct hfp_pvt *  hfp, char *  buf  )

static

Parse a CUSD answer.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Note

buf will be modified when the CUSD string is parsed

Returns

NULL on error (parse error) or a pointer to the cusd message information in buf

Definition at line 2416 of file chan_mobile.c.

References NULL.

Referenced by handle_response_cusd().

{
 int i, message_start, message_end;
 char *cusd;
 size_t s;

 /* parse cusd message in the following format:
 * +CUSD: 0,"100,00 EURO, valid till 01.01.2010, you are using tariff "Mega Tariff". More informations *111#."
 */
 message_start = 0;
 message_end = 0;
 s = strlen(buf);

 /* Find the start of the message (") */
 for (i = 0; i < s; i++) {
 if (buf[i] == '"') {
 message_start = i + 1;
 break;
 }
 }

 if (message_start == 0 || message_start >= s) {
 return NULL;
 }

 /* Find the end of the message (") */
 for (i = s; i > 0; i--) {
 if (buf[i] == '"') {
 message_end = i;
 break;
 }
 }

 if (message_end == 0) {
 return NULL;
 }

 if (message_start >= message_end) {
 return NULL;
 }

 cusd = &buf[message_start];
 buf[message_end] = '\0';

 return cusd;
}

hfp_parse_ecav()

static int hfp_parse_ecav ( struct hfp_pvt *  hfp, char *  buf  )

static

Parse a ECAV event.

Parameters

hfp	an hfp_pvt struct
buf	the buffer to parse (null terminated)

Returns

-1 on error (parse error) or a ECAM value on success

Example string: *ECAV: <ccid>,<ccstatus>,<calltype>[,<processid>] [,exitcause][,<number>,<type>]

Example indicating busy: *ECAV: 1,7,1

Definition at line 2164 of file chan_mobile.c.

References ast_debug, mbl_pvt::id, and hfp_pvt::owner.

Referenced by do_monitor_phone().

{
 int ccid = 0;
 int ccstatus = 0;
 int calltype = 0;

 if (!sscanf(buf, "*ECAV: %2d,%2d,%2d", &ccid, &ccstatus, &calltype)) {
 ast_debug(1, "[%s] error parsing ECAV event '%s'\n", hfp->owner->id, buf);
 return -1;
 }

 return ccstatus;
}

hfp_send_ata()

static int hfp_send_ata ( struct hfp_pvt *  hfp )

static

Send ATA.

Parameters

hfp	an hfp_pvt struct

Definition at line 2702 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by mbl_answer().

{
 return rfcomm_write(hfp->rsock, "ATA\r");
}

hfp_send_atd()

static int hfp_send_atd ( struct hfp_pvt *  hfp, const char *  number  )

static

Send ATD.

Parameters

hfp	an hfp_pvt struct
number	the number to send

Definition at line 2691 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by mbl_call().

{
 char cmd[64];
 snprintf(cmd, sizeof(cmd), "ATD%s;\r", number);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_brsf()

static int hfp_send_brsf ( struct hfp_pvt *  hfp, struct hfp_hf *  brsf  )

static

Send a BRSF request.

Parameters

hfp	an hfp_pvt struct
brsf	an hfp_hf brsf struct

Return values

0	on success
-1	on error

Definition at line 2514 of file chan_mobile.c.

References hfp_brsf2int(), rfcomm_write(), and hfp_pvt::rsock.

Referenced by do_monitor_phone().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "AT+BRSF=%d\r", hfp_brsf2int(brsf));
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_chup()

static int hfp_send_chup ( struct hfp_pvt *  hfp )

static

Send AT+CHUP.

Parameters

hfp	an hfp_pvt struct

Definition at line 2681 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_clip(), and mbl_hangup().

{
 return rfcomm_write(hfp->rsock, "AT+CHUP\r");
}

hfp_send_cind()

static int hfp_send_cind ( struct hfp_pvt *  hfp )

static

Send the CIND read command.

Parameters

hfp	an hfp_pvt struct

Definition at line 2525 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_ok().

{
 return rfcomm_write(hfp->rsock, "AT+CIND?\r");
}

hfp_send_cind_test()

static int hfp_send_cind_test ( struct hfp_pvt *  hfp )

static

Send the CIND test command.

Parameters

hfp	an hfp_pvt struct

Definition at line 2534 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_ok().

{
 return rfcomm_write(hfp->rsock, "AT+CIND=?\r");
}

hfp_send_clip()

static int hfp_send_clip ( struct hfp_pvt *  hfp, int  status  )

static

Enable or disable calling line identification.

Parameters

hfp	an hfp_pvt struct
status	enable or disable calling line identification (should be 1 or 0)

Definition at line 2583 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_ok().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "AT+CLIP=%d\r", status ? 1 : 0);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_cmer()

static int hfp_send_cmer ( struct hfp_pvt *  hfp, int  status  )

static

Enable or disable indicator events reporting.

Parameters

hfp	an hfp_pvt struct
status	enable or disable events reporting (should be 1 or 0)

Definition at line 2544 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_ok().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "AT+CMER=3,0,0,%d\r", status ? 1 : 0);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_cmgf()

static int hfp_send_cmgf ( struct hfp_pvt *  hfp, int  mode  )

static

Set the SMS mode.

Parameters

hfp	an hfp_pvt struct
mode	the sms mode (0 = PDU, 1 = Text)

Definition at line 2625 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_error(), and handle_response_ok().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "AT+CMGF=%d\r", mode);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_cmgr()

static int hfp_send_cmgr ( struct hfp_pvt *  hfp, int  index  )

static

Read an SMS message.

Parameters

hfp	an hfp_pvt struct
index	the location of the requested message

Definition at line 2646 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_cmti().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "AT+CMGR=%d\r", index);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_cmgs()

static int hfp_send_cmgs ( struct hfp_pvt *  hfp, const char *  number  )

static

Start sending an SMS message.

Parameters

hfp	an hfp_pvt struct
number	the destination of the message

Definition at line 2658 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by mbl_sendsms_exec().

{
 char cmd[64];
 snprintf(cmd, sizeof(cmd), "AT+CMGS=\"%s\"\r", number);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_cnmi()

static int hfp_send_cnmi ( struct hfp_pvt *  hfp )

static

Setup SMS new message indication.

Parameters

hfp	an hfp_pvt struct

Definition at line 2636 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_ok().

{
 return rfcomm_write(hfp->rsock, "AT+CNMI=2,1,0,0,0\r");
}

hfp_send_cusd()

static int hfp_send_cusd ( struct hfp_pvt *  hfp, const char *  code  )

static

Send CUSD.

Parameters

hfp	an hfp_pvt struct
code	the CUSD code to send

Definition at line 2712 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_cli_mobile_cusd().

{
 char cmd[128];
 snprintf(cmd, sizeof(cmd), "AT+CUSD=1,\"%s\",15\r", code);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_dtmf()

static int hfp_send_dtmf ( struct hfp_pvt *  hfp, char  digit  )

static

Send a DTMF command.

Parameters

hfp	an hfp_pvt struct
digit	the dtmf digit to send

Returns

the result of rfcomm_write() or -1 on an invalid digit being sent

Definition at line 2596 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by mbl_digit_end().

{
 char cmd[10];

 switch(digit) {
 case '0':
 case '1':
 case '2':
 case '3':
 case '4':
 case '5':
 case '6':
 case '7':
 case '8':
 case '9':
 case '*':
 case '#':
 snprintf(cmd, sizeof(cmd), "AT+VTS=%c\r", digit);
 return rfcomm_write(hfp->rsock, cmd);
 default:
 return -1;
 }
}

hfp_send_ecam()

static int hfp_send_ecam ( struct hfp_pvt *  hfp )

static

Enable Sony Erricson extensions / indications.

Parameters

hfp	an hfp_pvt struct

Definition at line 2182 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_response_ok().

{
 return rfcomm_write(hfp->rsock, "AT*ECAM=1\r");
}

hfp_send_sms_text()

static int hfp_send_sms_text ( struct hfp_pvt *  hfp, const char *  message  )

static

Send the text of an SMS message.

Parameters

hfp	an hfp_pvt struct
message	the text of the message

Definition at line 2670 of file chan_mobile.c.

References rfcomm_write(), and hfp_pvt::rsock.

Referenced by handle_sms_prompt().

{
 char cmd[162];
 snprintf(cmd, sizeof(cmd), "%.160s\x1a", message);
 return rfcomm_write(hfp->rsock, cmd);
}

hfp_send_vgs()

static int hfp_send_vgs ( struct hfp_pvt *  hfp, int  value  )

static

Send the current speaker gain level.

Parameters

hfp	an hfp_pvt struct
value	the value to send (must be between 0 and 15)

Definition at line 2556 of file chan_mobile.c.

References rfcomm_write(), hfp_pvt::rsock, and value.

Referenced by handle_response_error(), and handle_response_ok().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "AT+VGS=%d\r", value);
 return rfcomm_write(hfp->rsock, cmd);
}

hsp_send_error()

static int hsp_send_error ( int  rsock )

static

Send an ERROR AT response.

Parameters

rsock

the rfcomm socket to use

Definition at line 2933 of file chan_mobile.c.

References rfcomm_write().

Referenced by do_monitor_headset().

{
 return rfcomm_write(rsock, "\r\nERROR\r\n");
}

hsp_send_ok()

static int hsp_send_ok ( int  rsock )

static

Send an OK AT response.

Parameters

rsock

the rfcomm socket to use

Definition at line 2924 of file chan_mobile.c.

References rfcomm_write().

Referenced by do_monitor_headset().

{
 return rfcomm_write(rsock, "\r\nOK\r\n");
}

hsp_send_ring()

static int hsp_send_ring ( int  rsock )

static

Send a RING unsolicited AT response.

Parameters

rsock

the rfcomm socket to use

Definition at line 2966 of file chan_mobile.c.

References rfcomm_write().

Referenced by headset_send_ring(), and mbl_call().

{
 return rfcomm_write(rsock, "\r\nRING\r\n");
}

hsp_send_vgm()

static int hsp_send_vgm ( int  rsock, int  gain  )

static

Send a microphone gain unsolicited AT response.

Parameters

rsock	the rfcomm socket to use
gain	the microphone gain value

Definition at line 2955 of file chan_mobile.c.

References rfcomm_write().

Referenced by do_monitor_headset().

{
 char cmd[32];
 snprintf(cmd, sizeof(cmd), "\r\n+VGM=%d\r\n", gain);
 return