Searched refs:tcpMessageProcessor (Results 1 – 2 of 2) sorted by relevance
100 private TCPMessageProcessor tcpMessageProcessor; field in TCPMessageChannel138 this.tcpMessageProcessor = msgProcessor; in TCPMessageChannel()139 this.myPort = this.tcpMessageProcessor.getPort(); in TCPMessageChannel()165 this.tcpMessageProcessor = messageProcessor; in TCPMessageChannel()603 this.tcpMessageProcessor.useCount++; in run()615 synchronized (tcpMessageProcessor) { in run()616 tcpMessageProcessor.nConnections--; in run()617 tcpMessageProcessor.notify(); in run()641 synchronized (tcpMessageProcessor) { in run()642 tcpMessageProcessor.nConnections--; in run()[all …]
1946 TCPMessageProcessor tcpMessageProcessor = new TCPMessageProcessor(ipAddress, this, in createMessageProcessor() local1948 this.addMessageProcessor(tcpMessageProcessor); in createMessageProcessor()1950 return tcpMessageProcessor; in createMessageProcessor()