From 8cb5dbb5d3164137ae15eb9ee72419572b7019fa Mon Sep 17 00:00:00 2001 From: Neel Patel Date: Fri, 24 Mar 2017 19:23:31 +0530 Subject: [PATCH] bug fix... bug :- long time to process data server queue in main server flow. --- ProgramTester.jar | Bin 594288 -> 595211 bytes nbproject/private/private.xml | 5 ++++- src/net/logSer/LogHandler.java | 1 + src/net/mainSer/SerDetails.java | 14 ++++++++++++-- src/net/mainSer/userStatus/UserFactory.java | 11 +++++++---- 5 files changed, 24 insertions(+), 7 deletions(-) diff --git a/ProgramTester.jar b/ProgramTester.jar index 979a722e022f6c6441f7cdb7eafea7cc7d5b0ec5..7dec2b171d0c863fce8ff4aee18b01e0dd28c1e3 100644 GIT binary patch delta 13920 zcmaib2Ygk<^8d_jXYb8PxLgtl2_-;)kV5Yr1d$LBX%UnXArxsL31WG8L49^qL_NYo zK_7}JAVqUSP{C*K;=}d;DbiJnSWqed@9dt0=&7x1L%tuEmMVaa4p_hR0XMch)iuW>`& z?&B=oCV1NDc7iWyNxmmu!&BV8e|S3S=g&Reb(`qT(QQ9(7u_!Kw%6@GZ}O5)ya_Jc zOt(Q_rfxg>n(KCgudzFxv}BpDW)=K~3xDb2`~0o-SSP>XcdFm;x7^=K_kZj+{Gak0 zx+wu8U!Q;(FA13WeF7;Ii5!nH1v8m&j8j?To2Ff*&13r&GUXA4UK!jQ+uq2<|*%O zJ`J6-y;D3Inq0$s)~lg{THYpp4c(RO9hsw{z5TtN0~$)n^ZssWsLlxQ#J&Qpp8uFP zSvZX?SnsW2CjiRremLXkz3D{vraQCudQ+UC7dY%J-RrFp`=Y{opVm)o(q8YWZkkkn zs;?}pp>Vb@$**Z;wDC1J(6Elavo&j=)V`GN-N1DD(!~ORL z^k}a!{znY-#RUIZv(ApG{*6Yezt8m_GJP}W`$I-cH%I*|YU#Q4miVtRJl_1I|D_Dw z*XAAnIwRHo5BwujbYGXl{`FoB9Y5yZWixi13wy0 zC$$WmGtk7=0b6@|thjIBXCu+|BLb66-@hjZ@(q=o;y_0;V{%DgmEj=%fxwGKj%|+y z>KYyHS{B%rsJVLL#lXjA?yRkW)rQmLZGol+ulJjQ-9{S?cLc6A9(C)!Kv$!Utp@^+ znbk%d3@kIy=|h1Bz1p8^Y#jIGq!b)xDNZ!oN^&mxf{D(WeSw77TgL*E4R0-d)-1E; z3d{N|U2{~LZ510@$8xN#23p<9>TjTvtu5CU=h|8in!X3xTXW1FYPF=INuxNTMsd#g zgMlO`?VW(-tn6#migoW}wJ~xQx~9qTWKxQr)zA;dh1D}g_9es$IV{8_dRQp={x;_wN#&Qu|?lmV~o9ypR;zGx$lM4 zk-A#e&FQMb$WYWwEoSZ2{)-ETE~`Vd%t^>lS<${B%BA~*ltha{)PNoc(u4GnMTEbS8cdPIgF6~xEn%ZXrTERUln=t)H@ELtfOpHlR6i2g~dLi7whYtd>&&xL3W zJulBMC|Vmw>u9}2FG{;1M5z?rXwfF2yjh68BwsIws0o!>6pIkk7DW~Eyj8wl31RqE z!G6uJue4zE?b5$3MBC|gi~bcyE$IzKZ%X@?qPH!2Cq(V&{t&%O??uQ%AH~tf^ht!g z^lyQ7hH^3Tc^rK~Ut08)pna|AKO*ifp|RVdJ&L}uXs=n1C={f9wBMowAsRs6hUhXn zXwe}iPf>}(dp#+!$6Kg;=9SK=Om#IMb_QmtHokvZbR>3bmYU4G$9a7c4&RH}Dw1>! zU2D@I%CqSx-D%M=o2FBqv#_zRe#05Fr=)ewvFSK{XVdregH0y{c`yyJX%yu<1>gH> zC!Gw_wKW2C%BCVZZPAZ5ouQwcMLDWzF^edgU=r@~w zr$3yXIjTj5Ybw; zbPBroYxlM|$>!QzC(OygDVEv{#CeQpruhUiWUb0eD@a}%4>xv9;~xVgm{ zHn-qRr%x+YKPii|nf$U!8uZUF!gVy!S)8ltI}f!|eSY9Qb=Z>`p;cHAB=%N?A3C;YXY-m83e>_ThR-Q(}bR6E02I9Jti z>QA$>o!i=}9o)$||EbD$7PMD4ac5`aNB(-T+8xwUPU&KESMF)k-|0@VH57RpWTOSN z&}p;R>cG7njs=c-xR0~r5i9SSB+o`4?dIcv6u=`<9U6~sTf=^uKm~YeAqvyT^}47Vd7SfT z7uBhq;ME49!B}<@73vxJz#NMH$@nPpsxAX9nnIc4Ccqr)T%s0w#Wh zbv$VMISJiW*Jhi@7in8YUhi7n+mX6Zm^x8s-FivnZAL+7a(C4z+Ls>ELZ*R)qBc|l z!I`>N(_udHbixxIZyRaNt&k!xFPxn$t9FP%c%xES>+L!pjQV1An^^emPMW+vKAJ>9C9LtI~ z*Ua?3O5Mw;$1<{ftH}ooiI0f<#@!#+^dUi1u;~shsEFVvPmSITqS&G?(dS&N4}iV5 zk{^l=M0%Ey+C*_>)T@kwZ~?%XTd22(@>f%%ylRMjftXc=#+xZ_qvo(Fl-UP_;cqYZ zR86K_t03-Fi|(!u=eftYE12yE_mRJJq3hjDXVWPo7{gvOuH^T?0`z#&h6@5DMhDC^07S(aS zAEGj&oEoBDv>=ELzc5ZrD9{}teEmHL)!zkSLvYmvkXPD!-A{|+a9BNH(SwQ} zl8KAs=wVtSLCn%PVOoNX6#}gc!JVJB=$}Fqfy|xsObFZaS(&stD&Hog5qdAk>IiBY z(+lzi^6M0>mo;Bhw85f{A#7!YH_c=v50wf1n0%GXM2T&L-d07gD2Z#D(E8!p=UEgq>MISKLC@!2bt)#TDxC+HH zsRVcvo$O)i18(P>9j1oX`xjI4jDnfhO)5zL3x0ZAXX90>e)1@$L>Hslg6VCX3By%> z(tjIjZNj2YhO0>9TpDE4ZPSl*NJ6e3Ec(f&pG|xP zZu`<@64KOjl18e;+Mm%`rtl=_JPjdB8Z;(BjdSG`Z&GL6)4zr3cdYwInC97Zj?UY3 zfiBuOjIc;=>cfE5}e(`K}~qM&5z;DREHgEoga&RLtQQk{bXytSO( ziK`c53 z25OfVND7RSd0~eaS~<=w^HpzW`95Ju(iyau>p2OV{C%9(ms)5z4pz<5VC^v|P=1{Q-dFr|$Pl^tCoC_cN0v&u55}oP82}aN@TnBB6_!Bnx z6@Wc75I2Pfx*vp|JQL9j#(+8EQ*@|Q8PQ0!hfQ$_G(%3( z9JxXUwMFRD9tUA3%BmugL=6#Rjlc|vumU(F!;L+_8)XPSHdZwoAoR>7*B(oCfD{tn zn42<$^B|wDuA0vXkw#+;>;_>7{Rcr)ZuIM%nPXL*Xayz8<(=dqTqk8zdpp$`g!?^t zDWz;851_i`l(L0VK^9j}Jktj0-a_?o3GoKpL6;stHVY~n3FZb$w6B>IX4~QdC#W<6 zrPc#RIv5d=+tQU$xc^X~OJq45Q$|A4Q3wq4wL}sCj>2S-h%u!T;!3fP=mt^dIf8W8 z4iX7Nve{e-=b{w}>llX1sXm0t%i2N>nAYaul9s!>7UYH!qlgX(j7elLmf}Gp5qEYH zI1r6W7!{Axc|2BS^g?FMi3GBjIDsRK5FUb~H&Meal*YKtYz;Po26@9E z-k@2m6-BI?fHjkJ>($(t=yf{clo=SAjgdK6uei#_bzDA-9&lwR_A$#B;3hXlt^nhr zf(|esq;D+JYbJtOo2j91t#>Uf7uZTxJmL%$X;MZZgb(RXbiAq`6^%4T1VFgU6oQ1B zbT|0B2Rtmo<^3Rb$3sYx7guRW0b?Te4`U>?N<$qGU{w0C4m9gnROkkplO@m;g-xmC zn1{jyVuV$jqM9+yS5xqniBFltK=xK@HX8o6g~CiRYFH}goBsKkE#Cu$gdNom_(Qb%Or{UaUy$@2zdye}1&QWjd1<|j^qRB{PM8Pc( zaQ=T>qH;qlC2g?q2^nouzZZ#AOZQS2V_>@6oK{Ic_?!OaE%en>9`B5 z?nc&eq-y6VeY(yB-Yk6N&^A4@@np{WBE;mlG%zA(R zA9Ek3+d^O#*PP4jV9XJ9MdbKiM#7tWPD@Z;T`|vs zi`B5GkALmz4Epy`Dg~REdU_)3Gvcad+ibXc_X8U!;=!N=gEim+ydT0{C446wNm` zHLyDCrHB#}smo@{-b&rzMv|~?CXdNfgqAt|>*BVpkJG*Zu7>(hmz!O3ZD0f?dr9PE zPI3mlXVq=CT*{dAD6lqT3%~3_uhGkYPE`(1L^)L#Q7`VBv*e2mqA#3vg{o838@O5%P0mS)@sv)Yn2%UlZJnkW|<#&WfYUI6FcCZY5Z) z<*SY2wve3LK_}c^aR+cOe&U1#yc5Vr76VPKNQg;G1(8Iq^T7K#`=HMVDp`jq)ZZ2dIVjrpYW zT5Z+KX)#^(e8ETg|@Hd*zxTp8m2sUzR6e)kZX?#6Xa4vF% z;iUzog%(e@c?Qq4c^0j(aZt^-c{Uf>aMCi1=h$4#B_hw1 z7B95K>-j~SH}FP_HwpKfEq+P3f7!1ISSp1F6Yj`gP_l4<>Fz*L+AWYkZ@o#ND$jE>nqQ%bsvHrwVJ}i!R z#HMHXdYg|ju#O2uy#J8`eH|Yk=T9Z`t?m7ezjt<&sI^w0q_A{k@eJpdQgtBV2Rl@PxOMCH$jv z?tA3_>%Q{mIVWyZcd8OT!_+7v*Wp~ev}--kA9DV2lS%>VPtNS015Y`lZ&sh+>1U@+ zH><8wG+zypG&SsONl^`hUbv&M^^5b$i~i}cH*Qg7jEuL0e|4^U*O%>#|BpYSpU*lq zZ&f#e&Tr0;iI$N6-AT9(1UKXchBy;m@CTigsCu~XA2y%!AX@nZj$;ZOAJPXlp-N`U zdn%jWhAYxrGWrI5gkBY>LNxg=y2GYzwB2bm$KT%L@t7poZ{y|=0=taIc6?Vlwi?qvf<_^#hSoMYMcvEtdjcv?TB{G zy@R1ZO8{cI#D9x}m= za2*19LYR|?@MZxZNkgTC@UUJ;pe2A%Gy~=%2tK4hfNkh5SA=I_EC&lAR%__NDc9J* zX$VxY-WEa@nu*lEv4qY|JS5RSW*D8B^m8oqH4drgc+j4J)cd+>md!y0cPa2iWJGLP zK#?-8HZgnACG0M&TBrh{AJ%CqSz0rk6=l?XJ0%Z}X1_ymux}&-=B#Gt7O-)486ocr zN05OCjQ?G;V~(Fug0LfSg@_CRrR7qIcI^m~v`DrdMD`MaJ5-8flCmPCW^)i46+@vV zlpclqXT$YJ!1=F+^N&HmdmUVVCY*mRV$ykV_bC2b05Zk`3#%-!(6vAs-e4IEh%OMf zouh1vmgm&dDtW@S$gQx5STv)WO4@+(|ItZamKHDT66Yz{Sg2-$^9R8BgJ9$#Xmc@w z=7%+7CYa7}8B2o)3OiisjpwKt*a0)Rj$HfPi47<;?~7(e+Llwhyv#^@GoK40@DsVyp>M1*@7c%@Z>V4_7 zFv;#Ki0xm6TfCx$F!e}z+4dAjwtx;?^H)2*qvh1+5*2fPzg}&&A6gTEf^s3dOiJ<4 zkG{dk#`Si4af4Kx;CO?DI|sNBdP z>{OF2_ePzh4(Q7XXv$A-!=2xO3ErjV^d7w8Ltwm*>i!2v&Og$ewg)!~Y2G4ORgBdN zmc0RLY>ukLI>_z?wyHAGV10ZOj4pRnv~t3Wm>}CXNSfWuJu*T*}!ci0> z7)W^a4wIMD@Jq9eF+O)^y#x^uzPl#a=K9IlYPuZ(-C{S5G`fXtMqzMt8Rh3!NG(_! zqyqII18LJ-?TbncFt_q{9Rm_LN?j7zkPH<{b-Z$;nF7Yw=-q`)wHJ5gK8)^1{q_KA zp$D}&?3!h0vm`XqFTF|u67g3>6!|>a>UqJ4^&jCNOKn+ zL!x^eg#ko0t{PgS73~Ee?YMlwuO5dStLDc6>#H@HXkRw)2P;f1nu8YB96 zj$R{q(Tga|UAr=XiuzMtr72?c>YVSX#<`zf$AKf9Bar*cY(MNh^{a! zN$^*z&9|ydhWOTM$K_&Zo!)FaVM|Z#pGsJSG{VNx5_38 z?SUaNeh?0y2|c#_>oNF%=EYDAR$cl*P{rK}jUxUwq@p;O{|Bu(|AQ9ZSh{R=bx8%X zz|-`JnmAr(oDqN zv&w1qW{Fsf@Gz&GiZ@gJOS{v_TclE=JG2jf#uw3sP$@f)>d^)4jU#xz13UL942RdF z_y}~Ce!~yS1j4IJc!Y+yMio?#>q{RuOffk;PJO7RUh+Xf*z~Xar5)a%nj;(^8?B)@2aV_1ZPYn-?~pD zzg1mz_ftoJwC-D_e?#qH*;MDqx2jI%l#Z1^sxuPg^i#<}ckYIRs<-ZeM5#`~A=N}b zX_l`%xjF67V~z9p)o;M|FZ#S*AdlM_oN+F`X3B9n&iBrF3A-~RYz@?ua2t08pt@NMra^< zOpVmQm&epq8pt}XhHGHqaTj^VaWzi&wEa$9rvc|XHAw>(zEe{*FztIaMgwnu4{M26 zB>kYS)WDPN2$bq`F1}4Nj@? z8dz{jjn+83PpKigC+D=fS_5~V##%D#^V2TnoFCnun}39WGW79}kX?YLXCSEnx14bq z`}mAYr^Qe1qIdlSxdi86Wl!IqA(!+#^0OMIfnz_r)4TuTQeN_lD$ql}{-Uncz^Gr{ z)t|2fF8u0JzUHh8l%Iv3g>v2Bpl1PY{Y_2R!1tBFnBUbL-ShG9>P8I={6kI9z}i1t zI>B=)U-wL`1YSMo%9VWH>I#rgQLuyWd)0RD*QStry*) z_bwVUJz6(-xr{t|T~Kehub&V2N2(CpdH9K6g-<)GQT?{m;>@I+70tTWzYh&a!A z+@T*Uf$rX5e?9#UuS@5BZ_x0P>6_w% z-L)8}5>pk_08z7$k`XOYCE$Mf{})>SnllX@7~C_h~!fjw^QZc zs)eP_iiBWBBSE_K8!|%Hcj<4{LeG`TIXwiw>Bm_e51dt*SiWKQ3lF&;GAfnr?C?M-UJd zMU;*&1yt}Mf)5cZf{KVrM**=QqW-_L=cMTG-|~@jW_M?2r|s;_p6jAl(k?!q7B#T1 z+Y=yCMA1vGya~{NiD*C=E|?`kryM(d|!N9rZiTou%L1-R<=IE_X}){@R_i_@F!5 zfg9+z-;<%=tvwC(y5l`{_4{jg{Nm-F*a~>J1Ahj5;nU;I*6%i6o8QUaX1cw?+f={b z_tw_$i(Z>IbjwB5ZZO=IUD zb6@PBpHLLJi~2z=XQEp$Lqed zPd%osrWQv$J{#(Iv>fVj+|%9ed-#MW%7#{)@l>}dmtOV^N!L_jYI>^$HB`Tm_q@$Z zT()&PeYP8#*-Jd&OSt!^z$)wrKaw^`5Z%W-RaqY*pPB@jhEk)2p%A zJIZGCwpHHO^qwwhw%5DC7VY?c@6cq8*Y2cuqwOhY&v?JE)wl1m_d#3mA%A*PZ7TEp zzMt#r8M7MuezZBwZ{oXVLld%nW>}9Fb@TmfOEh(eZ=&7z@kHM+n@U!ZuQhA)PMqyq zldPerM}3mj^J`ywmxgwH<6CO4Hsm|savQpI!uOav8V=ScX3N-B`N@cA$yTJX5pVse{K?j) zuYIay&l%rDo3|z&W2U|4vxf1J4g@808XHA6tutB14jWqA)aYSD7qSi5LLB&7bK^0) z@6ndV&8A+n>EiA6>I8}E1g&x3`QokAy*|TQ-OZ?0(y^=2%$Bn-*C@8vOdn`;_i0*% zHyTgt@KzF>Z`86i)A$kND|<%NGGn8y!8cbMk3{Ji{Wlt`Y(6e*Hl9w>eGk2BUzeuG_~E9p|F8^f}=!lGkR~jcX}exbSt`% z%8YagP;Xk~r+9ieK(*)*KRrs18T5F7ytGKs6Y_pi9*bpoi6A~DkELO3k7t6kf>tV8 zWze%SakZl70`xq+5TG^mqCqbyS{tC3X`QrRQS@q%*3$-qHp+WbfKn*3*`O^#d8-iJ zCXd$wRFD2`P;r=;N)?q!d%HY#1Tg%%V87wj=bFFaF6nvP=s9J2ftB;Vs%fQUs%-ww z%FR^GJZ~9vqGVyFn#lZx^;SNDuq#W2<44jcllo9!lTOlo2Awi#D)qG%*7ek^J$=@s z)b?2>ou)G;ouzXoofqU>>SxkWy3xuz?@5UNK18EpeDs4!v*?0B7frfEKU$Axsrq#< zQ(q<%R3=TCIVp8w-jwME{bbV5^ov2inskMJv%c=8QX0*l->+YO{^ZFsX3U;#&{dOu zr)wttL4PuNn#{R%jzNE!Ow85~)qE)dlU?jKX(W5BEv24>I03yT-9Up(8cah>_OW3t z{KTl%DaOYNY_XpyDi>T76r~QCTvU*kFH-_0%@k=S;lV+9m>gwrw8=3XVoJ0YHc*MR zOpaxPDfXtk3Df2lriv_}(mpHItCvkOylTA+H z8X>NU?ph(PZE`BtF}W_+GdYdx8{EL;hTO<{{9|uQqRHu;!Q_>dQlWFsG%1g6vYN3< zu{JkV-TjSC&f+Fa4XsPtRlF6>R&i=1Hx*&BtxK`)cElb9RAYBC_;Bx&5jwZxU;ozv^v8%)`v@s+)?q^w?qa7#D4$<#5M3vrv5YlJ7*wZ7bTz{ z#?j-jkAA~@G~O^8UV%4)Okl$u(KFiO6`q8KV}RsClPHnK;%REwOXFxfTIr%6joi7N zx|PRRCGAw37J`=mLjADp1j^Slh5>T``U~(+kz2LvZO}x@5ZeQDv{k3Q8r)YFOTf+} z$l`${jX!tp?XWEB zCXNF?(5N16(m{2^@U#x9X?nR_0g44_QKQ2pjRBKx5G{0O?e3s5G3!DHRj-yq)WGn~ zwh}P$Ev)0hyQ7ueQMIq-UawoNsU3x=4Yk#8H;J5eNm-9~RCOY8-wQj1td0Tt~@4U{aa|BC=rBS!duqQD5YwBcTn>YCDbApjh5S~ z6;Tl21<<_-idAp4e=Ix><&PpG5FFXVR`{z7u^{O)DYLkpm1M+E~!sK z8JVTju8i7S2Ro_wh^Q-!)rgjpoHfz(48_pO3YWkHy*dy8iF4R%8RY6OYlQ-`hnzKf zVhs^EHpBe}btt8d%gOMpB@av`P9kgB{%)1~dqlA59xbSd;3Zc~7Y0#mQHSWum?>)S zwUsHZr#WkF^G(wHc~I=P9686Rig&e7NW#?f|3!PJ(vaiQ7|k zxCguqh))A)84R?{fl3@`AH7Te)qU^NLHeMw?v(WEvmEuTodnMBp}cllv#^(1WavaI zxp3&Z{c%M5 z09@_PAX0{iL3b%yC=>4v!kqU??($HO7D>+Y2t8`hV?qi!&pb(Zvgt`dT`Z3!0qlmQ z5uswqnokF@CoFk@=rTpiWu<2ntq^3%gcLn%(CPqo%+2yZI@FM!mrUj*S#PZ@|FS{r z1pO6*UX|6>8?-?(6-?Mjn+%eah{=uPj;VU?%z`;hOKuye7I4B{Ou>m$X6AR#o0B)V zpa_v5AFNwZgVa>dGK02Sw+~X)t)~a6ce$B$(_l3)WgS!8^t>52<>#eUnV6Q%)W`a8 zFpz5xQ5~$^`R*j^!67PKH;1~I)PXu0w9TZ~=-(#7R(lg+s2B1vlS-)6I{vz=hIM3! zN{TO|?I!Jzq1R1%gWfceh4r#RpLmn3T0>PRxQoUkCo}0kv|DE@sc(m953-eaLNv{! zy|mAucTIT6euLgK=>WZN9b92lZ(_pV2AkqBCVfaBne;L3F_EObZ_uYE9iq=nIxL(a zsFr66*72b#p?Vn|VT#U&a#ANuE|@S)XA1N=inx(Cs!VIZBzJsW%Aqez`jU2s=qOnE zDn!Rj`kIcL^bLJ$(sy)1&itBfPtyCKH8t;+yr$FhW=?9FJ8R}7lTOhGNJn(<+&NRG zH@!Y@_T+wfg$A8A=?tA^O0ZG~sDu*tFx8zsbdJtjmxilO?pE}@)og@nZslC@uCcx! zq4s&)g>&avd3U>N^K2`2vQZm2KUnV%R;iXJ!AP)fAEky_D=xz>AB|FDW9foP7bShe zsb?ZsPPFRW>}|!rSX|;e!@uf`phYWe5eZ}gecs4kh4IjnEEa_ab^`3e85)Hr42_^gqepx)P?tOtJye}7(s9?rnp@c-xo(;!ZJ$UN-jW&rIb`g)!j4X>fia~G5XB@S4HB+vlw;5heMP2#c)cSNPIoO+qRnh6r9hzE%rdIM zv_2Qdm7HSLC{C+Qc(aelQ4}=+hiM$*csx!pSzpfTC`70sSe4N$+z2O<(^YZ;+Yb>Q z(!q7PUJHRGc-6O3%`&RRi0P&VYg;AbRn3SjYbR_|pqQyxbq3nAK)0~MdWp_@w!Ao` z;=0N*eyC>{h<62v?O;&M*9u00l&K=6Ud*4ljcR()Pf$XP=x}ZWzG`QkFrK?{d zonSi&WEU_W4OMm1Z`&0cK!rpvP(-1uj-?l=DYCyDS_`ySfVLh-{{}e0#wv1mKwDg( zdlk9I{ZnpO=Z3$_oen?xKbQ&*nWjB*8Huet|CFYIBaL-Kp5rdIrTzm;?FQFx!%}-- zseQ22e_@aPu+)21IF5BV{(o8Oe{d}IiAy`zG&q;|aKjxDY6u5vguJ-n2$-RaP-K=+ zdNE~WY^O}gi5t5pV>57V4cqbPL$LZ0Lflc!mPAFR16m&NZouP| z#l2U86F1(GY*-%Qs9J{Y6J?a8v%x6w2|Et0rRaW@EjtgaLurURHcNKQ{REr&Q)ulo z1d}f?dIao!4*P#up}G19CAlcBWLIS)`UNivvjH@slUf-_4*Y0WfRVQNrvr z$FUoL4Md)%F4{%e#njB^s-n4M6?ro^{|{yLLS1t`IO?rAk-#UV#dIC+uzmx?hw}Ad zl{BbwCh0Q>cuh1mjsd4`LDjO2Ty|304db>sYC!gy2xm2*ky+?V&y*S?+NIkiMSinH)6f-Zg+iVBce=e#Ppd!hy5^t+!O`i4IkjTNZv=~@l}A1(bonYmt^x~ z05STMJWd;Q#-OuOSe`TJd;mOyejj1amwu;+9JKR3N9k?U3%$>pzAxCh!gvrn8$hCjv zZi=r9aChzzrU0jlDo_9v^7V>)i)4KQ+?R916y)qMhz*h{gAKVPEW}C1Lj~u?AP?i= z@)#lVjg+xb29Fkx|3Fw7WANAjyizyD89d(LJgBqe=u~xp`Ao^H(^UuNv(}plD#vOt zQ+4K{R>4eFU~T)x)1@SOmiof&M&)a5T%#Ihn|u>bVDitMT~IW5PTrgXgY!);;E5*v zn{G3C5>Ga13vD%cipf)Xnw>`H&sK?{={&>anLNwjLX&T%wfg$Zx-h~QpTtEWx()YN zvrV4Eb4{Ahx0pN+Yw9HX+u173T|~33ofkQNFa~cm@`3b9Nj;f#hB+o)B z(81)z0{C=l-OS`Ae7m(}j!KF=1*M7DGxKIZ>ZK-I{ItQ#OkU2<;7V<_t&J5XujEy7 zr?A}QXL+^B&+(mD{`n9sk>y_q@ftK=4AE|rU*feUzs&0lenl91)!_BQ&;}Fb{|bXQ zn!JfOBcGAl$a<}tip5>t7T${a+d_n?ck^rZtz&9Y!Gu}26ciP}82^UW*UeQmB2NIX zI7GWlF5yy>%XquVJNQn6UpM&;e$(WgysJF<*J*z4l-Y9(e#_+l@NVSzkf>-5DCgx5 zh1lH-=HPC%Nvg@y`E7&unEVd!HF+Pu8{?%|;pM+3@8|ch=mC@8=Yu1e!sV0m^<*hj z4F1664`~C?J_=EZNsDO-)ZWSDkNFdWKNWo)!r*5iS{UNPfR2PvcR_^DP5y$vG^LQW zj*s!irSMU4rmswTo+p@mj1QXpwNQKszJ)u}L=PY5-BJ!E_`cz9nd(|w*5I0R=VWDA zHRh=YtnsC2?wzOhM1RL8WZ#@bIa)M#X61dRh5O8)H8xo#TdSWmly&A-^{%^+Pg!@} zrW#pC=d0Cdoi0HO--`u29{*1s00gJ_+%nsqR$Tbs8ULBG48s7Uzu-g04j$DOJhLRTUG056*` zYwpZB;IdJAAM1vFp2pU=&%I%d2qzOP?Xi}5@{3!9}Rd6Xpcp{IlhW9v*dyam?AO~ zqfDS!xHQvNWjDHn-Gx;aswWGjx$vkDe<`L0yC|_=!KQ%V3c{X<)E?;=A$f~N5>^dK zODdc_4UXOzu08~=KAa+R@g?CFq{#Ddyxxk->iK}~fXgnZVu6Jf7Fg(5AQic)Z2{2* zGOugY7?*5WHMB~WI~KVU77>d!s-lwYzpDh)xD|SVrsiS-s7=bxU!Iz%Wk>tR_M>aH~*;8L{*IP zP!?_uBP5`5>Z0FWQC*`Q!Trb>-7yvkxFF1cz2t3MuqVndsZH?J7SL)W)X$-ecpi@V z0!XdFR(=sX_9blQwV?De%Jp?{+gDK6yb4O|L1_c*zESI}GuSXtTgZ08-5BszQe+h@ zR0G!;&tj{4K)R1sq!*Jaw|Ws4F5l|)$@dpl_8RmY{_~*ZUPcrZ6&>wVqt8hdE^z># zmK`@30a?Ti8e%h+Q9Gtu+ojadJ0r3kQ3zm1*(9BCmx3$y%79=O6J?Zy%ZCO)5X;+f zwIO(4g;qLr;8?gyP%fpMN+NbpezVGCFO(+o`01qx^kzq8`6wj&w>7Rey6mE^xtYvm z)Xh!(5U0TOb}5#0*pMyP9UE;enYi)j5$*}tE&|iBvl5_2*?V>gy&InSHgvrQLFXNC z`z|o{QWlP`Rw$(x$k`zG@(RNb!F*ztB$#kE6qbeF@?hIq2VjC>Z3Wm^uL4WAAGK-zGak)_`8ex$-ZOFwXN|3sD9pu z1P7esa3d&hs-RpOxbkPfo~6{kakkuHc^u1EVQJBbqb6bg4_A)n7O{WT)Zt_mFZIDhIBhT; znT#`ihNH!-jPPi0F^wsuvD@*L7Z@<>b{a2Go|yEe+)Q`#Ob>$E1guiNh<*8Z1j_gv z*8Kv$82Pe70XR9~d9p9+;+pV9kdx16NSmCsD{`LXHz;3>UX}6Bt1#}x7X}pfn2f~h zpOazkf+~|ES{q0HHoH`qz-(l3|C`zARc7nS2mUenNj({PpfkCu%5$nHLwjokJF_yX zh|2A?kxM$$o8c`MGmukE#HH>(1m9j|x=~><uF@R6w2lD~h+j7X@k z_l+Ii?1L@V32*XEQ@p_5=M~>Hk@Gs_J7Gv-s~?*n9lFi>Cw~uX{%orLigVl#syHq~ zfrup0|G%_m{oiTnZ-{m0u%3ym6a6{9!9Cm5!}d?thP*_Zu$BkbgTOGeuO*HV<8I+y>`c~=Ru33+smYVciRZmYl@vUmA zrzL);^v_hSgEC(Doob-Fmwl(2Ye09ODen%SP`z~b=o2be1FxRI_c&Sq+zHiN18q*K z?i#rBq-tFbq*x!FR4KZ3@uX_6fvi)ijb;XmrC4{LQi-~SX(?98DPW6yx^=O<9}bPO82?5sZOvKpn4 z%Py;N8c6v`jnKfnpHzPh?E6U#*K*hU*;%XbXNU5>@}Br#908~N;>f=17e~^BUmeD# z{0chaS8xC7EL!)9BUj{#({uESBUjVk)F6#~?{CiZ&wg_#H@T|v^w5)6)o2Y|y6UXn z<97#G_Pay*mvUh6HAl~{U32tY{SP%wPk*2s`1ucYv+kMlr@B=G-~Fk^YoOO(4#72l zsbRY3PX~BvxL=F))Hc7(O_=@8jw%OUV!yqAzApz_y8PE`DiN38-edb+{=T}Wy4xAb zcl&LBdd=`|T~7>v0G!_V_z#+kEWtU#EfUUJ#UxQQ!p|0&Mbvpa56Bpd-L_ zK4<8Wa^N$czlR>GZ8&ra4Dch!+YJ8*4a6w_NDWL^{yYtQp!`EL(9jRr1^Irze}D!K z`<FE35VZ93iX2e*HUeYZFL#j!aNw-Ta1;W)1og zKS~iA72jy^od*9^{H}uYU_~jgbDDo6%qAw70Hx^^(&6n~1eZ`q%HX R`)ga@$N7_d@y8U%|1Vzfh<^Y8 diff --git a/nbproject/private/private.xml b/nbproject/private/private.xml index 5a5a590..01270d0 100644 --- a/nbproject/private/private.xml +++ b/nbproject/private/private.xml @@ -3,13 +3,16 @@ + file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/logSer/LogHandler.java file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/SerDetails.java + file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/userStatus/UserStatusLog.java + file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/flow/mainSerFlows/MainSerFlow.java file:/C:/My%20folder/Fun/Data/Program%20Tester/test/net/flow/MainLogFlowTest.java file:/C:/My%20folder/Fun/Data/Program%20Tester/test/net/flow/MainDataFlowTest.java file:/C:/My%20folder/Fun/Data/Program%20Tester/src/programtester/config/Configurator.java file:/C:/My%20folder/Fun/Data/Program%20Tester/src/lib/ui/gui/QuestionPage.java file:/C:/My%20folder/Fun/Data/Program%20Tester/test/net/flow/MainSerFlowTest.java - file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/userStatus/UserStatus.java + file:/C:/My%20folder/Fun/Data/Program%20Tester/src/net/mainSer/userStatus/UserFactory.java diff --git a/src/net/logSer/LogHandler.java b/src/net/logSer/LogHandler.java index c97b0ce..40fa698 100644 --- a/src/net/logSer/LogHandler.java +++ b/src/net/logSer/LogHandler.java @@ -140,6 +140,7 @@ public static boolean setBackupLog(String url){ return false; } } catch (Exception ex) { + System.out.println("Setting backup server fail.."); return false; } } diff --git a/src/net/mainSer/SerDetails.java b/src/net/mainSer/SerDetails.java index 8bc62fb..146ad74 100644 --- a/src/net/mainSer/SerDetails.java +++ b/src/net/mainSer/SerDetails.java @@ -22,6 +22,7 @@ * @author Neel Patel */ public class SerDetails { + private static long QUE_LEN = 6; private SerDetails(){} private static IntRemoteLog log; private static IntDataSer mainDataSer; @@ -67,6 +68,7 @@ public static synchronized String getMainDataSer(){ */ private synchronized static String findDataSer(){ IntDataSer d=dataSer.keySet().parallelStream() + //.filter(i->isAlive(i)) .reduce((x,y)->{ if(dataSer.get(x)>dataSer.get(y)) return y; @@ -100,7 +102,7 @@ private static boolean isAlive(IntDataSer d){ * @return URI of log server, null if log sever is not reachable exception occur */ - public static synchronized String getLogSer(){ + public static String getLogSer(){ try { if(log.aya()) return log.toUrl(); @@ -159,6 +161,14 @@ public static boolean setLogSer(String url){ reason. */ public static boolean registerDataSer(String url){ + System.out.println("data ser reg :- "+url); + long c = new HashSet(dataSer.keySet()).parallelStream().peek(i->{ + if(!isAlive(i)){ + dataSer.remove(i); + } + }).count(); + if(c>QUE_LEN) + return false; try { IntDataSer ds=(IntDataSer)Naming.lookup(url); if(ds.aya()){ @@ -207,7 +217,7 @@ public synchronized static boolean registerMainDataSer(String url){ public synchronized static Set getAllDataSer(){ Set s=new HashSet(); - new HashSet(dataSer.keySet()).stream().forEach(i->{ + new HashSet(dataSer.keySet()).parallelStream().forEach(i->{ try { if(isAlive(i)){ s.add(i.toUrl()); diff --git a/src/net/mainSer/userStatus/UserFactory.java b/src/net/mainSer/userStatus/UserFactory.java index 67348fc..33aaa34 100644 --- a/src/net/mainSer/userStatus/UserFactory.java +++ b/src/net/mainSer/userStatus/UserFactory.java @@ -52,6 +52,8 @@ public static synchronized String init(String lp){ IntRemoteLog ir=new UserStatusLog(); int port=getDefaultRMIPort(); String uri=UrlTools.registerObj(ir, port,"userState"); + ((UserStatusLog)ir).setUrl(uri); + readProgramDetails(); readUserDetail(getDefaultUserDetailPath()); System.out.println("user factory uri :- "+uri); @@ -152,7 +154,7 @@ public static synchronized IntUserStatus getUser(String uName){ * @param log String of log * @return true if processed successfully, false otherwise. */ - public synchronized static boolean processLog(String log){ + public static synchronized boolean processLog(String log){ try{ String uName=LogTools.getLogProperty(log, "username"); //String passwd=LogTools.getLogProperty(log, "password"); @@ -171,6 +173,7 @@ else if(status==TEST_FILE_ERROR) return u.update(pid, 0); else return false; }catch(Exception ex){ + System.out.println("Log Processing fail :- "+log); return false; } } @@ -181,7 +184,7 @@ else if(status==TEST_FILE_ERROR) * @param pid programId. * @return credit of the program. */ - public static synchronized int getCredit(long pid){ + public static int getCredit(long pid){ return problems.stream().filter(i->i.getProgramID()==pid) .mapToInt(i->i.getCredit()).findAny().orElse(-1); } @@ -194,8 +197,8 @@ public static void proBack(String uri){ try { IntLogProc lp=(IntLogProc)Naming.lookup(uri); List l=lp.getLogs(null,null); - l.stream().forEach(i->processLog(i)); - System.out.println("Log recovered"); + long c=l.stream().peek(i->processLog(i)).count(); + System.out.println("Log recovered "+c); } catch (Exception ex) { System.err.println("Error in log recovery!!"); }