<commit_before>package io.reactors
package remote



import java.io._
import java.net._
import org.scalatest.FunSuite
import scala.sys.process._



class TcpRemoteTest extends FunSuite {
  test("tcp connection established") {
    val proc = Seq("java", "-cp", sys.props("java.class.path"), "io.reactors.remote.TcpRemoteTest").run()
    Thread.sleep(3000)

    val socket = new Socket("localhost", 9500)
    val bufferSize = TcpRemoteTest.bufferSize
    val totalBatches = 1000000
    val buffer = new Array[Byte](bufferSize)
    try {
      var j = 0
      while (j < totalBatches) {
        val os = socket.getOutputStream
        var i = 0
        while (i < bufferSize) {
          buffer(i) = 1
          i += 1
        }
        os.write(buffer, 0, bufferSize)
        j += 1
      }
    } finally {
      println("producer: sent all the batches")
      Thread.sleep(3000)
      proc.destroy()<commit_msg>Fix lint.<commit_after>package io.reactors
package remote



import java.io._
import java.net._
import org.scalatest.FunSuite
import scala.sys.process._



class TcpRemoteTest extends FunSuite {
  test("tcp connection established") {
    val proc = Seq(
      "java", "-cp", sys.props("java.class.path"), "io.reactors.remote.TcpRemoteTest"
    ).run()
    Thread.sleep(3000)

    val socket = new Socket("localhost", 9500)
    val bufferSize = TcpRemoteTest.bufferSize
    val totalBatches = 1000000
    val buffer = new Array[Byte](bufferSize)
    try {
      var j = 0
      while (j < totalBatches) {
        val os = socket.getOutputStream
        var i = 0
        while (i < bufferSize) {
          buffer(i) = 1
          i += 1
        }
        os.write(buffer, 0, bufferSize)
        j += 1
      }
    } finally {
      println("producer: sent all the batches")
      Thread.sleep(3000)
      proc.destroy()
{'fraction_non_alphanumeric': 0.11214442013129103, 'fraction_numerical': 0.02735229759299781, 'mean_word_length': 2.3683241252302025, 'pattern_counts': {'":': 0, '<': 7, '<?xml version=': 0, '>': 3, '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': '6989852', 'n_tokens_mistral': 623, 'n_tokens_neox': 560, 'n_words': 150}