|
@@ -642,7 +642,6 @@ class BotAgent:
|
|
self.ep.transportCreate(pj.PJSIP_TRANSPORT_UDP, sipTpConfig)
|
|
self.ep.transportCreate(pj.PJSIP_TRANSPORT_UDP, sipTpConfig)
|
|
# Start the library
|
|
# Start the library
|
|
self.ep.libStart()
|
|
self.ep.libStart()
|
|
- self._add_new_job()
|
|
|
|
|
|
|
|
for user_part in self.user_part_range:
|
|
for user_part in self.user_part_range:
|
|
acfg = build_account_config(self.host, self.port, user_part, self.password, timeout_sec)
|
|
acfg = build_account_config(self.host, self.port, user_part, self.password, timeout_sec)
|
|
@@ -659,6 +658,8 @@ class BotAgent:
|
|
registry.BOT_CREATE_ACCOUNT_LATENCY.observe(latency)
|
|
registry.BOT_CREATE_ACCOUNT_LATENCY.observe(latency)
|
|
self.logger.info("create pjsua latency: %.3fs", latency)
|
|
self.logger.info("create pjsua latency: %.3fs", latency)
|
|
|
|
|
|
|
|
+ self._add_new_job()
|
|
|
|
+ self.ep.mainLoop()
|
|
while not self.is_stopping:
|
|
while not self.is_stopping:
|
|
self.logger.info('1111111111111111111')
|
|
self.logger.info('1111111111111111111')
|
|
registry.BOT_AGENT_LIVES.set(self.user_part_pool.qsize())
|
|
registry.BOT_AGENT_LIVES.set(self.user_part_pool.qsize())
|