176 |
176 |
177 // close down all the event queues |
177 // close down all the event queues |
178 // Closing a queue causes a VMDisconnectEvent to |
178 // Closing a queue causes a VMDisconnectEvent to |
179 // be put onto the queue. |
179 // be put onto the queue. |
180 synchronized(eventQueues) { |
180 synchronized(eventQueues) { |
181 Iterator iter = eventQueues.iterator(); |
181 Iterator<EventQueue> iter = eventQueues.iterator(); |
182 while (iter.hasNext()) { |
182 while (iter.hasNext()) { |
183 ((EventQueueImpl)iter.next()).close(); |
183 ((EventQueueImpl)iter.next()).close(); |
184 } |
184 } |
185 } |
185 } |
186 |
186 |
187 // indirectly throw VMDisconnectedException to |
187 // indirectly throw VMDisconnectedException to |
188 // command requesters. |
188 // command requesters. |
189 synchronized(waitingQueue) { |
189 synchronized(waitingQueue) { |
190 Iterator iter = waitingQueue.values().iterator(); |
190 Iterator<Packet> iter = waitingQueue.values().iterator(); |
191 while (iter.hasNext()) { |
191 while (iter.hasNext()) { |
192 Packet packet = (Packet)iter.next(); |
192 Packet packet = iter.next(); |
193 synchronized(packet) { |
193 synchronized(packet) { |
194 packet.notify(); |
194 packet.notify(); |
195 } |
195 } |
196 } |
196 } |
197 waitingQueue.clear(); |
197 waitingQueue.clear(); |
250 } |
250 } |
251 |
251 |
252 void notifyDequeueEventSet() { |
252 void notifyDequeueEventSet() { |
253 int maxQueueSize = 0; |
253 int maxQueueSize = 0; |
254 synchronized(eventQueues) { |
254 synchronized(eventQueues) { |
255 Iterator iter = eventQueues.iterator(); |
255 Iterator<EventQueue> iter = eventQueues.iterator(); |
256 while (iter.hasNext()) { |
256 while (iter.hasNext()) { |
257 EventQueueImpl queue = (EventQueueImpl)iter.next(); |
257 EventQueueImpl queue = (EventQueueImpl)iter.next(); |
258 maxQueueSize = Math.max(maxQueueSize, queue.size()); |
258 maxQueueSize = Math.max(maxQueueSize, queue.size()); |
259 } |
259 } |
260 } |
260 } |
263 |
263 |
264 private void queueEventSet(EventSet eventSet) { |
264 private void queueEventSet(EventSet eventSet) { |
265 int maxQueueSize = 0; |
265 int maxQueueSize = 0; |
266 |
266 |
267 synchronized(eventQueues) { |
267 synchronized(eventQueues) { |
268 Iterator iter = eventQueues.iterator(); |
268 Iterator<EventQueue> iter = eventQueues.iterator(); |
269 while (iter.hasNext()) { |
269 while (iter.hasNext()) { |
270 EventQueueImpl queue = (EventQueueImpl)iter.next(); |
270 EventQueueImpl queue = (EventQueueImpl)iter.next(); |
271 queue.enqueue(eventSet); |
271 queue.enqueue(eventSet); |
272 maxQueueSize = Math.max(maxQueueSize, queue.size()); |
272 maxQueueSize = Math.max(maxQueueSize, queue.size()); |
273 } |
273 } |