node1.ipynb

{
 "cells": [
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Importing all important libraries"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 78,
   "metadata": {},
   "outputs": [],
   "source": [
    "import socket\n",
    "import psutil as p\n",
    "import yaml\n",
    "import os\n",
    "import pynvml\n",
    "import threading\n",
    "import speedtest\n",
    "import math\n",
    "# ML Specific\n",
    "import pandas as pd\n",
    "import numpy as np\n",
    "from sklearn.model_selection import train_test_split\n",
    "from sklearn.metrics import classification_report, accuracy_score\n",
    "from sklearn.neighbors import KNeighborsClassifier"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Initializing important variables"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 79,
   "metadata": {},
   "outputs": [],
   "source": [
    "# Read YAML file\n",
    "with open(\"config.yaml\", 'r') as stream:\n",
    "    config_loaded = yaml.safe_load(stream)\n",
    "    \n",
    "######################################## Connections ################################\n",
    "# format: [(ip,port,connection)i] for i=onode_count\n",
    "onodes_connections = []\n",
    "# format: connection_object\n",
    "snode_connection = None\n",
    "server_connection = None\n",
    "    \n",
    "# Connecting to server's ip address\n",
    "server_connection = socket.socket()\n",
    "host = config_loaded[\"server\"][\"ip\"]\n",
    "port = config_loaded[\"server\"][\"port\"]\n",
    "o_nodes_count = config_loaded[\"kazaa\"][\"o_node_per\"]"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Formats:\n",
    "\n",
    "onodes_connections = [(ip,port,connection)i] for i=onode_count"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "snode_connection = connection_object"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 80,
   "metadata": {},
   "outputs": [],
   "source": [
    "# Global Fields\n",
    "status = ''\n",
    "onodes = []\n",
    "onodes_threads = [None]*o_nodes_count\n",
    "snodes = []\n",
    "self_kazaa_constant = 0\n",
    "onodes_kazaa_constant = [0]*o_nodes_count\n",
    "# this will be used to handle personal data\n",
    "df = None"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Defining main functions required"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 81,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "All defined perfectly\n"
     ]
    }
   ],
   "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",
    "\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",
    "def memory():\n",
    "    mem = p.virtual_memory()\n",
    "    return (mem.total, mem.available)\n",
    "\n",
    "def cpu():\n",
    "    return (100-p.cpu_percent(), p.cpu_count(logical=True))\n",
    "\n",
    "def gpu_memory():\n",
    "    try:\n",
    "        pynvml.nvmlInit()\n",
    "        # 1 here is the GPU id\n",
    "        handle = pynvml.nvmlDeviceGetHandleByIndex(1)\n",
    "        meminfo = pynvml.nvmlDeviceGetMemoryInfo(handle)\n",
    "        return meminfo.free\n",
    "    except:\n",
    "        return 0\n",
    "\n",
    "def download_speed():\n",
    "    try:\n",
    "        st = speedtest.Speedtest()\n",
    "        return st.download()/8\n",
    "    except:\n",
    "        return 0\n",
    "   \n",
    "def receive_rows(connection):\n",
    "    print(\"starting receiving rows\")\n",
    "    row_count_str = socket_rcv(connection)\n",
    "    if row_count_str.startswith(\"rcv:\"):\n",
    "        row_count = int(row_count_str[len(\"rcv:\"):])\n",
    "        headers = socket_rcv(connection)[len(\"rcv:\"):].split(\":\")\n",
    "        print(\"row_count:\", row_count, \"headers:\", headers)\n",
    "        data = []\n",
    "        for i in range(row_count):\n",
    "            data_rcvd = socket_rcv(connection, 32768)\n",
    "            while(data_rcvd.count(\":\") > 3):\n",
    "                socket_send(connection, \"resend\")\n",
    "                data_rcvd = socket_rcv(connection, 32768)\n",
    "            data.append(data_rcvd.split(\":\"))\n",
    "            socket_send(connection, \"rcvd\")\n",
    "            print(\"Rcvd row:\", data[-1][:-1])\n",
    "    return pd.DataFrame(data, columns=headers)\n",
    "\n",
    "def send_rows_onode(connection, df, division, index, headers):\n",
    "    start = division[index - 1] if index > 0 else 0\n",
    "    end = division[index]\n",
    "    socket_send(connection, \"rcv:\"+str(end - start))\n",
    "    socket_send(connection, \"rcv:\"+headers)\n",
    "    for i, row in df[start:end].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",
    "# here snode is sender and onode is receiver\n",
    "def snode_onode_socket(connection, id):\n",
    "    print(\"Waiting for kazaa_constant of\",id,\"ordinary node.\")\n",
    "    onodes_kazaa_constant[id] = float(socket_rcv(connection)[len(\"k_const:\"):])\n",
    "        \n",
    "# here onode is sender and snode is receiver\n",
    "def onode_snode_socket(connection):\n",
    "    socket_send(connection, \"k_const:\"+str(self_kazaa_constant))\n",
    "    df = receive_rows(connection)\n",
    "    print(\"df received from supernode of my region has shape: \", df.shape)\n",
    "    return df\n",
    " \n",
    "def send_system_info():\n",
    "    messages_to_send = 5\n",
    "    socket_send(server_connection, \"rcv:\"+str(messages_to_send))\n",
    "    # download speed in bytes\n",
    "    socket_send(server_connection, \"dsp:\"+str(download_speed()))\n",
    "    # available GPU ram in bytes\n",
    "    socket_send(server_connection, \"gpu:\"+str(gpu_memory()))\n",
    "    # available ram in bytes\n",
    "    socket_send(server_connection, \"ram:\"+str(memory()[1]))\n",
    "    # cpu free in percentage\n",
    "    socket_send(server_connection, \"cpu:\"+str(cpu()[0]))\n",
    "    # cpu cores in count\n",
    "    socket_send(server_connection, \"cor:\"+str(cpu()[1]))\n",
    "    \n",
    "def train_and_predict(df, df2):\n",
    "    X = df[[i for i in list(df.columns)[:-1]]]\n",
    "    y = df.Target\n",
    "    X_train, X_test, y_train, y_test = train_test_split(X, y, test_size=0.2, random_state=0)\n",
    "    models = {\n",
    "        \"knn\": {\"model\":KNeighborsClassifier()}\n",
    "    }\n",
    "\n",
    "    for name, model in models.items():\n",
    "        model['model'].fit(X_train, y_train)\n",
    "        \n",
    "    models_acc = []\n",
    "    for name, model in models.items():\n",
    "        models_acc.append(model[\"model\"].score(X_test, y_test))\n",
    "    \n",
    "    for name, model in models.items():\n",
    "        prediction = model['model'].predict(df2)\n",
    "        \n",
    "    return prediction\n",
    "\n",
    "\n",
    "def most_frequent(List):\n",
    "    return max(set(List), key = List.count)\n",
    "\n",
    "print(\"All defined perfectly\")\n",
    "   "
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Starting our main socket"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Sending system info"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 82,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Input your username: saif\n",
      "Waiting for connection response\n",
      "Connected\n",
      ">>received Server is working:...\n",
      "Server is working:\n",
      ">>sending rcv:5...\n",
      ">>sending dsp:486451.4990844669...\n",
      ">>sending gpu:0...\n",
      ">>sending ram:11109564416...\n",
      ">>sending cpu:82.5...\n",
      ">>sending cor:4...\n"
     ]
    }
   ],
   "source": [
    "username = input(\"Input your username: \")\n",
    "print('Waiting for connection response')\n",
    "try:\n",
    "    server_connection.connect((host, port))\n",
    "    print(\"Connected\")\n",
    "except socket.error as e:\n",
    "    print(str(e))\n",
    "    \n",
    "# first check response received i.e \"Server is working\"\n",
    "res = socket_rcv(server_connection)\n",
    "print(res)\n",
    "\n",
    "# sending system info\n",
    "send_system_info()\n"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Receiving acknowledgement"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 83,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for ack ////////////////////////////////////////\n",
      ">>received 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",
      "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"
     ]
    }
   ],
   "source": [
    "# receive acknowledge\n",
    "print(\"\\n\" + \"/\"*40 + \" waiting for ack \" + \"/\"*40)\n",
    "res = socket_rcv(server_connection)\n",
    "print(res)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Receiving Status"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 89,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for status ////////////////////////////////////////\n",
      ">>received status:s...\n"
     ]
    }
   ],
   "source": [
    "# receive status in kazaa architecture\n",
    "print(\"\\n\" + \"/\"*40 + \" waiting for status \" + \"/\"*40)\n",
    "status = socket_rcv(server_connection)[len(\"status:\"):]"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Receiving Kazaa Constant"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 90,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for kazaa constant ////////////////////////////////////////\n",
      ">>received k_const:0.8287499999999999...\n"
     ]
    }
   ],
   "source": [
    "print(\"\\n\" + \"/\"*40 + \" waiting for kazaa constant \" + \"/\"*40)\n",
    "self_kazaa_constant = socket_rcv(server_connection)[len(\"k_const:\"):]"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 91,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "You are appointed as Super node with kazaa constant as 0.8287499999999999\n"
     ]
    }
   ],
   "source": [
    "print(\"You are appointed as \" + (\"Super node\" if status==\"s\" else \"Ordinary node\") + \" with kazaa constant as\", self_kazaa_constant)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Super Node"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Create a socket for ordinary nodes and send to server"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 92,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// Supernode Socket ////////////////////////////////////////\n",
      "Socket for listening to 1 ordinary nodes is listening at ubuntu:4355\n",
      "\n",
      ">>sending ubuntu:4355...\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    onodesSocket = socket.socket()\n",
    "    host = socket.gethostname()\n",
    "    oport = port + 1\n",
    "    while(True):\n",
    "        try:\n",
    "            onodesSocket.bind((host, oport))\n",
    "            print(\"\\n\" + \"/\"*40 + \" Supernode Socket \" + \"/\"*40)\n",
    "            print(\"Socket for listening to\", o_nodes_count,\"ordinary nodes is listening at \"+host+\":\"+str(onodesSocket.getsockname()[1])+\"\\n\")\n",
    "            break\n",
    "        except:\n",
    "            oport += 1\n",
    "    \n",
    "    socket_send(server_connection, str(host+\":\"+str(onodesSocket.getsockname()[1])))\n",
    "    # server_connection.send(str.encode(str(host+\":\"+str(onodesSocket.getsockname()[1]))))\n",
    "    onodesSocket.listen(o_nodes_count)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Accept responses from ordinary nodes and as a result get their kazaa constant"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 93,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for kazaa constant from each ordinary node ////////////////////\n",
      "Supernode is accepting responses from ordinary nodes...\n",
      "Waiting for kazaa_constant of 0 ordinary node.\n",
      ">>received k_const:0.8285163917212575...\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    # open your onode socket for onodes to get connect\n",
    "    id = 0\n",
    "    print(\"\\n\" + \"/\"*40 + \" waiting for kazaa constant from each ordinary node \" + \"/\"*20)\n",
    "    print(\"Supernode is accepting responses from ordinary nodes...\")\n",
    "    while(id != o_nodes_count):\n",
    "        Client, address = onodesSocket.accept()\n",
    "        onodes_connections.append((address[0], address[1], Client))\n",
    "        onodes_threads[id] = threading.Thread(target = snode_onode_socket, args=(Client, id))\n",
    "        onodes_threads[id].start()\n",
    "        # print('Thread Number: ' + str(id) + \" - \" + 'Connected to ordinary node: ' + address[0] + ':' + str(address[1]))\n",
    "        id += 1\n",
    "\n",
    "    # joining all the threads\n",
    "    for i in onodes_threads:\n",
    "        i.join()"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Accept data for your region from server"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 94,
   "metadata": {
    "scrolled": true
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for region data ////////////////////////////////////////\n",
      "starting receiving rows\n",
      ">>received rcv:248...\n",
      ">>received rcv:Acceleration:Speed(m/s):Angle:Target...\n",
      "row_count: 248 headers: ['Acceleration', 'Speed(m/s)', 'Angle', 'Target']\n",
      ">>received 186.0:28.0:32.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['186.0', '28.0', '32.0']\n",
      ">>received 187.0:29.0:33.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['187.0', '29.0', '33.0']\n",
      ">>received 188.0:30.0:34.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['188.0', '30.0', '34.0']\n",
      ">>received 189.0:31.0:35.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['189.0', '31.0', '35.0']\n",
      ">>received 190.0:32.0:36.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['190.0', '32.0', '36.0']\n",
      ">>received 191.0:33.0:37.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['191.0', '33.0', '37.0']\n",
      ">>received 192.0:34.0:38.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['192.0', '34.0', '38.0']\n",
      ">>received 193.0:35.0:39.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['193.0', '35.0', '39.0']\n",
      ">>received 194.0:36.0:40.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['194.0', '36.0', '40.0']\n",
      ">>received 195.0:37.0:41.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['195.0', '37.0', '41.0']\n",
      ">>received 160.0:41.0:49.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['160.0', '41.0', '49.0']\n",
      ">>received 161.0:42.0:50.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['161.0', '42.0', '50.0']\n",
      ">>received 162.0:43.0:51.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['162.0', '43.0', '51.0']\n",
      ">>received 163.0:44.0:52.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['163.0', '44.0', '52.0']\n",
      ">>received 164.0:45.0:53.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['164.0', '45.0', '53.0']\n",
      ">>received 165.0:46.0:54.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['165.0', '46.0', '54.0']\n",
      ">>received 166.0:47.0:55.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['166.0', '47.0', '55.0']\n",
      ">>received 167.0:48.0:56.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['167.0', '48.0', '56.0']\n",
      ">>received 168.0:49.0:57.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['168.0', '49.0', '57.0']\n",
      ">>received 169.0:50.0:58.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['169.0', '50.0', '58.0']\n",
      ">>received 195.0:33.0:62.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['195.0', '33.0', '62.0']\n",
      ">>received 196.0:34.0:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['196.0', '34.0', '63.0']\n",
      ">>received 197.0:35.0:64.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['197.0', '35.0', '64.0']\n",
      ">>received 198.0:36.0:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['198.0', '36.0', '65.0']\n",
      ">>received 199.0:37.0:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['199.0', '37.0', '66.0']\n",
      ">>received 200.0:38.0:67.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['200.0', '38.0', '67.0']\n",
      ">>received 201.0:39.0:68.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '39.0', '68.0']\n",
      ">>received 202.0:40.0:69.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '40.0', '69.0']\n",
      ">>received 203.0:41.0:70.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['203.0', '41.0', '70.0']\n",
      ">>received 204.0:42.0:71.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['204.0', '42.0', '71.0']\n",
      ">>received 195.0:33.0:62.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['195.0', '33.0', '62.0']\n",
      ">>received 196.0:34.0:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['196.0', '34.0', '63.0']\n",
      ">>received 197.0:35.0:64.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['197.0', '35.0', '64.0']\n",
      ">>received 198.0:36.0:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['198.0', '36.0', '65.0']\n",
      ">>received 199.0:37.0:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['199.0', '37.0', '66.0']\n",
      ">>received 200.0:38.0:67.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['200.0', '38.0', '67.0']\n",
      ">>received 201.0:39.0:68.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '39.0', '68.0']\n",
      ">>received 202.0:40.0:69.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '40.0', '69.0']\n",
      ">>received 203.0:41.0:70.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['203.0', '41.0', '70.0']\n",
      ">>received 204.0:42.0:71.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['204.0', '42.0', '71.0']\n",
      ">>received 156.0:34.0:42.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['156.0', '34.0', '42.0']\n",
      ">>received 157.0:35.0:43.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['157.0', '35.0', '43.0']\n",
      ">>received 158.0:36.0:44.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['158.0', '36.0', '44.0']\n",
      ">>received 159.0:37.0:45.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['159.0', '37.0', '45.0']\n",
      ">>received 160.0:38.0:46.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['160.0', '38.0', '46.0']\n",
      ">>received 161.0:39.0:47.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['161.0', '39.0', '47.0']\n",
      ">>received 162.0:40.0:48.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['162.0', '40.0', '48.0']\n",
      ">>received 163.0:41.0:49.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['163.0', '41.0', '49.0']\n",
      ">>received 164.0:42.0:50.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['164.0', '42.0', '50.0']\n",
      ">>received 165.0:43.0:51.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['165.0', '43.0', '51.0']\n",
      ">>received 201.0:22.0:39.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '22.0', '39.3']\n",
      ">>received 202.0:23.0:40.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '23.0', '40.3']\n",
      ">>received 203.0:24.0:41.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['203.0', '24.0', '41.3']\n",
      ">>received 204.0:25.0:42.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['204.0', '25.0', '42.3']\n",
      ">>received 205.0:26.0:43.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['205.0', '26.0', '43.3']\n",
      ">>received 206.0:27.0:44.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['206.0', '27.0', '44.3']\n",
      ">>received 207.0:28.0:45.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['207.0', '28.0', '45.3']\n",
      ">>received 208.0:29.0:46.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['208.0', '29.0', '46.3']\n",
      ">>received 209.0:30.0:47.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['209.0', '30.0', '47.3']\n",
      ">>received 210.0:31.0:48.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['210.0', '31.0', '48.3']\n",
      ">>received 121.0:21.0:45.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['121.0', '21.0', '45.0']\n",
      ">>received 122.0:22.0:46.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['122.0', '22.0', '46.0']\n",
      ">>received 123.0:23.0:47.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '23.0', '47.0']\n",
      ">>received 124.0:24.0:48.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['124.0', '24.0', '48.0']\n",
      ">>received 125.0:25.0:49.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['125.0', '25.0', '49.0']\n",
      ">>received 126.0:26.0:50.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['126.0', '26.0', '50.0']\n",
      ">>received 127.0:27.0:51.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['127.0', '27.0', '51.0']\n",
      ">>received 128.0:28.0:52.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['128.0', '28.0', '52.0']\n",
      ">>received 129.0:29.0:53.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['129.0', '29.0', '53.0']\n",
      ">>received 130.0:30.0:54.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['130.0', '30.0', '54.0']\n",
      ">>received 118.0:17.6:41.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['118.0', '17.6', '41.8']\n",
      ">>received 119.0:18.6:42.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['119.0', '18.6', '42.8']\n",
      ">>received 120.0:19.6:43.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['120.0', '19.6', '43.8']\n",
      ">>received 121.0:20.6:44.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['121.0', '20.6', '44.8']\n",
      ">>received 122.0:21.6:45.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['122.0', '21.6', '45.8']\n",
      ">>received 123.0:22.6:46.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '22.6', '46.8']\n",
      ">>received 124.0:23.6:47.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['124.0', '23.6', '47.8']\n",
      ">>received 125.0:24.6:48.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['125.0', '24.6', '48.8']\n",
      ">>received 126.0:25.6:49.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['126.0', '25.6', '49.8']\n",
      ">>received 127.0:26.6:50.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['127.0', '26.6', '50.8']\n",
      ">>received 292.0:17.35:56.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['292.0', '17.35', '56.0']\n",
      ">>received 293.0:18.35:57.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['293.0', '18.35', '57.0']\n",
      ">>received 294.0:19.35:58.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['294.0', '19.35', '58.0']\n",
      ">>received 295.0:20.35:59.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['295.0', '20.35', '59.0']\n",
      ">>received 296.0:21.35:60.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['296.0', '21.35', '60.0']\n",
      ">>received 297.0:22.35:61.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['297.0', '22.35', '61.0']\n",
      ">>received 298.0:23.35:62.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['298.0', '23.35', '62.0']\n",
      ">>received 299.0:24.35:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['299.0', '24.35', '63.0']\n",
      ">>received 300.0:25.35:64.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['300.0', '25.35', '64.0']\n",
      ">>received 301.0:26.35:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['301.0', '26.35', '65.0']\n",
      ">>received 305.0:19.82:58.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['305.0', '19.82', '58.0']\n",
      ">>received 306.0:20.82:59.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['306.0', '20.82', '59.0']\n",
      ">>received 307.0:21.82:60.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['307.0', '21.82', '60.0']\n",
      ">>received 308.0:22.82:61.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['308.0', '22.82', '61.0']\n",
      ">>received 309.0:23.82:62.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['309.0', '23.82', '62.0']\n",
      ">>received 310.0:24.82:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['310.0', '24.82', '63.0']\n",
      ">>received 311.0:25.82:64.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['311.0', '25.82', '64.0']\n",
      ">>received 312.0:26.82:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['312.0', '26.82', '65.0']\n",
      ">>received 210.0:18.26:59.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['210.0', '18.26', '59.0']\n",
      ">>received 211.0:19.26:60.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['211.0', '19.26', '60.0']\n",
      ">>received 212.0:20.26:61.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['212.0', '20.26', '61.0']\n",
      ">>received 213.0:21.26:62.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['213.0', '21.26', '62.0']\n",
      ">>received 214.0:22.26:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['214.0', '22.26', '63.0']\n",
      ">>received 215.0:23.26:64.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['215.0', '23.26', '64.0']\n",
      ">>received 216.0:24.26:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['216.0', '24.26', '65.0']\n",
      ">>received 217.0:25.26:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['217.0', '25.26', '66.0']\n",
      ">>received 218.0:26.26:67.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['218.0', '26.26', '67.0']\n",
      ">>received 219.0:27.26:68.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['219.0', '27.26', '68.0']\n",
      ">>received 132.0:29.0:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['132.0', '29.0', '65.0']\n",
      ">>received 133.0:30.0:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['133.0', '30.0', '66.0']\n",
      ">>received 134.0:31.0:67.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['134.0', '31.0', '67.0']\n",
      ">>received 135.0:32.0:68.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['135.0', '32.0', '68.0']\n",
      ">>received 136.0:33.0:69.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['136.0', '33.0', '69.0']\n",
      ">>received 137.0:34.0:70.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['137.0', '34.0', '70.0']\n",
      ">>received 138.0:35.0:71.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['138.0', '35.0', '71.0']\n",
      ">>received 139.0:36.0:72.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['139.0', '36.0', '72.0']\n",
      ">>received 140.0:37.0:73.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['140.0', '37.0', '73.0']\n",
      ">>received 141.0:38.0:74.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['141.0', '38.0', '74.0']\n",
      ">>received 114.0:20.0:22.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['114.0', '20.0', '22.0']\n",
      ">>received 115.0:21.0:23.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['115.0', '21.0', '23.0']\n",
      ">>received 116.0:22.0:24.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['116.0', '22.0', '24.0']\n",
      ">>received 117.0:23.0:25.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['117.0', '23.0', '25.0']\n",
      ">>received 118.0:24.0:26.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['118.0', '24.0', '26.0']\n",
      ">>received 119.0:25.0:27.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['119.0', '25.0', '27.0']\n",
      ">>received 120.0:26.0:28.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['120.0', '26.0', '28.0']\n",
      ">>received 121.0:27.0:29.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['121.0', '27.0', '29.0']\n",
      ">>received 122.0:28.0:30.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['122.0', '28.0', '30.0']\n",
      ">>received 123.0:29.0:31.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '29.0', '31.0']\n",
      ">>received 250.0:22.0:11.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['250.0', '22.0', '11.6']\n",
      ">>received 251.0:23.0:12.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['251.0', '23.0', '12.6']\n",
      ">>received 252.0:24.0:13.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['252.0', '24.0', '13.6']\n",
      ">>received 253.0:25.0:14.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['253.0', '25.0', '14.6']\n",
      ">>received 254.0:26.0:15.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['254.0', '26.0', '15.6']\n",
      ">>received 255.0:27.0:16.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['255.0', '27.0', '16.6']\n",
      ">>received 256.0:28.0:17.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['256.0', '28.0', '17.6']\n",
      ">>received 257.0:29.0:18.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['257.0', '29.0', '18.6']\n",
      ">>received 258.0:30.0:19.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['258.0', '30.0', '19.6']\n",
      ">>received 259.0:31.0:20.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['259.0', '31.0', '20.6']\n",
      ">>received 196.0:19.0:18.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['196.0', '19.0', '18.0']\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">>received 197.0:20.0:19.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['197.0', '20.0', '19.0']\n",
      ">>received 198.0:21.0:20.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['198.0', '21.0', '20.0']\n",
      ">>received 199.0:22.0:21.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['199.0', '22.0', '21.0']\n",
      ">>received 200.0:23.0:22.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['200.0', '23.0', '22.0']\n",
      ">>received 201.0:24.0:23.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '24.0', '23.0']\n",
      ">>received 202.0:25.0:24.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '25.0', '24.0']\n",
      ">>received 203.0:26.0:25.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['203.0', '26.0', '25.0']\n",
      ">>received 204.0:27.0:26.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['204.0', '27.0', '26.0']\n",
      ">>received 205.0:28.0:27.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['205.0', '28.0', '27.0']\n",
      ">>received 407.0:31.0:9.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['407.0', '31.0', '9.0']\n",
      ">>received 408.0:32.0:10.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['408.0', '32.0', '10.0']\n",
      ">>received 409.0:33.0:11.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['409.0', '33.0', '11.0']\n",
      ">>received 410.0:34.0:12.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['410.0', '34.0', '12.0']\n",
      ">>received 411.0:35.0:13.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['411.0', '35.0', '13.0']\n",
      ">>received 412.0:36.0:14.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['412.0', '36.0', '14.0']\n",
      ">>received 413.0:37.0:15.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['413.0', '37.0', '15.0']\n",
      ">>received 414.0:38.0:16.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['414.0', '38.0', '16.0']\n",
      ">>received 415.0:39.0:17.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['415.0', '39.0', '17.0']\n",
      ">>received 416.0:40.0:18.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['416.0', '40.0', '18.0']\n",
      ">>received 179.0:48.6:9.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['179.0', '48.6', '9.8']\n",
      ">>received 180.0:49.6:10.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['180.0', '49.6', '10.8']\n",
      ">>received 181.0:50.6:11.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['181.0', '50.6', '11.8']\n",
      ">>received 182.0:51.6:12.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['182.0', '51.6', '12.8']\n",
      ">>received 183.0:52.6:13.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['183.0', '52.6', '13.8']\n",
      ">>received 184.0:53.6:14.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['184.0', '53.6', '14.8']\n",
      ">>received 185.0:54.6:15.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['185.0', '54.6', '15.8']\n",
      ">>received 186.0:55.6:16.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['186.0', '55.6', '16.8']\n",
      ">>received 187.0:56.6:17.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['187.0', '56.6', '17.8']\n",
      ">>received 188.0:57.6:18.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['188.0', '57.6', '18.8']\n",
      ">>received 87.0:16.0:17.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['87.0', '16.0', '17.0']\n",
      ">>received 88.0:17.0:18.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['88.0', '17.0', '18.0']\n",
      ">>received 89.0:18.0:19.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['89.0', '18.0', '19.0']\n",
      ">>received 90.0:19.0:20.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['90.0', '19.0', '20.0']\n",
      ">>received 91.0:20.0:21.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['91.0', '20.0', '21.0']\n",
      ">>received 92.0:21.0:22.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['92.0', '21.0', '22.0']\n",
      ">>received 93.0:22.0:23.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['93.0', '22.0', '23.0']\n",
      ">>received 94.0:23.0:24.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['94.0', '23.0', '24.0']\n",
      ">>received 95.0:24.0:25.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['95.0', '24.0', '25.0']\n",
      ">>received 96.0:25.0:26.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['96.0', '25.0', '26.0']\n",
      ">>received 156.0:23.0:12.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['156.0', '23.0', '12.0']\n",
      ">>received 157.0:24.0:13.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['157.0', '24.0', '13.0']\n",
      ">>received 158.0:25.0:14.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['158.0', '25.0', '14.0']\n",
      ">>received 159.0:26.0:15.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['159.0', '26.0', '15.0']\n",
      ">>received 160.0:27.0:16.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['160.0', '27.0', '16.0']\n",
      ">>received 161.0:28.0:17.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['161.0', '28.0', '17.0']\n",
      ">>received 162.0:29.0:18.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['162.0', '29.0', '18.0']\n",
      ">>received 163.0:30.0:19.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['163.0', '30.0', '19.0']\n",
      ">>received 164.0:31.0:20.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['164.0', '31.0', '20.0']\n",
      ">>received 165.0:32.0:21.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['165.0', '32.0', '21.0']\n",
      ">>received 61.0:15.0:9.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['61.0', '15.0', '9.0']\n",
      ">>received 62.0:16.0:10.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['62.0', '16.0', '10.0']\n",
      ">>received 63.0:17.0:11.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['63.0', '17.0', '11.0']\n",
      ">>received 64.0:18.0:12.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['64.0', '18.0', '12.0']\n",
      ">>received 65.0:19.0:13.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['65.0', '19.0', '13.0']\n",
      ">>received 66.0:20.0:14.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['66.0', '20.0', '14.0']\n",
      ">>received 67.0:21.0:15.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['67.0', '21.0', '15.0']\n",
      ">>received 68.0:22.0:16.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['68.0', '22.0', '16.0']\n",
      ">>received 69.0:23.0:17.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['69.0', '23.0', '17.0']\n",
      ">>received 70.0:24.0:18.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['70.0', '24.0', '18.0']\n",
      ">>received 18.0:6.52:11.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['18.0', '6.52', '11.3']\n",
      ">>received 19.0:7.52:12.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['19.0', '7.52', '12.3']\n",
      ">>received 20.0:8.52:13.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['20.0', '8.52', '13.3']\n",
      ">>received 21.0:9.52:14.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['21.0', '9.52', '14.3']\n",
      ">>received 22.0:10.52:15.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['22.0', '10.52', '15.3']\n",
      ">>received 23.0:11.52:16.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['23.0', '11.52', '16.3']\n",
      ">>received 24.0:12.52:17.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['24.0', '12.52', '17.3']\n",
      ">>received 25.0:13.52:18.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['25.0', '13.52', '18.3']\n",
      ">>received 26.0:14.52:19.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['26.0', '14.52', '19.3']\n",
      ">>received 27.0:15.52:20.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['27.0', '15.52', '20.3']\n",
      ">>received 116.0:27.6:13.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['116.0', '27.6', '13.2']\n",
      ">>received 117.0:28.6:14.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['117.0', '28.6', '14.2']\n",
      ">>received 118.0:29.6:15.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['118.0', '29.6', '15.2']\n",
      ">>received 119.0:30.6:16.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['119.0', '30.6', '16.2']\n",
      ">>received 120.0:31.6:17.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['120.0', '31.6', '17.2']\n",
      ">>received 121.0:32.6:18.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['121.0', '32.6', '18.2']\n",
      ">>received 122.0:33.6:19.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['122.0', '33.6', '19.2']\n",
      ">>received 123.0:34.6:20.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '34.6', '20.2']\n",
      ">>received 124.0:35.6:21.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['124.0', '35.6', '21.2']\n",
      ">>received 125.0:36.6:22.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['125.0', '36.6', '22.2']\n",
      ">>received 38.1:21.5:9.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['38.1', '21.5', '9.6']\n",
      ">>received 39.1:22.5:10.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['39.1', '22.5', '10.6']\n",
      ">>received 40.1:23.5:11.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['40.1', '23.5', '11.6']\n",
      ">>received 41.1:24.5:12.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['41.1', '24.5', '12.6']\n",
      ">>received 42.1:25.5:13.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['42.1', '25.5', '13.6']\n",
      ">>received 43.1:26.5:14.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['43.1', '26.5', '14.6']\n",
      ">>received 44.1:27.5:15.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['44.1', '27.5', '15.6']\n",
      ">>received 45.1:28.5:16.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['45.1', '28.5', '16.6']\n",
      ">>received 46.1:29.5:17.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['46.1', '29.5', '17.6']\n",
      ">>received 47.1:30.5:18.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['47.1', '30.5', '18.6']\n",
      ">>received 73.0:24.0:10.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['73.0', '24.0', '10.5']\n",
      ">>received 74.0:25.0:11.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['74.0', '25.0', '11.5']\n",
      ">>received 75.0:26.0:12.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['75.0', '26.0', '12.5']\n",
      ">>received 76.0:27.0:13.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['76.0', '27.0', '13.5']\n",
      ">>received 77.0:28.0:14.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['77.0', '28.0', '14.5']\n",
      ">>received 78.0:29.0:15.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['78.0', '29.0', '15.5']\n",
      ">>received 79.0:30.0:16.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['79.0', '30.0', '16.5']\n",
      ">>received 80.0:31.0:17.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['80.0', '31.0', '17.5']\n",
      ">>received 81.0:32.0:18.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['81.0', '32.0', '18.5']\n",
      ">>received 82.0:33.0:19.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['82.0', '33.0', '19.5']\n",
      ">>received 83.5:36.0:11.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['83.5', '36.0', '11.8']\n",
      ">>received 84.5:37.0:12.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['84.5', '37.0', '12.8']\n",
      ">>received 85.5:38.0:13.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['85.5', '38.0', '13.8']\n",
      ">>received 86.5:39.0:14.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['86.5', '39.0', '14.8']\n",
      ">>received 87.5:40.0:15.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['87.5', '40.0', '15.8']\n",
      ">>received 88.5:41.0:16.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['88.5', '41.0', '16.8']\n",
      ">>received 89.5:42.0:17.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['89.5', '42.0', '17.8']\n",
      ">>received 90.5:43.0:18.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['90.5', '43.0', '18.8']\n",
      ">>received 91.5:44.0:19.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['91.5', '44.0', '19.8']\n",
      ">>received 92.5:45.0:20.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['92.5', '45.0', '20.8']\n",
      "data rcvd from server for 248 rows with headers: Index(['Acceleration', 'Speed(m/s)', 'Angle', 'Target'], dtype='object')\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    #ensemble_distribution()\n",
    "    # receive data from server\n",
    "    print(\"\\n\" + \"/\"*40 + \" waiting for region data \" + \"/\"*40)\n",
    "    df = receive_rows(server_connection)\n",
    "    print(\"data rcvd from server for\",df.shape[0],\"rows with headers:\",df.columns)\n"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Get division of data for all nodes in region"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 95,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "[124, 248]\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    division = []\n",
    "    for i in onodes_kazaa_constant:\n",
    "        division.append(math.ceil((df.shape[0]*i)/(sum(onodes_kazaa_constant)+float(self_kazaa_constant))))\n",
    "    division.append(int(df.shape[0]*float(self_kazaa_constant)/sum(onodes_kazaa_constant)))\n",
    "    print(division)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Get headers for the data frame"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 96,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Acceleration:Speed(m/s):Angle:Target\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    headers = \":\".join(list(df.columns))\n",
    "    print(headers)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Send respective data to each ordinary data"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 97,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting to send data to ordinary nodes ////////////////////////////////////////\n",
      "Sending data...\n",
      ">>sending rcv:124...\n",
      ">>sending rcv:Acceleration:Speed(m/s):Angle:Target...\n",
      ">>sending 43.1:26.5:14.6:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 63.0:17.0:11.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 251.0:23.0:12.6:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 306.0:20.82:59.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 133.0:30.0:66.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 40.1:23.5:11.6:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 123.0:29.0:31.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 75.0:26.0:12.5:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 196.0:19.0:18.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 69.0:23.0:17.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 165.0:32.0:21.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 295.0:20.35:59.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 124.0:23.6:47.8:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 194.0:36.0:40.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 87.0:16.0:17.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 91.0:20.0:21.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 252.0:24.0:13.6:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 124.0:35.6:21.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 88.5:41.0:16.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 70.0:24.0:18.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 202.0:40.0:69.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 311.0:25.82:64.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 120.0:19.6:43.8:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 121.0:32.6:18.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 125.0:25.0:49.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 184.0:53.6:14.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 126.0:25.6:49.8:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 156.0:34.0:42.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 191.0:33.0:37.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 18.0:6.52:11.3:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 205.0:26.0:43.3:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 195.0:33.0:62.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 92.5:45.0:20.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 204.0:25.0:42.3:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 21.0:9.52:14.3:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 127.0:27.0:51.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 198.0:21.0:20.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 186.0:28.0:32.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 139.0:36.0:72.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 412.0:36.0:14.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 121.0:27.0:29.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 259.0:31.0:20.6:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 82.0:33.0:19.5:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 407.0:31.0:9.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 202.0:25.0:24.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 164.0:31.0:20.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 214.0:22.26:63.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 199.0:22.0:21.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 91.5:44.0:19.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 85.5:38.0:13.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 201.0:39.0:68.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 83.5:36.0:11.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 25.0:13.52:18.3:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 117.0:23.0:25.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 87.5:40.0:15.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 38.1:21.5:9.6:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 296.0:21.35:60.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 208.0:29.0:46.3:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 213.0:21.26:62.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 96.0:25.0:26.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 77.0:28.0:14.5:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 203.0:26.0:25.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 183.0:52.6:13.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 117.0:28.6:14.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 125.0:24.6:48.8:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 122.0:21.6:45.8:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 163.0:30.0:19.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 211.0:19.26:60.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 118.0:24.0:26.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 162.0:43.0:51.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 201.0:39.0:68.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 219.0:27.26:68.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 61.0:15.0:9.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 134.0:31.0:67.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 189.0:31.0:35.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 207.0:28.0:45.3:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 206.0:27.0:44.3:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 120.0:31.6:17.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 121.0:20.6:44.8:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 254.0:26.0:15.6:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 253.0:25.0:14.6:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 258.0:30.0:19.6:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 122.0:22.0:46.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 163.0:41.0:49.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 195.0:33.0:62.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 126.0:26.0:50.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 218.0:26.26:67.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 66.0:20.0:14.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 89.0:18.0:19.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 192.0:34.0:38.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 19.0:7.52:12.3:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 164.0:45.0:53.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 158.0:36.0:44.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 129.0:29.0:53.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 122.0:28.0:30.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 136.0:33.0:69.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 411.0:35.0:13.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 180.0:49.6:10.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 190.0:32.0:36.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 181.0:50.6:11.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 67.0:21.0:15.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 122.0:33.6:19.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 202.0:40.0:69.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 199.0:37.0:66.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 118.0:29.6:15.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 64.0:18.0:12.0:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 76.0:27.0:13.5:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 182.0:51.6:12.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 116.0:22.0:24.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 198.0:36.0:65.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 197.0:35.0:64.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 193.0:35.0:39.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 141.0:38.0:74.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 163.0:44.0:52.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 89.5:42.0:17.8:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 125.0:36.6:22.2:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 297.0:22.35:61.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 197.0:20.0:19.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 46.1:29.5:17.6:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 305.0:19.82:58.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 161.0:42.0:50.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 74.0:25.0:11.5:Not-scored...\n",
      ">>received rcvd...\n",
      ">>sending 216.0:24.26:65.0:Scored...\n",
      ">>received rcvd...\n",
      ">>sending 186.0:55.6:16.8:Not-scored...\n",
      ">>received rcvd...\n",
      "Sent all data to 192.168.40.189 at port 38910\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    # firstly we'll shuffle the data \n",
    "    df = df.sample(frac=1).reset_index(drop=True)\n",
    "    # data for regional ordinary nodes\n",
    "    index = 0\n",
    "    print(\"\\n\" + \"/\"*40 + \" waiting to send data to ordinary nodes \" + \"/\"*40)\n",
    "    print(\"Sending data...\")\n",
    "    for onode_connection in onodes_connections:\n",
    "        send_rows_onode(onode_connection[2], df, division, index, headers)\n",
    "        print(\"Sent all data to\", onode_connection[0], \"at port\", onode_connection[1])\n",
    "        index += 1"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Take out your own part of the data"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 98,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "data i kept is:\n"
     ]
    },
    {
     "data": {
      "text/html": [
       "<div>\n",
       "<style scoped>\n",
       "    .dataframe tbody tr th:only-of-type {\n",
       "        vertical-align: middle;\n",
       "    }\n",
       "\n",
       "    .dataframe tbody tr th {\n",
       "        vertical-align: top;\n",
       "    }\n",
       "\n",
       "    .dataframe thead th {\n",
       "        text-align: right;\n",
       "    }\n",
       "</style>\n",
       "<table border=\"1\" class=\"dataframe\">\n",
       "  <thead>\n",
       "    <tr style=\"text-align: right;\">\n",
       "      <th></th>\n",
       "      <th>Acceleration</th>\n",
       "      <th>Speed(m/s)</th>\n",
       "      <th>Angle</th>\n",
       "      <th>Target</th>\n",
       "    </tr>\n",
       "  </thead>\n",
       "  <tbody>\n",
       "    <tr>\n",
       "      <th>124</th>\n",
       "      <td>157.0</td>\n",
       "      <td>24.0</td>\n",
       "      <td>13.0</td>\n",
       "      <td>Not-scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>125</th>\n",
       "      <td>137.0</td>\n",
       "      <td>34.0</td>\n",
       "      <td>70.0</td>\n",
       "      <td>Scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>126</th>\n",
       "      <td>123.0</td>\n",
       "      <td>22.6</td>\n",
       "      <td>46.8</td>\n",
       "      <td>Scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>127</th>\n",
       "      <td>204.0</td>\n",
       "      <td>42.0</td>\n",
       "      <td>71.0</td>\n",
       "      <td>Scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>128</th>\n",
       "      <td>187.0</td>\n",
       "      <td>29.0</td>\n",
       "      <td>33.0</td>\n",
       "      <td>Scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>...</th>\n",
       "      <td>...</td>\n",
       "      <td>...</td>\n",
       "      <td>...</td>\n",
       "      <td>...</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>243</th>\n",
       "      <td>93.0</td>\n",
       "      <td>22.0</td>\n",
       "      <td>23.0</td>\n",
       "      <td>Not-scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>244</th>\n",
       "      <td>68.0</td>\n",
       "      <td>22.0</td>\n",
       "      <td>16.0</td>\n",
       "      <td>Not-scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>245</th>\n",
       "      <td>45.1</td>\n",
       "      <td>28.5</td>\n",
       "      <td>16.6</td>\n",
       "      <td>Not-scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>246</th>\n",
       "      <td>293.0</td>\n",
       "      <td>18.35</td>\n",
       "      <td>57.0</td>\n",
       "      <td>Scored</td>\n",
       "    </tr>\n",
       "    <tr>\n",
       "      <th>247</th>\n",
       "      <td>196.0</td>\n",
       "      <td>34.0</td>\n",
       "      <td>63.0</td>\n",
       "      <td>Scored</td>\n",
       "    </tr>\n",
       "  </tbody>\n",
       "</table>\n",
       "<p>124 rows × 4 columns</p>\n",
       "</div>"
      ],
      "text/plain": [
       "    Acceleration Speed(m/s) Angle      Target\n",
       "124        157.0       24.0  13.0  Not-scored\n",
       "125        137.0       34.0  70.0      Scored\n",
       "126        123.0       22.6  46.8      Scored\n",
       "127        204.0       42.0  71.0      Scored\n",
       "128        187.0       29.0  33.0      Scored\n",
       "..           ...        ...   ...         ...\n",
       "243         93.0       22.0  23.0  Not-scored\n",
       "244         68.0       22.0  16.0  Not-scored\n",
       "245         45.1       28.5  16.6  Not-scored\n",
       "246        293.0      18.35  57.0      Scored\n",
       "247        196.0       34.0  63.0      Scored\n",
       "\n",
       "[124 rows x 4 columns]"
      ]
     },
     "execution_count": 98,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    df = df[division[-2]:division[-1]]\n",
    "print(\"data i kept is:\")\n",
    "df"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Get x_test from server and Predict your own results firstly"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 66,
   "metadata": {},
   "outputs": [],
   "source": [
    "if status == \"s\":\n",
    "    print(\"\\n\" + \"/\"*40 + \" waiting to receive predictions from region \" + \"/\"*40)\n",
    "    x_test = socket_rcv(server_connection)[len(\"rcv_test:\"):]\n",
    "    predictions = []\n",
    "    print(\"Sending x_test...\")\n",
    "    for onode_connection in onodes_connections:\n",
    "        socket_send(onode_connection[2], \"rcv_test:\"+x_test)\n",
    "        predictions.append(socket_rcv(onode_connection[2]))\n",
    "    print(\">>>>>>>>>>>\", my_prediction)\n",
    "    predictions.append(train_and_predict(df, pd.DataFrame([x_test.split(\":\")], columns=[list(df.columns)[:-1]]))[0])\n",
    "    predictions.reverse()\n",
    "    print(most_frequent(predictions),\"is the most frequent prediction from my region.\")\n",
    "    socket_send(server_connection, most_frequent(predictions))"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 102,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:186.0:28.0:32.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:186.0:28.0:32.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:187.0:29.0:33.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:187.0:29.0:33.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:188.0:30.0:34.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:188.0:30.0:34.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:189.0:31.0:35.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:189.0:31.0:35.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:190.0:32.0:36.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:190.0:32.0:36.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:191.0:33.0:37.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:191.0:33.0:37.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:192.0:34.0:38.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:192.0:34.0:38.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:193.0:35.0:39.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:193.0:35.0:39.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:194.0:36.0:40.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:194.0:36.0:40.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:195.0:37.0:41.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:195.0:37.0:41.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:160.0:41.0:49.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:160.0:41.0:49.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:161.0:42.0:50.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:161.0:42.0:50.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:162.0:43.0:51.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:162.0:43.0:51.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:163.0:44.0:52.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:163.0:44.0:52.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:164.0:45.0:53.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:164.0:45.0:53.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:165.0:46.0:54.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:165.0:46.0:54.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:166.0:47.0:55.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:166.0:47.0:55.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:167.0:48.0:56.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:167.0:48.0:56.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:168.0:49.0:57.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:168.0:49.0:57.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:169.0:50.0:58.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:169.0:50.0:58.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:195.0:33.0:62.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:195.0:33.0:62.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:196.0:34.0:63.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:196.0:34.0:63.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:197.0:35.0:64.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:197.0:35.0:64.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:198.0:36.0:65.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:198.0:36.0:65.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:199.0:37.0:66.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:199.0:37.0:66.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:200.0:38.0:67.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:200.0:38.0:67.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:201.0:39.0:68.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:201.0:39.0:68.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:202.0:40.0:69.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:202.0:40.0:69.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:203.0:41.0:70.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:203.0:41.0:70.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:204.0:42.0:71.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:204.0:42.0:71.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:195.0:33.0:62.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:195.0:33.0:62.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:196.0:34.0:63.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:196.0:34.0:63.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:197.0:35.0:64.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:197.0:35.0:64.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:198.0:36.0:65.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:198.0:36.0:65.0...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:199.0:37.0:66.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:199.0:37.0:66.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:200.0:38.0:67.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:200.0:38.0:67.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:201.0:39.0:68.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:201.0:39.0:68.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:202.0:40.0:69.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:202.0:40.0:69.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:203.0:41.0:70.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:203.0:41.0:70.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:204.0:42.0:71.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:204.0:42.0:71.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:156.0:34.0:42.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:156.0:34.0:42.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:157.0:35.0:43.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:157.0:35.0:43.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:158.0:36.0:44.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:158.0:36.0:44.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:159.0:37.0:45.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:159.0:37.0:45.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:160.0:38.0:46.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:160.0:38.0:46.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:161.0:39.0:47.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:161.0:39.0:47.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:162.0:40.0:48.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:162.0:40.0:48.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:163.0:41.0:49.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:163.0:41.0:49.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:164.0:42.0:50.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:164.0:42.0:50.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:165.0:43.0:51.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:165.0:43.0:51.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:201.0:22.0:39.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:201.0:22.0:39.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:202.0:23.0:40.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:202.0:23.0:40.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:203.0:24.0:41.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:203.0:24.0:41.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:204.0:25.0:42.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:204.0:25.0:42.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:205.0:26.0:43.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:205.0:26.0:43.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:206.0:27.0:44.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:206.0:27.0:44.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:207.0:28.0:45.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:207.0:28.0:45.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:208.0:29.0:46.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:208.0:29.0:46.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:209.0:30.0:47.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:209.0:30.0:47.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:210.0:31.0:48.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:210.0:31.0:48.3...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:121.0:21.0:45.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:121.0:21.0:45.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:122.0:22.0:46.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:122.0:22.0:46.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:123.0:23.0:47.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:123.0:23.0:47.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:124.0:24.0:48.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:124.0:24.0:48.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:125.0:25.0:49.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:125.0:25.0:49.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:126.0:26.0:50.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:126.0:26.0:50.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:127.0:27.0:51.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:127.0:27.0:51.0...\n",
      ">>received Scored...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:128.0:28.0:52.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:128.0:28.0:52.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:129.0:29.0:53.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:129.0:29.0:53.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:130.0:30.0:54.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:130.0:30.0:54.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:118.0:17.6:41.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:118.0:17.6:41.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:119.0:18.6:42.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:119.0:18.6:42.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:120.0:19.6:43.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:120.0:19.6:43.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:121.0:20.6:44.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:121.0:20.6:44.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:122.0:21.6:45.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:122.0:21.6:45.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:123.0:22.6:46.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:123.0:22.6:46.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:124.0:23.6:47.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:124.0:23.6:47.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:125.0:24.6:48.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:125.0:24.6:48.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:126.0:25.6:49.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:126.0:25.6:49.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:127.0:26.6:50.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:127.0:26.6:50.8...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:292.0:17.35:56.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:292.0:17.35:56.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:293.0:18.35:57.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:293.0:18.35:57.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:294.0:19.35:58.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:294.0:19.35:58.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:295.0:20.35:59.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:295.0:20.35:59.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:296.0:21.35:60.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:296.0:21.35:60.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:297.0:22.35:61.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:297.0:22.35:61.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:298.0:23.35:62.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:298.0:23.35:62.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:299.0:24.35:63.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:299.0:24.35:63.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:300.0:25.35:64.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:300.0:25.35:64.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:301.0:26.35:65.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:301.0:26.35:65.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:305.0:19.82:58.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:305.0:19.82:58.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:306.0:20.82:59.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:306.0:20.82:59.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:307.0:21.82:60.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:307.0:21.82:60.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:308.0:22.82:61.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:308.0:22.82:61.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:309.0:23.82:62.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:309.0:23.82:62.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:310.0:24.82:63.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:310.0:24.82:63.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:311.0:25.82:64.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:311.0:25.82:64.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:312.0:26.82:65.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:312.0:26.82:65.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:210.0:18.26:59.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:210.0:18.26:59.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:211.0:19.26:60.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:211.0:19.26:60.0...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:212.0:20.26:61.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:212.0:20.26:61.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:213.0:21.26:62.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:213.0:21.26:62.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:214.0:22.26:63.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:214.0:22.26:63.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:215.0:23.26:64.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:215.0:23.26:64.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:216.0:24.26:65.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:216.0:24.26:65.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:217.0:25.26:66.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:217.0:25.26:66.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:218.0:26.26:67.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:218.0:26.26:67.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:219.0:27.26:68.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:219.0:27.26:68.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:132.0:29.0:65.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:132.0:29.0:65.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:133.0:30.0:66.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:133.0:30.0:66.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:134.0:31.0:67.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:134.0:31.0:67.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:135.0:32.0:68.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:135.0:32.0:68.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:136.0:33.0:69.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:136.0:33.0:69.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:137.0:34.0:70.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:137.0:34.0:70.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:138.0:35.0:71.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:138.0:35.0:71.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:139.0:36.0:72.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:139.0:36.0:72.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:140.0:37.0:73.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:140.0:37.0:73.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:141.0:38.0:74.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:141.0:38.0:74.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:114.0:20.0:22.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:114.0:20.0:22.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:115.0:21.0:23.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:115.0:21.0:23.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:116.0:22.0:24.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:116.0:22.0:24.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:117.0:23.0:25.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:117.0:23.0:25.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:118.0:24.0:26.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:118.0:24.0:26.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:119.0:25.0:27.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:119.0:25.0:27.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:120.0:26.0:28.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:120.0:26.0:28.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:121.0:27.0:29.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:121.0:27.0:29.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:122.0:28.0:30.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:122.0:28.0:30.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:123.0:29.0:31.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:123.0:29.0:31.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:250.0:22.0:11.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:250.0:22.0:11.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:251.0:23.0:12.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:251.0:23.0:12.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:252.0:24.0:13.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:252.0:24.0:13.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:253.0:25.0:14.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:253.0:25.0:14.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:254.0:26.0:15.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:254.0:26.0:15.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:255.0:27.0:16.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:255.0:27.0:16.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:256.0:28.0:17.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:256.0:28.0:17.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:257.0:29.0:18.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:257.0:29.0:18.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:258.0:30.0:19.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:258.0:30.0:19.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:259.0:31.0:20.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:259.0:31.0:20.6...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:196.0:19.0:18.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:196.0:19.0:18.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:197.0:20.0:19.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:197.0:20.0:19.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:198.0:21.0:20.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:198.0:21.0:20.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:199.0:22.0:21.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:199.0:22.0:21.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:200.0:23.0:22.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:200.0:23.0:22.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:201.0:24.0:23.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:201.0:24.0:23.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:202.0:25.0:24.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:202.0:25.0:24.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:203.0:26.0:25.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:203.0:26.0:25.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:204.0:27.0:26.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:204.0:27.0:26.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:205.0:28.0:27.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:205.0:28.0:27.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Scored\n",
      "Scored is the most frequent prediction from my region.\n",
      ">>sending Scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:407.0:31.0:9.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:407.0:31.0:9.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:408.0:32.0:10.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:408.0:32.0:10.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:409.0:33.0:11.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:409.0:33.0:11.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:410.0:34.0:12.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:410.0:34.0:12.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:411.0:35.0:13.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:411.0:35.0:13.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:412.0:36.0:14.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:412.0:36.0:14.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:413.0:37.0:15.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:413.0:37.0:15.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:414.0:38.0:16.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:414.0:38.0:16.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:415.0:39.0:17.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:415.0:39.0:17.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:416.0:40.0:18.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:416.0:40.0:18.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:179.0:48.6:9.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:179.0:48.6:9.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:180.0:49.6:10.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:180.0:49.6:10.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:181.0:50.6:11.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:181.0:50.6:11.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:182.0:51.6:12.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:182.0:51.6:12.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:183.0:52.6:13.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:183.0:52.6:13.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:184.0:53.6:14.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:184.0:53.6:14.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:185.0:54.6:15.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:185.0:54.6:15.8...\n",
      ">>received Not-scored...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:186.0:55.6:16.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:186.0:55.6:16.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:187.0:56.6:17.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:187.0:56.6:17.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:188.0:57.6:18.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:188.0:57.6:18.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:87.0:16.0:17.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:87.0:16.0:17.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:88.0:17.0:18.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:88.0:17.0:18.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:89.0:18.0:19.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:89.0:18.0:19.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:90.0:19.0:20.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:90.0:19.0:20.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:91.0:20.0:21.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:91.0:20.0:21.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:92.0:21.0:22.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:92.0:21.0:22.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:93.0:22.0:23.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:93.0:22.0:23.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:94.0:23.0:24.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:94.0:23.0:24.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:95.0:24.0:25.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:95.0:24.0:25.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:96.0:25.0:26.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:96.0:25.0:26.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:156.0:23.0:12.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:156.0:23.0:12.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:157.0:24.0:13.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:157.0:24.0:13.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:158.0:25.0:14.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:158.0:25.0:14.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:159.0:26.0:15.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:159.0:26.0:15.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:160.0:27.0:16.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:160.0:27.0:16.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:161.0:28.0:17.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:161.0:28.0:17.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:162.0:29.0:18.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:162.0:29.0:18.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:163.0:30.0:19.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:163.0:30.0:19.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:164.0:31.0:20.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:164.0:31.0:20.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:165.0:32.0:21.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:165.0:32.0:21.0...\n",
      ">>received Scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:61.0:15.0:9.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:61.0:15.0:9.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:62.0:16.0:10.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:62.0:16.0:10.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:63.0:17.0:11.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:63.0:17.0:11.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:64.0:18.0:12.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:64.0:18.0:12.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:65.0:19.0:13.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:65.0:19.0:13.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:66.0:20.0:14.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:66.0:20.0:14.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:67.0:21.0:15.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:67.0:21.0:15.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:68.0:22.0:16.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:68.0:22.0:16.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:69.0:23.0:17.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:69.0:23.0:17.0...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:70.0:24.0:18.0...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:70.0:24.0:18.0...\n",
      ">>received Not-scored...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:18.0:6.52:11.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:18.0:6.52:11.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:19.0:7.52:12.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:19.0:7.52:12.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:20.0:8.52:13.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:20.0:8.52:13.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:21.0:9.52:14.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:21.0:9.52:14.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:22.0:10.52:15.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:22.0:10.52:15.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:23.0:11.52:16.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:23.0:11.52:16.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:24.0:12.52:17.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:24.0:12.52:17.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:25.0:13.52:18.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:25.0:13.52:18.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:26.0:14.52:19.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:26.0:14.52:19.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:27.0:15.52:20.3...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:27.0:15.52:20.3...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:116.0:27.6:13.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:116.0:27.6:13.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:117.0:28.6:14.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:117.0:28.6:14.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:118.0:29.6:15.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:118.0:29.6:15.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:119.0:30.6:16.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:119.0:30.6:16.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:120.0:31.6:17.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:120.0:31.6:17.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:121.0:32.6:18.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:121.0:32.6:18.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:122.0:33.6:19.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:122.0:33.6:19.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:123.0:34.6:20.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:123.0:34.6:20.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:124.0:35.6:21.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:124.0:35.6:21.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:125.0:36.6:22.2...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:125.0:36.6:22.2...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:38.1:21.5:9.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:38.1:21.5:9.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:39.1:22.5:10.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:39.1:22.5:10.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:40.1:23.5:11.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:40.1:23.5:11.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:41.1:24.5:12.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:41.1:24.5:12.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:42.1:25.5:13.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:42.1:25.5:13.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:43.1:26.5:14.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:43.1:26.5:14.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:44.1:27.5:15.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:44.1:27.5:15.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:45.1:28.5:16.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:45.1:28.5:16.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:46.1:29.5:17.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:46.1:29.5:17.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:47.1:30.5:18.6...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:47.1:30.5:18.6...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:73.0:24.0:10.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:73.0:24.0:10.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:74.0:25.0:11.5...\n",
      "Sending x_test...\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ">>sending rcv_test:74.0:25.0:11.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:75.0:26.0:12.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:75.0:26.0:12.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:76.0:27.0:13.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:76.0:27.0:13.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:77.0:28.0:14.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:77.0:28.0:14.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:78.0:29.0:15.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:78.0:29.0:15.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:79.0:30.0:16.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:79.0:30.0:16.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:80.0:31.0:17.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:80.0:31.0:17.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:81.0:32.0:18.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:81.0:32.0:18.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:82.0:33.0:19.5...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:82.0:33.0:19.5...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:83.5:36.0:11.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:83.5:36.0:11.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:84.5:37.0:12.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:84.5:37.0:12.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:85.5:38.0:13.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:85.5:38.0:13.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:86.5:39.0:14.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:86.5:39.0:14.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:87.5:40.0:15.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:87.5:40.0:15.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:88.5:41.0:16.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:88.5:41.0:16.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:89.5:42.0:17.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:89.5:42.0:17.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:90.5:43.0:18.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:90.5:43.0:18.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:91.5:44.0:19.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:91.5:44.0:19.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n",
      "\n",
      "//////////////////////////////////////// waiting to receive predictions from region ////////////////////////////////////////\n",
      ">>received rcv_test:92.5:45.0:20.8...\n",
      "Sending x_test...\n",
      ">>sending rcv_test:92.5:45.0:20.8...\n",
      ">>received Not-scored...\n",
      "sf:: [1.0]\n",
      ">>>>>>>>>>> Not-scored\n",
      "Not-scored is the most frequent prediction from my region.\n",
      ">>sending Not-scored...\n"
     ]
    }
   ],
   "source": [
    "if status == \"s\":\n",
    "    for i in range(248):\n",
    "        print(\"\\n\" + \"/\"*40 + \" waiting to receive predictions from region \" + \"/\"*40)\n",
    "        x_test = socket_rcv(server_connection)[len(\"rcv_test:\"):]\n",
    "        predictions = []\n",
    "        print(\"Sending x_test...\")\n",
    "        for onode_connection in onodes_connections:\n",
    "            socket_send(onode_connection[2], \"rcv_test:\"+x_test)\n",
    "            predictions.append(socket_rcv(onode_connection[2]))\n",
    "        my_prediction = train_and_predict(df, pd.DataFrame([x_test.split(\":\")], columns=[list(df.columns)[:-1]]))[0]\n",
    "        print(\">>>>>>>>>>>\", my_prediction)\n",
    "        predictions.append(my_prediction)\n",
    "        predictions.reverse()\n",
    "        print(most_frequent(predictions),\"is the most frequent prediction from my region.\")\n",
    "        socket_send(server_connection, most_frequent(predictions))"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Ordinary Node"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Receiving IP:Port for super node of your current region"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 67,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// Ordinary Node Socket ////////////////////////////////////////\n",
      ">>received ubuntu:4353...\n",
      "Snode of my region is present at ubuntu:4353\n"
     ]
    }
   ],
   "source": [
    "if status == \"o\":\n",
    "    print(\"\\n\" + \"/\"*40 + \" Ordinary Node Socket \" + \"/\"*40)\n",
    "    ip_port = socket_rcv(server_connection).split(\":\")\n",
    "    snodes.append((ip_port[0], int(ip_port[1])))\n",
    "\n",
    "    for ip,port in snodes:\n",
    "        print(\"Snode of my region is present at \"+ip+\":\"+str(port))"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### After sending a connection request to the super node, ordinary nodes sends its kazaa_constant and start receiving its share in the dataset"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 68,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting to receive data from super node ////////////////////////////////////////\n",
      "Connected to the supernode.\n",
      "\n",
      ">>sending k_const:0.8302342411950161...\n",
      "starting receiving rows\n",
      ">>received rcv:124...\n",
      ">>received rcv:Acceleration:Speed(m/s):Angle:Target...\n",
      "row_count: 124 headers: ['Acceleration', 'Speed(m/s)', 'Angle', 'Target']\n",
      ">>received 129.0:29.0:53.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['129.0', '29.0', '53.0']\n",
      ">>received 252.0:24.0:13.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['252.0', '24.0', '13.6']\n",
      ">>received 127.0:27.0:51.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['127.0', '27.0', '51.0']\n",
      ">>received 300.0:25.35:64.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['300.0', '25.35', '64.0']\n",
      ">>received 68.0:22.0:16.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['68.0', '22.0', '16.0']\n",
      ">>received 204.0:42.0:71.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['204.0', '42.0', '71.0']\n",
      ">>received 259.0:31.0:20.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['259.0', '31.0', '20.6']\n",
      ">>received 301.0:26.35:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['301.0', '26.35', '65.0']\n",
      ">>received 213.0:21.26:62.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['213.0', '21.26', '62.0']\n",
      ">>received 197.0:20.0:19.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['197.0', '20.0', '19.0']\n",
      ">>received 20.0:8.52:13.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['20.0', '8.52', '13.3']\n",
      ">>received 253.0:25.0:14.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['253.0', '25.0', '14.6']\n",
      ">>received 123.0:22.6:46.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '22.6', '46.8']\n",
      ">>received 123.0:34.6:20.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '34.6', '20.2']\n",
      ">>received 121.0:20.6:44.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['121.0', '20.6', '44.8']\n",
      ">>received 200.0:38.0:67.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['200.0', '38.0', '67.0']\n",
      ">>received 83.5:36.0:11.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['83.5', '36.0', '11.8']\n",
      ">>received 21.0:9.52:14.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['21.0', '9.52', '14.3']\n",
      ">>received 413.0:37.0:15.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['413.0', '37.0', '15.0']\n",
      ">>received 164.0:42.0:50.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['164.0', '42.0', '50.0']\n",
      ">>received 23.0:11.52:16.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['23.0', '11.52', '16.3']\n",
      ">>received 125.0:24.6:48.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['125.0', '24.6', '48.8']\n",
      ">>received 92.0:21.0:22.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['92.0', '21.0', '22.0']\n",
      ">>received 188.0:57.6:18.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['188.0', '57.6', '18.8']\n",
      ">>received 411.0:35.0:13.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['411.0', '35.0', '13.0']\n",
      ">>received 46.1:29.5:17.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['46.1', '29.5', '17.6']\n",
      ">>received 126.0:25.6:49.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['126.0', '25.6', '49.8']\n",
      ">>received 163.0:41.0:49.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['163.0', '41.0', '49.0']\n",
      ">>received 39.1:22.5:10.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['39.1', '22.5', '10.6']\n",
      ">>received 210.0:18.26:59.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['210.0', '18.26', '59.0']\n",
      ">>received 27.0:15.52:20.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['27.0', '15.52', '20.3']\n",
      ">>received 122.0:33.6:19.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['122.0', '33.6', '19.2']\n",
      ">>received 123.0:23.0:47.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['123.0', '23.0', '47.0']\n",
      ">>received 93.0:22.0:23.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['93.0', '22.0', '23.0']\n",
      ">>received 203.0:26.0:25.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['203.0', '26.0', '25.0']\n",
      ">>received 192.0:34.0:38.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['192.0', '34.0', '38.0']\n",
      ">>received 125.0:25.0:49.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['125.0', '25.0', '49.0']\n",
      ">>received 218.0:26.26:67.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['218.0', '26.26', '67.0']\n",
      ">>received 118.0:24.0:26.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['118.0', '24.0', '26.0']\n",
      ">>received 199.0:22.0:21.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['199.0', '22.0', '21.0']\n",
      ">>received 94.0:23.0:24.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['94.0', '23.0', '24.0']\n",
      ">>received 204.0:25.0:42.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['204.0', '25.0', '42.3']\n",
      ">>received 79.0:30.0:16.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['79.0', '30.0', '16.5']\n",
      ">>received 410.0:34.0:12.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['410.0', '34.0', '12.0']\n",
      ">>received 119.0:25.0:27.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['119.0', '25.0', '27.0']\n",
      ">>received 158.0:36.0:44.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['158.0', '36.0', '44.0']\n",
      ">>received 66.0:20.0:14.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['66.0', '20.0', '14.0']\n",
      ">>received 119.0:30.6:16.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['119.0', '30.6', '16.2']\n",
      ">>received 166.0:47.0:55.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['166.0', '47.0', '55.0']\n",
      ">>received 196.0:34.0:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['196.0', '34.0', '63.0']\n",
      ">>received 202.0:25.0:24.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '25.0', '24.0']\n",
      ">>received 18.0:6.52:11.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['18.0', '6.52', '11.3']\n",
      ">>received 138.0:35.0:71.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['138.0', '35.0', '71.0']\n",
      ">>received 254.0:26.0:15.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['254.0', '26.0', '15.6']\n",
      ">>received 127.0:26.6:50.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['127.0', '26.6', '50.8']\n",
      ">>received 183.0:52.6:13.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['183.0', '52.6', '13.8']\n",
      ">>received 312.0:26.82:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['312.0', '26.82', '65.0']\n",
      ">>received 61.0:15.0:9.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['61.0', '15.0', '9.0']\n",
      ">>received 41.1:24.5:12.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['41.1', '24.5', '12.6']\n",
      ">>received 96.0:25.0:26.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['96.0', '25.0', '26.0']\n",
      ">>received 184.0:53.6:14.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['184.0', '53.6', '14.8']\n",
      ">>received 198.0:36.0:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['198.0', '36.0', '65.0']\n",
      ">>received 187.0:29.0:33.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['187.0', '29.0', '33.0']\n",
      ">>received 136.0:33.0:69.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['136.0', '33.0', '69.0']\n",
      ">>received 82.0:33.0:19.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['82.0', '33.0', '19.5']\n",
      ">>received 160.0:41.0:49.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['160.0', '41.0', '49.0']\n",
      ">>received 307.0:21.82:60.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['307.0', '21.82', '60.0']\n",
      ">>received 133.0:30.0:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['133.0', '30.0', '66.0']\n",
      ">>received 251.0:23.0:12.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['251.0', '23.0', '12.6']\n",
      ">>received 24.0:12.52:17.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['24.0', '12.52', '17.3']\n",
      ">>received 306.0:20.82:59.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['306.0', '20.82', '59.0']\n",
      ">>received 42.1:25.5:13.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['42.1', '25.5', '13.6']\n",
      ">>received 137.0:34.0:70.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['137.0', '34.0', '70.0']\n",
      ">>received 189.0:31.0:35.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['189.0', '31.0', '35.0']\n",
      ">>received 132.0:29.0:65.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['132.0', '29.0', '65.0']\n",
      ">>received 195.0:37.0:41.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['195.0', '37.0', '41.0']\n",
      ">>received 62.0:16.0:10.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['62.0', '16.0', '10.0']\n",
      ">>received 88.5:41.0:16.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['88.5', '41.0', '16.8']\n",
      ">>received 250.0:22.0:11.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['250.0', '22.0', '11.6']\n",
      ">>received 118.0:29.6:15.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['118.0', '29.6', '15.2']\n",
      ">>received 200.0:23.0:22.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['200.0', '23.0', '22.0']\n",
      ">>received 139.0:36.0:72.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['139.0', '36.0', '72.0']\n",
      ">>received 81.0:32.0:18.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['81.0', '32.0', '18.5']\n",
      ">>received 124.0:35.6:21.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['124.0', '35.6', '21.2']\n",
      ">>received 199.0:37.0:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['199.0', '37.0', '66.0']\n",
      ">>received 167.0:48.0:56.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['167.0', '48.0', '56.0']\n",
      ">>received 409.0:33.0:11.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['409.0', '33.0', '11.0']\n",
      ">>received 85.5:38.0:13.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['85.5', '38.0', '13.8']\n",
      ">>received 196.0:19.0:18.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['196.0', '19.0', '18.0']\n",
      ">>received 201.0:22.0:39.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '22.0', '39.3']\n",
      ">>received 121.0:21.0:45.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['121.0', '21.0', '45.0']\n",
      ">>received 193.0:35.0:39.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['193.0', '35.0', '39.0']\n",
      ">>received 196.0:34.0:63.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['196.0', '34.0', '63.0']\n",
      ">>received 201.0:39.0:68.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '39.0', '68.0']\n",
      ">>received 202.0:23.0:40.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '23.0', '40.3']\n",
      ">>received 22.0:10.52:15.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['22.0', '10.52', '15.3']\n",
      ">>received 25.0:13.52:18.3:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['25.0', '13.52', '18.3']\n",
      ">>received 191.0:33.0:37.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['191.0', '33.0', '37.0']\n",
      ">>received 163.0:30.0:19.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['163.0', '30.0', '19.0']\n",
      ">>received 128.0:28.0:52.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['128.0', '28.0', '52.0']\n",
      ">>received 90.5:43.0:18.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['90.5', '43.0', '18.8']\n",
      ">>received 117.0:28.6:14.2:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['117.0', '28.6', '14.2']\n",
      ">>received 161.0:42.0:50.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['161.0', '42.0', '50.0']\n",
      ">>received 91.5:44.0:19.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['91.5', '44.0', '19.8']\n",
      ">>received 199.0:37.0:66.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['199.0', '37.0', '66.0']\n",
      ">>received 119.0:18.6:42.8:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['119.0', '18.6', '42.8']\n",
      ">>received 38.1:21.5:9.6:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['38.1', '21.5', '9.6']\n",
      ">>received 124.0:24.0:48.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['124.0', '24.0', '48.0']\n",
      ">>received 415.0:39.0:17.0:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['415.0', '39.0', '17.0']\n",
      ">>received 305.0:19.82:58.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['305.0', '19.82', '58.0']\n",
      ">>received 255.0:27.0:16.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['255.0', '27.0', '16.6']\n",
      ">>received 87.5:40.0:15.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['87.5', '40.0', '15.8']\n",
      ">>received 205.0:26.0:43.3:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['205.0', '26.0', '43.3']\n",
      ">>received 205.0:28.0:27.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['205.0', '28.0', '27.0']\n",
      ">>received 114.0:20.0:22.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['114.0', '20.0', '22.0']\n",
      ">>received 256.0:28.0:17.6:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['256.0', '28.0', '17.6']\n",
      ">>received 117.0:23.0:25.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['117.0', '23.0', '25.0']\n",
      ">>received 202.0:40.0:69.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['202.0', '40.0', '69.0']\n",
      ">>received 201.0:24.0:23.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['201.0', '24.0', '23.0']\n",
      ">>received 162.0:43.0:51.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['162.0', '43.0', '51.0']\n",
      ">>received 80.0:31.0:17.5:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['80.0', '31.0', '17.5']\n",
      ">>received 168.0:49.0:57.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['168.0', '49.0', '57.0']\n",
      ">>received 115.0:21.0:23.0:Scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['115.0', '21.0', '23.0']\n",
      ">>received 180.0:49.6:10.8:Not-scored...\n",
      ">>sending rcvd...\n",
      "Rcvd row: ['180.0', '49.6', '10.8']\n",
      "df received from supernode of my region has shape:  (124, 4)\n"
     ]
    }
   ],
   "source": [
    "if status == \"o\":\n",
    "# starting connections with onodes:\n",
    "    print(\"\\n\" + \"/\"*40 + \" waiting to receive data from super node \" + \"/\"*40)\n",
    "    i = 0\n",
    "    for ip,port in snodes:\n",
    "        try:\n",
    "            snode_connection = socket.socket()\n",
    "            snode_connection.connect((ip, port))\n",
    "            print(\"Connected to the supernode.\\n\")\n",
    "            df = onode_snode_socket(snode_connection)\n",
    "        except socket.error as e:\n",
    "            print(str(e))\n",
    "        i += 1"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Receiving x_test from supernode of region and sending pack a prediction"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 47,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for x_test ////////////////////////////////////////\n",
      ">>received rcv_test:190.0:32.0:36.0...\n",
      ">>sending Scored...\n"
     ]
    }
   ],
   "source": [
    "if status == \"o\":\n",
    "    print(\"\\n\" + \"/\"*40 + \" waiting for x_test \" + \"/\"*40)\n",
    "    x_test = socket_rcv(snode_connection)[len(\"rcv_test:\"):]\n",
    "    df2 = pd.DataFrame([x_test.split(\":\")], columns=[list(df.columns)[:-1]])\n",
    "    socket_send(snode_connection, train_and_predict(df, df2)[0])"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 72,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "//////////////////////////////////////// waiting for x_test ////////////////////////////////////////\n",
      ">>received rcv_test:186.0:28.0:32.0...\n",
      "\n",
      "//////////////////////////////////////// waiting for x_test ////////////////////////////////////////\n"
     ]
    },
    {
     "ename": "KeyboardInterrupt",
     "evalue": "",
     "output_type": "error",
     "traceback": [
      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[0;31mKeyboardInterrupt\u001b[0m                         Traceback (most recent call last)",
      "\u001b[0;32m<ipython-input-72-da63daa2f7ba>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m\u001b[0m\n\u001b[1;32m      2\u001b[0m     \u001b[0;32mfor\u001b[0m \u001b[0mi\u001b[0m \u001b[0;32min\u001b[0m \u001b[0mrange\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;36m248\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      3\u001b[0m         \u001b[0mprint\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"\\n\"\u001b[0m \u001b[0;34m+\u001b[0m \u001b[0;34m\"/\"\u001b[0m\u001b[0;34m*\u001b[0m\u001b[0;36m40\u001b[0m \u001b[0;34m+\u001b[0m \u001b[0;34m\" waiting for x_test \"\u001b[0m \u001b[0;34m+\u001b[0m \u001b[0;34m\"/\"\u001b[0m\u001b[0;34m*\u001b[0m\u001b[0;36m40\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m----> 4\u001b[0;31m         \u001b[0mx_test\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0msocket_rcv\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0msnode_connection\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0mlen\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"rcv_test:\"\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m      5\u001b[0m         \u001b[0mdf2\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mpd\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mDataFrame\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0mx_test\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msplit\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\":\"\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mcolumns\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0mlist\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mdf\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mcolumns\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m-\u001b[0m\u001b[0;36m1\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      6\u001b[0m         \u001b[0;31m#socket_send(snode_connection, train_and_predict(df, df2)[0])\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m<ipython-input-53-a55133030158>\u001b[0m in \u001b[0;36msocket_rcv\u001b[0;34m(connection, size)\u001b[0m\n\u001b[1;32m     20\u001b[0m     \u001b[0mack\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mFalse\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     21\u001b[0m     \u001b[0;32mwhile\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;32mnot\u001b[0m \u001b[0mack\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 22\u001b[0;31m         \u001b[0mtxt\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mconnection\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mrecv\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0msize\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mdecode\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m'utf-8'\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m     23\u001b[0m         \u001b[0mconnection\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msend\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mstr\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mencode\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mstr\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mlen\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mtxt\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     24\u001b[0m         \u001b[0mack\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mTrue\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0mconnection\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mrecv\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0msize\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mdecode\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m'utf-8'\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;34m==\u001b[0m \u001b[0;34m\"ack\"\u001b[0m \u001b[0;32melse\u001b[0m \u001b[0;32mFalse\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;31mKeyboardInterrupt\u001b[0m: "
     ]
    }
   ],
   "source": [
    "if status == \"o\":\n",
    "    for i in range(248):\n",
    "        print(\"\\n\" + \"/\"*40 + \" waiting for x_test \" + \"/\"*40)\n",
    "        x_test = socket_rcv(snode_connection)[len(\"rcv_test:\"):]\n",
    "        df2 = pd.DataFrame([x_test.split(\":\")], columns=[list(df.columns)[:-1]])\n",
    "        socket_send(snode_connection, train_and_predict(df, df2)[0])"
   ]
  },
  {
   "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
}