Fair queue processing

This commit is contained in:
Serghey Rodin 2011-12-23 11:54:23 +02:00
commit 479d47e2fd

View file

@ -18,7 +18,7 @@ source $V_FUNC/shared.func
# Defining pipe functions # Defining pipe functions
restart_pipe() { restart_pipe() {
for service in $(cat $V_QUEUE/restart.pipe |sort |uniq); do for service in $(cat $V_QUEUE/restart.pipe |awk '!x[$0]++'); do
$V_BIN/v_restart_$service $V_BIN/v_restart_$service
done done
echo > $V_QUEUE/restart.pipe echo > $V_QUEUE/restart.pipe
@ -37,7 +37,7 @@ traff_pipe() {
} }
backup_pipe() { backup_pipe() {
for user in $(cat $V_QUEUE/backup.pipe |sort |uniq ); do for user in $(cat $V_QUEUE/backup.pipe |awk '!x[$0]++' ); do
sed -i "/^$user$/d" $V_QUEUE/backup.pipe sed -i "/^$user$/d" $V_QUEUE/backup.pipe
bash $V_BIN/v_backup_user $user bash $V_BIN/v_backup_user $user
# Send notification to user # Send notification to user