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