| 502 | |
| 503 | |
| 504 | void REMOTE_reset_request( Rrq* request, RMessage* active_message) |
| 505 | { |
| 506 | /************************************** |
| 507 | * |
| 508 | * R E M O T E _ r e s e t _ r e q u e s t |
| 509 | * |
| 510 | ************************************** |
| 511 | * |
| 512 | * Functional description |
| 513 | * Clean up a request in preparation to use it again. Since |
| 514 | * there may be an active message (start_and_send), exercise |
| 515 | * some care to avoid zapping that message. |
| 516 | * |
| 517 | **************************************/ |
| 518 | Rrq::rrq_repeat* tail = request->rrq_rpt.begin(); |
| 519 | const Rrq::rrq_repeat* const end = tail + request->rrq_max_msg; |
| 520 | for (; tail <= end; tail++) |
| 521 | { |
| 522 | RMessage* message = tail->rrq_message; |
| 523 | if (message != NULL && message != active_message) |
| 524 | { |
| 525 | tail->rrq_xdr = message; |
| 526 | tail->rrq_rows_pending = 0; |
| 527 | tail->rrq_reorder_level = 0; |
| 528 | tail->rrq_batch_count = 0; |
| 529 | while (true) |
| 530 | { |
| 531 | message->msg_address = NULL; |
| 532 | message = message->msg_next; |
| 533 | if (message == tail->rrq_message) |
| 534 | break; |
| 535 | } |
| 536 | } |
| 537 | } |
| 538 | |
| 539 | // Initialize the request status to FB_SUCCESS |
| 540 | |
| 541 | //request->rrq_status_vector[1] = 0; |
| 542 | request->rrqStatus.clear(); |
| 543 | } |
| 544 | |
| 545 | |
| 546 | void REMOTE_reset_statement( Rsr* statement) |
no test coverage detected