Kerrigan1.x-server/Server.py at master · fansubgroup/Kerrigan1.x-server · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
#!/usr/bin/env python

import socket
import os
import sys
import select
import time
import shutil
import json
from multiprocessing import Process, Pipe
from multiprocessing import Manager

import ServerClone
import ExchangeCenter

class ServerLoop:

    def __init__(self, host_ip, port, passwd):

        self.HOST_IP = host_ip

        self.PORT = port

        self.MAXLISTEN = 10

        self.PASSWD = passwd

        self.PROCESS_ID = 1


    def remove_sock_temp(self):

        if os.path.isdir('temp/sock'):

            shutil.rmtree('temp/sock')

        os.mkdir('temp/sock')


    def super_server(self):

        self.remove_sock_temp()

        CONNECTION_LIST = []

        server_pipe_update, client_pipe_update = Pipe()

        server_socks = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        mgr = Manager()

        share_list = mgr.list()

        to_megaphone_list = mgr.list()

        ec0 = Process(target = ExchangeCenter.exchangecenterstaff, args = (server_pipe_update, share_list, to_megaphone_list))

        ec0.daemon = True

        ec0.start()

        ec1 = Process(target = ExchangeCenter.megaphone, args = (share_list, to_megaphone_list))

        ec1.daemon = True

        ec1.start()

        server_socks.bind((self.HOST_IP, self.PORT))

        server_socks.listen(self.MAXLISTEN)

        print "Server start at %s:%d..." % (self.HOST_IP, self.PORT)

        CONNECTION_LIST.append(server_socks)

        log_file = open('temp/Log-server.log', 'a')

        while True:

            # get the list sockets which are ready to be read through select
            reads, writes, errors = select.select(CONNECTION_LIST, [], [])

            for s in reads:

                # new connection
                if s == server_socks:

                    socknew, addrnew = server_socks.accept()

                    CONNECTION_LIST.append(socknew)

                    t = time.localtime()

                    now_time = "%d-%d-%d-%d:%d:%d"  % (t.tm_year, t.tm_mon, t.tm_mday, t.tm_hour, t.tm_min, t.tm_sec)

                    log_file.writelines("ip:%s, port:%s want to connected at %s\n" % (addrnew[0], addrnew[1], now_time))

                else:

                    transfer_trouble = Process(target = ServerClone.server, args = (s, self.PASSWD, addrnew, self.PROCESS_ID, client_pipe_update))

                    transfer_trouble.daemon = True

                    transfer_trouble.start()

                    CONNECTION_LIST.remove(s)

                    self.PROCESS_ID += 1


def main():

    chat_init = ServerLoop('127.0.0.1', 8001, '11')

    chat_init.super_server()

if __name__ == "__main__":

    main()