aboutsummaryrefslogtreecommitdiff
path: root/src/plugins/Transports/mms
diff options
context:
space:
mode:
Diffstat (limited to 'src/plugins/Transports/mms')
-rw-r--r--src/plugins/Transports/mms/mmsinputsource.cpp1
-rw-r--r--src/plugins/Transports/mms/mmsstreamreader.cpp9
2 files changed, 9 insertions, 1 deletions
diff --git a/src/plugins/Transports/mms/mmsinputsource.cpp b/src/plugins/Transports/mms/mmsinputsource.cpp
index d6b303800..436b3c033 100644
--- a/src/plugins/Transports/mms/mmsinputsource.cpp
+++ b/src/plugins/Transports/mms/mmsinputsource.cpp
@@ -25,6 +25,7 @@ MMSInputSource::MMSInputSource(const QString &url, QObject *parent) : InputSourc
{
m_reader = new MMSStreamReader(url, this);
connect(m_reader, SIGNAL(ready()),SIGNAL(ready()));
+ connect(m_reader, SIGNAL(error()),SIGNAL(error()));
}
QIODevice *MMSInputSource::ioDevice()
diff --git a/src/plugins/Transports/mms/mmsstreamreader.cpp b/src/plugins/Transports/mms/mmsstreamreader.cpp
index 712432546..4d4ce34af 100644
--- a/src/plugins/Transports/mms/mmsstreamreader.cpp
+++ b/src/plugins/Transports/mms/mmsstreamreader.cpp
@@ -139,6 +139,8 @@ void MMSStreamReader::run()
if(!m_handle)
{
qWarning("MMSStreamReader: connection failed");
+ setErrorString("connection failed");
+ emit error();
return;
}
m_mutex.lock();
@@ -162,8 +164,13 @@ void MMSStreamReader::run()
len = mmsx_read (0, m_handle, m_buffer + m_buffer_at, to_read);
if(len < 0)
{
- qWarning("MMSStreamReader: error: %s", strerror(len));
m_mutex.unlock();
+ qWarning("MMSStreamReader: mms thread funished with code %lld (%s)", len, strerror(len));
+ if(!m_aborted && !m_ready)
+ {
+ setErrorString(strerror(len));
+ emit error();
+ }
break;
}
m_buffer_at += len;