| 2825 | |
| 2826 | |
| 2827 | void Batch::add(CheckStatusWrapper* status, unsigned count, const void* inBuffer) |
| 2828 | { |
| 2829 | try |
| 2830 | { |
| 2831 | // Check and validate handles, etc. |
| 2832 | |
| 2833 | if (!stmt) |
| 2834 | { |
| 2835 | Arg::Gds(isc_bad_req_handle).raise(); |
| 2836 | } |
| 2837 | |
| 2838 | Rsr* statement = stmt->getStatement(); |
| 2839 | CHECK_HANDLE(statement, isc_bad_req_handle); |
| 2840 | Rdb* rdb = statement->rsr_rdb; |
| 2841 | CHECK_HANDLE(rdb, isc_bad_db_handle); |
| 2842 | rem_port* port = rdb->rdb_port; |
| 2843 | |
| 2844 | if (count == 0) |
| 2845 | return; |
| 2846 | |
| 2847 | RefMutexGuard portGuard(*port->port_sync, FB_FUNCTION); |
| 2848 | putMessageData(count, inBuffer); |
| 2849 | |
| 2850 | batchActive = true; |
| 2851 | } |
| 2852 | catch (const Exception& ex) |
| 2853 | { |
| 2854 | ex.stuffException(status); |
| 2855 | } |
| 2856 | } |
| 2857 | |
| 2858 | |
| 2859 | void Batch::sendMessagePacket(unsigned count, const UCHAR* ptr, bool flash) |
no test coverage detected