This C# program should run on a DTM/WHQL server. It's used by the whql_submission test to schedule and monitor device submission jobs.
Note: the binary is copied to the server at run time, so it doesn't need to be packaged in winutils.iso. Signed-off-by: Michael Goldish <[email protected]> --- client/tests/kvm/deps/whql_submission_15.cs | 254 ++++++++++++++++++++++++++ client/tests/kvm/deps/whql_submission_15.exe | Bin 0 -> 10240 bytes 2 files changed, 254 insertions(+), 0 deletions(-) create mode 100644 client/tests/kvm/deps/whql_submission_15.cs create mode 100644 client/tests/kvm/deps/whql_submission_15.exe diff --git a/client/tests/kvm/deps/whql_submission_15.cs b/client/tests/kvm/deps/whql_submission_15.cs new file mode 100644 index 0000000..540674a --- /dev/null +++ b/client/tests/kvm/deps/whql_submission_15.cs @@ -0,0 +1,254 @@ +// DTM submission automation program +// Author: Michael Goldish <[email protected]> +// Based on sample code by Microsoft. + +// Note: this program has only been tested with DTM version 1.5. +// It might fail to work with other versions, specifically because it uses +// a few undocumented methods/attributes. + +using System; +using System.Collections.Generic; +using System.Text.RegularExpressions; +using Microsoft.DistributedAutomation.DeviceSelection; +using Microsoft.DistributedAutomation.SqlDataStore; + +namespace automate0 +{ + class AutoJob + { + static int Main(string[] args) + { + if (args.Length != 5) + { + Console.WriteLine("Error: incorrect number of command line arguments"); + Console.WriteLine("Usage: {0} serverName clientName machinePoolName submissionName timeout", + System.Environment.GetCommandLineArgs()[0]); + return 1; + } + string serverName = args[0]; + string clientName = args[1]; + string machinePoolName = args[2]; + string submissionName = args[3]; + double timeout = Convert.ToDouble(args[4]); + + try + { + // Initialize DeviceScript and connect to data store + Console.WriteLine("Initializing DeviceScript object"); + DeviceScript script = new DeviceScript(); + Console.WriteLine("Connecting to data store"); + + script.ConnectToNamedDataStore(serverName); + + // Find client machine + IResourcePool rootPool = script.GetResourcePoolByName("$"); + Console.WriteLine("Looking for client machine '{0}'", clientName); + IResource machine = null; + while (true) + { + try + { + machine = rootPool.GetResourceByName(clientName); + } + catch (Exception e) + { + Console.WriteLine("Warning: " + e.Message); + } + // Make sure the machine is valid + if (machine != null && + machine.OperatingSystem != null && + machine.OperatingSystem.Length > 0 && + machine.ProcessorArchitecture != null && + machine.ProcessorArchitecture.Length > 0 && + machine.GetDevices().Length > 0) + break; + System.Threading.Thread.Sleep(1000); + } + Console.WriteLine("Client machine '{0}' found ({1}, {2})", + clientName, machine.OperatingSystem, machine.ProcessorArchitecture); + + // Create machine pool and add client machine to it + // (this must be done because jobs cannot be scheduled for machines in the + // default pool) + try + { + script.CreateResourcePool(machinePoolName, rootPool.ResourcePoolId); + } + catch (Exception e) + { + Console.WriteLine("Warning: " + e.Message); + } + IResourcePool newPool = script.GetResourcePoolByName(machinePoolName); + Console.WriteLine("Moving the client machine to pool '{0}'", machinePoolName); + machine.ChangeResourcePool(newPool); + + // Reset client machine + if (machine.Status != "Ready") + { + Console.WriteLine("Changing the client machine's status to 'Reset'"); + while (true) + { + try + { + machine.ChangeResourceStatus("Reset"); + break; + } + catch (Exception e) + { + Console.WriteLine("Warning: " + e.Message); + } + System.Threading.Thread.Sleep(5000); + } + Console.WriteLine("Waiting for client machine to be ready"); + while (machine.Status != "Ready") + { + try + { + machine = rootPool.GetResourceByName(clientName); + } + catch (Exception e) + { + Console.WriteLine("Warning: " + e.Message); + } + System.Threading.Thread.Sleep(1000); + } + } + Console.WriteLine("Client machine is ready"); + + // Get requested device regex and look for a matching device + Console.WriteLine("Device to test: "); + Regex deviceRegex = new Regex(Console.ReadLine(), RegexOptions.IgnoreCase); + Console.WriteLine("Looking for device '{0}'", deviceRegex); + IDevice device = null; + foreach (IDevice d in machine.GetDevices()) + { + if (deviceRegex.IsMatch(d.FriendlyName)) + { + device = d; + Console.WriteLine("Found device '{0}'", d.FriendlyName); + break; + } + } + if (device == null) + { + Console.WriteLine("Error: device '{0}' not found", deviceRegex); + return 1; + } + + // Create submission + Object[] existingSubmissions = script.GetSubmissionByName(submissionName); + if (existingSubmissions.Length > 0) + { + Console.WriteLine("Submission '{0}' already exists -- removing it", + submissionName); + script.DeleteSubmission(((ISubmission)existingSubmissions[0]).Id); + } + Console.WriteLine("Creating submission '{0}'", submissionName); + ISubmission submission = script.CreateHardwareSubmission(submissionName, + newPool.ResourcePoolId, device.InstanceId); + + // Get DeviceData objects from the user + List<Object> deviceDataList = new List<Object>(); + while (true) + { + ISubmissionDeviceData dd = script.CreateNewSubmissionDeviceData(); + Console.WriteLine("DeviceData name: "); + dd.Name = Console.ReadLine(); + if (dd.Name.Length == 0) + break; + Console.WriteLine("DeviceData data: "); + dd.Data = Console.ReadLine(); + deviceDataList.Add(dd); + } + + // Set the submission's DeviceData + submission.SetDeviceData(deviceDataList.ToArray()); + + // Get descriptors from the user + List<Object> descriptorList = new List<Object>(); + while (true) + { + Console.WriteLine("Descriptor path: "); + string descriptorPath = Console.ReadLine(); + if (descriptorPath.Length == 0) + break; + descriptorList.Add(script.GetDescriptorByPath(descriptorPath)); + } + + // Set the submission's descriptors + submission.SetLogoDescriptors(descriptorList.ToArray()); + + // Create a schedule + ISchedule schedule = script.CreateNewSchedule(); + Console.WriteLine("Scheduling jobs:"); + foreach (IJob j in submission.GetJobs()) + { + Console.WriteLine(" " + j.Name); + schedule.AddDeviceJob(device, j); + } + schedule.AddSubmission(submission); + schedule.SetResourcePool(newPool); + script.RunSchedule(schedule); + + // Wait for jobs to complete + Console.WriteLine("Waiting for all jobs to complete (timeout={0})", timeout); + DateTime endTime = DateTime.Now.AddSeconds(timeout); + int numCompleted = 0, numFailed = 0; + while (numCompleted < submission.GetResults().Length && DateTime.Now < endTime) + { + // Sleep for 30 seconds + System.Threading.Thread.Sleep(30000); + // Count completed submission jobs + numCompleted = 0; + foreach (IResult r in submission.GetResults()) + if (r.ResultStatus != "InProgress") + numCompleted++; + // Report results in a Python readable format and count failed schedule jobs + // (submission jobs are a subset of schedule jobs) + Console.WriteLine(); + Console.WriteLine("---- ["); + numFailed = 0; + foreach (IResult r in schedule.GetResults()) + { + Console.WriteLine(" {"); + Console.WriteLine(" 'job': r'''{0}''',", r.Job.Name); + Console.WriteLine(" 'logs': r'''{0}''',", r.LogLocation); + if (r.ResultStatus != "InProgress") + Console.WriteLine(" 'report': r'''{0}''',", + submission.GetSubmissionResultReport(r)); + Console.WriteLine(" 'status': '{0}',", r.ResultStatus); + Console.WriteLine(" 'pass': {0}, 'fail': {1}, 'notrun': {2}, 'notapplicable': {3}", + r.Pass, r.Fail, r.NotRun, r.NotApplicable); + Console.WriteLine(" },"); + numFailed += r.Fail; + } + Console.WriteLine("] ----"); + } + Console.WriteLine(); + + // Cancel incomplete jobs + foreach (IResult r in schedule.GetResults()) + if (r.ResultStatus == "InProgress") + r.Cancel(); + + // Report failures + if (numCompleted < submission.GetResults().Length) + Console.WriteLine("Some jobs did not complete on time."); + if (numFailed > 0) + Console.WriteLine("Some jobs failed."); + + if (numFailed > 0 || numCompleted < submission.GetResults().Length) + return 1; + + Console.WriteLine("All jobs completed."); + + return 0; + } + catch (Exception e) + { + Console.WriteLine("Error: " + e.Message); + return 1; + } + } + } +} diff --git a/client/tests/kvm/deps/whql_submission_15.exe b/client/tests/kvm/deps/whql_submission_15.exe new file mode 100644 index 0000000000000000000000000000000000000000..1e513a1783db619fbc8b17f9245783087f235232 GIT binary patch literal 10240 zcmehm...@zb$@#wyyJ;hy...@m3m56l*fs*9!w`vbt^1fk(6={Dakxawi_wZ@@_?~ za(8>4-IGb%X%qx09Kcp=AT0_tZR(<Fn*s&w#6{z#wu^qaC}0OkksvM#t4?7!MrzbS zn)D+^qW<3OF7HT5u7dWT0$Flr-+S}koA)&{y...@{3l~md1!u?b)v80$=a...@mzx z?&O_+mZaxeU+wv-HuGxF`~}O=YtmknMnx|g)vE343#KmXRo$xUQ^yN>#V(n-_V&a! zU-gM;q8Tkrk6*icCK&Av3Tf-KIMG&6...@zjs(K{Pt<aopVKc!WH=0V(_WNtbbh&R3Ym zKTWh={WqRI>aoyc&|6...@5oai+u!rjq`q5$hl9u$sj+xlfbzgaxkiua>p6MxP%mt5d) zcB4U`^3}H+n7VYLb2;hAA~0p!IDi)1I_{=x9M<QgS+>E*w$eG=tZN7ErfZz&a1*M) zzu>syV%tI#r5|L8-cA!~z;W|vKi9QoG(ts4k~{vwsx*...@0qh&?cnGP!v$+Y8E_+ zj-8>*)kLV{>blUTt8JmpSKC9KSF<tnq$bd*12g3b...@6ud`7dqahksxd)^...@uyu zzeQF7$CTa;>6mDV+3T1dyVjYG%V*Fh;x?j_$hLFC_FN+o8#*9jb`r?YZXdAk0G1is z...@}7~0|kKD`a70R4)U8Ew<w...@xxkfdt@ff6e3jN_?3tA_+6&qQ%|-$li!%2MlWU z3~Ig6plIB4Cn48|s1{f5h?q#&8P*iDJMfU_(3RZ;Xx|e^jx00e4vcn21+...@u<Q3 zb>1lJZWu*>40d^Dzan1?qz6Y=1+C4KZo5%>#pxUD8Gb?T2>Zs!QvsCiggqV37PRSh zxdgIk_w$s53XW!4&!l?>_X%C}Ty;Uv(szh<afgj5m#{HK5<?y0j&xG~5es`{rC~5B zdOGe;_lO>$U$J(*B$C4$<Tn~4bfoWm{oBZqh_>2TO%mz#Vm&f9rpvYn)mpvqM#cKf zRTo**>^pfp9gV!$)ZdEubN)oq?qP;rg-...@gpuo_bic6^0y)4<sq$Hwzq>W(l(}H zLRHUDkNnHEJpIg*0v9G;V(`mCh?G6R0z1)oLu`<51yV|HdZXCr=}U<XA_`=X1(bqs zLBR%3!4QZrZWxbrMkb<xal+0qsW+4E8{92=Mc-8yRi&jn<Pdm7hdqMs#w-yTkpyv+ zwe=y^ewfkfbg!l{4q=zmi...@vjwcq_hf=j7i)?<jvCcejI(<{O>awW6Ors)3~tJ# zH)qnFdoh7YAFcc42qJX;5;JViq<0JsitS>@RTuT6rMHMJ_6Jz^lk5ps|4...@ta41+d{ z9cXum9b!AodNsS3nSMWT7lXj4eXO!Slg{pa6EjBii>$A;OFkEH%0FkLyX^ho^<uzl zl>EL&{UBhkT)Nhpk(Qk;kQ9)`F5z*>V@&c`m6%)tq4Np2tEC6TKn8tSdJ~UhR%pK~ z20DP>-Gpxfey9oG41Bx^&rSf5KZQ=O;yQi#`{8aD;m...@t=)Yne64$R^m$6vD7KHbT zH6m0_#HK9vgv9=(pIyJMA{PW}XC^&3I3#w8K|fO6qPxlQNeB(aK$-#|1~KBG7!*5^ zfLBD*APKo~W$ez(s...@lpy)1S)-V%*M{UL1BMLH?(|m...@o2chldqwldkmxo+1qx z;^GJIeUITrxiE}S6UESCX47Uoo9Pb%$FfhKSVMmnIO};~4V|~i7SzKeZmdU2|JG1; z8s6...@3qd$ck@`-lkQ1-t+9wP4~PtJ6v01gNu9nTfDKowKwf<t^Upy5s~4Pe6JC& z`0FpjGJhY6s9jA&)F!6(Avqim${->?3)tHy^4MC{_846g<7*=;BVo&g...@t9ihgerj> z#9(TBV%=(j4!<aWD;P75-Xn;XeH2Y59Y=0sUT$M+RCb_~L>#%DfjhXqh?{fu72M4^ zd=)tMczSIO9jl?r{vdL)HdluW_Z-%|(ol...@187ykd3vyrftn-hawyu2gvaze4l| zo-R_?S8%0OU38dZ9xon0zza#=$pTHGu<(jNeMe8`F%4)Q_~$TY-{G>oz|6Q%6WY;@ zp*X~dexmIr?Bie|Onbbadhe~^Aw)&t40Au<+>c=S*0#_D?Z*q*gY;2&{b}^H&~x-T zwBJ(gPgHN4#yo>)6Ldh!YYBQvwSR)Pg}$kJzo*)JLi<8VdMos|Xx~Abp#KUne=f|N zzzqn...@ggpea($?oxtmm%zna5#dq3fhp...@tb+%o)<in_GUahqGG|(*Vo*SeQ=e z%=h...@!ae*al}vb<->)LNukYr|?#u0QNR^wV;pVq0s|=D`=KBP!HNp8bG_A#_-*6 zC+(w6+BO9bAY!|<5z4FHJS}T`0DnQ-NB7c8+95LNAGK++=wG!wwEkGZt)b(9H-x6q z=0XKT``*y~O4}Jo-G|;h...@0d%{dlo1_dojb^qv0g_)DQZ;CwN(M9UcQQThyN;c39B z...@tvzv8gz~n?+>$viEt-+=g^xcBYXvw$oA*y%i+({)AWt-9<={}-lyrG0k_e=gr7$H zZuk$N;XlHE3{DaG3gGP#h7U)c2Rt7s(DO>_Su!Fo(z8^jyo~ninetkj...@7qd$!n zJ=$j?-vR&E!2eD9dSqI8_c}N|%0ETE3;op...@fk0e_5xw7o~srj#w)NBbRUI}-gj zL|`r|!Sm7RdTLd^Jm7n3Mms5odOfG*C`}gHEhM$~=$Q8F6uFF4uDX5*jAuY_X&8ks zt?_*a?0_n=)qGy{ap$aEs+Y~XX=;9U-gMlYxn$Br-L>z*ohx#p7_k=qp...@6m40y z7O1f7xMqcpFI+T>f3lqnm2ys...@prlt+8&cyd#...@yo*d5+rwiheg7mbcoipjcn zSg5<EPs5S{Tg(-yxq8*LDrRoduGFluDGR2&WEIix5e(O|t...@asw=mfq0eiw8@d*( zvgIx}dVN2krRvyalkSt2YtC3zlcuYeENNFOX4R#mrVIIsQ7v)T1UmzPOQv*b-k!4S zupef#J%ysQY6yT;l(u7^cj2w$J67U2B7QJ5=QEpSL<=};s{)+2j~NxSG-bF(0l_mV zKW932T^7v~wq0g3n(@QS%-!H=?)Uqqmx^Xhjj(9CXJ<{vF&0hoR%9NuXt=~Z$7`m9 zWz|JLk4&2}tBdXh)qO(R2(@F&30b^=02SRjjDtCzA1g_kzaUMc1U2MAR4AKfO{r)$ zJYS+oFuG<lktQz~)y35$HlyGgZrvffb~ax%AFLakzcsu*%N)j5sq+hM9)|?EIdidI zHsthDO~M1j+98n4C9gfMg5yx$b3|EsL|SIGRQ7}G%o=X-0{dF1FH|h0A_#ngq6FdA z6f)|XYw1<THL68(#qAFnvh<K4oB4c`C+)Id5>d...@sv93qq#0duxiqk&w0g#JmH2Ty zW<GS&UI+10HNt^Z08^CUM5%<@osiO4rb3WN)q_|#s){jt...@b@bU=*1p)3Ed(m!i zA$*161(O$!CVK)3RABJ{4=*7Y)id5l8dkH~Rpo$ryP`FiVknt;ECMRp$Lxn#UBN8c z)sn-OLcCsfF_H%aWe1vHARGlAn4fTA#zy(`?1OB>5Knl{tl5~|%z46aptI`k-lfnZ zhE-O;G24ZW0XR{sm8~MLWL&B<sI__2GsDv>MaxA{_G={Ym8dvP5`Q-C{iI_zs8Ug3 zl...@xjq6hg%*hiu^bmc%rckq8r#tmfdpqcko8hmc1ik^ca@lF{_IIS43JGV$RjjL z9|x<WR9;f;G4xjev1(T42{))bRFN+D!<@kIHuxI-4u)KS1`Appv^EBB^tzz1b{kwc zx|_(O*8*fgE06XtZUhsfPl4+aup*uXv=VSlg~5jYi=c8)XlzoAQ1$UZ+67fdKn(C0 z%0s...@gashku(qHhpYmwDYQWwa>Z=Yr|Ka`pJt}KfXWjgI=kuXL~ti^x?^-h`pb* zj?{4kyp(03bqskJf{sUM7oY*sj?aRF{r95bBI0Xva^nb|*EL9TPFC5wZVvJWBC<?$ zb`sjSU>1Ka{r$)%*9u3}h4qYiBlZ((=pgg$btbfvvk...@-pmsa(j{X^m3`|Dr>&w zBkvz!uDMnGJ<U}VSnDcVT`y;2x2l8^xPtmy70K;KnsRqbt`DxB&b...@no^x)%...@v`y zDcocZHQT_GyWA8P9kwnZ%A6aHz%c&2I8>m$QAL~wZTF-v$+OPO$<5|$^LScca~!8s z{&`ka0r6~B)qe|~U=B8ToTk~#b5h5==8C%D>FMFw&edK*6ujk(*Mp1jWC7mcB{ix8 zr!%*zERGFVe;^U$-CHVa=;J!&%F5!|ydE9&=Qqv{H|F8p30P-imhig4s~NR(WWDHq zgt...@d(i{Kl!iUAG2S1B7yT?ux2nkMA}G$yR5W3pmTI?!N0q~&vx+amazMMWd<5D z&GXfhX;=hn...@q%4ulxjvps5ux=q=t=66>uk-}v...@pqy~hi94}#>oLAfijOMWO zVs0RboPdCLH+Z#Hwt;1+{S2TW$lB2Yob@)NMlws#!#iCtac)d2Z#kTFFSR(R?Yo(t zz$...@bpi>uGM9;R<q)}WA((qit~}e%3d}tqrgua5bzlw8d#w...@h;Gk!HVuX3Zc zh{*...@ufcf+eh*<={q}&#...@3k^b7p?`<6Z7K~5K-n-uW;eUST$Fom-`yJ=I%RgO5 z...@jrd|^r_8z-uMj8I^x~QuufW3*EG={K^u>drX?ddib_WD$(-y0-k#*1B$!eIsvTw_ z?oTEeibr(nw...@qx=zwx?1!qc;gU(3>d+Q^N=LST2f3vU5FKRcO_$bIF(PvlhKW- zS*;6-q...@nwoq#zz&YBO`U`hlzJcr4XNqW8SY5sRr>&}6(&Gowqp>d`m5us...@m z?yeXN5T-EaVneVv*`C^-8b}SN#_%_w+JjIz-QAVSD=Sj>sz);QK<bPz<MEWG{>I|n zuh...@7dkonusxpy|=Ltk8A#+0011l;o8baO7o%2ebT5Mv#TrLi1=o+A96IsLo2^2 zhk!qY`$ssP{}Fx#nk!5dp4wdQ`^3p7kA89co15nU>lvdon1wv$dde==`f...@ujte zg`U4CozoMgidE&$U<2...@r)qv-6~5d_ec*k7dcm!iel-0-i=c5xzbty_...@jny)<V zg^Q>0g>M>;8PIaI(gk_n3?dh2...@=18ns(_`SA4Jv(xr...@87v0p=g;^ggpJU<| z{q3ZWE9mx`5Kf`g(3kQ13gL&8%d6$Qle`nRpkKHNo#odk0maMElYo9_oM?&@<X>+e zCi;GmK+vW__~nRB;Whd!+G)J36>yq$9i...@jooh0q2=i<lubidk...@eem{p|^OV zj...@mlui+lqzsl5jcv#teerpu)zYK=F!V9oDTYVtM@(&6a!Aueh;>4u*n6Nx4zt{ z>9XP(#RrS`w+H*kC=?8#thJSqd7Wy0y=aW1gLf2_-{3t3UJ337&nWhR#?85F13!Di zuM7OL²#|-;Ek8`?tHKq$$ehD)%PFC4819(w...@fz+qfw&6kB3^Cq*+Oj3xYB>z zr?cm*kkz+xx...@dz3%koa5a%@dwdbuNwZaZ|oDtU;=*g3p#&ImSLIxKgvOr-u>E3 z2M#S&$~um`_zdM>?^tfMS2wFgn@@WV_MV(SGQ77}=W~vdQMRk*!QN%l={<CJd*T2- zpUuibd0B^os&lZnF01<;oDNhBXSfoalMNT`%6`MC<Svc%>Nse#&g1m)RP$(1rRyuo z...@+gv@I0;&15q^w-rag2{9qgt...@y0d7dwi^^snntv>PAeD%D2oA&JLRdN{HF^hE^ z4=(#SC=v%!u+uD^kk%!fN-mntZED>eXw`8w^k69}*4g42^O9NC%iJF9HJp6)lKnAL z_Ud(OqR2;a2Yb&OWykcLQc6Z{VohNB$ST_pjI0C!3<pMn3<2S6|Khss2w-Bhf%%Q5 p{pyr2f5g_wj...@ru|}y literal 0 HcmV?d00001 -- 1.5.4.1 _______________________________________________ Autotest mailing list [email protected] http://test.kernel.org/cgi-bin/mailman/listinfo/autotest
