#include <DccFileTransfer.h>
◆ DccSendThread()
◆ ~DccSendThread()
DccSendThread::~DccSendThread |
( |
| ) |
|
◆ ackedBytes()
quint64 DccSendThread::ackedBytes |
( |
| ) |
|
|
inline |
◆ averageSpeed()
uint DccSendThread::averageSpeed |
( |
| ) |
|
|
inline |
◆ bandwidthLimit()
unsigned int DccSendThread::bandwidthLimit |
( |
| ) |
|
|
inline |
◆ doneGetInfo()
void DccSendThread::doneGetInfo |
( |
| ) |
|
◆ filePosition()
quint64 DccSendThread::filePosition |
( |
| ) |
|
|
inline |
◆ initGetInfo()
void DccSendThread::initGetInfo |
( |
| ) |
|
◆ instantSpeed()
uint DccSendThread::instantSpeed |
( |
| ) |
|
|
inline |
◆ run()
void DccSendThread::run |
( |
| ) |
|
|
protectedvirtual |
Reimplemented from KviThread.
References __tr2qs_ctx, KviError::AcknowledgeError, KviMemory::allocate(), KviDccSendThreadOptions::bFastSend, KviDccSendThreadOptions::bIsTdcc, KviDccSendThreadOptions::bNoAcks, _ack_buffer::cAckBuffer, KviError::CantOpenFileForReading, KviError::CantSendAZeroSizeFile, KviSensitiveThread::dequeueEvent(), e, KviError::FileIOError, KviMemory::free(), DccThread::handleInvalidSocketRead(), _ack_buffer::i32AckBuffer, KviDccSendThreadOptions::iIdleStepLengthInMSec, INSTANT_BANDWIDTH_CHECK_INTERVAL_IN_MSECS, INSTANT_BANDWIDTH_CHECK_INTERVAL_IN_SECS, KviDccSendThreadOptions::iPacketSize, KVI_DCC_THREAD_EVENT_MESSAGE, KVI_DCC_THREAD_EVENT_SUCCESS, KVI_INVALID_SOCKET, kvi_select(), kvi_socket_close, kvi_socket_error(), kvi_socket_recv(), kvi_socket_send(), KVI_THREAD_EVENT_TERMINATE, KviMutex::lock(), DccThread::m_fd, DccThread::m_pMutex, m_pOpt, m_pTimeInterval, m_uAckedBytes, m_uFilePosition, m_uInstantSentBytes, m_uInstantSpeedInterval, m_uStartTime, m_uTotalSentBytes, KviMSecTimeInterval::mark(), MAX_DCC_BANDWIDTH_LIMIT, KviThread::msleep(), DccThread::parent(), DccThread::postErrorEvent(), KviThread::postEvent(), KviCString::ptr(), KviMSecTimeInterval::secondsCounter(), KviError::SSLError, KviDccSendThreadOptions::szFileName, KviError::translateSystemError(), KviDccSendThreadOptions::uMaxBandwidth, KviMutex::unlock(), updateStats(), and KviDccSendThreadOptions::uStartPosition.
◆ sentBytes()
quint64 DccSendThread::sentBytes |
( |
| ) |
|
|
inline |
◆ setBandwidthLimit()
void DccSendThread::setBandwidthLimit |
( |
unsigned int | uMaxBandwidth | ) |
|
|
inline |
◆ updateStats()
void DccSendThread::updateStats |
( |
| ) |
|
|
protected |
References KviDccSendThreadOptions::bNoAcks, INSTANT_BANDWIDTH_CHECK_INTERVAL_IN_MSECS, INSTANT_BANDWIDTH_CHECK_INTERVAL_IN_SECS, KviMutex::lock(), DccThread::m_pMutex, m_pOpt, m_pTimeInterval, m_uAckedBytes, m_uAverageSpeed, m_uInstantSentBytes, m_uInstantSpeed, m_uInstantSpeedInterval, m_uStartTime, m_uTotalSentBytes, KviMSecTimeInterval::mark(), KviMSecTimeInterval::secondsCounter(), KviMutex::unlock(), and KviDccSendThreadOptions::uStartPosition.
Referenced by run().
◆ m_pOpt
◆ m_pTimeInterval
◆ m_uAckedBytes
quint64 DccSendThread::m_uAckedBytes = 0 |
|
private |
◆ m_uAverageSpeed
uint DccSendThread::m_uAverageSpeed |
|
private |
◆ m_uFilePosition
quint64 DccSendThread::m_uFilePosition |
|
private |
◆ m_uInstantSentBytes
quint64 DccSendThread::m_uInstantSentBytes |
|
private |
◆ m_uInstantSpeed
uint DccSendThread::m_uInstantSpeed |
|
private |
◆ m_uInstantSpeedInterval
unsigned long DccSendThread::m_uInstantSpeedInterval |
|
private |
◆ m_uStartTime
unsigned long DccSendThread::m_uStartTime |
|
private |
◆ m_uTotalSentBytes
quint64 DccSendThread::m_uTotalSentBytes = 0 |
|
private |
The documentation for this class was generated from the following files: