... |
... |
@@ -471,109 +471,109 @@
|
471 |
471 |
std::string _attributes_caption;
|
472 |
472 |
|
473 |
473 |
typedef std::map<std::string, Node> NodeIndex;
|
474 |
474 |
NodeIndex _node_index;
|
475 |
475 |
typedef std::map<std::string, Arc> ArcIndex;
|
476 |
476 |
ArcIndex _arc_index;
|
477 |
477 |
|
478 |
478 |
typedef std::vector<std::pair<std::string,
|
479 |
479 |
_reader_bits::MapStorageBase<Node>*> > NodeMaps;
|
480 |
480 |
NodeMaps _node_maps;
|
481 |
481 |
|
482 |
482 |
typedef std::vector<std::pair<std::string,
|
483 |
483 |
_reader_bits::MapStorageBase<Arc>*> >ArcMaps;
|
484 |
484 |
ArcMaps _arc_maps;
|
485 |
485 |
|
486 |
486 |
typedef std::multimap<std::string, _reader_bits::ValueStorageBase*>
|
487 |
487 |
Attributes;
|
488 |
488 |
Attributes _attributes;
|
489 |
489 |
|
490 |
490 |
bool _use_nodes;
|
491 |
491 |
bool _use_arcs;
|
492 |
492 |
|
493 |
493 |
bool _skip_nodes;
|
494 |
494 |
bool _skip_arcs;
|
495 |
495 |
|
496 |
496 |
int line_num;
|
497 |
497 |
std::istringstream line;
|
498 |
498 |
|
499 |
499 |
public:
|
500 |
500 |
|
501 |
501 |
/// \brief Constructor
|
502 |
502 |
///
|
503 |
503 |
/// Construct a directed graph reader, which reads from the given
|
504 |
504 |
/// input stream.
|
505 |
505 |
DigraphReader(std::istream& is, Digraph& digraph)
|
506 |
506 |
: _is(&is), local_is(false), _digraph(digraph),
|
507 |
507 |
_use_nodes(false), _use_arcs(false),
|
508 |
508 |
_skip_nodes(false), _skip_arcs(false) {}
|
509 |
509 |
|
510 |
510 |
/// \brief Constructor
|
511 |
511 |
///
|
512 |
512 |
/// Construct a directed graph reader, which reads from the given
|
513 |
513 |
/// file.
|
514 |
514 |
DigraphReader(const std::string& fn, Digraph& digraph)
|
515 |
515 |
: _is(new std::ifstream(fn.c_str())), local_is(true),
|
516 |
516 |
_filename(fn), _digraph(digraph),
|
517 |
517 |
_use_nodes(false), _use_arcs(false),
|
518 |
518 |
_skip_nodes(false), _skip_arcs(false) {
|
519 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
519 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
520 |
520 |
}
|
521 |
521 |
|
522 |
522 |
/// \brief Constructor
|
523 |
523 |
///
|
524 |
524 |
/// Construct a directed graph reader, which reads from the given
|
525 |
525 |
/// file.
|
526 |
526 |
DigraphReader(const char* fn, Digraph& digraph)
|
527 |
527 |
: _is(new std::ifstream(fn)), local_is(true),
|
528 |
528 |
_filename(fn), _digraph(digraph),
|
529 |
529 |
_use_nodes(false), _use_arcs(false),
|
530 |
530 |
_skip_nodes(false), _skip_arcs(false) {
|
531 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
531 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
532 |
532 |
}
|
533 |
533 |
|
534 |
534 |
/// \brief Destructor
|
535 |
535 |
~DigraphReader() {
|
536 |
536 |
for (typename NodeMaps::iterator it = _node_maps.begin();
|
537 |
537 |
it != _node_maps.end(); ++it) {
|
538 |
538 |
delete it->second;
|
539 |
539 |
}
|
540 |
540 |
|
541 |
541 |
for (typename ArcMaps::iterator it = _arc_maps.begin();
|
542 |
542 |
it != _arc_maps.end(); ++it) {
|
543 |
543 |
delete it->second;
|
544 |
544 |
}
|
545 |
545 |
|
546 |
546 |
for (typename Attributes::iterator it = _attributes.begin();
|
547 |
547 |
it != _attributes.end(); ++it) {
|
548 |
548 |
delete it->second;
|
549 |
549 |
}
|
550 |
550 |
|
551 |
551 |
if (local_is) {
|
552 |
552 |
delete _is;
|
553 |
553 |
}
|
554 |
554 |
|
555 |
555 |
}
|
556 |
556 |
|
557 |
557 |
private:
|
558 |
558 |
|
559 |
559 |
friend DigraphReader<Digraph> digraphReader<>(std::istream& is,
|
560 |
560 |
Digraph& digraph);
|
561 |
561 |
friend DigraphReader<Digraph> digraphReader<>(const std::string& fn,
|
562 |
562 |
Digraph& digraph);
|
563 |
563 |
friend DigraphReader<Digraph> digraphReader<>(const char *fn,
|
564 |
564 |
Digraph& digraph);
|
565 |
565 |
|
566 |
566 |
DigraphReader(DigraphReader& other)
|
567 |
567 |
: _is(other._is), local_is(other.local_is), _digraph(other._digraph),
|
568 |
568 |
_use_nodes(other._use_nodes), _use_arcs(other._use_arcs),
|
569 |
569 |
_skip_nodes(other._skip_nodes), _skip_arcs(other._skip_arcs) {
|
570 |
570 |
|
571 |
571 |
other._is = 0;
|
572 |
572 |
other.local_is = false;
|
573 |
573 |
|
574 |
574 |
_node_index.swap(other._node_index);
|
575 |
575 |
_arc_index.swap(other._arc_index);
|
576 |
576 |
|
577 |
577 |
_node_maps.swap(other._node_maps);
|
578 |
578 |
_arc_maps.swap(other._arc_maps);
|
579 |
579 |
_attributes.swap(other._attributes);
|
... |
... |
@@ -834,356 +834,353 @@
|
834 |
834 |
}
|
835 |
835 |
|
836 |
836 |
bool readSuccess() {
|
837 |
837 |
return static_cast<bool>(*_is);
|
838 |
838 |
}
|
839 |
839 |
|
840 |
840 |
void skipSection() {
|
841 |
841 |
char c;
|
842 |
842 |
while (readSuccess() && line >> c && c != '@') {
|
843 |
843 |
readLine();
|
844 |
844 |
}
|
845 |
845 |
line.putback(c);
|
846 |
846 |
}
|
847 |
847 |
|
848 |
848 |
void readNodes() {
|
849 |
849 |
|
850 |
850 |
std::vector<int> map_index(_node_maps.size());
|
851 |
851 |
int map_num, label_index;
|
852 |
852 |
|
853 |
853 |
char c;
|
854 |
854 |
if (!readLine() || !(line >> c) || c == '@') {
|
855 |
855 |
if (readSuccess() && line) line.putback(c);
|
856 |
856 |
if (!_node_maps.empty())
|
857 |
857 |
throw FormatError("Cannot find map names");
|
858 |
858 |
return;
|
859 |
859 |
}
|
860 |
860 |
line.putback(c);
|
861 |
861 |
|
862 |
862 |
{
|
863 |
863 |
std::map<std::string, int> maps;
|
864 |
864 |
|
865 |
865 |
std::string map;
|
866 |
866 |
int index = 0;
|
867 |
867 |
while (_reader_bits::readToken(line, map)) {
|
868 |
868 |
if (maps.find(map) != maps.end()) {
|
869 |
869 |
std::ostringstream msg;
|
870 |
870 |
msg << "Multiple occurence of node map: " << map;
|
871 |
871 |
throw FormatError(msg.str());
|
872 |
872 |
}
|
873 |
873 |
maps.insert(std::make_pair(map, index));
|
874 |
874 |
++index;
|
875 |
875 |
}
|
876 |
876 |
|
877 |
877 |
for (int i = 0; i < static_cast<int>(_node_maps.size()); ++i) {
|
878 |
878 |
std::map<std::string, int>::iterator jt =
|
879 |
879 |
maps.find(_node_maps[i].first);
|
880 |
880 |
if (jt == maps.end()) {
|
881 |
881 |
std::ostringstream msg;
|
882 |
|
msg << "Map not found in file: " << _node_maps[i].first;
|
|
882 |
msg << "Map not found: " << _node_maps[i].first;
|
883 |
883 |
throw FormatError(msg.str());
|
884 |
884 |
}
|
885 |
885 |
map_index[i] = jt->second;
|
886 |
886 |
}
|
887 |
887 |
|
888 |
888 |
{
|
889 |
889 |
std::map<std::string, int>::iterator jt = maps.find("label");
|
890 |
890 |
if (jt != maps.end()) {
|
891 |
891 |
label_index = jt->second;
|
892 |
892 |
} else {
|
893 |
893 |
label_index = -1;
|
894 |
894 |
}
|
895 |
895 |
}
|
896 |
896 |
map_num = maps.size();
|
897 |
897 |
}
|
898 |
898 |
|
899 |
899 |
while (readLine() && line >> c && c != '@') {
|
900 |
900 |
line.putback(c);
|
901 |
901 |
|
902 |
902 |
std::vector<std::string> tokens(map_num);
|
903 |
903 |
for (int i = 0; i < map_num; ++i) {
|
904 |
904 |
if (!_reader_bits::readToken(line, tokens[i])) {
|
905 |
905 |
std::ostringstream msg;
|
906 |
906 |
msg << "Column not found (" << i + 1 << ")";
|
907 |
907 |
throw FormatError(msg.str());
|
908 |
908 |
}
|
909 |
909 |
}
|
910 |
910 |
if (line >> std::ws >> c)
|
911 |
|
throw FormatError("Extra character on the end of line");
|
|
911 |
throw FormatError("Extra character at the end of line");
|
912 |
912 |
|
913 |
913 |
Node n;
|
914 |
914 |
if (!_use_nodes) {
|
915 |
915 |
n = _digraph.addNode();
|
916 |
916 |
if (label_index != -1)
|
917 |
917 |
_node_index.insert(std::make_pair(tokens[label_index], n));
|
918 |
918 |
} else {
|
919 |
919 |
if (label_index == -1)
|
920 |
|
throw FormatError("Label map not found in file");
|
|
920 |
throw FormatError("Label map not found");
|
921 |
921 |
typename std::map<std::string, Node>::iterator it =
|
922 |
922 |
_node_index.find(tokens[label_index]);
|
923 |
923 |
if (it == _node_index.end()) {
|
924 |
924 |
std::ostringstream msg;
|
925 |
925 |
msg << "Node with label not found: " << tokens[label_index];
|
926 |
926 |
throw FormatError(msg.str());
|
927 |
927 |
}
|
928 |
928 |
n = it->second;
|
929 |
929 |
}
|
930 |
930 |
|
931 |
931 |
for (int i = 0; i < static_cast<int>(_node_maps.size()); ++i) {
|
932 |
932 |
_node_maps[i].second->set(n, tokens[map_index[i]]);
|
933 |
933 |
}
|
934 |
934 |
|
935 |
935 |
}
|
936 |
936 |
if (readSuccess()) {
|
937 |
937 |
line.putback(c);
|
938 |
938 |
}
|
939 |
939 |
}
|
940 |
940 |
|
941 |
941 |
void readArcs() {
|
942 |
942 |
|
943 |
943 |
std::vector<int> map_index(_arc_maps.size());
|
944 |
944 |
int map_num, label_index;
|
945 |
945 |
|
946 |
946 |
char c;
|
947 |
947 |
if (!readLine() || !(line >> c) || c == '@') {
|
948 |
948 |
if (readSuccess() && line) line.putback(c);
|
949 |
949 |
if (!_arc_maps.empty())
|
950 |
950 |
throw FormatError("Cannot find map names");
|
951 |
951 |
return;
|
952 |
952 |
}
|
953 |
953 |
line.putback(c);
|
954 |
954 |
|
955 |
955 |
{
|
956 |
956 |
std::map<std::string, int> maps;
|
957 |
957 |
|
958 |
958 |
std::string map;
|
959 |
959 |
int index = 0;
|
960 |
960 |
while (_reader_bits::readToken(line, map)) {
|
961 |
961 |
if (maps.find(map) != maps.end()) {
|
962 |
962 |
std::ostringstream msg;
|
963 |
963 |
msg << "Multiple occurence of arc map: " << map;
|
964 |
964 |
throw FormatError(msg.str());
|
965 |
965 |
}
|
966 |
966 |
maps.insert(std::make_pair(map, index));
|
967 |
967 |
++index;
|
968 |
968 |
}
|
969 |
969 |
|
970 |
970 |
for (int i = 0; i < static_cast<int>(_arc_maps.size()); ++i) {
|
971 |
971 |
std::map<std::string, int>::iterator jt =
|
972 |
972 |
maps.find(_arc_maps[i].first);
|
973 |
973 |
if (jt == maps.end()) {
|
974 |
974 |
std::ostringstream msg;
|
975 |
|
msg << "Map not found in file: " << _arc_maps[i].first;
|
|
975 |
msg << "Map not found: " << _arc_maps[i].first;
|
976 |
976 |
throw FormatError(msg.str());
|
977 |
977 |
}
|
978 |
978 |
map_index[i] = jt->second;
|
979 |
979 |
}
|
980 |
980 |
|
981 |
981 |
{
|
982 |
982 |
std::map<std::string, int>::iterator jt = maps.find("label");
|
983 |
983 |
if (jt != maps.end()) {
|
984 |
984 |
label_index = jt->second;
|
985 |
985 |
} else {
|
986 |
986 |
label_index = -1;
|
987 |
987 |
}
|
988 |
988 |
}
|
989 |
989 |
map_num = maps.size();
|
990 |
990 |
}
|
991 |
991 |
|
992 |
992 |
while (readLine() && line >> c && c != '@') {
|
993 |
993 |
line.putback(c);
|
994 |
994 |
|
995 |
995 |
std::string source_token;
|
996 |
996 |
std::string target_token;
|
997 |
997 |
|
998 |
998 |
if (!_reader_bits::readToken(line, source_token))
|
999 |
999 |
throw FormatError("Source not found");
|
1000 |
1000 |
|
1001 |
1001 |
if (!_reader_bits::readToken(line, target_token))
|
1002 |
1002 |
throw FormatError("Target not found");
|
1003 |
1003 |
|
1004 |
1004 |
std::vector<std::string> tokens(map_num);
|
1005 |
1005 |
for (int i = 0; i < map_num; ++i) {
|
1006 |
1006 |
if (!_reader_bits::readToken(line, tokens[i])) {
|
1007 |
1007 |
std::ostringstream msg;
|
1008 |
1008 |
msg << "Column not found (" << i + 1 << ")";
|
1009 |
1009 |
throw FormatError(msg.str());
|
1010 |
1010 |
}
|
1011 |
1011 |
}
|
1012 |
1012 |
if (line >> std::ws >> c)
|
1013 |
|
throw FormatError("Extra character on the end of line");
|
|
1013 |
throw FormatError("Extra character at the end of line");
|
1014 |
1014 |
|
1015 |
1015 |
Arc a;
|
1016 |
1016 |
if (!_use_arcs) {
|
1017 |
1017 |
|
1018 |
1018 |
typename NodeIndex::iterator it;
|
1019 |
1019 |
|
1020 |
1020 |
it = _node_index.find(source_token);
|
1021 |
1021 |
if (it == _node_index.end()) {
|
1022 |
1022 |
std::ostringstream msg;
|
1023 |
1023 |
msg << "Item not found: " << source_token;
|
1024 |
1024 |
throw FormatError(msg.str());
|
1025 |
1025 |
}
|
1026 |
1026 |
Node source = it->second;
|
1027 |
1027 |
|
1028 |
1028 |
it = _node_index.find(target_token);
|
1029 |
1029 |
if (it == _node_index.end()) {
|
1030 |
1030 |
std::ostringstream msg;
|
1031 |
1031 |
msg << "Item not found: " << target_token;
|
1032 |
1032 |
throw FormatError(msg.str());
|
1033 |
1033 |
}
|
1034 |
1034 |
Node target = it->second;
|
1035 |
1035 |
|
1036 |
1036 |
a = _digraph.addArc(source, target);
|
1037 |
1037 |
if (label_index != -1)
|
1038 |
1038 |
_arc_index.insert(std::make_pair(tokens[label_index], a));
|
1039 |
1039 |
} else {
|
1040 |
1040 |
if (label_index == -1)
|
1041 |
|
throw FormatError("Label map not found in file");
|
|
1041 |
throw FormatError("Label map not found");
|
1042 |
1042 |
typename std::map<std::string, Arc>::iterator it =
|
1043 |
1043 |
_arc_index.find(tokens[label_index]);
|
1044 |
1044 |
if (it == _arc_index.end()) {
|
1045 |
1045 |
std::ostringstream msg;
|
1046 |
1046 |
msg << "Arc with label not found: " << tokens[label_index];
|
1047 |
1047 |
throw FormatError(msg.str());
|
1048 |
1048 |
}
|
1049 |
1049 |
a = it->second;
|
1050 |
1050 |
}
|
1051 |
1051 |
|
1052 |
1052 |
for (int i = 0; i < static_cast<int>(_arc_maps.size()); ++i) {
|
1053 |
1053 |
_arc_maps[i].second->set(a, tokens[map_index[i]]);
|
1054 |
1054 |
}
|
1055 |
1055 |
|
1056 |
1056 |
}
|
1057 |
1057 |
if (readSuccess()) {
|
1058 |
1058 |
line.putback(c);
|
1059 |
1059 |
}
|
1060 |
1060 |
}
|
1061 |
1061 |
|
1062 |
1062 |
void readAttributes() {
|
1063 |
1063 |
|
1064 |
1064 |
std::set<std::string> read_attr;
|
1065 |
1065 |
|
1066 |
1066 |
char c;
|
1067 |
1067 |
while (readLine() && line >> c && c != '@') {
|
1068 |
1068 |
line.putback(c);
|
1069 |
1069 |
|
1070 |
1070 |
std::string attr, token;
|
1071 |
1071 |
if (!_reader_bits::readToken(line, attr))
|
1072 |
1072 |
throw FormatError("Attribute name not found");
|
1073 |
1073 |
if (!_reader_bits::readToken(line, token))
|
1074 |
1074 |
throw FormatError("Attribute value not found");
|
1075 |
1075 |
if (line >> c)
|
1076 |
|
throw FormatError("Extra character on the end of line");
|
|
1076 |
throw FormatError("Extra character at the end of line");
|
1077 |
1077 |
|
1078 |
1078 |
{
|
1079 |
1079 |
std::set<std::string>::iterator it = read_attr.find(attr);
|
1080 |
1080 |
if (it != read_attr.end()) {
|
1081 |
1081 |
std::ostringstream msg;
|
1082 |
|
msg << "Multiple occurence of attribute " << attr;
|
|
1082 |
msg << "Multiple occurence of attribute: " << attr;
|
1083 |
1083 |
throw FormatError(msg.str());
|
1084 |
1084 |
}
|
1085 |
1085 |
read_attr.insert(attr);
|
1086 |
1086 |
}
|
1087 |
1087 |
|
1088 |
1088 |
{
|
1089 |
1089 |
typename Attributes::iterator it = _attributes.lower_bound(attr);
|
1090 |
1090 |
while (it != _attributes.end() && it->first == attr) {
|
1091 |
1091 |
it->second->set(token);
|
1092 |
1092 |
++it;
|
1093 |
1093 |
}
|
1094 |
1094 |
}
|
1095 |
1095 |
|
1096 |
1096 |
}
|
1097 |
1097 |
if (readSuccess()) {
|
1098 |
1098 |
line.putback(c);
|
1099 |
1099 |
}
|
1100 |
1100 |
for (typename Attributes::iterator it = _attributes.begin();
|
1101 |
1101 |
it != _attributes.end(); ++it) {
|
1102 |
1102 |
if (read_attr.find(it->first) == read_attr.end()) {
|
1103 |
1103 |
std::ostringstream msg;
|
1104 |
|
msg << "Attribute not found in file: " << it->first;
|
|
1104 |
msg << "Attribute not found: " << it->first;
|
1105 |
1105 |
throw FormatError(msg.str());
|
1106 |
1106 |
}
|
1107 |
1107 |
}
|
1108 |
1108 |
}
|
1109 |
1109 |
|
1110 |
1110 |
public:
|
1111 |
1111 |
|
1112 |
1112 |
/// \name Execution of the reader
|
1113 |
1113 |
/// @{
|
1114 |
1114 |
|
1115 |
1115 |
/// \brief Start the batch processing
|
1116 |
1116 |
///
|
1117 |
1117 |
/// This function starts the batch processing
|
1118 |
1118 |
void run() {
|
1119 |
1119 |
LEMON_ASSERT(_is != 0, "This reader assigned to an other reader");
|
1120 |
|
if (!*_is) {
|
1121 |
|
throw FormatError("Cannot find file");
|
1122 |
|
}
|
1123 |
1120 |
|
1124 |
1121 |
bool nodes_done = _skip_nodes;
|
1125 |
1122 |
bool arcs_done = _skip_arcs;
|
1126 |
1123 |
bool attributes_done = false;
|
1127 |
1124 |
|
1128 |
1125 |
line_num = 0;
|
1129 |
1126 |
readLine();
|
1130 |
1127 |
skipSection();
|
1131 |
1128 |
|
1132 |
1129 |
while (readSuccess()) {
|
1133 |
1130 |
try {
|
1134 |
1131 |
char c;
|
1135 |
1132 |
std::string section, caption;
|
1136 |
1133 |
line >> c;
|
1137 |
1134 |
_reader_bits::readToken(line, section);
|
1138 |
1135 |
_reader_bits::readToken(line, caption);
|
1139 |
1136 |
|
1140 |
1137 |
if (line >> c)
|
1141 |
|
throw FormatError("Extra character on the end of line");
|
|
1138 |
throw FormatError("Extra character at the end of line");
|
1142 |
1139 |
|
1143 |
1140 |
if (section == "nodes" && !nodes_done) {
|
1144 |
1141 |
if (_nodes_caption.empty() || _nodes_caption == caption) {
|
1145 |
1142 |
readNodes();
|
1146 |
1143 |
nodes_done = true;
|
1147 |
1144 |
}
|
1148 |
1145 |
} else if ((section == "arcs" || section == "edges") &&
|
1149 |
1146 |
!arcs_done) {
|
1150 |
1147 |
if (_arcs_caption.empty() || _arcs_caption == caption) {
|
1151 |
1148 |
readArcs();
|
1152 |
1149 |
arcs_done = true;
|
1153 |
1150 |
}
|
1154 |
1151 |
} else if (section == "attributes" && !attributes_done) {
|
1155 |
1152 |
if (_attributes_caption.empty() || _attributes_caption == caption) {
|
1156 |
1153 |
readAttributes();
|
1157 |
1154 |
attributes_done = true;
|
1158 |
1155 |
}
|
1159 |
1156 |
} else {
|
1160 |
1157 |
readLine();
|
1161 |
1158 |
skipSection();
|
1162 |
1159 |
}
|
1163 |
1160 |
} catch (FormatError& error) {
|
1164 |
1161 |
error.line(line_num);
|
1165 |
1162 |
error.file(_filename);
|
1166 |
1163 |
throw;
|
1167 |
1164 |
}
|
1168 |
1165 |
}
|
1169 |
1166 |
|
1170 |
1167 |
if (!nodes_done) {
|
1171 |
1168 |
throw FormatError("Section @nodes not found");
|
1172 |
1169 |
}
|
1173 |
1170 |
|
1174 |
1171 |
if (!arcs_done) {
|
1175 |
1172 |
throw FormatError("Section @arcs not found");
|
1176 |
1173 |
}
|
1177 |
1174 |
|
1178 |
1175 |
if (!attributes_done && !_attributes.empty()) {
|
1179 |
1176 |
throw FormatError("Section @attributes not found");
|
1180 |
1177 |
}
|
1181 |
1178 |
|
1182 |
1179 |
}
|
1183 |
1180 |
|
1184 |
1181 |
/// @}
|
1185 |
1182 |
|
1186 |
1183 |
};
|
1187 |
1184 |
|
1188 |
1185 |
/// \brief Return a \ref DigraphReader class
|
1189 |
1186 |
///
|
... |
... |
@@ -1263,109 +1260,109 @@
|
1263 |
1260 |
std::string _attributes_caption;
|
1264 |
1261 |
|
1265 |
1262 |
typedef std::map<std::string, Node> NodeIndex;
|
1266 |
1263 |
NodeIndex _node_index;
|
1267 |
1264 |
typedef std::map<std::string, Edge> EdgeIndex;
|
1268 |
1265 |
EdgeIndex _edge_index;
|
1269 |
1266 |
|
1270 |
1267 |
typedef std::vector<std::pair<std::string,
|
1271 |
1268 |
_reader_bits::MapStorageBase<Node>*> > NodeMaps;
|
1272 |
1269 |
NodeMaps _node_maps;
|
1273 |
1270 |
|
1274 |
1271 |
typedef std::vector<std::pair<std::string,
|
1275 |
1272 |
_reader_bits::MapStorageBase<Edge>*> > EdgeMaps;
|
1276 |
1273 |
EdgeMaps _edge_maps;
|
1277 |
1274 |
|
1278 |
1275 |
typedef std::multimap<std::string, _reader_bits::ValueStorageBase*>
|
1279 |
1276 |
Attributes;
|
1280 |
1277 |
Attributes _attributes;
|
1281 |
1278 |
|
1282 |
1279 |
bool _use_nodes;
|
1283 |
1280 |
bool _use_edges;
|
1284 |
1281 |
|
1285 |
1282 |
bool _skip_nodes;
|
1286 |
1283 |
bool _skip_edges;
|
1287 |
1284 |
|
1288 |
1285 |
int line_num;
|
1289 |
1286 |
std::istringstream line;
|
1290 |
1287 |
|
1291 |
1288 |
public:
|
1292 |
1289 |
|
1293 |
1290 |
/// \brief Constructor
|
1294 |
1291 |
///
|
1295 |
1292 |
/// Construct an undirected graph reader, which reads from the given
|
1296 |
1293 |
/// input stream.
|
1297 |
1294 |
GraphReader(std::istream& is, Graph& graph)
|
1298 |
1295 |
: _is(&is), local_is(false), _graph(graph),
|
1299 |
1296 |
_use_nodes(false), _use_edges(false),
|
1300 |
1297 |
_skip_nodes(false), _skip_edges(false) {}
|
1301 |
1298 |
|
1302 |
1299 |
/// \brief Constructor
|
1303 |
1300 |
///
|
1304 |
1301 |
/// Construct an undirected graph reader, which reads from the given
|
1305 |
1302 |
/// file.
|
1306 |
1303 |
GraphReader(const std::string& fn, Graph& graph)
|
1307 |
1304 |
: _is(new std::ifstream(fn.c_str())), local_is(true),
|
1308 |
1305 |
_filename(fn), _graph(graph),
|
1309 |
1306 |
_use_nodes(false), _use_edges(false),
|
1310 |
1307 |
_skip_nodes(false), _skip_edges(false) {
|
1311 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
1308 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
1312 |
1309 |
}
|
1313 |
1310 |
|
1314 |
1311 |
/// \brief Constructor
|
1315 |
1312 |
///
|
1316 |
1313 |
/// Construct an undirected graph reader, which reads from the given
|
1317 |
1314 |
/// file.
|
1318 |
1315 |
GraphReader(const char* fn, Graph& graph)
|
1319 |
1316 |
: _is(new std::ifstream(fn)), local_is(true),
|
1320 |
1317 |
_filename(fn), _graph(graph),
|
1321 |
1318 |
_use_nodes(false), _use_edges(false),
|
1322 |
1319 |
_skip_nodes(false), _skip_edges(false) {
|
1323 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
1320 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
1324 |
1321 |
}
|
1325 |
1322 |
|
1326 |
1323 |
/// \brief Destructor
|
1327 |
1324 |
~GraphReader() {
|
1328 |
1325 |
for (typename NodeMaps::iterator it = _node_maps.begin();
|
1329 |
1326 |
it != _node_maps.end(); ++it) {
|
1330 |
1327 |
delete it->second;
|
1331 |
1328 |
}
|
1332 |
1329 |
|
1333 |
1330 |
for (typename EdgeMaps::iterator it = _edge_maps.begin();
|
1334 |
1331 |
it != _edge_maps.end(); ++it) {
|
1335 |
1332 |
delete it->second;
|
1336 |
1333 |
}
|
1337 |
1334 |
|
1338 |
1335 |
for (typename Attributes::iterator it = _attributes.begin();
|
1339 |
1336 |
it != _attributes.end(); ++it) {
|
1340 |
1337 |
delete it->second;
|
1341 |
1338 |
}
|
1342 |
1339 |
|
1343 |
1340 |
if (local_is) {
|
1344 |
1341 |
delete _is;
|
1345 |
1342 |
}
|
1346 |
1343 |
|
1347 |
1344 |
}
|
1348 |
1345 |
|
1349 |
1346 |
private:
|
1350 |
1347 |
friend GraphReader<Graph> graphReader<>(std::istream& is, Graph& graph);
|
1351 |
1348 |
friend GraphReader<Graph> graphReader<>(const std::string& fn,
|
1352 |
1349 |
Graph& graph);
|
1353 |
1350 |
friend GraphReader<Graph> graphReader<>(const char *fn, Graph& graph);
|
1354 |
1351 |
|
1355 |
1352 |
GraphReader(GraphReader& other)
|
1356 |
1353 |
: _is(other._is), local_is(other.local_is), _graph(other._graph),
|
1357 |
1354 |
_use_nodes(other._use_nodes), _use_edges(other._use_edges),
|
1358 |
1355 |
_skip_nodes(other._skip_nodes), _skip_edges(other._skip_edges) {
|
1359 |
1356 |
|
1360 |
1357 |
other._is = 0;
|
1361 |
1358 |
other.local_is = false;
|
1362 |
1359 |
|
1363 |
1360 |
_node_index.swap(other._node_index);
|
1364 |
1361 |
_edge_index.swap(other._edge_index);
|
1365 |
1362 |
|
1366 |
1363 |
_node_maps.swap(other._node_maps);
|
1367 |
1364 |
_edge_maps.swap(other._edge_maps);
|
1368 |
1365 |
_attributes.swap(other._attributes);
|
1369 |
1366 |
|
1370 |
1367 |
_nodes_caption = other._nodes_caption;
|
1371 |
1368 |
_edges_caption = other._edges_caption;
|
... |
... |
@@ -1670,354 +1667,354 @@
|
1670 |
1667 |
}
|
1671 |
1668 |
|
1672 |
1669 |
bool readSuccess() {
|
1673 |
1670 |
return static_cast<bool>(*_is);
|
1674 |
1671 |
}
|
1675 |
1672 |
|
1676 |
1673 |
void skipSection() {
|
1677 |
1674 |
char c;
|
1678 |
1675 |
while (readSuccess() && line >> c && c != '@') {
|
1679 |
1676 |
readLine();
|
1680 |
1677 |
}
|
1681 |
1678 |
line.putback(c);
|
1682 |
1679 |
}
|
1683 |
1680 |
|
1684 |
1681 |
void readNodes() {
|
1685 |
1682 |
|
1686 |
1683 |
std::vector<int> map_index(_node_maps.size());
|
1687 |
1684 |
int map_num, label_index;
|
1688 |
1685 |
|
1689 |
1686 |
char c;
|
1690 |
1687 |
if (!readLine() || !(line >> c) || c == '@') {
|
1691 |
1688 |
if (readSuccess() && line) line.putback(c);
|
1692 |
1689 |
if (!_node_maps.empty())
|
1693 |
1690 |
throw FormatError("Cannot find map names");
|
1694 |
1691 |
return;
|
1695 |
1692 |
}
|
1696 |
1693 |
line.putback(c);
|
1697 |
1694 |
|
1698 |
1695 |
{
|
1699 |
1696 |
std::map<std::string, int> maps;
|
1700 |
1697 |
|
1701 |
1698 |
std::string map;
|
1702 |
1699 |
int index = 0;
|
1703 |
1700 |
while (_reader_bits::readToken(line, map)) {
|
1704 |
1701 |
if (maps.find(map) != maps.end()) {
|
1705 |
1702 |
std::ostringstream msg;
|
1706 |
1703 |
msg << "Multiple occurence of node map: " << map;
|
1707 |
1704 |
throw FormatError(msg.str());
|
1708 |
1705 |
}
|
1709 |
1706 |
maps.insert(std::make_pair(map, index));
|
1710 |
1707 |
++index;
|
1711 |
1708 |
}
|
1712 |
1709 |
|
1713 |
1710 |
for (int i = 0; i < static_cast<int>(_node_maps.size()); ++i) {
|
1714 |
1711 |
std::map<std::string, int>::iterator jt =
|
1715 |
1712 |
maps.find(_node_maps[i].first);
|
1716 |
1713 |
if (jt == maps.end()) {
|
1717 |
1714 |
std::ostringstream msg;
|
1718 |
|
msg << "Map not found in file: " << _node_maps[i].first;
|
|
1715 |
msg << "Map not found: " << _node_maps[i].first;
|
1719 |
1716 |
throw FormatError(msg.str());
|
1720 |
1717 |
}
|
1721 |
1718 |
map_index[i] = jt->second;
|
1722 |
1719 |
}
|
1723 |
1720 |
|
1724 |
1721 |
{
|
1725 |
1722 |
std::map<std::string, int>::iterator jt = maps.find("label");
|
1726 |
1723 |
if (jt != maps.end()) {
|
1727 |
1724 |
label_index = jt->second;
|
1728 |
1725 |
} else {
|
1729 |
1726 |
label_index = -1;
|
1730 |
1727 |
}
|
1731 |
1728 |
}
|
1732 |
1729 |
map_num = maps.size();
|
1733 |
1730 |
}
|
1734 |
1731 |
|
1735 |
1732 |
while (readLine() && line >> c && c != '@') {
|
1736 |
1733 |
line.putback(c);
|
1737 |
1734 |
|
1738 |
1735 |
std::vector<std::string> tokens(map_num);
|
1739 |
1736 |
for (int i = 0; i < map_num; ++i) {
|
1740 |
1737 |
if (!_reader_bits::readToken(line, tokens[i])) {
|
1741 |
1738 |
std::ostringstream msg;
|
1742 |
1739 |
msg << "Column not found (" << i + 1 << ")";
|
1743 |
1740 |
throw FormatError(msg.str());
|
1744 |
1741 |
}
|
1745 |
1742 |
}
|
1746 |
1743 |
if (line >> std::ws >> c)
|
1747 |
|
throw FormatError("Extra character on the end of line");
|
|
1744 |
throw FormatError("Extra character at the end of line");
|
1748 |
1745 |
|
1749 |
1746 |
Node n;
|
1750 |
1747 |
if (!_use_nodes) {
|
1751 |
1748 |
n = _graph.addNode();
|
1752 |
1749 |
if (label_index != -1)
|
1753 |
1750 |
_node_index.insert(std::make_pair(tokens[label_index], n));
|
1754 |
1751 |
} else {
|
1755 |
1752 |
if (label_index == -1)
|
1756 |
|
throw FormatError("Label map not found in file");
|
|
1753 |
throw FormatError("Label map not found");
|
1757 |
1754 |
typename std::map<std::string, Node>::iterator it =
|
1758 |
1755 |
_node_index.find(tokens[label_index]);
|
1759 |
1756 |
if (it == _node_index.end()) {
|
1760 |
1757 |
std::ostringstream msg;
|
1761 |
1758 |
msg << "Node with label not found: " << tokens[label_index];
|
1762 |
1759 |
throw FormatError(msg.str());
|
1763 |
1760 |
}
|
1764 |
1761 |
n = it->second;
|
1765 |
1762 |
}
|
1766 |
1763 |
|
1767 |
1764 |
for (int i = 0; i < static_cast<int>(_node_maps.size()); ++i) {
|
1768 |
1765 |
_node_maps[i].second->set(n, tokens[map_index[i]]);
|
1769 |
1766 |
}
|
1770 |
1767 |
|
1771 |
1768 |
}
|
1772 |
1769 |
if (readSuccess()) {
|
1773 |
1770 |
line.putback(c);
|
1774 |
1771 |
}
|
1775 |
1772 |
}
|
1776 |
1773 |
|
1777 |
1774 |
void readEdges() {
|
1778 |
1775 |
|
1779 |
1776 |
std::vector<int> map_index(_edge_maps.size());
|
1780 |
1777 |
int map_num, label_index;
|
1781 |
1778 |
|
1782 |
1779 |
char c;
|
1783 |
1780 |
if (!readLine() || !(line >> c) || c == '@') {
|
1784 |
1781 |
if (readSuccess() && line) line.putback(c);
|
1785 |
1782 |
if (!_edge_maps.empty())
|
1786 |
1783 |
throw FormatError("Cannot find map names");
|
1787 |
1784 |
return;
|
1788 |
1785 |
}
|
1789 |
1786 |
line.putback(c);
|
1790 |
1787 |
|
1791 |
1788 |
{
|
1792 |
1789 |
std::map<std::string, int> maps;
|
1793 |
1790 |
|
1794 |
1791 |
std::string map;
|
1795 |
1792 |
int index = 0;
|
1796 |
1793 |
while (_reader_bits::readToken(line, map)) {
|
1797 |
1794 |
if (maps.find(map) != maps.end()) {
|
1798 |
1795 |
std::ostringstream msg;
|
1799 |
1796 |
msg << "Multiple occurence of edge map: " << map;
|
1800 |
1797 |
throw FormatError(msg.str());
|
1801 |
1798 |
}
|
1802 |
1799 |
maps.insert(std::make_pair(map, index));
|
1803 |
1800 |
++index;
|
1804 |
1801 |
}
|
1805 |
1802 |
|
1806 |
1803 |
for (int i = 0; i < static_cast<int>(_edge_maps.size()); ++i) {
|
1807 |
1804 |
std::map<std::string, int>::iterator jt =
|
1808 |
1805 |
maps.find(_edge_maps[i].first);
|
1809 |
1806 |
if (jt == maps.end()) {
|
1810 |
1807 |
std::ostringstream msg;
|
1811 |
|
msg << "Map not found in file: " << _edge_maps[i].first;
|
|
1808 |
msg << "Map not found: " << _edge_maps[i].first;
|
1812 |
1809 |
throw FormatError(msg.str());
|
1813 |
1810 |
}
|
1814 |
1811 |
map_index[i] = jt->second;
|
1815 |
1812 |
}
|
1816 |
1813 |
|
1817 |
1814 |
{
|
1818 |
1815 |
std::map<std::string, int>::iterator jt = maps.find("label");
|
1819 |
1816 |
if (jt != maps.end()) {
|
1820 |
1817 |
label_index = jt->second;
|
1821 |
1818 |
} else {
|
1822 |
1819 |
label_index = -1;
|
1823 |
1820 |
}
|
1824 |
1821 |
}
|
1825 |
1822 |
map_num = maps.size();
|
1826 |
1823 |
}
|
1827 |
1824 |
|
1828 |
1825 |
while (readLine() && line >> c && c != '@') {
|
1829 |
1826 |
line.putback(c);
|
1830 |
1827 |
|
1831 |
1828 |
std::string source_token;
|
1832 |
1829 |
std::string target_token;
|
1833 |
1830 |
|
1834 |
1831 |
if (!_reader_bits::readToken(line, source_token))
|
1835 |
1832 |
throw FormatError("Node u not found");
|
1836 |
1833 |
|
1837 |
1834 |
if (!_reader_bits::readToken(line, target_token))
|
1838 |
1835 |
throw FormatError("Node v not found");
|
1839 |
1836 |
|
1840 |
1837 |
std::vector<std::string> tokens(map_num);
|
1841 |
1838 |
for (int i = 0; i < map_num; ++i) {
|
1842 |
1839 |
if (!_reader_bits::readToken(line, tokens[i])) {
|
1843 |
1840 |
std::ostringstream msg;
|
1844 |
1841 |
msg << "Column not found (" << i + 1 << ")";
|
1845 |
1842 |
throw FormatError(msg.str());
|
1846 |
1843 |
}
|
1847 |
1844 |
}
|
1848 |
1845 |
if (line >> std::ws >> c)
|
1849 |
|
throw FormatError("Extra character on the end of line");
|
|
1846 |
throw FormatError("Extra character at the end of line");
|
1850 |
1847 |
|
1851 |
1848 |
Edge e;
|
1852 |
1849 |
if (!_use_edges) {
|
1853 |
1850 |
|
1854 |
1851 |
typename NodeIndex::iterator it;
|
1855 |
1852 |
|
1856 |
1853 |
it = _node_index.find(source_token);
|
1857 |
1854 |
if (it == _node_index.end()) {
|
1858 |
1855 |
std::ostringstream msg;
|
1859 |
1856 |
msg << "Item not found: " << source_token;
|
1860 |
1857 |
throw FormatError(msg.str());
|
1861 |
1858 |
}
|
1862 |
1859 |
Node source = it->second;
|
1863 |
1860 |
|
1864 |
1861 |
it = _node_index.find(target_token);
|
1865 |
1862 |
if (it == _node_index.end()) {
|
1866 |
1863 |
std::ostringstream msg;
|
1867 |
1864 |
msg << "Item not found: " << target_token;
|
1868 |
1865 |
throw FormatError(msg.str());
|
1869 |
1866 |
}
|
1870 |
1867 |
Node target = it->second;
|
1871 |
1868 |
|
1872 |
1869 |
e = _graph.addEdge(source, target);
|
1873 |
1870 |
if (label_index != -1)
|
1874 |
1871 |
_edge_index.insert(std::make_pair(tokens[label_index], e));
|
1875 |
1872 |
} else {
|
1876 |
1873 |
if (label_index == -1)
|
1877 |
|
throw FormatError("Label map not found in file");
|
|
1874 |
throw FormatError("Label map not found");
|
1878 |
1875 |
typename std::map<std::string, Edge>::iterator it =
|
1879 |
1876 |
_edge_index.find(tokens[label_index]);
|
1880 |
1877 |
if (it == _edge_index.end()) {
|
1881 |
1878 |
std::ostringstream msg;
|
1882 |
1879 |
msg << "Edge with label not found: " << tokens[label_index];
|
1883 |
1880 |
throw FormatError(msg.str());
|
1884 |
1881 |
}
|
1885 |
1882 |
e = it->second;
|
1886 |
1883 |
}
|
1887 |
1884 |
|
1888 |
1885 |
for (int i = 0; i < static_cast<int>(_edge_maps.size()); ++i) {
|
1889 |
1886 |
_edge_maps[i].second->set(e, tokens[map_index[i]]);
|
1890 |
1887 |
}
|
1891 |
1888 |
|
1892 |
1889 |
}
|
1893 |
1890 |
if (readSuccess()) {
|
1894 |
1891 |
line.putback(c);
|
1895 |
1892 |
}
|
1896 |
1893 |
}
|
1897 |
1894 |
|
1898 |
1895 |
void readAttributes() {
|
1899 |
1896 |
|
1900 |
1897 |
std::set<std::string> read_attr;
|
1901 |
1898 |
|
1902 |
1899 |
char c;
|
1903 |
1900 |
while (readLine() && line >> c && c != '@') {
|
1904 |
1901 |
line.putback(c);
|
1905 |
1902 |
|
1906 |
1903 |
std::string attr, token;
|
1907 |
1904 |
if (!_reader_bits::readToken(line, attr))
|
1908 |
1905 |
throw FormatError("Attribute name not found");
|
1909 |
1906 |
if (!_reader_bits::readToken(line, token))
|
1910 |
1907 |
throw FormatError("Attribute value not found");
|
1911 |
1908 |
if (line >> c)
|
1912 |
|
throw FormatError("Extra character on the end of line");
|
|
1909 |
throw FormatError("Extra character at the end of line");
|
1913 |
1910 |
|
1914 |
1911 |
{
|
1915 |
1912 |
std::set<std::string>::iterator it = read_attr.find(attr);
|
1916 |
1913 |
if (it != read_attr.end()) {
|
1917 |
1914 |
std::ostringstream msg;
|
1918 |
|
msg << "Multiple occurence of attribute " << attr;
|
|
1915 |
msg << "Multiple occurence of attribute: " << attr;
|
1919 |
1916 |
throw FormatError(msg.str());
|
1920 |
1917 |
}
|
1921 |
1918 |
read_attr.insert(attr);
|
1922 |
1919 |
}
|
1923 |
1920 |
|
1924 |
1921 |
{
|
1925 |
1922 |
typename Attributes::iterator it = _attributes.lower_bound(attr);
|
1926 |
1923 |
while (it != _attributes.end() && it->first == attr) {
|
1927 |
1924 |
it->second->set(token);
|
1928 |
1925 |
++it;
|
1929 |
1926 |
}
|
1930 |
1927 |
}
|
1931 |
1928 |
|
1932 |
1929 |
}
|
1933 |
1930 |
if (readSuccess()) {
|
1934 |
1931 |
line.putback(c);
|
1935 |
1932 |
}
|
1936 |
1933 |
for (typename Attributes::iterator it = _attributes.begin();
|
1937 |
1934 |
it != _attributes.end(); ++it) {
|
1938 |
1935 |
if (read_attr.find(it->first) == read_attr.end()) {
|
1939 |
1936 |
std::ostringstream msg;
|
1940 |
|
msg << "Attribute not found in file: " << it->first;
|
|
1937 |
msg << "Attribute not found: " << it->first;
|
1941 |
1938 |
throw FormatError(msg.str());
|
1942 |
1939 |
}
|
1943 |
1940 |
}
|
1944 |
1941 |
}
|
1945 |
1942 |
|
1946 |
1943 |
public:
|
1947 |
1944 |
|
1948 |
1945 |
/// \name Execution of the reader
|
1949 |
1946 |
/// @{
|
1950 |
1947 |
|
1951 |
1948 |
/// \brief Start the batch processing
|
1952 |
1949 |
///
|
1953 |
1950 |
/// This function starts the batch processing
|
1954 |
1951 |
void run() {
|
1955 |
1952 |
|
1956 |
1953 |
LEMON_ASSERT(_is != 0, "This reader assigned to an other reader");
|
1957 |
1954 |
|
1958 |
1955 |
bool nodes_done = _skip_nodes;
|
1959 |
1956 |
bool edges_done = _skip_edges;
|
1960 |
1957 |
bool attributes_done = false;
|
1961 |
1958 |
|
1962 |
1959 |
line_num = 0;
|
1963 |
1960 |
readLine();
|
1964 |
1961 |
skipSection();
|
1965 |
1962 |
|
1966 |
1963 |
while (readSuccess()) {
|
1967 |
1964 |
try {
|
1968 |
1965 |
char c;
|
1969 |
1966 |
std::string section, caption;
|
1970 |
1967 |
line >> c;
|
1971 |
1968 |
_reader_bits::readToken(line, section);
|
1972 |
1969 |
_reader_bits::readToken(line, caption);
|
1973 |
1970 |
|
1974 |
1971 |
if (line >> c)
|
1975 |
|
throw FormatError("Extra character on the end of line");
|
|
1972 |
throw FormatError("Extra character at the end of line");
|
1976 |
1973 |
|
1977 |
1974 |
if (section == "nodes" && !nodes_done) {
|
1978 |
1975 |
if (_nodes_caption.empty() || _nodes_caption == caption) {
|
1979 |
1976 |
readNodes();
|
1980 |
1977 |
nodes_done = true;
|
1981 |
1978 |
}
|
1982 |
1979 |
} else if ((section == "edges" || section == "arcs") &&
|
1983 |
1980 |
!edges_done) {
|
1984 |
1981 |
if (_edges_caption.empty() || _edges_caption == caption) {
|
1985 |
1982 |
readEdges();
|
1986 |
1983 |
edges_done = true;
|
1987 |
1984 |
}
|
1988 |
1985 |
} else if (section == "attributes" && !attributes_done) {
|
1989 |
1986 |
if (_attributes_caption.empty() || _attributes_caption == caption) {
|
1990 |
1987 |
readAttributes();
|
1991 |
1988 |
attributes_done = true;
|
1992 |
1989 |
}
|
1993 |
1990 |
} else {
|
1994 |
1991 |
readLine();
|
1995 |
1992 |
skipSection();
|
1996 |
1993 |
}
|
1997 |
1994 |
} catch (FormatError& error) {
|
1998 |
1995 |
error.line(line_num);
|
1999 |
1996 |
error.file(_filename);
|
2000 |
1997 |
throw;
|
2001 |
1998 |
}
|
2002 |
1999 |
}
|
2003 |
2000 |
|
2004 |
2001 |
if (!nodes_done) {
|
2005 |
2002 |
throw FormatError("Section @nodes not found");
|
2006 |
2003 |
}
|
2007 |
2004 |
|
2008 |
2005 |
if (!edges_done) {
|
2009 |
2006 |
throw FormatError("Section @edges not found");
|
2010 |
2007 |
}
|
2011 |
2008 |
|
2012 |
2009 |
if (!attributes_done && !_attributes.empty()) {
|
2013 |
2010 |
throw FormatError("Section @attributes not found");
|
2014 |
2011 |
}
|
2015 |
2012 |
|
2016 |
2013 |
}
|
2017 |
2014 |
|
2018 |
2015 |
/// @}
|
2019 |
2016 |
|
2020 |
2017 |
};
|
2021 |
2018 |
|
2022 |
2019 |
/// \brief Return a \ref GraphReader class
|
2023 |
2020 |
///
|
... |
... |
@@ -2050,106 +2047,106 @@
|
2050 |
2047 |
return tmp;
|
2051 |
2048 |
}
|
2052 |
2049 |
|
2053 |
2050 |
class SectionReader;
|
2054 |
2051 |
|
2055 |
2052 |
SectionReader sectionReader(std::istream& is);
|
2056 |
2053 |
SectionReader sectionReader(const std::string& fn);
|
2057 |
2054 |
SectionReader sectionReader(const char* fn);
|
2058 |
2055 |
|
2059 |
2056 |
/// \ingroup lemon_io
|
2060 |
2057 |
///
|
2061 |
2058 |
/// \brief Section reader class
|
2062 |
2059 |
///
|
2063 |
2060 |
/// In the \ref lgf-format "LGF" file extra sections can be placed,
|
2064 |
2061 |
/// which contain any data in arbitrary format. Such sections can be
|
2065 |
2062 |
/// read with this class. A reading rule can be added to the class
|
2066 |
2063 |
/// with two different functions. With the \c sectionLines() function a
|
2067 |
2064 |
/// functor can process the section line-by-line, while with the \c
|
2068 |
2065 |
/// sectionStream() member the section can be read from an input
|
2069 |
2066 |
/// stream.
|
2070 |
2067 |
class SectionReader {
|
2071 |
2068 |
private:
|
2072 |
2069 |
|
2073 |
2070 |
std::istream* _is;
|
2074 |
2071 |
bool local_is;
|
2075 |
2072 |
std::string _filename;
|
2076 |
2073 |
|
2077 |
2074 |
typedef std::map<std::string, _reader_bits::Section*> Sections;
|
2078 |
2075 |
Sections _sections;
|
2079 |
2076 |
|
2080 |
2077 |
int line_num;
|
2081 |
2078 |
std::istringstream line;
|
2082 |
2079 |
|
2083 |
2080 |
public:
|
2084 |
2081 |
|
2085 |
2082 |
/// \brief Constructor
|
2086 |
2083 |
///
|
2087 |
2084 |
/// Construct a section reader, which reads from the given input
|
2088 |
2085 |
/// stream.
|
2089 |
2086 |
SectionReader(std::istream& is)
|
2090 |
2087 |
: _is(&is), local_is(false) {}
|
2091 |
2088 |
|
2092 |
2089 |
/// \brief Constructor
|
2093 |
2090 |
///
|
2094 |
2091 |
/// Construct a section reader, which reads from the given file.
|
2095 |
2092 |
SectionReader(const std::string& fn)
|
2096 |
2093 |
: _is(new std::ifstream(fn.c_str())), local_is(true),
|
2097 |
2094 |
_filename(fn) {
|
2098 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
2095 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
2099 |
2096 |
}
|
2100 |
2097 |
|
2101 |
2098 |
/// \brief Constructor
|
2102 |
2099 |
///
|
2103 |
2100 |
/// Construct a section reader, which reads from the given file.
|
2104 |
2101 |
SectionReader(const char* fn)
|
2105 |
2102 |
: _is(new std::ifstream(fn)), local_is(true),
|
2106 |
2103 |
_filename(fn) {
|
2107 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
2104 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
2108 |
2105 |
}
|
2109 |
2106 |
|
2110 |
2107 |
/// \brief Destructor
|
2111 |
2108 |
~SectionReader() {
|
2112 |
2109 |
for (Sections::iterator it = _sections.begin();
|
2113 |
2110 |
it != _sections.end(); ++it) {
|
2114 |
2111 |
delete it->second;
|
2115 |
2112 |
}
|
2116 |
2113 |
|
2117 |
2114 |
if (local_is) {
|
2118 |
2115 |
delete _is;
|
2119 |
2116 |
}
|
2120 |
2117 |
|
2121 |
2118 |
}
|
2122 |
2119 |
|
2123 |
2120 |
private:
|
2124 |
2121 |
|
2125 |
2122 |
friend SectionReader sectionReader(std::istream& is);
|
2126 |
2123 |
friend SectionReader sectionReader(const std::string& fn);
|
2127 |
2124 |
friend SectionReader sectionReader(const char* fn);
|
2128 |
2125 |
|
2129 |
2126 |
SectionReader(SectionReader& other)
|
2130 |
2127 |
: _is(other._is), local_is(other.local_is) {
|
2131 |
2128 |
|
2132 |
2129 |
other._is = 0;
|
2133 |
2130 |
other.local_is = false;
|
2134 |
2131 |
|
2135 |
2132 |
_sections.swap(other._sections);
|
2136 |
2133 |
}
|
2137 |
2134 |
|
2138 |
2135 |
SectionReader& operator=(const SectionReader&);
|
2139 |
2136 |
|
2140 |
2137 |
public:
|
2141 |
2138 |
|
2142 |
2139 |
/// \name Section readers
|
2143 |
2140 |
/// @{
|
2144 |
2141 |
|
2145 |
2142 |
/// \brief Add a section processor with line oriented reading
|
2146 |
2143 |
///
|
2147 |
2144 |
/// The first parameter is the type descriptor of the section, the
|
2148 |
2145 |
/// second is a functor, which takes just one \c std::string
|
2149 |
2146 |
/// parameter. At the reading process, each line of the section
|
2150 |
2147 |
/// will be given to the functor object. However, the empty lines
|
2151 |
2148 |
/// and the comment lines are filtered out, and the leading
|
2152 |
2149 |
/// whitespaces are trimmed from each processed string.
|
2153 |
2150 |
///
|
2154 |
2151 |
/// For example let's see a section, which contain several
|
2155 |
2152 |
/// integers, which should be inserted into a vector.
|
... |
... |
@@ -2216,101 +2213,101 @@
|
2216 |
2213 |
if (line >> std::ws >> c && c != '#') {
|
2217 |
2214 |
line.putback(c);
|
2218 |
2215 |
return true;
|
2219 |
2216 |
}
|
2220 |
2217 |
}
|
2221 |
2218 |
return false;
|
2222 |
2219 |
}
|
2223 |
2220 |
|
2224 |
2221 |
bool readSuccess() {
|
2225 |
2222 |
return static_cast<bool>(*_is);
|
2226 |
2223 |
}
|
2227 |
2224 |
|
2228 |
2225 |
void skipSection() {
|
2229 |
2226 |
char c;
|
2230 |
2227 |
while (readSuccess() && line >> c && c != '@') {
|
2231 |
2228 |
readLine();
|
2232 |
2229 |
}
|
2233 |
2230 |
line.putback(c);
|
2234 |
2231 |
}
|
2235 |
2232 |
|
2236 |
2233 |
public:
|
2237 |
2234 |
|
2238 |
2235 |
|
2239 |
2236 |
/// \name Execution of the reader
|
2240 |
2237 |
/// @{
|
2241 |
2238 |
|
2242 |
2239 |
/// \brief Start the batch processing
|
2243 |
2240 |
///
|
2244 |
2241 |
/// This function starts the batch processing.
|
2245 |
2242 |
void run() {
|
2246 |
2243 |
|
2247 |
2244 |
LEMON_ASSERT(_is != 0, "This reader assigned to an other reader");
|
2248 |
2245 |
|
2249 |
2246 |
std::set<std::string> extra_sections;
|
2250 |
2247 |
|
2251 |
2248 |
line_num = 0;
|
2252 |
2249 |
readLine();
|
2253 |
2250 |
skipSection();
|
2254 |
2251 |
|
2255 |
2252 |
while (readSuccess()) {
|
2256 |
2253 |
try {
|
2257 |
2254 |
char c;
|
2258 |
2255 |
std::string section, caption;
|
2259 |
2256 |
line >> c;
|
2260 |
2257 |
_reader_bits::readToken(line, section);
|
2261 |
2258 |
_reader_bits::readToken(line, caption);
|
2262 |
2259 |
|
2263 |
2260 |
if (line >> c)
|
2264 |
|
throw FormatError("Extra character on the end of line");
|
|
2261 |
throw FormatError("Extra character at the end of line");
|
2265 |
2262 |
|
2266 |
2263 |
if (extra_sections.find(section) != extra_sections.end()) {
|
2267 |
2264 |
std::ostringstream msg;
|
2268 |
|
msg << "Multiple occurence of section " << section;
|
|
2265 |
msg << "Multiple occurence of section: " << section;
|
2269 |
2266 |
throw FormatError(msg.str());
|
2270 |
2267 |
}
|
2271 |
2268 |
Sections::iterator it = _sections.find(section);
|
2272 |
2269 |
if (it != _sections.end()) {
|
2273 |
2270 |
extra_sections.insert(section);
|
2274 |
2271 |
it->second->process(*_is, line_num);
|
2275 |
2272 |
}
|
2276 |
2273 |
readLine();
|
2277 |
2274 |
skipSection();
|
2278 |
2275 |
} catch (FormatError& error) {
|
2279 |
2276 |
error.line(line_num);
|
2280 |
2277 |
error.file(_filename);
|
2281 |
2278 |
throw;
|
2282 |
2279 |
}
|
2283 |
2280 |
}
|
2284 |
2281 |
for (Sections::iterator it = _sections.begin();
|
2285 |
2282 |
it != _sections.end(); ++it) {
|
2286 |
2283 |
if (extra_sections.find(it->first) == extra_sections.end()) {
|
2287 |
2284 |
std::ostringstream os;
|
2288 |
2285 |
os << "Cannot find section: " << it->first;
|
2289 |
2286 |
throw FormatError(os.str());
|
2290 |
2287 |
}
|
2291 |
2288 |
}
|
2292 |
2289 |
}
|
2293 |
2290 |
|
2294 |
2291 |
/// @}
|
2295 |
2292 |
|
2296 |
2293 |
};
|
2297 |
2294 |
|
2298 |
2295 |
/// \brief Return a \ref SectionReader class
|
2299 |
2296 |
///
|
2300 |
2297 |
/// This function just returns a \ref SectionReader class.
|
2301 |
2298 |
/// \relates SectionReader
|
2302 |
2299 |
inline SectionReader sectionReader(std::istream& is) {
|
2303 |
2300 |
SectionReader tmp(is);
|
2304 |
2301 |
return tmp;
|
2305 |
2302 |
}
|
2306 |
2303 |
|
2307 |
2304 |
/// \brief Return a \ref SectionReader class
|
2308 |
2305 |
///
|
2309 |
2306 |
/// This function just returns a \ref SectionReader class.
|
2310 |
2307 |
/// \relates SectionReader
|
2311 |
2308 |
inline SectionReader sectionReader(const std::string& fn) {
|
2312 |
2309 |
SectionReader tmp(fn);
|
2313 |
2310 |
return tmp;
|
2314 |
2311 |
}
|
2315 |
2312 |
|
2316 |
2313 |
/// \brief Return a \ref SectionReader class
|
... |
... |
@@ -2342,106 +2339,106 @@
|
2342 |
2339 |
/// if (contents.nodeSectionNum() == 0 || contents.arcSectionNum()) {
|
2343 |
2340 |
/// std::cerr << "Failure, cannot find graph." << std::endl;
|
2344 |
2341 |
/// return -1;
|
2345 |
2342 |
/// }
|
2346 |
2343 |
/// std::cout << "The name of the default node section: "
|
2347 |
2344 |
/// << contents.nodeSection(0) << std::endl;
|
2348 |
2345 |
/// std::cout << "The number of the arc maps: "
|
2349 |
2346 |
/// << contents.arcMaps(0).size() << std::endl;
|
2350 |
2347 |
/// std::cout << "The name of second arc map: "
|
2351 |
2348 |
/// << contents.arcMaps(0)[1] << std::endl;
|
2352 |
2349 |
///\endcode
|
2353 |
2350 |
class LgfContents {
|
2354 |
2351 |
private:
|
2355 |
2352 |
|
2356 |
2353 |
std::istream* _is;
|
2357 |
2354 |
bool local_is;
|
2358 |
2355 |
|
2359 |
2356 |
std::vector<std::string> _node_sections;
|
2360 |
2357 |
std::vector<std::string> _edge_sections;
|
2361 |
2358 |
std::vector<std::string> _attribute_sections;
|
2362 |
2359 |
std::vector<std::string> _extra_sections;
|
2363 |
2360 |
|
2364 |
2361 |
std::vector<bool> _arc_sections;
|
2365 |
2362 |
|
2366 |
2363 |
std::vector<std::vector<std::string> > _node_maps;
|
2367 |
2364 |
std::vector<std::vector<std::string> > _edge_maps;
|
2368 |
2365 |
|
2369 |
2366 |
std::vector<std::vector<std::string> > _attributes;
|
2370 |
2367 |
|
2371 |
2368 |
|
2372 |
2369 |
int line_num;
|
2373 |
2370 |
std::istringstream line;
|
2374 |
2371 |
|
2375 |
2372 |
public:
|
2376 |
2373 |
|
2377 |
2374 |
/// \brief Constructor
|
2378 |
2375 |
///
|
2379 |
2376 |
/// Construct an \e LGF contents reader, which reads from the given
|
2380 |
2377 |
/// input stream.
|
2381 |
2378 |
LgfContents(std::istream& is)
|
2382 |
2379 |
: _is(&is), local_is(false) {}
|
2383 |
2380 |
|
2384 |
2381 |
/// \brief Constructor
|
2385 |
2382 |
///
|
2386 |
2383 |
/// Construct an \e LGF contents reader, which reads from the given
|
2387 |
2384 |
/// file.
|
2388 |
2385 |
LgfContents(const std::string& fn)
|
2389 |
2386 |
: _is(new std::ifstream(fn.c_str())), local_is(true) {
|
2390 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
2387 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
2391 |
2388 |
}
|
2392 |
2389 |
|
2393 |
2390 |
/// \brief Constructor
|
2394 |
2391 |
///
|
2395 |
2392 |
/// Construct an \e LGF contents reader, which reads from the given
|
2396 |
2393 |
/// file.
|
2397 |
2394 |
LgfContents(const char* fn)
|
2398 |
2395 |
: _is(new std::ifstream(fn)), local_is(true) {
|
2399 |
|
if (!(*_is)) throw IoError(fn, "Cannot open file");
|
|
2396 |
if (!(*_is)) throw IoError("Cannot open file", fn);
|
2400 |
2397 |
}
|
2401 |
2398 |
|
2402 |
2399 |
/// \brief Destructor
|
2403 |
2400 |
~LgfContents() {
|
2404 |
2401 |
if (local_is) delete _is;
|
2405 |
2402 |
}
|
2406 |
2403 |
|
2407 |
2404 |
private:
|
2408 |
2405 |
|
2409 |
2406 |
LgfContents(const LgfContents&);
|
2410 |
2407 |
LgfContents& operator=(const LgfContents&);
|
2411 |
2408 |
|
2412 |
2409 |
public:
|
2413 |
2410 |
|
2414 |
2411 |
|
2415 |
2412 |
/// \name Node sections
|
2416 |
2413 |
/// @{
|
2417 |
2414 |
|
2418 |
2415 |
/// \brief Gives back the number of node sections in the file.
|
2419 |
2416 |
///
|
2420 |
2417 |
/// Gives back the number of node sections in the file.
|
2421 |
2418 |
int nodeSectionNum() const {
|
2422 |
2419 |
return _node_sections.size();
|
2423 |
2420 |
}
|
2424 |
2421 |
|
2425 |
2422 |
/// \brief Returns the node section name at the given position.
|
2426 |
2423 |
///
|
2427 |
2424 |
/// Returns the node section name at the given position.
|
2428 |
2425 |
const std::string& nodeSection(int i) const {
|
2429 |
2426 |
return _node_sections[i];
|
2430 |
2427 |
}
|
2431 |
2428 |
|
2432 |
2429 |
/// \brief Gives back the node maps for the given section.
|
2433 |
2430 |
///
|
2434 |
2431 |
/// Gives back the node maps for the given section.
|
2435 |
2432 |
const std::vector<std::string>& nodeMapNames(int i) const {
|
2436 |
2433 |
return _node_maps[i];
|
2437 |
2434 |
}
|
2438 |
2435 |
|
2439 |
2436 |
/// @}
|
2440 |
2437 |
|
2441 |
2438 |
/// \name Arc/Edge sections
|
2442 |
2439 |
/// @{
|
2443 |
2440 |
|
2444 |
2441 |
/// \brief Gives back the number of arc/edge sections in the file.
|
2445 |
2442 |
///
|
2446 |
2443 |
/// Gives back the number of arc/edge sections in the file.
|
2447 |
2444 |
/// \note It is synonym of \c edgeSectionNum().
|