diff options
author | pzread <netfirewall@gmail.com> | 2013-06-22 18:55:10 +0800 |
---|---|---|
committer | pzread <netfirewall@gmail.com> | 2013-06-22 18:55:10 +0800 |
commit | e0043639746fdbbf4958c67a3ef55c63c2fe51a5 (patch) | |
tree | bf553445c16ad67b56fd26403057428c4e6dd4af /src/py/backend_server.py | |
parent | a66de70527978a4510c6e230fcc56ce890bf20a2 (diff) | |
download | taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.tar taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.tar.gz taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.tar.bz2 taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.tar.lz taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.tar.xz taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.tar.zst taiwan-online-judge-e0043639746fdbbf4958c67a3ef55c63c2fe51a5.zip |
Add notice. Done profile page
Diffstat (limited to 'src/py/backend_server.py')
-rwxr-xr-x | src/py/backend_server.py | 36 |
1 files changed, 24 insertions, 12 deletions
diff --git a/src/py/backend_server.py b/src/py/backend_server.py index 197d820..b9bb07b 100755 --- a/src/py/backend_server.py +++ b/src/py/backend_server.py @@ -14,12 +14,14 @@ import tornado.websocket from imc import auth import imc.async -from imc.proxy import Proxy,Connection,imc_call,imc_call_async,imc_register_call +from imc.proxy import Proxy,Connection import netio from netio import SocketStream,SocketConnection,WebSocketConnection from tojauth import TOJAuth -import mod +from notice import Notice +from user import UserMg +from mail import Mail class BackendWorker(tornado.tcpserver.TCPServer): def __init__(self,center_addr,ws_port): @@ -113,8 +115,15 @@ class BackendWorker(tornado.tcpserver.TCPServer): Proxy.instance.register_call('test/','test_dst',self._test_dst) #Proxy.instance.register_filter('test/',self._test_filter) - mod.load('core_user','user',self._idendesc,self._get_link) - mod.load('core_mail','mail',self._idendesc,self._get_link) + try: + Notice(self._idendesc,self._get_link) + UserMg(self._idendesc,self._get_link) + Mail(self._idendesc,self._get_link) + except Exception as e: + print(e) + + #mod.load('core_user','user',self._idendesc,self._get_link) + #mod.load('core_mail','mail',self._idendesc,self._get_link) #if self._link == '/backend/2/': # self._test_call(None) @@ -178,6 +187,9 @@ class BackendWorker(tornado.tcpserver.TCPServer): with TOJAuth.change_current_iden(self._idendesc): stat,ret = Proxy.instance.call(self.center_conn.link,'lookup_link',65536,link) + print(link) + print(ret) + if stat == False or ret == None: return None @@ -236,10 +248,15 @@ class BackendWorker(tornado.tcpserver.TCPServer): except KeyError: pass - def _get_link(self,linkclass): + def _get_link(self,linkclass,uid = None): if linkclass == 'center': return self.center_conn.link + elif linkclass == 'client' and uid != None: + stat,ret = Proxy.instance.call(self.center_conn.link + 'core/','get_uid_clientlink',10000,uid) + print(ret) + return ret + @imc.async.caller def _test_get_client_list(self,talk,talk2): stat,ret = Proxy.instance.call(TOJAuth.get_current_iden()['link'] + 'test/route/','80s',1000,'attation','mega') @@ -262,18 +279,13 @@ class BackendWorker(tornado.tcpserver.TCPServer): continue fileres = Proxy.instance.sendfile(dst,'Fedora-18-x86_64-DVD.iso') - ret = imc_call_async(dst + 'test/','test_dst',lambda result: print('ok'),fileres.filekey) + ret = Proxy.instance.call_async(dst + 'test/','test_dst',lambda result: print('ok'),fileres.filekey) print(fileres.wait()) print(time.perf_counter() - st) print(self._link) - #imc_call_async(dst,'test_dst',lambda result : print(result),'test',113) - - #ret = imc_call('/center/1/','create_iden','client','1234',1221,TOJAuth.ROLETYPE_USER,{'uid':31}) - #print(ret) - return pend = [] @@ -284,7 +296,7 @@ class BackendWorker(tornado.tcpserver.TCPServer): fileres = Proxy.instance.sendfile('/backend/' + str((i % 16) + 2) + '/','Fedora-18-x86_64-DVD.iso') dst = '/backend/' + str((i % 16) + 2) + '/' - ret = imc_call(self._idendesc,dst,'test_dst',fileres.filekey) + ret = Proxy.instance.call(self._idendesc,dst,'test_dst',fileres.filekey) pend.append(fileres) |