/*
This file is part of Ingen.
Copyright 2007-2012 David Robillard
Ingen is free software: you can redistribute it and/or modify it under the
terms of the GNU Affero General Public License as published by the Free
Software Foundation, either version 3 of the License, or any later version.
Ingen is distributed in the hope that it will be useful, but WITHOUT ANY
WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
A PARTICULAR PURPOSE. See the GNU Affero General Public License for details.
You should have received a copy of the GNU Affero General Public License
along with Ingen. If not, see .
*/
#include
#include
#include "raul/log.hpp"
#include "ingen/shared/ClashAvoider.hpp"
#include "ingen/shared/Store.hpp"
using namespace std;
namespace Ingen {
namespace Shared {
const Raul::URI
ClashAvoider::map_uri(const Raul::URI& in)
{
if (Raul::Path::is_path(in))
return map_path(in.str());
else
return in;
}
const Raul::Path
ClashAvoider::map_path(const Raul::Path& in)
{
Raul::debug << "MAP PATH: " << in;
unsigned offset = 0;
bool has_offset = false;
const size_t pos = in.find_last_of('_');
if (pos != string::npos && pos != (in.length()-1)) {
const std::string trailing = in.substr(pos + 1);
has_offset = (sscanf(trailing.c_str(), "%u", &offset) > 0);
}
Raul::debug << "OFFSET: " << offset << endl;
// Path without _n suffix
Raul::Path base_path = in;
if (has_offset)
base_path = base_path.substr(0, base_path.find_last_of('_'));
Raul::debug << "BASE: " << base_path << endl;
SymbolMap::iterator m = _symbol_map.find(in);
if (m != _symbol_map.end()) {
Raul::debug << " (1) " << m->second << endl;
return m->second;
} else {
typedef std::pair InsertRecord;
// See if parent is mapped
Raul::Path parent = in.parent();
do {
Raul::debug << "CHECK: " << parent << endl;
SymbolMap::iterator p = _symbol_map.find(parent);
if (p != _symbol_map.end()) {
const Raul::Path mapped = p->second.base() + in.substr(parent.base().length());
InsertRecord i = _symbol_map.insert(make_pair(in, mapped));
Raul::debug << " (2) " << i.first->second << endl;
return i.first->second;
}
parent = parent.parent();
} while (!parent.is_root());
// No clash, use symbol unmodified
if (!exists(in) && _symbol_map.find(in) == _symbol_map.end()) {
InsertRecord i = _symbol_map.insert(make_pair(in, in));
assert(i.second);
Raul::debug << " (3) " << i.first->second << endl;
return i.first->second;
// Append _2 _3 etc until an unused symbol is found
} else {
while (true) {
Offsets::iterator o = _offsets.find(base_path);
if (o != _offsets.end()) {
offset = ++o->second;
} else {
string parent_str = in.parent().base();
parent_str = parent_str.substr(0, parent_str.find_last_of("/"));
if (parent_str.empty())
parent_str = "/";
Raul::debug << "PARENT: " << parent_str << endl;
}
if (offset == 0)
offset = 2;
std::stringstream ss;
ss << base_path << "_" << offset;
if (!exists(ss.str())) {
string name = base_path.symbol();
if (name == "")
name = "_";
string str = ss.str();
InsertRecord i = _symbol_map.insert(make_pair(in, str));
Raul::debug << "HIT: offset = " << offset << ", str = " << str << endl;
offset = _store.child_name_offset(in.parent(), name, false);
_offsets.insert(make_pair(base_path, offset));
Raul::debug << " (4) " << i.first->second << endl;
return i.first->second;
} else {
Raul::debug << "MISSED OFFSET: " << in << " => " << ss.str() << endl;
if (o != _offsets.end())
offset = ++o->second;
else
++offset;
}
}
}
}
}
bool
ClashAvoider::exists(const Raul::Path& path) const
{
bool exists = (_store.find(path) != _store.end());
if (exists)
return true;
if (_also_avoid)
return (_also_avoid->find(path) != _also_avoid->end());
else
return false;
}
void
ClashAvoider::put(const Raul::URI& path,
const Resource::Properties& properties,
Resource::Graph ctx)
{
_target.put(map_uri(path), properties, ctx);
}
void
ClashAvoider::delta(const Raul::URI& path,
const Resource::Properties& remove,
const Resource::Properties& add)
{
_target.delta(map_uri(path), remove, add);
}
void
ClashAvoider::move(const Raul::Path& old_path,
const Raul::Path& new_path)
{
_target.move(map_path(old_path), map_path(new_path));
}
void
ClashAvoider::connect(const Raul::Path& tail,
const Raul::Path& head)
{
_target.connect(map_path(tail), map_path(head));
}
void
ClashAvoider::disconnect(const Raul::Path& tail,
const Raul::Path& head)
{
_target.disconnect(map_path(tail), map_path(head));
}
void
ClashAvoider::disconnect_all(const Raul::Path& parent_patch,
const Raul::Path& path)
{
_target.disconnect_all(map_path(parent_patch), map_path(path));
}
void
ClashAvoider::set_property(const Raul::URI& subject,
const Raul::URI& predicate,
const Raul::Atom& value)
{
_target.set_property(map_uri(subject), predicate, value);
}
void
ClashAvoider::del(const Raul::URI& uri)
{
if (Raul::Path::is_path(uri))
_target.del(map_path(Raul::Path(uri.str())));
}
} // namespace Shared
} // namespace Ingen