|
Lines 1483-1489
Link Here
|
| 1483 |
info = addList.get(); |
1483 |
info = addList.get(); |
| 1484 |
while (info != null) { |
1484 |
while (info != null) { |
| 1485 |
boolean comet = connections.get(Long.valueOf(info.socket)).isComet(); |
1485 |
boolean comet = connections.get(Long.valueOf(info.socket)).isComet(); |
| 1486 |
if (!comet || (comet && !processSocket(info.socket, SocketStatus.STOP))) { |
1486 |
if (!comet || !processSocket(info.socket, SocketStatus.STOP)) { |
| 1487 |
// Make sure the socket isn't in the poller before we close it |
1487 |
// Make sure the socket isn't in the poller before we close it |
| 1488 |
removeFromPoller(info.socket); |
1488 |
removeFromPoller(info.socket); |
| 1489 |
// Poller isn't running at this point so use destroySocket() |
1489 |
// Poller isn't running at this point so use destroySocket() |
|
Lines 1500-1507
Link Here
|
| 1500 |
for (int n = 0; n < rv; n++) { |
1500 |
for (int n = 0; n < rv; n++) { |
| 1501 |
boolean comet = connections.get( |
1501 |
boolean comet = connections.get( |
| 1502 |
Long.valueOf(desc[n*2+1])).isComet(); |
1502 |
Long.valueOf(desc[n*2+1])).isComet(); |
| 1503 |
if (!comet || (comet && !processSocket( |
1503 |
if (!comet || !processSocket(desc[n*2+1], SocketStatus.STOP)) { |
| 1504 |
desc[n*2+1], SocketStatus.STOP))) { |
|
|
| 1505 |
destroySocket(desc[n*2+1]); |
1504 |
destroySocket(desc[n*2+1]); |
| 1506 |
} |
1505 |
} |
| 1507 |
} |
1506 |
} |
|
Lines 1630-1637
Link Here
|
| 1630 |
removeFromPoller(socket); |
1629 |
removeFromPoller(socket); |
| 1631 |
boolean comet = connections.get( |
1630 |
boolean comet = connections.get( |
| 1632 |
Long.valueOf(socket)).isComet(); |
1631 |
Long.valueOf(socket)).isComet(); |
| 1633 |
if (!comet || (comet && !processSocket( |
1632 |
if (!comet || !processSocket(socket, SocketStatus.TIMEOUT)) { |
| 1634 |
socket, SocketStatus.TIMEOUT))) { |
|
|
| 1635 |
destroySocket(socket); |
1633 |
destroySocket(socket); |
| 1636 |
addList.remove(socket); |
1634 |
addList.remove(socket); |
| 1637 |
closeList.remove(socket); |
1635 |
closeList.remove(socket); |
|
Lines 1779-1786
Link Here
|
| 1779 |
if (!addToPoller(info.socket, wrapper.pollerFlags)) { |
1777 |
if (!addToPoller(info.socket, wrapper.pollerFlags)) { |
| 1780 |
// Can't do anything: close the socket right |
1778 |
// Can't do anything: close the socket right |
| 1781 |
// away |
1779 |
// away |
| 1782 |
if (!comet || (comet && !processSocket( |
1780 |
if (!comet || !processSocket(info.socket, SocketStatus.ERROR)) { |
| 1783 |
info.socket, SocketStatus.ERROR))) { |
|
|
| 1784 |
closeSocket(info.socket); |
1781 |
closeSocket(info.socket); |
| 1785 |
} |
1782 |
} |
| 1786 |
} else { |
1783 |
} else { |