Changeset 937 in ntrip for trunk/BNC/bncapp.cpp
- Timestamp:
- Jun 8, 2008, 5:48:54 PM (16 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/BNC/bncapp.cpp
r936 r937 98 98 _sockets = 0; 99 99 100 _portCorr = 0; 101 _serverCorr = 0; 102 _socketsCorr = 0; 103 100 104 _pgmName = _bncVersion.leftJustified(20, ' ', true); 101 105 #ifdef WIN32 … … 117 121 delete _server; 118 122 delete _sockets; 123 delete _serverCorr; 124 delete _socketsCorr; 119 125 if (_rinexVers == 2) { 120 126 delete _ephStreamGlonass; … … 555 561 } 556 562 563 // Set Port Number 564 //////////////////////////////////////////////////////////////////////////// 565 void bncApp::setPortCorr(int port) { 566 _portCorr = port; 567 if (_portCorr != 0) { 568 _serverCorr = new QTcpServer; 569 _serverCorr->listen(QHostAddress::Any, _portCorr); 570 connect(_serverCorr, SIGNAL(newConnection()), this, SLOT(slotNewConnectionCorr())); 571 _socketsCorr = new QList<QTcpSocket*>; 572 } 573 } 574 557 575 // New Connection 558 576 //////////////////////////////////////////////////////////////////////////// 559 577 void bncApp::slotNewConnection() { 560 578 _sockets->push_back( _server->nextPendingConnection() ); 579 } 580 581 // New Connection 582 //////////////////////////////////////////////////////////////////////////// 583 void bncApp::slotNewConnectionCorr() { 584 _socketsCorr->push_back( _serverCorr->nextPendingConnection() ); 561 585 } 562 586 … … 569 593 } 570 594 571 572 595 // 573 596 //////////////////////////////////////////////////////////////////////////// 574 597 void bncApp::slotNewCorrLine(QString line) { 575 cout << line.toAscii().data() << endl; 576 } 598 if (_socketsCorr) { 599 QMutableListIterator<QTcpSocket*> is(*_socketsCorr); 600 while (is.hasNext()) { 601 QTcpSocket* sock = is.next(); 602 if (sock->state() == QAbstractSocket::ConnectedState) { 603 if (sock->write(line.toAscii()) == -1) { 604 delete sock; 605 is.remove(); 606 } 607 } 608 else if (sock->state() != QAbstractSocket::ConnectingState) { 609 delete sock; 610 is.remove(); 611 } 612 } 613 } 614 }
Note:
See TracChangeset
for help on using the changeset viewer.