From 4ed7bc7f9095934cfc8ec1881bc24649d00e77d8 Mon Sep 17 00:00:00 2001
From: arcan1s <esalexeev@gmail.com>
Date: Sat, 21 Dec 2013 12:09:18 +0400
Subject: [PATCH] Release 1.0.0

---
 PKGBUILD            |  26 ++++++++++++++++++++++++++
 README.md           |  44 +++++++++++++++++++++++++++++++++++++++++++-
 queued-1.0.0.tar.xz | Bin 0 -> 2216 bytes
 sources/queued      |   7 ++++---
 4 files changed, 73 insertions(+), 4 deletions(-)
 create mode 100644 PKGBUILD
 create mode 100644 queued-1.0.0.tar.xz

diff --git a/PKGBUILD b/PKGBUILD
new file mode 100644
index 0000000..33b997b
--- /dev/null
+++ b/PKGBUILD
@@ -0,0 +1,26 @@
+# Author: Evgeniy "arcanis" Alexeev <esalexeev@gmail.com>
+# Maintainer: Evgeniy "arcanis" Alexeev <esalexeev@gmail.com>
+
+pkgname=queued
+pkgver=1.0.0
+pkgrel=1
+pkgdesc="Daemon for starting jobs to queue of calculations"
+arch=('any')
+url="https://github.com/arcan1s/queued"
+license=("GPL")
+makedeps=('git')
+source=(https://github.com/arcan1s/queued/releases/download/V.${pkgver}/${pkgname}-${pkgver}.tar.xz)
+md5sums=('d93c8cf20804b07b47645b0c43d45d3d')
+backup=('etc/queued.conf')
+
+package()
+{
+  # daemon
+  install -D -m755 "${srcdir}/${pkgname}/usr/bin/queued" "${pkgdir}/usr/bin/queued"
+  
+  # service
+  install -D -m644 "${srcdir}/${pkgname}/usr/lib/systemd/system/queued.service" \
+                   "${pkgdir}/usr/lib/systemd/system/queued.service"
+  install -D -m644 "${srcdir}/${pkgname}/etc/queued.conf" \
+                   "${pkgdir}/etc/queued.conf"
+}
diff --git a/README.md b/README.md
index 0a0001d..667aff5 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,46 @@
 queued
 ======
 
-Daemon for starting jobs to queue of calculations
+Information
+-----------
+Daemon for starting jobs to queue of calculations. To start deamon just run `systemctl start queued` as root.
+
+help message
+------------
+    queued [ -jd | --jobdir /var/lib/queued/job ] [ --priority 0 ] [ -q | --queuefile /var/lib/queued/queue ] [ -u | --user root ] [ -wd | --workdir /var/lib/queued/work ] [-v | --version ] [ -h | --help ]
+
+    Parametrs:
+      -jd  --jobdir    PATH     - path to job directory. Default is '/var/lib/queued/job'
+           --priority  NUM      - defalut priority. Default is '0'
+      -q   --queuefile PATH     - path to queue file. Default is '/var/lib/queued/queue'
+      -u   --user      USERNAME - start jobs by user. Default is 'root'
+      -wd  --workdir   PATH     - path to work directory. Default is '/var/lib/queued/work'
+      -v   --version            - show version and exit
+      -h   --help               - show this help and exit
+
+Configuration
+-------------
+All settings are stored in `/etc/queued.conf`. After edit them you must restart daemon (`systemctl restart queued`).
+
+How-to run jobs
+---------------
+* create shell script with the command (it have a name `script.sh` for example)
+* create priority file (`script.sh.pr`) with the job priority if it is needed
+* create user file (`script.sh.user`) with the job username if it is needed
+* copy files to `$WORKDIR`
+
+
+Instruction
+===========
+
+Dependencies
+------------
+* bash (sed, awk, etc)
+* systemd
+
+Installation
+------------
+* download sources
+* copy source to `/`:
+
+        sudo cp ../queued/* /
diff --git a/queued-1.0.0.tar.xz b/queued-1.0.0.tar.xz
new file mode 100644
index 0000000000000000000000000000000000000000..3256961e1aad02be57243a386cde5b53e26b4cea
GIT binary patch
literal 2216
zcmV;Z2v_(0H+ooF000E$*0e?f03iVu0001VFXf})Gye!>T>v<pNZ0iWMme_qd!Wk|
z9RgIgD2OCMPGlG;Xc5e1p$?1;v=D{0pmK@5xLv;F`moSJECCVP?-w~JkwBL09pAKE
zTlB{=EAYEn%b7VpXC!5AggQuWqCmT<M7leV{#`ELB=6lH1Wf^|``<SXa8VW&G?GfA
z%6$tMA3CmpR;Af%x$8>m&rwJ>hrzoU!3PVY{00wTIJy}d=Lq+b@C8jCiX$IL(^vIQ
zCW`~F%1K}`0HqBzU}j#AZqi)>VB{{$@pHR>sdD~O@oqZxb^zCYHQhu>@=hM;(r*Jq
z`P){7v^^Wy3BA~pts?o$QD_TdLj4L^+n*(1lJiy;dveK!#lKDjhxsW(2B>gUNAB4Q
zsRPWdTXl>s_(!6*6XA?K6aV&eMX3V8gv%29;6<n<3|nf}HZ@{i9q2Hr(S5+eID}lc
z%)5DtbB;&S-~S23pW(SdRpRj_mGj(+%yUzjSMs}%nlw<*&(#YS8hop^Hp+p*3515q
zpFYhGZ6ZQO2VRHR-9w9MuJ)d;E57<y^_i47ay}2uBL8bM@fK*yw)Ct?Pl19&N883_
zZI3t_oYzF2;YQp)CzG7+D$=r0p?~reB@AEt76c~AA8~%zt5Fu18L8bzP8p=xGEWNu
ztiOkKcKo4+H;qyJAJ%=37a`YS^G{b!wm<iX*tcTHU3JdAk`LIGw)q4&XQbuMjfrd8
zf)|XL1;K+V4p}-tG>?`yMI$G6Wc7rxLksH+BOR*-JB3(ouK)d>r5ZXkESJu~r(5va
zyW^`aJT~RGuMN?&pTCbRS=o}?vTQc5lzpJZdjt*7cf#k(Fi-WZPB#K26P-b`rzQEz
zwhJ1GO7Lul4qcJ$giLq*=k4Wf6rR<eCN0)0UeTsdI6w9<31@vN)r^uF(dsGts$Srs
z&*0+DPvo9Gey3D)=&$|)T_SVWaAj++MNsebFQooSzw4npkv=FRy8}tE%uZGS)YS^~
zth16dI$mo^{1ctv!fqdu1qiy=c$K_1ok~Ho*A{)DJ6x$=k7Hp7ZH*hP92G4;f>=oX
zP>vcn1*VpGrg{?f$BW=6eY0S1@>&Rs#!XDS2HTUIW}R&&PSYen@IT7DRXj-gZgb~_
zMx9q@W2y&C8ZfrfmHcv&qLvd05VuTV_zr%V=-a$LHZX0O4mKUQ@$n>_od~W`YRsZF
zelU)FBSX;rIlpc{Nv`4Lq{er}8zQK~le<`#%ChQ5!;lj=Kg2hWtKkDA)Hki*C;XMb
zJ0!|WgEVzx@^!Qik-@}`E0I7Ud6w|KG2)j;EGbnC3!5YDr4usq7T<x_;4UXKS-wFk
z)XnA~{55yMV2R1t?lW@^myn&X7K%_Y_3TFmV;{-7TSxCE1lhw-Q7Fbd#ah_XwYmM4
z+lUJY_=kV@c?*6-rs*HEPj<B(EPP?tB{4=g63K1P_4Z#EW~?^0U{xOzun~tAxfdh5
zp{N1bu5{e4J5q?@FY8K!e`mA1ccLrjaRh}-1INTO!Qz()T?;M2(a@8TtcPL_E;i0i
zsjKuJ7-l+7%?XkZaR6AN+0<+g){R93u!xjTIOFiD1WV&PgYaSc>upa+1nF(O@(<WJ
zs#(8BVG(61tM~W)fYXhTW-=sA;*GD|V<b%{vZj_7uc$aW6!2<(4vcj8ljR7%Cmu!~
zcj?y`*~}IWL^`htM+1eo+4+pLn6TQ7QwqXY&5Wnmpa+Xs?NIVGw_#OLOhyB;Ib4sb
zQo|^=CxgXb*LUX5_>H0@FEZ+QW}ZS=2(+}C-2h25`Vg=D8)8FgNhJ%+S+!65uJNe}
zyZ_$?2^9$9F&g7ex!T?o?)n@<J?}ojH)!I&k>}sA6{Jp~6{q%jowv|riXq(7=W}S_
z<rppxFCc;%PBne!Q%;m#8&ONgO+M8Un+d{Ny_FP~Fw2k*=AE1<IBo&&SJwnNv7gwM
zv7#dX&X%|=PL2ar{o>uk4DqsIb@J%zRjLP9%N@2_k3nUaNSKY>NqsIq6tF*P@0kkP
z=PIwq)r<RD(Wcr`p#0)BD^$2#xVDsP<`k8igSLzIV^?N^Lx3^ijocd{)e!#%4wjo^
zuNC+YMxMTVP?7>TUs{Nm)hz{O(sgC-dgSIYoBkN5V$iRJ5qTbetDnElkEJAh)4jF!
zs6Ho9Xpq0o2Nkp(sZ(<C&&W2O)mKovnwmKRD9R1TWa&Bi7k)L6@eqHpE)@kEfZg2K
zx%FHZhlTqi=BN^#Y%t_Il?qc7HK<GXZP6fGc8LZ287Vh)f|0>+>Fi&K+YVA_78O#K
zPPm4i;zmfyGi-T<o2D+OJ%7wG=~bNSr%9iu5Bs;Bd_ior4Z5sMkLMMTx|A1e`suhk
z+i-UwK1|gBv7<!#0=58Oux{^&KexY*M3vE<356kazNl|6naRm9@7rZwDKW9c<N<K~
z$2ZHAs6+^Q<DXXP@^}$o3yzq!>R^FidoH2pB!!he4s5mTkiP6nRTVz)3R>OK;tRA(
zej)$G0S)e0VvBBE=glA5wbV&xH<_I;Xv=0&V*e#Xt}n~V8^tQ@`f3QJVJ<8cw(JvP
z02Wj{w7DV<U#v|9MtF3)3Z?wAqP}MD5aRYf%_nkv$nT3_JYITW0(tq6Pai_(z_L@2
zK0895H?7$F&P^q|UA2xcYhu)ngjC|EKMmqbJ7p|Tkx`6;wAB|He>>kM6^EsJ7;%~B
zPm9K7xRMGFSt;%(QC^`32AReN(G}%UItF;pX{0{iwCruom7duidi_CDQnsKFcT5;k
zEmp@}Cv4N<dt#xz2%2mGEb?js-3opHy7GZQon25GSK~nmuOX=(*a%elsptd{orNcq
q0^AM&0002{%3I-oVf}mn0f7;KXaE2)fu!KE#Ao{g000001X)@e;VuXO

literal 0
HcmV?d00001

diff --git a/sources/queued b/sources/queued
index f32387d..fe06ac5 100755
--- a/sources/queued
+++ b/sources/queued
@@ -120,6 +120,7 @@ cd /
       [ -d "$WORKDIR/$FILE" ] && continue
       FILE_EXT="${FILE##*.}"
       [ "$FILE_EXT" = "pr" ] && continue
+      [ "$FILE_EXT" = "user" ] && continue
       [ -e "$QUEUEFILE" ] && grep --quiet "$WORKDIR/$FILE" "$QUEUEFILE" && continue
       echo "[II] Adding file '$FILE' to list"
       if [ -e "$WORKDIR/$FILE".pr ]; then
@@ -168,10 +169,10 @@ cd /
       CURJOB=$(tail -1 "$QUEUEFILE" | awk -F "==" '{print $2}')
       [ -z "$CURJOB" ] && break
       sed -i '$d' "$QUEUEFILE"
-      [ -e "$CURJOB".pr ] && mv "$CURJOB".pr "$JOBDIR/$(basename "$CURJOB")".pr
-      mv "$CURJOB" "$JOBDIR/$(basename "$CURJOB")" 2> /dev/null || break
+      [ -e "$CURJOB".user ] && CUR_USER="$(cat "$CURJOB".user)" || CUR_USER="$STARTASUSER"
+      mv "$CURJOB"* "$JOBDIR/" 2> /dev/null || break
       echo "[II] Running job '$CURJOB'"
-      su -c "/bin/sh "$JOBDIR/$(basename "$CURJOB")"" $STARTASUSER &> "$JOBDIR/$(basename "$CURJOB")".log &
+      su -c "/bin/sh "$JOBDIR/$(basename "$CURJOB")" &> "$JOBDIR/$(basename "$CURJOB")".log" $CUR_USER &
     )
     else
       echo "[II] You have a running job"