outgoingQueue should be a class ------------------------------- Key: ZOOKEEPER-879 URL: https://issues.apache.org/jira/browse/ZOOKEEPER-879 Project: Zookeeper Issue Type: Sub-task Reporter: Thomas Koch
I'm not yet 100% sure about this yet, but it seems reasonable to me. Currently outgoingQueue is a simple list. Whether additional items can be added to the queue and the logic to add sth to the queue is handled by ClientCnxn. class OutgoingQueue - isOpen + add(Packet) / offer(Packet) + poll() / take() OutgoingQueue must have knowledge about the state of SendThreat and may only accept additional Packets if SendThread has not yet terminated. OutgoingQueue knows, when it must call ConnectionLoss on the remaining Packets in its queue. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.