Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
S
snf-ganeti
Manage
Activity
Members
Labels
Plan
Issues
0
Issue boards
Milestones
Wiki
Code
Merge requests
0
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Model registry
Operate
Environments
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
itminedu
snf-ganeti
Commits
9f774ee8
Commit
9f774ee8
authored
16 years ago
by
Michael Hanselmann
Browse files
Options
Downloads
Patches
Plain Diff
jqueue: Use new job queue RPC functions
Reviewed-by: iustinp
parent
ca52cdeb
No related branches found
Branches containing commit
No related tags found
Tags containing commit
No related merge requests found
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
lib/jqueue.py
+11
-3
11 additions, 3 deletions
lib/jqueue.py
with
11 additions
and
3 deletions
lib/jqueue.py
+
11
−
3
View file @
9f774ee8
...
...
@@ -330,7 +330,8 @@ class JobQueue(object):
def
AddNode
(
self
,
node_name
):
assert
node_name
!=
self
.
_my_hostname
# TODO: Clean queue directory on added node
# Clean queue directory on added node
rpc
.
call_jobqueue_purge
(
node_name
)
# Upload the whole queue excluding archived jobs
files
=
[
self
.
_GetJobPath
(
job_id
)
for
job_id
in
self
.
_GetJobIDsUnlocked
()]
...
...
@@ -339,7 +340,14 @@ class JobQueue(object):
files
.
append
(
constants
.
JOB_QUEUE_SERIAL_FILE
)
for
file_name
in
files
:
result
=
rpc
.
call_upload_file
([
node_name
],
file_name
)
# Read file content
fd
=
open
(
file_name
,
"
r
"
)
try
:
content
=
fd
.
read
()
finally
:
fd
.
close
()
result
=
rpc
.
call_jobqueue_update
([
node_name
],
file_name
,
content
)
if
not
result
[
node_name
]:
logging
.
error
(
"
Failed to upload %s to %s
"
,
file_name
,
node_name
)
...
...
@@ -361,7 +369,7 @@ class JobQueue(object):
utils
.
WriteFile
(
file_name
,
data
=
data
)
failed_nodes
=
0
result
=
rpc
.
call_
upload_fil
e
(
self
.
_nodes
,
file_name
)
result
=
rpc
.
call_
jobqueue_updat
e
(
self
.
_nodes
,
file_name
,
data
)
for
node
in
self
.
_nodes
:
if
not
result
[
node
]:
failed_nodes
+=
1
...
...
This diff is collapsed.
Click to expand it.
Preview
0%
Loading
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment