nx_job_poll.nx source
↩ module page · 80 lines · 3434 B
1// nx_job_poll.nx -- R5 job-state tracking: poll Get-Job-Attributes for a job-id until it reaches a
2// terminal state. Confirms our print actually COMPLETED (vs silently stalling) -- the "said done but
3// nothing came out" killer. READ-ONLY -> never-brick. license_tier: ORIGINAL
4
5import "nx_syscalls.nx"
6import "nx_ipp_codec.nx"
7import "nx_ipp_transport.nx"
8import "nx_ipp_submit.nx"
9const K_MAGIC_2048: i64 = 2048
10const K_MAGIC_131072: i64 = 131072
11const K_MAGIC_1500: i64 = 1500
12
13const JOBID: i64 = 49 // the job we just submitted
14
15func p(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } sys_write(1, s, n); return 0 }
16func pn(v: i64) -> i64 {
17 if v == 0 { sys_write(1, "0" as *u8, 1); return 0 }
18 var m: i64 = v
19 let t: *u8 = sys_mmap(24); var k: i64 = 0
20 while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 }
21 let b: *u8 = sys_mmap(24); var i: i64 = 0
22 while i < k { b[i] = t[k - 1 - i]; i = i + 1 }
23 sys_write(1, b, k); return 0
24}
25func phex16(v: i64) -> i64 {
26 let hx: *u8 = "0123456789abcdef"; var sh: i64 = 12
27 while sh >= 0 { sys_write(1, ((hx as i64) + ((v >> sh) & 0xf)) as *u8, 1); sh = sh - 4 }
28 return 0
29}
30func jslabel(s: i64) -> *u8 {
31 if s == 3 { return "pending" as *u8 }
32 if s == 4 { return "pending-held" as *u8 }
33 if s == 5 { return "PROCESSING (printing)" as *u8 }
34 if s == 6 { return "processing-STOPPED" as *u8 }
35 if s == 7 { return "canceled" as *u8 }
36 if s == 8 { return "aborted" as *u8 }
37 if s == 9 { return "COMPLETED" as *u8 }
38 return "?" as *u8
39}
40
41func main() -> i64 {
42 let a: i64 = 192
43 let b: i64 = 168
44 let c: i64 = 8
45 let d: i64 = 127
46 p("=== POLL job-id "); pn(JOBID); p(" until terminal ===\n")
47 let req: *u8 = sys_mmap(K_MAGIC_2048)
48 let resp: *u8 = sys_mmap(K_MAGIC_131072)
49 let body: *u8 = sys_mmap(K_MAGIC_131072)
50 let out2: *i64 = sys_mmap(16) as *i64
51 let sc: *i64 = sys_mmap(64) as *i64
52 let js: *i64 = sys_mmap(8) as *i64
53
54 var tries: i64 = 0
55 var done: i64 = 0
56 while tries < 12 {
57 if done == 0 {
58 let rlen: i64 = nx_ipp_build_get_job_attrs(req, a, b, c, d, "/ipp/print", "nishi", JOBID)
59 let v: i64 = nx_ipt_post_ipp(a, b, c, d, 631, "/ipp/print", req, rlen, resp, K_MAGIC_131072, body, K_MAGIC_131072, 6, out2)
60 if v == NX_IPT_OK {
61 let st: i64 = nx_ipp_status(body)
62 p(" try "); pn(tries); p(": ipp=0x"); phex16(st)
63 if st == 0x0406 {
64 p(" job not found -> purged after COMPLETION (Brother clears finished jobs)\n")
65 done = 1
66 } else {
67 if nx_ipp_get_enum(body, out2[1], "job-state", sc, js) == NX_IPP_OK {
68 p(" job-state="); pn(js[0]); p(" "); p(jslabel(js[0])); p("\n")
69 if js[0] >= 7 { done = 1 }
70 if js[0] == 6 { p(" !! processing-STOPPED -- likely toner hard-stop; apply Continue-mode override.\n"); done = 1 }
71 } else { p(" (no job-state in response)\n") }
72 }
73 } else { p(" try "); pn(tries); p(": transport="); p(nx_ipt_verdict_name(v)); p("\n") }
74 if done == 0 { sys_sleep_ms(K_MAGIC_1500) }
75 }
76 tries = tries + 1
77 }
78 if done == 0 { p("(still processing after polling window -- check the printer)\n") }
79 sys_exit(0); return 0
80}