| 9430 | |
| 9431 | |
| 9432 | static void enqueue_receive(rem_port* port, |
| 9433 | t_rmtque_fn fn, |
| 9434 | Rdb* rdb, |
| 9435 | void* parm, |
| 9436 | Rrq::rrq_repeat* parm1) |
| 9437 | { |
| 9438 | /************************************** |
| 9439 | * |
| 9440 | * e n q u e u e _ r e c e i v e |
| 9441 | * |
| 9442 | ************************************** |
| 9443 | * |
| 9444 | * Functional description |
| 9445 | * |
| 9446 | **************************************/ |
| 9447 | rmtque* const que_inst = FB_NEW rmtque; |
| 9448 | |
| 9449 | // Prepare a queue entry |
| 9450 | |
| 9451 | que_inst->rmtque_next = NULL; |
| 9452 | que_inst->rmtque_function = fn; |
| 9453 | que_inst->rmtque_parm = parm; |
| 9454 | que_inst->rmtque_message = parm1; |
| 9455 | que_inst->rmtque_rdb = rdb; |
| 9456 | |
| 9457 | // Walk to the end of the current queue |
| 9458 | rmtque** queptr = &port->port_receive_rmtque; |
| 9459 | while (*queptr) |
| 9460 | queptr = &(*queptr)->rmtque_next; |
| 9461 | |
| 9462 | // Add the new entry to the end of the queue |
| 9463 | |
| 9464 | *queptr = que_inst; |
| 9465 | } |
| 9466 | |
| 9467 | |
| 9468 | static void dequeue_receive( rem_port* port) |