Eliminate duplicate words.

doc/admin-guide/plugins/icap.en.rst

@@ -108,7 +108,10 @@ After finishing sending the message, the plugin will receive the returned messag
    value modified by an ICAP server.
    0
 
-In case of virus detected, the scanner will include fields like "X-Infection-Found" and "X-Violations-Found" in the ICAP response header. Therefore, by evaluating the ICAP header, if infection headers are found, then then plugin will discard the HTTP response header from the origin server and use the HTTP header returned by ICAP server to generate the response header. Otherwise, the file is clean, in which case headers will not be modified. Once finished reading headers, the plugin proceeds to read the message body, which is, if file is clean, an exact copy of the response from origin server or, if file is bad, an error message generated by scanner server.
+In case of virus detected, the scanner will include fields like "X-Infection-Found" and "X-Violations-Found" in the ICAP response header. Therefore, by evaluating the ICAP header,
+if infection headers are found, then plugin will discard the HTTP response header from the origin server and use the HTTP header returned by ICAP server to generate the response
+header. Otherwise, the file is clean, in which case headers will not be modified. Once finished reading headers, the plugin proceeds to read the message body, which is, if file is
+clean, an exact copy of the response from origin server or, if file is bad, an error message generated by scanner server.
 
 Scanner Server
 --------------

doc/admin-guide/plugins/money_trace.en.rst

@@ -39,7 +39,7 @@ How it Works
 
 This plugin checks incoming requests for the "X-MoneyTrace" header.
 If the header is not present no further processing takes place.
-However if the header is present,  the plugin will check to to see if the
+However if the header is present,  the plugin will check to see if the
 request has been cached.  If so, the plugin will add the "X-Moneytrace"
 header from the incoming request to the cached response returned to the
 client as required by the money_trace protocol.  If the request has not

doc/admin-guide/plugins/slice.en.rst

@@ -238,7 +238,7 @@ and sends it to the client.  If necessary it then skips over bytes in the
 first block and starts sending byte content, examining each block header
 and sends its bytes to the client until the client request is satisfied.
 
-Any extra bytes at the end of the last block are consumed by the the
+Any extra bytes at the end of the last block are consumed by the
 Slice plugin to allow cache_range_requests to finish the block fetch to
 ensure the block is cached.
 

doc/admin-guide/security/mtls.en.rst

@@ -100,7 +100,7 @@ Then you would set :ts:cv:`proxy.config.ssl.CA.cert.filename` to client_CA_bundl
 
 Guidance for testing
 --------------------
-If you use curl to test your SNI-based Traffic Server configuration, you must make sure the the
+If you use curl to test your SNI-based Traffic Server configuration, you must make sure the
 SNI value is really set in the TLS Client Hello message.  If you use the |TS| name or address
 in the URL and explicitly set the host field (as shown below) to indicate the real domain, the
 SNI value will not be set to the host field value.  In the example below the SNI value will

example/plugins/cpp-api/serverresponse/ServerResponse.cc

@@ -83,7 +83,7 @@ class ServerResponsePlugin : public GlobalPlugin
 
     //
     // If the url contains a query parameter redirect=1 we will send the
-    // user to to somewhere else. Obviously this is a silly example
+    // user to somewhere else. Obviously this is a silly example
     // since we should technically detect this long before the origin
     // request and prevent the origin request in the first place.
     //

include/tscore/Throttler.h

@@ -44,7 +44,7 @@
  *   returned false. The number of times the check has been called between
  *   these two times is provided in the suppressed_count output parameter.
  *
- *   2b. If is_throttled returns returns true, then not enough time has elapsed
+ *   2b. If is_throttled returns true, then not enough time has elapsed
  *   since the last time the operation returned true per the throttling
  *   interval. Thus the operation should be skipped or suppressed, depending
  *   upon the context.

include/tscpp/api/TransactionPlugin.h

@@ -94,7 +94,7 @@ class TransactionPlugin : public Plugin
    *  callback, a default implementation will be used that will only resume the Transaction.
    *
    * \note For automatic destruction, you must either register dynamically allocated instances of
