246   size_t idone = effp1->oend - effp1->obeg;  in flow_effect()
247   size_t obeg = sox_globals.bufsiz - effp->oend;  in flow_effect()  local
252   size_t pre_odone = obeg;  in flow_effect()
257     effstatus = effp->handler.flow(effp, effp1->obuf + effp1->obeg,  in flow_effect()
259                     &idone, &obeg);  in flow_effect()
260     if (obeg % effp->out_signal.channels != 0) {  in flow_effect()
265       deinterleave(chain->effects[n+1]->flows, obeg, chain->il_buf,  in flow_effect()
277         shared(effp,effp1,idone,obeg,obuf,flow_offs,chain,n,effstatus) \  in flow_effect()
283         shared(effp,effp1,idone,obeg,obuf,flow_offs,chain,n,effstatus) \  in flow_effect()
289       size_t odonec = obeg / effp->flows;  in flow_effect()
291           effp1->obuf + f*flow_offs + effp1->obeg/effp->flows,  in flow_effect()
306     obeg = effp->flows * odone_max;  in flow_effect()
309       interleave(effp->flows, obeg, chain->il_buf, sox_globals.bufsiz,  in flow_effect()
312   effp1->obeg += idone;  in flow_effect()
313   if (effp1->obeg == effp1->oend)  in flow_effect()
314     effp1->obeg = effp1->oend = 0;  in flow_effect()
315   else if (effp1->oend - effp1->obeg < effp->imin) { /* Need to refill? */  in flow_effect()
319           effp1->obuf + f * flow_offs + effp1->obeg/effp->flows,  in flow_effect()
320           (effp1->oend - effp1->obeg)/effp->flows * sizeof(*effp1->obuf));  in flow_effect()
321     effp1->oend -= effp1->obeg;  in flow_effect()
322     effp1->obeg = 0;  in flow_effect()
325   effp->oend += obeg;  in flow_effect()
331       n, effp->flows, pre_idone, pre_odone, idone, obeg,  in flow_effect()
332       effp1->oend - effp1->obeg, effp1->obeg, effp1->oend);  in flow_effect()
344   size_t obeg = sox_globals.bufsiz - effp->oend;  in drain_effect()  local
348   size_t pre_odone = obeg;  in drain_effect()
354                     &obeg);  in drain_effect()
355     if (obeg % effp->out_signal.channels != 0) {  in drain_effect()
360       deinterleave(chain->effects[n+1]->flows, obeg, chain->il_buf,  in drain_effect()
368       size_t odonec = obeg / effp->flows;  in drain_effect()
382     obeg = effp->flows * odone_last;  in drain_effect()
385       interleave(effp->flows, obeg, chain->il_buf, sox_globals.bufsiz,  in drain_effect()
388   if (!obeg)   /* This is the only thing that drain has and flow hasn't */  in drain_effect()
391   effp->oend += obeg;  in drain_effect()
396       n, effp->flows, (size_t)0, pre_odone, (size_t)0, obeg);  in drain_effect()
420         effp->obeg = effp->oend = 0;  in sox_flow_effects()
433     if (effp->oend > effp->obeg && chain->effects[e+1]->flows > 1) {  in sox_flow_effects()
435       deinterleave(chain->effects[e+1]->flows, effp->oend - effp->obeg,  in sox_flow_effects()
436           chain->il_buf, effp->obuf, sox_globals.bufsiz, effp->obeg);  in sox_flow_effects()
442 …e < chain->length && chain->effects[e - 1]->oend - chain->effects[e - 1]->obeg >= chain->effects[e…  in sox_flow_effects()
443     size_t osize = chain->effects[e]->oend - chain->effects[e]->obeg;  in sox_flow_effects()
456 …if (e < chain->length && chain->effects[e]->oend - chain->effects[e]->obeg > osize) /* False for o…  in sox_flow_effects()
476     if (effp->oend > effp->obeg && chain->effects[e+1]->flows > 1) {  in sox_flow_effects()
478       interleave(chain->effects[e+1]->flows, effp->oend - effp->obeg,  in sox_flow_effects()
479           chain->il_buf, sox_globals.bufsiz, effp->obeg, effp->obuf);  in sox_flow_effects()
547   if (effp->obeg != effp->oend)  in sox_delete_effect()
549         (effp->oend - effp->obeg)/effp->out_signal.channels);  in sox_delete_effect()