Searched refs:rt (Results 1 – 8 of 8) sorted by relevance
74 Thread rt; field in PipedOutputStreamTest100 rt = new Thread(reader = new PReader(out)); in test_close()101 rt.start(); in test_close()126 rt = new Thread(reader = new PReader(out)); in test_connectLjava_io_PipedInputStream()127 rt.start(); in test_connectLjava_io_PipedInputStream()140 rt = new Thread(reader = new PReader(out)); in test_flush()141 rt.start(); in test_flush()153 rt = new Thread(reader = new PReader(out)); in test_write$BII()154 rt.start(); in test_write$BII()214 rt = new Thread(reader = new PReader(out)); in test_writeI()[all …]
145 CumulateTask<T> lt = t.left, rt = t.right, f; in compute() local148 f = rt = t.right = in compute()157 if (rt != null) { in compute()159 rt.in = (l == org ? lout : in compute()162 if (((c = rt.getPendingCount()) & CUMULATE) != 0) in compute()164 if (rt.compareAndSetPendingCount(c, c|CUMULATE)){ in compute()165 t = rt; in compute()231 int nextState; CumulateTask<T> lt, rt; in compute() local233 (rt = par.right) != null) { in compute()235 par.out = (rt.hi == fnc ? lout : in compute()[all …]
79 Thread rt; field in OldPipedOutputStreamTest117 rt = new Thread(reader = new PReader(out)); in test_close()118 rt.start(); in test_close()159 rt = new Thread(reader = new PReader(out)); in test_flush()160 rt.start(); in test_flush()204 rt = new Thread(reader = new PReader(out)); in test_write$BII()205 rt.start(); in test_write$BII()234 rt = new Thread(reader = new PReader(out)); in test_writeI()235 rt.start(); in test_writeI()266 if (rt != null) in tearDown()[all …]
134 RemoveThread rt = new RemoveThread(); in test_remove() local135 rt.start(); in test_remove()141 rt.interrupt(); in test_remove()210 RemoveThread rt = new RemoveThread(); in test_removeJ() local211 rt.start(); in test_removeJ()213 rt.inBlock.await(); in test_removeJ()217 rt.interrupt(); in test_removeJ()219 rt.outOfBlock.await(); in test_removeJ()
192 Class<?> rt = erasedType.returnType(); in MethodTypeForm() local193 Class<?> bt = rt; in MethodTypeForm()194 if (rt != Object.class) { in MethodTypeForm()196 Wrapper w = Wrapper.forPrimitiveType(rt); in MethodTypeForm()198 if (w.isSubwordOrInt() && rt != int.class) in MethodTypeForm()201 if (rt == void.class) in MethodTypeForm()206 if (epts == bpts && bt == rt) { in MethodTypeForm()
143 List<HttpCookie> rt = new ArrayList<HttpCookie>(); in getCookies() local153 } else if (!rt.contains(cookie)) { in getCookies()154 rt.add(cookie); in getCookies()159 rt = Collections.unmodifiableList(rt); in getCookies()164 return rt; in getCookies()
166 Runtime rt = Runtime.getRuntime(); in stuff() local168 Process proc = rt.exec("ls"); in stuff()175 rt.gc(); in stuff()176 rt = null; in stuff()
757 RunThread rt = new RunThread(); in test_run() local758 Thread t = new Thread(rt); in test_run()762 while (!rt.didThreadRun && count < 20) { in test_run()766 assertTrue("Thread did not run", rt.didThreadRun); in test_run()