org.freedesktop.dbus.AbstractConnection._sender クラス

org.freedesktop.dbus.AbstractConnection._sender の継承関係図

org.freedesktop.dbus.AbstractConnection._sender 連携図

公開メンバ関数
	_sender ()
void	run ()

詳解

構築子と解体子

_sender()

org.freedesktop.dbus.AbstractConnection._sender._sender ( )

inline

                         {
            setName("Sender");
        }

関数詳解

run()

void org.freedesktop.dbus.AbstractConnection._sender.run ( )

inline

                          {
            Message m = null;

            if (Debug.debug) Debug.print(Debug.INFO, "Monitoring outbound queue");
            // block on the outbound queue and send from it
            while (_run) {
                if (null != outgoing) synchronized (outgoing) {
                    if (Debug.debug) Debug.print(Debug.VERBOSE, "Blocking");
                    while (outgoing.size() == 0 && _run)
                        try {
                            outgoing.wait();
                        } catch (InterruptedException Ie) {
                        }
                    if (Debug.debug) Debug.print(Debug.VERBOSE, "Notified");
                    if (outgoing.size() > 0)
                        m = outgoing.remove();
                    if (Debug.debug) Debug.print(Debug.DEBUG, "Got message: " + m);
                }
                if (null != m)
                    sendMessage(m);
                m = null;
            }

            if (Debug.debug) Debug.print(Debug.INFO, "Flushing outbound queue and quitting");
            // flush the outbound queue before disconnect.
            if (null != outgoing) do {
                EfficientQueue ogq = outgoing;
                synchronized (ogq) {
                    outgoing = null;
                }
                if (!ogq.isEmpty())
                    m = ogq.remove();
                else m = null;
                sendMessage(m);
            } while (null != m);

            // close the underlying streams
        }

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/federation/src/federation/sssd/src/main/java/org/freedesktop/dbus/AbstractConnection.java