]> git.ipfire.org Git - thirdparty/freeradius-server.git/commitdiff
is_dup is set false by network side
authorAlan T. DeKok <aland@freeradius.org>
Fri, 31 Aug 2018 18:12:43 +0000 (14:12 -0400)
committerAlan T. DeKok <aland@freeradius.org>
Fri, 31 Aug 2018 18:15:25 +0000 (14:15 -0400)
and only really ever set to "true" by io/master.c

src/lib/io/master.c
src/lib/io/network.c
src/modules/proto_detail/proto_detail_work.c

index a715a9f5f45dacf2c3a10b3dcdae30acb349c67a..434b7ddc74d08222bca380d38ec2f4eec43589d9 100644 (file)
@@ -767,8 +767,6 @@ static fr_io_track_t *fr_io_track_add(fr_io_client_t *client,
 
        if (client->inst->app_io->track_duplicates) track = rbtree_finddata(client->table, &my_track);
        if (!track) {
-               *is_dup = false;
-
                MEM(track = talloc_zero(client, fr_io_track_t));
                talloc_get_type_abort(track, fr_io_track_t);
 
@@ -932,7 +930,6 @@ static ssize_t mod_read(void *instance, void **packet_ctx, fr_time_t **recv_time
 
        get_inst(instance, &inst, &connection, &app_io_instance);
 
-       *is_dup = false;
        track = NULL;
 
        /*
index d195feea3869b318c8ab362dd000c59311697f1d..f5894798a9065d11a3f5c8cb9c6cc2111f83292b 100644 (file)
@@ -438,6 +438,9 @@ next_message:
                return;
        }
 
+       cd->request.is_dup = false;
+       cd->priority = PRIORITY_NORMAL;
+
        /*
         *      Read data from the network.
         *
index 6d7f8268875d73c93bed248111437be98283705e..7c89d2244276ae40bce67a099e9159ebce55dc93 100644 (file)
@@ -136,7 +136,7 @@ static fr_event_update_t resume_read[] = {
        { 0 }
 };
 
-static ssize_t mod_read(void *instance, void **packet_ctx, fr_time_t **recv_time, uint8_t *buffer, size_t buffer_len, size_t *leftover, uint32_t *priority, bool *is_dup)
+static ssize_t mod_read(void *instance, void **packet_ctx, fr_time_t **recv_time, uint8_t *buffer, size_t buffer_len, size_t *leftover, uint32_t *priority, UNUSED bool *is_dup)
 {
        proto_detail_work_t             *inst = talloc_get_type_abort(instance, proto_detail_work_t);
 
@@ -149,7 +149,6 @@ static ssize_t mod_read(void *instance, void **packet_ctx, fr_time_t **recv_time
 
        rad_assert(*leftover < buffer_len);
        rad_assert(inst->fd >= 0);
-       *is_dup = false;
 
        /*
         *      Process retransmissions before anything else in the