logos-messaging/negentropy
1
0
Fork 0
mirror of https://github.com/logos-messaging/negentropy.git synced 2026-05-11 20:49:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: better message

Browse Source
This commit is contained in:
DarshanBPatel 2024-10-09 01:50:36 +05:30
parent 4e6e1d7539
commit 7b2b8ca9d6
No known key found for this signature in database
GPG Key ID: 9A92CCD9899F0D22
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
cpp/negentropy_wrapper.cpp
View File

@ -40,7 +40,7 @@ void* storage_new(const char* db_path, const char* name){
storage = new negentropy::storage::BTreeMem(); storage = new negentropy::storage::BTreeMem();
} catch (const std::exception& e) { } catch (const std::exception& e) {
lastError = e.what(); lastError = std::string("Exception in storage_new: ") + e.what();
return nullptr; return nullptr;
} }
@ -72,7 +72,7 @@ void* negentropy_new(void* storage, uint64_t frameSizeLimit){
try{ try{
ne = new Negentropy<negentropy::storage::BTreeMem>(*lmdbStorage, frameSizeLimit); ne = new Negentropy<negentropy::storage::BTreeMem>(*lmdbStorage, frameSizeLimit);
}catch(negentropy::err e){ }catch(negentropy::err e){
lastError = e.what(); lastError = std::string("Exception in negentropy_new: ") + e.what();
return nullptr; return nullptr;
} }
return ne; return ne;
@ -90,7 +90,7 @@ int negentropy_initiate(void* negentropy, result* result){
printHexString(std::string_view(*output)); */ printHexString(std::string_view(*output)); */
} catch(negentropy::err e){ } catch(negentropy::err e){
//std::cout << "Exception raised in initiate " << e.what() << std::endl; //std::cout << "Exception raised in initiate " << e.what() << std::endl;
lastError = e.what(); lastError = std::string("Exception in negentropy_initiate: ") + e.what();
return -1; return -1;
} }
if (output.size() > 0 ){ if (output.size() > 0 ){
@ -123,7 +123,7 @@ bool storage_insert(void* storage, uint64_t createdAt, buffer* id){
try { try {
return lmdbStorage->insert(createdAt, data); return lmdbStorage->insert(createdAt, data);
} catch (const std::exception& e) { } catch (const std::exception& e) {
lastError = e.what(); lastError = std::string("Exception in storage_insert: ") + e.what();
return false; return false;
} }
} }
@ -139,7 +139,7 @@ bool storage_erase(void* storage, uint64_t createdAt, buffer* id){
try { try {
return lmdbStorage->erase(createdAt, data); return lmdbStorage->erase(createdAt, data);
} catch (const std::exception& e) { } catch (const std::exception& e) {
lastError = e.what(); lastError = std::string("Exception in storage_erase: ") + e.what();
return false; return false;
} }
} }
@ -155,7 +155,7 @@ int reconcile(void* negentropy, buffer* query, result* result){
} catch(negentropy::err e){ } catch(negentropy::err e){
//All errors returned are non-recoverable errors. //All errors returned are non-recoverable errors.
//So passing on the error message upwards //So passing on the error message upwards
lastError = e.what(); lastError = std::string("Exception in reconcile: ") + e.what();
result->error = (char*)calloc(strlen(e.what()), sizeof(char)); result->error = (char*)calloc(strlen(e.what()), sizeof(char));
strcpy(result->error,e.what()); strcpy(result->error,e.what());
return -1; return -1;
@ -258,7 +258,7 @@ int reconcile_with_ids_no_cbk(void* negentropy, buffer* query, result* result){
} catch(negentropy::err e){ } catch(negentropy::err e){
lastError = e.what(); lastError = std::string("Exception in reconcile_with_ids_no_cbk: ") + e.what();
result->error = strdup(e.what()); result->error = strdup(e.what());
return -1; return -1;
} }
@ -312,7 +312,7 @@ void* subrange_new(void* storage, uint64_t startTimeStamp, uint64_t endTimeStamp
try { try {
subRange = new negentropy::storage::SubRange(*st, negentropy::Bound(startTimeStamp), negentropy::Bound(endTimeStamp)); subRange = new negentropy::storage::SubRange(*st, negentropy::Bound(startTimeStamp), negentropy::Bound(endTimeStamp));
} catch (negentropy::err e){ } catch (negentropy::err e){
lastError = e.what(); lastError = std::string("Exception in subrange_new: ") + e.what();
return NULL; return NULL;
} }
return subRange; return subRange;
@ -343,7 +343,7 @@ void* negentropy_subrange_new(void* subrange, uint64_t frameSizeLimit){
try{ try{
ne = new Negentropy<negentropy::storage::SubRange>(*sub_range, frameSizeLimit); ne = new Negentropy<negentropy::storage::SubRange>(*sub_range, frameSizeLimit);
}catch(negentropy::err e){ }catch(negentropy::err e){
lastError = e.what(); lastError = std::string("Exception in negentropy_subrange_new: ") + e.what();
return NULL; return NULL;
} }
return ne; return ne;
@ -360,7 +360,7 @@ int negentropy_subrange_initiate(void* negentropy, result* result){
/* std::cout << "output of initiate is, len:" << output->size() << ", output:"; /* std::cout << "output of initiate is, len:" << output->size() << ", output:";
printHexString(std::string_view(*output)); */ printHexString(std::string_view(*output)); */
} catch(negentropy::err e){ } catch(negentropy::err e){
lastError = e.what(); lastError = std::string("Exception in negentropy_subrange_initiate: ") + e.what();
return -1; return -1;
} }
if (output.size() > 0 ){ if (output.size() > 0 ){
@ -393,7 +393,7 @@ int reconcile_subrange(void* negentropy, buffer* query, result* result){
} catch(negentropy::err e){ } catch(negentropy::err e){
//All errors returned are non-recoverable errors. //All errors returned are non-recoverable errors.
//So passing on the error message upwards //So passing on the error message upwards
lastError = e.what(); lastError = std::string("Exception in reconcile_subrange: ") + e.what();
result->error = (char*)calloc(strlen(e.what()), sizeof(char)); result->error = (char*)calloc(strlen(e.what()), sizeof(char));
strcpy(result->error,e.what()); strcpy(result->error,e.what());
return -1; return -1;
@ -433,7 +433,7 @@ int reconcile_with_ids_subrange_no_cbk(void* negentropy, buffer* query, result*
} catch(negentropy::err e){ } catch(negentropy::err e){
lastError = e.what(); lastError = std::string("Exception in reconcile_subrange_no_cbk: ") + e.what();
result->error = (char*)calloc(strlen(e.what()), sizeof(char)); result->error = (char*)calloc(strlen(e.what()), sizeof(char));
strcpy(result->error,e.what()); strcpy(result->error,e.what());
return -1; return -1;