diff options
author | Michele Calgaro <michele.calgaro@yahoo.it> | 2020-12-06 21:23:48 +0900 |
---|---|---|
committer | Michele Calgaro <michele.calgaro@yahoo.it> | 2020-12-06 21:24:20 +0900 |
commit | 4f99f868f09bbffa2e15733b8b7c78eba07a199e (patch) | |
tree | 3fb0957e93160f69f55942fff50a2ad496bf4f4c /arts/kde/kiotestslow.cc | |
parent | 19f44e5ff3756172540e768fc0d08d761f0c374e (diff) | |
download | tdelibs-4f99f868f09bbffa2e15733b8b7c78eba07a199e.tar.gz tdelibs-4f99f868f09bbffa2e15733b8b7c78eba07a199e.zip |
Renaming of files in preparation for code style tools.
Signed-off-by: Michele Calgaro <michele.calgaro@yahoo.it>
Diffstat (limited to 'arts/kde/kiotestslow.cc')
-rw-r--r-- | arts/kde/kiotestslow.cc | 131 |
1 files changed, 0 insertions, 131 deletions
diff --git a/arts/kde/kiotestslow.cc b/arts/kde/kiotestslow.cc deleted file mode 100644 index 93bfac388..000000000 --- a/arts/kde/kiotestslow.cc +++ /dev/null @@ -1,131 +0,0 @@ -#include <stdio.h> -#include <kmedia2.h> -#include <tdecmdlineargs.h> -#include <connect.h> -#include <tdelocale.h> -#include <tdeapplication.h> -#include <tdeaboutdata.h> -#include <stdsynthmodule.h> -#include "qiomanager.h" -#include "artskde.h" - -using namespace std; -using namespace Arts; - -namespace Arts { -/* simulate slow receiver */ -class KIOTestSlow_impl : public KIOTestSlow_skel, - public TimeNotify, - public StdSynthModule -{ - int pos; - list< DataPacket<mcopbyte>* > q; - InputStream _inputStream; - -public: - InputStream inputStream() { return _inputStream; } - void inputStream(InputStream i) { _inputStream = i; } - - KIOTestSlow_impl() - { - Dispatcher::the()->ioManager()->addTimer(10, this); - pos = 0; - } - void notifyTime() - { - if(!_inputStream.isNull() && _inputStream.eof()) - { - printf("\n[*EOF*] remaining = %d packets\n"); - _inputStream = InputStream::null(); - return; - } - - int TODO = 100; - do { - if(q.empty()) - return; - - DataPacket<mcopbyte> *p = q.front(); - char ch = p->contents[pos++]; - if(p->size == pos) - { - p->processed(); - q.pop_front(); - pos = 0; - } - - if(ch == '\n') - { - long size = 0; - list<DataPacket<mcopbyte>*>::iterator i; - for(i = q.begin(); i != q.end(); i++) - size += (*i)->size; - printf("\n[queued %8ld] ",size-pos); - } - else - putchar(ch); - - } while(TODO-- > 0); - } - void process_data(DataPacket<mcopbyte> *p) - { - if(p->size == 0) - p->processed(); - else - q.push_back(p); - } -}; -REGISTER_IMPLEMENTATION(KIOTestSlow_impl); -}; - -static TDECmdLineOptions options[] = -{ - { "+[URL]", I18N_NOOP("URL to open"), 0 }, - TDECmdLineLastOption -}; - -#undef USE_FILEINPUTSTREAM - -int main(int argc, char **argv) -{ - TDEAboutData aboutData( "kiotestslow", I18N_NOOP("KIOTest"), I18N_NOOP("0.1"), "", TDEAboutData::License_GPL, ""); - - TDECmdLineArgs::init(argc,argv,&aboutData); - TDECmdLineArgs::addCmdLineOptions(options); - TDEApplication app; - QIOManager qiomanager; - Dispatcher dispatcher(&qiomanager); -#ifndef USE_FILEINPUTSTREAM - TDEIOInputStream stream; -#else - FileInputStream stream; -#endif - KIOTestSlow writer; - - TDECmdLineArgs *args = TDECmdLineArgs::parsedArgs(); - - if(args->count()) - { -#ifdef USE_FILEINPUTSTREAM - if(!stream.open(args->arg(0))) -#else - if(!stream.openURL(args->arg(0))) -#endif - { - printf("can't open url"); - exit(1); - } - } - else - exit(1); - - args->clear(); - - writer.inputStream(stream); - connect(stream, writer); - - writer.start(); - stream.start(); - - app.exec(); -} |