diff options
Diffstat (limited to 'navit/map/csv/csv.c')
| -rw-r--r-- | navit/map/csv/csv.c | 1478 |
1 files changed, 714 insertions, 764 deletions
diff --git a/navit/map/csv/csv.c b/navit/map/csv/csv.c index 2726e8ab9..e463985b0 100644 --- a/navit/map/csv/csv.c +++ b/navit/map/csv/csv.c @@ -45,841 +45,791 @@ static int map_id; /*prototypes*/ -static int -csv_coord_set(void *priv_data, struct coord *c, int count, enum change_mode mode); +static int csv_coord_set(void *priv_data, struct coord *c, int count, enum change_mode mode); static struct item * csv_create_item(struct map_rect_priv *mr, enum item_type it_type); static void quadtree_item_free(void *mr, struct quadtree_item *qitem); static void quadtree_item_free_do(void *qitem); -struct quadtree_data -{ - enum item_type type; - int id_lo; - GList* attr_list; - struct item *item; +struct quadtree_data { + enum item_type type; + int id_lo; + GList* attr_list; + struct item *item; }; -struct quadtree_data *quadtree_data_dup(struct quadtree_data *qdata) -{ - struct quadtree_data *ret=g_new0(struct quadtree_data,1); - GList *l; - ret->type=qdata->type; - ret->id_lo=qdata->id_lo; - ret->item=g_new(struct item,1); - *(ret->item)=*(qdata->item); - for(l=qdata->attr_list;l;l=g_list_next(l)) { - ret->attr_list=g_list_prepend(ret->attr_list,attr_dup(l->data)); - } - return ret; +struct quadtree_data *quadtree_data_dup(struct quadtree_data *qdata) { + struct quadtree_data *ret=g_new0(struct quadtree_data,1); + GList *l; + ret->type=qdata->type; + ret->id_lo=qdata->id_lo; + ret->item=g_new(struct item,1); + *(ret->item)=*(qdata->item); + for(l=qdata->attr_list; l; l=g_list_next(l)) { + ret->attr_list=g_list_prepend(ret->attr_list,attr_dup(l->data)); + } + return ret; } -static void -save_map_csv(struct map_priv *m) -{ - if(m->filename && m->dirty) { - char* filename = g_strdup_printf("%s.tmp",m->filename); - FILE* fp; - int ferr = 0; - char *csv_line = 0; - char *tmpstr = 0; - char *oldstr = 0; - struct quadtree_iter *iter; - struct quadtree_item *qitem; - - if( ! (fp=fopen(filename,"w+"))) { - dbg(lvl_error, "Error opening csv file to write new entries"); - return; - } - /*query the world*/ - iter=quadtree_query(m->tree_root, -180, 180, -180, 180, quadtree_item_free, m); - - while((qitem = quadtree_item_next(iter))!=NULL) { - int i; - enum attr_type *at = m->attr_types; - if(qitem->deleted) - continue; - csv_line = NULL; - tmpstr = NULL; - for(i=0;i<m->attr_cnt;++i) { - if(*at == attr_position_latitude) { - tmpstr = g_strdup_printf("%lf",qitem->latitude); - } else if(*at == attr_position_longitude) { - tmpstr = g_strdup_printf("%lf",qitem->longitude); - } else { - GList* attr_list = ((struct quadtree_data*)(qitem->data))->attr_list; - GList* attr_it = attr_list; - struct attr* found_attr = NULL; - /*search attributes*/ - while(attr_it) { - if(((struct attr*)(attr_it->data))->type == *at) { - found_attr = attr_it->data; - break; - } - attr_it = g_list_next(attr_it); - } - if(found_attr) { - if(ATTR_IS_INT(*at)) { - tmpstr = g_strdup_printf("%d", (int)found_attr->u.num); - } else if(ATTR_IS_DOUBLE(*at)) { - tmpstr = g_strdup_printf("%lf", *found_attr->u.numd); - } else if(ATTR_IS_STRING(*at)) { - tmpstr = g_strdup(found_attr->u.str); - } else { - dbg(lvl_error,"Cant represent attribute %s\n",attr_to_name(*at)); - tmpstr=g_strdup(""); - } - } else { - dbg(lvl_debug,"No value defined for the atribute %s, assuming empty string\n",attr_to_name(*at)); - tmpstr=g_strdup(""); - } - } - if(i>0) { - oldstr = csv_line; - csv_line = g_strdup_printf("%s,%s",csv_line,tmpstr); - g_free(tmpstr); - g_free(oldstr); - tmpstr = NULL; - } else { - csv_line=tmpstr; - } - ++at; - } - - if(m->charset) { - tmpstr=g_convert(csv_line, -1,m->charset,"utf-8",NULL,NULL,NULL); - if(!tmpstr) - dbg(lvl_error,"Error converting '%s' to %s\n",csv_line, m->charset); - } else - tmpstr=csv_line; - - if(tmpstr && fprintf(fp,"%s\n", tmpstr)<0) { - ferr = 1; - } - g_free(csv_line); - if(m->charset) - g_free(tmpstr); - } - - if(fclose(fp)) { - ferr = 1; - } - - if(! ferr) { - unlink(m->filename); - rename(filename,m->filename); - m->dirty = 0; - } - g_free(filename); - quadtree_query_free(iter); - - } +static void save_map_csv(struct map_priv *m) { + if(m->filename && m->dirty) { + char* filename = g_strdup_printf("%s.tmp",m->filename); + FILE* fp; + int ferr = 0; + char *csv_line = 0; + char *tmpstr = 0; + char *oldstr = 0; + struct quadtree_iter *iter; + struct quadtree_item *qitem; + + if( ! (fp=fopen(filename,"w+"))) { + dbg(lvl_error, "Error opening csv file to write new entries"); + return; + } + /*query the world*/ + iter=quadtree_query(m->tree_root, -180, 180, -180, 180, quadtree_item_free, m); + + while((qitem = quadtree_item_next(iter))!=NULL) { + int i; + enum attr_type *at = m->attr_types; + if(qitem->deleted) + continue; + csv_line = NULL; + tmpstr = NULL; + for(i=0; i<m->attr_cnt; ++i) { + if(*at == attr_position_latitude) { + tmpstr = g_strdup_printf("%lf",qitem->latitude); + } else if(*at == attr_position_longitude) { + tmpstr = g_strdup_printf("%lf",qitem->longitude); + } else { + GList* attr_list = ((struct quadtree_data*)(qitem->data))->attr_list; + GList* attr_it = attr_list; + struct attr* found_attr = NULL; + /*search attributes*/ + while(attr_it) { + if(((struct attr*)(attr_it->data))->type == *at) { + found_attr = attr_it->data; + break; + } + attr_it = g_list_next(attr_it); + } + if(found_attr) { + if(ATTR_IS_INT(*at)) { + tmpstr = g_strdup_printf("%d", (int)found_attr->u.num); + } else if(ATTR_IS_DOUBLE(*at)) { + tmpstr = g_strdup_printf("%lf", *found_attr->u.numd); + } else if(ATTR_IS_STRING(*at)) { + tmpstr = g_strdup(found_attr->u.str); + } else { + dbg(lvl_error,"Cant represent attribute %s",attr_to_name(*at)); + tmpstr=g_strdup(""); + } + } else { + dbg(lvl_debug,"No value defined for the attribute %s, assuming empty string",attr_to_name(*at)); + tmpstr=g_strdup(""); + } + } + if(i>0) { + oldstr = csv_line; + csv_line = g_strdup_printf("%s,%s",csv_line,tmpstr); + g_free(tmpstr); + g_free(oldstr); + tmpstr = NULL; + } else { + csv_line=tmpstr; + } + ++at; + } + + if(m->charset) { + tmpstr=g_convert(csv_line, -1,m->charset,"utf-8",NULL,NULL,NULL); + if(!tmpstr) + dbg(lvl_error,"Error converting '%s' to %s",csv_line, m->charset); + } else + tmpstr=csv_line; + + if(tmpstr && fprintf(fp,"%s\n", tmpstr)<0) { + ferr = 1; + } + g_free(csv_line); + if(m->charset) + g_free(tmpstr); + } + + if(fclose(fp)) { + ferr = 1; + } + + if(! ferr) { + unlink(m->filename); + rename(filename,m->filename); + m->dirty = 0; + } + g_free(filename); + quadtree_query_free(iter); + + } } static const int zoom_max = 18; -static void -map_destroy_csv(struct map_priv *m) -{ - dbg(lvl_debug,"map_destroy_csv\n"); - /*save if changed */ - save_map_csv(m); - g_hash_table_destroy(m->qitem_hash); - quadtree_destroy(m->tree_root); - g_free(m->filename); - g_free(m->charset); - g_free(m->attr_types); - g_free(m); +static void map_destroy_csv(struct map_priv *m) { + dbg(lvl_debug,"map_destroy_csv"); + /*save if changed */ + save_map_csv(m); + g_hash_table_destroy(m->qitem_hash); + quadtree_destroy(m->tree_root); + g_free(m->filename); + g_free(m->charset); + g_free(m->attr_types); + g_free(m); } -static void -csv_coord_rewind(void *priv_data) -{ +static void csv_coord_rewind(void *priv_data) { } -static int -csv_coord_get(void *priv_data, struct coord *c, int count) -{ - struct map_rect_priv *mr=priv_data; - if(mr) { - *c = mr->c; - return 1; - } - else { - return 0; - } +static int csv_coord_get(void *priv_data, struct coord *c, int count) { + struct map_rect_priv *mr=priv_data; + if(mr) { + *c = mr->c; + return 1; + } else { + return 0; + } } -static void -csv_attr_rewind(void *priv_data) -{ - /*TODO implement if needed*/ +static void csv_attr_rewind(void *priv_data) { + /*TODO implement if needed*/ } -static int -csv_attr_get(void *priv_data, enum attr_type attr_type, struct attr *attr) -{ - int i, bAttrFound = 0; - GList* attr_list; - struct map_rect_priv *mr=priv_data; - enum attr_type *at; - if( !mr || !mr->m || !mr->m->attr_types ) { - return 0; - } - - attr_list = ((struct quadtree_data*)(mr->qitem->data))->attr_list; - - if (attr_type == attr_any) { - if (mr->at_iter==NULL) { /*start iteration*/ - mr->at_iter = attr_list; - if (mr->at_iter) { - *attr = *(struct attr*)(mr->at_iter->data); - return 1; - } else { /*empty attr list*/ - mr->at_iter = NULL; - return 0; - } - } else { /*continue iteration*/ - mr->at_iter = g_list_next(mr->at_iter); - if(mr->at_iter) { - *attr = *(struct attr*)mr->at_iter->data; - return 1; - } else { - return 0; - } - } - return 0; - } - - at = mr->m->attr_types; - - for(i=0;i<mr->m->attr_cnt;++i) { - if(*at == attr_type) { - bAttrFound = 1; - break; - } - ++at; - } - - if(!bAttrFound) { - return 0; - } - - while(attr_list) { - if(((struct attr*)attr_list->data)->type == attr_type) { - *attr = *(struct attr*)attr_list->data; - return 1; - } - attr_list = g_list_next(attr_list); - } - return 0; +static int csv_attr_get(void *priv_data, enum attr_type attr_type, struct attr *attr) { + int i, bAttrFound = 0; + GList* attr_list; + struct map_rect_priv *mr=priv_data; + enum attr_type *at; + if( !mr || !mr->m || !mr->m->attr_types ) { + return 0; + } + + attr_list = ((struct quadtree_data*)(mr->qitem->data))->attr_list; + + if (attr_type == attr_any) { + if (mr->at_iter==NULL) { /*start iteration*/ + mr->at_iter = attr_list; + if (mr->at_iter) { + *attr = *(struct attr*)(mr->at_iter->data); + return 1; + } else { /*empty attr list*/ + mr->at_iter = NULL; + return 0; + } + } else { /*continue iteration*/ + mr->at_iter = g_list_next(mr->at_iter); + if(mr->at_iter) { + *attr = *(struct attr*)mr->at_iter->data; + return 1; + } else { + return 0; + } + } + return 0; + } + + at = mr->m->attr_types; + + for(i=0; i<mr->m->attr_cnt; ++i) { + if(*at == attr_type) { + bAttrFound = 1; + break; + } + ++at; + } + + if(!bAttrFound) { + return 0; + } + + while(attr_list) { + if(((struct attr*)attr_list->data)->type == attr_type) { + *attr = *(struct attr*)attr_list->data; + return 1; + } + attr_list = g_list_next(attr_list); + } + return 0; } -static int -csv_attr_set(void *priv_data, struct attr *attr, enum change_mode mode) -{ - struct map_rect_priv* mr; - struct map_priv* m; - int i, bFound; - struct attr *attr_new; - GList *attr_list, *curr_attr_list; - enum attr_type *at; - - mr = (struct map_rect_priv*)priv_data; - if(!mr || !mr->qitem) { - return 0; - } - - m = mr->m; - bFound = 0; - at = m->attr_types; - - /*if attribute is not supported by this csv map return 0*/ - for(i=0;i<m->attr_cnt;++i) { - if(*at==attr->type) { - bFound = 1; - break; - } - ++at; - } - if( ! bFound) { - return 0; - } - m->dirty = 1; - attr_new = attr_dup(attr); - attr_list = ((struct quadtree_data*)(mr->qitem->data))->attr_list; - curr_attr_list = attr_list; - - while(attr_list) { - if(((struct attr*)attr_list->data)->type == attr->type) { - switch(mode) { - case change_mode_delete: - attr_free((struct attr*)attr_list->data); - curr_attr_list = g_list_delete_link(curr_attr_list,attr_list); - m->dirty = 1; - /* FIXME: To preserve consistency, may be the save_map_csv should be called here... */ - attr_free(attr_new); - return 1; - case change_mode_modify: - case change_mode_prepend: - case change_mode_append: - /* replace existing attribute */ - if(attr_list->data) { - attr_free((struct attr*)attr_list->data); - } - attr_list->data = attr_new; - m->dirty = 1; - save_map_csv(m); - return 1; - default: - attr_free(attr_new); - return 0; - } - } - attr_list = g_list_next(attr_list); - } - - if( mode==change_mode_modify || mode==change_mode_prepend || mode==change_mode_append) { - /* add new attribute */ - curr_attr_list = g_list_prepend(curr_attr_list, attr_new); - ((struct quadtree_data*)(mr->qitem->data))->attr_list = curr_attr_list; - m->dirty = 1; - save_map_csv(m); - return 1; - } - attr_free(attr_new); - return 0; +static int csv_attr_set(void *priv_data, struct attr *attr, enum change_mode mode) { + struct map_rect_priv* mr; + struct map_priv* m; + int i, bFound; + struct attr *attr_new; + GList *attr_list, *curr_attr_list; + enum attr_type *at; + + mr = (struct map_rect_priv*)priv_data; + if(!mr || !mr->qitem) { + return 0; + } + + m = mr->m; + bFound = 0; + at = m->attr_types; + + /*if attribute is not supported by this csv map return 0*/ + for(i=0; i<m->attr_cnt; ++i) { + if(*at==attr->type) { + bFound = 1; + break; + } + ++at; + } + if( ! bFound) { + return 0; + } + m->dirty = 1; + attr_new = attr_dup(attr); + attr_list = ((struct quadtree_data*)(mr->qitem->data))->attr_list; + curr_attr_list = attr_list; + + while(attr_list) { + if(((struct attr*)attr_list->data)->type == attr->type) { + switch(mode) { + case change_mode_delete: + attr_free((struct attr*)attr_list->data); + curr_attr_list = g_list_delete_link(curr_attr_list,attr_list); + m->dirty = 1; + /* FIXME: To preserve consistency, may be the save_map_csv should be called here... */ + attr_free(attr_new); + return 1; + case change_mode_modify: + case change_mode_prepend: + case change_mode_append: + /* replace existing attribute */ + if(attr_list->data) { + attr_free((struct attr*)attr_list->data); + } + attr_list->data = attr_new; + m->dirty = 1; + save_map_csv(m); + return 1; + default: + attr_free(attr_new); + return 0; + } + } + attr_list = g_list_next(attr_list); + } + + if( mode==change_mode_modify || mode==change_mode_prepend || mode==change_mode_append) { + /* add new attribute */ + curr_attr_list = g_list_prepend(curr_attr_list, attr_new); + ((struct quadtree_data*)(mr->qitem->data))->attr_list = curr_attr_list; + m->dirty = 1; + save_map_csv(m); + return 1; + } + attr_free(attr_new); + return 0; } -static int -csv_type_set(void *priv_data, enum item_type type) -{ - struct map_rect_priv* mr = (struct map_rect_priv*)priv_data; - dbg(lvl_debug,"Enter %d\n", type); +static int csv_type_set(void *priv_data, enum item_type type) { + struct map_rect_priv* mr = (struct map_rect_priv*)priv_data; + dbg(lvl_debug,"Enter %d", type); - if(!mr || !mr->qitem) { - dbg(lvl_debug,"Nothing to do\n"); - return 0; - } + if(!mr || !mr->qitem) { + dbg(lvl_debug,"Nothing to do"); + return 0; + } - if(type!=type_none) - return 0; + if(type!=type_none) + return 0; - mr->qitem->deleted=1; - dbg(lvl_debug,"Item %p is deleted\n",mr->qitem); + mr->qitem->deleted=1; + dbg(lvl_debug,"Item %p is deleted",mr->qitem); - return 1; + return 1; } static struct item_methods methods_csv = { - csv_coord_rewind, - csv_coord_get, - csv_attr_rewind, - csv_attr_get, - NULL, - csv_attr_set, - csv_coord_set, - csv_type_set + csv_coord_rewind, + csv_coord_get, + csv_attr_rewind, + csv_attr_get, + NULL, + csv_attr_set, + csv_coord_set, + csv_type_set }; /* * Sets coordinate of an existing item (either on the new list or an item with coord ) */ -static int -csv_coord_set(void *priv_data, struct coord *c, int count, enum change_mode mode) -{ - struct quadtree_item query_item, *insert_item, *query_res; - struct coord_geo cg; - struct map_rect_priv* mr; - struct map_priv* m; - struct quadtree_item* qi; - GList* new_it; - dbg(lvl_debug,"Set coordinates %d %d\n", c->x, c->y); - - /* for now we only support coord modification only */ - if( ! change_mode_modify) { - return 0; - } - /* csv driver supports one coord per record only */ - if( count != 1) { - return 0; - } - - /* get curr_item of given map_rect */ - mr = (struct map_rect_priv*)priv_data; - m = mr->m; - - if(!mr->qitem) { - return 0; - } - - qi = mr->qitem; - - transform_to_geo(projection_mg, &c[0], &cg); - - /* if it is on the new list remove from new list and add it to the tree with the coord */ - new_it = m->new_items; - while(new_it) { - if(new_it->data==qi) { - break; - } - new_it = g_list_next(new_it); - } - if(new_it) { - qi->longitude = cg.lng; - qi->latitude = cg.lat; - quadtree_add( m->tree_root, qi, mr->qiter); - dbg(lvl_debug,"Set coordinates %f %f\n", cg.lng, cg.lat); - m->new_items = g_list_remove_link(m->new_items,new_it); - m->dirty=1; - save_map_csv(m); - return 1; - } - - /* else update quadtree item with the new coord - remove item from the quadtree */ - query_item.longitude = cg.lng; - query_item.latitude = cg.lat; - query_res = quadtree_find_item(m->tree_root, &query_item); - if(!query_res) { - return 0; - } - quadtree_delete_item(m->tree_root, query_res); - /* add item to the tree with the new coord */ - insert_item=g_new0(struct quadtree_item,1); - insert_item->data=quadtree_data_dup(query_res->data); - insert_item->longitude = cg.lng; - insert_item->latitude = cg.lat; - quadtree_add(m->tree_root, query_res, mr->qiter); - - mr->qitem->ref_count--; - mr->qitem=insert_item; - mr->qitem->ref_count++; - - m->dirty = 1; - save_map_csv(m); - return 1; +static int csv_coord_set(void *priv_data, struct coord *c, int count, enum change_mode mode) { + struct quadtree_item query_item, *insert_item, *query_res; + struct coord_geo cg; + struct map_rect_priv* mr; + struct map_priv* m; + struct quadtree_item* qi; + GList* new_it; + dbg(lvl_debug,"Set coordinates %d %d", c->x, c->y); + + /* for now we only support coord modification only */ + if( ! change_mode_modify) { + return 0; + } + /* csv driver supports one coord per record only */ + if( count != 1) { + return 0; + } + + /* get curr_item of given map_rect */ + mr = (struct map_rect_priv*)priv_data; + m = mr->m; + + if(!mr->qitem) { + return 0; + } + + qi = mr->qitem; + + transform_to_geo(projection_mg, &c[0], &cg); + + /* if it is on the new list remove from new list and add it to the tree with the coord */ + new_it = m->new_items; + while(new_it) { + if(new_it->data==qi) { + break; + } + new_it = g_list_next(new_it); + } + if(new_it) { + qi->longitude = cg.lng; + qi->latitude = cg.lat; + quadtree_add( m->tree_root, qi, mr->qiter); + dbg(lvl_debug,"Set coordinates %f %f", cg.lng, cg.lat); + m->new_items = g_list_remove_link(m->new_items,new_it); + m->dirty=1; + save_map_csv(m); + return 1; + } + + /* else update quadtree item with the new coord + remove item from the quadtree */ + query_item.longitude = cg.lng; + query_item.latitude = cg.lat; + query_res = quadtree_find_item(m->tree_root, &query_item); + if(!query_res) { + return 0; + } + quadtree_delete_item(m->tree_root, query_res); + /* add item to the tree with the new coord */ + insert_item=g_new0(struct quadtree_item,1); + insert_item->data=quadtree_data_dup(query_res->data); + insert_item->longitude = cg.lng; + insert_item->latitude = cg.lat; + quadtree_add(m->tree_root, query_res, mr->qiter); + + mr->qitem->ref_count--; + mr->qitem=insert_item; + mr->qitem->ref_count++; + + m->dirty = 1; + save_map_csv(m); + return 1; } -static void quadtree_item_free(void *this, struct quadtree_item *qitem) -{ - struct map_priv* m=this; - struct quadtree_data * qdata=qitem->data; - if(m) { - g_hash_table_remove(m->qitem_hash,&(qdata->item->id_lo)); - } +static void quadtree_item_free(void *this, struct quadtree_item *qitem) { + struct map_priv* m=this; + struct quadtree_data * qdata=qitem->data; + if(m) { + g_hash_table_remove(m->qitem_hash,&(qdata->item->id_lo)); + } } -static void quadtree_item_free_do(void *data) -{ - struct quadtree_item *qitem=data; - GList* attr_it; - struct attr* attr; - struct quadtree_data * qdata=qitem->data; - if(qdata) { - for(attr_it = qdata->attr_list;attr_it;attr_it = g_list_next(attr_it)) { - attr = attr_it->data; - attr_free(attr); - } - g_list_free(qdata->attr_list); - g_free(qdata->item); - g_free(qitem->data); - } - g_free(data); +static void quadtree_item_free_do(void *data) { + struct quadtree_item *qitem=data; + GList* attr_it; + struct attr* attr; + struct quadtree_data * qdata=qitem->data; + if(qdata) { + for(attr_it = qdata->attr_list; attr_it; attr_it = g_list_next(attr_it)) { + attr = attr_it->data; + attr_free(attr); + } + g_list_free(qdata->attr_list); + g_free(qdata->item); + g_free(qitem->data); + } + g_free(data); } -static void map_csv_debug_dump_hash_item(gpointer key, gpointer value, gpointer user_data) -{ - struct quadtree_item *qi=value; - GList *attrs; - dbg(lvl_debug,"%p del=%d ref=%d\n", qi,qi->deleted, qi->ref_count); - attrs=((struct quadtree_data *)qi->data)->attr_list; - while(attrs) { - if(((struct attr*)attrs->data)->type==attr_label) - dbg(lvl_debug,"... %s\n",((struct attr*)attrs->data)->u.str); - attrs=g_list_next(attrs); - } +static void map_csv_debug_dump_hash_item(gpointer key, gpointer value, gpointer user_data) { + struct quadtree_item *qi=value; + GList *attrs; + dbg(lvl_debug,"%p del=%d ref=%d", qi,qi->deleted, qi->ref_count); + attrs=((struct quadtree_data *)qi->data)->attr_list; + while(attrs) { + if(((struct attr*)attrs->data)->type==attr_label) + dbg(lvl_debug,"... %s",((struct attr*)attrs->data)->u.str); + attrs=g_list_next(attrs); + } } /** * Dump all map data (including deleted items) to the log. */ -static void map_csv_debug_dump(struct map_priv *map) -{ - g_hash_table_foreach(map->qitem_hash, map_csv_debug_dump_hash_item, NULL); +static void map_csv_debug_dump(struct map_priv *map) { + g_hash_table_foreach(map->qitem_hash, map_csv_debug_dump_hash_item, NULL); } -static struct map_rect_priv * -map_rect_new_csv(struct map_priv *map, struct map_selection *sel) -{ - struct map_rect_priv *mr; - struct coord_geo lu; - struct coord_geo rl; - struct quadtree_iter *res = NULL; - dbg(lvl_debug,"map_rect_new_csv\n"); - if(debug_level_get("map_csv")>2) { - map_csv_debug_dump(map); - } - mr=g_new0(struct map_rect_priv, 1); - mr->m=map; - mr->bStarted = 0; - mr->sel=sel; - if (map->flags & 1) - mr->item.id_hi=1; - else - mr->item.id_hi=0; - mr->item.id_lo=0; - mr->item.meth=&methods_csv; - mr->item.priv_data=mr; - - if(!sel) { - lu.lng=-180; - lu.lat=180; - rl.lng=180; - rl.lat=-180; - } else { - transform_to_geo(projection_mg, &sel->u.c_rect.lu, &lu); - transform_to_geo(projection_mg, &sel->u.c_rect.rl, &rl); - } - res=quadtree_query(map->tree_root, lu.lng, rl.lng, rl.lat, lu.lat, quadtree_item_free, mr->m); - mr->qiter = res; - mr->qitem = NULL; - return mr; +static struct map_rect_priv *map_rect_new_csv(struct map_priv *map, struct map_selection *sel) { + struct map_rect_priv *mr; + struct coord_geo lu; + struct coord_geo rl; + struct quadtree_iter *res = NULL; + dbg(lvl_debug,"map_rect_new_csv"); + if(debug_level_get("map_csv")>2) { + map_csv_debug_dump(map); + } + mr=g_new0(struct map_rect_priv, 1); + mr->m=map; + mr->bStarted = 0; + mr->sel=sel; + if (map->flags & 1) + mr->item.id_hi=1; + else + mr->item.id_hi=0; + mr->item.id_lo=0; + mr->item.meth=&methods_csv; + mr->item.priv_data=mr; + + if(!sel) { + lu.lng=-180; + lu.lat=180; + rl.lng=180; + rl.lat=-180; + } else { + transform_to_geo(projection_mg, &sel->u.c_rect.lu, &lu); + transform_to_geo(projection_mg, &sel->u.c_rect.rl, &rl); + } + res=quadtree_query(map->tree_root, lu.lng, rl.lng, rl.lat, lu.lat, quadtree_item_free, mr->m); + mr->qiter = res; + mr->qitem = NULL; + return mr; } -static void -map_rect_destroy_csv(struct map_rect_priv *mr) -{ - if(mr->qitem) - mr->qitem->ref_count--; +static void map_rect_destroy_csv(struct map_rect_priv *mr) { + if(mr->qitem) + mr->qitem->ref_count--; - if(mr->qiter) - quadtree_query_free(mr->qiter); + if(mr->qiter) + quadtree_query_free(mr->qiter); - g_free(mr); + g_free(mr); } -static struct item * -map_rect_get_item_csv(struct map_rect_priv *mr) -{ - - if(mr->qitem) - mr->qitem->ref_count--; - - mr->qitem=quadtree_item_next(mr->qiter); - - if(mr->qitem) { - struct item* ret=&(mr->item); - struct coord_geo cg; - mr->qitem->ref_count++; - mr->item = *(((struct quadtree_data*)(mr->qitem->data))->item); - ret->priv_data=mr; - cg.lng = mr->qitem->longitude; - cg.lat = mr->qitem->latitude; - transform_from_geo(projection_mg, &cg, &mr->c); - return ret; - } - return NULL; +static struct item *map_rect_get_item_csv(struct map_rect_priv *mr) { + + if(mr->qitem) + mr->qitem->ref_count--; + + mr->qitem=quadtree_item_next(mr->qiter); + + if(mr->qitem) { + struct item* ret=&(mr->item); + struct coord_geo cg; + mr->qitem->ref_count++; + mr->item = *(((struct quadtree_data*)(mr->qitem->data))->item); + ret->priv_data=mr; + cg.lng = mr->qitem->longitude; + cg.lat = mr->qitem->latitude; + transform_from_geo(projection_mg, &cg, &mr->c); + return ret; + } + return NULL; } -static struct item * -map_rect_get_item_byid_csv(struct map_rect_priv *mr, int id_hi, int id_lo) -{ - /*currently id_hi is ignored*/ - - struct quadtree_item *qit = g_hash_table_lookup(mr->m->qitem_hash,&id_lo); - - if(mr->qitem ) - mr->qitem->ref_count--; - - if(qit) { - mr->qitem = qit; - mr->qitem->ref_count++; - mr->item=*(((struct quadtree_data*)(qit->data))->item); - mr->item.priv_data=mr; - return &(mr->item); - } else { - mr->qitem = NULL; - return NULL; - } +static struct item *map_rect_get_item_byid_csv(struct map_rect_priv *mr, int id_hi, int id_lo) { + /*currently id_hi is ignored*/ + + struct quadtree_item *qit = g_hash_table_lookup(mr->m->qitem_hash,&id_lo); + + if(mr->qitem ) + mr->qitem->ref_count--; + + if(qit) { + mr->qitem = qit; + mr->qitem->ref_count++; + mr->item=*(((struct quadtree_data*)(qit->data))->item); + mr->item.priv_data=mr; + return &(mr->item); + } else { + mr->qitem = NULL; + return NULL; + } } -static int -csv_get_attr(struct map_priv *m, enum attr_type type, struct attr *attr) -{ - return 0; +static int csv_get_attr(struct map_priv *m, enum attr_type type, struct attr *attr) { + return 0; } -static struct item * -csv_create_item(struct map_rect_priv *mr, enum item_type it_type) -{ - struct map_priv* m; - struct quadtree_data* qd; - struct quadtree_item* qi; - struct item* curr_item; - int* pID; - if(mr && mr->m) { - m = mr->m; - } - else { - return NULL; - } - - if( m->item_type != it_type) { - return NULL; - } - - m->dirty = 1; - /*add item to the map*/ - curr_item = item_new("",zoom_max); - curr_item->type = m->item_type; - curr_item->meth=&methods_csv; - - curr_item->id_lo = m->next_item_idx; - if (m->flags & 1) - curr_item->id_hi=1; - else - curr_item->id_hi=0; - - qd = g_new0(struct quadtree_data,1); - qi = g_new0(struct quadtree_item,1); - qd->item = curr_item; - qd->attr_list = NULL; - qi->data = qd; - /*we don`t have valid coord yet*/ - qi->longitude = 0; - qi->latitude = 0; - /*add the coord less item to the new list*/ - m->new_items = g_list_prepend(m->new_items, qi); - if(mr->qitem) - mr->qitem->ref_count--; - mr->qitem=qi; - mr->item=*curr_item; - mr->item.priv_data=mr; - mr->qitem->ref_count++; - /*don't add to the quadtree yet, wait until we have a valid coord*/ - pID = g_new(int,1); - *pID = m->next_item_idx; - g_hash_table_insert(m->qitem_hash, pID,qi); - ++m->next_item_idx; - return &mr->item; +static struct item *csv_create_item(struct map_rect_priv *mr, enum item_type it_type) { + struct map_priv* m; + struct quadtree_data* qd; + struct quadtree_item* qi; + struct item* curr_item; + int* pID; + if(mr && mr->m) { + m = mr->m; + } else { + return NULL; + } + + if( m->item_type != it_type) { + return NULL; + } + + m->dirty = 1; + /*add item to the map*/ + curr_item = item_new("",zoom_max); + curr_item->type = m->item_type; + curr_item->meth=&methods_csv; + + curr_item->id_lo = m->next_item_idx; + if (m->flags & 1) + curr_item->id_hi=1; + else + curr_item->id_hi=0; + + qd = g_new0(struct quadtree_data,1); + qi = g_new0(struct quadtree_item,1); + qd->item = curr_item; + qd->attr_list = NULL; + qi->data = qd; + /*we don`t have valid coord yet*/ + qi->longitude = 0; + qi->latitude = 0; + /*add the coord less item to the new list*/ + m->new_items = g_list_prepend(m->new_items, qi); + if(mr->qitem) + mr->qitem->ref_count--; + mr->qitem=qi; + mr->item=*curr_item; + mr->item.priv_data=mr; + mr->qitem->ref_count++; + /*don't add to the quadtree yet, wait until we have a valid coord*/ + pID = g_new(int,1); + *pID = m->next_item_idx; + g_hash_table_insert(m->qitem_hash, pID,qi); + ++m->next_item_idx; + return &mr->item; } static struct map_methods map_methods_csv = { - projection_mg, - "utf-8", - map_destroy_csv, - map_rect_new_csv, - map_rect_destroy_csv, - map_rect_get_item_csv, - map_rect_get_item_byid_csv, - NULL, - NULL, - NULL, - csv_create_item, - csv_get_attr, + projection_mg, + "utf-8", + map_destroy_csv, + map_rect_new_csv, + map_rect_destroy_csv, + map_rect_get_item_csv, + map_rect_get_item_byid_csv, + NULL, + NULL, + NULL, + csv_create_item, + csv_get_attr, }; -static struct map_priv * -map_new_csv(struct map_methods *meth, struct attr **attrs, struct callback_list *cbl) -{ - struct map_priv *m = NULL; - struct attr *attr_types; - struct attr *item_type_attr; - struct attr *data; - struct attr *flags; - struct attr *charset; - int bLonFound = 0; - int bLatFound = 0; - int attr_cnt = 0; - enum attr_type* attr_type_list = NULL; - struct quadtree_node* tree_root = quadtree_node_new(NULL,-180,180,-180,180); - m = g_new0(struct map_priv, 1); - m->id = ++map_id; - m->qitem_hash = g_hash_table_new_full(g_int_hash, g_int_equal, g_free, quadtree_item_free_do); - m->tree_root = tree_root; - - attr_types = attr_search(attrs, NULL, attr_attr_types); - if(attr_types) { - enum attr_type* at = attr_types->u.attr_types; - while(*at != attr_none) { - attr_type_list = g_realloc(attr_type_list,sizeof(enum attr_type)*(attr_cnt+1)); - attr_type_list[attr_cnt] = *at; - if(*at==attr_position_latitude) { - bLatFound = 1; - } - else if(*at==attr_position_longitude) { - bLonFound = 1; - } - ++attr_cnt; - ++at; - } - m->attr_cnt = attr_cnt; - m->attr_types = attr_type_list; - } else { - m->attr_types = NULL; - return NULL; - } - - charset = attr_search(attrs, NULL, attr_charset); - if(charset) { - dbg(lvl_debug,"charset:%s\n",charset->u.str); - m->charset=g_strdup(charset->u.str); - } else { - m->charset=g_strdup(map_methods_csv.charset); - } - - if(bLonFound==0 || bLatFound==0) { - return NULL; - } - - item_type_attr=attr_search(attrs, NULL, attr_item_type); - - if( !item_type_attr || item_type_attr->u.item_type==type_none) { - return NULL; - } - - m->item_type = item_type_attr->u.item_type; - - flags=attr_search(attrs, NULL, attr_flags); - if (flags) - m->flags=flags->u.num; - - *meth = map_methods_csv; - - data=attr_search(attrs, NULL, attr_data); - - if(data) { - struct file_wordexp *wexp; - char **wexp_data; - FILE *fp; - wexp=file_wordexp_new(data->u.str); - wexp_data=file_wordexp_get_array(wexp); - dbg(lvl_debug,"map_new_csv %s\n", data->u.str); - m->filename=g_strdup(wexp_data[0]); - file_wordexp_destroy(wexp); - - /*load csv file into quadtree structure*/ - /*if column number is wrong skip*/ - if((fp=fopen(m->filename,"rt"))) { - const int max_line_len = 256; - char *linebuf=g_alloca(sizeof(char)*max_line_len); - while(!feof(fp)) { - if(fgets(linebuf,max_line_len,fp)) { - char *line=g_convert(linebuf, -1,"utf-8",m->charset,NULL,NULL,NULL); - char *line2=NULL; - char *delim = ","; - int col_cnt=0; - char *tok; - if(!line) { - dbg(lvl_error,"Error converting '%s' to utf-8 from %s\n",linebuf, m->charset); - continue; - } - if(line[strlen(line)-1]=='\n' || line[strlen(line)-1]=='\r') { - line[strlen(line)-1] = '\0'; - } - line2 = g_strdup(line); - while((tok=strtok( (col_cnt==0)?line:NULL , delim))) { - ++col_cnt; - } - - if(col_cnt==attr_cnt) { - int cnt = 0; /*index of current attr*/ - char*tok; - GList* attr_list = NULL; - int bAddSum = 1; - double longitude = 0.0, latitude=0.0; - struct item *curr_item = item_new("",zoom_max);/*does not use parameters*/ - - curr_item->type = item_type_attr->u.item_type; - curr_item->id_lo = m->next_item_idx; - if (m->flags & 1) - curr_item->id_hi=1; - else - curr_item->id_hi=0; - curr_item->meth=&methods_csv; - - - while((tok=strtok( (cnt==0)?line2:NULL , delim))) { - struct attr*curr_attr = g_new0(struct attr,1); - int bAdd = 1; - curr_attr->type = attr_types->u.attr_types[cnt]; - if(ATTR_IS_STRING(attr_types->u.attr_types[cnt])) { - curr_attr->u.str = g_strdup(tok); - } - else if(ATTR_IS_INT(attr_types->u.attr_types[cnt])) { - curr_attr->u.num = atoi(tok); - } - else if(ATTR_IS_DOUBLE(attr_types->u.attr_types[cnt])) { - double *d = g_new(double,1); - *d = atof(tok); - curr_attr->u.numd = d; - if(attr_types->u.attr_types[cnt] == attr_position_longitude) { - longitude = *d; - } - if(attr_types->u.attr_types[cnt] == attr_position_latitude) { - latitude = *d; - } - } - else { - /*unknown attribute*/ - bAddSum = bAdd = 0; - g_free(curr_attr); - } - - if(bAdd) { - attr_list = g_list_prepend(attr_list, curr_attr); - } - ++cnt; - } - if(bAddSum && (longitude!=0.0 || latitude!=0.0)) { - struct quadtree_data* qd = g_new0(struct quadtree_data,1); - struct quadtree_item* qi =g_new0(struct quadtree_item,1); - int* pID = g_new(int,1); - qd->item = curr_item; - qd->attr_list = attr_list; - qi->data = qd; - qi->longitude = longitude; - qi->latitude = latitude; - quadtree_add(tree_root, qi, NULL); - *pID = m->next_item_idx; - g_hash_table_insert(m->qitem_hash, pID,qi); - ++m->next_item_idx; - dbg(lvl_debug,"%s\n",line); - } - else { - g_free(curr_item); - } - - } - else { - dbg(lvl_error,"ERROR: Non-matching attr count and column count: %d %d SKIPPING line: %s\n",col_cnt, attr_cnt,line); - } - g_free(line); - g_free(line2); - } - } - fclose(fp); - } - else { - dbg(lvl_error,"Error opening csv map file '%s': %s\n", m->filename, strerror(errno)); - return NULL; - } - } else { - dbg(lvl_debug,"No data attribute, starting with in-memory map\n"); - } - - dbg(lvl_info,"%p\n",tree_root); - return m; +static struct map_priv *map_new_csv(struct map_methods *meth, struct attr **attrs, struct callback_list *cbl) { + struct map_priv *m = NULL; + struct attr *attr_types; + struct attr *item_type_attr; + struct attr *data; + struct attr *flags; + struct attr *charset; + int bLonFound = 0; + int bLatFound = 0; + int attr_cnt = 0; + enum attr_type* attr_type_list = NULL; + struct quadtree_node* tree_root = quadtree_node_new(NULL,-180,180,-180,180); + m = g_new0(struct map_priv, 1); + m->id = ++map_id; + m->qitem_hash = g_hash_table_new_full(g_int_hash, g_int_equal, g_free, quadtree_item_free_do); + m->tree_root = tree_root; + + attr_types = attr_search(attrs, NULL, attr_attr_types); + if(attr_types) { + enum attr_type* at = attr_types->u.attr_types; + while(*at != attr_none) { + attr_type_list = g_realloc(attr_type_list,sizeof(enum attr_type)*(attr_cnt+1)); + attr_type_list[attr_cnt] = *at; + if(*at==attr_position_latitude) { + bLatFound = 1; + } else if(*at==attr_position_longitude) { + bLonFound = 1; + } + ++attr_cnt; + ++at; + } + m->attr_cnt = attr_cnt; + m->attr_types = attr_type_list; + } else { + m->attr_types = NULL; + return NULL; + } + + charset = attr_search(attrs, NULL, attr_charset); + if(charset) { + dbg(lvl_debug,"charset:%s",charset->u.str); + m->charset=g_strdup(charset->u.str); + } else { + m->charset=g_strdup(map_methods_csv.charset); + } + + if(bLonFound==0 || bLatFound==0) { + return NULL; + } + + item_type_attr=attr_search(attrs, NULL, attr_item_type); + + if( !item_type_attr || item_type_attr->u.item_type==type_none) { + return NULL; + } + + m->item_type = item_type_attr->u.item_type; + + flags=attr_search(attrs, NULL, attr_flags); + if (flags) + m->flags=flags->u.num; + + *meth = map_methods_csv; + + data=attr_search(attrs, NULL, attr_data); + + if(data) { + struct file_wordexp *wexp; + char **wexp_data; + FILE *fp; + wexp=file_wordexp_new(data->u.str); + wexp_data=file_wordexp_get_array(wexp); + dbg(lvl_debug,"map_new_csv %s", data->u.str); + m->filename=g_strdup(wexp_data[0]); + file_wordexp_destroy(wexp); + + /*load csv file into quadtree structure*/ + /*if column number is wrong skip*/ + if((fp=fopen(m->filename,"rt"))) { + const int max_line_len = 256; + char *linebuf=g_alloca(sizeof(char)*max_line_len); + while(!feof(fp)) { + if(fgets(linebuf,max_line_len,fp)) { + char *line=g_convert(linebuf, -1,"utf-8",m->charset,NULL,NULL,NULL); + char *line2=NULL; + char *delim = ","; + int col_cnt=0; + char *tok; + if(!line) { + dbg(lvl_error,"Error converting '%s' to utf-8 from %s",linebuf, m->charset); + continue; + } + if(line[strlen(line)-1]=='\n' || line[strlen(line)-1]=='\r') { + line[strlen(line)-1] = '\0'; + } + line2 = g_strdup(line); + while((tok=strtok( (col_cnt==0)?line:NULL, delim))) { + ++col_cnt; + } + + if(col_cnt==attr_cnt) { + int cnt = 0; /*index of current attr*/ + char*tok; + GList* attr_list = NULL; + int bAddSum = 1; + double longitude = 0.0, latitude=0.0; + struct item *curr_item = item_new("",zoom_max);/*does not use parameters*/ + + curr_item->type = item_type_attr->u.item_type; + curr_item->id_lo = m->next_item_idx; + if (m->flags & 1) + curr_item->id_hi=1; + else + curr_item->id_hi=0; + curr_item->meth=&methods_csv; + + + while((tok=strtok( (cnt==0)?line2:NULL, delim))) { + struct attr*curr_attr = g_new0(struct attr,1); + int bAdd = 1; + curr_attr->type = attr_types->u.attr_types[cnt]; + if(ATTR_IS_STRING(attr_types->u.attr_types[cnt])) { + curr_attr->u.str = g_strdup(tok); + } else if(ATTR_IS_INT(attr_types->u.attr_types[cnt])) { + curr_attr->u.num = atoi(tok); + } else if(ATTR_IS_DOUBLE(attr_types->u.attr_types[cnt])) { + double *d = g_new(double,1); + *d = atof(tok); + curr_attr->u.numd = d; + if(attr_types->u.attr_types[cnt] == attr_position_longitude) { + longitude = *d; + } + if(attr_types->u.attr_types[cnt] == attr_position_latitude) { + latitude = *d; + } + } else { + /*unknown attribute*/ + bAddSum = bAdd = 0; + g_free(curr_attr); + } + + if(bAdd) { + attr_list = g_list_prepend(attr_list, curr_attr); + } + ++cnt; + } + if(bAddSum && (longitude!=0.0 || latitude!=0.0)) { + struct quadtree_data* qd = g_new0(struct quadtree_data,1); + struct quadtree_item* qi =g_new0(struct quadtree_item,1); + int* pID = g_new(int,1); + qd->item = curr_item; + qd->attr_list = attr_list; + qi->data = qd; + qi->longitude = longitude; + qi->latitude = latitude; + quadtree_add(tree_root, qi, NULL); + *pID = m->next_item_idx; + g_hash_table_insert(m->qitem_hash, pID,qi); + ++m->next_item_idx; + dbg(lvl_debug,"%s",line); + } else { + g_free(curr_item); + } + + } else { + dbg(lvl_error,"ERROR: Non-matching attr count and column count: %d %d SKIPPING line: %s",col_cnt, attr_cnt,line); + } + g_free(line); + g_free(line2); + } + } + fclose(fp); + } else { + dbg(lvl_error,"Error opening csv map file '%s': %s", m->filename, strerror(errno)); + return NULL; + } + } else { + dbg(lvl_debug,"No data attribute, starting with in-memory map"); + } + + dbg(lvl_info,"%p",tree_root); + return m; } -void -plugin_init(void) -{ - dbg(lvl_debug,"csv: plugin_init\n"); - plugin_register_category_map("csv", map_new_csv); +void plugin_init(void) { + dbg(lvl_debug,"csv: plugin_init"); + plugin_register_category_map("csv", map_new_csv); } |