| 49 | // ============================================================================= |
| 50 | |
| 51 | void StreamThreadRtp::doStartStreaming(const int clientID) { |
| 52 | const int streamID = _stream.getStreamID(); |
| 53 | SocketAttr &rtp = _stream.getStreamClient(clientID).getRtpSocketAttr(); |
| 54 | |
| 55 | // RTP |
| 56 | if (!rtp.setupSocketHandle(SOCK_DGRAM, IPPROTO_UDP)) { |
| 57 | SI_LOG_ERROR("Stream: %d, Get RTP handle failed", streamID); |
| 58 | } |
| 59 | |
| 60 | // Get default buffer size and set it x times as big |
| 61 | const int bufferSize = rtp.getNetworkSendBufferSize() * 20; |
| 62 | rtp.setNetworkSendBufferSize(bufferSize); |
| 63 | SI_LOG_INFO("Stream: %d, %s set network buffer size: %d KBytes", streamID, |
| 64 | _protocol.c_str(), bufferSize / 1024); |
| 65 | |
| 66 | // RTCP |
| 67 | _rtcp.startStreaming(clientID); |
| 68 | } |
| 69 | |
| 70 | void StreamThreadRtp::doPauseStreaming(const int clientID) { |
| 71 | // RTCP |
nothing calls this directly
no test coverage detected