X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=xfer-src%2Ffilter-xor.c;h=7d836657c6171430eb03c01dd9f8881f12b3f031;hb=4c9eba1feb11adf189bceb4001c425e641f0b56a;hp=7bec75ea2713a22527a76ec7debb3e9860ebc2e3;hpb=b116e9366c7b2ea2c2eb53b0a13df4090e176235;p=debian%2Famanda diff --git a/xfer-src/filter-xor.c b/xfer-src/filter-xor.c index 7bec75e..7d83665 100644 --- a/xfer-src/filter-xor.c +++ b/xfer-src/filter-xor.c @@ -91,7 +91,7 @@ pull_buffer_impl( if (elt->cancelled) { /* drain our upstream only if we're expecting an EOF */ if (elt->expect_eof) { - xfer_element_drain_by_pulling(XFER_ELEMENT(self)->upstream); + xfer_element_drain_buffers(XFER_ELEMENT(self)->upstream); } /* return an EOF */ @@ -140,9 +140,9 @@ class_init( { XferElementClass *klass = XFER_ELEMENT_CLASS(selfc); static xfer_element_mech_pair_t mech_pairs[] = { - { XFER_MECH_PULL_BUFFER, XFER_MECH_PULL_BUFFER, 1, 0}, - { XFER_MECH_PUSH_BUFFER, XFER_MECH_PUSH_BUFFER, 1, 0}, - { XFER_MECH_NONE, XFER_MECH_NONE, 0, 0}, + { XFER_MECH_PULL_BUFFER, XFER_MECH_PULL_BUFFER, XFER_NROPS(1), XFER_NTHREADS(0) }, + { XFER_MECH_PUSH_BUFFER, XFER_MECH_PUSH_BUFFER, XFER_NROPS(1), XFER_NTHREADS(0) }, + { XFER_MECH_NONE, XFER_MECH_NONE, XFER_NROPS(0), XFER_NTHREADS(0) }, }; klass->push_buffer = push_buffer_impl;