<commit_before>package com.socrata.http.client

import scala.collection.JavaConverters._
import java.io.{IOException, Closeable}
import java.nio.channels.spi.SelectorProvider
import scala.concurrent.duration.FiniteDuration
import java.net.{InetSocketAddress, InetAddress}
import scala.util.hashing.MurmurHash3
import java.util.concurrent.{Executor, ConcurrentHashMap, ConcurrentLinkedQueue}
import java.nio.ByteBuffer
import scala.annotation.tailrec
import scala.util.Random
import java.nio.channels.SelectionKey
import java.nio.charset.StandardCharsets
import com.socrata.http.`-impl`.{NoopCloseable, IntrusivePriorityQueueNode, IntrusivePriorityQueue}

// Note: "response" must not be mutated after being passed to this
final class LivenessCheckTarget private[client] (private [client] val host: InetAddress, private [client] val port: Int, private val response: Array[Byte]) {
  def this(host: InetAddress, port: Int, response: String) = this(host, port, response.getBytes(StandardCharsets.UTF_8))

  private val address = host.getAddress

  override val hashCode = MurmurHash3.bytesHash(response, MurmurHash3.bytesHash(address, port))

  override def equals(o: Any) = o match {
    case that: LivenessCheckTarget =>
      java.util.Arrays.equals(this.address, that.address) && this.port == that.port && java.util.Arrays.equals(this.response, that.response)
    case _ => false
  }

  override lazy val toString =
    "LivenessCheckTarget(" + host + ", " + port + ", " + response.map("%02X" format _).mkString + ")"
}<commit_msg>Only use rand bytes to match jobs in liveness chk<commit_after>package com.socrata.http.client

import scala.collection.JavaConverters._
import java.io.{IOException, Closeable}
import java.nio.channels.spi.SelectorProvider
import scala.concurrent.duration.FiniteDuration
import java.net.{InetSocketAddress, InetAddress}
import scala.util.hashing.MurmurHash3
import java.util.concurrent.{Executor, ConcurrentHashMap, ConcurrentLinkedQueue}
import java.nio.ByteBuffer
import scala.annotation.tailrec
import scala.util.Random
import java.nio.channels.SelectionKey
import java.nio.charset.StandardCharsets
import com.socrata.http.`-impl`.{NoopCloseable, IntrusivePriorityQueueNode, IntrusivePriorityQueue}

// Note: "response" must not be mutated after being passed to this
final class LivenessCheckTarget private[client] (private [client] val host: InetAddress, private [client] val port: Int, private val response: Array[Byte]) {
  def this(host: InetAddress, port: Int, response: String) = this(host, port, response.getBytes(StandardCharsets.UTF_8))

  private val address = host.getAddress

  override val hashCode = MurmurHash3.bytesHash(response, MurmurHash3.bytesHash(address, port))

  override def equals(o: Any) = o match {
    case that: LivenessCheckTarget =>
      java.util.Arrays.equals(this.response, that.response)
    case _ => false
  }

  override lazy val toString =
    "LivenessCheckTarget(" + host + ", " + port + ", " + response.map("%02X" format _).mkString + ")"
}
{'fraction_non_alphanumeric': 0.10665783371977476, 'fraction_numerical': 0.003974826101358066, 'mean_word_length': 5.536796536796537, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 7, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6443348', 'n_tokens_mistral': 909, 'n_tokens_neox': 890, 'n_words': 225}