summaryrefslogtreecommitdiffstats
path: root/tdeioslave/filter/filter.cpp
diff options
context:
space:
mode:
authorMichele Calgaro <[email protected]>2020-12-07 22:58:44 +0900
committerMichele Calgaro <[email protected]>2020-12-07 22:58:44 +0900
commit145abc15d57fb29701a12e8a14dcb9c1fd72e9be (patch)
treefbb4f2f737ec6f4e8a85bea5f2ca2257d20d7e22 /tdeioslave/filter/filter.cpp
parentd95494d97233919fa0b2eebf60759537b793e05b (diff)
downloadtdebase-145abc15d57fb29701a12e8a14dcb9c1fd72e9be.tar.gz
tdebase-145abc15d57fb29701a12e8a14dcb9c1fd72e9be.zip
Renaming of files in preparation for code style tools.
Signed-off-by: Michele Calgaro <[email protected]>
Diffstat (limited to 'tdeioslave/filter/filter.cpp')
-rw-r--r--tdeioslave/filter/filter.cpp167
1 files changed, 167 insertions, 0 deletions
diff --git a/tdeioslave/filter/filter.cpp b/tdeioslave/filter/filter.cpp
new file mode 100644
index 000000000..a429103e1
--- /dev/null
+++ b/tdeioslave/filter/filter.cpp
@@ -0,0 +1,167 @@
+/*
+This file is part of KDE
+
+ Copyright (C) 1999-2000 Waldo Bastian ([email protected])
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+*/
+
+#include <unistd.h>
+#include <stdio.h>
+#include <stdlib.h>
+
+#include <kinstance.h>
+#include <kdebug.h>
+#include <kmimemagic.h>
+#include <kfilterbase.h>
+
+#include "filter.h"
+
+extern "C" { KDE_EXPORT int kdemain(int argc, char **argv); }
+
+int kdemain( int argc, char ** argv)
+{
+ TDEInstance instance( "tdeio_filter" );
+
+ kdDebug(7110) << "Starting " << getpid() << endl;
+
+ if (argc != 4)
+ {
+ fprintf(stderr, "Usage: tdeio_filter protocol domain-socket1 domain-socket2\n");
+ exit(-1);
+ }
+
+ FilterProtocol slave(argv[1], argv[2], argv[3]);
+ slave.dispatchLoop();
+
+ kdDebug(7110) << "Done" << endl;
+ return 0;
+}
+
+FilterProtocol::FilterProtocol( const TQCString & protocol, const TQCString &pool, const TQCString &app )
+ : TDEIO::SlaveBase( protocol, pool, app )
+{
+ TQString mimetype = TQString::fromLatin1("application/x-") + TQString::fromLatin1(protocol);
+ filter = KFilterBase::findFilterByMimeType( mimetype );
+ Q_ASSERT(filter);
+}
+
+void FilterProtocol::get( const KURL & )
+{
+ if (subURL.isEmpty())
+ {
+ error( TDEIO::ERR_NO_SOURCE_PROTOCOL, mProtocol );
+ return;
+ }
+ if (!filter)
+ {
+ error( TDEIO::ERR_INTERNAL, mProtocol );
+ return;
+ }
+ needSubURLData();
+
+ filter->init(IO_ReadOnly);
+
+ bool bNeedHeader = true;
+ bool bNeedMimetype = true;
+ bool bError = true;
+ int result;
+
+ TQByteArray inputBuffer;
+ TQByteArray outputBuffer(8*1024); // Start with a modest buffer
+ filter->setOutBuffer( outputBuffer.data(), outputBuffer.size() );
+ while(true)
+ {
+ if (filter->inBufferEmpty())
+ {
+ dataReq(); // Request data
+ result = readData( inputBuffer);
+ kdDebug(7110) << "requestData: got " << result << endl;
+ if (result <= 0)
+ {
+ bError = true;
+ break; // Unexpected EOF.
+ }
+ filter->setInBuffer( inputBuffer.data(), inputBuffer.size() );
+ }
+ if (bNeedHeader)
+ {
+ bError = !filter->readHeader();
+ if (bError)
+ break;
+ bNeedHeader = false;
+ }
+ result = filter->uncompress();
+ if ((filter->outBufferAvailable() == 0) || (result == KFilterBase::END))
+ {
+ kdDebug(7110) << "avail_out = " << filter->outBufferAvailable() << endl;
+ if (filter->outBufferAvailable() != 0)
+ {
+ // Discard unused space :-)
+ outputBuffer.resize(outputBuffer.size() - filter->outBufferAvailable());
+ }
+ if (bNeedMimetype)
+ {
+ KMimeMagicResult * result = KMimeMagic::self()->findBufferFileType( outputBuffer, subURL.fileName() );
+ kdDebug(7110) << "Emitting mimetype " << result->mimeType() << endl;
+ mimeType( result->mimeType() );
+ bNeedMimetype = false;
+ }
+ data( outputBuffer ); // Send data
+ filter->setOutBuffer( outputBuffer.data(), outputBuffer.size() );
+ if (result == KFilterBase::END)
+ break; // Finished.
+ }
+ if (result != KFilterBase::OK)
+ {
+ bError = true;
+ break; // Error
+ }
+ }
+
+ if (!bError)
+ {
+ dataReq(); // Request data
+ result = readData( inputBuffer);
+ kdDebug(7110) << "requestData: got " << result << "(expecting 0)" << endl;
+ data( TQByteArray() ); // Send EOF
+ }
+
+ filter->terminate();
+
+ if (bError)
+ {
+ error(TDEIO::ERR_COULD_NOT_READ, subURL.url());
+ subURL = KURL(); // Clear subURL
+ return;
+ }
+
+ subURL = KURL(); // Clear subURL
+ finished();
+}
+
+void FilterProtocol::put( const KURL &/*url*/, int, bool /*_overwrite*/, bool /*_resume*/ )
+{
+ error( TDEIO::ERR_UNSUPPORTED_ACTION, TQString::fromLatin1("put"));
+}
+
+void FilterProtocol::setSubURL(const KURL &url)
+{
+ subURL = url;
+}
+