-   *  classes derived from this class with the the corresponding Transaction object (using
+   *  classes derived from this class with the corresponding Transaction object (using
    *  Transaction::addPlugin()), or register HOOK_TXN_CLOSE (but not both).
    *
    * @param HookType the type of hook you wish to register

include/tscpp/util/ts_meta.h

@@ -83,7 +83,7 @@ namespace meta
   };
 
   /** This is the final case - it forces the super class hierarchy.
-   * After defining the cases using the indexed case arguments, this is used to to perform the call.
+   * After defining the cases using the indexed case arguments, this is used to perform the call.
    * To increase the hierarchy depth, change the template argument to a larger number.
    */
   static constexpr CaseTag<9> CaseArg{};

include/wccp/Wccp.h

@@ -177,7 +177,7 @@ class ServiceGroup : public ServiceConstants
   self &setProtocol(uint8_t p); ///< Set protocol field to @a p.
 
   uint32_t getFlags() const;  ///< Get flags field.
-  self &setFlags(uint32_t f); ///< Set the flags flags in field to @a f.
+  self &setFlags(uint32_t f); ///< Set the flags in field to @a f.
   /// Set the flags in the flag field that are set in @a f.
   /// Other flags are unchanged.
   self &enableFlags(uint32_t f);

iocore/cache/Cache.cc

@@ -2901,7 +2901,7 @@ cplist_reconfigure()
            them equal */
         int64_t size_diff = (cp->disk_vols[disk_no]) ? largest_vol - cp->disk_vols[disk_no]->size : largest_vol;
         size_diff         = (size_diff < size_to_alloc) ? size_diff : size_to_alloc;
-        /* if size_diff == 0, then then the disks have volumes of the
+        /* if size_diff == 0, then the disks have volumes of the
            same sizes, so we don't need to balance the disks */
         if (size_diff == 0) {
           break;
@@ -3249,7 +3249,7 @@ CacheProcessor::open_write(Continuation *cont, int expected_size, const HttpCach
 }
 
 //----------------------------------------------------------------------------
-// Note: this should not be called from from the cluster processor, or bad
+// Note: this should not be called from the cluster processor, or bad
 // recursion could occur. This is merely a convenience wrapper.
 Action *
 CacheProcessor::remove(Continuation *cont, const HttpCacheKey *key, CacheFragType frag_type)

iocore/cache/CacheDir.cc

@@ -1099,8 +1099,7 @@ CacheSync::mainEvent(int event, Event *e)
       Debug("cache_dir_sync", "sync started");
       /* Don't sync the directory to disk if its not dirty. Syncing the
          clean directory to disk is also the cause of INKqa07151. Increasing
-         the serial serial causes the cache to recover more data
-         than necessary.
+         the serial number causes the cache to recover more data than necessary.
          The dirty bit it set in dir_insert, dir_overwrite and dir_delete_entry
        */
       if (!vol->header->dirty) {

iocore/cache/CacheHosting.cc

@@ -74,7 +74,7 @@ CacheHostMatcher::PrintFunc(void *opaque_data)
 
 // void CacheHostMatcher::AllocateSpace(int num_entries)
 //
-//  Allocates the the HostLeaf and Data arrays
+//  Allocates the HostLeaf and Data arrays
 //
 void
 CacheHostMatcher::AllocateSpace(int num_entries)

iocore/cache/CacheWrite.cc

@@ -1682,7 +1682,7 @@ CacheVC::openWriteStartBegin(int /* event ATS_UNUSED */, Event * /* e ATS_UNUSED
   }
 }
 
-// main entry point for writing of of non-http documents
+// main entry point for writing of non-http documents
 Action *
 Cache::open_write(Continuation *cont, const CacheKey *key, CacheFragType frag_type, int options, time_t apin_in_cache,
                   const char *hostname, int host_len)

iocore/cache/P_CacheDisk.h

@@ -46,7 +46,7 @@ struct CacheDisk;
 
 struct DiskVolBlock {
   uint64_t offset; // offset in bytes from the start of the disk
-  uint64_t len;    // length in in store blocks
+  uint64_t len;    // length in store blocks
   int number;
   unsigned int type : 3;
   unsigned int free : 1;

iocore/net/P_SSLNetVConnection.h

@@ -285,7 +285,7 @@ class SSLNetVConnection : public UnixNetVConnection,
   const char *protocol_contains(std::string_view tag) const override;
 
   /**
-   * Populate the current object based on the socket information in in the
+   * Populate the current object based on the socket information in the
    * con parameter and the ssl object in the arg parameter
    * This is logic is invoked when the NetVC object is created in a new thread context
    */

iocore/net/P_UnixNetState.h

@@ -30,7 +30,7 @@
 
    State information for a particular channel of a NetVConnection
    This information is private to the Net module.   It is only here
-   because of the the C++ compiler needs it to define NetVConnection.
+   because the C++ compiler needs it to define NetVConnection.
 
 
  ****************************************************************************/

iocore/net/P_UnixNetVConnection.h

@@ -252,7 +252,7 @@ class UnixNetVConnection : public NetVConnection, public NetEvent
   int mainEvent(int event, Event *e);
   virtual int connectUp(EThread *t, int fd);
   /**
-   * Populate the current object based on the socket information in in the
+   * Populate the current object based on the socket information in the
    * con parameter.
    * This is logic is invoked when the NetVC object is created in a new thread context
    */

lib/records/RecMessage.cc

@@ -196,7 +196,7 @@ RecMessageUnmarshalNext(RecMessage *msg, RecMessageItr *itr, RecRecord **record)
 
   ink_assert(eh->magic == REC_MESSAGE_ELE_MAGIC);
 
-  // If the file is corrupt, ignore the the rest of the file.
+  // If the file is corrupt, ignore the rest of the file.
   if (eh->magic != REC_MESSAGE_ELE_MAGIC) {
     Warning("Persistent statistics file records.stat is corrupted. Ignoring the rest of the file\n");
     return REC_ERR_FAIL;

mgmt/RecordsConfig.cc

@@ -624,7 +624,7 @@ static const RecordElement RecordsConfig[] =
   ,
   //       #  when_to_revalidate has 4 options:
   //       #
-  //       #  0 - default. use use cache directives or heuristic
+  //       #  0 - default. use cache directives or heuristic
   //       #  1 - stale if heuristic
   //       #  2 - always stale (always revalidate)
   //       #  3 - never stale

mgmt/api/CoreAPI.cc

@@ -856,7 +856,7 @@ EventIsActive(const char *event_name, bool *is_current)
  * only allow registering callbacks for general alarms.
  * Mimic remote side and have a separate structure (eg. hashtable) of
  * event callback functions for each type of event. The functions are also
- * stored in the the hashtable, not in the TM alarm processor model
+ * stored in the hashtable, not in the TM alarm processor model
  */
 TSMgmtError
 EventSignalCbRegister(const char *event_name, TSEventSignalFunc func, void *data)

mgmt/api/CoreAPIRemote.cc

@@ -999,7 +999,7 @@ EventSignalCbRegister(const char *event_name, TSEventSignalFunc func, void *data
  * Removes the callback function from the remote side callback table.
  * After removing the callback function, needs to check which events now
  * no longer have any callbacks registered at all; sends an unregister callback
- * notification to TM so that TM knows that that event doesn't have any
+ * notification to TM so that TM knows that event doesn't have any
  * remote callbacks registered for it
  * Input: event_name - the event to unregister the callback from; if NULL,
  *                     unregisters the specified func from all events

plugins/cache_promote/chance_policy.h

@@ -57,7 +57,7 @@ class ChancePolicy : public PromotionPolicy
     };
 
     if (nullptr == remap_id) {
-      TSError("[%s] no remap identifier specified for for stats, no stats will be used", PLUGIN_NAME);
+      TSError("[%s] no remap identifier specified for stats, no stats will be used", PLUGIN_NAME);
       return false;
     }
 

plugins/cache_promote/lru_policy.cc

@@ -266,7 +266,7 @@ LRUPolicy::stats_add(const char *remap_id)
   };
 
   if (nullptr == remap_id) {
-    TSError("[%s] no remap identifier specified for for stats, no stats will be used", PLUGIN_NAME);
+    TSError("[%s] no remap identifier specified for stats, no stats will be used", PLUGIN_NAME);
     return false;
   }
 

plugins/cachekey/pattern.cc

@@ -198,7 +198,7 @@ Pattern::process(const String &subject, StringVector &result)
 }
 
 /**
- * @brief PCRE matches a subject string against the the regex pattern.
+ * @brief PCRE matches a subject string against the regex pattern.
  * @param subject PCRE subject
  * @return true - matched, false - did not.
  */

plugins/experimental/access_control/pattern.cc

@@ -207,7 +207,7 @@ Pattern::process(const String &subject, StringVector &result)
 }
 
 /**
- * @brief PCRE matches a subject string against the the regex pattern.
+ * @brief PCRE matches a subject string against the regex pattern.
  * @param subject PCRE subject
  * @return true - matched, false - did not.
  */

plugins/experimental/parent_select/consistenthash.cc

@@ -490,7 +490,7 @@ PLNextHopConsistentHash::next(TSHttpTxn txnp, void *strategyTxn, const char *exc
           break;
         }
       }
