C027_Support - vvvv

Users » irsanjul » Code » C027_Support

vvvv

MDM.cpp@120:305e520c136e, 2019-08-06 (annotated)

Committer:: irsanjul
Date:: Tue Aug 06 12:55:22 2019 +0000
Revision:: 120:305e520c136e
Parent:: 118:c2c4b6b421c8

xxx

Who changed what in which revision?

User	Revision	Line number	New contents of line
mazgch	18:e5697801df29	1	#include "mbed.h"
mazgch	18:e5697801df29	2	#include "MDM.h"
mazgch	74:208e3e32d263	3	#ifdef TARGET_UBLOX_C027
mazgch	74:208e3e32d263	4	#include "C027_api.h"
mazgch	74:208e3e32d263	5	#endif
mazgch	85:dd8f4f0d0ca9	6	#include "MDMAPN.h"
mazgch	84:a05edb010176	7
mazgch	74:208e3e32d263	8	#define PROFILE "0" //!< this is the psd profile used
mazgch	74:208e3e32d263	9	#define MAX_SIZE 128 //!< max expected messages
mazgch	103:197fa7920ad8	10	// num sockets
mazgch	104:c64ba749a422	11	#define NUMSOCKETS (sizeof(_sockets)/sizeof(*_sockets))
mazgch	104:c64ba749a422	12	//! test if it is a socket is ok to use
mazgch	104:c64ba749a422	13	#define ISSOCKET(s) (((s) >= 0) && ((s) < NUMSOCKETS) && (_sockets[s].handle != SOCKET_ERROR))
mazgch	75:ce6e12067d0c	14	//! check for timeout
mazgch	75:ce6e12067d0c	15	#define TIMEOUT(t, ms) ((ms != TIMEOUT_BLOCKING) && (ms < t.read_ms()))
mazgch	80:34985b4d821e	16	//! registration ok check helper
mazgch	79:291df065e345	17	#define REG_OK(r) ((r == REG_HOME) \|\| (r == REG_ROAMING))
mazgch	80:34985b4d821e	18	//! registration done check helper (no need to poll further)
mazgch	79:291df065e345	19	#define REG_DONE(r) ((r == REG_HOME) \|\| (r == REG_ROAMING) \|\| (r == REG_DENIED))
mazgch	95:8282dbbe1492	20	//! helper to make sure that lock unlock pair is always balaced
mazgch	95:8282dbbe1492	21	#define LOCK() { lock()
mazgch	95:8282dbbe1492	22	//! helper to make sure that lock unlock pair is always balaced
mazgch	95:8282dbbe1492	23	#define UNLOCK() } unlock()
mazgch	79:291df065e345	24
mazgch	74:208e3e32d263	25	#ifdef MDM_DEBUG
mazgch	95:8282dbbe1492	26	#if 1 // colored terminal output using ANSI escape sequences
mazgch	95:8282dbbe1492	27	#define COL(c) "\033[" c
mazgch	95:8282dbbe1492	28	#else
mazgch	95:8282dbbe1492	29	#define COL(c)
mazgch	95:8282dbbe1492	30	#endif
mazgch	95:8282dbbe1492	31	#define DEF COL("39m")
mazgch	95:8282dbbe1492	32	#define BLA COL("30m")
mazgch	95:8282dbbe1492	33	#define RED COL("31m")
mazgch	95:8282dbbe1492	34	#define GRE COL("32m")
mazgch	95:8282dbbe1492	35	#define YEL COL("33m")
mazgch	95:8282dbbe1492	36	#define BLU COL("34m")
mazgch	95:8282dbbe1492	37	#define MAG COL("35m")
mazgch	95:8282dbbe1492	38	#define CYA COL("36m")
mazgch	95:8282dbbe1492	39	#define WHY COL("37m")
mazgch	95:8282dbbe1492	40
mazgch	74:208e3e32d263	41	void dumpAtCmd(const char* buf, int len)
mazgch	21:c4d64830bf02	42	{
mazgch	75:ce6e12067d0c	43	::printf(" %3d \"", len);
mazgch	21:c4d64830bf02	44	while (len --) {
mazgch	21:c4d64830bf02	45	char ch = *buf++;
mazgch	75:ce6e12067d0c	46	if ((ch > 0x1F) && (ch != 0x7F)) { // is printable
mazgch	75:ce6e12067d0c	47	if (ch == '%') ::printf("%%");
mazgch	75:ce6e12067d0c	48	else if (ch == '"') ::printf("\\\"");
mazgch	75:ce6e12067d0c	49	else if (ch == '\\') ::printf("\\\\");
mazgch	75:ce6e12067d0c	50	else putchar(ch);
mazgch	75:ce6e12067d0c	51	} else {
mazgch	75:ce6e12067d0c	52	if (ch == '\a') ::printf("\\a"); // BEL (0x07)
mazgch	75:ce6e12067d0c	53	else if (ch == '\b') ::printf("\\b"); // Backspace (0x08)
mazgch	75:ce6e12067d0c	54	else if (ch == '\t') ::printf("\\t"); // Horizontal Tab (0x09)
mazgch	75:ce6e12067d0c	55	else if (ch == '\n') ::printf("\\n"); // Linefeed (0x0A)
mazgch	75:ce6e12067d0c	56	else if (ch == '\v') ::printf("\\v"); // Vertical Tab (0x0B)
mazgch	75:ce6e12067d0c	57	else if (ch == '\f') ::printf("\\f"); // Formfeed (0x0C)
mazgch	75:ce6e12067d0c	58	else if (ch == '\r') ::printf("\\r"); // Carriage Return (0x0D)
mazgch	76:f7c3dd568dae	59	else ::printf("\\x%02x", (unsigned char)ch);
mazgch	75:ce6e12067d0c	60	}
mazgch	21:c4d64830bf02	61	}
mazgch	75:ce6e12067d0c	62	::printf("\"\r\n");
mazgch	21:c4d64830bf02	63	}
mazgch	74:208e3e32d263	64
mazgch	117:74e4e0109a9e	65	void MDMParser::_debugPrint(int level, const char* color, const char* format, ...)
mazgch	117:74e4e0109a9e	66	{
mazgch	117:74e4e0109a9e	67	if (_debugLevel >= level)
mazgch	117:74e4e0109a9e	68	{
mazgch	117:74e4e0109a9e	69	va_list args;
mazgch	117:74e4e0109a9e	70	va_start (args, format);
mazgch	117:74e4e0109a9e	71	if (color) ::printf(color);
mazgch	117:74e4e0109a9e	72	::vprintf(format, args);
mazgch	117:74e4e0109a9e	73	if (color) ::printf(DEF);
mazgch	117:74e4e0109a9e	74	va_end (args);
mazgch	117:74e4e0109a9e	75	}
mazgch	117:74e4e0109a9e	76	}
mazgch	117:74e4e0109a9e	77
mazgch	117:74e4e0109a9e	78	#define ERROR(...) _debugPrint(0, RED, __VA_ARGS__)
mazgch	117:74e4e0109a9e	79	#define INFO(...) _debugPrint(1, GRE, __VA_ARGS__)
mazgch	117:74e4e0109a9e	80	#define TRACE(...) _debugPrint(2, DEF, __VA_ARGS__)
mazgch	117:74e4e0109a9e	81	#define TEST(...) _debugPrint(3, CYA, __VA_ARGS__)
mazgch	74:208e3e32d263	82
mazgch	74:208e3e32d263	83	#else
mazgch	74:208e3e32d263	84
mazgch	75:ce6e12067d0c	85	#define ERROR(...) (void)0 // no tracing
mazgch	95:8282dbbe1492	86	#define TEST(...) (void)0 // no tracing
mazgch	74:208e3e32d263	87	#define INFO(...) (void)0 // no tracing
mazgch	74:208e3e32d263	88	#define TRACE(...) (void)0 // no tracing
mazgch	74:208e3e32d263	89
mazgch	31:a0bed6c1e05d	90	#endif
mazgch	21:c4d64830bf02	91
mazgch	44:9d12223b78ff	92	MDMParser* MDMParser::inst;
mazgch	44:9d12223b78ff	93
mazgch	21:c4d64830bf02	94	MDMParser::MDMParser(void)
mazgch	21:c4d64830bf02	95	{
mazgch	44:9d12223b78ff	96	inst = this;
mazgch	31:a0bed6c1e05d	97	memset(&_dev, 0, sizeof(_dev));
mazgch	31:a0bed6c1e05d	98	memset(&_net, 0, sizeof(_net));
mazgch	54:7ba8e4c218e2	99	_net.lac = 0xFFFF;
mazgch	54:7ba8e4c218e2	100	_net.ci = 0xFFFFFFFF;
mazgch	35:9275215a3a5b	101	_ip = NOIP;
mazgch	76:f7c3dd568dae	102	_init = false;
mazgch	31:a0bed6c1e05d	103	memset(_sockets, 0, sizeof(_sockets));
mazgch	104:c64ba749a422	104	for (int socket = 0; socket < NUMSOCKETS; socket ++)
mazgch	103:197fa7920ad8	105	_sockets[socket].handle = SOCKET_ERROR;
mazgch	74:208e3e32d263	106	#ifdef MDM_DEBUG
mazgch	76:f7c3dd568dae	107	_debugLevel = 1;
mazgch	74:208e3e32d263	108	_debugTime.start();
mazgch	74:208e3e32d263	109	#endif
mazgch	74:208e3e32d263	110	}
mazgch	74:208e3e32d263	111
mazgch	18:e5697801df29	112	int MDMParser::send(const char* buf, int len)
mazgch	18:e5697801df29	113	{
mazgch	74:208e3e32d263	114	#ifdef MDM_DEBUG
mazgch	74:208e3e32d263	115	if (_debugLevel >= 3) {
mazgch	75:ce6e12067d0c	116	::printf("%10.3f AT send ", _debugTime.read_ms()*0.001);
mazgch	74:208e3e32d263	117	dumpAtCmd(buf,len);
mazgch	74:208e3e32d263	118	}
mazgch	21:c4d64830bf02	119	#endif
mazgch	18:e5697801df29	120	return _send(buf, len);
mazgch	18:e5697801df29	121	}
mazgch	18:e5697801df29	122
mazgch	21:c4d64830bf02	123	int MDMParser::sendFormated(const char* format, ...) {
mazgch	21:c4d64830bf02	124	char buf[MAX_SIZE];
mazgch	21:c4d64830bf02	125	va_list args;
mazgch	21:c4d64830bf02	126	va_start(args, format);
mazgch	21:c4d64830bf02	127	int len = vsnprintf(buf,sizeof(buf), format, args);
mazgch	21:c4d64830bf02	128	va_end(args);
mazgch	21:c4d64830bf02	129	return send(buf, len);
mazgch	21:c4d64830bf02	130	}
mazgch	21:c4d64830bf02	131
mazgch	26:07be5faf8925	132	int MDMParser::waitFinalResp(_CALLBACKPTR cb /* = NULL*/,
mazgch	26:07be5faf8925	133	void* param /* = NULL*/,
mazgch	26:07be5faf8925	134	int timeout_ms /= 5000/)
mazgch	26:07be5faf8925	135	{
mazgch	69:4d6fa520dfca	136	char buf[MAX_SIZE + 64 /* add some more space for framing */];
mazgch	21:c4d64830bf02	137	Timer timer;
mazgch	21:c4d64830bf02	138	timer.start();
mazgch	21:c4d64830bf02	139	do {
mazgch	21:c4d64830bf02	140	int ret = getLine(buf, sizeof(buf));
mazgch	74:208e3e32d263	141	#ifdef MDM_DEBUG
mazgch	74:208e3e32d263	142	if ((_debugLevel >= 3) && (ret != WAIT) && (ret != NOT_FOUND))
mazgch	21:c4d64830bf02	143	{
mazgch	31:a0bed6c1e05d	144	int len = LENGTH(ret);
mazgch	31:a0bed6c1e05d	145	int type = TYPE(ret);
mazgch	95:8282dbbe1492	146	const char* s = (type == TYPE_UNKNOWN)? YEL "UNK" DEF :
mazgch	95:8282dbbe1492	147	(type == TYPE_TEXT) ? MAG "TXT" DEF :
mazgch	95:8282dbbe1492	148	(type == TYPE_OK ) ? GRE "OK " DEF :
mazgch	95:8282dbbe1492	149	(type == TYPE_ERROR) ? RED "ERR" DEF :
mazgch	95:8282dbbe1492	150	(type == TYPE_PLUS) ? CYA " + " DEF :
mazgch	95:8282dbbe1492	151	(type == TYPE_PROMPT) ? BLU " > " DEF :
mazgch	95:8282dbbe1492	152	"..." ;
mazgch	75:ce6e12067d0c	153	::printf("%10.3f AT read %s", _debugTime.read_ms()*0.001, s);
mazgch	74:208e3e32d263	154	dumpAtCmd(buf, len);
mazgch	21:c4d64830bf02	155	}
mazgch	21:c4d64830bf02	156	#endif
mazgch	21:c4d64830bf02	157	if ((ret != WAIT) && (ret != NOT_FOUND))
mazgch	18:e5697801df29	158	{
mazgch	21:c4d64830bf02	159	int type = TYPE(ret);
mazgch	21:c4d64830bf02	160	// handle unsolicited commands here
mazgch	21:c4d64830bf02	161	if (type == TYPE_PLUS) {
mazgch	21:c4d64830bf02	162	const char* cmd = buf+3;
mazgch	54:7ba8e4c218e2	163	int a, b, c, d, r;
mazgch	23:05a1aeeb5fd9	164	char s[32];
mazgch	21:c4d64830bf02	165
mazgch	31:a0bed6c1e05d	166	// SMS Command ---------------------------------
mazgch	31:a0bed6c1e05d	167	// +CNMI: <mem>,<index>
mazgch	31:a0bed6c1e05d	168	if (sscanf(cmd, "CMTI: \"%*[^\"]\",%d", &a) == 1) {
mazgch	31:a0bed6c1e05d	169	TRACE("New SMS at index %d\r\n", a);
mazgch	21:c4d64830bf02	170	// Socket Specific Command ---------------------------------
mazgch	21:c4d64830bf02	171	// +UUSORD: <socket>,<length>
mazgch	103:197fa7920ad8	172	} else if ((sscanf(cmd, "UUSORD: %d,%d", &a, &b) == 2)) {
mazgch	103:197fa7920ad8	173	int socket = _findSocket(a);
mazgch	103:197fa7920ad8	174	TRACE("Socket %d: handle %d has %d bytes pending\r\n", socket, a, b);
mazgch	103:197fa7920ad8	175	if (socket != SOCKET_ERROR)
mazgch	103:197fa7920ad8	176	_sockets[socket].pending = b;
mazgch	69:4d6fa520dfca	177	// +UUSORF: <socket>,<length>
mazgch	103:197fa7920ad8	178	} else if ((sscanf(cmd, "UUSORF: %d,%d", &a, &b) == 2)) {
mazgch	103:197fa7920ad8	179	int socket = _findSocket(a);
mazgch	103:197fa7920ad8	180	TRACE("Socket %d: handle %d has %d bytes pending\r\n", socket, a, b);
mazgch	103:197fa7920ad8	181	if (socket != SOCKET_ERROR)
mazgch	103:197fa7920ad8	182	_sockets[socket].pending = b;
mazgch	21:c4d64830bf02	183	// +UUSOCL: <socket>
mazgch	103:197fa7920ad8	184	} else if ((sscanf(cmd, "UUSOCL: %d", &a) == 1)) {
mazgch	103:197fa7920ad8	185	int socket = _findSocket(a);
mazgch	103:197fa7920ad8	186	TRACE("Socket %d: handle %d closed by remote host\r\n", socket, a);
mazgch	103:197fa7920ad8	187	if ((socket != SOCKET_ERROR) && _sockets[socket].connected)
mazgch	103:197fa7920ad8	188	_sockets[socket].connected = false;
mazgch	103:197fa7920ad8	189	}
mazgch	32:8f12ac182bbb	190	if (_dev.dev == DEV_LISA_C200) {
mazgch	21:c4d64830bf02	191	// CDMA Specific -------------------------------------------
mazgch	21:c4d64830bf02	192	// +CREG: <n><SID>,<NID>,<stat>
mazgch	54:7ba8e4c218e2	193	if (sscanf(cmd, "CREG: %*d,%d,%d,%d",&a,&b,&c) == 3) {
mazgch	54:7ba8e4c218e2	194	// _net.sid = a;
mazgch	54:7ba8e4c218e2	195	// _net.nid = b;
mazgch	79:291df065e345	196	if (c == 0) _net.csd = REG_NONE; // not registered, home network
mazgch	79:291df065e345	197	else if (c == 1) _net.csd = REG_HOME; // registered, home network
mazgch	79:291df065e345	198	else if (c == 2) _net.csd = REG_NONE; // not registered, but MT is currently searching a new operator to register to
mazgch	79:291df065e345	199	else if (c == 3) _net.csd = REG_DENIED; // registration denied
mazgch	79:291df065e345	200	else if (c == 5) _net.csd = REG_ROAMING; // registered, roaming
mazgch	79:291df065e345	201	_net.psd = _net.csd; // fake PSD registration (CDMA is always registered)
mazgch	31:a0bed6c1e05d	202	_net.act = ACT_CDMA;
mazgch	84:a05edb010176	203	// +CSS: <mode>[,<format>,<oper>[,<AcT>]]
mazgch	21:c4d64830bf02	204	} else if (sscanf(cmd, "CSS %c,%2s,%d",s) == 1) {
mazgch	31:a0bed6c1e05d	205	//_net.reg = (strcmp("Z", s) == 0) ? REG_UNKNOWN : REG_HOME;
mazgch	21:c4d64830bf02	206	}
mazgch	21:c4d64830bf02	207	} else {
mazgch	21:c4d64830bf02	208	// GSM/UMTS Specific -------------------------------------------
mazgch	79:291df065e345	209	// +UUPSDD: <profile_id>
mazgch	79:291df065e345	210	if (sscanf(cmd, "UUPSDD: %d",&a) == 1) {
mazgch	79:291df065e345	211	if (*PROFILE == a) _ip = NOIP;
mazgch	79:291df065e345	212	} else {
mazgch	79:291df065e345	213	// +CREG\|CGREG: <n>,<stat>[,<lac>,<ci>[,AcT[,<rac>]]] // reply to AT+CREG\|AT+CGREG
mazgch	79:291df065e345	214	// +CREG\|CGREG: <stat>[,<lac>,<ci>[,AcT[,<rac>]]] // URC
mazgch	79:291df065e345	215	b = 0xFFFF; c = 0xFFFFFFFF; d = -1;
mazgch	79:291df065e345	216	r = sscanf(cmd, "%s %*d,%d,\"%X\",\"%X\",%d",s,&a,&b,&c,&d);
mazgch	79:291df065e345	217	if (r <= 1)
mazgch	79:291df065e345	218	r = sscanf(cmd, "%s %d,\"%X\",\"%X\",%d",s,&a,&b,&c,&d);
mazgch	79:291df065e345	219	if (r >= 2) {
mazgch	79:291df065e345	220	Reg *reg = !strcmp(s, "CREG:") ? &_net.csd :
mazgch	79:291df065e345	221	!strcmp(s, "CGREG:") ? &_net.psd : NULL;
mazgch	79:291df065e345	222	if (reg) {
mazgch	79:291df065e345	223	// network status
mazgch	79:291df065e345	224	if (a == 0) *reg = REG_NONE; // 0: not registered, home network
mazgch	79:291df065e345	225	else if (a == 1) *reg = REG_HOME; // 1: registered, home network
mazgch	79:291df065e345	226	else if (a == 2) *reg = REG_NONE; // 2: not registered, but MT is currently searching a new operator to register to
mazgch	79:291df065e345	227	else if (a == 3) *reg = REG_DENIED; // 3: registration denied
mazgch	79:291df065e345	228	else if (a == 4) *reg = REG_UNKNOWN; // 4: unknown
mazgch	79:291df065e345	229	else if (a == 5) *reg = REG_ROAMING; // 5: registered, roaming
mazgch	79:291df065e345	230	if ((r >= 3) && (b != 0xFFFF)) _net.lac = b; // location area code
mazgch	79:291df065e345	231	if ((r >= 4) && (c != 0xFFFFFFFF)) _net.ci = c; // cell ID
mazgch	79:291df065e345	232	// access technology
mazgch	79:291df065e345	233	if (r >= 5) {
mazgch	79:291df065e345	234	if (d == 0) _net.act = ACT_GSM; // 0: GSM
mazgch	79:291df065e345	235	else if (d == 1) _net.act = ACT_GSM; // 1: GSM COMPACT
mazgch	79:291df065e345	236	else if (d == 2) _net.act = ACT_UTRAN; // 2: UTRAN
mazgch	79:291df065e345	237	else if (d == 3) _net.act = ACT_EDGE; // 3: GSM with EDGE availability
mazgch	79:291df065e345	238	else if (d == 4) _net.act = ACT_UTRAN; // 4: UTRAN with HSDPA availability
mazgch	79:291df065e345	239	else if (d == 5) _net.act = ACT_UTRAN; // 5: UTRAN with HSUPA availability
mazgch	79:291df065e345	240	else if (d == 6) _net.act = ACT_UTRAN; // 6: UTRAN with HSDPA and HSUPA availability
mazgch	79:291df065e345	241	}
mazgch	79:291df065e345	242	}
mazgch	54:7ba8e4c218e2	243	}
mazgch	21:c4d64830bf02	244	}
mazgch	21:c4d64830bf02	245	}
mazgch	21:c4d64830bf02	246	}
mazgch	21:c4d64830bf02	247	if (cb) {
mazgch	21:c4d64830bf02	248	int len = LENGTH(ret);
mazgch	21:c4d64830bf02	249	int ret = cb(type, buf, len, param);
mazgch	21:c4d64830bf02	250	if (WAIT != ret)
mazgch	21:c4d64830bf02	251	return ret;
mazgch	21:c4d64830bf02	252	}
mazgch	95:8282dbbe1492	253	if (type == TYPE_OK)
mazgch	95:8282dbbe1492	254	return RESP_OK;
mazgch	95:8282dbbe1492	255	if (type == TYPE_ERROR)
mazgch	95:8282dbbe1492	256	return RESP_ERROR;
mazgch	95:8282dbbe1492	257	if (type == TYPE_PROMPT)
mazgch	95:8282dbbe1492	258	return RESP_PROMPT;
mazgch	21:c4d64830bf02	259	}
mazgch	21:c4d64830bf02	260	// relax a bit
mazgch	95:8282dbbe1492	261	wait_ms(10);
mazgch	21:c4d64830bf02	262	}
mazgch	75:ce6e12067d0c	263	while (!TIMEOUT(timer, timeout_ms));
mazgch	21:c4d64830bf02	264	return WAIT;
mazgch	21:c4d64830bf02	265	}
mazgch	21:c4d64830bf02	266
mazgch	31:a0bed6c1e05d	267	int MDMParser::_cbString(int type, const char* buf, int len, char* str)
mazgch	21:c4d64830bf02	268	{
mazgch	37:cc3433329d66	269	if (str && (type == TYPE_UNKNOWN)) {
mazgch	31:a0bed6c1e05d	270	if (sscanf(buf, "\r\n%s\r\n", str) == 1)
mazgch	31:a0bed6c1e05d	271	/nothing/;
mazgch	21:c4d64830bf02	272	}
mazgch	21:c4d64830bf02	273	return WAIT;
mazgch	21:c4d64830bf02	274	}
mazgch	21:c4d64830bf02	275
mazgch	31:a0bed6c1e05d	276	int MDMParser::_cbInt(int type, const char* buf, int len, int* val)
mazgch	31:a0bed6c1e05d	277	{
mazgch	37:cc3433329d66	278	if (val && (type == TYPE_UNKNOWN)) {
mazgch	31:a0bed6c1e05d	279	if (sscanf(buf, "\r\n%d\r\n", val) == 1)
mazgch	31:a0bed6c1e05d	280	/nothing/;
mazgch	31:a0bed6c1e05d	281	}
mazgch	31:a0bed6c1e05d	282	return WAIT;
mazgch	31:a0bed6c1e05d	283	}
mazgch	31:a0bed6c1e05d	284
mazgch	31:a0bed6c1e05d	285	// ----------------------------------------------------------------
mazgch	31:a0bed6c1e05d	286
mazgch	57:869bd35f44cc	287	bool MDMParser::connect(
mazgch	57:869bd35f44cc	288	const char* simpin,
mazgch	80:34985b4d821e	289	const char* apn, const char* username,
mazgch	80:34985b4d821e	290	const char* password, Auth auth,
mazgch	74:208e3e32d263	291	PinName pn)
mazgch	57:869bd35f44cc	292	{
mazgch	75:ce6e12067d0c	293	bool ok = init(simpin, NULL, pn);
mazgch	74:208e3e32d263	294	#ifdef MDM_DEBUG
mazgch	75:ce6e12067d0c	295	if (_debugLevel >= 1) dumpDevStatus(&_dev);
mazgch	74:208e3e32d263	296	#endif
mazgch	75:ce6e12067d0c	297	if (!ok)
mazgch	57:869bd35f44cc	298	return false;
mazgch	75:ce6e12067d0c	299	ok = registerNet();
mazgch	74:208e3e32d263	300	#ifdef MDM_DEBUG
mazgch	75:ce6e12067d0c	301	if (_debugLevel >= 1) dumpNetStatus(&_net);
mazgch	74:208e3e32d263	302	#endif
mazgch	75:ce6e12067d0c	303	if (!ok)
mazgch	57:869bd35f44cc	304	return false;
mazgch	80:34985b4d821e	305	IP ip = join(apn,username,password,auth);
mazgch	74:208e3e32d263	306	#ifdef MDM_DEBUG
mazgch	74:208e3e32d263	307	if (_debugLevel >= 1) dumpIp(ip);
mazgch	74:208e3e32d263	308	#endif
mazgch	57:869bd35f44cc	309	if (ip == NOIP)
mazgch	57:869bd35f44cc	310	return false;
mazgch	57:869bd35f44cc	311	return true;
mazgch	57:869bd35f44cc	312	}
mazgch	57:869bd35f44cc	313
mazgch	74:208e3e32d263	314	bool MDMParser::init(const char* simpin, DevStatus* status, PinName pn)
mazgch	21:c4d64830bf02	315	{
mazgch	74:208e3e32d263	316	int i = 10;
mazgch	95:8282dbbe1492	317	LOCK();
mazgch	76:f7c3dd568dae	318	memset(&_dev, 0, sizeof(_dev));
mazgch	74:208e3e32d263	319	if (pn != NC) {
mazgch	74:208e3e32d263	320	INFO("Modem::wakeup\r\n");
mazgch	74:208e3e32d263	321	DigitalOut pin(pn, 1);
mazgch	74:208e3e32d263	322	while (i--) {
mazgch	79:291df065e345	323	// SARA-U2/LISA-U2 50..80us
irsanjul	120:305e520c136e	324	/*pin = 0; ::wait_us(50);
mazgch	95:8282dbbe1492	325	pin = 1; ::wait_ms(10);
irsanjul	120:305e520c136e	326	*/
mazgch	98:c786461edd40	327	// SARA-G35 >5ms, LISA-C2 > 150ms, LEON-G2 >5ms
mazgch	95:8282dbbe1492	328	pin = 0; ::wait_ms(150);
mazgch	95:8282dbbe1492	329	pin = 1; ::wait_ms(100);
mazgch	79:291df065e345	330
mazgch	79:291df065e345	331	// purge any messages
mazgch	101:edfeb8af206e	332	purge();
mazgch	95:8282dbbe1492	333
mazgch	101:edfeb8af206e	334	// check interface
mazgch	74:208e3e32d263	335	sendFormated("AT\r\n");
mazgch	101:edfeb8af206e	336	int r = waitFinalResp(NULL,NULL,1000);
mazgch	95:8282dbbe1492	337	if(RESP_OK == r) break;
mazgch	74:208e3e32d263	338	}
mazgch	75:ce6e12067d0c	339	if (i < 0) {
mazgch	95:8282dbbe1492	340	ERROR("No Reply from Modem\r\n");
mazgch	95:8282dbbe1492	341	goto failure;
mazgch	75:ce6e12067d0c	342	}
mazgch	21:c4d64830bf02	343	}
mazgch	76:f7c3dd568dae	344	_init = true;
mazgch	75:ce6e12067d0c	345
mazgch	74:208e3e32d263	346	INFO("Modem::init\r\n");
mazgch	21:c4d64830bf02	347	// echo off
mazgch	21:c4d64830bf02	348	sendFormated("AT E0\r\n");
mazgch	52:8071747a7cb3	349	if(RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	350	goto failure;
mazgch	21:c4d64830bf02	351	// enable verbose error messages
mazgch	21:c4d64830bf02	352	sendFormated("AT+CMEE=2\r\n");
mazgch	52:8071747a7cb3	353	if(RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	354	goto failure;
mazgch	21:c4d64830bf02	355	// set baud rate
mazgch	21:c4d64830bf02	356	sendFormated("AT+IPR=115200\r\n");
mazgch	52:8071747a7cb3	357	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	358	goto failure;
mazgch	112:89b5b21db71e	359	// wait some time until baudrate is applied
mazgch	112:89b5b21db71e	360	wait_ms(200); // SARA-G > 40ms
mazgch	21:c4d64830bf02	361	// identify the module
mazgch	21:c4d64830bf02	362	sendFormated("ATI\r\n");
mazgch	52:8071747a7cb3	363	if (RESP_OK != waitFinalResp(_cbATI, &_dev.dev))
mazgch	95:8282dbbe1492	364	goto failure;
mazgch	32:8f12ac182bbb	365	if (_dev.dev == DEV_UNKNOWN)
mazgch	95:8282dbbe1492	366	goto failure;
mazgch	32:8f12ac182bbb	367	// device specific init
mazgch	32:8f12ac182bbb	368	if (_dev.dev == DEV_LISA_C200) {
mazgch	32:8f12ac182bbb	369	// get the manufacturer
mazgch	32:8f12ac182bbb	370	sendFormated("AT+GMI\r\n");
mazgch	52:8071747a7cb3	371	if (RESP_OK != waitFinalResp(_cbString, _dev.manu))
mazgch	95:8282dbbe1492	372	goto failure;
mazgch	32:8f12ac182bbb	373	// get the model identification
mazgch	32:8f12ac182bbb	374	sendFormated("AT+GMM\r\n");
mazgch	52:8071747a7cb3	375	if (RESP_OK != waitFinalResp(_cbString, _dev.model))
mazgch	95:8282dbbe1492	376	goto failure;
mazgch	32:8f12ac182bbb	377	// get the sw version
mazgch	32:8f12ac182bbb	378	sendFormated("AT+GMR\r\n");
mazgch	52:8071747a7cb3	379	if (RESP_OK != waitFinalResp(_cbString, _dev.ver))
mazgch	95:8282dbbe1492	380	goto failure;
mazgch	95:8282dbbe1492	381	// get the pseudo ESN or MEID
mazgch	21:c4d64830bf02	382	sendFormated("AT+GSN\r\n");
mazgch	52:8071747a7cb3	383	if (RESP_OK != waitFinalResp(_cbString, _dev.meid))
mazgch	95:8282dbbe1492	384	goto failure;
mazgch	50:d76aece8038f	385	#if 0
mazgch	50:d76aece8038f	386	// enable power saving
mazgch	50:d76aece8038f	387	if (_dev.lpm != LPM_DISABLED) {
mazgch	50:d76aece8038f	388	// enable power saving (requires flow control, cts at least)
mazgch	50:d76aece8038f	389	sendFormated("AT+UPSV=1,1280\r\n");
mazgch	52:8071747a7cb3	390	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	391	goto failure;
mazgch	50:d76aece8038f	392	_dev.lpm = LPM_ACTIVE;
mazgch	50:d76aece8038f	393	}
mazgch	50:d76aece8038f	394	#endif
mazgch	26:07be5faf8925	395	} else {
mazgch	98:c786461edd40	396	if ((_dev.dev == DEV_LISA_U200) \|\| (_dev.dev == DEV_LEON_G200)) {
mazgch	35:9275215a3a5b	397	// enable the network identification feature
mazgch	21:c4d64830bf02	398	sendFormated("AT+UGPIOC=20,2\r\n");
mazgch	52:8071747a7cb3	399	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	400	goto failure;
mazgch	98:c786461edd40	401	} else if ((_dev.dev == DEV_SARA_U260) \|\| (_dev.dev == DEV_SARA_U270) \|\|
mazgch	98:c786461edd40	402	(_dev.dev == DEV_SARA_G350)) {
mazgch	35:9275215a3a5b	403	// enable the network identification feature
mazgch	21:c4d64830bf02	404	sendFormated("AT+UGPIOC=16,2\r\n");
mazgch	52:8071747a7cb3	405	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	406	goto failure;
mazgch	21:c4d64830bf02	407	}
mazgch	21:c4d64830bf02	408	// check the sim card
mazgch	31:a0bed6c1e05d	409	for (int i = 0; (i < 5) && (_dev.sim != SIM_READY); i++) {
mazgch	21:c4d64830bf02	410	sendFormated("AT+CPIN?\r\n");
mazgch	31:a0bed6c1e05d	411	int ret = waitFinalResp(_cbCPIN, &_dev.sim);
mazgch	62:a02f026bdd7c	412	// having an error here is ok (sim may still be initializing)
mazgch	52:8071747a7cb3	413	if ((RESP_OK != ret) && (RESP_ERROR != ret))
mazgch	95:8282dbbe1492	414	goto failure;
mazgch	31:a0bed6c1e05d	415	// Enter PIN if needed
mazgch	77:55788e619858	416	if (_dev.sim == SIM_PIN) {
mazgch	57:869bd35f44cc	417	if (!simpin) {
mazgch	75:ce6e12067d0c	418	ERROR("SIM PIN not available\r\n");
mazgch	95:8282dbbe1492	419	goto failure;
mazgch	31:a0bed6c1e05d	420	}
mazgch	57:869bd35f44cc	421	sendFormated("AT+CPIN=%s\r\n", simpin);
mazgch	52:8071747a7cb3	422	if (RESP_OK != waitFinalResp(_cbCPIN, &_dev.sim))
mazgch	95:8282dbbe1492	423	goto failure;
mazgch	62:a02f026bdd7c	424	} else if (_dev.sim != SIM_READY) {
mazgch	95:8282dbbe1492	425	wait_ms(1000);
mazgch	62:a02f026bdd7c	426	}
mazgch	21:c4d64830bf02	427	}
mazgch	77:55788e619858	428	if (_dev.sim != SIM_READY) {
mazgch	77:55788e619858	429	if (_dev.sim == SIM_MISSING)
mazgch	77:55788e619858	430	ERROR("SIM not inserted\r\n");
mazgch	95:8282dbbe1492	431	goto failure;
mazgch	77:55788e619858	432	}
mazgch	32:8f12ac182bbb	433	// get the manufacturer
mazgch	32:8f12ac182bbb	434	sendFormated("AT+CGMI\r\n");
mazgch	52:8071747a7cb3	435	if (RESP_OK != waitFinalResp(_cbString, _dev.manu))
mazgch	95:8282dbbe1492	436	goto failure;
mazgch	32:8f12ac182bbb	437	// get the model identification
mazgch	32:8f12ac182bbb	438	sendFormated("AT+CGMM\r\n");
mazgch	52:8071747a7cb3	439	if (RESP_OK != waitFinalResp(_cbString, _dev.model))
mazgch	95:8282dbbe1492	440	goto failure;
mazgch	32:8f12ac182bbb	441	// get the
mazgch	32:8f12ac182bbb	442	sendFormated("AT+CGMR\r\n");
mazgch	52:8071747a7cb3	443	if (RESP_OK != waitFinalResp(_cbString, _dev.ver))
irsanjul	120:305e520c136e	444	goto failure;
mazgch	21:c4d64830bf02	445	// Returns the ICCID (Integrated Circuit Card ID) of the SIM-card.
mazgch	21:c4d64830bf02	446	// ICCID is a serial number identifying the SIM.
mazgch	21:c4d64830bf02	447	sendFormated("AT+CCID\r\n");
mazgch	52:8071747a7cb3	448	if (RESP_OK != waitFinalResp(_cbCCID, _dev.ccid))
mazgch	95:8282dbbe1492	449	goto failure;
mazgch	21:c4d64830bf02	450	// Returns the product serial number, IMEI (International Mobile Equipment Identity)
mazgch	21:c4d64830bf02	451	sendFormated("AT+CGSN\r\n");
mazgch	52:8071747a7cb3	452	if (RESP_OK != waitFinalResp(_cbString, _dev.imei))
mazgch	95:8282dbbe1492	453	goto failure;
mazgch	50:d76aece8038f	454	// enable power saving
mazgch	50:d76aece8038f	455	if (_dev.lpm != LPM_DISABLED) {
mazgch	50:d76aece8038f	456	// enable power saving (requires flow control, cts at least)
mazgch	50:d76aece8038f	457	sendFormated("AT+UPSV=1\r\n");
mazgch	52:8071747a7cb3	458	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	459	goto failure;
mazgch	50:d76aece8038f	460	_dev.lpm = LPM_ACTIVE;
mazgch	50:d76aece8038f	461	}
mazgch	79:291df065e345	462	// enable the psd registration unsolicited result code
mazgch	79:291df065e345	463	sendFormated("AT+CGREG=2\r\n");
mazgch	79:291df065e345	464	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	465	goto failure;
mazgch	21:c4d64830bf02	466	}
mazgch	79:291df065e345	467	// enable the network registration unsolicited result code
mazgch	79:291df065e345	468	sendFormated("AT+CREG=%d\r\n", (_dev.dev == DEV_LISA_C200) ? 1 : 2);
mazgch	79:291df065e345	469	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	470	goto failure;
mazgch	31:a0bed6c1e05d	471	// Setup SMS in text mode
mazgch	31:a0bed6c1e05d	472	sendFormated("AT+CMGF=1\r\n");
mazgch	52:8071747a7cb3	473	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	474	goto failure;
mazgch	31:a0bed6c1e05d	475	// setup new message indication
mazgch	75:ce6e12067d0c	476	sendFormated("AT+CNMI=2,1\r\n");
mazgch	52:8071747a7cb3	477	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	478	goto failure;
irsanjul	120:305e520c136e	479	/*
mazgch	21:c4d64830bf02	480	// Request IMSI (International Mobile Subscriber Identification)
mazgch	21:c4d64830bf02	481	sendFormated("AT+CIMI\r\n");
mazgch	52:8071747a7cb3	482	if (RESP_OK != waitFinalResp(_cbString, _dev.imsi))
mazgch	95:8282dbbe1492	483	goto failure;
irsanjul	120:305e520c136e	484	*/
irsanjul	120:305e520c136e	485
mazgch	28:4d9509e3b1cf	486	if (status)
mazgch	31:a0bed6c1e05d	487	memcpy(status, &_dev, sizeof(DevStatus));
mazgch	95:8282dbbe1492	488	UNLOCK();
mazgch	31:a0bed6c1e05d	489	return true;
mazgch	95:8282dbbe1492	490	failure:
mazgch	95:8282dbbe1492	491	unlock();
mazgch	95:8282dbbe1492	492	return false;
mazgch	31:a0bed6c1e05d	493	}
mazgch	31:a0bed6c1e05d	494
mazgch	74:208e3e32d263	495	bool MDMParser::powerOff(void)
irsanjul	120:305e520c136e	496	{/*
mazgch	95:8282dbbe1492	497	bool ok = false;
mazgch	76:f7c3dd568dae	498	if (_init) {
mazgch	95:8282dbbe1492	499	LOCK();
mazgch	76:f7c3dd568dae	500	INFO("Modem::powerOff\r\n");
mazgch	76:f7c3dd568dae	501	sendFormated("AT+CPWROFF\r\n");
mazgch	95:8282dbbe1492	502	if (RESP_OK == waitFinalResp(NULL,NULL,120*1000)) {
mazgch	95:8282dbbe1492	503	_init = false;
mazgch	95:8282dbbe1492	504	ok = true;
mazgch	95:8282dbbe1492	505	}
mazgch	95:8282dbbe1492	506	UNLOCK();
mazgch	76:f7c3dd568dae	507	}
irsanjul	120:305e520c136e	508	return ok;*/
mazgch	74:208e3e32d263	509	}
mazgch	74:208e3e32d263	510
mazgch	32:8f12ac182bbb	511	int MDMParser::_cbATI(int type, const char* buf, int len, Dev* dev)
mazgch	31:a0bed6c1e05d	512	{
mazgch	37:cc3433329d66	513	if ((type == TYPE_UNKNOWN) && dev) {
mazgch	98:c786461edd40	514	if (strstr(buf, "SARA-G350")) *dev = DEV_SARA_G350;
mazgch	98:c786461edd40	515	else if (strstr(buf, "LISA-U200")) *dev = DEV_LISA_U200;
mazgch	98:c786461edd40	516	else if (strstr(buf, "LISA-C200")) *dev = DEV_LISA_C200;
mazgch	98:c786461edd40	517	else if (strstr(buf, "SARA-U260")) *dev = DEV_SARA_U260;
mazgch	98:c786461edd40	518	else if (strstr(buf, "SARA-U270")) *dev = DEV_SARA_U270;
mazgch	98:c786461edd40	519	else if (strstr(buf, "LEON-G200")) *dev = DEV_LEON_G200;
mazgch	28:4d9509e3b1cf	520	}
mazgch	31:a0bed6c1e05d	521	return WAIT;
mazgch	31:a0bed6c1e05d	522	}
mazgch	31:a0bed6c1e05d	523
mazgch	31:a0bed6c1e05d	524	int MDMParser::_cbCPIN(int type, const char* buf, int len, Sim* sim)
mazgch	31:a0bed6c1e05d	525	{
mazgch	75:ce6e12067d0c	526	if (sim) {
mazgch	75:ce6e12067d0c	527	if (type == TYPE_PLUS){
mazgch	75:ce6e12067d0c	528	char s[16];
mazgch	75:ce6e12067d0c	529	if (sscanf(buf, "\r\n+CPIN: %[^\r]\r\n", s) >= 1)
mazgch	75:ce6e12067d0c	530	*sim = (0 == strcmp("READY", s)) ? SIM_READY : SIM_PIN;
mazgch	75:ce6e12067d0c	531	} else if (type == TYPE_ERROR) {
mazgch	75:ce6e12067d0c	532	if (strstr(buf, "+CME ERROR: SIM not inserted"))
mazgch	75:ce6e12067d0c	533	*sim = SIM_MISSING;
mazgch	31:a0bed6c1e05d	534	}
mazgch	31:a0bed6c1e05d	535	}
mazgch	31:a0bed6c1e05d	536	return WAIT;
mazgch	21:c4d64830bf02	537	}
mazgch	21:c4d64830bf02	538
mazgch	26:07be5faf8925	539	int MDMParser::_cbCCID(int type, const char* buf, int len, char* ccid)
mazgch	26:07be5faf8925	540	{
mazgch	26:07be5faf8925	541	if ((type == TYPE_PLUS) && ccid){
mazgch	26:07be5faf8925	542	if (sscanf(buf, "\r\n+CCID: %[^\r]\r\n", ccid) == 1)
mazgch	31:a0bed6c1e05d	543	/TRACE("Got CCID: %s\r\n", ccid)/;
mazgch	26:07be5faf8925	544	}
mazgch	26:07be5faf8925	545	return WAIT;
mazgch	26:07be5faf8925	546	}
mazgch	26:07be5faf8925	547
mazgch	75:ce6e12067d0c	548	bool MDMParser::registerNet(NetStatus* status /= NULL/, int timeout_ms /= 180000/)
mazgch	75:ce6e12067d0c	549	{
mazgch	75:ce6e12067d0c	550	Timer timer;
mazgch	75:ce6e12067d0c	551	timer.start();
mazgch	75:ce6e12067d0c	552	INFO("Modem::register\r\n");
mazgch	75:ce6e12067d0c	553	while (!checkNetStatus(status) && !TIMEOUT(timer, timeout_ms))
mazgch	95:8282dbbe1492	554	wait_ms(1000);
mazgch	79:291df065e345	555	if (_net.csd == REG_DENIED) ERROR("CSD Registration Denied\r\n");
mazgch	79:291df065e345	556	if (_net.psd == REG_DENIED) ERROR("PSD Registration Denied\r\n");
mazgch	79:291df065e345	557	return REG_OK(_net.csd) \|\| REG_OK(_net.psd);
mazgch	75:ce6e12067d0c	558	}
mazgch	75:ce6e12067d0c	559
mazgch	28:4d9509e3b1cf	560	bool MDMParser::checkNetStatus(NetStatus* status /= NULL/)
mazgch	21:c4d64830bf02	561	{
mazgch	95:8282dbbe1492	562	bool ok = false;
mazgch	95:8282dbbe1492	563	LOCK();
mazgch	75:ce6e12067d0c	564	memset(&_net, 0, sizeof(_net));
mazgch	75:ce6e12067d0c	565	_net.lac = 0xFFFF;
mazgch	75:ce6e12067d0c	566	_net.ci = 0xFFFFFFFF;
mazgch	21:c4d64830bf02	567	// check registration
mazgch	21:c4d64830bf02	568	sendFormated("AT+CREG?\r\n");
mazgch	88:135fb4bb7aac	569	waitFinalResp(); // don't fail as service could be not subscribed
mazgch	79:291df065e345	570	if (_dev.dev != DEV_LISA_C200) {
mazgch	79:291df065e345	571	// check PSD registration
mazgch	79:291df065e345	572	sendFormated("AT+CGREG?\r\n");
mazgch	88:135fb4bb7aac	573	waitFinalResp(); // don't fail as service could be not subscribed
mazgch	79:291df065e345	574	}
mazgch	79:291df065e345	575	if (REG_OK(_net.csd) \|\| REG_OK(_net.psd))
mazgch	75:ce6e12067d0c	576	{
mazgch	75:ce6e12067d0c	577	// check modem specific status messages
mazgch	75:ce6e12067d0c	578	if (_dev.dev == DEV_LISA_C200) {
mazgch	75:ce6e12067d0c	579	sendFormated("AT+CSS?\r\n");
mazgch	75:ce6e12067d0c	580	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	581	goto failure;
mazgch	81:3966a5c17037	582	while (1) {
mazgch	81:3966a5c17037	583	// get the Telephone number
mazgch	81:3966a5c17037	584	sendFormated("AT$MDN?\r\n");
mazgch	81:3966a5c17037	585	if (RESP_OK != waitFinalResp(_cbString, _net.num))
mazgch	95:8282dbbe1492	586	goto failure;
mazgch	81:3966a5c17037	587	// check if we have a Mobile Directory Number
mazgch	81:3966a5c17037	588	if (*_net.num && (memcmp(_net.num, "000000", 6) != 0))
mazgch	81:3966a5c17037	589	break;
mazgch	81:3966a5c17037	590
mazgch	81:3966a5c17037	591	INFO("Device not yet activated\r\n");
mazgch	81:3966a5c17037	592	INFO("Make sure you have a valid contract with the network operator for this device.\r\n");
mazgch	81:3966a5c17037	593	// Check if the the version contains a V for Verizon
mazgch	81:3966a5c17037	594	// Verizon: E0.V.xx.00.xxR,
mazgch	81:3966a5c17037	595	// Sprint E0.S.xx.00.xxR
mazgch	81:3966a5c17037	596	if (_dev.ver[3] == 'V') {
mazgch	81:3966a5c17037	597	int i;
mazgch	81:3966a5c17037	598	INFO("Start device over-the-air activation (this can take a few minutes)\r\n");
mazgch	81:3966a5c17037	599	sendFormated("AT+CDV=*22899\r\n");
mazgch	81:3966a5c17037	600	i = 1;
mazgch	82:055dcfcf9dcc	601	if ((RESP_OK != waitFinalResp(_cbUACTIND, &i, 120*1000)) \|\| (i == 1)) {
mazgch	81:3966a5c17037	602	ERROR("Device over-the-air activation failed\r\n");
mazgch	95:8282dbbe1492	603	goto failure;
mazgch	81:3966a5c17037	604	}
mazgch	81:3966a5c17037	605	INFO("Device over-the-air activation successful\r\n");
mazgch	81:3966a5c17037	606
mazgch	81:3966a5c17037	607	INFO("Start PRL over-the-air update (this can take a few minutes)\r\n");
mazgch	81:3966a5c17037	608	sendFormated("AT+CDV=*22891\r\n");
mazgch	81:3966a5c17037	609	i = 1;
mazgch	82:055dcfcf9dcc	610	if ((RESP_OK != waitFinalResp(_cbUACTIND, &i, 120*1000)) \|\| (i == 1)) {
mazgch	81:3966a5c17037	611	ERROR("PRL over-the-air update failed\r\n");
mazgch	95:8282dbbe1492	612	goto failure;
mazgch	81:3966a5c17037	613	}
mazgch	81:3966a5c17037	614	INFO("PRL over-the-air update successful\r\n");
mazgch	81:3966a5c17037	615
mazgch	81:3966a5c17037	616	} else {
mazgch	81:3966a5c17037	617	// Sprint or Aeris
mazgch	81:3966a5c17037	618	INFO("Wait for OMA-DM over-the-air activation (this can take a few minutes)\r\n");
mazgch	95:8282dbbe1492	619	wait_ms(120*1000);
mazgch	81:3966a5c17037	620	}
mazgch	81:3966a5c17037	621	}
mazgch	75:ce6e12067d0c	622	// get the the Network access identifier string
mazgch	75:ce6e12067d0c	623	char nai[64];
mazgch	75:ce6e12067d0c	624	sendFormated("AT$QCMIPNAI?\r\n");
mazgch	75:ce6e12067d0c	625	if (RESP_OK != waitFinalResp(_cbString, nai))
mazgch	95:8282dbbe1492	626	goto failure;
mazgch	75:ce6e12067d0c	627	} else {
mazgch	75:ce6e12067d0c	628	sendFormated("AT+COPS?\r\n");
mazgch	75:ce6e12067d0c	629	if (RESP_OK != waitFinalResp(_cbCOPS, &_net))
mazgch	95:8282dbbe1492	630	goto failure;
mazgch	95:8282dbbe1492	631	// get the MSISDNs related to this subscriber
mazgch	75:ce6e12067d0c	632	sendFormated("AT+CNUM\r\n");
mazgch	75:ce6e12067d0c	633	if (RESP_OK != waitFinalResp(_cbCNUM, _net.num))
mazgch	95:8282dbbe1492	634	goto failure;
mazgch	75:ce6e12067d0c	635	}
mazgch	95:8282dbbe1492	636	// get the signal strength indication
mazgch	75:ce6e12067d0c	637	sendFormated("AT+CSQ\r\n");
mazgch	75:ce6e12067d0c	638	if (RESP_OK != waitFinalResp(_cbCSQ, &_net))
mazgch	95:8282dbbe1492	639	goto failure;
mazgch	75:ce6e12067d0c	640	}
mazgch	28:4d9509e3b1cf	641	if (status) {
mazgch	31:a0bed6c1e05d	642	memcpy(status, &_net, sizeof(NetStatus));
mazgch	25:4045d02e44f1	643	}
mazgch	95:8282dbbe1492	644	ok = REG_DONE(_net.csd) && REG_DONE(_net.psd);
mazgch	95:8282dbbe1492	645	UNLOCK();
mazgch	95:8282dbbe1492	646	return ok;
mazgch	95:8282dbbe1492	647	failure:
mazgch	95:8282dbbe1492	648	unlock();
mazgch	95:8282dbbe1492	649	return false;
mazgch	31:a0bed6c1e05d	650	}
mazgch	31:a0bed6c1e05d	651
mazgch	31:a0bed6c1e05d	652	int MDMParser::_cbCOPS(int type, const char* buf, int len, NetStatus* status)
mazgch	31:a0bed6c1e05d	653	{
mazgch	31:a0bed6c1e05d	654	if ((type == TYPE_PLUS) && status){
mazgch	31:a0bed6c1e05d	655	int act = 99;
mazgch	31:a0bed6c1e05d	656	// +COPS: <mode>[,<format>,<oper>[,<AcT>]]
mazgch	31:a0bed6c1e05d	657	if (sscanf(buf, "\r\n+COPS: %d,%d,\"%[^\"]\",%d",status->opr,&act) >= 1) {
mazgch	31:a0bed6c1e05d	658	if (act == 0) status->act = ACT_GSM; // 0: GSM,
mazgch	31:a0bed6c1e05d	659	else if (act == 2) status->act = ACT_UTRAN; // 2: UTRAN
mazgch	31:a0bed6c1e05d	660	}
mazgch	31:a0bed6c1e05d	661	}
mazgch	31:a0bed6c1e05d	662	return WAIT;
mazgch	31:a0bed6c1e05d	663	}
mazgch	31:a0bed6c1e05d	664
mazgch	31:a0bed6c1e05d	665	int MDMParser::_cbCNUM(int type, const char* buf, int len, char* num)
mazgch	31:a0bed6c1e05d	666	{
mazgch	31:a0bed6c1e05d	667	if ((type == TYPE_PLUS) && num){
mazgch	31:a0bed6c1e05d	668	int a;
mazgch	31:a0bed6c1e05d	669	if ((sscanf(buf, "\r\n+CNUM: \"My Number\",\"%31[^\"]\",%d", num, &a) == 2) &&
mazgch	31:a0bed6c1e05d	670	((a == 129) \|\| (a == 145))) {
mazgch	31:a0bed6c1e05d	671	}
mazgch	31:a0bed6c1e05d	672	}
mazgch	31:a0bed6c1e05d	673	return WAIT;
mazgch	31:a0bed6c1e05d	674	}
mazgch	31:a0bed6c1e05d	675
mazgch	54:7ba8e4c218e2	676	int MDMParser::_cbCSQ(int type, const char* buf, int len, NetStatus* status)
mazgch	31:a0bed6c1e05d	677	{
mazgch	54:7ba8e4c218e2	678	if ((type == TYPE_PLUS) && status){
mazgch	54:7ba8e4c218e2	679	int a,b;
mazgch	54:7ba8e4c218e2	680	char _ber[] = { 49, 43, 37, 25, 19, 13, 7, 0 }; // see 3GPP TS 45.008 [20] subclause 8.2.4
mazgch	31:a0bed6c1e05d	681	// +CSQ: <rssi>,<qual>
mazgch	54:7ba8e4c218e2	682	if (sscanf(buf, "\r\n+CSQ: %d,%d",&a,&b) == 2) {
mazgch	54:7ba8e4c218e2	683	if (a != 99) status->rssi = -113 + 2*a; // 0: -113 1: -111 ... 30: -53 dBm with 2 dBm steps
mazgch	54:7ba8e4c218e2	684	if ((b != 99) && (b < sizeof(_ber))) status->ber = _ber[b]; //
mazgch	31:a0bed6c1e05d	685	}
mazgch	31:a0bed6c1e05d	686	}
mazgch	31:a0bed6c1e05d	687	return WAIT;
mazgch	31:a0bed6c1e05d	688	}
mazgch	21:c4d64830bf02	689
mazgch	81:3966a5c17037	690	int MDMParser::_cbUACTIND(int type, const char* buf, int len, int* i)
mazgch	81:3966a5c17037	691	{
mazgch	81:3966a5c17037	692	if ((type == TYPE_PLUS) && i){
mazgch	82:055dcfcf9dcc	693	int a;
mazgch	82:055dcfcf9dcc	694	if (sscanf(buf, "\r\n+UACTIND: %d", &a) == 1) {
mazgch	82:055dcfcf9dcc	695	*i = a;
mazgch	81:3966a5c17037	696	}
mazgch	81:3966a5c17037	697	}
mazgch	81:3966a5c17037	698	return WAIT;
mazgch	81:3966a5c17037	699	}
mazgch	81:3966a5c17037	700
mazgch	21:c4d64830bf02	701	// ----------------------------------------------------------------
mazgch	21:c4d64830bf02	702	// internet connection
mazgch	21:c4d64830bf02	703
mazgch	79:291df065e345	704	MDMParser::IP MDMParser::join(const char* apn /= NULL/, const char* username /= NULL/,
mazgch	79:291df065e345	705	const char* password /= NULL/, Auth auth /= AUTH_DETECT/)
mazgch	21:c4d64830bf02	706	{
mazgch	95:8282dbbe1492	707	LOCK();
mazgch	78:caf0014375cb	708	INFO("Modem::join\r\n");
mazgch	32:8f12ac182bbb	709	_ip = NOIP;
mazgch	32:8f12ac182bbb	710	if (_dev.dev == DEV_LISA_C200) {
mazgch	76:f7c3dd568dae	711	// make a dumy dns lookup (which will fail, so ignore the result)
mazgch	76:f7c3dd568dae	712	sendFormated("AT+UDNSRN=0,\"u-blox.com\"\r\n");
mazgch	76:f7c3dd568dae	713	waitFinalResp();
mazgch	76:f7c3dd568dae	714	// This fake lookup will enable the IP connection and we
mazgch	76:f7c3dd568dae	715	// should have an IP after this, so we check it
mazgch	76:f7c3dd568dae	716
mazgch	21:c4d64830bf02	717	//Get local IP address
mazgch	21:c4d64830bf02	718	sendFormated("AT+CMIP?\r\n");
mazgch	52:8071747a7cb3	719	if (RESP_OK != waitFinalResp(_cbCMIP, &_ip))
mazgch	95:8282dbbe1492	720	goto failure;
mazgch	21:c4d64830bf02	721	} else {
mazgch	21:c4d64830bf02	722	// check gprs attach status
mazgch	72:d1e943ad6558	723	sendFormated("AT+CGATT=1\r\n");
mazgch	74:208e3e32d263	724	if (RESP_OK != waitFinalResp(NULL,NULL,3601000))
mazgch	95:8282dbbe1492	725	goto failure;
mazgch	31:a0bed6c1e05d	726
mazgch	31:a0bed6c1e05d	727	// Check the profile
mazgch	31:a0bed6c1e05d	728	int a = 0;
mazgch	79:291df065e345	729	bool force = true;
mazgch	31:a0bed6c1e05d	730	sendFormated("AT+UPSND=" PROFILE ",8\r\n");
mazgch	52:8071747a7cb3	731	if (RESP_OK != waitFinalResp(_cbUPSND, &a))
mazgch	95:8282dbbe1492	732	goto failure;
mazgch	79:291df065e345	733	if (a == 1 && force) {
mazgch	31:a0bed6c1e05d	734	// disconnect the profile already if it is connected
mazgch	31:a0bed6c1e05d	735	sendFormated("AT+UPSDA=" PROFILE ",4\r\n");
mazgch	58:e38a2e942fbb	736	if (RESP_OK != waitFinalResp(NULL,NULL,40*1000))
mazgch	95:8282dbbe1492	737	goto failure;
mazgch	79:291df065e345	738	a = 0;
mazgch	31:a0bed6c1e05d	739	}
mazgch	79:291df065e345	740	if (a == 0) {
mazgch	84:a05edb010176	741	bool ok = false;
mazgch	84:a05edb010176	742	// try to lookup the apn settings from our local database by mccmnc
mazgch	84:a05edb010176	743	const char* config = NULL;
mazgch	88:135fb4bb7aac	744	if (!apn && !username && !password)
mazgch	88:135fb4bb7aac	745	config = apnconfig(_dev.imsi);
mazgch	84:a05edb010176	746
mazgch	79:291df065e345	747	// Set up the dynamic IP address assignment.
mazgch	79:291df065e345	748	sendFormated("AT+UPSD=" PROFILE ",7,\"0.0.0.0\"\r\n");
mazgch	52:8071747a7cb3	749	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	750	goto failure;
mazgch	84:a05edb010176	751
mazgch	84:a05edb010176	752	do {
mazgch	84:a05edb010176	753	if (config) {
mazgch	85:dd8f4f0d0ca9	754	apn = _APN_GET(config);
mazgch	85:dd8f4f0d0ca9	755	username = _APN_GET(config);
mazgch	85:dd8f4f0d0ca9	756	password = _APN_GET(config);
mazgch	84:a05edb010176	757	TRACE("Testing APN Settings(\"%s\",\"%s\",\"%s\")\r\n", apn, username, password);
mazgch	79:291df065e345	758	}
mazgch	84:a05edb010176	759	// Set up the APN
mazgch	90:3915192f6d7e	760	if (apn && *apn) {
mazgch	90:3915192f6d7e	761	sendFormated("AT+UPSD=" PROFILE ",1,\"%s\"\r\n", apn);
mazgch	90:3915192f6d7e	762	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	763	goto failure;
mazgch	90:3915192f6d7e	764	}
mazgch	90:3915192f6d7e	765	if (username && *username) {
mazgch	90:3915192f6d7e	766	sendFormated("AT+UPSD=" PROFILE ",2,\"%s\"\r\n", username);
mazgch	90:3915192f6d7e	767	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	768	goto failure;
mazgch	90:3915192f6d7e	769	}
mazgch	90:3915192f6d7e	770	if (password && *password) {
mazgch	90:3915192f6d7e	771	sendFormated("AT+UPSD=" PROFILE ",3,\"%s\"\r\n", password);
mazgch	90:3915192f6d7e	772	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	773	goto failure;
mazgch	90:3915192f6d7e	774	}
mazgch	84:a05edb010176	775	// try different Authentication Protocols
mazgch	84:a05edb010176	776	// 0 = none
mazgch	84:a05edb010176	777	// 1 = PAP (Password Authentication Protocol)
mazgch	84:a05edb010176	778	// 2 = CHAP (Challenge Handshake Authentication Protocol)
mazgch	84:a05edb010176	779	for (int i = AUTH_NONE; i <= AUTH_CHAP && !ok; i ++) {
mazgch	84:a05edb010176	780	if ((auth == AUTH_DETECT) \|\| (auth == i)) {
mazgch	84:a05edb010176	781	// Set up the Authentication Protocol
mazgch	84:a05edb010176	782	sendFormated("AT+UPSD=" PROFILE ",6,%d\r\n", i);
mazgch	84:a05edb010176	783	if (RESP_OK != waitFinalResp())
mazgch	95:8282dbbe1492	784	goto failure;
mazgch	84:a05edb010176	785	// Activate the profile and make connection
mazgch	84:a05edb010176	786	sendFormated("AT+UPSDA=" PROFILE ",3\r\n");
mazgch	84:a05edb010176	787	if (RESP_OK == waitFinalResp(NULL,NULL,150*1000))
mazgch	84:a05edb010176	788	ok = true;
mazgch	84:a05edb010176	789	}
mazgch	84:a05edb010176	790	}
mazgch	99:3116d3e900ed	791	} while (!ok && config && *config); // maybe use next setting ?
mazgch	84:a05edb010176	792	if (!ok) {
mazgch	79:291df065e345	793	ERROR("Your modem APN/password/username may be wrong\r\n");
mazgch	95:8282dbbe1492	794	goto failure;
mazgch	79:291df065e345	795	}
mazgch	74:208e3e32d263	796	}
mazgch	21:c4d64830bf02	797	//Get local IP address
mazgch	21:c4d64830bf02	798	sendFormated("AT+UPSND=" PROFILE ",0\r\n");
mazgch	52:8071747a7cb3	799	if (RESP_OK != waitFinalResp(_cbUPSND, &_ip))
mazgch	95:8282dbbe1492	800	goto failure;
mazgch	31:a0bed6c1e05d	801	}
mazgch	95:8282dbbe1492	802	UNLOCK();
mazgch	32:8f12ac182bbb	803	return _ip;
mazgch	95:8282dbbe1492	804	failure:
mazgch	95:8282dbbe1492	805	unlock();
mazgch	95:8282dbbe1492	806	return NOIP;
mazgch	31:a0bed6c1e05d	807	}
mazgch	31:a0bed6c1e05d	808
irsanjul	120:305e520c136e	809	//------------------------------------------------------------------------------
irsanjul	120:305e520c136e	810	/*
irsanjul	120:305e520c136e	811	Check Connection of Modem
irsanjul	120:305e520c136e	812	*/
irsanjul	120:305e520c136e	813	bool MDMParser::CheckCon()
irsanjul	120:305e520c136e	814	{
irsanjul	120:305e520c136e	815	bool ok = false;
irsanjul	120:305e520c136e	816	LOCK();
irsanjul	120:305e520c136e	817
irsanjul	120:305e520c136e	818	// Check the profile
irsanjul	120:305e520c136e	819	int a = 0;
irsanjul	120:305e520c136e	820	bool force = true;
irsanjul	120:305e520c136e	821	sendFormated("AT+UPSND=" PROFILE ",8\r\n");
irsanjul	120:305e520c136e	822	if (RESP_OK != waitFinalResp(_cbUPSND, &a))
irsanjul	120:305e520c136e	823	goto failure;
irsanjul	120:305e520c136e	824
irsanjul	120:305e520c136e	825	TRACE("+UPSND: " PROFILE ",8,%d\r\n",a);
irsanjul	120:305e520c136e	826
irsanjul	120:305e520c136e	827	if (a == 1 && force)
irsanjul	120:305e520c136e	828	{
irsanjul	120:305e520c136e	829	// if connected, return true directly
irsanjul	120:305e520c136e	830	ok = true;
irsanjul	120:305e520c136e	831	}
irsanjul	120:305e520c136e	832	if (a == 0)
irsanjul	120:305e520c136e	833	{
irsanjul	120:305e520c136e	834	// if not connected, return false directly
irsanjul	120:305e520c136e	835	ok = false;
irsanjul	120:305e520c136e	836	}
irsanjul	120:305e520c136e	837	UNLOCK();
irsanjul	120:305e520c136e	838	return ok;
irsanjul	120:305e520c136e	839
irsanjul	120:305e520c136e	840	failure:
irsanjul	120:305e520c136e	841	unlock();
irsanjul	120:305e520c136e	842	return false;
irsanjul	120:305e520c136e	843	}
irsanjul	120:305e520c136e	844
irsanjul	120:305e520c136e	845	//------------------------------------------------------------------------------
mazgch	84:a05edb010176	846	int MDMParser::_cbUDOPN(int type, const char* buf, int len, char* mccmnc)
mazgch	84:a05edb010176	847	{
mazgch	84:a05edb010176	848	if ((type == TYPE_PLUS) && mccmnc) {
mazgch	84:a05edb010176	849	if (sscanf(buf, "\r\n+UDOPN: 0,\"%[^\"]\"", mccmnc) == 1)
mazgch	84:a05edb010176	850	;
mazgch	84:a05edb010176	851	}
mazgch	84:a05edb010176	852	return WAIT;
mazgch	84:a05edb010176	853	}
mazgch	84:a05edb010176	854
mazgch	32:8f12ac182bbb	855	int MDMParser::_cbCMIP(int type, const char* buf, int len, IP* ip)
mazgch	32:8f12ac182bbb	856	{
mazgch	102:fb982ff9da82	857	if ((type == TYPE_UNKNOWN) && ip) {
mazgch	32:8f12ac182bbb	858	int a,b,c,d;
mazgch	102:fb982ff9da82	859	if (sscanf(buf, "\r\n" IPSTR, &a,&b,&c,&d) == 4)
mazgch	32:8f12ac182bbb	860	*ip = IPADR(a,b,c,d);
mazgch	32:8f12ac182bbb	861	}
mazgch	32:8f12ac182bbb	862	return WAIT;
mazgch	32:8f12ac182bbb	863	}
mazgch	32:8f12ac182bbb	864
mazgch	31:a0bed6c1e05d	865	int MDMParser::_cbUPSND(int type, const char* buf, int len, int* act)
mazgch	31:a0bed6c1e05d	866	{
mazgch	31:a0bed6c1e05d	867	if ((type == TYPE_PLUS) && act) {
mazgch	31:a0bed6c1e05d	868	if (sscanf(buf, "\r\n+UPSND: %d,%d,%d", act) == 1)
mazgch	31:a0bed6c1e05d	869	/nothing/;
mazgch	21:c4d64830bf02	870	}
mazgch	31:a0bed6c1e05d	871	return WAIT;
mazgch	31:a0bed6c1e05d	872	}
mazgch	31:a0bed6c1e05d	873
mazgch	31:a0bed6c1e05d	874	int MDMParser::_cbUPSND(int type, const char* buf, int len, IP* ip)
mazgch	31:a0bed6c1e05d	875	{
mazgch	31:a0bed6c1e05d	876	if ((type == TYPE_PLUS) && ip) {
mazgch	31:a0bed6c1e05d	877	int a,b,c,d;
mazgch	31:a0bed6c1e05d	878	// +UPSND=<profile_id>,<param_tag>[,<dynamic_param_val>]
mazgch	31:a0bed6c1e05d	879	if (sscanf(buf, "\r\n+UPSND: " PROFILE ",0,\"" IPSTR "\"", &a,&b,&c,&d) == 4)
mazgch	31:a0bed6c1e05d	880	*ip = IPADR(a,b,c,d);
mazgch	31:a0bed6c1e05d	881	}
mazgch	31:a0bed6c1e05d	882	return WAIT;
mazgch	31:a0bed6c1e05d	883	}
mazgch	31:a0bed6c1e05d	884
mazgch	31:a0bed6c1e05d	885	int MDMParser::_cbUDNSRN(int type, const char* buf, int len, IP* ip)
mazgch	31:a0bed6c1e05d	886	{
mazgch	31:a0bed6c1e05d	887	if ((type == TYPE_PLUS) && ip) {
mazgch	31:a0bed6c1e05d	888	int a,b,c,d;
mazgch	95:8282dbbe1492	889	if (sscanf(buf, "\r\n+UDNSRN: \"" IPSTR "\"", &a,&b,&c,&d) == 4)
mazgch	31:a0bed6c1e05d	890	*ip = IPADR(a,b,c,d);
mazgch	31:a0bed6c1e05d	891	}
mazgch	31:a0bed6c1e05d	892	return WAIT;
mazgch	21:c4d64830bf02	893	}
mazgch	21:c4d64830bf02	894
mazgch	21:c4d64830bf02	895	bool MDMParser::disconnect(void)
mazgch	21:c4d64830bf02	896	{
mazgch	95:8282dbbe1492	897	bool ok = false;
mazgch	95:8282dbbe1492	898	LOCK();
mazgch	74:208e3e32d263	899	INFO("Modem::disconnect\r\n");
mazgch	95:8282dbbe1492	900	if (_ip != NOIP) {
mazgch	95:8282dbbe1492	901	if (_dev.dev == DEV_LISA_C200) {
mazgch	95:8282dbbe1492	902	// There something to do here
mazgch	95:8282dbbe1492	903	_ip = NOIP;
mazgch	95:8282dbbe1492	904	ok = true;
mazgch	95:8282dbbe1492	905	} else {
mazgch	95:8282dbbe1492	906	sendFormated("AT+UPSDA=" PROFILE ",4\r\n");
mazgch	95:8282dbbe1492	907	if (RESP_OK != waitFinalResp()) {
mazgch	95:8282dbbe1492	908	_ip = NOIP;
mazgch	95:8282dbbe1492	909	ok = true;
mazgch	95:8282dbbe1492	910	}
mazgch	95:8282dbbe1492	911	}
mazgch	21:c4d64830bf02	912	}
mazgch	95:8282dbbe1492	913	UNLOCK();
mazgch	95:8282dbbe1492	914	return ok;
mazgch	21:c4d64830bf02	915	}
mazgch	21:c4d64830bf02	916
mazgch	31:a0bed6c1e05d	917	MDMParser::IP MDMParser::gethostbyname(const char* host)
mazgch	21:c4d64830bf02	918	{
mazgch	31:a0bed6c1e05d	919	IP ip = NOIP;
mazgch	31:a0bed6c1e05d	920	int a,b,c,d;
mazgch	31:a0bed6c1e05d	921	if (sscanf(host, IPSTR, &a,&b,&c,&d) == 4)
mazgch	31:a0bed6c1e05d	922	ip = IPADR(a,b,c,d);
mazgch	31:a0bed6c1e05d	923	else {
mazgch	95:8282dbbe1492	924	LOCK();
mazgch	31:a0bed6c1e05d	925	sendFormated("AT+UDNSRN=0,\"%s\"\r\n", host);
mazgch	52:8071747a7cb3	926	if (RESP_OK != waitFinalResp(_cbUDNSRN, &ip))
mazgch	95:8282dbbe1492	927	ip = NOIP;
mazgch	95:8282dbbe1492	928	UNLOCK();
mazgch	21:c4d64830bf02	929	}
mazgch	31:a0bed6c1e05d	930	return ip;
mazgch	21:c4d64830bf02	931	}
mazgch	21:c4d64830bf02	932
mazgch	21:c4d64830bf02	933	// ----------------------------------------------------------------
mazgch	21:c4d64830bf02	934	// sockets
mazgch	21:c4d64830bf02	935
mazgch	103:197fa7920ad8	936	int MDMParser::_cbUSOCR(int type, const char* buf, int len, int* handle)
mazgch	21:c4d64830bf02	937	{
mazgch	103:197fa7920ad8	938	if ((type == TYPE_PLUS) && handle) {
mazgch	108:254bf037f83f	939	// +USOCR: socket
mazgch	108:254bf037f83f	940	if (sscanf(buf, "\r\n+USOCR: %d", handle) == 1)
mazgch	108:254bf037f83f	941	/nothing/;
mazgch	21:c4d64830bf02	942	}
mazgch	21:c4d64830bf02	943	return WAIT;
mazgch	21:c4d64830bf02	944	}
mazgch	21:c4d64830bf02	945
mazgch	63:42cb563a25bc	946	int MDMParser::socketSocket(IpProtocol ipproto, int port)
mazgch	21:c4d64830bf02	947	{
mazgch	103:197fa7920ad8	948	int socket;
mazgch	95:8282dbbe1492	949	LOCK();
mazgch	103:197fa7920ad8	950	// find an free socket
mazgch	103:197fa7920ad8	951	socket = _findSocket();
mazgch	47:9a89e5195721	952	TRACE("socketSocket(%d)\r\n", ipproto);
mazgch	95:8282dbbe1492	953	if (socket != SOCKET_ERROR) {
mazgch	106:18aeacdae391	954	if (ipproto == IPPROTO_UDP) {
mazgch	106:18aeacdae391	955	// sending port can only be set on 2G/3G modules
mazgch	106:18aeacdae391	956	if ((port != -1) && (_dev.dev != DEV_LISA_C200)) {
mazgch	106:18aeacdae391	957	sendFormated("AT+USOCR=17,%d\r\n", port);
mazgch	106:18aeacdae391	958	} else {
mazgch	106:18aeacdae391	959	sendFormated("AT+USOCR=17\r\n");
mazgch	106:18aeacdae391	960	}
mazgch	103:197fa7920ad8	961	} else /(ipproto == IPPROTO_TCP)/ {
mazgch	103:197fa7920ad8	962	sendFormated("AT+USOCR=6\r\n");
mazgch	103:197fa7920ad8	963	}
mazgch	103:197fa7920ad8	964	int handle = SOCKET_ERROR;
mazgch	103:197fa7920ad8	965	if ((RESP_OK == waitFinalResp(_cbUSOCR, &handle)) &&
mazgch	103:197fa7920ad8	966	(handle != SOCKET_ERROR)) {
mazgch	103:197fa7920ad8	967	TRACE("Socket %d: handle %d was created\r\n", socket, handle);
mazgch	103:197fa7920ad8	968	_sockets[socket].handle = handle;
mazgch	103:197fa7920ad8	969	_sockets[socket].timeout_ms = TIMEOUT_BLOCKING;
mazgch	103:197fa7920ad8	970	_sockets[socket].connected = false;
mazgch	103:197fa7920ad8	971	_sockets[socket].pending = 0;
mazgch	103:197fa7920ad8	972	}
mazgch	103:197fa7920ad8	973	else
mazgch	103:197fa7920ad8	974	socket = SOCKET_ERROR;
mazgch	95:8282dbbe1492	975	}
mazgch	95:8282dbbe1492	976	UNLOCK();
mazgch	21:c4d64830bf02	977	return socket;
mazgch	21:c4d64830bf02	978	}
mazgch	21:c4d64830bf02	979
mazgch	21:c4d64830bf02	980	bool MDMParser::socketConnect(int socket, const char * host, int port)
mazgch	21:c4d64830bf02	981	{
mazgch	31:a0bed6c1e05d	982	IP ip = gethostbyname(host);
mazgch	31:a0bed6c1e05d	983	if (ip == NOIP)
mazgch	21:c4d64830bf02	984	return false;
mazgch	21:c4d64830bf02	985	// connect to socket
mazgch	95:8282dbbe1492	986	bool ok = false;
mazgch	95:8282dbbe1492	987	LOCK();
mazgch	103:197fa7920ad8	988	if (ISSOCKET(socket) && (!_sockets[socket].connected)) {
mazgch	95:8282dbbe1492	989	TRACE("socketConnect(%d,%s,%d)\r\n", socket,host,port);
mazgch	103:197fa7920ad8	990	sendFormated("AT+USOCO=%d,\"" IPSTR "\",%d\r\n", _sockets[socket].handle, IPNUM(ip), port);
mazgch	95:8282dbbe1492	991	if (RESP_OK == waitFinalResp())
mazgch	103:197fa7920ad8	992	ok = _sockets[socket].connected = true;
mazgch	95:8282dbbe1492	993	}
mazgch	95:8282dbbe1492	994	UNLOCK();
mazgch	95:8282dbbe1492	995	return ok;
mazgch	21:c4d64830bf02	996	}
mazgch	21:c4d64830bf02	997
mazgch	44:9d12223b78ff	998	bool MDMParser::socketIsConnected(int socket)
mazgch	44:9d12223b78ff	999	{
mazgch	95:8282dbbe1492	1000	bool ok = false;
mazgch	95:8282dbbe1492	1001	LOCK();
mazgch	103:197fa7920ad8	1002	ok = ISSOCKET(socket) && _sockets[socket].connected;
mazgch	107:436ee320efd6	1003	TRACE("socketIsConnected(%d) %s\r\n", socket, ok?"yes":"no");
mazgch	95:8282dbbe1492	1004	UNLOCK();
mazgch	95:8282dbbe1492	1005	return ok;
mazgch	44:9d12223b78ff	1006	}
mazgch	44:9d12223b78ff	1007
mazgch	66:69072b3c5bca	1008	bool MDMParser::socketSetBlocking(int socket, int timeout_ms)
mazgch	44:9d12223b78ff	1009	{
mazgch	95:8282dbbe1492	1010	bool ok = false;
mazgch	95:8282dbbe1492	1011	LOCK();
mazgch	103:197fa7920ad8	1012	TRACE("socketSetBlocking(%d,%d)\r\n", socket,timeout_ms);
mazgch	95:8282dbbe1492	1013	if (ISSOCKET(socket)) {
mazgch	95:8282dbbe1492	1014	_sockets[socket].timeout_ms = timeout_ms;
mazgch	95:8282dbbe1492	1015	ok = true;
mazgch	95:8282dbbe1492	1016	}
mazgch	95:8282dbbe1492	1017	UNLOCK();
mazgch	95:8282dbbe1492	1018	return ok;
mazgch	44:9d12223b78ff	1019	}
mazgch	44:9d12223b78ff	1020
mazgch	21:c4d64830bf02	1021	bool MDMParser::socketClose(int socket)
mazgch	21:c4d64830bf02	1022	{
mazgch	95:8282dbbe1492	1023	bool ok = false;
mazgch	95:8282dbbe1492	1024	LOCK();
mazgch	103:197fa7920ad8	1025	if (ISSOCKET(socket) && _sockets[socket].connected) {
mazgch	95:8282dbbe1492	1026	TRACE("socketClose(%d)\r\n", socket);
mazgch	103:197fa7920ad8	1027	sendFormated("AT+USOCL=%d\r\n", _sockets[socket].handle);
mazgch	95:8282dbbe1492	1028	if (RESP_OK == waitFinalResp()) {
mazgch	103:197fa7920ad8	1029	_sockets[socket].connected = false;
mazgch	95:8282dbbe1492	1030	ok = true;
mazgch	95:8282dbbe1492	1031	}
mazgch	95:8282dbbe1492	1032	}
mazgch	95:8282dbbe1492	1033	UNLOCK();
mazgch	95:8282dbbe1492	1034	return ok;
mazgch	21:c4d64830bf02	1035	}
mazgch	21:c4d64830bf02	1036
mazgch	21:c4d64830bf02	1037	bool MDMParser::socketFree(int socket)
mazgch	21:c4d64830bf02	1038	{
mazgch	95:8282dbbe1492	1039	// make sure it is closed
mazgch	21:c4d64830bf02	1040	socketClose(socket);
mazgch	95:8282dbbe1492	1041	bool ok = true;
mazgch	95:8282dbbe1492	1042	LOCK();
mazgch	103:197fa7920ad8	1043	if (ISSOCKET(socket)) {
mazgch	103:197fa7920ad8	1044	TRACE("socketFree(%d)\r\n", socket);
mazgch	103:197fa7920ad8	1045	_sockets[socket].handle = SOCKET_ERROR;
mazgch	103:197fa7920ad8	1046	_sockets[socket].timeout_ms = TIMEOUT_BLOCKING;
mazgch	103:197fa7920ad8	1047	_sockets[socket].connected = false;
mazgch	103:197fa7920ad8	1048	_sockets[socket].pending = 0;
mazgch	95:8282dbbe1492	1049	ok = true;
mazgch	95:8282dbbe1492	1050	}
mazgch	95:8282dbbe1492	1051	UNLOCK();
mazgch	95:8282dbbe1492	1052	return ok;
mazgch	21:c4d64830bf02	1053	}
mazgch	21:c4d64830bf02	1054
mazgch	69:4d6fa520dfca	1055	#define USO_MAX_WRITE 1024 //!< maximum number of bytes to write to socket
mazgch	69:4d6fa520dfca	1056
mazgch	21:c4d64830bf02	1057	int MDMParser::socketSend(int socket, const char * buf, int len)
mazgch	21:c4d64830bf02	1058	{
mazgch	47:9a89e5195721	1059	TRACE("socketSend(%d,,%d)\r\n", socket,len);
mazgch	68:33a96cf64986	1060	int cnt = len;
mazgch	68:33a96cf64986	1061	while (cnt > 0) {
mazgch	69:4d6fa520dfca	1062	int blk = USO_MAX_WRITE;
mazgch	68:33a96cf64986	1063	if (cnt < blk)
mazgch	68:33a96cf64986	1064	blk = cnt;
mazgch	95:8282dbbe1492	1065	bool ok = false;
mazgch	95:8282dbbe1492	1066	LOCK();
mazgch	103:197fa7920ad8	1067	if (ISSOCKET(socket)) {
mazgch	103:197fa7920ad8	1068	sendFormated("AT+USOWR=%d,%d\r\n",_sockets[socket].handle,blk);
mazgch	103:197fa7920ad8	1069	if (RESP_PROMPT == waitFinalResp()) {
mazgch	103:197fa7920ad8	1070	wait_ms(50);
mazgch	103:197fa7920ad8	1071	send(buf, blk);
mazgch	103:197fa7920ad8	1072	if (RESP_OK == waitFinalResp())
mazgch	103:197fa7920ad8	1073	ok = true;
mazgch	103:197fa7920ad8	1074	}
mazgch	95:8282dbbe1492	1075	}
mazgch	95:8282dbbe1492	1076	UNLOCK();
mazgch	95:8282dbbe1492	1077	if (!ok)
mazgch	21:c4d64830bf02	1078	return SOCKET_ERROR;
mazgch	68:33a96cf64986	1079	buf += blk;
mazgch	68:33a96cf64986	1080	cnt -= blk;
mazgch	21:c4d64830bf02	1081	}
mazgch	68:33a96cf64986	1082	return (len - cnt);
mazgch	21:c4d64830bf02	1083	}
mazgch	21:c4d64830bf02	1084
mazgch	21:c4d64830bf02	1085	int MDMParser::socketSendTo(int socket, IP ip, int port, const char * buf, int len)
mazgch	21:c4d64830bf02	1086	{
mazgch	103:197fa7920ad8	1087	TRACE("socketSendTo(%d," IPSTR ",%d,,%d)\r\n", socket,IPNUM(ip),port,len);
mazgch	68:33a96cf64986	1088	int cnt = len;
mazgch	68:33a96cf64986	1089	while (cnt > 0) {
mazgch	69:4d6fa520dfca	1090	int blk = USO_MAX_WRITE;
mazgch	68:33a96cf64986	1091	if (cnt < blk)
mazgch	68:33a96cf64986	1092	blk = cnt;
mazgch	95:8282dbbe1492	1093	bool ok = false;
mazgch	95:8282dbbe1492	1094	LOCK();
mazgch	103:197fa7920ad8	1095	if (ISSOCKET(socket)) {
mazgch	103:197fa7920ad8	1096	sendFormated("AT+USOST=%d,\"" IPSTR "\",%d,%d\r\n",_sockets[socket].handle,IPNUM(ip),port,blk);
mazgch	103:197fa7920ad8	1097	if (RESP_PROMPT == waitFinalResp()) {
mazgch	103:197fa7920ad8	1098	wait_ms(50);
mazgch	103:197fa7920ad8	1099	send(buf, blk);
mazgch	103:197fa7920ad8	1100	if (RESP_OK == waitFinalResp())
mazgch	103:197fa7920ad8	1101	ok = true;
mazgch	103:197fa7920ad8	1102	}
mazgch	95:8282dbbe1492	1103	}
mazgch	95:8282dbbe1492	1104	UNLOCK();
mazgch	95:8282dbbe1492	1105	if (!ok)
mazgch	21:c4d64830bf02	1106	return SOCKET_ERROR;
mazgch	68:33a96cf64986	1107	buf += blk;
mazgch	68:33a96cf64986	1108	cnt -= blk;
mazgch	21:c4d64830bf02	1109	}
mazgch	68:33a96cf64986	1110	return (len - cnt);
mazgch	21:c4d64830bf02	1111	}
mazgch	21:c4d64830bf02	1112
mazgch	21:c4d64830bf02	1113	int MDMParser::socketReadable(int socket)
mazgch	21:c4d64830bf02	1114	{
mazgch	95:8282dbbe1492	1115	int pending = SOCKET_ERROR;
mazgch	95:8282dbbe1492	1116	LOCK();
mazgch	103:197fa7920ad8	1117	if (ISSOCKET(socket) && _sockets[socket].connected) {
mazgch	95:8282dbbe1492	1118	TRACE("socketReadable(%d)\r\n", socket);
mazgch	95:8282dbbe1492	1119	// allow to receive unsolicited commands
mazgch	95:8282dbbe1492	1120	waitFinalResp(NULL, NULL, 0);
mazgch	103:197fa7920ad8	1121	if (_sockets[socket].connected)
mazgch	95:8282dbbe1492	1122	pending = _sockets[socket].pending;
mazgch	95:8282dbbe1492	1123	}
mazgch	95:8282dbbe1492	1124	UNLOCK();
mazgch	95:8282dbbe1492	1125	return pending;
mazgch	21:c4d64830bf02	1126	}
mazgch	21:c4d64830bf02	1127
mazgch	21:c4d64830bf02	1128	int MDMParser::_cbUSORD(int type, const char* buf, int len, char* out)
mazgch	21:c4d64830bf02	1129	{
mazgch	21:c4d64830bf02	1130	if ((type == TYPE_PLUS) && out) {
mazgch	21:c4d64830bf02	1131	int sz, sk;
mazgch	21:c4d64830bf02	1132	if ((sscanf(buf, "\r\n+USORD: %d,%d,", &sk, &sz) == 2) &&
mazgch	21:c4d64830bf02	1133	(buf[len-sz-2] == '\"') && (buf[len-1] == '\"')) {
mazgch	21:c4d64830bf02	1134	memcpy(out, &buf[len-1-sz], sz);
mazgch	21:c4d64830bf02	1135	}
mazgch	21:c4d64830bf02	1136	}
mazgch	21:c4d64830bf02	1137	return WAIT;
mazgch	21:c4d64830bf02	1138	}
mazgch	21:c4d64830bf02	1139
mazgch	21:c4d64830bf02	1140	int MDMParser::socketRecv(int socket, char* buf, int len)
mazgch	21:c4d64830bf02	1141	{
mazgch	21:c4d64830bf02	1142	int cnt = 0;
mazgch	47:9a89e5195721	1143	TRACE("socketRecv(%d,,%d)\r\n", socket, len);
mazgch	95:8282dbbe1492	1144	#ifdef MDM_DEBUG
mazgch	21:c4d64830bf02	1145	memset(buf, '\0', len);
mazgch	95:8282dbbe1492	1146	#endif
mazgch	44:9d12223b78ff	1147	Timer timer;
mazgch	44:9d12223b78ff	1148	timer.start();
mazgch	21:c4d64830bf02	1149	while (len) {
mazgch	69:4d6fa520dfca	1150	int blk = MAX_SIZE; // still need space for headers and unsolicited commands
mazgch	21:c4d64830bf02	1151	if (len < blk) blk = len;
mazgch	95:8282dbbe1492	1152	bool ok = false;
mazgch	95:8282dbbe1492	1153	LOCK();
mazgch	95:8282dbbe1492	1154	if (ISSOCKET(socket)) {
mazgch	103:197fa7920ad8	1155	if (_sockets[socket].connected) {
mazgch	95:8282dbbe1492	1156	if (_sockets[socket].pending < blk)
mazgch	95:8282dbbe1492	1157	blk = _sockets[socket].pending;
mazgch	95:8282dbbe1492	1158	if (blk > 0) {
mazgch	103:197fa7920ad8	1159	sendFormated("AT+USORD=%d,%d\r\n",_sockets[socket].handle, blk);
mazgch	95:8282dbbe1492	1160	if (RESP_OK == waitFinalResp(_cbUSORD, buf)) {
mazgch	95:8282dbbe1492	1161	_sockets[socket].pending -= blk;
mazgch	95:8282dbbe1492	1162	len -= blk;
mazgch	95:8282dbbe1492	1163	cnt += blk;
mazgch	95:8282dbbe1492	1164	buf += blk;
mazgch	95:8282dbbe1492	1165	ok = true;
mazgch	95:8282dbbe1492	1166	}
mazgch	95:8282dbbe1492	1167	} else if (!TIMEOUT(timer, _sockets[socket].timeout_ms)) {
mazgch	95:8282dbbe1492	1168	ok = (WAIT == waitFinalResp(NULL,NULL,0)); // wait for URCs
mazgch	95:8282dbbe1492	1169	} else {
mazgch	95:8282dbbe1492	1170	len = 0;
mazgch	95:8282dbbe1492	1171	ok = true;
mazgch	95:8282dbbe1492	1172	}
mazgch	103:197fa7920ad8	1173	} else {
mazgch	95:8282dbbe1492	1174	len = 0;
mazgch	95:8282dbbe1492	1175	ok = true;
mazgch	21:c4d64830bf02	1176	}
mazgch	21:c4d64830bf02	1177	}
mazgch	95:8282dbbe1492	1178	UNLOCK();
mazgch	107:436ee320efd6	1179	if (!ok) {
mazgch	107:436ee320efd6	1180	TRACE("socketRecv: ERROR\r\n");
mazgch	95:8282dbbe1492	1181	return SOCKET_ERROR;
mazgch	107:436ee320efd6	1182	}
mazgch	21:c4d64830bf02	1183	}
mazgch	107:436ee320efd6	1184	TRACE("socketRecv: %d \"%*s\"\r\n", cnt, cnt, buf-cnt);
mazgch	21:c4d64830bf02	1185	return cnt;
mazgch	21:c4d64830bf02	1186	}
mazgch	21:c4d64830bf02	1187
mazgch	21:c4d64830bf02	1188	int MDMParser::_cbUSORF(int type, const char* buf, int len, USORFparam* param)
mazgch	21:c4d64830bf02	1189	{
mazgch	21:c4d64830bf02	1190	if ((type == TYPE_PLUS) && param) {
mazgch	21:c4d64830bf02	1191	int sz, sk, p, a,b,c,d;
mazgch	95:8282dbbe1492	1192	int r = sscanf(buf, "\r\n+USORF: %d,\"" IPSTR "\",%d,%d,",
mazgch	95:8282dbbe1492	1193	&sk,&a,&b,&c,&d,&p,&sz);
mazgch	95:8282dbbe1492	1194	if ((r == 7) && (buf[len-sz-2] == '\"') && (buf[len-1] == '\"')) {
mazgch	21:c4d64830bf02	1195	memcpy(param->buf, &buf[len-1-sz], sz);
mazgch	21:c4d64830bf02	1196	param->ip = IPADR(a,b,c,d);
mazgch	21:c4d64830bf02	1197	param->port = p;
mazgch	21:c4d64830bf02	1198	}
mazgch	21:c4d64830bf02	1199	}
mazgch	21:c4d64830bf02	1200	return WAIT;
mazgch	21:c4d64830bf02	1201	}
mazgch	21:c4d64830bf02	1202
mazgch	63:42cb563a25bc	1203	int MDMParser::socketRecvFrom(int socket, IP* ip, int* port, char* buf, int len)
mazgch	21:c4d64830bf02	1204	{
mazgch	21:c4d64830bf02	1205	int cnt = 0;
mazgch	63:42cb563a25bc	1206	TRACE("socketRecvFrom(%d,,%d)\r\n", socket, len);
mazgch	95:8282dbbe1492	1207	#ifdef MDM_DEBUG
mazgch	21:c4d64830bf02	1208	memset(buf, '\0', len);
mazgch	95:8282dbbe1492	1209	#endif
mazgch	44:9d12223b78ff	1210	Timer timer;
mazgch	44:9d12223b78ff	1211	timer.start();
mazgch	21:c4d64830bf02	1212	while (len) {
mazgch	69:4d6fa520dfca	1213	int blk = MAX_SIZE; // still need space for headers and unsolicited commands
mazgch	21:c4d64830bf02	1214	if (len < blk) blk = len;
mazgch	95:8282dbbe1492	1215	bool ok = false;
mazgch	95:8282dbbe1492	1216	LOCK();
mazgch	95:8282dbbe1492	1217	if (ISSOCKET(socket)) {
mazgch	95:8282dbbe1492	1218	if (_sockets[socket].pending < blk)
mazgch	95:8282dbbe1492	1219	blk = _sockets[socket].pending;
mazgch	95:8282dbbe1492	1220	if (blk > 0) {
mazgch	103:197fa7920ad8	1221	sendFormated("AT+USORF=%d,%d\r\n",_sockets[socket].handle, blk);
mazgch	95:8282dbbe1492	1222	USORFparam param;
mazgch	95:8282dbbe1492	1223	param.buf = buf;
mazgch	95:8282dbbe1492	1224	if (RESP_OK == waitFinalResp(_cbUSORF, &param)) {
mazgch	95:8282dbbe1492	1225	_sockets[socket].pending -= blk;
mazgch	95:8282dbbe1492	1226	*ip = param.ip;
mazgch	95:8282dbbe1492	1227	*port = param.port;
mazgch	95:8282dbbe1492	1228	len -= blk;
mazgch	95:8282dbbe1492	1229	cnt += blk;
mazgch	95:8282dbbe1492	1230	buf += blk;
mazgch	95:8282dbbe1492	1231	len = 0; // done
mazgch	95:8282dbbe1492	1232	ok = true;
mazgch	95:8282dbbe1492	1233	}
mazgch	95:8282dbbe1492	1234	} else if (!TIMEOUT(timer, _sockets[socket].timeout_ms)) {
mazgch	95:8282dbbe1492	1235	ok = (WAIT == waitFinalResp(NULL,NULL,0)); // wait for URCs
mazgch	95:8282dbbe1492	1236	} else {
mazgch	95:8282dbbe1492	1237	len = 0; // no more data and socket closed or timed-out
mazgch	95:8282dbbe1492	1238	ok = true;
mazgch	21:c4d64830bf02	1239	}
mazgch	95:8282dbbe1492	1240	}
mazgch	95:8282dbbe1492	1241	UNLOCK();
mazgch	107:436ee320efd6	1242	if (!ok) {
mazgch	107:436ee320efd6	1243	TRACE("socketRecv: ERROR\r\n");
mazgch	95:8282dbbe1492	1244	return SOCKET_ERROR;
mazgch	107:436ee320efd6	1245	}
mazgch	21:c4d64830bf02	1246	}
mazgch	44:9d12223b78ff	1247	timer.stop();
mazgch	44:9d12223b78ff	1248	timer.reset();
mazgch	107:436ee320efd6	1249	TRACE("socketRecv: %d \"%*s\"\r\n", cnt, cnt, buf-cnt);
mazgch	21:c4d64830bf02	1250	return cnt;
mazgch	21:c4d64830bf02	1251	}
mazgch	21:c4d64830bf02	1252
mazgch	103:197fa7920ad8	1253	int MDMParser::_findSocket(int handle) {
mazgch	104:c64ba749a422	1254	for (int socket = 0; socket < NUMSOCKETS; socket ++) {
mazgch	103:197fa7920ad8	1255	if (_sockets[socket].handle == handle)
mazgch	103:197fa7920ad8	1256	return socket;
mazgch	103:197fa7920ad8	1257	}
mazgch	103:197fa7920ad8	1258	return SOCKET_ERROR;
mazgch	103:197fa7920ad8	1259	}
mazgch	103:197fa7920ad8	1260
mazgch	21:c4d64830bf02	1261	// ----------------------------------------------------------------
mazgch	31:a0bed6c1e05d	1262
mazgch	31:a0bed6c1e05d	1263	int MDMParser::_cbCMGL(int type, const char* buf, int len, CMGLparam* param)
mazgch	21:c4d64830bf02	1264	{
mazgch	31:a0bed6c1e05d	1265	if ((type == TYPE_PLUS) && param && param->num) {
mazgch	31:a0bed6c1e05d	1266	// +CMGL: <ix>,...
mazgch	31:a0bed6c1e05d	1267	int ix;
mazgch	31:a0bed6c1e05d	1268	if (sscanf(buf, "\r\n+CMGL: %d,", &ix) == 1)
mazgch	31:a0bed6c1e05d	1269	{
mazgch	31:a0bed6c1e05d	1270	*param->ix++ = ix;
mazgch	31:a0bed6c1e05d	1271	param->num--;
mazgch	31:a0bed6c1e05d	1272	}
mazgch	29:53d346010624	1273	}
mazgch	29:53d346010624	1274	return WAIT;
mazgch	21:c4d64830bf02	1275	}
mazgch	21:c4d64830bf02	1276
mazgch	31:a0bed6c1e05d	1277	int MDMParser::smsList(const char* stat /= "ALL"/, int* ix /=NULL/, int num /= 0/) {
mazgch	95:8282dbbe1492	1278	int ret = -1;
mazgch	95:8282dbbe1492	1279	LOCK();
mazgch	31:a0bed6c1e05d	1280	sendFormated("AT+CMGL=\"%s\"\r\n", stat);
mazgch	31:a0bed6c1e05d	1281	CMGLparam param;
mazgch	31:a0bed6c1e05d	1282	param.ix = ix;
mazgch	31:a0bed6c1e05d	1283	param.num = num;
mazgch	95:8282dbbe1492	1284	if (RESP_OK == waitFinalResp(_cbCMGL, &param))
mazgch	95:8282dbbe1492	1285	ret = num - param.num;
mazgch	95:8282dbbe1492	1286	UNLOCK();
mazgch	95:8282dbbe1492	1287	return ret;
mazgch	21:c4d64830bf02	1288	}
mazgch	21:c4d64830bf02	1289
mazgch	21:c4d64830bf02	1290	bool MDMParser::smsSend(const char* num, const char* buf)
mazgch	21:c4d64830bf02	1291	{
mazgch	95:8282dbbe1492	1292	bool ok = false;
mazgch	95:8282dbbe1492	1293	LOCK();
mazgch	80:34985b4d821e	1294	sendFormated("AT+CMGS=\"%s\"\r\n",num);
mazgch	95:8282dbbe1492	1295	if (RESP_PROMPT == waitFinalResp(NULL,NULL,150*1000)) {
mazgch	95:8282dbbe1492	1296	send(buf, strlen(buf));
mazgch	95:8282dbbe1492	1297	const char ctrlZ = 0x1A;
mazgch	95:8282dbbe1492	1298	send(&ctrlZ, sizeof(ctrlZ));
mazgch	95:8282dbbe1492	1299	ok = (RESP_OK == waitFinalResp());
mazgch	21:c4d64830bf02	1300	}
mazgch	95:8282dbbe1492	1301	UNLOCK();
mazgch	95:8282dbbe1492	1302	return ok;
mazgch	21:c4d64830bf02	1303	}
mazgch	21:c4d64830bf02	1304
mazgch	21:c4d64830bf02	1305	bool MDMParser::smsDelete(int ix)
mazgch	21:c4d64830bf02	1306	{
mazgch	95:8282dbbe1492	1307	bool ok = false;
mazgch	95:8282dbbe1492	1308	LOCK();
mazgch	21:c4d64830bf02	1309	sendFormated("AT+CMGD=%d\r\n",ix);
mazgch	95:8282dbbe1492	1310	ok = (RESP_OK == waitFinalResp());
mazgch	95:8282dbbe1492	1311	UNLOCK();
mazgch	95:8282dbbe1492	1312	return ok;
mazgch	21:c4d64830bf02	1313	}
mazgch	21:c4d64830bf02	1314
mazgch	21:c4d64830bf02	1315	int MDMParser::_cbCMGR(int type, const char* buf, int len, CMGRparam* param)
mazgch	21:c4d64830bf02	1316	{
mazgch	21:c4d64830bf02	1317	if (param) {
mazgch	21:c4d64830bf02	1318	if (type == TYPE_PLUS) {
mazgch	21:c4d64830bf02	1319	if (sscanf(buf, "\r\n+CMGR: \"%*[^\"]\",\"%[^\"]", param->num) == 1) {
mazgch	21:c4d64830bf02	1320	}
mazgch	37:cc3433329d66	1321	} else if ((type == TYPE_UNKNOWN) && (buf[len-2] == '\r') && (buf[len-1] == '\n')) {
mazgch	21:c4d64830bf02	1322	memcpy(param->buf, buf, len-2);
mazgch	21:c4d64830bf02	1323	param->buf[len-2] = '\0';
mazgch	21:c4d64830bf02	1324	}
mazgch	21:c4d64830bf02	1325	}
mazgch	21:c4d64830bf02	1326	return WAIT;
mazgch	21:c4d64830bf02	1327	}
mazgch	21:c4d64830bf02	1328
mazgch	21:c4d64830bf02	1329	bool MDMParser::smsRead(int ix, char* num, char* buf, int len)
mazgch	21:c4d64830bf02	1330	{
mazgch	95:8282dbbe1492	1331	bool ok = false;
mazgch	95:8282dbbe1492	1332	LOCK();
mazgch	21:c4d64830bf02	1333	CMGRparam param;
mazgch	21:c4d64830bf02	1334	param.num = num;
mazgch	21:c4d64830bf02	1335	param.buf = buf;
mazgch	21:c4d64830bf02	1336	sendFormated("AT+CMGR=%d\r\n",ix);
mazgch	95:8282dbbe1492	1337	ok = (RESP_OK == waitFinalResp(_cbCMGR, &param));
mazgch	95:8282dbbe1492	1338	UNLOCK();
mazgch	95:8282dbbe1492	1339	return ok;
mazgch	21:c4d64830bf02	1340	}
mazgch	54:7ba8e4c218e2	1341
mazgch	54:7ba8e4c218e2	1342	// ----------------------------------------------------------------
mazgch	70:0a87d256cd24	1343
mazgch	70:0a87d256cd24	1344	int MDMParser::_cbCUSD(int type, const char* buf, int len, char* resp)
mazgch	70:0a87d256cd24	1345	{
mazgch	70:0a87d256cd24	1346	if ((type == TYPE_PLUS) && resp) {
mazgch	70:0a87d256cd24	1347	// +USD: \"%[^\"]\",\"%[^\"]\",,\"%[^\"]\",%d,%d,%d,%d,\"*[^\"]\",%d,%d"..);
mazgch	70:0a87d256cd24	1348	if (sscanf(buf, "\r\n+CUSD: %d,\"%[^\"]\",%d", resp) == 1) {
mazgch	70:0a87d256cd24	1349	/nothing/
mazgch	70:0a87d256cd24	1350	}
mazgch	70:0a87d256cd24	1351	}
mazgch	70:0a87d256cd24	1352	return WAIT;
mazgch	70:0a87d256cd24	1353	}
mazgch	70:0a87d256cd24	1354
mazgch	70:0a87d256cd24	1355	bool MDMParser::ussdCommand(const char* cmd, char* buf)
mazgch	70:0a87d256cd24	1356	{
mazgch	95:8282dbbe1492	1357	bool ok = false;
mazgch	95:8282dbbe1492	1358	LOCK();
mazgch	70:0a87d256cd24	1359	*buf = '\0';
mazgch	95:8282dbbe1492	1360	if (_dev.dev != DEV_LISA_C200) {
mazgch	95:8282dbbe1492	1361	sendFormated("AT+CUSD=1,\"%s\"\r\n",cmd);
mazgch	95:8282dbbe1492	1362	ok = (RESP_OK == waitFinalResp(_cbCUSD, buf));
mazgch	70:0a87d256cd24	1363	}
mazgch	95:8282dbbe1492	1364	UNLOCK();
mazgch	95:8282dbbe1492	1365	return ok;
mazgch	70:0a87d256cd24	1366	}
mazgch	80:34985b4d821e	1367
mazgch	80:34985b4d821e	1368	// ----------------------------------------------------------------
mazgch	70:0a87d256cd24	1369
mazgch	115:d8d94b73c725	1370	int MDMParser::_cbUDELFILE(int type, const char* buf, int len, void*)
mazgch	115:d8d94b73c725	1371	{
mazgch	115:d8d94b73c725	1372	if ((type == TYPE_ERROR) && strstr(buf, "+CME ERROR: FILE NOT FOUND"))
mazgch	115:d8d94b73c725	1373	return RESP_OK; // file does not exist, so all ok...
mazgch	115:d8d94b73c725	1374	return WAIT;
mazgch	115:d8d94b73c725	1375	}
mazgch	115:d8d94b73c725	1376
mazgch	80:34985b4d821e	1377	bool MDMParser::delFile(const char* filename)
mazgch	80:34985b4d821e	1378	{
mazgch	95:8282dbbe1492	1379	bool ok = false;
mazgch	95:8282dbbe1492	1380	LOCK();
mazgch	80:34985b4d821e	1381	sendFormated("AT+UDELFILE=\"%s\"\r\n", filename);
mazgch	115:d8d94b73c725	1382	ok = (RESP_OK == waitFinalResp(_cbUDELFILE));
mazgch	95:8282dbbe1492	1383	UNLOCK();
mazgch	95:8282dbbe1492	1384	return ok;
mazgch	80:34985b4d821e	1385	}
mazgch	80:34985b4d821e	1386
mazgch	80:34985b4d821e	1387	int MDMParser::writeFile(const char* filename, const char* buf, int len)
mazgch	80:34985b4d821e	1388	{
mazgch	95:8282dbbe1492	1389	bool ok = false;
mazgch	95:8282dbbe1492	1390	LOCK();
mazgch	80:34985b4d821e	1391	sendFormated("AT+UDWNFILE=\"%s\",%d\r\n", filename, len);
mazgch	95:8282dbbe1492	1392	if (RESP_PROMPT == waitFinalResp()) {
mazgch	95:8282dbbe1492	1393	send(buf, len);
mazgch	95:8282dbbe1492	1394	ok = (RESP_OK == waitFinalResp());
mazgch	95:8282dbbe1492	1395	}
mazgch	95:8282dbbe1492	1396	UNLOCK();
mazgch	95:8282dbbe1492	1397	return ok ? len : -1;
mazgch	80:34985b4d821e	1398	}
mazgch	80:34985b4d821e	1399
mazgch	80:34985b4d821e	1400	int MDMParser::readFile(const char* filename, char* buf, int len)
mazgch	80:34985b4d821e	1401	{
mazgch	80:34985b4d821e	1402	URDFILEparam param;
mazgch	80:34985b4d821e	1403	param.filename = filename;
mazgch	80:34985b4d821e	1404	param.buf = buf;
mazgch	80:34985b4d821e	1405	param.sz = len;
mazgch	80:34985b4d821e	1406	param.len = 0;
mazgch	95:8282dbbe1492	1407	LOCK();
mazgch	95:8282dbbe1492	1408	sendFormated("AT+URDFILE=\"%s\"\r\n", filename, len);
mazgch	105:f6bb2a20de70	1409	if (RESP_OK != waitFinalResp(_cbURDFILE, &param))
mazgch	95:8282dbbe1492	1410	param.len = -1;
mazgch	95:8282dbbe1492	1411	UNLOCK();
mazgch	80:34985b4d821e	1412	return param.len;
mazgch	80:34985b4d821e	1413	}
mazgch	80:34985b4d821e	1414
mazgch	80:34985b4d821e	1415	int MDMParser::_cbURDFILE(int type, const char* buf, int len, URDFILEparam* param)
mazgch	80:34985b4d821e	1416	{
mazgch	80:34985b4d821e	1417	if ((type == TYPE_PLUS) && param && param->filename && param->buf) {
mazgch	80:34985b4d821e	1418	char filename[48];
mazgch	80:34985b4d821e	1419	int sz;
mazgch	80:34985b4d821e	1420	if ((sscanf(buf, "\r\n+URDFILE: \"%[^\"]\",%d,", filename, &sz) == 2) &&
mazgch	80:34985b4d821e	1421	(0 == strcmp(param->filename, filename)) &&
mazgch	80:34985b4d821e	1422	(buf[len-sz-2] == '\"') && (buf[len-1] == '\"')) {
mazgch	80:34985b4d821e	1423	param->len = (sz < param->sz) ? sz : param->sz;
mazgch	80:34985b4d821e	1424	memcpy(param->buf, &buf[len-1-sz], param->len);
mazgch	80:34985b4d821e	1425	}
mazgch	80:34985b4d821e	1426	}
mazgch	80:34985b4d821e	1427	return WAIT;
mazgch	80:34985b4d821e	1428	}
mazgch	80:34985b4d821e	1429
mazgch	70:0a87d256cd24	1430	// ----------------------------------------------------------------
mazgch	74:208e3e32d263	1431	bool MDMParser::setDebug(int level)
mazgch	74:208e3e32d263	1432	{
mazgch	74:208e3e32d263	1433	#ifdef MDM_DEBUG
mazgch	117:74e4e0109a9e	1434	if ((_debugLevel >= -1) && (level >= -1) &&
mazgch	117:74e4e0109a9e	1435	(_debugLevel <= 3) && (level <= 3)) {
mazgch	74:208e3e32d263	1436	_debugLevel = level;
mazgch	74:208e3e32d263	1437	return true;
mazgch	74:208e3e32d263	1438	}
mazgch	74:208e3e32d263	1439	#endif
mazgch	74:208e3e32d263	1440	return false;
mazgch	74:208e3e32d263	1441	}
mazgch	74:208e3e32d263	1442
mazgch	73:2b32e0a21df2	1443	void MDMParser::dumpDevStatus(MDMParser::DevStatus* status,
mazgch	73:2b32e0a21df2	1444	_DPRINT dprint, void* param)
mazgch	54:7ba8e4c218e2	1445	{
mazgch	75:ce6e12067d0c	1446	dprint(param, "Modem::devStatus\r\n");
mazgch	98:c786461edd40	1447	const char* txtDev[] = { "Unknown", "SARA-G350", "LISA-U200", "LISA-C200", "SARA-U260", "SARA-U270", "LEON-G200" };
mazgch	98:c786461edd40	1448	if (status->dev < sizeof(txtDev)/sizeof(*txtDev) && (status->dev != DEV_UNKNOWN))
mazgch	73:2b32e0a21df2	1449	dprint(param, " Device: %s\r\n", txtDev[status->dev]);
mazgch	54:7ba8e4c218e2	1450	const char* txtLpm[] = { "Disabled", "Enabled", "Active" };
mazgch	54:7ba8e4c218e2	1451	if (status->lpm < sizeof(txtLpm)/sizeof(*txtLpm))
mazgch	73:2b32e0a21df2	1452	dprint(param, " Power Save: %s\r\n", txtLpm[status->lpm]);
mazgch	75:ce6e12067d0c	1453	const char* txtSim[] = { "Unknown", "Missing", "Pin", "Ready" };
mazgch	98:c786461edd40	1454	if (status->sim < sizeof(txtSim)/sizeof(*txtSim) && (status->sim != SIM_UNKNOWN))
mazgch	73:2b32e0a21df2	1455	dprint(param, " SIM: %s\r\n", txtSim[status->sim]);
mazgch	54:7ba8e4c218e2	1456	if (*status->ccid)
mazgch	73:2b32e0a21df2	1457	dprint(param, " CCID: %s\r\n", status->ccid);
mazgch	54:7ba8e4c218e2	1458	if (*status->imei)
mazgch	73:2b32e0a21df2	1459	dprint(param, " IMEI: %s\r\n", status->imei);
mazgch	54:7ba8e4c218e2	1460	if (*status->imsi)
mazgch	73:2b32e0a21df2	1461	dprint(param, " IMSI: %s\r\n", status->imsi);
mazgch	54:7ba8e4c218e2	1462	if (*status->meid)
mazgch	73:2b32e0a21df2	1463	dprint(param, " MEID: %s\r\n", status->meid); // LISA-C
mazgch	54:7ba8e4c218e2	1464	if (*status->manu)
mazgch	73:2b32e0a21df2	1465	dprint(param, " Manufacturer: %s\r\n", status->manu);
mazgch	54:7ba8e4c218e2	1466	if (*status->model)
mazgch	73:2b32e0a21df2	1467	dprint(param, " Model: %s\r\n", status->model);
mazgch	54:7ba8e4c218e2	1468	if (*status->ver)
mazgch	73:2b32e0a21df2	1469	dprint(param, " Version: %s\r\n", status->ver);
mazgch	54:7ba8e4c218e2	1470	}
mazgch	54:7ba8e4c218e2	1471
mazgch	73:2b32e0a21df2	1472	void MDMParser::dumpNetStatus(MDMParser::NetStatus *status,
mazgch	73:2b32e0a21df2	1473	_DPRINT dprint, void* param)
mazgch	54:7ba8e4c218e2	1474	{
mazgch	75:ce6e12067d0c	1475	dprint(param, "Modem::netStatus\r\n");
mazgch	54:7ba8e4c218e2	1476	const char* txtReg[] = { "Unknown", "Denied", "None", "Home", "Roaming" };
mazgch	98:c786461edd40	1477	if (status->csd < sizeof(txtReg)/sizeof(*txtReg) && (status->csd != REG_UNKNOWN))
mazgch	79:291df065e345	1478	dprint(param, " CSD Registration: %s\r\n", txtReg[status->csd]);
mazgch	98:c786461edd40	1479	if (status->psd < sizeof(txtReg)/sizeof(*txtReg) && (status->psd != REG_UNKNOWN))
mazgch	79:291df065e345	1480	dprint(param, " PSD Registration: %s\r\n", txtReg[status->psd]);
mazgch	54:7ba8e4c218e2	1481	const char* txtAct[] = { "Unknown", "GSM", "Edge", "3G", "CDMA" };
mazgch	98:c786461edd40	1482	if (status->act < sizeof(txtAct)/sizeof(*txtAct) && (status->act != ACT_UNKNOWN))
mazgch	73:2b32e0a21df2	1483	dprint(param, " Access Technology: %s\r\n", txtAct[status->act]);
mazgch	54:7ba8e4c218e2	1484	if (status->rssi)
mazgch	73:2b32e0a21df2	1485	dprint(param, " Signal Strength: %d dBm\r\n", status->rssi);
mazgch	54:7ba8e4c218e2	1486	if (status->ber)
mazgch	73:2b32e0a21df2	1487	dprint(param, " Bit Error Rate: %d\r\n", status->ber);
mazgch	54:7ba8e4c218e2	1488	if (*status->opr)
mazgch	73:2b32e0a21df2	1489	dprint(param, " Operator: %s\r\n", status->opr);
mazgch	54:7ba8e4c218e2	1490	if (status->lac != 0xFFFF)
mazgch	73:2b32e0a21df2	1491	dprint(param, " Location Area Code: %04X\r\n", status->lac);
mazgch	54:7ba8e4c218e2	1492	if (status->ci != 0xFFFFFFFF)
mazgch	73:2b32e0a21df2	1493	dprint(param, " Cell ID: %08X\r\n", status->ci);
mazgch	54:7ba8e4c218e2	1494	if (*status->num)
mazgch	73:2b32e0a21df2	1495	dprint(param, " Phone Number: %s\r\n", status->num);
mazgch	54:7ba8e4c218e2	1496	}
mazgch	54:7ba8e4c218e2	1497
mazgch	73:2b32e0a21df2	1498	void MDMParser::dumpIp(MDMParser::IP ip,
mazgch	73:2b32e0a21df2	1499	_DPRINT dprint, void* param)
mazgch	54:7ba8e4c218e2	1500	{
mazgch	57:869bd35f44cc	1501	if (ip != NOIP)
mazgch	75:ce6e12067d0c	1502	dprint(param, "Modem:IP " IPSTR "\r\n", IPNUM(ip));
mazgch	54:7ba8e4c218e2	1503	}
mazgch	70:0a87d256cd24	1504
mazgch	21:c4d64830bf02	1505	// ----------------------------------------------------------------
mazgch	21:c4d64830bf02	1506	int MDMParser::_parseMatch(Pipe<char>* pipe, int len, const char* sta, const char* end)
mazgch	18:e5697801df29	1507	{
mazgch	18:e5697801df29	1508	int o = 0;
mazgch	21:c4d64830bf02	1509	if (sta) {
mazgch	21:c4d64830bf02	1510	while (*sta) {
mazgch	21:c4d64830bf02	1511	if (++o > len) return WAIT;
mazgch	21:c4d64830bf02	1512	char ch = pipe->next();
mazgch	21:c4d64830bf02	1513	if (*sta++ != ch) return NOT_FOUND;
mazgch	21:c4d64830bf02	1514	}
mazgch	21:c4d64830bf02	1515	}
mazgch	21:c4d64830bf02	1516	if (!end) return o; // no termination
mazgch	35:9275215a3a5b	1517	// at least any char
mazgch	35:9275215a3a5b	1518	if (++o > len) return WAIT;
mazgch	35:9275215a3a5b	1519	pipe->next();
mazgch	35:9275215a3a5b	1520	// check the end
mazgch	21:c4d64830bf02	1521	int x = 0;
mazgch	21:c4d64830bf02	1522	while (end[x]) {
mazgch	21:c4d64830bf02	1523	if (++o > len) return WAIT;
mazgch	21:c4d64830bf02	1524	char ch = pipe->next();
mazgch	21:c4d64830bf02	1525	x = (end[x] == ch) ? x + 1 :
mazgch	21:c4d64830bf02	1526	(end[0] == ch) ? 1 :
mazgch	21:c4d64830bf02	1527	0;
mazgch	21:c4d64830bf02	1528	}
mazgch	21:c4d64830bf02	1529	return o;
mazgch	21:c4d64830bf02	1530	}
mazgch	21:c4d64830bf02	1531
mazgch	21:c4d64830bf02	1532	int MDMParser::_parseFormated(Pipe<char>* pipe, int len, const char* fmt)
mazgch	21:c4d64830bf02	1533	{
mazgch	21:c4d64830bf02	1534	int o = 0;
mazgch	21:c4d64830bf02	1535	int num = 0;
mazgch	21:c4d64830bf02	1536	if (fmt) {
mazgch	21:c4d64830bf02	1537	while (*fmt) {
mazgch	21:c4d64830bf02	1538	if (++o > len) return WAIT;
mazgch	21:c4d64830bf02	1539	char ch = pipe->next();
mazgch	21:c4d64830bf02	1540	if (*fmt == '%') {
mazgch	21:c4d64830bf02	1541	fmt++;
mazgch	21:c4d64830bf02	1542	if (*fmt == 'd') { // numeric
mazgch	21:c4d64830bf02	1543	fmt ++;
mazgch	21:c4d64830bf02	1544	num = 0;
mazgch	21:c4d64830bf02	1545	while (ch >= '0' && ch <= '9') {
mazgch	21:c4d64830bf02	1546	num = num * 10 + (ch - '0');
mazgch	21:c4d64830bf02	1547	if (++o > len) return WAIT;
mazgch	21:c4d64830bf02	1548	ch = pipe->next();
mazgch	21:c4d64830bf02	1549	}
mazgch	21:c4d64830bf02	1550	}
mazgch	21:c4d64830bf02	1551	else if (*fmt == 'c') { // char buffer (takes last numeric as length)
mazgch	21:c4d64830bf02	1552	fmt ++;
mazgch	21:c4d64830bf02	1553	while (num --) {
mazgch	21:c4d64830bf02	1554	if (++o > len) return WAIT;
mazgch	21:c4d64830bf02	1555	ch = pipe->next();
mazgch	21:c4d64830bf02	1556	}
mazgch	21:c4d64830bf02	1557	}
mazgch	80:34985b4d821e	1558	else if (*fmt == 's') {
mazgch	80:34985b4d821e	1559	fmt ++;
mazgch	80:34985b4d821e	1560	if (ch != '\"') return NOT_FOUND;
mazgch	80:34985b4d821e	1561	do {
mazgch	80:34985b4d821e	1562	if (++o > len) return WAIT;
mazgch	80:34985b4d821e	1563	ch = pipe->next();
mazgch	80:34985b4d821e	1564	} while (ch != '\"');
mazgch	80:34985b4d821e	1565	if (++o > len) return WAIT;
mazgch	80:34985b4d821e	1566	ch = pipe->next();
mazgch	80:34985b4d821e	1567	}
mazgch	21:c4d64830bf02	1568	}
mazgch	21:c4d64830bf02	1569	if (*fmt++ != ch) return NOT_FOUND;
mazgch	18:e5697801df29	1570	}
mazgch	18:e5697801df29	1571	}
mazgch	21:c4d64830bf02	1572	return o;
mazgch	21:c4d64830bf02	1573	}
mazgch	21:c4d64830bf02	1574
mazgch	21:c4d64830bf02	1575	int MDMParser::_getLine(Pipe<char>* pipe, char* buf, int len)
mazgch	21:c4d64830bf02	1576	{
mazgch	21:c4d64830bf02	1577	int unkn = 0;
mazgch	21:c4d64830bf02	1578	int sz = pipe->size();
mazgch	21:c4d64830bf02	1579	int fr = pipe->free();
mazgch	21:c4d64830bf02	1580	if (len > sz)
mazgch	21:c4d64830bf02	1581	len = sz;
mazgch	21:c4d64830bf02	1582	while (len > 0)
mazgch	21:c4d64830bf02	1583	{
mazgch	21:c4d64830bf02	1584	static struct {
mazgch	21:c4d64830bf02	1585	const char* fmt; int type;
mazgch	21:c4d64830bf02	1586	} lutF[] = {
mazgch	21:c4d64830bf02	1587	{ "\r\n+USORD: %d,%d,\"%c\"", TYPE_PLUS },
mazgch	95:8282dbbe1492	1588	{ "\r\n+USORF: %d,\"" IPSTR "\",%d,%d,\"%c\"", TYPE_PLUS },
mazgch	80:34985b4d821e	1589	{ "\r\n+URDFILE: %s,%d,\"%c\"", TYPE_PLUS },
mazgch	21:c4d64830bf02	1590	};
mazgch	21:c4d64830bf02	1591	static struct {
mazgch	21:c4d64830bf02	1592	const char* sta; const char* end; int type;
mazgch	21:c4d64830bf02	1593	} lut[] = {
mazgch	21:c4d64830bf02	1594	{ "\r\nOK\r\n", NULL, TYPE_OK },
mazgch	21:c4d64830bf02	1595	{ "\r\nERROR\r\n", NULL, TYPE_ERROR },
mazgch	31:a0bed6c1e05d	1596	{ "\r\n+CME ERROR:", "\r\n", TYPE_ERROR },
mazgch	21:c4d64830bf02	1597	{ "\r\n+CMS ERROR:", "\r\n", TYPE_ERROR },
mazgch	21:c4d64830bf02	1598	{ "\r\nRING\r\n", NULL, TYPE_RING },
mazgch	21:c4d64830bf02	1599	{ "\r\nCONNECT\r\n", NULL, TYPE_CONNECT },
mazgch	21:c4d64830bf02	1600	{ "\r\nNO CARRIER\r\n", NULL, TYPE_NOCARRIER },
mazgch	21:c4d64830bf02	1601	{ "\r\nNO DIALTONE\r\n", NULL, TYPE_NODIALTONE },
mazgch	21:c4d64830bf02	1602	{ "\r\nBUSY\r\n", NULL, TYPE_BUSY },
mazgch	21:c4d64830bf02	1603	{ "\r\nNO ANSWER\r\n", NULL, TYPE_NOANSWER },
mazgch	21:c4d64830bf02	1604	{ "\r\n+", "\r\n", TYPE_PLUS },
mazgch	21:c4d64830bf02	1605	{ "\r\n@", NULL, TYPE_PROMPT }, // Sockets
mazgch	21:c4d64830bf02	1606	{ "\r\n>", NULL, TYPE_PROMPT }, // SMS
mazgch	80:34985b4d821e	1607	{ "\n>", NULL, TYPE_PROMPT }, // File
mazgch	21:c4d64830bf02	1608	};
mazgch	21:c4d64830bf02	1609	for (int i = 0; i < sizeof(lutF)/sizeof(*lutF); i ++) {
mazgch	21:c4d64830bf02	1610	pipe->set(unkn);
mazgch	21:c4d64830bf02	1611	int ln = _parseFormated(pipe, len, lutF[i].fmt);
mazgch	21:c4d64830bf02	1612	if (ln == WAIT && fr)
mazgch	21:c4d64830bf02	1613	return WAIT;
mazgch	21:c4d64830bf02	1614	if ((ln != NOT_FOUND) && (unkn > 0))
mazgch	31:a0bed6c1e05d	1615	return TYPE_UNKNOWN \| pipe->get(buf, unkn);
mazgch	21:c4d64830bf02	1616	if (ln > 0)
mazgch	21:c4d64830bf02	1617	return lutF[i].type \| pipe->get(buf, ln);
mazgch	21:c4d64830bf02	1618	}
mazgch	21:c4d64830bf02	1619	for (int i = 0; i < sizeof(lut)/sizeof(*lut); i ++) {
mazgch	21:c4d64830bf02	1620	pipe->set(unkn);
mazgch	21:c4d64830bf02	1621	int ln = _parseMatch(pipe, len, lut[i].sta, lut[i].end);
mazgch	21:c4d64830bf02	1622	if (ln == WAIT && fr)
mazgch	21:c4d64830bf02	1623	return WAIT;
mazgch	21:c4d64830bf02	1624	if ((ln != NOT_FOUND) && (unkn > 0))
mazgch	31:a0bed6c1e05d	1625	return TYPE_UNKNOWN \| pipe->get(buf, unkn);
mazgch	21:c4d64830bf02	1626	if (ln > 0)
mazgch	21:c4d64830bf02	1627	return lut[i].type \| pipe->get(buf, ln);
mazgch	21:c4d64830bf02	1628	}
mazgch	21:c4d64830bf02	1629	// UNKNOWN
mazgch	21:c4d64830bf02	1630	unkn ++;
mazgch	21:c4d64830bf02	1631	len--;
mazgch	21:c4d64830bf02	1632	}
mazgch	18:e5697801df29	1633	return WAIT;
mazgch	18:e5697801df29	1634	}
mazgch	18:e5697801df29	1635
mazgch	18:e5697801df29	1636	// ----------------------------------------------------------------
mazgch	18:e5697801df29	1637	// Serial Implementation
mazgch	18:e5697801df29	1638	// ----------------------------------------------------------------
mazgch	18:e5697801df29	1639
mazgch	76:f7c3dd568dae	1640	/*! Helper Dev Null Device
mazgch	76:f7c3dd568dae	1641	Small helper class used to shut off stderr/stdout. Sometimes stdin/stdout
mazgch	76:f7c3dd568dae	1642	is shared with the serial port of the modem. Having printfs inbetween the
mazgch	76:f7c3dd568dae	1643	AT commands you cause a failure of the modem.
mazgch	76:f7c3dd568dae	1644	*/
mazgch	76:f7c3dd568dae	1645	class DevNull : public Stream {
mazgch	76:f7c3dd568dae	1646	public:
mazgch	76:f7c3dd568dae	1647	DevNull() : Stream(_name+1) { } //!< Constructor
mazgch	76:f7c3dd568dae	1648	void claim(const char* mode, FILE* file)
mazgch	76:f7c3dd568dae	1649	{ freopen(_name, mode, file); } //!< claim a stream
mazgch	76:f7c3dd568dae	1650	protected:
mazgch	76:f7c3dd568dae	1651	virtual int _getc() { return EOF; } //!< Nothing
mazgch	76:f7c3dd568dae	1652	virtual int _putc(int c) { return c; } //!< Discard
mazgch	76:f7c3dd568dae	1653	static const char* _name; //!< File name
mazgch	76:f7c3dd568dae	1654	};
mazgch	76:f7c3dd568dae	1655	const char* DevNull::_name = "/null"; //!< the null device name
mazgch	76:f7c3dd568dae	1656	static DevNull null; //!< the null device
mazgch	76:f7c3dd568dae	1657
mazgch	19:2b5d097ca15d	1658	MDMSerial::MDMSerial(PinName tx /= MDMTXD/, PinName rx /= MDMRXD/,
mazgch	19:2b5d097ca15d	1659	int baudrate /= MDMBAUD/,
mazgch	43:a89a7a505991	1660	#if DEVICE_SERIAL_FC
mazgch	19:2b5d097ca15d	1661	PinName rts /= MDMRTS/, PinName cts /= MDMCTS/,
mazgch	43:a89a7a505991	1662	#endif
mazgch	18:e5697801df29	1663	int rxSize /= 256/, int txSize /= 128/) :
mazgch	35:9275215a3a5b	1664	SerialPipe(tx, rx, rxSize, txSize)
mazgch	18:e5697801df29	1665	{
mazgch	76:f7c3dd568dae	1666	if (rx == USBRX)
mazgch	76:f7c3dd568dae	1667	null.claim("r", stdin);
mazgch	76:f7c3dd568dae	1668	if (tx == USBTX) {
mazgch	76:f7c3dd568dae	1669	null.claim("w", stdout);
mazgch	76:f7c3dd568dae	1670	null.claim("w", stderr);
mazgch	74:208e3e32d263	1671	#ifdef MDM_DEBUG
mazgch	76:f7c3dd568dae	1672	_debugLevel = -1;
mazgch	76:f7c3dd568dae	1673	#endif
mazgch	76:f7c3dd568dae	1674	}
mazgch	74:208e3e32d263	1675	#ifdef TARGET_UBLOX_C027
mazgch	74:208e3e32d263	1676	_onboard = (tx == MDMTXD) && (rx == MDMRXD);
mazgch	74:208e3e32d263	1677	if (_onboard)
mazgch	74:208e3e32d263	1678	c027_mdm_powerOn(false);
mazgch	74:208e3e32d263	1679	#endif
mazgch	18:e5697801df29	1680	baud(baudrate);
mazgch	35:9275215a3a5b	1681	#if DEVICE_SERIAL_FC
mazgch	35:9275215a3a5b	1682	if ((rts != NC) \|\| (cts != NC))
mazgch	35:9275215a3a5b	1683	{
mazgch	35:9275215a3a5b	1684	Flow flow = (cts == NC) ? RTS :
mazgch	35:9275215a3a5b	1685	(rts == NC) ? CTS : RTSCTS ;
mazgch	35:9275215a3a5b	1686	set_flow_control(flow, rts, cts);
mazgch	35:9275215a3a5b	1687	if (cts != NC) _dev.lpm = LPM_ENABLED;
mazgch	35:9275215a3a5b	1688	}
mazgch	35:9275215a3a5b	1689	#endif
mazgch	18:e5697801df29	1690	}
mazgch	18:e5697801df29	1691
mazgch	76:f7c3dd568dae	1692	MDMSerial::~MDMSerial(void)
mazgch	76:f7c3dd568dae	1693	{
mazgch	76:f7c3dd568dae	1694	powerOff();
mazgch	76:f7c3dd568dae	1695	#ifdef TARGET_UBLOX_C027
mazgch	76:f7c3dd568dae	1696	if (_onboard)
mazgch	76:f7c3dd568dae	1697	c027_mdm_powerOff();
mazgch	76:f7c3dd568dae	1698	#endif
mazgch	76:f7c3dd568dae	1699	}
mazgch	76:f7c3dd568dae	1700
mazgch	18:e5697801df29	1701	int MDMSerial::_send(const void* buf, int len)
mazgch	18:e5697801df29	1702	{
mazgch	35:9275215a3a5b	1703	return put((const char)buf, len, true/=blocking*/);
mazgch	18:e5697801df29	1704	}
mazgch	18:e5697801df29	1705
mazgch	18:e5697801df29	1706	int MDMSerial::getLine(char* buffer, int length)
mazgch	18:e5697801df29	1707	{
mazgch	18:e5697801df29	1708	return _getLine(&_pipeRx, buffer, length);
mazgch	18:e5697801df29	1709	}
mazgch	18:e5697801df29	1710
mazgch	18:e5697801df29	1711	// ----------------------------------------------------------------
mazgch	18:e5697801df29	1712	// USB Implementation
mazgch	18:e5697801df29	1713	// ----------------------------------------------------------------
mazgch	18:e5697801df29	1714
mazgch	18:e5697801df29	1715	#ifdef HAVE_MDMUSB
mazgch	76:f7c3dd568dae	1716	MDMUsb::MDMUsb(void)
mazgch	74:208e3e32d263	1717	{
mazgch	74:208e3e32d263	1718	#ifdef MDM_DEBUG
mazgch	74:208e3e32d263	1719	_debugLevel = 1;
mazgch	74:208e3e32d263	1720	#endif
mazgch	74:208e3e32d263	1721	#ifdef TARGET_UBLOX_C027
mazgch	74:208e3e32d263	1722	_onboard = true;
mazgch	74:208e3e32d263	1723	c027_mdm_powerOn(true);
mazgch	74:208e3e32d263	1724	#endif
mazgch	74:208e3e32d263	1725	}
mazgch	76:f7c3dd568dae	1726
mazgch	76:f7c3dd568dae	1727	MDMUsb::~MDMUsb(void)
mazgch	76:f7c3dd568dae	1728	{
mazgch	76:f7c3dd568dae	1729	powerOff();
mazgch	76:f7c3dd568dae	1730	#ifdef TARGET_UBLOX_C027
mazgch	76:f7c3dd568dae	1731	if (_onboard)
mazgch	76:f7c3dd568dae	1732	c027_mdm_powerOff();
mazgch	76:f7c3dd568dae	1733	#endif
mazgch	76:f7c3dd568dae	1734	}
mazgch	76:f7c3dd568dae	1735
mazgch	76:f7c3dd568dae	1736	int MDMUsb::_send(const void* buf, int len) { return 0; }
mazgch	76:f7c3dd568dae	1737
mazgch	18:e5697801df29	1738	int MDMUsb::getLine(char* buffer, int length) { return NOT_FOUND; }
mazgch	76:f7c3dd568dae	1739
mazgch	35:9275215a3a5b	1740	#endif

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	06 Aug 2019
Imports:	0
Forks:	0
Commits:	141
Dependents:	0
Dependencies:	0
Followers:	1

MDM.cpp@120:305e520c136e, 2019-08-06 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning