def initialisation(host,port):
'''
??????????,?????????????
'''
flag=False
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
rsync={"MagicHeader":"@RSYNCD:","HeaderVersion":" 30.0"}
payload=struct.pack("!8s5ss",rsync["MagicHeader"],rsync["HeaderVersion"],"\n")#init
try:
socket.setdefaulttimeout(20)#??
s.connect((host,port))#?????????
s.send(payload)
data=s.recv(1024)
reply=struct.unpack('!8s5ss',data)
if len(reply)==3:
flag=True #????
rsynclist=ClientQuery(s) #?????
except Exception :
pass
finally:
s.close()
if flag:
return True,reply[0],reply[1],rsynclist
return False,"port not open"
评论列表
文章目录