corba/src/java.corba/share/classes/com/sun/corba/se/impl/transport/SelectorImpl.java
equal
deleted
inserted
replaced
59 /** |
59 /** |
60 * @author Harold Carr |
60 * @author Harold Carr |
61 */ |
61 */ |
62 class SelectorImpl |
62 class SelectorImpl |
63 extends |
63 extends |
64 sun.misc.ManagedLocalsThread |
64 Thread |
65 implements |
65 implements |
66 com.sun.corba.se.pept.transport.Selector |
66 com.sun.corba.se.pept.transport.Selector |
67 { |
67 { |
68 private ORB orb; |
68 private ORB orb; |
69 private Selector selector; |
69 private Selector selector; |
77 private ORBUtilSystemException wrapper; |
77 private ORBUtilSystemException wrapper; |
78 |
78 |
79 |
79 |
80 public SelectorImpl(ORB orb) |
80 public SelectorImpl(ORB orb) |
81 { |
81 { |
|
82 super(null, null, "ORB-Selector-Thread", 0, false); |
82 this.orb = orb; |
83 this.orb = orb; |
83 selector = null; |
84 selector = null; |
84 selectorStarted = false; |
85 selectorStarted = false; |
85 timeout = 60000; |
86 timeout = 60000; |
86 deferredRegistrations = new ArrayList(); |
87 deferredRegistrations = new ArrayList(); |
275 // Thread methods. |
276 // Thread methods. |
276 // |
277 // |
277 |
278 |
278 public void run() |
279 public void run() |
279 { |
280 { |
280 setName("SelectorThread"); |
|
281 while (!closed) { |
281 while (!closed) { |
282 try { |
282 try { |
283 int n = 0; |
283 int n = 0; |
284 if (timeout == 0 && orb.transportDebugFlag) { |
284 if (timeout == 0 && orb.transportDebugFlag) { |
285 dprint(".run: Beginning of selection cycle"); |
285 dprint(".run: Beginning of selection cycle"); |