Page MenuHomePhorge
Files F16570839

No OneTemporary
Actions

View Options

diff --git a/kpty/tests/kptyprocesstest.cpp b/kpty/tests/kptyprocesstest.cpp
index 72c2aaf984..d932027554 100644
--- a/kpty/tests/kptyprocesstest.cpp
+++ b/kpty/tests/kptyprocesstest.cpp
@@ -1,195 +1,199 @@
/*
This file is part of the KDE libraries
Copyright (C) 2007 Oswald Buddenhagen <ossi@kde.org>
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Library General Public License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
Boston, MA 02110-1301, USA.
*/
#include "kptyprocesstest.h"
#include <kptydevice.h>
#include <qtest_kde.h>
void KPtyProcessTest::test_suspend_pty()
{
KPtyProcess p;
p.setPtyChannels(KPtyProcess::AllChannels);
p.setProgram("ping", QStringList() << "-i" << "0.5" << "localhost");
p.start();
// verify that data is available to read from the pty
QVERIFY(p.pty()->waitForReadyRead(1500));
// suspend the pty device and read all available data from it
p.pty()->setSuspended(true);
QVERIFY(p.pty()->isSuspended());
p.pty()->readAll();
// verify that no data was read by the pty
QVERIFY(!p.pty()->waitForReadyRead(1500));
// allow process to write more data
p.pty()->setSuspended(false);
QVERIFY(!p.pty()->isSuspended());
// verify that data is available once more
QVERIFY(p.pty()->waitForReadyRead(1500));
p.pty()->readAll();
p.terminate();
p.waitForFinished();
}
void KPtyProcessTest::test_shared_pty()
{
// start a first process
KPtyProcess p;
p.setProgram("cat");
p.setPtyChannels(KPtyProcess::AllChannels);
p.pty()->setEcho(false);
p.start();
// start a second process using the first one's fd
int fd = p.pty()->masterFd();
KPtyProcess p2(fd);
p2.setProgram("echo", QStringList() << "hello from me");
p2.setPtyChannels(KPtyProcess::AllChannels);
p2.pty()->setEcho(false);
p2.start();
// read the second processes greeting from the first process' pty
QVERIFY(p.pty()->waitForReadyRead(1000));
QCOMPARE(p.pty()->readAll(), QByteArray("hello from me\r\n"));
// write to the second process' pty
p2.pty()->write("hello from process 2\n");
QVERIFY(p2.pty()->waitForBytesWritten(1000));
// read the result back from the first process' pty
QVERIFY(p.pty()->waitForReadyRead(1000));
QCOMPARE(p.pty()->readAll(), QByteArray("hello from process 2\r\n"));
// write to the first process' pty
p.pty()->write("hi from process 1\n");
QVERIFY(p.pty()->waitForBytesWritten(1000));
// read the result back from the second process' pty
QVERIFY(p2.pty()->waitForReadyRead(1000));
QCOMPARE(p2.pty()->readAll(), QByteArray("hi from process 1\r\n"));
// cleanup
p.terminate();
p2.terminate();
p.waitForFinished(1000);
p2.waitForFinished(1000);
}
void KPtyProcessTest::test_pty_basic()
{
KPtyProcess p;
p.setProgram("/bin/bash", QStringList() << "-c" << "read -s VAL; echo \"1: $VAL\"; echo \"2: $VAL\" >&2");
p.setPtyChannels(KPtyProcess::AllChannels);
p.pty()->setEcho(false);
p.start();
p.pty()->write("test\n");
p.pty()->waitForBytesWritten(1000);
p.waitForFinished(1000);
p.pty()->waitForReadyRead(1000);
QString output = p.pty()->readAll();
QCOMPARE(output, QLatin1String("1: test\r\n2: test\r\n"));
}
void KPtyProcessTest::slotReadyRead()
{
delay.start(30);
}
void KPtyProcessTest::slotDoRead()
{
while (sp.pty()->canReadLine())
log.append('>').append(sp.pty()->readLine()).append("$\n");
log.append("!\n");
}
void KPtyProcessTest::slotReadEof()
{
log.append('|').append(sp.pty()->readAll()).append("$\n");
}
void KPtyProcessTest::slotBytesWritten()
{
log.append('<');
}
static const char * const feeds[] = {
"bla\n",
"foo\x04", "bar\n",
"fooish\nbar\n",
"\x04",
0
};
static const char want[] =
"<>bla\r\n$\n!\n"
"<!\n<>foobar\r\n$\n!\n"
"<>fooish\r\n$\n>bar\r\n$\n!\n"
"<|$\n"
;
void KPtyProcessTest::slotStep()
{
if (feeds[phase]) {
sp.pty()->write(feeds[phase]);
phase++;
}
}
void KPtyProcessTest::test_pty_signals()
{
sp.setShellCommand("cat; sleep .1");
sp.setPtyChannels(KPtyProcess::StdinChannel | KPtyProcess::StdoutChannel);
sp.pty()->setEcho(false);
connect(sp.pty(), SIGNAL(readyRead()), SLOT(slotReadyRead()));
connect(sp.pty(), SIGNAL(readEof()), SLOT(slotReadEof()));
connect(sp.pty(), SIGNAL(bytesWritten(qint64)), SLOT(slotBytesWritten()));
QTimer t;
connect(&t, SIGNAL(timeout()), SLOT(slotStep()));
t.start(50);
connect(&delay, SIGNAL(timeout()), SLOT(slotDoRead()));
delay.setSingleShot(true);
sp.start();
sp.pty()->closeSlave();
phase = 0;
QTest::kWaitForSignal(&sp, SIGNAL(finished(int, QProcess::ExitStatus)), 1000);
QCOMPARE(QLatin1String(log), QLatin1String(want));
}
void KPtyProcessTest::test_ctty()
{
+#ifdef Q_OS_MAC
+ QSKIP("This test currently hangs on OSX", SkipSingle);
+#else
KPtyProcess p;
p.setShellCommand("echo this is a test > /dev/tty");
p.execute(1000);
p.pty()->waitForReadyRead(1000);
QString output = p.pty()->readAll();
QCOMPARE(output, QLatin1String("this is a test\r\n"));
+#endif
}
QTEST_KDEMAIN_CORE( KPtyProcessTest )

File Metadata

Mime Type
text/x-diff
Expires
Fri, Nov 1, 9:40 AM (1 d, 19 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
10076061
Default Alt Text
(5 KB)

Event Timeline