logos-messaging/negentropy
1
0
Fork 0
mirror of https://github.com/logos-messaging/negentropy.git synced 2026-01-07 16:33:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: callback integration in progress

Browse Source
This commit is contained in:
Prem Chaitanya Prathi 2024-03-05 20:36:35 +05:30
parent 8972f3ba69
commit 315e1de72e
No known key found for this signature in database
2 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cpp/negentropy_wrapper.c
View File

@ -126,7 +126,7 @@ void transform(std::vector<std::string> &from_ids, buffer* to_ids)
} }
} }
int reconcile_with_ids(void* negentropy, buffer* query,reconcile_cbk cbk){ int reconcile_with_ids(void* negentropy, buffer* query,reconcile_cbk cbk, char* outptr){
Negentropy<negentropy::storage::BTreeMem> *ngn_inst; Negentropy<negentropy::storage::BTreeMem> *ngn_inst;
ngn_inst = reinterpret_cast<Negentropy<negentropy::storage::BTreeMem>*>(negentropy); ngn_inst = reinterpret_cast<Negentropy<negentropy::storage::BTreeMem>*>(negentropy);
@ -145,25 +145,28 @@ int reconcile_with_ids(void* negentropy, buffer* query,reconcile_cbk cbk){
need_ids = (buffer*)malloc(need_ids_len*sizeof(buffer)); need_ids = (buffer*)malloc(need_ids_len*sizeof(buffer));
std::cout << "have_ids_len:" << have_ids_len << "need_ids_len:" << need_ids_len << std::endl; std::cout << "have_ids_len:" << have_ids_len << "need_ids_len:" << need_ids_len << std::endl;
std::flush(std::cout);
transform(haveIds, have_ids); transform(haveIds, have_ids);
transform(needIds, need_ids); transform(needIds, need_ids);
std::cout << "for debug" << std::endl;
} catch(negentropy::err e){ } catch(negentropy::err e){
std::cout << "caught error "<< e.what() << std::endl; std::cout << "caught error "<< e.what() << std::endl;
//TODO:Find a way to return this error and cleanup partially allocated memory if any //TODO:Find a way to return this error and cleanup partially allocated memory if any
return -1; return -1;
} }
buffer output; buffer output = {0,NULL};
if (out) { if (out) {
output.len = out.value().size(); output.len = out.value().size();
output.data = (unsigned char*)out.value().c_str(); output.data = (unsigned char*)out.value().c_str();
std::cout << "reconcile_with_ids output of reconcile is, len:" << out.value().size() << ", output:"; std::cout << "reconcile_with_ids output of reconcile is, len:" << out.value().size() << ", output:";
printHexString(std::string_view(out.value())); printHexString(std::string_view(out.value()));
std::cout << "invoking callback" << std::endl;
} }
cbk(have_ids, have_ids_len, need_ids, need_ids_len, &output); std::cout << "invoking callback" << std::endl;
std::flush(std::cout);
cbk(have_ids, have_ids_len, need_ids, need_ids_len, &output, outptr);
std::cout << "invoked callback" << std::endl;
std::flush(std::cout);
free(have_ids); free(have_ids);
free(need_ids); free(need_ids);
return 0; return 0;

4
cpp/negentropy_wrapper.h
View File

@ -30,9 +30,9 @@ EXTERNC bool storage_erase(void* storage, uint64_t createdAt, buffer* id);
EXTERNC size_t reconcile(void* negentropy, buffer* query, buffer* output); EXTERNC size_t reconcile(void* negentropy, buffer* query, buffer* output);
EXTERNC typedef void (*reconcile_cbk)(buffer* have_ids, uint64_t have_ids_len, buffer* need_ids, uint64_t need_ids_len, buffer* output); EXTERNC typedef void (*reconcile_cbk)(buffer* have_ids, uint64_t have_ids_len, buffer* need_ids, uint64_t need_ids_len, buffer* output, char* outptr );
EXTERNC int reconcile_with_ids(void* negentropy, buffer* query, reconcile_cbk cbk); EXTERNC int reconcile_with_ids(void* negentropy, buffer* query, reconcile_cbk cbk, char* outptr);
#endif #endif