private void finishPacket ( Packet p ) { if ( p . watcherRegistration != null ) { if ( ErrorCode . OK . equals ( p . respHeader . getErr ( ) ) ) { this . watcherManager . register ( p . watcherRegistration ) ; } } synchronized ( p ) { p . finished = true ; PacketLatency . finishPacket ( p ) ; if ( p . cb == null && p . future == null ) { p . notifyAll ( ) ; } } eventThread . queuePacket ( p ) ; }
The Packet finished .