lobo/isync
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

de-noise msg_fetched() somewhat (prospectively)

Browse Source 
assign temporary srec object instead of always spelling out the
indirection.
This commit is contained in:
Oswald Buddenhagen 2019-12-29 12:31:10 +01:00
parent be9625725c
commit a2880d740c
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/sync.c
View File

@ -276,6 +276,7 @@ static void
msg_fetched( int sts, void *aux ) msg_fetched( int sts, void *aux )
{ {
copy_vars_t *vars = (copy_vars_t *)aux; copy_vars_t *vars = (copy_vars_t *)aux;
sync_rec_t *srec = vars->srec;
DECL_SVARS; DECL_SVARS;
int scr, tcr; int scr, tcr;
@ -292,14 +293,14 @@ msg_fetched( int sts, void *aux )
scr = svars->can_crlf[t^1]; scr = svars->can_crlf[t^1];
tcr = svars->can_crlf[t]; tcr = svars->can_crlf[t];
if (vars->srec || scr != tcr) { if (srec || scr != tcr) {
if (!copy_msg_convert( scr, tcr, vars, t )) { if (!copy_msg_convert( scr, tcr, vars, t )) {
vars->cb( SYNC_NOGOOD, 0, vars ); vars->cb( SYNC_NOGOOD, 0, vars );
return; return;
} }
} }
svars->drv[t]->store_msg( svars->ctx[t], &vars->data, !vars->srec, msg_stored, vars ); svars->drv[t]->store_msg( svars->ctx[t], &vars->data, !srec, msg_stored, vars );
break; break;
case DRV_CANCELED: case DRV_CANCELED:
vars->cb( SYNC_CANCELED, 0, vars ); vars->cb( SYNC_CANCELED, 0, vars );