KNetwork::KBufferedSocket
#include <k3bufferedsocket.h>

Public Member Functions | |
KBufferedSocket (const QString &node=QString(), const QString &service=QString(), QObject *parent=nullptr) | |
~KBufferedSocket () override | |
qint64 | bytesAvailable () const override |
qint64 | bytesToWrite () const override |
bool | canReadLine () const override |
void | close () override |
virtual void | closeNow () |
void | enableRead (bool enable) override |
void | enableWrite (bool enable) override |
void | setInputBuffering (bool enable) |
void | setOutputBuffering (bool enable) |
void | setSocketDevice (KSocketDevice *device) override |
void | waitForConnect () |
qint64 | waitForMore (int msecs, bool *timeout=nullptr) override |
![]() | |
KStreamSocket (const QString &node=QString(), const QString &service=QString(), QObject *parent=nullptr) | |
~KStreamSocket () override | |
bool | bind (const KResolverEntry &entry) override |
bool | bind (const QString &node=QString(), const QString &service=QString()) override |
bool | connect (const KResolverEntry &entry, OpenMode mode=ReadWrite) override |
bool | connect (const QString &node=QString(), const QString &service=QString(), OpenMode mode=ReadWrite) override |
int | remainingTimeout () const |
void | setTimeout (int msecs) |
int | timeout () const |
![]() | |
KClientSocketBase (QObject *parent) | |
~KClientSocketBase () override | |
qint64 | bytesAvailable () const override |
void | close () override |
bool | disconnect () override |
bool | emitsReadyRead () const |
bool | emitsReadyWrite () const |
virtual bool | flush () |
KSocketAddress | localAddress () const override |
KResolver & | localResolver () const |
const KResolverResults & | localResults () const |
virtual bool | lookup () |
bool | open (OpenMode mode) override |
KSocketAddress | peerAddress () const override |
KResolver & | peerResolver () const |
const KResolverResults & | peerResults () const |
void | setFamily (int families) |
void | setResolutionEnabled (bool enable) |
SocketState | state () const |
qint64 | waitForMore (int msecs, bool *timeout=nullptr) override |
![]() | |
KActiveSocketBase (QObject *parent) | |
~KActiveSocketBase () override | |
bool | atEnd () const override |
QString | errorString () const |
bool | isSequential () const override |
bool | open (OpenMode mode) override |
qint64 | peek (char *data, qint64 maxlen) |
qint64 | peek (char *data, qint64 maxlen, KSocketAddress &from) |
qint64 | pos () const override |
qint64 | read (char *data, qint64 maxlen) |
qint64 | read (char *data, qint64 maxlen, KSocketAddress &from) |
QByteArray | read (qint64 len) |
bool | seek (qint64) override |
void | setSocketDevice (KSocketDevice *device) override |
qint64 | size () const override |
void | ungetChar (char) |
qint64 | write (const char *data, qint64 len) |
qint64 | write (const char *data, qint64 len, const KSocketAddress &to) |
qint64 | write (const QByteArray &data) |
![]() | |
QIODevice (QObject *parent) | |
void | aboutToClose () |
void | bytesWritten (qint64 bytes) |
void | channelBytesWritten (int channel, qint64 bytes) |
void | channelReadyRead (int channel) |
void | commitTransaction () |
int | currentReadChannel () const const |
int | currentWriteChannel () const const |
QString | errorString () const const |
bool | getChar (char *c) |
bool | isOpen () const const |
bool | isReadable () const const |
bool | isTextModeEnabled () const const |
bool | isTransactionStarted () const const |
bool | isWritable () const const |
virtual bool | open (QIODevice::OpenMode mode) |
QIODevice::OpenMode | openMode () const const |
qint64 | peek (char *data, qint64 maxSize) |
QByteArray | peek (qint64 maxSize) |
bool | putChar (char c) |
qint64 | read (char *data, qint64 maxSize) |
QByteArray | read (qint64 maxSize) |
QByteArray | readAll () |
int | readChannelCount () const const |
void | readChannelFinished () |
qint64 | readLine (char *data, qint64 maxSize) |
QByteArray | readLine (qint64 maxSize) |
void | readyRead () |
virtual bool | reset () |
void | rollbackTransaction () |
void | setCurrentReadChannel (int channel) |
void | setCurrentWriteChannel (int channel) |
void | setTextModeEnabled (bool enabled) |
qint64 | skip (qint64 maxSize) |
void | startTransaction () |
void | ungetChar (char c) |
virtual bool | waitForBytesWritten (int msecs) |
virtual bool | waitForReadyRead (int msecs) |
qint64 | write (const char *data) |
qint64 | write (const char *data, qint64 maxSize) |
qint64 | write (const QByteArray &byteArray) |
int | writeChannelCount () const const |
![]() | |
QObject (QObject *parent) | |
bool | blockSignals (bool block) |
const QObjectList & | children () const const |
QMetaObject::Connection | connect (const QObject *sender, const char *signal, const char *method, Qt::ConnectionType type) const const |
void | deleteLater () |
void | destroyed (QObject *obj) |
bool | disconnect (const char *signal, const QObject *receiver, const char *method) const const |
bool | disconnect (const QObject *receiver, const char *method) const const |
void | dumpObjectInfo () |
void | dumpObjectInfo () const const |
void | dumpObjectTree () |
void | dumpObjectTree () const const |
QList< QByteArray > | dynamicPropertyNames () const const |
virtual bool | event (QEvent *e) |
virtual bool | eventFilter (QObject *watched, QEvent *event) |
T | findChild (const QString &name, Qt::FindChildOptions options) const const |
QList< T > | findChildren (const QRegExp ®Exp, Qt::FindChildOptions options) const const |
QList< T > | findChildren (const QRegularExpression &re, Qt::FindChildOptions options) const const |
QList< T > | findChildren (const QString &name, Qt::FindChildOptions options) const const |
bool | inherits (const char *className) const const |
void | installEventFilter (QObject *filterObj) |
bool | isWidgetType () const const |
bool | isWindowType () const const |
void | killTimer (int id) |
virtual const QMetaObject * | metaObject () const const |
void | moveToThread (QThread *targetThread) |
QString | objectName () const const |
void | objectNameChanged (const QString &objectName) |
QObject * | parent () const const |
QVariant | property (const char *name) const const |
Q_CLASSINFO (Name, Value) | |
Q_DISABLE_COPY (Class) | |
Q_DISABLE_COPY_MOVE (Class) | |
Q_DISABLE_MOVE (Class) | |
Q_EMIT Q_EMIT | |
Q_ENUM (...) | |
Q_ENUM_NS (...) | |
Q_ENUMS (...) | |
Q_FLAG (...) | |
Q_FLAG_NS (...) | |
Q_FLAGS (...) | |
Q_GADGET Q_GADGET | |
Q_INTERFACES (...) | |
Q_INVOKABLE Q_INVOKABLE | |
Q_NAMESPACE Q_NAMESPACE | |
Q_NAMESPACE_EXPORT (EXPORT_MACRO) | |
Q_OBJECT Q_OBJECT | |
Q_PROPERTY (...) | |
Q_REVISION Q_REVISION | |
Q_SET_OBJECT_NAME (Object) | |
Q_SIGNAL Q_SIGNAL | |
Q_SIGNALS Q_SIGNALS | |
Q_SLOT Q_SLOT | |
Q_SLOTS Q_SLOTS | |
T | qFindChild (const QObject *obj, const QString &name) |
QList< T > | qFindChildren (const QObject *obj, const QRegExp ®Exp) |
QList< T > | qFindChildren (const QObject *obj, const QString &name) |
T | qobject_cast (const QObject *object) |
T | qobject_cast (QObject *object) |
QT_NO_NARROWING_CONVERSIONS_IN_CONNECT QT_NO_NARROWING_CONVERSIONS_IN_CONNECT | |
void | removeEventFilter (QObject *obj) |
void | setObjectName (const QString &name) |
void | setParent (QObject *parent) |
bool | setProperty (const char *name, const QVariant &value) |
bool | signalsBlocked () const const |
int | startTimer (int interval, Qt::TimerType timerType) |
int | startTimer (std::chrono::milliseconds time, Qt::TimerType timerType) |
QThread * | thread () const const |
![]() | |
KSocketBase () | |
virtual | ~KSocketBase () |
bool | addressReuseable () const |
bool | blocking () const |
bool | broadcast () const |
SocketError | error () const |
QString | errorString () const |
bool | isIPv6Only () const |
QMutex * | mutex () const |
bool | noDelay () const |
virtual bool | setAddressReuseable (bool enable) |
virtual bool | setBlocking (bool enable) |
virtual bool | setBroadcast (bool enable) |
virtual bool | setIPv6Only (bool enable) |
virtual bool | setNoDelay (bool enable) |
int | setRequestedCapabilities (int add, int remove=0) |
KSocketDevice * | socketDevice () const |
Protected Slots | |
void | slotReadActivity () override |
void | slotWriteActivity () override |
![]() | |
virtual void | slotReadActivity () |
virtual void | slotWriteActivity () |
Protected Member Functions | |
qint64 | peekData (char *data, qint64 maxlen, KSocketAddress *from) override |
qint64 | readData (char *data, qint64 maxlen, KSocketAddress *from) override |
qint64 | readLineData (char *data, qint64 maxSize) override |
bool | setSocketOptions (int opts) override |
void | stateChanging (SocketState newState) override |
qint64 | writeData (const char *data, qint64 len, const KSocketAddress *to) override |
![]() | |
void | copyError () |
qint64 | peekData (char *data, qint64 maxlen, KSocketAddress *from) override |
qint64 | readData (char *data, qint64 maxlen, KSocketAddress *from) override |
bool | setSocketOptions (int opts) override |
void | setState (SocketState state) |
qint64 | writeData (const char *data, qint64 len, const KSocketAddress *to) override |
![]() | |
qint64 | readData (char *data, qint64 len) override |
void | resetError () |
void | setError (SocketError error) |
qint64 | writeData (const char *data, qint64 len) override |
![]() | |
void | setErrorString (const QString &str) |
void | setOpenMode (QIODevice::OpenMode openMode) |
![]() | |
virtual void | childEvent (QChildEvent *event) |
virtual void | connectNotify (const QMetaMethod &signal) |
virtual void | customEvent (QEvent *event) |
virtual void | disconnectNotify (const QMetaMethod &signal) |
bool | isSignalConnected (const QMetaMethod &signal) const const |
int | receivers (const char *signal) const const |
QObject * | sender () const const |
int | senderSignalIndex () const const |
virtual void | timerEvent (QTimerEvent *event) |
![]() | |
bool | hasDevice () const |
void | resetError () |
void | setError (SocketError error) |
virtual int | socketOptions () const |
Additional Inherited Members | |
![]() | |
enum | SocketState { Idle, HostLookup, HostFound, Bound, Connecting, Open, Closing, Unconnected = Bound, Connected = Open, Connection = Open } |
![]() | |
enum | OpenModeFlag |
![]() | |
enum | SocketError { NoError = 0, LookupFailure, AddressInUse, AlreadyCreated, AlreadyBound, AlreadyConnected, NotConnected, NotBound, NotCreated, WouldBlock, ConnectionRefused, ConnectionTimedOut, InProgress, NetFailure, NotSupported, Timeout, UnknownError, RemotelyDisconnected } |
enum | SocketOptions { Blocking = 0x01, AddressReuseable = 0x02, IPv6Only = 0x04, Keepalive = 0x08, Broadcast = 0x10, NoDelay = 0x20 } |
![]() | |
objectName | |
![]() | |
void | timedOut () |
![]() | |
void | aboutToConnect (const KNetwork::KResolverEntry &remote, bool &skip) |
void | bound (const KNetwork::KResolverEntry &local) |
void | closed () |
void | connected (const KNetwork::KResolverEntry &remote) |
void | gotError (int code) |
void | hostFound () |
void | readyWrite () |
void | stateChanged (int newstate) |
![]() | |
QMetaObject::Connection | connect (const QObject *sender, const char *signal, const QObject *receiver, const char *method, Qt::ConnectionType type) |
QMetaObject::Connection | connect (const QObject *sender, const QMetaMethod &signal, const QObject *receiver, const QMetaMethod &method, Qt::ConnectionType type) |
QMetaObject::Connection | connect (const QObject *sender, PointerToMemberFunction signal, const QObject *context, Functor functor, Qt::ConnectionType type) |
QMetaObject::Connection | connect (const QObject *sender, PointerToMemberFunction signal, const QObject *receiver, PointerToMemberFunction method, Qt::ConnectionType type) |
QMetaObject::Connection | connect (const QObject *sender, PointerToMemberFunction signal, Functor functor) |
bool | disconnect (const QMetaObject::Connection &connection) |
bool | disconnect (const QObject *sender, const char *signal, const QObject *receiver, const char *method) |
bool | disconnect (const QObject *sender, const QMetaMethod &signal, const QObject *receiver, const QMetaMethod &method) |
bool | disconnect (const QObject *sender, PointerToMemberFunction signal, const QObject *receiver, PointerToMemberFunction method) |
QString | tr (const char *sourceText, const char *disambiguation, int n) |
QString | trUtf8 (const char *sourceText, const char *disambiguation, int n) |
![]() | |
static QString | errorString (SocketError code) |
static bool | isFatalError (int code) |
![]() | |
Append | |
ExistingOnly | |
NewOnly | |
NotOpen | |
typedef | OpenMode |
ReadOnly | |
ReadWrite | |
Text | |
Truncate | |
Unbuffered | |
WriteOnly | |
![]() | |
typedef | QObjectList |
Detailed Description
Buffered stream sockets.
This class allows the user to create and operate buffered stream sockets such as those used in most Internet connections. This class is also the one that resembles the most to the old QSocket implementation.
Objects of this type operate only in non-blocking mode. A call to setBlocking(true) will result in an error.
- Note
- Buffered sockets only make sense if you're using them from the main (event-loop) thread. This is actually a restriction imposed by Qt's QSocketNotifier. If you want to use a socket in an auxiliary thread, please use KStreamSocket.
- Deprecated:
- Use KSocketFactory or KLocalSocket instead
Definition at line 59 of file k3bufferedsocket.h.
Constructor & Destructor Documentation
◆ KBufferedSocket()
|
explicit |
Default constructor.
- Parameters
-
node destination host service destination service to connect to parent the parent object for this object
Definition at line 51 of file k3bufferedsocket.cpp.
◆ ~KBufferedSocket()
|
override |
Destructor.
Definition at line 60 of file k3bufferedsocket.cpp.
Member Function Documentation
◆ bytesAvailable()
|
overridevirtual |
Make use of the buffers.
Reimplemented from QIODevice.
Definition at line 99 of file k3bufferedsocket.cpp.
◆ bytesToWrite()
|
overridevirtual |
Returns the length of the output buffer.
Reimplemented from QIODevice.
Definition at line 251 of file k3bufferedsocket.cpp.
◆ canReadLine()
|
overridevirtual |
Returns true if a line can be read with readLine()
Reimplemented from QIODevice.
Definition at line 268 of file k3bufferedsocket.cpp.
◆ close()
|
overridevirtual |
Closes the socket for new data, but allow data that had been buffered for output with writeData() to be still be written.
- See also
- closeNow
Reimplemented from QIODevice.
Definition at line 85 of file k3bufferedsocket.cpp.
◆ closeNow()
|
virtual |
Closes the socket and discards any output data that had been buffered with writeData() but that had not yet been written.
- See also
- close
Definition at line 260 of file k3bufferedsocket.cpp.
◆ enableRead()
|
overridevirtual |
Catch changes.
Reimplemented from KNetwork::KClientSocketBase.
Definition at line 179 of file k3bufferedsocket.cpp.
◆ enableWrite()
|
overridevirtual |
Catch changes.
Reimplemented from KNetwork::KClientSocketBase.
Definition at line 198 of file k3bufferedsocket.cpp.
◆ peekData()
|
overrideprotectedvirtual |
Peeks data from the socket.
The from
parameter is always set to peerAddress()
Implements KNetwork::KActiveSocketBase.
Definition at line 134 of file k3bufferedsocket.cpp.
◆ readData()
|
overrideprotectedvirtual |
Reads data from a socket.
The from
parameter is always set to peerAddress()
Implements KNetwork::KActiveSocketBase.
Definition at line 119 of file k3bufferedsocket.cpp.
◆ readLineData()
|
overrideprotectedvirtual |
Improve the readLine performance.
Reimplemented from QIODevice.
Definition at line 277 of file k3bufferedsocket.cpp.
◆ setInputBuffering()
void KBufferedSocket::setInputBuffering | ( | bool | enable | ) |
Sets the use of input buffering.
Definition at line 229 of file k3bufferedsocket.cpp.
◆ setOutputBuffering()
void KBufferedSocket::setOutputBuffering | ( | bool | enable | ) |
Sets the use of output buffering.
Definition at line 240 of file k3bufferedsocket.cpp.
◆ setSocketDevice()
|
overridevirtual |
Be sure to catch new devices.
Reimplemented from KNetwork::KSocketBase.
Definition at line 68 of file k3bufferedsocket.cpp.
◆ setSocketOptions()
|
overrideprotectedvirtual |
Buffered sockets can only operate in non-blocking mode.
Reimplemented from KNetwork::KSocketBase.
Definition at line 75 of file k3bufferedsocket.cpp.
◆ slotReadActivity
|
overrideprotectedslot |
Slot called when there's read activity.
Definition at line 293 of file k3bufferedsocket.cpp.
◆ slotWriteActivity
|
overrideprotectedslot |
Slot called when there's write activity.
Definition at line 333 of file k3bufferedsocket.cpp.
◆ stateChanging()
|
overrideprotectedvirtual |
Catch connection to clear the buffers.
Reimplemented from KNetwork::KClientSocketBase.
Definition at line 210 of file k3bufferedsocket.cpp.
◆ waitForConnect()
void KBufferedSocket::waitForConnect | ( | ) |
Blocks until the connection is either established, or completely failed.
Definition at line 282 of file k3bufferedsocket.cpp.
◆ waitForMore()
|
overridevirtual |
Make use of buffers.
Implements KNetwork::KActiveSocketBase.
Definition at line 108 of file k3bufferedsocket.cpp.
◆ writeData()
|
overrideprotectedvirtual |
Writes data to the socket.
The to
parameter is discarded.
Implements KNetwork::KActiveSocketBase.
Definition at line 149 of file k3bufferedsocket.cpp.
The documentation for this class was generated from the following files:
Documentation copyright © 1996-2023 The KDE developers.
Generated on Mon May 8 2023 03:56:01 by doxygen 1.8.17 written by Dimitri van Heesch, © 1997-2006
KDE's Doxygen guidelines are available online.