#include <algorithm>
#include "common.h"
-#include "base_store.h"
-#include "settings.h"
+#include "store.h"
+#include "settings_impl.h"
#include "conffiles.h"
#include "user_stat.h"
#include "service_conf.h"
#include "admin_conf.h"
#include "tariff_conf.h"
-#include "base_settings.h"
+#include "settings.h"
#include "stg_message.h"
using namespace std;
{
printfd(__FILE__, "Start\n");
-BASE_STORE * fromStore = NULL;
-BASE_STORE * toStore = NULL;
+STORE * fromStore = NULL;
+STORE * toStore = NULL;
-SETTINGS * settings = NULL;
+SETTINGS_IMPL * settings = NULL;
string modulePath;
CORP_CONF cc;
SERVICE_CONF sc;
vector<STG_MSG_HDR> hdrs;
-vector<STG_MSG_HDR>::iterator mit;
-
-void * src_lh;
-void * dst_lh;
if (argc == 2)
- settings = new SETTINGS(argv[1]);
+ settings = new SETTINGS_IMPL(argv[1]);
else
- settings = new SETTINGS();
+ settings = new SETTINGS_IMPL();
if (settings->ReadSettings())
-{
+ {
printfd(__FILE__, "Error reading settings\n");
delete settings;
return -1;
-}
+ }
fromStoreSettings = settings->GetSourceStoreModuleSettings();
toStoreSettings = settings->GetDestStoreModuleSettings();
string sourcePlugin(modulePath + "/mod_" + fromStoreSettings.moduleName + ".so");
string destPlugin(modulePath + "/mod_" + toStoreSettings.moduleName + ".so");
-src_lh = dlopen(sourcePlugin.c_str(), RTLD_NOW);
+void * src_lh = dlopen(sourcePlugin.c_str(), RTLD_NOW);
if (!src_lh)
{
printfd(__FILE__, "Source storage plugin loading failed: %s\n", dlerror());
return -1;
}
-dst_lh = dlopen(destPlugin.c_str(), RTLD_NOW);
+void * dst_lh = dlopen(destPlugin.c_str(), RTLD_NOW);
if (!dst_lh)
{
printfd(__FILE__, "Destination storage plugin loading failed: %s\n", dlerror());
return -1;
}
-BASE_STORE * (*GetSourceStore)();
-BASE_STORE * (*GetDestStore)();
-GetSourceStore = (BASE_STORE * (*)())dlsym(src_lh, "GetStore");
+STORE * (*GetSourceStore)();
+STORE * (*GetDestStore)();
+GetSourceStore = (STORE * (*)())dlsym(src_lh, "GetStore");
if (!GetSourceStore)
{
printfd(__FILE__, "Source storage plugin loading failed. GetStore not found: %s\n", dlerror());
delete settings;
return -1;
}
-GetDestStore = (BASE_STORE * (*)())dlsym(dst_lh, "GetStore");
+GetDestStore = (STORE * (*)())dlsym(dst_lh, "GetStore");
if (!GetDestStore)
{
printfd(__FILE__, "Storage plugin (firebird) loading failed. GetStore not found: %s\n", dlerror());
vector<string> entities;
vector<string> ready;
-vector<string>::const_iterator it;
fromStore->SetSettings(fromStoreSettings);
fromStore->ParseSettings();
toStore->SetSettings(toStoreSettings);
delete settings;
return -1;
}
+
+vector<string>::const_iterator it;
for (it = entities.begin(); it != entities.end(); ++it)
{
printfd(__FILE__, "\t - %s\n", it->c_str());
delete settings;
return -1;
}
+
for (it = entities.begin(); it != entities.end(); ++it)
{
printfd(__FILE__, "\t - %s\n", it->c_str());
delete settings;
return -1;
}
+
for (it = entities.begin(); it != entities.end(); ++it)
{
printfd(__FILE__, "\t - %s\n", it->c_str());
delete settings;
return -1;
}
+
for (it = entities.begin(); it != entities.end(); ++it)
{
printfd(__FILE__, "\t - %s\n", it->c_str());
delete settings;
return -1;
}
+
sort(ready.begin(), ready.end());
for (it = entities.begin(); it != entities.end(); ++it)
{
delete settings;
return -1;
}
+ vector<STG_MSG_HDR>::iterator mit;
for (mit = hdrs.begin(); mit != hdrs.end(); ++mit)
{
if (fromStore->GetMessage(mit->id, &msg, *it))
return -1;
}
}
-
}
dlclose(src_lh);