-      // try other rings per per the ring mode
+      // try other rings per the ring mode
       switch (ring_mode) {
       case PL_NH_ALTERNATE_RING:
         if (pRec && groups > 0) {

plugins/experimental/parent_select/consistenthash_config.cc

@@ -171,7 +171,7 @@ createStrategiesFromFile(const char *file)
 
 /*
  * loads the contents of a file into a std::stringstream document.  If the file has a '#include file'
- * directive, that 'file' is read into the document beginning at the the point where the
+ * directive, that 'file' is read into the document beginning at the point where the
  * '#include' was found. This allows the 'strategy' and 'hosts' yaml files to be separate.  The
  * 'strategy' yaml file would then normally have the '#include hosts.yml' in it's beginning.
  */

plugins/prefetch/pattern.cc

@@ -197,7 +197,7 @@ Pattern::process(const String &subject, StringVector &result)
 }
 
 /**
- * @brief PCRE matches a subject string against the the regex pattern.
+ * @brief PCRE matches a subject string against the regex pattern.
  * @param subject PCRE subject
  * @return true - matched, false - did not.
  */

proxy/CacheControl.h

@@ -84,7 +84,7 @@ class CacheControlResult
   //    on which a parameter was set
   //   Used to tell if a parameter needs to
   //    be overridden by something that appeared
-  //    earlier in the the config file
+  //    earlier in the config file
   //
   int reval_line         = -1;
   int never_line         = -1;

proxy/ControlMatcher.cc

@@ -127,7 +127,7 @@ HostMatcher<Data, MatchResult>::PrintFunc(void *opaque_data)
 
 // void HostMatcher<Data,MatchResult>::AllocateSpace(int num_entries)
 //
-//  Allocates the the HostLeaf and Data arrays
+//  Allocates the HostLeaf and Data arrays
 //
 template <class Data, class MatchResult>
 void

proxy/ControlMatcher.h

@@ -69,7 +69,7 @@
  *   ip table - supports ip ranges.  A single ip address is treated as
  *       a range with the same beginning and end address.  The table is
  *       is divided up into a fixed number of  levels, indexed 8 bit
- *       boundaries, starting at the the high bit of the address.  Subsequent
+ *       boundaries, starting at the high bit of the address.  Subsequent
  *       levels are allocated only when needed.
  *
  ****************************************************************************/

proxy/ParentConsistentHash.cc

@@ -368,7 +368,7 @@ ParentConsistentHash::markParentUp(ParentResult *result)
 {
   pRecord *pRec;
 
-  //  Make sure that we are being called back with with a
+  //  Make sure that we are being called back with a
   //   result structure with a parent that is being retried
   ink_release_assert(result->retry == true);
   ink_assert(result->result == PARENT_SPECIFIED);

proxy/ParentSelection.h

@@ -177,7 +177,7 @@ class ParentRecord : public ControlBase
 //   between HttpTransact & the parent selection code.  The following
 ParentRecord *const extApiRecord = (ParentRecord *)0xeeeeffff;
 
-// used here to to set the number of ATSConsistentHashIter's
+// used here to set the number of ATSConsistentHashIter's
 // used in NextHopSelectionStrategy to limit the host group
 // size as well, group size is one to one with the number of rings
 constexpr const uint32_t MAX_GROUP_RINGS = 5;

proxy/ParentSelectionStrategy.cc

@@ -30,7 +30,7 @@ ParentSelectionStrategy::markParentDown(ParentResult *result, unsigned int fail_
   pRecord *pRec, *parents = result->rec->selection_strategy->getParents(result);
   int new_fail_count = 0;
 
-  //  Make sure that we are being called back with with a
+  //  Make sure that we are being called back with a
   //   result structure with a parent
   ink_assert(result->result == PARENT_SPECIFIED);
   if (result->result != PARENT_SPECIFIED) {
@@ -102,7 +102,7 @@ ParentSelectionStrategy::markParentUp(ParentResult *result)
   pRecord *pRec, *parents = result->rec->selection_strategy->getParents(result);
   int num_parents = result->rec->selection_strategy->numParents(result);
 
-  //  Make sure that we are being called back with with a
+  //  Make sure that we are being called back with a
   //   result structure with a parent that is being retried
   ink_release_assert(result->retry == true);
   ink_assert(result->result == PARENT_SPECIFIED);

proxy/PluginVC.cc

@@ -502,7 +502,7 @@ PluginVC::process_write_side(bool other_side_call)
   if (act_on <= 0) {
     if (ntodo > 0) {
       // Notify the continuation that we are "disabling"
-      //  ourselves due to to nothing to write
+      //  ourselves due to nothing to write
       write_state.vio.cont->handleEvent(VC_EVENT_WRITE_READY, &write_state.vio);
     }
     return;
@@ -700,7 +700,7 @@ PluginVC::process_read_side(bool other_side_call)
 //   This function may only be called while holding
 //      this->mutex
 //
-//   Tries to close the and dealloc the the vc
+//   Tries to close the and dealloc the vc
 //
 void
 PluginVC::process_close()

proxy/http/HttpSM.cc

@@ -1330,7 +1330,7 @@ HttpSM::state_common_wait_for_transform_read(HttpTransformInfo *t_info, HttpSMHa
 
   switch (event) {
   case HTTP_TUNNEL_EVENT_DONE:
-    // There are three reasons why the the tunnel could signal completed
+    // There are three reasons why the tunnel could signal completed
     //   1) there was error from the transform write
     //   2) there was an error from the data source
     //   3) the transform write completed before it sent
@@ -8085,7 +8085,7 @@ HttpSM::redirect_request(const char *arg_redirect_url, const int arg_redirect_le
       // RFC7230 § 5.5
       // The redirect URL lacked a scheme and so it is a relative URL.
       // The redirect URL did not begin with a slash, so we parsed some or all
-      // of the the relative URI path as the host.
+      // of the relative URI path as the host.
       // Prepend a slash and parse again.
       char redirect_url_leading_slash[arg_redirect_len + 1];
       redirect_url_leading_slash[0] = '/';

proxy/http/HttpSessionManager.h

@@ -95,7 +95,7 @@ class ServerSessionPool : public Continuation
   */
   HSMresult_t acquireSession(sockaddr const *addr, CryptoHash const &host_hash, TSServerSessionSharingMatchMask match_style,
                              HttpSM *sm, PoolableSession *&server_session);
-  /** Release a session to to pool.
+  /** Release a session to the pool.
    */
   void releaseSession(PoolableSession *ss);