| 762 | } |
| 763 | |
| 764 | class Request final : public RefCntIface<IRequestImpl<Request, CheckStatusWrapper> > |
| 765 | { |
| 766 | public: |
| 767 | // IRequest implementation |
| 768 | int release() override; |
| 769 | void receive(CheckStatusWrapper* status, int level, unsigned int msg_type, |
| 770 | unsigned int length, void* message) override; |
| 771 | void send(CheckStatusWrapper* status, int level, unsigned int msg_type, |
| 772 | unsigned int length, const void* message) override; |
| 773 | void getInfo(CheckStatusWrapper* status, int level, |
| 774 | unsigned int itemsLength, const unsigned char* items, |
| 775 | unsigned int bufferLength, unsigned char* buffer) override; |
| 776 | void start(CheckStatusWrapper* status, ITransaction* tra, int level) override; |
| 777 | void startAndSend(CheckStatusWrapper* status, ITransaction* tra, int level, unsigned int msg_type, |
| 778 | unsigned int length, const void* message) override; |
| 779 | void unwind(CheckStatusWrapper* status, int level) override; |
| 780 | void free(CheckStatusWrapper* status) override; |
| 781 | void deprecatedFree(CheckStatusWrapper* status) override; |
| 782 | |
| 783 | public: |
| 784 | Request(Rrq* handle, Attachment* a) |
| 785 | : remAtt(a), rq(handle) |
| 786 | { |
| 787 | rq->rrq_self = &rq; |
| 788 | } |
| 789 | |
| 790 | private: |
| 791 | void freeClientData(CheckStatusWrapper* status, bool force = false); |
| 792 | void internalFree(CheckStatusWrapper* status); |
| 793 | |
| 794 | Attachment* remAtt; |
| 795 | Rrq* rq; |
| 796 | }; |
| 797 | |
| 798 | int Request::release() |
| 799 | { |