| | |
|---|
| | | del_codes = self.subscripted_codes - codes |
|---|
| | | print("add del codes", add_codes, del_codes) |
|---|
| | | for c in codes: |
|---|
| | | l2_data_manager.target_codes.add(c) |
|---|
| | | l2_data_manager.add_target_code(c) |
|---|
| | | for c in del_codes: |
|---|
| | | l2_data_manager.target_codes.discard(c) |
|---|
| | | l2_data_manager.del_target_code(c) |
|---|
| | | for c in add_codes: |
|---|
| | | l2_data_manager.run_upload_task(c, l2_data_callback) |
|---|
| | | self.__subscribe(add_codes) |
|---|
| | |
|---|
| | | l2_data_manager.run_upload_common(l2_data_callback) |
|---|
| | | l2_data_manager.run_upload_trading_canceled(l2_data_callback) |
|---|
| | | l2_data_manager.run_log() |
|---|
| | | l2_data_manager.run_upload_daemon(l2_data_callback) |
|---|
| | | # l2_data_manager.run_test(l2_data_callback) |
|---|
| | | global l2CommandManager |
|---|
| | | l2CommandManager = command_manager.L2CommandManager() |
|---|
