| 618 | } |
| 619 | |
| 620 | class Replicator final : public RefCntIface<IReplicatorImpl<Replicator, CheckStatusWrapper> > |
| 621 | { |
| 622 | public: |
| 623 | // IReplicator implementation |
| 624 | int release() override; |
| 625 | void process(CheckStatusWrapper* status, unsigned length, const unsigned char* data) override; |
| 626 | void close(CheckStatusWrapper* status) override; |
| 627 | void deprecatedClose(CheckStatusWrapper* status) override; |
| 628 | |
| 629 | explicit Replicator(Attachment* att) : attachment(att) |
| 630 | {} |
| 631 | |
| 632 | private: |
| 633 | void freeClientData(CheckStatusWrapper* status, bool force = false); |
| 634 | void internalClose(CheckStatusWrapper* status); |
| 635 | |
| 636 | Attachment* attachment; |
| 637 | }; |
| 638 | |
| 639 | int Replicator::release() |
| 640 | { |