WeatherStation - mbed Weather Platform firmware http://mbed.org/us…

Users » okini3939 » Code » WeatherStation

Suga koubou / Mbed 2 deprecated WeatherStation

mbed Weather Platform firmware http://mbed.org/users/okini3939/notebook/mbed-weather-platform-firmware/

Dependencies: ChaNFSSD EthernetNetIf I2CLEDDisp Agentbed ChaNFSUSB ILinterpreter mbed BMP085 WeatherMeters ConfigFile ChaNFS I2CLCD

file.cpp@2:a3e5edf84f74, 2011-08-24 (annotated)

Committer:: okini3939
Date:: Wed Aug 24 13:22:32 2011 +0000
Revision:: 2:a3e5edf84f74
Parent:: 1:6c7141895545
Child:: 5:90f840432195

Who changed what in which revision?

User	Revision	Line number	New contents of line
okini3939	1:6c7141895545	1	/*
okini3939	1:6c7141895545	2	* Weather Station - mbed Weather Platform
okini3939	1:6c7141895545	3	* Copyright (c) 2011 Hiroshi Suga
okini3939	1:6c7141895545	4	* Released under the MIT License: http://mbed.org/license/mit
okini3939	1:6c7141895545	5	*/
okini3939	1:6c7141895545	6
okini3939	1:6c7141895545	7	/** @file
okini3939	1:6c7141895545	8	* @brief Weather Station
okini3939	1:6c7141895545	9	*/
okini3939	1:6c7141895545	10
okini3939	0:bdb53686c194	11	#include "mbed.h"
okini3939	0:bdb53686c194	12	#include "weather.h"
okini3939	2:a3e5edf84f74	13	#include "SDFileSystem.h"
okini3939	2:a3e5edf84f74	14	#ifdef USE_USB
okini3939	0:bdb53686c194	15	#include "MSCFileSystem.h"
okini3939	2:a3e5edf84f74	16	#endif
okini3939	0:bdb53686c194	17	#include "ConfigFile.h"
okini3939	0:bdb53686c194	18
okini3939	0:bdb53686c194	19	static SDFileSystem sd(p5, p6, p7, p8, "sd");
okini3939	0:bdb53686c194	20	static LocalFileSystem *local;
okini3939	2:a3e5edf84f74	21	#ifdef USE_USB
okini3939	0:bdb53686c194	22	static MSCFileSystem *usb;
okini3939	2:a3e5edf84f74	23	#endif
okini3939	1:6c7141895545	24	static DigitalIn sd_ins(p27);
okini3939	2:a3e5edf84f74	25	struct Config conf;
okini3939	0:bdb53686c194	26	static char filename[30] = "";
okini3939	0:bdb53686c194	27
okini3939	0:bdb53686c194	28	int write_log (const char *buf) {
okini3939	0:bdb53686c194	29	FILE *fp;
okini3939	0:bdb53686c194	30
okini3939	0:bdb53686c194	31	if (filename[0] == 0) return 0;
okini3939	1:6c7141895545	32	#ifdef USE_SD_INS
okini3939	1:6c7141895545	33	if (sd_ins != 0) return -1;
okini3939	1:6c7141895545	34	#endif
okini3939	0:bdb53686c194	35
okini3939	2:a3e5edf84f74	36	LED_FILE_ACT_ON;
okini3939	0:bdb53686c194	37	fp = fopen(filename, "a");
okini3939	0:bdb53686c194	38	if (fp) {
okini3939	0:bdb53686c194	39	fprintf(fp, buf);
okini3939	0:bdb53686c194	40	fclose(fp);
okini3939	0:bdb53686c194	41	} else {
okini3939	2:a3e5edf84f74	42	LED_FILE_ACT_OFF;
okini3939	0:bdb53686c194	43	return -1;
okini3939	0:bdb53686c194	44	}
okini3939	2:a3e5edf84f74	45	LED_FILE_ACT_OFF;
okini3939	0:bdb53686c194	46	return 0;
okini3939	0:bdb53686c194	47	}
okini3939	0:bdb53686c194	48
okini3939	0:bdb53686c194	49	int init_file () {
okini3939	0:bdb53686c194	50	int seq = 0;
okini3939	2:a3e5edf84f74	51	char dir[8];
okini3939	0:bdb53686c194	52	FILE *fp;
okini3939	0:bdb53686c194	53
okini3939	2:a3e5edf84f74	54	if (conf.filetype) {
okini3939	2:a3e5edf84f74	55	if (conf.filetype == 1) {
okini3939	2:a3e5edf84f74	56	strcpy(dir, "/sd/");
okini3939	0:bdb53686c194	57	} else
okini3939	2:a3e5edf84f74	58	if (conf.filetype == 2) {
okini3939	2:a3e5edf84f74	59	#ifdef USE_USB
okini3939	0:bdb53686c194	60	usb = new MSCFileSystem("usb");
okini3939	2:a3e5edf84f74	61	strcpy(dir, "/usb/");
okini3939	2:a3e5edf84f74	62	#endif
okini3939	0:bdb53686c194	63	}
okini3939	0:bdb53686c194	64
okini3939	0:bdb53686c194	65	// seq num
okini3939	2:a3e5edf84f74	66	strcpy(filename, dir);
okini3939	0:bdb53686c194	67	strcat(filename, "weather.seq");
okini3939	2:a3e5edf84f74	68	LED_FILE_ACT_ON;
okini3939	0:bdb53686c194	69	fp = fopen(filename, "r");
okini3939	0:bdb53686c194	70	if (fp) {
okini3939	0:bdb53686c194	71	fscanf(fp, "%d", &seq);
okini3939	0:bdb53686c194	72	fclose(fp);
okini3939	0:bdb53686c194	73	}
okini3939	0:bdb53686c194	74	seq ++;
okini3939	0:bdb53686c194	75
okini3939	0:bdb53686c194	76	// save seq num
okini3939	0:bdb53686c194	77	fp = fopen(filename, "w");
okini3939	0:bdb53686c194	78	if (fp) {
okini3939	0:bdb53686c194	79	fprintf(fp, "%d", seq);
okini3939	0:bdb53686c194	80	fclose(fp);
okini3939	0:bdb53686c194	81	}
okini3939	2:a3e5edf84f74	82	LED_FILE_ACT_OFF;
okini3939	0:bdb53686c194	83
okini3939	0:bdb53686c194	84	// csv filename
okini3939	2:a3e5edf84f74	85	sprintf(filename, "%sw%05d.csv", dir, seq);
okini3939	0:bdb53686c194	86	pc.printf("CSV Filename: %s\r\n", filename);
okini3939	0:bdb53686c194	87	}
okini3939	0:bdb53686c194	88	return 0;
okini3939	0:bdb53686c194	89	}
okini3939	0:bdb53686c194	90
okini3939	0:bdb53686c194	91	char* chop (char *s) {
okini3939	0:bdb53686c194	92	int i;
okini3939	0:bdb53686c194	93
okini3939	0:bdb53686c194	94	for (i = strlen(s) - 1; i >= 0; i --) {
okini3939	0:bdb53686c194	95	if (s[i] == ' ' \|\| s[i] == '\n' \|\| s[i] == '\r') {
okini3939	0:bdb53686c194	96	s[i] = 0;
okini3939	0:bdb53686c194	97	} else {
okini3939	0:bdb53686c194	98	break;
okini3939	0:bdb53686c194	99	}
okini3939	0:bdb53686c194	100	}
okini3939	0:bdb53686c194	101	return s;
okini3939	0:bdb53686c194	102	}
okini3939	2:a3e5edf84f74	103
okini3939	2:a3e5edf84f74	104	int init_conf () {
okini3939	2:a3e5edf84f74	105	ConfigFile cfg;
okini3939	2:a3e5edf84f74	106	int i;
okini3939	2:a3e5edf84f74	107	char buf[CF_VALUE_SIZE], key[CF_KEY_SIZE];
okini3939	2:a3e5edf84f74	108	int ip0, ip1, ip2, ip3;
okini3939	2:a3e5edf84f74	109
okini3939	2:a3e5edf84f74	110	memset(&conf, 0, sizeof(conf));
okini3939	2:a3e5edf84f74	111	conf.interval = 60;
okini3939	2:a3e5edf84f74	112	strcpy(conf.csv_mesg, CSV_MESG);
okini3939	2:a3e5edf84f74	113
okini3939	2:a3e5edf84f74	114	#ifdef USE_SD_INS
okini3939	2:a3e5edf84f74	115	sd_ins.mode(PullUp);
okini3939	2:a3e5edf84f74	116	#endif
okini3939	2:a3e5edf84f74	117
okini3939	2:a3e5edf84f74	118	// open config
okini3939	2:a3e5edf84f74	119	LED_FILE_ACT_ON;
okini3939	2:a3e5edf84f74	120	#ifdef USE_SD_INS
okini3939	2:a3e5edf84f74	121	if (sd_ins == 0 && cfg.read("/sd/" CONFIG_FILE)) {
okini3939	2:a3e5edf84f74	122	#else
okini3939	2:a3e5edf84f74	123	if (cfg.read("/sd/" CONFIG_FILE)) {
okini3939	2:a3e5edf84f74	124	#endif
okini3939	2:a3e5edf84f74	125	// from sd
okini3939	2:a3e5edf84f74	126
okini3939	2:a3e5edf84f74	127	strcpy(conf.dir, "/sd/");
okini3939	2:a3e5edf84f74	128	LED_FILE_ACT_OFF;
okini3939	2:a3e5edf84f74	129
okini3939	2:a3e5edf84f74	130	} else {
okini3939	2:a3e5edf84f74	131	local = new LocalFileSystem("local");
okini3939	2:a3e5edf84f74	132	if (cfg.read("/local/" CONFIG_FILE)) {
okini3939	2:a3e5edf84f74	133	// from usb
okini3939	2:a3e5edf84f74	134
okini3939	2:a3e5edf84f74	135	strcpy(conf.dir, "/local/");
okini3939	2:a3e5edf84f74	136	LED_FILE_ACT_OFF;
okini3939	2:a3e5edf84f74	137
okini3939	2:a3e5edf84f74	138	} else {
okini3939	2:a3e5edf84f74	139	// none
okini3939	2:a3e5edf84f74	140	LED_FILE_ACT_OFF;
okini3939	2:a3e5edf84f74	141	return -1;
okini3939	2:a3e5edf84f74	142	}
okini3939	2:a3e5edf84f74	143	}
okini3939	2:a3e5edf84f74	144
okini3939	2:a3e5edf84f74	145	// load config
okini3939	2:a3e5edf84f74	146	if (cfg.getValue("INTERVAL", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	147	conf.interval = atoi(buf);
okini3939	2:a3e5edf84f74	148	}
okini3939	2:a3e5edf84f74	149	if (cfg.getValue("BAUD", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	150	conf.baud = atoi(buf);
okini3939	2:a3e5edf84f74	151	}
okini3939	2:a3e5edf84f74	152
okini3939	2:a3e5edf84f74	153	if (cfg.getValue("FILE", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	154	chop(buf);
okini3939	2:a3e5edf84f74	155	if (strcmp(buf, "SD") == 0) {
okini3939	2:a3e5edf84f74	156	conf.filetype = 1;
okini3939	2:a3e5edf84f74	157	} else
okini3939	2:a3e5edf84f74	158	if (strcmp(buf, "USB") == 0) {
okini3939	2:a3e5edf84f74	159	conf.filetype = 2;
okini3939	2:a3e5edf84f74	160	}
okini3939	2:a3e5edf84f74	161	}
okini3939	2:a3e5edf84f74	162	if (cfg.getValue("CSV_MESG", conf.csv_mesg, sizeof_1(conf.csv_mesg))) {
okini3939	2:a3e5edf84f74	163	chop(conf.csv_mesg);
okini3939	2:a3e5edf84f74	164	}
okini3939	2:a3e5edf84f74	165
okini3939	2:a3e5edf84f74	166	if (cfg.getValue("IPADDRESS", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	167	if (strncmp(buf, "DHCP", 4) == 0) {
okini3939	2:a3e5edf84f74	168	conf.ipaddr = IpAddr(255, 255, 255, 255);
okini3939	2:a3e5edf84f74	169	} else {
okini3939	2:a3e5edf84f74	170	sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939	2:a3e5edf84f74	171	conf.ipaddr = IpAddr(ip0, ip1, ip2, ip3);
okini3939	2:a3e5edf84f74	172	}
okini3939	2:a3e5edf84f74	173	}
okini3939	2:a3e5edf84f74	174	if (cfg.getValue("NETMASK", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	175	sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939	2:a3e5edf84f74	176	conf.netmask = IpAddr(ip0, ip1, ip2, ip3);
okini3939	2:a3e5edf84f74	177	}
okini3939	2:a3e5edf84f74	178	if (cfg.getValue("GATEWAY", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	179	sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939	2:a3e5edf84f74	180	conf.gateway = IpAddr(ip0, ip1, ip2, ip3);
okini3939	2:a3e5edf84f74	181	}
okini3939	2:a3e5edf84f74	182	if (cfg.getValue("NAMESERVER", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	183	sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939	2:a3e5edf84f74	184	conf.nameserver = IpAddr(ip0, ip1, ip2, ip3);
okini3939	2:a3e5edf84f74	185	}
okini3939	2:a3e5edf84f74	186
okini3939	2:a3e5edf84f74	187	cfg.getValue("NTPSERVER", conf.ntpserver, sizeof_1(conf.ntpserver));
okini3939	2:a3e5edf84f74	188	chop(conf.ntpserver);
okini3939	2:a3e5edf84f74	189	cfg.getValue("SNMP_COMMNAME", conf.snmp_commname, sizeof_1(conf.snmp_commname));
okini3939	2:a3e5edf84f74	190	chop(conf.snmp_commname);
okini3939	2:a3e5edf84f74	191
okini3939	2:a3e5edf84f74	192	cfg.getValue("PACHUBE_APIKEY", conf.pachube_apikey, sizeof_1(conf.pachube_apikey));
okini3939	2:a3e5edf84f74	193	chop(conf.pachube_apikey);
okini3939	2:a3e5edf84f74	194	cfg.getValue("PACHUBE_FEEDID", conf.pachube_feedid, sizeof_1(conf.pachube_feedid));
okini3939	2:a3e5edf84f74	195	chop(conf.pachube_feedid);
okini3939	2:a3e5edf84f74	196	if (cfg.getValue("PACHUBE_MESG", conf.pachube_mesg, sizeof_1(conf.pachube_mesg))) {
okini3939	2:a3e5edf84f74	197	chop(conf.pachube_mesg);
okini3939	2:a3e5edf84f74	198	} else {
okini3939	2:a3e5edf84f74	199	strcpy(conf.pachube_mesg, PACHUBE_MESG);
okini3939	2:a3e5edf84f74	200	}
okini3939	2:a3e5edf84f74	201
okini3939	2:a3e5edf84f74	202	cfg.getValue("TWITTER_USER", conf.twitter_user, sizeof_1(conf.twitter_user));
okini3939	2:a3e5edf84f74	203	chop(conf.twitter_user);
okini3939	2:a3e5edf84f74	204	cfg.getValue("TWITTER_PWD", conf.twitter_pwd, sizeof_1(conf.twitter_pwd));
okini3939	2:a3e5edf84f74	205	chop(conf.twitter_pwd);
okini3939	2:a3e5edf84f74	206	cfg.getValue("TWITTER_MESG", conf.twitter_mesg[0], sizeof_1(conf.twitter_mesg[0]));
okini3939	2:a3e5edf84f74	207	chop(conf.twitter_mesg[0]);
okini3939	2:a3e5edf84f74	208	for (i = 0; i < CF_TWITTER_NUM; i ++) {
okini3939	2:a3e5edf84f74	209	sprintf(key, "TWITTER_MESG[%d]", i);
okini3939	2:a3e5edf84f74	210	cfg.getValue(key, conf.twitter_mesg[i], sizeof_1(conf.twitter_mesg[i]));
okini3939	2:a3e5edf84f74	211	chop(conf.twitter_mesg[i]);
okini3939	2:a3e5edf84f74	212	}
okini3939	2:a3e5edf84f74	213
okini3939	2:a3e5edf84f74	214	cfg.getValue("STATIONS_ID", conf.stations_id, sizeof_1(conf.stations_id));
okini3939	2:a3e5edf84f74	215	chop(conf.stations_id);
okini3939	2:a3e5edf84f74	216	cfg.getValue("STATIONS_PIN", conf.stations_pin, sizeof_1(conf.stations_pin));
okini3939	2:a3e5edf84f74	217	chop(conf.stations_pin);
okini3939	2:a3e5edf84f74	218
okini3939	2:a3e5edf84f74	219	if (cfg.getValue("LCD_TYPE", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	220	conf.lcdtype = (enum I2CLCDType)atoi(buf);
okini3939	2:a3e5edf84f74	221	} else {
okini3939	2:a3e5edf84f74	222	conf.lcdtype = LCD16x2;
okini3939	2:a3e5edf84f74	223	}
okini3939	2:a3e5edf84f74	224	if (cfg.getValue("LCD_CONF", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	225	conf.lcdconf = (enum I2CLCDConfig)atoi(buf);
okini3939	2:a3e5edf84f74	226	} else {
okini3939	2:a3e5edf84f74	227	conf.lcdconf = LCDCFG_3V;
okini3939	2:a3e5edf84f74	228	}
okini3939	2:a3e5edf84f74	229	if (cfg.getValue("LCD_MESG", conf.lcd_mesg, sizeof_1(conf.lcd_mesg))) {
okini3939	2:a3e5edf84f74	230	chop(conf.lcd_mesg);
okini3939	2:a3e5edf84f74	231	}
okini3939	2:a3e5edf84f74	232	if (cfg.getValue("LEDDISP_MESG", conf.leddisp_mesg, sizeof_1(conf.leddisp_mesg))) {
okini3939	2:a3e5edf84f74	233	chop(conf.leddisp_mesg);
okini3939	2:a3e5edf84f74	234	}
okini3939	2:a3e5edf84f74	235
okini3939	2:a3e5edf84f74	236	if (cfg.getValue("XBEE", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	237	conf.xbeebaud = atoi(buf);
okini3939	2:a3e5edf84f74	238	}
okini3939	2:a3e5edf84f74	239
okini3939	2:a3e5edf84f74	240	if (cfg.getValue("INPUT", buf, sizeof(buf))) {
okini3939	2:a3e5edf84f74	241	conf.inputtype = (enum eINPUTTYPE)atoi(buf);
okini3939	2:a3e5edf84f74	242	}
okini3939	2:a3e5edf84f74	243
okini3939	2:a3e5edf84f74	244	if (cfg.getValue("OFFSET[P]", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	245	offset.pres = atof(buf);
okini3939	2:a3e5edf84f74	246	}
okini3939	2:a3e5edf84f74	247	if (cfg.getValue("OFFSET[T]", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	248	offset.temp = atof(buf);
okini3939	2:a3e5edf84f74	249	}
okini3939	2:a3e5edf84f74	250	if (cfg.getValue("OFFSET[H]", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	251	offset.humi = atof(buf);
okini3939	2:a3e5edf84f74	252	}
okini3939	2:a3e5edf84f74	253
okini3939	2:a3e5edf84f74	254	#ifdef USE_EMAIL
okini3939	2:a3e5edf84f74	255	cfg.getValue("SMTPSERVER", conf.smtphost, sizeof_1(conf.smtphost));
okini3939	2:a3e5edf84f74	256	chop(conf.smtphost);
okini3939	2:a3e5edf84f74	257	if (cfg.getValue("SMTPPORT", buf, sizeof_1(buf))) {
okini3939	2:a3e5edf84f74	258	conf.smtpport = atoi(buf);
okini3939	2:a3e5edf84f74	259	} else {
okini3939	2:a3e5edf84f74	260	conf.smtpport = 25;
okini3939	2:a3e5edf84f74	261	}
okini3939	2:a3e5edf84f74	262	cfg.getValue("SMTPUSER", conf.smtpuser, sizeof_1(conf.smtpuser));
okini3939	2:a3e5edf84f74	263	chop(conf.smtpuser);
okini3939	2:a3e5edf84f74	264	cfg.getValue("SMTPPWD", conf.smtppwd, sizeof_1(conf.smtppwd));
okini3939	2:a3e5edf84f74	265	chop(conf.smtppwd);
okini3939	2:a3e5edf84f74	266	cfg.getValue("MAIL_FROM", conf.mailfrom, sizeof_1(conf.mailfrom));
okini3939	2:a3e5edf84f74	267	chop(conf.mailfrom);
okini3939	2:a3e5edf84f74	268	for (i = 0; i < CF_MAIL_NUM; i ++) {
okini3939	2:a3e5edf84f74	269	snprintf(key, sizeof_1(key), "MAIL_MESG[%d]", i);
okini3939	2:a3e5edf84f74	270	cfg.getValue(key, conf.mailmesg[i], sizeof_1(conf.mailmesg[i]));
okini3939	2:a3e5edf84f74	271	chop(conf.mailmesg[i]);
okini3939	2:a3e5edf84f74	272	snprintf(key, sizeof_1(key), "MAIL_TO[%d]", i);
okini3939	2:a3e5edf84f74	273	cfg.getValue(key, conf.mailto[i], sizeof_1(conf.mailto[i]));
okini3939	2:a3e5edf84f74	274	chop(conf.mailto[i]);
okini3939	2:a3e5edf84f74	275	}
okini3939	2:a3e5edf84f74	276	#endif
okini3939	2:a3e5edf84f74	277
okini3939	2:a3e5edf84f74	278	#ifdef DEBUG
okini3939	2:a3e5edf84f74	279	pc.printf("Configration: %d\r\n", cfg.getCount());
okini3939	2:a3e5edf84f74	280	#endif
okini3939	2:a3e5edf84f74	281	return 0;
okini3939	2:a3e5edf84f74	282	}

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	04 Jul 2011
Imports:	120
Forks:	0
Commits:	9
Dependents:	0
Dependencies:	12
Followers:	8

file.cpp@2:a3e5edf84f74, 2011-08-24 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning