<reponame>marcrobinson/hc2017
import os, numpy
from VideoCache import time_saved_calculator

from end_point import Endpoint
from cache_server import CacheServer
from cache_server_connection import CacheServerConnection
import time_saved_calculator
from video import Video
from request_description import RequestDescrption


class DataReader:
    def __init__(self, filename):
        self.filename = filename

    def get_line_list(self, line):
        items = line.strip().split(" ")
        for i in range(len(items)):
            items[i] = int(items[i])
        return items

    def get_next_line_list(self):
        line = self.file.readline()
        return self.get_line_list(line)

    def read(self):


        self.file = open(self.filename)
        self.num_of_videos, self.num_of_endpoints, self.num_of_request_descriptions, self.num_of_cache_servers, self.capacity_of_cache_server = self.get_next_line_list()

        CacheServer.capacity = self.capacity_of_cache_server

        self.cache_servers = []
        for i in range(self.num_of_cache_servers):
            self.cache_servers.append(CacheServer(i))

        self.videos = []
        self.video_to_requests = {}
        video_sizes = self.get_next_line_list()
        for i in range(self.num_of_videos):
            self.videos.append(Video(i, video_sizes[i]))
            self.video_to_requests[self.videos[-1]] = []

        self.endpoints = []
        for i in range(self.num_of_endpoints):
            data_center_latency, num_of_cache_servers = self.get_next_line_list()
            endpoint = Endpoint(i, data_center_latency)
            endpoint.cache_server_connections = []
            for i in range(num_of_cache_servers):
                cache_server_ID, cache_server_latency = self.get_next_line_list()
                cache_server = self.cache_servers[cache_server_ID]
                cache_server_connection = CacheServerConnection(cache_server, endpoint, cache_server_latency)
                endpoint.cache_server_connections.append(cache_server_connection)
                cache_server.cache_server_connections.append(cache_server_connection)
#                endpoint.cache_server_connections_hash[cache_server]=cache_server_connection
            self.endpoints.append(endpoint)

        self.request_descriptions = []

        for i in range(self.num_of_request_descriptions):
            video_ID, endpoint_ID, num_of_requests = self.get_next_line_list()
            video = self.videos[video_ID]
            endpoint = self.endpoints[endpoint_ID]
            self.request_descriptions.append(RequestDescrption(video, endpoint, num_of_requests))

            self.video_to_requests[video].append(self.request_descriptions[-1])



if __name__ == "__main__":
    reader = DataReader(os.path.join("input", "me_at_the_zoo.in"))
    reader.read()


    #
    #
    # cs_video_val = time_saved_calculator.calc_benefit(data_model.request_descriptions, data_model.videos, data_model.cache_servers)
    #
    #
    #
    # print(cs_video_val)
    #
    # print("*********")
    #
    # print(numpy.sort(cs_video_val))
    #
    # print(numpy.argsort(cs_video_val))
    #







import os, numpy
from VideoCache import time_saved_calculator

from end_point import Endpoint
from cache_server import CacheServer
from cache_server_connection import CacheServerConnection
import time_saved_calculator
from video import Video
from request_description import RequestDescrption


class DataReader:
    def __init__(self, filename):
        self.filename = filename

    def get_line_list(self, line):
        items = line.strip().split(" ")
        for i in range(len(items)):
            items[i] = int(items[i])
        return items

    def get_next_line_list(self):
        line = self.file.readline()
        return self.get_line_list(line)

    def read(self):


        self.file = open(self.filename)
        self.num_of_videos, self.num_of_endpoints, self.num_of_request_descriptions, self.num_of_cache_servers, self.capacity_of_cache_server = self.get_next_line_list()

        CacheServer.capacity = self.capacity_of_cache_server

        self.cache_servers = []
        for i in range(self.num_of_cache_servers):
            self.cache_servers.append(CacheServer(i))

        self.videos = []
        self.video_to_requests = {}
        video_sizes = self.get_next_line_list()
        for i in range(self.num_of_videos):
            self.videos.append(Video(i, video_sizes[i]))
            self.video_to_requests[self.videos[-1]] = []

        self.endpoints = []
        for i in range(self.num_of_endpoints):
            data_center_latency, num_of_cache_servers = self.get_next_line_list()
            endpoint = Endpoint(i, data_center_latency)
            endpoint.cache_server_connections = []
            for i in range(num_of_cache_servers):
                cache_server_ID, cache_server_latency = self.get_next_line_list()
                cache_server = self.cache_servers[cache_server_ID]
                cache_server_connection = CacheServerConnection(cache_server, endpoint, cache_server_latency)
                endpoint.cache_server_connections.append(cache_server_connection)
                cache_server.cache_server_connections.append(cache_server_connection)
#                endpoint.cache_server_connections_hash[cache_server]=cache_server_connection
            self.endpoints.append(endpoint)

        self.request_descriptions = []

        for i in range(self.num_of_request_descriptions):
            video_ID, endpoint_ID, num_of_requests = self.get_next_line_list()
            video = self.videos[video_ID]
            endpoint = self.endpoints[endpoint_ID]
            self.request_descriptions.append(RequestDescrption(video, endpoint, num_of_requests))

            self.video_to_requests[video].append(self.request_descriptions[-1])



if __name__ == "__main__":
    reader = DataReader(os.path.join("input", "me_at_the_zoo.in"))
    reader.read()


    #
    #
    # cs_video_val = time_saved_calculator.calc_benefit(data_model.request_descriptions, data_model.videos, data_model.cache_servers)
    #
    #
    #
    # print(cs_video_val)
    #
    # print("*********")
    #
    # print(numpy.sort(cs_video_val))
    #
    # print(numpy.argsort(cs_video_val))
    #
#                endpoint.cache_server_connections_hash[cache_server]=cache_server_connection # # # cs_video_val = time_saved_calculator.calc_benefit(data_model.request_descriptions, data_model.videos, data_model.cache_servers) # # # # print(cs_video_val) # # print("*********") # # print(numpy.sort(cs_video_val)) # # print(numpy.argsort(cs_video_val)) #