HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
ftest_test_async_MsgSend.py File Reference

Go to the source code of this file.

Classes

class  ftests.ftest_test_async_MsgSend.TestRequest
 
class  ftests.ftest_test_async_MsgSend.Client
 
class  ftests.ftest_test_async_MsgSend.Server
 

Namespaces

 ftests.ftest_test_async_MsgSend
 

Variables

string ftests.ftest_test_async_MsgSend.clientConnectName = "testConnect"
 
 ftests.ftest_test_async_MsgSend.connectBuilder = ConnectionBuilderLight()
 
 ftests.ftest_test_async_MsgSend.pollerManager = PollerManager(connectBuilder.zmq_poller)
 
 ftests.ftest_test_async_MsgSend.serverConnectAdmin = connectBuilder.build(transport.Consts.SERVER_CONNECT, BaseServerManager.ADMIN_CONNECT_ENDPOINT)
 
int ftests.ftest_test_async_MsgSend.client_request = 500
 
int ftests.ftest_test_async_MsgSend.client_number = 5
 
string ftests.ftest_test_async_MsgSend.connect_endpoint = "test_server1"
 
bool ftests.ftest_test_async_MsgSend.tcp_protocol = False
 
 ftests.ftest_test_async_MsgSend.clients = list()
 
 ftests.ftest_test_async_MsgSend.server = Server(pollerManager, client_request * client_number)
 
 ftests.ftest_test_async_MsgSend.serverConnect = None
 
 ftests.ftest_test_async_MsgSend.client = Client(client_request, "client" + str(index))
 
 ftests.ftest_test_async_MsgSend.clientConnect = None
 
 ftests.ftest_test_async_MsgSend.exit_flag