shaba/one
1
0
Fork 0
mirror of https://github.com/OpenNebula/one.git synced 2025-03-21 14:50:08 +03:00
Code Releases Wiki Activity

F #4809: Compress federated log

Browse Source
This commit is contained in:
Ruben S. Montero 2017-06-28 19:43:04 +02:00
parent e04dba14e4
commit 361409e7e1
1 changed files with 35 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/raft/FedReplicaManager.cc
View File

@ -107,7 +107,17 @@ int FedReplicaManager::apply_log_record(int index, const std::string& sql)
std::ostringstream oss;
char * sql_db = logdb->escape_str(sql.c_str());
std::string * zsql = one_util::zlib_compress(sql, true);
if ( zsql == 0 )
{
pthread_mutex_unlock(&mutex);
return -1;
}
char * sql_db = logdb->escape_str(zsql->c_str());
delete zsql;
if ( sql_db == 0 )
{
@ -392,18 +402,31 @@ int FedReplicaManager::get_next_record(int zone_id, int& index,
int FedReplicaManager::get_log_record(int index, std::string& sql)
{
std::string zsql;
ostringstream oss;
single_cb<std::string> cb;
oss << "SELECT sqlcmd FROM fed_logdb WHERE log_index = " << index;
cb.set_callback(&sql);
cb.set_callback(&zsql);
int rc = logdb->exec_rd(oss, &cb);
cb.unset_callback();
std::string * _sql = one_util::zlib_decompress(zsql, true);
if ( _sql == 0 )
{
return -1;
}
sql = *_sql;
delete _sql;
return rc;
}
@ -413,7 +436,16 @@ int FedReplicaManager::insert_log_record(int index, const std::string& sql)
{
std::ostringstream oss;
char * sql_db = logdb->escape_str(sql.c_str());
std::string * zsql = one_util::zlib_compress(sql, true);
if ( zsql == 0 )
{
return -1;
}
char * sql_db = logdb->escape_str(zsql->c_str());
delete zsql;
if ( sql_db == 0 )
{