| 516 | } |
| 517 | |
| 518 | bool StreamingSocket::connect (const String& remoteHostName, int remotePortNumber, int timeOutMillisecs) |
| 519 | { |
| 520 | jassert (SocketHelpers::isValidPortNumber (remotePortNumber)); |
| 521 | |
| 522 | if (isListener) |
| 523 | { |
| 524 | // a listener socket can't connect to another one! |
| 525 | jassertfalse; |
| 526 | return false; |
| 527 | } |
| 528 | |
| 529 | if (connected) |
| 530 | close(); |
| 531 | |
| 532 | hostName = remoteHostName; |
| 533 | portNumber = remotePortNumber; |
| 534 | isListener = false; |
| 535 | |
| 536 | connected = SocketHelpers::connectSocket (handle, readLock, remoteHostName, |
| 537 | remotePortNumber, timeOutMillisecs); |
| 538 | |
| 539 | if (! connected) |
| 540 | return false; |
| 541 | |
| 542 | if (! SocketHelpers::resetSocketOptions ((SocketHandle) handle.load(), false, false)) |
| 543 | { |
| 544 | close(); |
| 545 | return false; |
| 546 | } |
| 547 | |
| 548 | return true; |
| 549 | } |
| 550 | |
| 551 | void StreamingSocket::close() |
| 552 | { |
no test coverage detected