From 0dd463ba384d780b39aaed01095999fd20e2fde2 Mon Sep 17 00:00:00 2001 From: gumartinm Date: Fri, 27 Jan 2012 00:54:04 +0100 Subject: [PATCH] Sorry, committing forgotten changes... Just deleting files, there is nothing important about this commit. --- JavaFork/Daemon/javafork | Bin 22839 -> 0 bytes .../src/main/java/de/fork/java/ForkDaemon.java | 166 ------------- .../src/main/java/de/fork/java/ForkParser.java | 141 ----------- .../main/java/de/fork/java/LauncherProcesses.java | 275 --------------------- .../src/main/java/de/fork/java/MainJavaFork.java | 35 --- 5 files changed, 617 deletions(-) delete mode 100755 JavaFork/Daemon/javafork delete mode 100644 JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkDaemon.java delete mode 100644 JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkParser.java delete mode 100644 JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/LauncherProcesses.java delete mode 100644 JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/MainJavaFork.java diff --git a/JavaFork/Daemon/javafork b/JavaFork/Daemon/javafork deleted file mode 100755 index 7277198a27261ffd239c9af74f50b817dffd38d2..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 22839 zcmcJ13zSsFxo&kg1I=ruVR#LoG%!39W(Gt=gV+d-jSe^gyuoKr&veg2d%7pn-3TfH z9Y$>@m?6j9F#v zehE;Iz8=@<$LH5e+|WDe5JIn}Mvv}MPb}aGVL`nlh91<88EVSMvhkRy%Qw><07pJR zBG$?C5Tz_b-HCLR@s@d#1r5lEp|uJYh8n#uLr?mt)Bh`C{H%_*Hmq1)9gi-Fw zmh4!$V#$i-RjFjvGU>k$hFHW)HeDf2n);Xsj(JbQ!75|=GmrePE`QI(_skph`u(dP z>;2U~Y&r5ci*XK)={T0+(AAHa3R5*52YNOR$}ht)3&&YFnEw(Si*Qup7>lC{M>UQb z9J6tJ5eI|0Rv0hEF^v%f*2@=gun8CAU?^9laMsNz%VNM$CZg$R3vVu4LSrmAqvLT* z#xVuQ1RN%?uB@R1jA;kIC1H*wJ{R!{%`en+1}N*k3ek_<9FBe{{ez4t73vkZ*9nw>a4O2M76f z2l;Cq@KFxJj8y1g}85KYD6O@jG|NMmEHT^UQZ#}WmJXe=FR zY$>p@9mt4T(-Jfrw~N$HxYZ`XOaeF98$>wV+?Gs)Q|U-YIvi$c8d;7NB9&~sAqM@H zwq}r)bTWZ*w0E>7(oLehwH-dUv_(*mSVu>)L!?@p6OlNv#&jH3kWGSIG%cXcVzee= z>2N#D(201mS)|e(aR{*lWE)yh=4hsUnP^YOmgerwmMIl<5pA-CamOxUgR0 zoGV!G^T#yKxqvn$<&Il$>s(;Kf)}Qe(8yVE-n&gWX~8)kFyXWXr%#2js9r|tk9B_H zwcut>K|!AdA1gK0X_^J++{*;N1?N1*goPHIb1M^SEI8*QCakpJrp}obu;A9YQOJT@ z$D29}Zk@Ajv*6ZwRlNnDY@7jYvEZDSnb2;*&0LgeJ1n@FM-ty-!Ogsk_?;G8@Gn^K zX%^f(KQP&E!TH=_!a@tqd$$QS7QEVkperqSjRg-_a6S*25VGLQ3%7EITYphNd9^9Y=(ThW@*Ilte#w8EJcppXPx9X+&!HzTB!3rq4mtUgp8=S68+i^j z`2oq_M4m%T{+Q%D$a84P_e=hI@*Gm~2PNM?oW#lTXBW>Oll-5^vuo%3CI2pYcIo^<$-haST{+(? z`Pay^3+Haz0m=WEJiBDR zM)D7kXIISoCI4;m?1FipiW#0^SzJ0Q8 z>xLu!f!P5OI`U+lBu9Q(9uT<$Fz``N5BpZAyW~fc{UX%WpLP!(lU=LF8mSA_RKlgM~Q&Uyhti96zD?*(YhRcx=@=Z@XM2x<9pE!+t zo*Nu^?&+Q$`UIE!*hTJKXE!25>Ff-wanmH(ICoYyl>@e@G z&wT~)Z1B_0U7s>}J(Ht_3S5X1+;dp$>j&&ZtjUGYq4-^OFzC3|5Yl%*fvq)B-Z z2$bWW?Pf{}W-ddlJNRkn-ca@_w7}6&_T|HuO$~@XfxwD;9s;;B@97(`n|SK4gM;~7 zaKV|&G?d+y%VyrrUNN9*mX-R%U!bHKdt$+#!OSG&2-8WJkcs(!f^7E{Z+CATK*i*; zFEZo%kqS9wY|d68vPYDqZ7KmGRft(K6LU>wKScEvdVtEzZ8Cdr6#!X0Sa|%j%tT%W zU?0*feFuA=Vi9`=F`2vS7F$BMzP}Jcq3mytvmz5fO2zV8hHMu{GU zJ#iS%HPCnisgvPMHu!$$uJ^^)X0z|z`|REl%HkUTmex`IksXayawN9~F7%B-5iLFF zLSRqOcJ3Fjs0OiH-#?1mbM`l@{z6Y4sUg`H?4?uJL5O3~W9&FC%DTRe)V_`OEH9Eq>GeDrqt`QJj9E^QF=jamFHil{W9Xif`daL^PW>4*$=q{0Q9>!vW0!at63X%27$j*=4TUavM$7x9<+7~w^pIWm zThLYYd$Wwu)33@HJ#CgTdU`El#?xEj^>ChUfQ<6=B~z9nPZvN!dHQdd$QgT2eyr^s zxBK>2;A$BB013InP|gMiI(H2WV#NNlUG`rft1RCP%iY0&!v`^(_i;K2?_Yw)+2Grq zyWXa%yV7>4ezTw&kg9L1jtfnyPC`-8+BrCz>lVC5&+hZt4Scy^V6a4%DtCm+BG)3b zeW7#L3xj1{w*gVNysrXQbv_E3-9gs*-#=oEb$&|5Sm$}fOdX9!;fJg9e}jyw^Q%p( z6xI1JAfaj|0`K4puGtgt1^Jr6r4Ax6es+>s!Tti= z-yQ6qCotv8KK0}$xc_1l^1U~P^oX3AtAS?>?6I1=0191sNYGvfn z1l$Vk>#75HcnUJXZHnDyIvPjAWG|z)S=@@gN5Sqcj$(53R0HQKNI$yQVrle{rDIf8 z8PJmJ^DX^}$$C)uGva8Ov-*1MRrki9FrOOL^WKP__gp+F`;KwAfNUKa2sIVjw~z4QXC=&A^*hKW8+_%_pIOSq zNuI8u)6lb&YZ2M3V+~D*N8Q0!LXF2zhs@}VI;6cv`z(3!X-((#b$edFfoGqS*TaxT zsW*LIsjq?wbh$H2{o#kI)JH9z@HtL<;$q=QYN6{T@O>wcljTNz&q-WKXLSc(Q1=XE%~5YPEb(gTg+@<^ zL!a-_zYe*mYC_!(JL%Jqi{riUOpF>an-LoP4YHlpD3U&Q4J#*!Hr4@r?Oi$Gf5KYbr7D#w&fb-OuM`l$!q z+z3COOHU7`D<0#v2mPG-o)^!(-FSXQEqth-NY%4(Zcx?^-Zt^wH}5@I>z3;eezpGK zZ;2$L@mPmkMY+H)(v9s>2&cwKB9Tn{+am4$Ie_Q*(@DQvH)u@8{fSIl1GJPW%R+@* z0`bc=n$~2(-xO($$D(>=#LoqbB1o-!6oC=BT4O-9RCI>T>S%0xbvnIM$VeiC6_8XU z-imdgq+D(BV_nFfN=K8Kw6VlR7z4v|179E69^oPq7Jj(S6KQWrcEtQ#Wib-6N`_7H zqx$@E9jYMfETwg>^+(Vf)rM|VdyT^}Y9D!-8cp&cu?9#)eUjuk8d^!m_ zT>345%i-&{t?5^G^8Jmp|6S01NdMT2h_QdoQ2OJ58}Jy+dcse_f}t;Io|6HF z-m-wCe38X4ZBBqh?!zIicL#75;^WT-lcYyI0g}RAwS!*8n|8?Qbl!g%9@ZI~HM(gE zmivfwR1#Uqh#gv3FL_f(dvy8Dbumh&3Nckv|JZ_gK)btHaKhX3uO-m=}{57r8bhW0NG`&vKgr;B9^lnY>)AV6Y`!sz~ z(>FBzK-14OEuEw;?_vx{pFvL1@Iy zzhd+rL`#-w$GJDGggU%gN&BX{ z$0yt?Au;MK+AcdEkk9)wE-LswfSC6nZM)|R-ycA||BDIkxo%aAm%zwkj2G@7LveJ3 z4!bXAbRRd)m2tP@h|%9*OZ)DE{n0(IQDQEVxRKa5`c1Zn@B2)8%j9$)pwVyBICApw zhCcel3CWG{?I4#cmz)=s_cSyooPff#F_*Y*2c0+$r!gTH6OhluBM=?4!NqLcbG;Mm z$zJMWox11xM7e+L{2wA|(p$jCE;tQ%(k`6FE@W#9_r;7aqTMnV{H+=H#jk+)xY{{x ziEQAxVsZw%ea2PYNcp)VCO4C-zD;soUl%27RN6S-01S;=s?vPEIMY;<&Yk32%(Qc4 z1J9k}t7O`8#ZB`qW!kxlo9?TJ3*%PsnsU$e`>rQSg>ziVOMnGi|NB#^=`g zt|PZjaa(=d;5a_W>T%EA=1bG&dgWEU?`z~PQCtgJjn!Ya7$`nbS3}1&L)zPa&D2LEC$E70 zbDq}}`Du=gQiuI196v2*p5fHcN==xmI1%HDF?^X&iWZe?&e4SM$X?yh(m zxa(XBy7$*te3je^Uh(ezbrruRcb?(`6`aJlRw}>Z6|X|Zb^d<<^XxygyW(;tUZ67h z(O+!Vy z+Oz{O&X*~!J6umf#uz=JjlT`-O&FgZ>1c)wMLheD-mJ=Sr!ui^T0*$8Dt^thhD?)i z-9;VG{$n?*A%ZuG85~LRCUc5w8$J83EQ`s8YqAVA@MI+J2~$0E>ASRvx=u`8fJ?{q zT~;ybI-y$cdn)zu-4!9=uKQRIp8Y+$E0$9CfMWOTRu1*js%QVfWW}cxzJID@`x6zD zX!(H!Dm76to$U8jSpqEA4^(_z#Tcgi(|Hhd?+;bXpp^&zfHT{7BTMunCAqcYa&kXr zheJEe+&LovDIu<#spwe?b>vb__1%CT$vS#zl&UoPB*)c8QR2e&%&hh8XtbBZ)!D8V zmbBI7GSz49mbU=sjdvFA#uQMV#f5(sU7O0w-Zk2jUR;le5dOP~PNNXec8v7*`_s@grQG(y?Qi4bjqt$aCg+3>D=z+&8}9 z%S!a935C=WYE9IsB^%0_T0Ye^WO34vCI%faUR5LtPN{NTG)|Rq!MF|OEO=lf4Nfg7 zWaoz5wB-dgvK3%;#gLs2VQrM`3|STE12e~>QYWHu&KfIJ796afGE5* zQFIHvz1Sc~gbpTh5X5!P>0u-q?NDlJqpym$CO}b*$TZrZh0Ti_Ez#bnB6v-sB7BX3 z7;?px=Qj5W&ve&2-t7l&eD%PMEf0C8T)EUU`fYFLRqwo-@m_epx4hY1S?*o!{fGqo zV>r1NBI+4;pJ#_Z<2~iQu-82gBG-85y5~$f@BoB6d);%&4{Sei;zaM2HQsX$Jnuc# z{G9iq1K!mSczoX5yih-IpjVLt2kv(-k-&iir@X6Q^{&3(`yA5?>?v=+JG+^9GtRx< z%tNr#>zz#zt@6MDZ#DdoCm8Y0_BOlcOzwSPKZ5rmcU3u0lTLXmz1uwXY40gG?R`il zz)_WU2I4*8z3?3G!=5pI$QToaEH8S@8@Td;hjQLp??ulaaJzBUp`OFhbSt(tv!NRK zPB4vK&Nsw%3LM)b@eDUTr($1~`=)WVVtHl29-l%WhBsl&2|QmwBo$_oRB5CNb+P>$uNhkt;igDiYkVg$ z*o~%?745Bg&x*a?d?hH_8ue~h1?vl-G zHp;9Mk#rin-8*92Q6t!!4lU^)3X0c%czvpULMbx|z8{X^-DXRqL)qE9Zlk~*w^6i* zrF&;QR?(i^cRu82!3-U?bjb|(bCxk5M3$~V1eUSc-ufih&YFzKKLeoJ@H&nS8VN@u z=?I&TPk*Z6Y?;U+ZwY?6Zq3@uf?MIMtT~Bl$nxZeHjPA=vS}mHWvY~GYcCIO3$6u* z283U&QM^&ibR_Us1nXlZ9FVWN!yGVl{jB+ltmRa!Idv2C=`ajX4%b*yq_H*Lir3Yw zrFL9zqPiv77OQT~;Ex2`lhw_w>6T1G^`&?hy*}BoK9exf8>-jIr(JlWA8{Kwk(W)t z3%k&2%p46&pW7StWoAYqd8Mb&@~SA2bS5PllWlEydo6v&i%#8Lm6n9Mkp(WEUX$lT~P@x?=!&&199o#FfvRjHkA=|}@;xu48M zSaph3t+{x^l60h5bC@MmHDs`qu>_ZX6}gs3szp>qcP3y@(R7DO(Q6YnCXBR>SUf@n z9cz!LMV0(#QB^v&1Mwy>NK48ArYhDFZtB3_W5O*MzzdwHYD_0PQpiw|>l={>n;6O) zkzo>MaH^8Fm7NAGc~r5hv9DG|V-1<+aHJ!WXvPADX4^9j9Ha_-YoaM>(jpBF7_JS6 z#gCYYqt;9`o@`XD_y2U3j}Ne*uUbR`;1D!0Q*ni}>3#;7iwNfTM!fJpY4iVSzY)|_ zUxfvfFTt$(tK0#Zwo2z;DY>Cju|A);FcB-{U+)fp<9mHc)J}Rt@ys9t9t>nKcGiKz z9-*Wu|4~msrXST^&y>GdUkc&02?rh}3i;=>eopHj)fusjtUHtcG{hO?n?6vJzgcfM zs0GdXf)vK7xc>RlgYWi@zImU29p~lnm=kjg0?N z2&bEHu!u&#us*>`K``Yku0MnCg^X3-tatde{vKU_)aR&U@;CZ-17n>S`)0kTw+tYH zkyD(?%fv~uIIQ}I$^wMNA+7Jz?I=Ni#6qnfDDvObpA^FBK^#_n^SuJ|9Rt2|vWDXP z`O?v=6?r$UVFxW^L+{P-HC&`{Otb>M&Fd{bzs)~&Hot>E|lU0 zdBqLs8$17Aq;J+24{3caV_1XHGxXge{W|^9rEam(GJYBxM$hmk5g}&EU$6D+wSIB` zE7t!Qx^%Gyhcy`e^Q|D_rZ|RvX2GnY|3l|rY}e=++3^61F{VAI_3to(nik8R<)B~p z1*O16Eo&&&=ZZuzM)~)bDXs4nB^I&bJO};ka;1N#85k6MMqX>ResMibI8Q0OVj8wc z-}te~A^#H>D21a&ut;CC@;e(vS;(Y^Rw;=q{|kL47Zp(|-g$}AKcw#?9FA7tFxQ{C zE=L0!F8{z5rT>=_Ma{X$9Rm+bJ*;ha;EXi>V|wPWxJRrS79UaAr(iYa!OX|ZSM2ym zVdf!re3UTr3p?%=X5L`OM+-9_u;XKdxzF42vBKQH?fAIDJ`6iP9{1UR6_Rlez5-+J zqt-+ZzMNw2k9ORL`(3~a$+!nsm${!=6FvAcg1JxG@p9aE>aCEBd$7C3+*hoL9_;ck z_X|5dW$1fDmIM!Wb(rzp0^|CdR@fI}$18*xkL~z$Va8cI&e{B#!6SF~42Sb?if0Co z{G!ir_^dNQARgg&z-K$)dU9e(WxsNx-9Mceu%PNYJR`)1gEkP%OdKwJ4XC)iIBdIy zX|I(MKeN4pz?rYVJb>6xxEfIxzJ6rtnf@_ckArxNzR#KQWCw8C=_#@^0r+tK@0E7S z#X!;ZwqN2C#j*JT#D>BFL|wyNZ$AOfd4Y_&++}KXJghCwVx3xKQnvp4(3Y4){k7c1EG#!`bKa^>BEV1HMk;XO5qj zI>=w+fODySxP13H;P*S=k2v5*flt7!-Hhkvd4r476VUI>qM*UwaIkaI0Uv>zy>FQ7 za{}<;%C*D+-{62>>wt3u!bJ2_v#ibMK89O0Zr1u2z;A}HJJ`7&IP1YInVNd|se?Q> z6%ALeV-EPc4)~`I_!KxW!CfJ?>G4o`k9|WDpCtIFYipk~|ILP1bfPcpU{~2%}?mK4uH!eNqApf!h{+0v&SBaMjvtWLW&R}%O z@a;9v0Y4u&{oGMh|EnG3>m2X~2YkB&ei!iJ>Sw=${0|-QUrW4Hn7t$?bv-<(akEak zN8`^r*m=VN|4`z?%s(3=@wnxiPNK0Rol0l$kB~+zMy%a>`Q~u#hAmt1si$ywosGM6 zttBa%3^&J<4Ust39`TAe9Len95=(nLmX1ZMR-ChZsbE65HM)b`IYPZ&j%M20cA9*G zo7Tx})?>vk7&aWUG4Y{X!U_beUxea+3G9gef>dKF6P7R0 z)pw?fWK=eVzlzvX<>q`lq`rA&$K(gC><|{cqG>x+^ntG7J})Le&SlrqU)8dM{2-Ve zVVzLaj;eC=Q)5MV@wc_?$^62Y9Z|bh?U?!;m>rWJ__9Oc4VRPu^OLHoDE>}l%1Ja&xLHC*Fb7kaJB*Xna=b{m!jTYkpO zp2)v~6d~#lLs*cHHx;E|-$fCkWzTG9)JQ6+cMO}3Z#tp;UK+1 z>*BHc>yO=;kZQL7 E12bH^XaE2J diff --git a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkDaemon.java b/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkDaemon.java deleted file mode 100644 index 074318f..0000000 --- a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkDaemon.java +++ /dev/null @@ -1,166 +0,0 @@ -package de.fork.java; - -import java.io.IOException; -import java.io.PrintWriter; -import java.net.InetAddress; -import java.net.Socket; -import java.net.UnknownHostException; -import javax.xml.parsers.FactoryConfigurationError; -import javax.xml.parsers.ParserConfigurationException; -import javax.xml.parsers.SAXParser; -import javax.xml.parsers.SAXParserFactory; -import org.xml.sax.SAXException; - -/** - *

