use new read_pause / read_continue routines

diff --git a/src/modules/proto_detail/proto_detail_file.c b/src/modules/proto_detail/proto_detail_file.c
index 1d6c0c70f65eecd1be8f3e155a90c91560c691e5..1fd1be3328e567c0d33e0952f91dfab12563a340 100644 (file)
--- a/src/modules/proto_detail/proto_detail_file.c
+++ b/src/modules/proto_detail/proto_detail_file.c
@@ -382,6 +382,10 @@ done:
         */
        inst->last_search = 0;
 
+       if (fr_event_fd_read_pause(inst->el, inst->fd) < 0) {
+               DEBUG("FAILED pausing read: %s", fr_strerror());
+       }
+
        MPRINT("Returning NUM %d - %.*s", inst->outstanding, (int) packet_len, buffer);
        return packet_len;
 }
@@ -397,6 +401,10 @@ static ssize_t mod_write(void *instance, void *packet_ctx,
        rad_assert(inst->outstanding > 0);
        inst->outstanding--;
 
+       if (fr_event_fd_read_continue(inst->el, inst->fd) < 0) {
+               DEBUG("FAILED continuing read: %s", fr_strerror());
+       }
+
        if (buffer[0] == 0) {
                DEBUG("Got Do-Not-Respond, not writing reply");