ExternalVendorCode/serval-dna
1
0
Fork 0
mirror of https://github.com/servalproject/serval-dna.git synced 2025-01-18 10:46:23 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Use trigger function to clear out sync bars

Browse Source
This commit is contained in:
Jeremy Lakeman 2016-03-07 14:33:50 +10:30
parent c1947cf774
commit ab15369af5
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
rhizome_sync.c
View File

@ -245,12 +245,15 @@ static int sync_bundle_inserted(struct subscriber *subscriber, void *context)
return 0;
}
static int rhizome_sync_bundle_inserted(const rhizome_bar_t *bar)
static void rhizome_sync_bundle_inserted(rhizome_manifest *m)
{
enum_subscribers(NULL, sync_bundle_inserted, (void *)bar);
return 0;
rhizome_bar_t bar;
rhizome_manifest_to_bar(m, &bar);
enum_subscribers(NULL, sync_bundle_inserted, (void *)&bar);
}
DEFINE_TRIGGER(bundle_add, rhizome_sync_bundle_inserted);
static int sync_cache_bar(struct rhizome_sync *state, const rhizome_bar_t *bar, uint64_t token)
{
int ret=0;
@ -445,11 +448,6 @@ static void sync_send_response(struct subscriber *dest, int forwards, uint64_t t
if (bar_size != RHIZOME_BAR_BYTES)
continue;
if (rowid>max_token){
// a new bundle has been imported
rhizome_sync_bundle_inserted((const rhizome_bar_t *)bar);
}
if (count < max_count){
// make sure we include the exact rowid that was requested, even if we just deleted / replaced the manifest
if (count==0 && rowid!=token){