- * With this class we can run processes using the intended daemon which is - * waiting for TCP connections in a specified port. - *

- *

- * Receiving the results in a XML format from the daemon where we can find three - * kinds of different fields: error, out and ret. Every field is related to the - * stderr, stdout and return code respectively.
- *

- *

- * 

- * Example, stream received from daemon:
- * {@code
- * 
- * }
- *
- *

- *

- * This class has to process the above stream and it offers two methods wich can be used - * to retrieve the stderr and stdout in a right way without having to know about the XML stream - * received from the daemon. The user does not have to know about how the daemon sends the data, - * he or she will work directly with the strings related to each stream. Those methods - * are {@link ForkDaemon#getStdout()} and {@link ForkDaemon#getStderr()} The return code from the command - * executed by the daemon can be retrieved as a return parameter from the method - * {@link ForkDaemon#exec(String, String, int)} - *

- *

- * Instances of this class are mutable. To use them concurrently, clients must surround each - * method invocation (or invocation sequence) with external synchronization of the clients choosing. - *

- */ -public class ForkDaemon { - private final ForkParser handler; - - - /** - * Simple constructor. - * Nothing special here. - * - */ - public ForkDaemon () { - handler = new ForkParser(); - } - - - /** - * This method sends commands to the daemon. - *
- * It uses a TCP connection in order to send commands to the daemon and receive - * the results related to that command. - *
- * The mehtod retrieves the stdout, stderr and the return code of that command. - * - *

The host name can either be a machine name, such as - * "java.sun.com", or a textual representation of its - * IP address. If a literal IP address is supplied, only the - * validity of the address format is checked. - *

- *

For host specified in literal IPv6 address, - * either the form defined in RFC 2732 or the literal IPv6 address - * format defined in RFC 2373 is accepted. IPv6 scoped addresses are also - * supported. See here for a description of IPv6 - * scoped addresses. - *

- * @param command the command to be executed by the daemon. - * @param host the specified host. - * @param port the TCP port where the daemon accepts connections. - * - * @return the executed command's return code. - * - * @throws UnknownHostException if no IP address for the - * host could be found, or if a scope_id was specified - * @throws SecurityException if a security manager exists - * and its checkConnect method doesn't allow the operation - * @throws IOException if an I/O error occurs when creating the socket. - * @throws SAXException - * @throws FactoryConfigurationError if the implementation is not available or cannot be instantiated. - * @throws SAXException If any SAX errors occur during processing. - * @throws ParserConfigurationException - */ - public int exec(final String command, String host, int port) - throws UnknownHostException, IOException, SAXException, ParserConfigurationException { - final SAXParserFactory spf = SAXParserFactory.newInstance(); - final SAXParser saxParser = spf.newSAXParser(); - PrintWriter out = null; - - final Socket socket = new Socket(InetAddress.getByName(host), port); - try { - out = new PrintWriter(socket.getOutputStream(), true); - out.println(command); - saxParser.parse(socket.getInputStream(), handler); - } - finally { - if (out != null) { - out.close(); - } - socket.close(); - } - - //Just for testing the parser by using a file instead of a TCP connection. - //InputSource input = new InputSource(new FileReader("/tmp/xmlfromdaemon.xml")); - //saxParser.parse(input, handler); - - return new Integer(handler.getReturnValue()).intValue(); - } - - - /** - * Retrieve the standard output. - * - * @see {@link ForkDaemon#getStderr()} - * @return stdout - */ - public String getStdout() { - return handler.getStdout(); - } - - - /** - *

- * Retrieve the standard error. - *

- *

- * 

-	 * Example, stream received from daemon:
-	 * {@code
-	 * 
-	 * }
-	 *
- *

- *

- * 

-	 * From that example with this method we are going to obtain this return parameter:
-	 * {@code
-	 * ls: no se puede acceder a bbb: No existe el fichero o el directorio
-	 * ls: no se puede acceder a aaa: No existe el fichero o el directorio
-	 * ls: no se puede acceder a dddd: No existe el fichero o el directorio
-	 * }
-	 *
- *

- * @return stderr - */ - public String getStderr() { - return handler.getStderr(); - } -} \ No newline at end of file diff --git a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkParser.java b/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkParser.java deleted file mode 100644 index c20ba15..0000000 --- a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/ForkParser.java +++ /dev/null @@ -1,141 +0,0 @@ -package de.fork.java; - -import org.apache.log4j.Logger; -import org.xml.sax.Attributes; -import org.xml.sax.SAXException; -import org.xml.sax.SAXParseException; -import org.xml.sax.ext.DefaultHandler2; - -/** - *

- * Class intended to parse the XML stream received from the daemon which is - * waiting to run commands. These commands are sent by the method - * {@link es.dia.pos.n2a.util.os.unix.ForkDaemon#exec(String, String, int)} - *

- *

- * After processing one command the daemon sends a XML stream with the stderr, - * stdout and return status of that command. With this class we extract those values - * and we can retrieve them using the methods {@link #getStderr() }, {@link #getStdout()} - * and {@link #getReturnValue()} - *

- *

- * 

- * Example, stream received from daemon:
- * {@code
- * 
- * }
- *
- *

- */ -public class ForkParser extends DefaultHandler2{ - private static final Logger logger = Logger.getLogger(ForkParser.class); - private StringBuffer accumulator = new StringBuffer(); - private String stderr = new String(); - private String stdout = new String(); - private String returnCode = new String(); - - - @Override - public void endElement (String uri, String localName, String qName) { - if (qName.equals("error")) { - // After , we've got the stderror - stderr = stderr + accumulator.toString(); - } else if (qName.equals("out")) { - // After , we've got the stdout - stdout = stdout + accumulator.toString(); - } else if (qName.equals("ret")) { - returnCode = returnCode + accumulator.toString(); - } - } - - - @Override - public void endDocument () throws SAXException - { - if (stderr.length() != 0) { - String lastStderr = stderr.replaceFirst("\\\n$", ""); - stderr = lastStderr; - } - else { - stderr = null; - } - if (stdout.length() != 0) { - String lastStdout = stdout.replaceFirst("\\\n$", ""); - stdout = lastStdout; - } - else { - stdout = null; - } - } - - /** - * Retrieve the standard error. - * - * 
-	 * From the above example with this method we are going to obtain this return parameter:
-	 * {@code
-	 * ls: no se puede acceder a bbb: No existe el fichero o el directorio
-	 * ls: no se puede acceder a aaa: No existe el fichero o el directorio
-	 * ls: no se puede acceder a dddd: No existe el fichero o el directorio
-	 * }
-	 *
- * - * @return stderr - */ - public String getStderr() { - return stderr; - - } - - - /** - * Retrieve the standard output. - * - * @see {@link ForkParser#getStderr()} - * @return stdout - */ - public String getStdout() { - return stdout; - } - - - /** - * Retrieve the return code from the executed command. - * - * @return return status, usually 0 means the command went OK. - */ - public String getReturnValue() { - return returnCode; - } - - - @Override - public void startElement (String uri, String localName, String qName, Attributes attributes) { - accumulator.setLength(0); - } - - - @Override - public void characters(char[] buffer, int start, int length) { - accumulator.append(buffer, start, length); - } - - @Override - public void warning(SAXParseException exception) { - logger.error("WARNING line:" + exception.getLineNumber(), exception); - } - - @Override - public void error(SAXParseException exception) { - logger.error("ERROR line:" + exception.getLineNumber(), exception); - } - - @Override - public void fatalError(SAXParseException exception) throws SAXException { - logger.error("FATAL ERROR line:" + exception.getLineNumber(), exception); - throw (exception); - } -} \ No newline at end of file diff --git a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/LauncherProcesses.java b/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/LauncherProcesses.java deleted file mode 100644 index 0f93fe2..0000000 --- a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/LauncherProcesses.java +++ /dev/null @@ -1,275 +0,0 @@ -package de.fork.java; - -import java.io.ByteArrayInputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.PrintStream; -import java.net.UnknownHostException; -import javax.xml.parsers.ParserConfigurationException; -import org.apache.log4j.Logger; -import org.xml.sax.SAXException; - - -public class LauncherProcesses { - - private static final Logger logger = Logger.getLogger(LauncherProcesses.class); - - // Exit process status - private static final int STATUS_ERR = -1; - - private static final int DEFAULT_PORT = 5193; - private static final String DEFAULT_HOST = "127.0.0.1"; - - /** - * Run a process. - * - * @param command system command to be executed. - * - * @return return code. - */ - public static int exec(final String command) throws IOException, InterruptedException { - - return exec(command, null, null); - } - - /** - * Run a process. - * - * @param command system command to execute. - * @param standarOutPut if not null, the standard output is redirected to this parameter. - * - * @return return code. - */ - public static int exec(final String command, final PrintStream standarOutPut) throws IOException, InterruptedException { - - return exec(command, standarOutPut, null); - } - - - /** - * Run a process. - * - * @param command system command to be executed. - * @param standarOutPut if not null, the standard output is redirected to this parameter. - * @param errorOutPut if not null, the error output is redirected to this parameter. - * - * @return return code from the executed system command. - */ - public static int exec(final String command, final PrintStream standarOutPut, final PrintStream errorOutPut) throws IOException, InterruptedException { - - return exec(command, standarOutPut, errorOutPut, DEFAULT_HOST, DEFAULT_PORT); - } - - /** - * Run a process. - * - * @param command system command to be executed. - * @param aLogger send the information to log. - */ - public static int exec(final String command, final Logger aLogger) throws IOException, InterruptedException { - - //calling private method to handle logger input/ouput in a common method - return execHandlingLogger(command, aLogger, DEFAULT_HOST, DEFAULT_PORT); - } - - - /** - * @param commandAndArguments String array containing system command and its - * arguments to be executed.
- * For example: - * 
-	 * commandAndArguments[0]="ls";
-	 * commandAndArguments[1]="-lr";
-	 *
- * @param aLogger - * - * @return return code from the executed system command. - * - * @throws IOException - * @throws InterruptedException - */ - public static int exec(final String[] commandAndArguments, final Logger aLogger) throws IOException, InterruptedException { - String wholeCommand=""; - - for(String argument : commandAndArguments) { - wholeCommand = wholeCommand + " " + argument; - } - - //calling private method to handle logger input/ouput in a common method - return execHandlingLogger(wholeCommand, aLogger, DEFAULT_HOST, DEFAULT_PORT); - } - - - /** - * - * @param command system command to be executed. - * @param standarOutPut the stdout stream from that command as a PrintStream - * @param errorOutPut the stderr stream from that command as a PrintStream - * @param host the specified host. - * @param port the TCP port where the daemon accepts connections. - * - *

The host name can either be a machine name, such as - * "java.sun.com", or a textual representation of its - * IP address. If a literal IP address is supplied, only the - * validity of the address format is checked. - *

- *

For host specified in literal IPv6 address, - * either the form defined in RFC 2732 or the literal IPv6 address - * format defined in RFC 2373 is accepted. IPv6 scoped addresses are also - * supported. See here for a description of IPv6 - * scoped addresses. - *

- * - * @return the executed command's return code. - * - * @throws UnknownHostException - * @throws IOException - */ - public static int exec(final String command, final PrintStream standarOutPut, - final PrintStream errorOutPut, final String host, int port) throws IOException { - int exitStatus = LauncherProcesses.STATUS_ERR; - - ForkDaemon process = new ForkDaemon(); - try { - exitStatus = process.exec(command, host, port); - } catch (SAXException e) { - // This is not a crazy thing, we are trying to insert this new method without - // breaking the old methods which did not throw SAXException or ParserConfigurationException - //[§EJ Item 61] Do not blame me. - throw new IOException(e); - } catch (ParserConfigurationException e) { - // This is not a crazy thing, we are trying to insert this new method without - // breaking the old methods which did not throw SAXException or ParserConfigurationException - //[§EJ Item 61] Do not blame me. - throw new IOException(e); - } - - if (standarOutPut != null) { - if (process.getStdout() != null) { - standarOutPut.println(process.getStdout()); - } - } - - if (errorOutPut != null) { - if (process.getStderr() != null) { - errorOutPut.println(process.getStderr()); - } - } - - return exitStatus; - } - - - /** - * - * @param command system command to be executed. - * @param aLogger - * @param host the specified host. - * @param port the TCP port where the daemon accepts connections. - * - * @return the executed command's return code. - * - * @throws IOException - * @throws InterruptedException - */ - private static int execHandlingLogger(final String command, final Logger aLogger, - final String host, int port) throws IOException, InterruptedException { - int exitStatus = LauncherProcesses.STATUS_ERR; - - ForkDaemon process = new ForkDaemon(); - try { - exitStatus = process.exec(command, host, port); - } catch (SAXException e) { - // This is not a crazy thing, we are trying to insert this new method without - // breaking the old methods which did not throw SAXException or ParserConfigurationException - // Do not blame me. - throw new IOException(e); - } catch (ParserConfigurationException e) { - // This is not a crazy thing, we are trying to insert this new method without - // breaking the old methods which did not throw SAXException or ParserConfigurationException - // Do not blame me. - throw new IOException(e); - } - - if (process.getStdout() != null) { - aLogger.info(process.getStdout()); - } - if (process.getStderr() != null) { - aLogger.error(process.getStderr()); - } - - return exitStatus; - } - - - /** - * @param command command and its arguments to be executed.
- * For example: - * 
-	 * commandAndArguments[0]="ls";
-	 * commandAndArguments[1]="-lr";
-	 *
- * @param aLogger send information to log - * - * @return the executed command's return code. - * - * @throws IOException - * @throws InterruptedException - */ - public static InputStream execStream (final String [] command, final Logger aLogger) - throws IOException, InterruptedException { - int exitStatus = LauncherProcesses.STATUS_ERR; - - InputStream stdInput = null; - - String wholeCommand=""; - for(String argument : command) { - wholeCommand = wholeCommand + " " + argument; - } - - ForkDaemon process = new ForkDaemon(); - try { - exitStatus = process.exec(wholeCommand, DEFAULT_HOST, DEFAULT_PORT); - } catch (SAXException e) { - // This is not a crazy thing, we are trying to insert this new method without - // breaking the old methods which did not throw SAXException or ParserConfigurationException - throw new IOException(e); - } catch (ParserConfigurationException e) { - // This is not a crazy thing, we are trying to insert this new method without - // breaking the old methods which did not throw SAXException or ParserConfigurationException - throw new IOException(e); - } - - if(exitStatus == 0) { - stdInput = new ByteArrayInputStream(process.getStdout().getBytes("UTF-8")); - } - else { - aLogger.error(process.getStderr()); - } - - - return stdInput; - } - - /** - *

The command is lunched from location - *

  • #>cd location
    • - *
  • #location> command

    • - * - * @param command the command to be executed by the daemon. - * @param location - * - * @return the executed command's return code.
    - * Usually 0 if execution is OK, otherwise !=0 - * - * @throws IOException - * @throws InterruptedException - */ - public static int execInLocation (final String command, final String location) throws IOException, InterruptedException { - int exitStatus = LauncherProcesses.STATUS_ERR; - final String wholeCommand = "cd " + location + " && " + command; - - exitStatus = exec(wholeCommand, null, null, DEFAULT_HOST, DEFAULT_PORT); - return exitStatus; - } -} \ No newline at end of file diff --git a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/MainJavaFork.java b/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/MainJavaFork.java deleted file mode 100644 index a422cdd..0000000 --- a/JavaFork/JavaExample/javafork-example/src/main/java/de/fork/java/MainJavaFork.java +++ /dev/null @@ -1,35 +0,0 @@ -package de.fork.java; - -import java.io.ByteArrayOutputStream; -import java.io.FileNotFoundException; -import java.io.IOException; -import java.io.PrintStream; -import javax.xml.parsers.ParserConfigurationException; -import org.xml.sax.SAXException; - - -public class MainJavaFork { - - /** - * @param args - * @throws SAXException - * @throws ParserConfigurationException - * @throws FileNotFoundException - */ - public static void main(String[] args) - throws ParserConfigurationException, SAXException, FileNotFoundException, IOException { - - final ByteArrayOutputStream stdoutByteOut = new ByteArrayOutputStream(); - final PrintStream stdout = new PrintStream(stdoutByteOut); - final String command = "/home/gustavo/github/JavaForFun/JavaFork/Daemon/script.sh"; - final ByteArrayOutputStream stderrByteOut = new ByteArrayOutputStream(); - final PrintStream stderr = new PrintStream(stderrByteOut); - int result; - - result = LauncherProcesses.exec(command,stdout, stderr, "127.0.0.1", 5193); - System.out.println(result); - System.out.println("Stdout: " + stdoutByteOut.toString()); - System.out.println("Stderr: " + stderrByteOut.toString()); - } - -} \ No newline at end of file -- 2.1.4