Actually move the kde files that were renamed in the last commit

1 files changed, 0 insertions, 424 deletions

diff --git a/kdecore/network/kbufferedsocket.cpp b/kdecore/network/kbufferedsocket.cpp
deleted file mode 100644
index ffac2e98b..000000000
--- a/kdecore/network/kbufferedsocket.cpp
+++ /dev/null
@@ -1,424 +0,0 @@
-/*  -*- C++ -*-
- *  Copyright (C) 2003-2005 Thiago Macieira <thiago.macieira@kdemail.net>
- *
- *
- *  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, sublicense, 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 OR COPYRIGHT HOLDERS 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 <config.h>
-
-#include <tqmutex.h>
-#include <tqtimer.h>
-
-#include "ksocketdevice.h"
-#include "ksocketaddress.h"
-#include "ksocketbuffer_p.h"
-#include "kbufferedsocket.h"
-
-using namespace KNetwork;
-using namespace KNetwork::Internal;
-
-class KNetwork::KBufferedSocketPrivate
-{
-public:
-  mutable KSocketBuffer *input, *output;
-
-  KBufferedSocketPrivate()
-  {
-    input = 0L;
-    output = 0L;
-  }
-};
-
-KBufferedSocket::KBufferedSocket(const TQString& host, const TQString& service,
-				 TQObject *parent, const char *name)
-  : KStreamSocket(host, service, parent, name),
-    d(new KBufferedSocketPrivate)
-{
-  setInputBuffering(true);
-  setOutputBuffering(true);
-}
-
-KBufferedSocket::~KBufferedSocket()
-{
-  closeNow();
-  delete d->input;
-  delete d->output;
-  delete d;
-}
-
-void KBufferedSocket::setSocketDevice(KSocketDevice* device)
-{
-  KStreamSocket::setSocketDevice(device);
-  device->setBlocking(false);
-}
-
-bool KBufferedSocket::setSocketOptions(int opts)
-{
-  if (opts == Blocking)
-    return false;
-
-  opts &= ~Blocking;
-  return KStreamSocket::setSocketOptions(opts);
-}
-
-void KBufferedSocket::close()
-{
-  if (!d->output || d->output->isEmpty())
-    closeNow();
-  else
-    {
-      setState(Closing);
-      TQSocketNotifier *n = socketDevice()->readNotifier();
-      if (n)
-	n->setEnabled(false);
-      emit stateChanged(Closing);
-    }
-}
-
-#ifdef USE_QT3
-TQ_LONG KBufferedSocket::bytesAvailable() const
-#endif
-#ifdef USE_QT4
-qint64 KBufferedSocket::bytesAvailable() const
-#endif
-{
-  if (!d->input)
-    return KStreamSocket::bytesAvailable();
-
-  return d->input->length();
-}
-
-TQ_LONG KBufferedSocket::waitForMore(int msecs, bool *timeout)
-{
-  TQ_LONG retval = KStreamSocket::waitForMore(msecs, timeout);
-  if (d->input)
-    {
-      resetError();
-      slotReadActivity();
-      return bytesAvailable();
-    }
-  return retval;
-}
-
-TQT_TQIO_LONG KBufferedSocket::tqreadBlock(char *data, TQT_TQIO_ULONG maxlen)
-{
-  if (d->input)
-    {
-      if (d->input->isEmpty())
-	{
-	  setError(IO_ReadError, WouldBlock);
-	  emit gotError(WouldBlock);
-	  return -1;
-	}
-      resetError();
-      return d->input->consumeBuffer(data, maxlen);
-    }
-  return KStreamSocket::tqreadBlock(data, maxlen);
-}
-
-TQT_TQIO_LONG KBufferedSocket::tqreadBlock(char *data, TQT_TQIO_ULONG maxlen, KSocketAddress& from)
-{
-  from = peerAddress();
-  return tqreadBlock(data, maxlen);
-}
-
-TQ_LONG KBufferedSocket::peekBlock(char *data, TQ_ULONG maxlen)
-{
-  if (d->input)
-    {
-      if (d->input->isEmpty())
-	{
-	  setError(IO_ReadError, WouldBlock);
-	  emit gotError(WouldBlock);
-	  return -1;
-	}
-      resetError();
-      return d->input->consumeBuffer(data, maxlen, false);
-    }
-  return KStreamSocket::peekBlock(data, maxlen);
-}
-
-TQ_LONG KBufferedSocket::peekBlock(char *data, TQ_ULONG maxlen, KSocketAddress& from)
-{
-  from = peerAddress();
-  return peekBlock(data, maxlen);
-}
-
-TQT_TQIO_LONG KBufferedSocket::tqwriteBlock(const char *data, TQT_TQIO_ULONG len)
-{
-  if (state() != Connected)
-    {
-      // cannot write now!
-      setError(IO_WriteError, NotConnected);
-      return -1;
-    }
-
-  if (d->output)
-    {
-      if (d->output->isFull())
-	{
-	  setError(IO_WriteError, WouldBlock);
-	  emit gotError(WouldBlock);
-	  return -1;
-	}
-      resetError();
-
-      // enable notifier to send data
-      TQSocketNotifier *n = socketDevice()->writeNotifier();
-      if (n)
-	n->setEnabled(true);
-
-      return d->output->feedBuffer(data, len);
-    }
-
-  return KStreamSocket::tqwriteBlock(data, len);
-}
-
-TQT_TQIO_LONG KBufferedSocket::tqwriteBlock(const char *data, TQT_TQIO_ULONG maxlen,
-				   const KSocketAddress&)
-{
-  // ignore the third parameter
-  return tqwriteBlock(data, maxlen);
-}
-
-void KBufferedSocket::enableRead(bool enable)
-{
-  KStreamSocket::enableRead(enable);
-  if (!enable && d->input)
-    {
-      // reenable it
-      TQSocketNotifier *n = socketDevice()->readNotifier();
-      if (n)
-	n->setEnabled(true);
-    }
-
-  if (enable && state() != Connected && d->input && !d->input->isEmpty())
-    // this means the buffer is still dirty
-    // allow the signal to be emitted
-    TQTimer::singleShot(0, this, TQT_SLOT(slotReadActivity()));
-}
-
-void KBufferedSocket::enableWrite(bool enable)
-{
-  KStreamSocket::enableWrite(enable);
-  if (!enable && d->output && !d->output->isEmpty())
-    {
-      // reenable it
-      TQSocketNotifier *n = socketDevice()->writeNotifier();
-      if (n)
-	n->setEnabled(true);
-    }
-}
-
-void KBufferedSocket::stateChanging(SocketState newState)
-{
-  if (newState == Connecting || newState == Connected)
-    {
-      // we're going to connect
-      // make sure the buffers are clean
-      if (d->input)
-	d->input->clear();
-      if (d->output)
-	d->output->clear();
-
-      // also, turn on notifiers
-      enableRead(emitsReadyRead());
-      enableWrite(emitsReadyWrite());
-    }
-  KStreamSocket::stateChanging(newState);
-}
-
-void KBufferedSocket::setInputBuffering(bool enable)
-{
-  TQMutexLocker locker(mutex());
-  if (!enable)
-    {
-      delete d->input;
-      d->input = 0L;
-    }
-  else if (d->input == 0L)
-    {
-      d->input = new KSocketBuffer;
-    }
-}
-
-KIOBufferBase* KBufferedSocket::inputBuffer()
-{
-  return d->input;
-}
-
-void KBufferedSocket::setOutputBuffering(bool enable)
-{
-  TQMutexLocker locker(mutex());
-  if (!enable)
-    {
-      delete d->output;
-      d->output = 0L;
-    }
-  else if (d->output == 0L)
-    {
-      d->output = new KSocketBuffer;
-    }
-}
-
-KIOBufferBase* KBufferedSocket::outputBuffer()
-{
-  return d->output;
-}
-
-#ifdef USE_QT3
-TQ_ULONG KBufferedSocket::bytesToWrite() const
-#endif
-#ifdef USE_QT4
-qint64 KBufferedSocket::bytesToWrite() const
-#endif
-{
-  if (!d->output)
-    return 0;
-
-  return d->output->length();
-}
-
-void KBufferedSocket::closeNow()
-{
-  KStreamSocket::close();
-  if (d->output)
-    d->output->clear();
-}
-
-bool KBufferedSocket::canReadLine() const
-{
-  if (!d->input)
-    return false;
-
-  return d->input->canReadLine();
-}
-
-TQCString KBufferedSocket::readLine()
-{
-  return d->input->readLine();
-}
-
-void KBufferedSocket::waitForConnect()
-{
-  if (state() != Connecting)
-    return;			// nothing to be waited on
-
-  KStreamSocket::setSocketOptions(socketOptions() | Blocking);
-  connectionEvent();
-  KStreamSocket::setSocketOptions(socketOptions() & ~Blocking);
-}
-
-void KBufferedSocket::slotReadActivity()
-{
-  if (d->input && state() == Connected)
-    {
-      mutex()->lock();
-      TQ_LONG len = d->input->receiveFrom(socketDevice());
-
-      if (len == -1)
-	{
-	  if (socketDevice()->error() != WouldBlock)
-	    {
-	      // nope, another error!
-	      copyError();
-	      mutex()->unlock();
-	      emit gotError(error());
-	      closeNow();	// emits closed
-	      return;
-	    }
-	}
-      else if (len == 0)
-	{
-	  // remotely closed
-	  setError(IO_ReadError, RemotelyDisconnected);
-	  mutex()->unlock();
-	  emit gotError(error());
-	  closeNow();		// emits closed
-	  return;
-	}
-
-      // no error
-      mutex()->unlock();
-    }
-
-  if (state() == Connected)
-    KStreamSocket::slotReadActivity(); // this emits readyRead
-  else if (emitsReadyRead())	// state() != Connected
-    {
-      if (d->input && !d->input->isEmpty())
-	{
-	  // buffer isn't empty
-	  // keep emitting signals till it is
-	  TQTimer::singleShot(0, this, TQT_SLOT(slotReadActivity()));
-	  emit readyRead();
-	}
-    }
-}
-
-void KBufferedSocket::slotWriteActivity()
-{
-  if (d->output && !d->output->isEmpty() &&
-      (state() == Connected || state() == Closing))
-    {
-      mutex()->lock();
-      TQ_LONG len = d->output->sendTo(socketDevice());
-
-      if (len == -1)
-	{
-	  if (socketDevice()->error() != WouldBlock)
-	    {
-	      // nope, another error!
-	      copyError();
-	      mutex()->unlock();
-	      emit gotError(error());
-	      closeNow();
-	      return;
-	    }
-	}
-      else if (len == 0)
-	{
-	  // remotely closed
-	  setError(IO_ReadError, RemotelyDisconnected);
-	  mutex()->unlock();
-	  emit gotError(error());
-	  closeNow();
-	  return;
-	}
-
-      if (d->output->isEmpty())
-	// deactivate the notifier until we have something to send
-	// writeNotifier can't return NULL here
-	socketDevice()->writeNotifier()->setEnabled(false);
-
-      mutex()->unlock();
-      emit bytesWritten(len);
-    }
-
-  if (state() != Closing)
-    KStreamSocket::slotWriteActivity();
-  else if (d->output && d->output->isEmpty() && state() == Closing)
-    {
-      KStreamSocket::close();	// finished sending data
-    }
-}
-
-#include "kbufferedsocket.moc"