| | |
|---|
| | | callback_info = self.get_available_callback() |
|---|
| | | if not callback_info: |
|---|
| | | distibuted_callbacks_ids = set() |
|---|
| | | need_release_codes = set() |
|---|
| | | for code in self.distibuted_code_callback_dict: |
|---|
| | | distibuted_callbacks_ids.add(self.distibuted_code_callback_dict[code][0]) |
|---|
| | | # 如果代码没在目标代码中就移除 |
|---|
| | | if target_codes and code not in target_codes: |
|---|
| | | self.release_distribute_callback(code) |
|---|
| | | need_release_codes.add(code) |
|---|
| | | for c in need_release_codes: |
|---|
| | | self.release_distribute_callback(c) |
|---|
| | | logger_local_huaxin_l2_error.info(f"已经分配的代码：{self.distibuted_code_callback_dict.keys()}") |
|---|
| | | logger_local_huaxin_l2_error.info(f"已经分配的callbackid：{distibuted_callbacks_ids}") |
|---|
| | | # 删除已经没在目标代码中的分配 |
|---|
