27 #include <tqsocketnotifier.h> 30 #include "ksocketaddress.h" 31 #include "kresolver.h" 32 #include "ksocketbase.h" 33 #include "ksocketdevice.h" 34 #include "kstreamsocket.h" 35 #include "kbufferedsocket.h" 36 #include "kserversocket.h" 40 class KNetwork::KServerSocketPrivate
46 enum { None, LookupDone, Bound, Listening } state;
50 bool bindWhenFound : 1, listenWhenBound : 1, useKBufferedSocket : 1;
52 KServerSocketPrivate()
53 : state(None), timeout(0), bindWhenFound(false), listenWhenBound(false),
54 useKBufferedSocket(true)
56 resolver.
setFlags(KResolver::Passive);
57 resolver.
setFamily(KResolver::KnownFamily);
62 : TQObject(parent, name), d(new KServerSocketPrivate)
65 this, TQT_SLOT(lookupFinishedSlot()));
69 : TQObject(parent, name), d(new KServerSocketPrivate)
72 this, TQT_SLOT(lookupFinishedSlot()));
73 d->resolver.setServiceName(service);
77 TQObject* parent,
const char* name)
78 : TQObject(parent, name), d(new KServerSocketPrivate)
81 this, TQT_SLOT(lookupFinishedSlot()));
93 TQMutexLocker locker(
mutex());
107 return d->resolverResults;
113 d->resolver.setFlags(d->resolver.flags() & ~
KResolver::NoResolve);
115 d->resolver.setFlags(d->resolver.flags() | KResolver::NoResolve);
120 d->resolver.setFamily(families);
125 d->resolver.setNodeName(TQString::null);
126 d->resolver.setServiceName(service);
127 d->resolverResults.empty();
128 if (d->state <= KServerSocketPrivate::LookupDone)
129 d->state = KServerSocketPrivate::None;
134 d->resolver.setNodeName(node);
135 d->resolver.setServiceName(service);
136 d->resolverResults.empty();
137 if (d->state <= KServerSocketPrivate::LookupDone)
138 d->state = KServerSocketPrivate::None;
149 if (d->resolver.isRunning() && !
blocking())
152 if (d->state >= KServerSocketPrivate::LookupDone)
156 if (d->resolver.serviceName().isNull() &&
157 !d->resolver.nodeName().isNull())
158 d->resolver.setServiceName(TQString::fromLatin1(
""));
166 if (d->resolver.status() <= 0)
188 d->state = KServerSocketPrivate::Bound;
210 if (d->state >= KServerSocketPrivate::Bound)
213 if (d->state < KServerSocketPrivate::LookupDone)
217 d->bindWhenFound =
true;
219 if (d->state >= KServerSocketPrivate::Bound)
220 d->bindWhenFound =
false;
239 if (d->state == KServerSocketPrivate::Listening)
242 d->backlog = backlog;
244 if (d->state < KServerSocketPrivate::Bound)
248 d->listenWhenBound =
true;
251 d->listenWhenBound =
false;
255 if (d->state < KServerSocketPrivate::Bound)
260 d->listenWhenBound =
false;
263 if (d->state < KServerSocketPrivate::Listening)
272 if (d->resolver.isRunning())
273 d->resolver.cancel(
false);
274 d->state = KServerSocketPrivate::None;
280 d->useKBufferedSocket = enable;
285 if (d->state < KServerSocketPrivate::Listening)
322 if (d->useKBufferedSocket)
331 streamsocket->
setState(KStreamSocket::Connected);
332 streamsocket->setFlags(IO_Sequential | IO_Raw | IO_ReadWrite | IO_Open | IO_Async);
347 void KServerSocket::lookupFinishedSlot()
349 if (d->resolver.isRunning() || d->state > KServerSocketPrivate::LookupDone)
352 if (d->resolver.status() < 0)
356 d->bindWhenFound = d->listenWhenBound =
false;
357 d->state = KServerSocketPrivate::None;
362 d->resolverResults = d->resolver.results();
363 d->state = KServerSocketPrivate::LookupDone;
366 if (d->bindWhenFound)
375 bool KServerSocket::doBind()
377 d->bindWhenFound =
false;
380 KResolverResults::ConstIterator it = d->resolverResults.begin();
381 for ( ; it != d->resolverResults.end(); ++it)
384 if (d->listenWhenBound)
396 bool KServerSocket::doListen()
406 TQObject::connect(
socketDevice()->readNotifier(), TQT_SIGNAL(activated(
int)),
408 d->state = KServerSocketPrivate::Listening;
413 #include "kserversocket.moc" virtual KSocketAddress externalAddress() const
Returns this socket's externally-visible address if know.
bool blocking() const
Retrieves this socket's blocking mode.
KSocketDevice * socketDevice() const
Retrieves the socket implementation used on this socket.
virtual KSocketAddress localAddress() const
Returns this socket's local address.
const KResolverResults & resolverResults() const
Returns the internal list of resolved results for the binding address.
virtual KSocketDevice * accept()
Accepts a new incoming connection.
Abstract class for active sockets.
void setFamily(int families)
Sets the allowed socket families.
TQMutex * mutex() const
Returns the internal mutex for this class.
Name and service resolution class.
SocketError error() const
Retrieves the socket error code.
A generic socket address.
void bound(const KResolverEntry &local)
This signal is emitted when the socket successfully binds to an address.
virtual bool listen(int backlog=5)
Puts this socket into listening mode.
Name and service resolution results.
virtual bool setSocketOptions(int opts)
This implementation sets the options on the socket.
void setAddress(const TQString &service)
Sets the address on which we will listen.
~KServerSocket()
Destructor.
A namespace to store all networking-related (socket) classes.
void gotError(int code)
This signal is emitted when this object finds an error.
void setError(SocketError error)
Sets the socket's error code.
void setResolutionEnabled(bool enable)
Enables or disables name resolution.
void setTimeout(int msecs)
Sets the timeout for accepting.
void setState(SocketState state)
Sets the socket state to state.
virtual bool setSocketOptions(int opts)
Set the given socket options.
void closed()
This signal is emitted when the socket completes the closing/shut down process.
void hostFound()
This signal is emitted when the lookup is successfully completed.
virtual KActiveSocketBase * accept()
Accepts one incoming connection and return the associated, open socket.
virtual bool bind()
Binds the socket to the addresses previously set with setAddress.
KServerSocket(TQObject *parent=0L, const char *name=0L)
Default constructor.
virtual void close()
Closes the socket.
virtual void setSocketDevice(KSocketDevice *device)
Sets the socket implementation to be used on this socket.
virtual KSocketAddress localAddress() const
Returns this socket's local address.
virtual void close()
Closes this socket.
void readyAccept()
This signal is emitted whenever the socket is ready for accepting – i.e., there is at least one conn...
void copyError()
Convenience function to set this object's error code to match that of the socket device.
Low-level socket functionality.
void setAcceptBuffered(bool enable)
Toggles whether the accepted socket will be buffered or not.
void setFamily(int families)
Sets the allowed families for the resolutions.
int setFlags(int flags)
Sets the flags.
KResolver & resolver() const
Returns the internal KResolver object used for looking up the host name and service.
virtual bool setSocketOptions(int opts)
Sets the socket options.
virtual KSocketAddress externalAddress() const
Returns this socket's externally visible local address.
virtual bool lookup()
Starts the lookup for peer and local hostnames as well as their services.