4 * Created on: Oct 31, 2010
16 #include <sys/types.h>
22 #include "W1Configure.hh"
30 std::string W1Store::store_base_dir = DEFAULT_STORAGE_BASE_DIR;
32 W1Store::W1Store(string device_id,
36 store_file_name = get_file_name(device_id, date_time);
37 log_debug("data file name: %s\n", store_file_name.c_str());
40 W1Store::W1Store(string file_name_param) {
43 store_file_name = file_name_param;
47 if (store_data != NULL) {
53 void W1Store::set_base_dir_name(string store_param) {
57 pos = store_param.find_last_of("/");
58 b_count = store_param.length();
59 if (pos == (b_count - 1)) {
60 store_base_dir = store_param;
63 store_base_dir = store_param + "/";
67 string W1Store::get_base_dir_name() {
68 return store_base_dir;
71 string W1Store::get_dir_name(string device_id, Date *date_time) {
75 snprintf(buffer, 30, "%d/%02d", date_time->year, date_time->month);
76 ret_val = W1Util::concat_paths(store_base_dir, device_id);
77 ret_val = ret_val + "/" + buffer;
81 string W1Store::get_file_name(string device_id, Date *date_time) {
86 snprintf(buffer, 30, "%d-%02d-%02d", date_time->year, date_time->month, date_time->day);
88 fname = fname + DATAFILE_SUFFIX;
89 ret_val = get_dir_name(device_id, date_time);
90 ret_val = W1Util::concat_paths(ret_val, fname);
94 void W1Store::store(std::string device_id,
95 std::list<std::string> *string_list) {
102 f_path = get_file_name(device_id, date);
103 ostream = W1Util::open_for_writing(f_path.c_str());
104 // TODO: add mutex to protect string_list while it's read and emptied
105 if (ostream != NULL) {
106 if (ostream->is_open()) {
107 log_info("[%s] writing %d data values to file: %s\n", device_id.c_str(), string_list->size(), f_path.c_str());
108 while(string_list->size() > 0) {
109 line = string_list->front();
110 string_list->pop_front();
111 if (line.length() > 0) {
112 log_debug("storing line: %s\n", line.c_str());
113 *ostream << line << endl;
119 log_error("[%s] Could not store data to file: %s\n", device_id.c_str(), f_path.c_str());
124 log_error("[%s] Could not store data to file: %s\n", device_id.c_str(), f_path.c_str());
129 void W1Store::load() {
134 if (store_data != NULL) {
138 in.open(store_file_name.c_str());
139 if (in.is_open() == true) {
140 while (in.eof() == false) {
142 data = Data::parse_data_string(line);
143 if (store_data == NULL) {
144 store_data = new DataRange(*data);
147 store_data->add_data(*data);
154 Data *W1Store::get_sum() {
166 if (store_data == NULL) {
169 if (store_data != NULL) {
170 row_count = store_data->get_data_row_count();
171 log_debug("data row count: %d\n", row_count);
173 col_count = store_data->get_data_column_count();
174 log_debug("data item count per row: %d\n", col_count);
175 ret_val = new Data(col_count);
177 for (ii = 0; ii < row_count - 1; ii++) {
178 data = store_data->get_data(ii);
179 for (jj = 0; jj < col_count; jj++) {
180 new_val = data->value_arr[jj];
181 ret_val->value_arr[jj] = ret_val->value_arr[jj] + new_val;
183 if (ii < (row_count - 2)) {
187 //log_debug("new val: %f, sum: %f\n", new_val, sum);
190 ret_val->set_date(data->get_date());
199 Data *W1Store::get_delta() {
209 dr = get_oldest_and_newest_data();
211 row_count = dr->get_data_row_count();
212 if (row_count == 2) {
213 o_data = dr->get_data(0);
214 n_data = dr->get_data(1);
215 col_count = dr->get_data_column_count();
216 ret_val = new Data(col_count);
218 for (ii = 0; ii < col_count; ii++) {
219 ret_val->value_arr[ii] = n_data->value_arr[ii] - o_data->value_arr[ii];
222 ret_val->set_date(n_data->get_date());
231 Data *W1Store::get_mean() {
238 if (store_data == NULL) {
241 if (store_data != NULL) {
242 row_count = store_data->get_data_row_count();
244 col_count = store_data->get_data_column_count();
247 for (ii = 0; ii < col_count; ii++) {
248 ret_val->value_arr[ii] = ret_val->value_arr[ii] / row_count;
249 log_debug("avg: %f\n", ret_val->value_arr[ii]);
257 Data *W1Store::get_max() {
270 if (store_data == NULL) {
273 if (store_data != NULL) {
274 row_count = store_data->get_data_row_count();
275 log_debug("data row count: %d\n", row_count);
277 col_count = store_data->get_data_column_count();
278 log_debug("data item count per row: %d\n", col_count);
279 min_val = numeric_limits<double>::min();
280 ret_val = new Data(col_count, min_val);
282 for (ii = 0; ii < row_count - 1; ii++) {
283 data = store_data->get_data(ii);
284 for (jj = 0; jj < col_count; jj++) {
285 new_val = data->value_arr[jj];
286 if (new_val > ret_val->value_arr[jj]) {
287 ret_val->value_arr[jj] = new_val;
290 if (ii < (row_count - 2)) {
296 ret_val->set_date(data->get_date());
305 Data *W1Store::get_min() {
318 if (store_data == NULL) {
321 if (store_data != NULL) {
322 row_count = store_data->get_data_row_count();
323 log_debug("data row count: %d\n", row_count);
325 col_count = store_data->get_data_column_count();
326 log_debug("data item count per row: %d\n", col_count);
327 max_val = numeric_limits<double>::max();
328 ret_val = new Data(col_count, max_val);
330 for (ii = 0; ii < row_count - 1; ii++) {
331 data = store_data->get_data(ii);
332 for (jj = 0; jj < col_count; jj++) {
333 new_val = data->value_arr[jj];
334 if (new_val < ret_val->value_arr[jj]) {
335 ret_val->value_arr[jj] = new_val;
338 if (ii < (row_count - 2)) {
344 ret_val->set_date(data->get_date());
353 DataRange *W1Store::get_oldest_and_newest_data() {
366 if (store_data != NULL) {
367 row_count = store_data->get_data_row_count();
369 o_data = store_data->get_data(0);
370 n_data = store_data->get_data(row_count - 1);
374 if (range_data != NULL) {
375 row_count = range_data->get_data_row_count();
377 o_data = range_data->get_data(0);
378 n_data = range_data->get_data(row_count - 1);
382 in.open(store_file_name.c_str());
383 while (in.eof() == false) {
385 if (line.empty() == false) {
386 if (o_data == NULL) {
387 o_data = Data::parse_data_string(line);
392 if (prev_line.empty() == false) {
393 n_data = Data::parse_data_string(prev_line);
397 if ((o_data != NULL) &&
399 ret_val = new DataRange(*o_data);
400 ret_val->add_data(*n_data);
401 if (range_data != NULL) {
402 range_data = new DataRange(*o_data);
403 range_data->add_data(*n_data);
406 if (o_data != NULL) {
409 if (n_data != NULL) {
415 Data *W1Store::get_oldest_data() {
422 dr = get_oldest_and_newest_data();
424 row_count = dr->get_data_row_count();
425 if (row_count >= 1) {
426 ret_val = dr->get_data(0);
433 Data *W1Store::get_newest_data() {
440 dr = get_oldest_and_newest_data();
442 row_count = dr->get_data_row_count();
443 if (row_count == 2) {
444 ret_val = dr->get_data(1);