Revision ce862cd5
b/daemons/ganeti-masterd | ||
---|---|---|
66 | 66 |
QUEUE_PROCESSOR_SIZE = 1 |
67 | 67 |
|
68 | 68 |
def __init__(self, address, rqhandler): |
69 |
"""IOServer constructor |
|
70 |
|
|
71 |
Args: |
|
72 |
address: the address to bind this IOServer to |
|
73 |
rqhandler: RequestHandler type object |
|
74 |
|
|
75 |
""" |
|
69 | 76 |
SocketServer.UnixStreamServer.__init__(self, address, rqhandler) |
70 | 77 |
self.do_quit = False |
71 | 78 |
self.queue = jqueue.QueueManager() |
... | ... | |
234 | 241 |
This functions processes a single job in the context of given |
235 | 242 |
processor instance. |
236 | 243 |
|
244 |
Args: |
|
245 |
proc: Ganeti Processor to run the job on |
|
246 |
job: The job to run (unserialized format) |
|
247 |
|
|
237 | 248 |
""" |
238 | 249 |
job.SetStatus(opcodes.Job.STATUS_RUNNING) |
239 | 250 |
fail = False |
... | ... | |
257 | 268 |
|
258 | 269 |
This is the actual processor of a single thread of Job execution. |
259 | 270 |
|
271 |
Args: |
|
272 |
worker_id: the unique id for this worker |
|
273 |
incoming_queue: a queue to get jobs from |
|
274 |
|
|
260 | 275 |
""" |
261 | 276 |
while True: |
262 | 277 |
print "worker %s sleeping" % worker_id |
Also available in: Unified diff