# -*- coding: utf-8 -*-
from socket import *
from time import ctime
from video import Video_Server
# 服务配置
HOST = '172.16.102.9'
PORT = 10087

BUFSIZE = 81920
ADDR = (HOST, PORT)
userList = []
MAXCLIENT = 1
FX = 0.5
SPD = 0.125


def loopServer(tcpSrvSock):
    # 服务监听
    global userList, MAXCLIENT
    while True:
        print('Waiting For Client Connection ...', ctime())
        tcpCliSock, addr = tcpSrvSock.accept()  # 会阻塞
        print('NewUser', addr, ctime())
        print('UserListLenght:', len(userList))
        # 增加线程
        if tcpCliSock not in userList and len(userList) < MAXCLIENT:
            newClinet = Video_Server(
                userList, tcpCliSock, BUFSIZE, addr, SPD, FX)
            newClinet.start()
        else:
            # 不允许连接
            print('不允许连接')
            tcpCliSock.close()


if __name__ == '__main__':
    tcpSrvSock = socket(AF_INET, SOCK_STREAM)
    tcpSrvSock.bind(ADDR)
    tcpSrvSock.listen(1)
    loopServer(tcpSrvSock)