decrease count process, add check in show_request

master3.3
Спиридонов Денис 12 years ago
parent 970037f625
commit 8d14209930

@ -17,8 +17,7 @@
import os, glob
import signal
import time, datetime
import pickle, threading
import multiprocessing
import pickle
import soaplib
# clear server files after restart

@ -295,8 +295,8 @@ class ApiWsdl () :
self.add_sid_pid(sid, pid)
# Manager for sending glob_process_dict between watcher and process
manager = multiprocessing.Manager()
self.glob_process_dict[pid] = manager.dict()
#manager = multiprocessing.Manager()
self.glob_process_dict[pid] = self.manager.dict()
self.glob_process_dict[pid]['sid'] = sid
self.glob_process_dict[pid]['status'] = 0
self.glob_process_dict[pid]['time'] = ""
@ -305,9 +305,9 @@ class ApiWsdl () :
self.glob_process_dict[pid]['flag'] = 0
self.glob_process_dict[pid]['counter'] = 0
self.glob_frame_list[pid] = manager.list()
self.glob_progress_dict[pid] = manager.dict()
self.glob_table_dict[pid] = manager.dict()
self.glob_frame_list[pid] = self.manager.list()
self.glob_progress_dict[pid] = self.manager.dict()
self.glob_table_dict[pid] = self.manager.dict()
# create object Common and send parameters
com = target(self.glob_process_dict[pid], \
@ -318,7 +318,7 @@ class ApiWsdl () :
if hasattr (com.__class__.__bases__[1], '__init__'):
com.__class__.__bases__[1].__init__(com)
# start helper
p = multiprocessing.process.Process(target = self.target_helper,\
p = multiprocessing.Process(target = self.target_helper,\
args = (com, getattr(com,method)) +(method_name, )+ args_proc)
self.process_pid[pid] = p

@ -77,14 +77,16 @@ class ApiWsdl:
page_offset = 0
list_req_id = dv.Get('cl_all_req_id')
if not len(list_req_id):
self.printSUCCESS('No requests')
return True
for i in range(len(list_req_id)):
list_req_id[i] = int(list_req_id[i])
list_req_id.sort()
max_id = list_req_id[len(list_req_id)-1]
if not len(list_req_id):
self.printSUCCESS('No requests')
return True
self.startTask('Current offset = %d' %page_offset)
if not page_count:
page_count = len(list_req_id)

Loading…
Cancel
Save