Package org.freedesktop.dbus.bin

Class DBusDaemon

java.lang.Object

java.lang.Thread

org.freedesktop.dbus.bin.DBusDaemon

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class DBusDaemon
extends Thread
implements Closeable

A replacement DBusDaemon

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DBusDaemon.ConnectionStruct
class	DBusDaemon.DBusDaemonReaderThread
class	DBusDaemon.DBusDaemonSenderThread
class	DBusDaemon.DBusServer
(package private) static class	DBusDaemon.Pair<A,B>

Nested classes/interfaces inherited from class java.lang.Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<DBusDaemon.ConnectionStruct,DBusDaemon.DBusDaemonReaderThread>	conns
private final DBusDaemon.DBusServer	dbusServer
private final BlockingDeque<DBusDaemon.Pair<Message,WeakReference<DBusDaemon.ConnectionStruct>>>	inqueue
private static final org.slf4j.Logger	LOGGER
private final Map<String,DBusDaemon.ConnectionStruct>	names
private final AtomicInteger	nextUnique
private final BlockingDeque<DBusDaemon.Pair<Message,WeakReference<DBusDaemon.ConnectionStruct>>>	outqueue
static final int	QUEUE_POLL_WAIT
private final AtomicBoolean	run
private final DBusDaemon.DBusDaemonSenderThread	sender
private final List<DBusDaemon.ConnectionStruct>	sigrecips
private final AbstractTransport	transport

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
DBusDaemon(AbstractTransport _transport)

Method Summary

Modifier and Type	Method	Description
(package private) void	addSock(TransportConnection _s)
void	close()
private DBusSignal	generatedNameOwnerChangedSignal(String _name, String _oldOwner, String _newOwner)	Create a 'NameOwnerChanged' signal manually.
private DBusSignal	generateNameAcquiredSignal(String _name)	Create a 'NameAcquired' signal manually.
boolean	isRunning()
private static void	logMessage(String _logStr, Message _m, String _connUniqueId)
static void	main(String[] _args)
private void	removeConnection(DBusDaemon.ConnectionStruct _c)
void	run()
static void	saveFile(String _data, String _file)
private void	send(DBusDaemon.ConnectionStruct _connStruct, Message _msg)
private void	send(DBusDaemon.ConnectionStruct _connStruct, Message _msg, boolean _head)
static void	syntax()
static void	version()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

QUEUE_POLL_WAIT

public static final int QUEUE_POLL_WAIT

See Also:

• Constant Field Values

LOGGER

private static final org.slf4j.Logger LOGGER

conns

private final Map<DBusDaemon.ConnectionStruct,DBusDaemon.DBusDaemonReaderThread> conns

names

private final Map<String,DBusDaemon.ConnectionStruct> names

outqueue

private final BlockingDeque<DBusDaemon.Pair<Message,WeakReference<DBusDaemon.ConnectionStruct>>> outqueue

inqueue

private final BlockingDeque<DBusDaemon.Pair<Message,WeakReference<DBusDaemon.ConnectionStruct>>> inqueue

sigrecips

private final List<DBusDaemon.ConnectionStruct> sigrecips

dbusServer

private final DBusDaemon.DBusServer dbusServer

sender

private final DBusDaemon.DBusDaemonSenderThread sender

run

private final AtomicBoolean run

nextUnique

private final AtomicInteger nextUnique

transport

private final AbstractTransport transport

Constructor Details

DBusDaemon

public DBusDaemon(AbstractTransport _transport)

Method Details

send

private void send(DBusDaemon.ConnectionStruct _connStruct,
 Message _msg)

send

private void send(DBusDaemon.ConnectionStruct _connStruct,
 Message _msg,
 boolean _head)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

logMessage

private static void logMessage(String _logStr,
 Message _m,
 String _connUniqueId)

isRunning

public boolean isRunning()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

removeConnection

private void removeConnection(DBusDaemon.ConnectionStruct _c)

addSock

void addSock(TransportConnection _s)
      throws IOException

Throws:

IOException

syntax

public static void syntax()

version

public static void version()

saveFile

public static void saveFile(String _data,
 String _file)
                     throws IOException

Throws:

IOException

main

public static void main(String[] _args)
                 throws Exception

Throws:

Exception

generateNameAcquiredSignal

private DBusSignal generateNameAcquiredSignal(String _name)
                                       throws DBusException

Create a 'NameAcquired' signal manually. This is required because the implementation in DBusNameAquired is for receiving of this signal only.

Parameters:

_name - name to announce

Returns:

signal

Throws:

DBusException - if signal creation fails

generatedNameOwnerChangedSignal

private DBusSignal generatedNameOwnerChangedSignal(String _name,
 String _oldOwner,
 String _newOwner)
                                            throws DBusException

Create a 'NameOwnerChanged' signal manually. This is required because the implementation in DBusNameAquired is for receiving of this signal only.

Parameters:

_name - name to announce

_oldOwner - previous owner

_newOwner - new owner

Returns:

signal

Throws:

DBusException - if signal creation fails