qcopenvelope_qws.cpp

Go to the documentation of this file.

/**********************************************************************
** Copyright (C) 2000-2002 Trolltech AS.  All rights reserved.
**
** This file is part of the Qtopia Environment.
**
** This file may be distributed and/or modified under the terms of the
** GNU General Public License version 2 as published by the Free Software
** Foundation and appearing in the file LICENSE.GPL included in the
** packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.trolltech.com/gpl/ for GPL licensing information.
**
** Contact info@trolltech.com if any conditions of this licensing are
** not clear to you.
**
**********************************************************************/

#ifndef QT_NO_COP
#include "qcopenvelope_qws.h"
#endif
#include <qbuffer.h>
#include <qfile.h>
#include <unistd.h>
#include <errno.h>
#include <sys/file.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <time.h>

#ifndef QT_NO_COP

QCopEnvelope::QCopEnvelope( const QCString& channel, const QCString& message ) :
    QDataStream(new QBuffer),
    ch(channel), msg(message)
{
    device()->open(IO_WriteOnly);
}

QCopEnvelope::~QCopEnvelope()
{
    QByteArray data = ((QBuffer*)device())->buffer();
    const int pref=16;
    if ( qstrncmp(ch.data(),"QPE/Application/",pref)==0 ) {
        QString qcopfn("/tmp/qcop-msg-");
        qcopfn += ch.mid(pref);
        QFile qcopfile(qcopfn);

        if ( qcopfile.open(IO_WriteOnly | IO_Append) ) {
#ifndef Q_OS_WIN32
            if(flock(qcopfile.handle(), LOCK_EX)) {
                /* some error occurred */
                qWarning(QString("Failed to obtain file lock on %1 (%2)")
                        .arg(qcopfn).arg( errno ));
            }
#endif
            {
                QDataStream ds(&qcopfile);
                ds << ch << msg << data;
                qcopfile.flush();
#ifndef Q_OS_WIN32
                flock(qcopfile.handle(), LOCK_UN);
#endif
                qcopfile.close();
            }

            QByteArray b;
            QDataStream stream(b, IO_WriteOnly);
            stream << QString(ch.mid(pref));
            QCopChannel::send("QPE/Server", "processQCop(QString)", b);
            delete device();
            return;
        } else {
            qWarning(QString("Failed to open file %1")
                        .arg(qcopfn));
        } // endif open
    }
    else if (qstrncmp(ch.data(), "QPE/SOAP/", 9) == 0) {
      // If this is a message that should go along the SOAP channel, we move the
      // endpoint URL to the data section.
      QString endpoint = ch.mid(9);

      ch = "QPE/SOAP";
      // Since byte arrays are explicitly shared, this is appended to the data variable..
      *this << endpoint;
    }

    QCopChannel::send(ch,msg,data);
    delete device();
}

#endif

---