server.ipynb

{
 "cells": [
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Importing all important libraries"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 75,
   "metadata": {},
   "outputs": [],
   "source": [
    "import socket\n",
    "import os\n",
    "import threading\n",
    "import yaml\n",
    "import io\n",
    "import math\n",
    "# ML Specific\n",
    "import numpy as np\n",
    "import pandas as pd\n",
    "from sklearn.model_selection import train_test_split\n",
    "from nltk.tokenize import RegexpTokenizer\n",
    "from sklearn.neighbors import KNeighborsClassifier"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Initializing important variables"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 76,
   "metadata": {},
   "outputs": [],
   "source": [
    "# Read YAML file\n",
    "with open(\"config.yaml\", 'r') as stream:\n",
    "    config_loaded = yaml.safe_load(stream)\n",
    "\n",
    "# reading from config file\n",
    "port = config_loaded[\"server\"][\"port\"]\n",
    "datasets = config_loaded[\"datasets\"]\n",
    "s_nodes_count = config_loaded[\"kazaa\"][\"s_nodes\"]\n",
    "o_nodes_count = config_loaded[\"kazaa\"][\"o_node_per\"]\n",
    "all_nodes = s_nodes_count + (s_nodes_count*o_nodes_count)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 77,
   "metadata": {},
   "outputs": [],
   "source": [
    "# Global fields\n",
    "lock = threading.Lock()\n",
    "clientId = -1\n",
    "threadCount = 0\n",
    "node_threads = [None]*all_nodes\n",
    "ports = []\n",
    "ips = []\n",
    "download_speed = [0]*all_nodes\n",
    "gpu_ram_free = [0]*all_nodes\n",
    "ram_free = [0]*all_nodes\n",
    "cpu_free = [0]*all_nodes\n",
    "cpu_cores = [0]*all_nodes\n",
    "status = ['']*all_nodes\n",
    "kazaa_constant = [0]*all_nodes\n",
    "# format: snode_(ip,port,connection_object) as key : [(ip,port,connection)i] for i=onode_count as value \n",
    "network = {}\n",
    "\n",
    "######################################## Connections ################################\n",
    "# format: [connection_objects] for all nodes\n",
    "connections = []\n",
    "# format: [(ip, port, connection_object)i] for i = snode_count\n",
    "snode_connections = []\n",
    "node_connection = None"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "#### Formats:\n",
    "Kazaa_constant = snode_(ip,port,connection_object) as key : [(ip,port,connection)i] for i=onode_count as value "
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "connections = [connection_objects] for all nodes"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "snode_connections = [(ip, port, connection_object)i] for i = snode_count"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Starting our main socket"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 78,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "The server's IP address:  192.168.40.189\n"
     ]
    }
   ],
   "source": [
    "# giving a dynamic IP and reuseable port to the server\n",
    "port += 1\n",
    "node_connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM)\n",
    "node_connection.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)\n",
    "host = socket.gethostname()\n",
    "print(\"The server's IP address: \", socket.gethostbyname(host))\n",
    "try:\n",
    "    node_connection.bind((host, port))\n",
    "except socket.error as e:\n",
    "    print(str(e))\n",
    "node_connection.listen(all_nodes)\n",
    "\n",
    "# Write server host to config.yaml file\n",
    "config_loaded[\"server\"][\"ip\"] = socket.gethostbyname(host)\n",
    "config_loaded[\"server\"][\"port\"] = port\n",
    "with io.open('config.yaml', 'w', encoding='utf8') as outfile:\n",
    "    yaml.dump(config_loaded, outfile, default_flow_style=False, allow_unicode=True)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Defining main functions required"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 79,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "'All defined'"
      ]
     },
     "execution_count": 79,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "# socket send consistent method \n",
    "# it sends the string, waits for the length of string client received, compares this length to the actual length. If both are equal\n",
    "# it sends ack else, it resends the same txt again.\n",
    "def socket_send(connection, txt):\n",
    "    ack = False\n",
    "    print(\">> sending\",txt+\"...\")\n",
    "    while(not ack):\n",
    "        connection.send(str.encode(txt))\n",
    "        len_txt = int(connection.recv(1024).decode('utf-8'))\n",
    "        if len_txt == len(txt):\n",
    "            connection.send(str.encode(\"ack\"))\n",
    "            ack = True\n",
    "        else:\n",
    "            connection.send(str.encode(\"resending\"))\n",
    "    print(\">> sent\")\n",
    "\n",
    "# socket receive consistent method \n",
    "# it receives the string, then sends its size back to the server and then it waits for an acknowledgement, If ack is received it \n",
    "# breaks out of the loop\n",
    "def socket_rcv(connection, size=1024):\n",
    "    ack = False\n",
    "    while(not ack):\n",
    "        txt = connection.recv(size).decode('utf-8')\n",
    "        connection.send(str.encode(str(len(txt))))\n",
    "        ack = True if connection.recv(size).decode('utf-8') == \"ack\" else False\n",
    "    print(\">> received\", txt+\"...\")\n",
    "    return txt\n",
    "    \n",
    "# giving minimum requirement of RAM for supernode\n",
    "def get_required_ram(fileSize, node=\"s\"):\n",
    "    amount = fileSize/s_nodes_count\n",
    "    if(node == \"o\"):\n",
    "        amount /= o_nodes_count\n",
    "    return amount\n",
    "        \n",
    "# calculating kazaa constant on the basis of which we are going to classify who is going to be a supernode or ordinary node\n",
    "def cal_kazaa_constant(id):\n",
    "    data_per_region = get_required_ram(size)\n",
    "    # /10 means to get data downloaded in max 10 secs\n",
    "    bytes_ps = data_per_region/10\n",
    "    kazaa_constant[id] = (((gpu_ram_free[id]+ram_free[id] >= data_per_region)*0.5)\n",
    "                          +(1 if (download_speed[id]/bytes_ps) >= 1 else (download_speed[id]/bytes_ps))*0.2\n",
    "                          +((gpu_ram_free[id]/(max(gpu_ram_free) if max(gpu_ram_free) != 0 else 1))*0.15)\n",
    "                          +((ram_free[id]/(max(ram_free) if max(ram_free) != 0 else 1))*0.075)\n",
    "                          +((cpu_free[id]/100)*0.05)\n",
    "                          +(1 if (cpu_cores[id]/8)>=1 else (cpu_cores[id]/8)*0.025)\n",
    "                          )\n",
    "\n",
    "# classifying nodes into supernode or ordinary node\n",
    "def get_node_status(id):\n",
    "    const = kazaa_constant[id]\n",
    "    a = kazaa_constant.copy()\n",
    "    a.sort()\n",
    "    if const in a[len(a)-s_nodes_count:]:\n",
    "        return \"s\"\n",
    "    else:\n",
    "        return \"o\"\n",
    "\n",
    "# assigning onodes to supernodes\n",
    "def create_network():\n",
    "    d2_lst = []\n",
    "    for i in range(len(ports)):\n",
    "        lst = [ips[i], ports[i], status[i], kazaa_constant[i], connections[i]]\n",
    "        d2_lst.append(lst)\n",
    "    \n",
    "    headers = ['IP', 'Port', 'Status', 'Kazaa Constant', 'Connection']\n",
    "    df = pd.DataFrame(d2_lst, columns = headers)\n",
    "    df = df.sort_values(by='Kazaa Constant', ascending=False)\n",
    "    \n",
    "    i = 0\n",
    "    for index1, row1 in df[:s_nodes_count].iterrows():\n",
    "        network[(row1['IP'], row1['Port'], row1['Connection'])] = []\n",
    "        start = df.shape[0] - o_nodes_count*(i+1)\n",
    "        end = df.shape[0] - o_nodes_count*i\n",
    "        for index2, row2 in df[start:end].iterrows():\n",
    "            network[(row1['IP'], row1['Port'], row1['Connection'])].append((row2['IP'], row2['Port'], row2['Connection']))\n",
    "        i+=1\n",
    "\n",
    "\n",
    "# cleaning the text of mails with respect to a tockenizer\n",
    "def clean_str(string, reg = RegexpTokenizer(r'[a-z]+')):\n",
    "    string = string.lower()\n",
    "    tokens = reg.tokenize(string)\n",
    "    return \" \".join(tokens)\n",
    "\n",
    "def send_rows_snode(connection, df, div, index, headers):\n",
    "    socket_send(connection, \"rcv:\"+str(div))\n",
    "    socket_send(connection, \"rcv:\"+headers)\n",
    "    for i, row in df[int(div*index):int(div*(index+1))].iterrows():\n",
    "        socket_send(connection, str(row[0])+\":\"+str(row[1])+\":\"+str(row[2])+\":\"+str(row[3]))\n",
    "        ack = socket_rcv(connection)\n",
    "        while(ack != \"rcvd\"):\n",
    "            socket_send(connection, str(row[0])+\":\"+str(row[1])+\":\"+str(row[2])+\":\"+str(row[3]))\n",
    "            ack = socket_rcv(connection)\n",
    "\n",
    "# function to be run in independent thread\n",
    "def multi_threaded_client(connection, id):\n",
    "    socket_send(connection, 'Server is working:')\n",
    "    \n",
    "    # receiving system info\n",
    "    data = socket_rcv(connection)\n",
    "    if data.startswith(\"rcv:\"):\n",
    "        count = int(data[len(\"rcv:\"):])\n",
    "        if(count == 5):\n",
    "            download_speed[id] = float(socket_rcv(connection)[len(\"dsp:\"):])\n",
    "            gpu_ram_free[id] = float(socket_rcv(connection)[len(\"gpu:\"):])\n",
    "            ram_free[id] = float(socket_rcv(connection)[len(\"ram:\"):])\n",
    "            cpu_free[id] = float(socket_rcv(connection)[len(\"cpu:\"):])\n",
    "            cpu_cores[id] = int(socket_rcv(connection)[len(\"cor:\"):])\n",
    "\n",
    "            # sending ack\n",
    "            send_str = \"ack: received following system info:  \\nDownload_speed = \" + str(download_speed[id]) + \"B \\nFree_GPU_RAM = \" + str(gpu_ram_free[id]) + \"B \\nFree_RAM = \" + str(ram_free[id]) + \"B \\nFree_CPU = \" + str(cpu_free[id]) + \" \\nCPU_Cores = \" + str(cpu_cores[id])\n",
    "            socket_send(connection, send_str)\n",
    "    lock.acquire()\n",
    "    connections.append(connection)\n",
    "    lock.release()\n",
    "\n",
    "def most_frequent(List):\n",
    "    return max(set(List), key = List.count)\n",
    "\n",
    "\"All defined\""
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Getting a dataset value"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 80,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Which dataset you want to use from 0 - 0 : 0\n"
     ]
    }
   ],
   "source": [
    "# assuming dataset uploaded by the user\n",
    "while(True):\n",
    "    try:\n",
    "        fileNumber = int(input(\"Which dataset you want to use from 0 - \" + str(len(datasets)-1) + \" : \"))\n",
    "        if fileNumber < len(datasets):\n",
    "            break\n",
    "    except:\n",
    "        pass\n",
    "size = os.path.getsize(datasets[fileNumber]) "
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Accepting connection from all nodes"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "accepting connection -> receiving count of parameters the nodes want to share -> receiving parameters -> sending an ack with all the received parameters"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 81,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Socket is listening..\n",
      ">> sending Server is working:...\n",
      "Thread Number: 1 - Connected to: 192.168.40.189:36106\n",
      ">> sent\n",
      ">> received rcv:5...\n",
      ">> sendingThread Number: 2 - Connected to: 192.168.40.189:36168\n",
      " Server is working:...\n",
      ">> sent\n",
      ">> received rcv:5...\n",
      ">> received dsp:486451.4990844669...\n",
      ">> received gpu:0...\n",
      ">> received ram:11109564416...\n",
      ">> received cpu:82.5...\n",
      ">> received cor:4...\n",
      ">> sending ack: received following system info:  \n",
      "Download_speed = 486451.4990844669B \n",
      "Free_GPU_RAM = 0.0B \n",
      "Free_RAM = 11109564416.0B \n",
      "Free_CPU = 82.5 \n",
      "CPU_Cores = 4...\n",
      ">> sent\n",
      ">> received dsp:191531.06234391162...\n",
      ">> received gpu:0...\n",
      ">> received ram:11082366976...\n",
      ">> received cpu:82.4...\n",
      ">> received cor:4...\n",
      ">> sending ack: received following system info:  \n",
      "Download_speed = 191531.06234391162B \n",
      "Free_GPU_RAM = 0.0B \n",
      "Free_RAM = 11082366976.0B \n",
      "Free_CPU = 82.4 \n",
      "CPU_Cores = 4...\n",
      ">> sent\n"
     ]
    }
   ],
   "source": [
    "# always open for more clients to connect\n",
    "print('Socket is listening..')\n",
    "while(threadCount != all_nodes):\n",
    "    Client, address = node_connection.accept()\n",
    "    clientId += 1\n",
    "    \n",
    "    node_threads[threadCount] = threading.Thread(target = multi_threaded_client, args = (Client, clientId))\n",
    "    node_threads[threadCount].start()\n",
    "    \n",
    "    threadCount += 1\n",
    "    ips.append(address[0])\n",
    "    ports.append(address[1])\n",
    "    print('Thread Number: ' + str(threadCount) + \" - \" + 'Connected to: ' + address[0] + ':' + str(address[1]))\n",
    "\n",
    "for thread in node_threads:\n",
    "    thread.join()"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Initiating Kazaa"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "calculating kazaa_constant for all nodes -> fetching node status -> sending node status to the respective node -> creating a network from all the available nodes -> getting IP of each snode again -> sending this new IP to onodes in their respective region"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 85,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Constants calculated are:  [0.8287499999999999, 0.8285163917212575]\n",
      "Statuses calculated are:  ['s', 'o']\n",
      ">> sending status:s...\n",
      ">> sent\n",
      ">> sending k_const:0.8287499999999999...\n",
      ">> sent\n",
      ">> sending status:o...\n",
      ">> sent\n",
      ">> sending k_const:0.8285163917212575...\n",
      ">> sent\n"
     ]
    }
   ],
   "source": [
    "# creates a nerwork of supernodes and ordinary nodes, and introduce them to each other\n",
    "if(len(connections) >= all_nodes):\n",
    "    #initiate_kazaa()\n",
    "    for i in range(len(connections)):\n",
    "        cal_kazaa_constant(i)\n",
    "    \n",
    "    print(\"Constants calculated are: \", kazaa_constant)\n",
    "    \n",
    "    for i in range(len(connections)):\n",
    "        status[i] = get_node_status(i)\n",
    "        \n",
    "    print(\"Statuses calculated are: \", status)\n",
    "        \n",
    "    for connection in connections:\n",
    "        send_str = \"status:\" + status[connections.index(connection)]\n",
    "        socket_send(connection, send_str)\n",
    "        send_str = \"k_const:\" + str(kazaa_constant[connections.index(connection)])\n",
    "        socket_send(connection, send_str)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 86,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "waiting to receive snodes ip:port to be shared among its region ordinary nodes...\n",
      ">> received ubuntu:4355...\n",
      "rcvd: ubuntu:4355\n",
      ">> sending ubuntu:4355...\n",
      ">> sent\n"
     ]
    }
   ],
   "source": [
    "# creates a nerwork of supernodes and ordinary nodes, and introduce them to each other\n",
    "if(len(connections) >= all_nodes):    \n",
    "    # creating a network topology as in kazaa\n",
    "    create_network()\n",
    "    \n",
    "    for (sIP, sPort, sConnection), onodes in network.items():\n",
    "        onodes_IP_PORTS_to_send = len(onodes)\n",
    "        snode_connections.append((sIP, sPort, sConnection))\n",
    "        print(\"waiting to receive snodes ip:port to be shared among its region ordinary nodes...\")\n",
    "        ip_port = socket_rcv(sConnection).split(\":\")\n",
    "        send_snode_IP_PORT = ip_port[0] + \":\" + ip_port[1]\n",
    "        print(\"rcvd: \" + send_snode_IP_PORT)\n",
    "        for (oIP, oPort, oConnection) in onodes:\n",
    "            socket_send(oConnection, send_snode_IP_PORT)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Ensemble Distribution"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "Reading the data -> cleaning the data -> Dividing the data into number of super nodes -> sending the data to respective supernodes"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 87,
   "metadata": {
    "scrolled": true
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Sending data...\n",
      ">> sending rcv:248...\n",
      ">> sent\n",
      ">> sending rcv:Acceleration:Speed(m/s):Angle:Target...\n",
      ">> sent\n",
      ">> sending 186.0:28.0:32.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 187.0:29.0:33.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 188.0:30.0:34.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 189.0:31.0:35.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 190.0:32.0:36.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 191.0:33.0:37.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 192.0:34.0:38.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 193.0:35.0:39.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 194.0:36.0:40.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 195.0:37.0:41.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 160.0:41.0:49.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 161.0:42.0:50.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 162.0:43.0:51.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 163.0:44.0:52.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 164.0:45.0:53.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 165.0:46.0:54.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 166.0:47.0:55.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 167.0:48.0:56.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 168.0:49.0:57.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 169.0:50.0:58.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 195.0:33.0:62.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 196.0:34.0:63.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 197.0:35.0:64.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 198.0:36.0:65.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 199.0:37.0:66.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 200.0:38.0:67.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 201.0:39.0:68.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 202.0:40.0:69.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 203.0:41.0:70.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 204.0:42.0:71.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 195.0:33.0:62.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 196.0:34.0:63.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 197.0:35.0:64.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 198.0:36.0:65.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 199.0:37.0:66.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 200.0:38.0:67.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 201.0:39.0:68.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 202.0:40.0:69.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 203.0:41.0:70.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 204.0:42.0:71.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 156.0:34.0:42.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 157.0:35.0:43.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 158.0:36.0:44.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 159.0:37.0:45.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 160.0:38.0:46.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 161.0:39.0:47.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 162.0:40.0:48.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 163.0:41.0:49.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 164.0:42.0:50.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 165.0:43.0:51.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 201.0:22.0:39.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 202.0:23.0:40.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 203.0:24.0:41.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 204.0:25.0:42.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 205.0:26.0:43.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 206.0:27.0:44.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 207.0:28.0:45.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 208.0:29.0:46.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 209.0:30.0:47.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 210.0:31.0:48.3:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 121.0:21.0:45.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 122.0:22.0:46.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 123.0:23.0:47.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 124.0:24.0:48.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 125.0:25.0:49.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 126.0:26.0:50.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 127.0:27.0:51.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 128.0:28.0:52.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 129.0:29.0:53.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 130.0:30.0:54.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 118.0:17.6:41.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 119.0:18.6:42.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 120.0:19.6:43.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 121.0:20.6:44.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 122.0:21.6:45.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 123.0:22.6:46.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 124.0:23.6:47.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 125.0:24.6:48.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 126.0:25.6:49.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 127.0:26.6:50.8:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 292.0:17.35:56.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 293.0:18.35:57.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 294.0:19.35:58.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 295.0:20.35:59.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 296.0:21.35:60.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 297.0:22.35:61.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 298.0:23.35:62.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 299.0:24.35:63.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 300.0:25.35:64.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 301.0:26.35:65.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 305.0:19.82:58.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 306.0:20.82:59.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 307.0:21.82:60.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 308.0:22.82:61.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 309.0:23.82:62.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 310.0:24.82:63.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 311.0:25.82:64.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 312.0:26.82:65.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 210.0:18.26:59.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 211.0:19.26:60.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 212.0:20.26:61.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 213.0:21.26:62.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 214.0:22.26:63.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 215.0:23.26:64.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 216.0:24.26:65.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 217.0:25.26:66.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 218.0:26.26:67.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 219.0:27.26:68.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 132.0:29.0:65.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 133.0:30.0:66.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 134.0:31.0:67.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 135.0:32.0:68.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 136.0:33.0:69.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 137.0:34.0:70.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 138.0:35.0:71.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 139.0:36.0:72.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 140.0:37.0:73.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 141.0:38.0:74.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 114.0:20.0:22.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 115.0:21.0:23.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 116.0:22.0:24.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 117.0:23.0:25.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 118.0:24.0:26.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 119.0:25.0:27.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 120.0:26.0:28.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 121.0:27.0:29.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 122.0:28.0:30.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 123.0:29.0:31.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 250.0:22.0:11.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 251.0:23.0:12.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 252.0:24.0:13.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 253.0:25.0:14.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 254.0:26.0:15.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 255.0:27.0:16.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 256.0:28.0:17.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 257.0:29.0:18.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 258.0:30.0:19.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 259.0:31.0:20.6:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 196.0:19.0:18.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 197.0:20.0:19.0:Scored...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 198.0:21.0:20.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 199.0:22.0:21.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 200.0:23.0:22.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 201.0:24.0:23.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 202.0:25.0:24.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 203.0:26.0:25.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 204.0:27.0:26.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 205.0:28.0:27.0:Scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 407.0:31.0:9.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 408.0:32.0:10.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 409.0:33.0:11.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 410.0:34.0:12.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 411.0:35.0:13.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 412.0:36.0:14.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 413.0:37.0:15.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 414.0:38.0:16.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 415.0:39.0:17.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 416.0:40.0:18.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 179.0:48.6:9.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 180.0:49.6:10.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 181.0:50.6:11.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 182.0:51.6:12.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 183.0:52.6:13.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 184.0:53.6:14.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 185.0:54.6:15.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 186.0:55.6:16.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 187.0:56.6:17.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 188.0:57.6:18.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 87.0:16.0:17.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 88.0:17.0:18.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 89.0:18.0:19.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 90.0:19.0:20.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 91.0:20.0:21.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 92.0:21.0:22.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 93.0:22.0:23.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 94.0:23.0:24.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 95.0:24.0:25.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 96.0:25.0:26.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 156.0:23.0:12.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 157.0:24.0:13.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 158.0:25.0:14.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 159.0:26.0:15.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 160.0:27.0:16.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 161.0:28.0:17.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 162.0:29.0:18.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 163.0:30.0:19.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 164.0:31.0:20.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 165.0:32.0:21.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 61.0:15.0:9.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 62.0:16.0:10.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 63.0:17.0:11.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 64.0:18.0:12.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 65.0:19.0:13.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 66.0:20.0:14.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 67.0:21.0:15.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 68.0:22.0:16.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 69.0:23.0:17.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 70.0:24.0:18.0:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 18.0:6.52:11.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 19.0:7.52:12.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 20.0:8.52:13.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 21.0:9.52:14.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 22.0:10.52:15.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 23.0:11.52:16.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 24.0:12.52:17.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 25.0:13.52:18.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 26.0:14.52:19.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 27.0:15.52:20.3:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 116.0:27.6:13.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 117.0:28.6:14.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 118.0:29.6:15.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 119.0:30.6:16.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 120.0:31.6:17.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 121.0:32.6:18.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 122.0:33.6:19.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 123.0:34.6:20.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 124.0:35.6:21.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 125.0:36.6:22.2:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 38.1:21.5:9.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 39.1:22.5:10.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 40.1:23.5:11.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 41.1:24.5:12.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 42.1:25.5:13.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 43.1:26.5:14.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 44.1:27.5:15.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 45.1:28.5:16.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 46.1:29.5:17.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 47.1:30.5:18.6:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 73.0:24.0:10.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 74.0:25.0:11.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 75.0:26.0:12.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 76.0:27.0:13.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 77.0:28.0:14.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 78.0:29.0:15.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 79.0:30.0:16.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 80.0:31.0:17.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 81.0:32.0:18.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 82.0:33.0:19.5:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 83.5:36.0:11.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 84.5:37.0:12.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 85.5:38.0:13.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 86.5:39.0:14.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 87.5:40.0:15.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 88.5:41.0:16.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 89.5:42.0:17.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 90.5:43.0:18.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 91.5:44.0:19.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      ">> sending 92.5:45.0:20.8:Not-scored...\n",
      ">> sent\n",
      ">> received rcvd...\n",
      "Sent all data to 192.168.40.189 at port 36106\n"
     ]
    }
   ],
   "source": [
    "if(len(connections) >= all_nodes):\n",
    "    # division, sending of dataset to supernodes, receiving predictions\n",
    "    # ensemble_distribution()\n",
    "    df = pd.read_csv(datasets[0])\n",
    "    \n",
    "    # data per supernode\n",
    "    division = math.ceil(df.shape[0]/s_nodes_count)\n",
    "    \n",
    "    # headers\n",
    "    headers = \":\".join(list(df.columns))\n",
    "    \n",
    "    index = 0\n",
    "    print(\"Sending data...\")\n",
    "    for snode_connection in snode_connections:\n",
    "        send_rows_snode(snode_connection[2], df, division, index, headers)\n",
    "        print(\"Sent all data to\", snode_connection[0], \"at port\", snode_connection[1])\n",
    "        index += 1"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# X_Test Distribution"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 30,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Write any penalty parameters to get classified (space separated):190.0 32.0 36.0\n",
      ">> sending rcv_test:190.0:32.0:36.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n"
     ]
    }
   ],
   "source": [
    "text = list(map(float, input(\"Write any penalty parameters to get classified (space separated):\").split()))\n",
    "predictions = []\n",
    "for snode_connection in snode_connections:\n",
    "    socket_send(snode_connection[2], \"rcv_test:\"+(\":\".join(map(str,text))))\n",
    "    # a word of either HAM or SPAM\n",
    "    predictions.append(socket_rcv(snode_connection[2]))\n",
    "\n",
    "print(most_frequent(predictions),\"is your prediction for the above added Penalty parameters.\")\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 90,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">> sending rcv_test:186.0:28.0:32.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:187.0:29.0:33.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:188.0:30.0:34.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:189.0:31.0:35.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:190.0:32.0:36.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:191.0:33.0:37.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:192.0:34.0:38.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:193.0:35.0:39.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:194.0:36.0:40.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:195.0:37.0:41.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:160.0:41.0:49.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:161.0:42.0:50.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:162.0:43.0:51.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:163.0:44.0:52.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:164.0:45.0:53.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:165.0:46.0:54.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:166.0:47.0:55.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:167.0:48.0:56.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:168.0:49.0:57.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:169.0:50.0:58.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:195.0:33.0:62.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:196.0:34.0:63.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:197.0:35.0:64.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:198.0:36.0:65.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:199.0:37.0:66.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:200.0:38.0:67.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:201.0:39.0:68.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:202.0:40.0:69.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:203.0:41.0:70.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:204.0:42.0:71.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:195.0:33.0:62.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:196.0:34.0:63.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:197.0:35.0:64.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:198.0:36.0:65.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:199.0:37.0:66.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:200.0:38.0:67.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:201.0:39.0:68.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:202.0:40.0:69.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:203.0:41.0:70.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:204.0:42.0:71.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:156.0:34.0:42.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:157.0:35.0:43.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:158.0:36.0:44.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:159.0:37.0:45.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:160.0:38.0:46.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:161.0:39.0:47.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:162.0:40.0:48.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:163.0:41.0:49.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:164.0:42.0:50.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:165.0:43.0:51.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:201.0:22.0:39.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:202.0:23.0:40.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:203.0:24.0:41.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:204.0:25.0:42.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:205.0:26.0:43.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:206.0:27.0:44.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:207.0:28.0:45.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:208.0:29.0:46.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:209.0:30.0:47.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:210.0:31.0:48.3...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:121.0:21.0:45.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:122.0:22.0:46.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:123.0:23.0:47.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:124.0:24.0:48.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:125.0:25.0:49.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:126.0:26.0:50.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:127.0:27.0:51.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:128.0:28.0:52.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:129.0:29.0:53.0...\n",
      ">> sent\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:130.0:30.0:54.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:118.0:17.6:41.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:119.0:18.6:42.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:120.0:19.6:43.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:121.0:20.6:44.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:122.0:21.6:45.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:123.0:22.6:46.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:124.0:23.6:47.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:125.0:24.6:48.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:126.0:25.6:49.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:127.0:26.6:50.8...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:292.0:17.35:56.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:293.0:18.35:57.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:294.0:19.35:58.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:295.0:20.35:59.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:296.0:21.35:60.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:297.0:22.35:61.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:298.0:23.35:62.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:299.0:24.35:63.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:300.0:25.35:64.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:301.0:26.35:65.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:305.0:19.82:58.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:306.0:20.82:59.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:307.0:21.82:60.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:308.0:22.82:61.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:309.0:23.82:62.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:310.0:24.82:63.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:311.0:25.82:64.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:312.0:26.82:65.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:210.0:18.26:59.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:211.0:19.26:60.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:212.0:20.26:61.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:213.0:21.26:62.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:214.0:22.26:63.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:215.0:23.26:64.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:216.0:24.26:65.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:217.0:25.26:66.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:218.0:26.26:67.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:219.0:27.26:68.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:132.0:29.0:65.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:133.0:30.0:66.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:134.0:31.0:67.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:135.0:32.0:68.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:136.0:33.0:69.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:137.0:34.0:70.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:138.0:35.0:71.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:139.0:36.0:72.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:140.0:37.0:73.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:141.0:38.0:74.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:114.0:20.0:22.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:115.0:21.0:23.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:116.0:22.0:24.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:117.0:23.0:25.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:118.0:24.0:26.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:119.0:25.0:27.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:120.0:26.0:28.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:121.0:27.0:29.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:122.0:28.0:30.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:123.0:29.0:31.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:250.0:22.0:11.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:251.0:23.0:12.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:252.0:24.0:13.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:253.0:25.0:14.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:254.0:26.0:15.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:255.0:27.0:16.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:256.0:28.0:17.6...\n",
      ">> sent\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:257.0:29.0:18.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:258.0:30.0:19.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:259.0:31.0:20.6...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:196.0:19.0:18.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:197.0:20.0:19.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:198.0:21.0:20.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:199.0:22.0:21.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:200.0:23.0:22.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:201.0:24.0:23.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:202.0:25.0:24.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:203.0:26.0:25.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:204.0:27.0:26.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:205.0:28.0:27.0...\n",
      ">> sent\n",
      ">> received Scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:407.0:31.0:9.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:408.0:32.0:10.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:409.0:33.0:11.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:410.0:34.0:12.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:411.0:35.0:13.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:412.0:36.0:14.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:413.0:37.0:15.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:414.0:38.0:16.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:415.0:39.0:17.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:416.0:40.0:18.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:179.0:48.6:9.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:180.0:49.6:10.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:181.0:50.6:11.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:182.0:51.6:12.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:183.0:52.6:13.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:184.0:53.6:14.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:185.0:54.6:15.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:186.0:55.6:16.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:187.0:56.6:17.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:188.0:57.6:18.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:87.0:16.0:17.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:88.0:17.0:18.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:89.0:18.0:19.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:90.0:19.0:20.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:91.0:20.0:21.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:92.0:21.0:22.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:93.0:22.0:23.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:94.0:23.0:24.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:95.0:24.0:25.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:96.0:25.0:26.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:156.0:23.0:12.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:157.0:24.0:13.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:158.0:25.0:14.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:159.0:26.0:15.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:160.0:27.0:16.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:161.0:28.0:17.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:162.0:29.0:18.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:163.0:30.0:19.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:164.0:31.0:20.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:165.0:32.0:21.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:61.0:15.0:9.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:62.0:16.0:10.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:63.0:17.0:11.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:64.0:18.0:12.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:65.0:19.0:13.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:66.0:20.0:14.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:67.0:21.0:15.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:68.0:22.0:16.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:69.0:23.0:17.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:70.0:24.0:18.0...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:18.0:6.52:11.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:19.0:7.52:12.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:20.0:8.52:13.3...\n",
      ">> sent\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:21.0:9.52:14.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:22.0:10.52:15.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:23.0:11.52:16.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:24.0:12.52:17.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:25.0:13.52:18.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:26.0:14.52:19.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:27.0:15.52:20.3...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:116.0:27.6:13.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:117.0:28.6:14.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:118.0:29.6:15.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:119.0:30.6:16.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:120.0:31.6:17.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:121.0:32.6:18.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:122.0:33.6:19.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:123.0:34.6:20.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:124.0:35.6:21.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:125.0:36.6:22.2...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:38.1:21.5:9.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:39.1:22.5:10.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:40.1:23.5:11.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:41.1:24.5:12.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:42.1:25.5:13.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:43.1:26.5:14.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:44.1:27.5:15.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:45.1:28.5:16.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:46.1:29.5:17.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:47.1:30.5:18.6...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:73.0:24.0:10.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:74.0:25.0:11.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:75.0:26.0:12.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:76.0:27.0:13.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:77.0:28.0:14.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:78.0:29.0:15.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:79.0:30.0:16.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:80.0:31.0:17.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:81.0:32.0:18.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:82.0:33.0:19.5...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:83.5:36.0:11.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:84.5:37.0:12.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:85.5:38.0:13.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:86.5:39.0:14.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:87.5:40.0:15.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:88.5:41.0:16.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:89.5:42.0:17.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:90.5:43.0:18.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:91.5:44.0:19.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n",
      ">> sending rcv_test:92.5:45.0:20.8...\n",
      ">> sent\n",
      ">> received Not-scored...\n",
      "Scored is your prediction for the above added Penalty parameters.\n"
     ]
    }
   ],
   "source": [
    "predictions = []\n",
    "for index, row in df[list(df.columns)[:-1]].iterrows():\n",
    "    text = list(map(float, (str(row['Acceleration'])+\" \"+str(row['Speed(m/s)'])+\" \"+str(row['Angle'])).split()))\n",
    "    for snode_connection in snode_connections:\n",
    "        socket_send(snode_connection[2], \"rcv_test:\"+(\":\".join(map(str,text))))\n",
    "        # a word of either HAM or SPAM\n",
    "        predictions.append(socket_rcv(snode_connection[2]))\n",
    "\n",
    "    print(most_frequent(predictions),\"is your prediction for the above added Penalty parameters.\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 105,
   "metadata": {},
   "outputs": [],
   "source": [
    "pd_pred = pd.DataFrame(predictions, columns=[\"Target\"])\n",
    "pd_actual = df[['Target']]"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 111,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "100.0 % of the predicted values are equal to the actual values.\n"
     ]
    }
   ],
   "source": [
    "print(list((pd_pred == pd_actual).Target.value_counts())[0]/df.shape[0]*100, \"% of the predicted values are equal to the actual values.\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "interpreter": {
   "hash": "31f2aee4e71d21fbe5cf8b01ff0e069b9275f58929596ceb00d14d90e3e16cd6"
  },
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.8.5"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}