| 2857 | |
| 2858 | |
| 2859 | void Batch::sendMessagePacket(unsigned count, const UCHAR* ptr, bool flash) |
| 2860 | { |
| 2861 | Rsr* statement = stmt->getStatement(); |
| 2862 | CHECK_HANDLE(statement, isc_bad_req_handle); |
| 2863 | Rdb* rdb = statement->rsr_rdb; |
| 2864 | CHECK_HANDLE(rdb, isc_bad_db_handle); |
| 2865 | rem_port* port = rdb->rdb_port; |
| 2866 | |
| 2867 | PACKET* packet = &rdb->rdb_packet; |
| 2868 | packet->p_operation = op_batch_msg; |
| 2869 | P_BATCH_MSG* batch = &packet->p_batch_msg; |
| 2870 | batch->p_batch_statement = statement->rsr_id; |
| 2871 | batch->p_batch_messages = count; |
| 2872 | batch->p_batch_data.cstr_address = const_cast<UCHAR*>(ptr); |
| 2873 | statement->rsr_batch_size = alignedSize; |
| 2874 | |
| 2875 | sendDeferredPacket(nullptr, port, packet, flash); |
| 2876 | messageCount += count; |
| 2877 | } |
| 2878 | |
| 2879 | |
| 2880 | void Batch::addBlob(CheckStatusWrapper* status, unsigned length, const void* inBuffer, ISC_QUAD* blobId, |
nothing calls this directly
no test coverage detected