Lines Matching refs:tcpMessageProcessor
100 private TCPMessageProcessor tcpMessageProcessor;
120 TCPMessageProcessor msgProcessor) throws IOException {
138 this.tcpMessageProcessor = msgProcessor;
139 this.myPort = this.tcpMessageProcessor.getPort();
155 TCPMessageProcessor messageProcessor) throws IOException {
165 this.tcpMessageProcessor = messageProcessor;
465 ((TCPMessageProcessor) this.messageProcessor).cacheMessageChannel(this);
603 this.tcpMessageProcessor.useCount++;
615 synchronized (tcpMessageProcessor) {
616 tcpMessageProcessor.nConnections--;
617 tcpMessageProcessor.notify();
641 synchronized (tcpMessageProcessor) {
642 tcpMessageProcessor.nConnections--;
644 tcpMessageProcessor.notify();
661 this.tcpMessageProcessor.remove(this);
662 this.tcpMessageProcessor.useCount--;
670 this.tcpMessageProcessor.remove(this);
