Package org.freedesktop.dbus.bin

Class DBusDaemon

java.lang.Object

java.lang.Thread

org.freedesktop.dbus.bin.DBusDaemon

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable

public class DBusDaemon
extends java.lang.Thread
implements java.io.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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Map<DBusDaemon.ConnectionStruct,DBusDaemon.DBusDaemonReaderThread>	conns
private DBusDaemon.DBusServer	dbusServer
private java.util.concurrent.BlockingDeque<DBusDaemon.Pair<Message,java.lang.ref.WeakReference<DBusDaemon.ConnectionStruct>>>	inqueue
private static org.slf4j.Logger	LOGGER
private java.util.Map<java.lang.String,DBusDaemon.ConnectionStruct>	names
private java.util.concurrent.atomic.AtomicInteger	nextUnique
private java.util.concurrent.BlockingDeque<DBusDaemon.Pair<Message,java.lang.ref.WeakReference<DBusDaemon.ConnectionStruct>>>	outqueue
static int	QUEUE_POLL_WAIT
private java.util.concurrent.atomic.AtomicBoolean	run
private DBusDaemon.DBusDaemonSenderThread	sender
private java.util.List<DBusDaemon.ConnectionStruct>	sigrecips
private 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(java.lang.String _name, java.lang.String _oldOwner, java.lang.String _newOwner)	Create a 'NameOwnerChanged' signal manually.
private DBusSignal	generateNameAcquiredSignal(java.lang.String _name)	Create a 'NameAcquired' signal manually.
boolean	isRunning()
private static void	logMessage(java.lang.String _logStr, Message _m, java.lang.String _connUniqueId)
static void	main(java.lang.String[] _args)
private void	removeConnection(DBusDaemon.ConnectionStruct _c)
void	run()
static void	saveFile(java.lang.String _data, java.lang.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, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

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 java.util.Map<DBusDaemon.ConnectionStruct,DBusDaemon.DBusDaemonReaderThread> conns

names

private final java.util.Map<java.lang.String,DBusDaemon.ConnectionStruct> names

outqueue

private final java.util.concurrent.BlockingDeque<DBusDaemon.Pair<Message,java.lang.ref.WeakReference<DBusDaemon.ConnectionStruct>>> outqueue

inqueue

private final java.util.concurrent.BlockingDeque<DBusDaemon.Pair<Message,java.lang.ref.WeakReference<DBusDaemon.ConnectionStruct>>> inqueue

sigrecips

private final java.util.List<DBusDaemon.ConnectionStruct> sigrecips

dbusServer

private final DBusDaemon.DBusServer dbusServer

sender

private final DBusDaemon.DBusDaemonSenderThread sender

run

private final java.util.concurrent.atomic.AtomicBoolean run

nextUnique

private final java.util.concurrent.atomic.AtomicInteger nextUnique

transport

private final AbstractTransport transport

Constructor Detail

DBusDaemon

public DBusDaemon(AbstractTransport _transport)

Method Detail

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 java.lang.Runnable

Overrides:

run in class java.lang.Thread

logMessage

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

isRunning

public boolean isRunning()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

removeConnection

private void removeConnection(DBusDaemon.ConnectionStruct _c)

addSock

void addSock(TransportConnection _s)
      throws java.io.IOException

Throws:

java.io.IOException

syntax

public static void syntax()

version

public static void version()

saveFile

public static void saveFile(java.lang.String _data,
                            java.lang.String _file)
                     throws java.io.IOException

Throws:

java.io.IOException

main

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

Throws:

java.lang.Exception

generateNameAcquiredSignal

private DBusSignal generateNameAcquiredSignal(java.lang.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(java.lang.String _name,
                                                   java.lang.String _oldOwner,
                                                   java.lang.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