org.freedesktop.dbus.Transport クラス

org.freedesktop.dbus.Transport 連携図

クラス
class	SASL

公開メンバ関数
	Transport ()
	Transport (BusAddress address) throws IOException
	Transport (String address) throws IOException, ParseException
	Transport (String address, int timeout) throws IOException, ParseException
void	connect (String address) throws IOException, ParseException
void	connect (String address, int timeout) throws IOException, ParseException
void	connect (BusAddress address) throws IOException
void	connect (BusAddress address, int timeout) throws IOException
void	disconnect () throws IOException

静的公開メンバ関数
static String	genGUID ()

公開変数類
MessageReader	min
MessageWriter	mout

詳解

構築子と解体子

Transport() [1/4]

org.freedesktop.dbus.Transport.Transport ( )

inline

                       {
    }

Transport() [2/4]

org.freedesktop.dbus.Transport.Transport ( BusAddress  address ) throws IOException

inline

                                                            {
        connect(address);
    }

Transport() [3/4]

org.freedesktop.dbus.Transport.Transport ( String  address ) throws IOException, ParseException

inline

                                                                        {
        connect(new BusAddress(address));
    }

Transport() [4/4]

org.freedesktop.dbus.Transport.Transport ( String  address, int  timeout  ) throws IOException, ParseException

inline

                                                                                     {
        connect(new BusAddress(address), timeout);
    }

関数詳解

connect() [1/4]

void org.freedesktop.dbus.Transport.connect ( String  address ) throws IOException, ParseException

inline

                                                                           {
        connect(new BusAddress(address), 0);
    }

connect() [2/4]

void org.freedesktop.dbus.Transport.connect ( String  address, int  timeout  ) throws IOException, ParseException

inline

                                                                                        {
        connect(new BusAddress(address), timeout);
    }

connect() [3/4]

void org.freedesktop.dbus.Transport.connect ( BusAddress  address ) throws IOException

inline

                                                               {
        connect(address, 0);
    }

connect() [4/4]

void org.freedesktop.dbus.Transport.connect ( BusAddress  address, int  timeout  ) throws IOException

inline

                                                                            {
        if (Debug.debug) Debug.print(Debug.INFO, "Connecting to " + address);
        OutputStream out = null;
        InputStream in = null;
        UnixSocket us = null;
        Socket s = null;
        int mode = 0;
        int types = 0;
        if ("unix".equals(address.getType())) {
            types = SASL.AUTH_EXTERNAL;
            mode = SASL.MODE_CLIENT;
            us = new UnixSocket();
            if (null != address.getParameter("abstract"))
                us.connect(new UnixSocketAddress(address.getParameter("abstract"), true));
            else if (null != address.getParameter("path"))
                us.connect(new UnixSocketAddress(address.getParameter("path"), false));
            us.setPassCred(true);
            in = us.getInputStream();
            out = us.getOutputStream();
        } else if ("tcp".equals(address.getType())) {
            types = SASL.AUTH_SHA;
            if (null != address.getParameter("listen")) {
                mode = SASL.MODE_SERVER;
                ServerSocket ss = new ServerSocket();
                ss.bind(new InetSocketAddress(address.getParameter("host"), Integer.parseInt(address.getParameter("port"))));
                s = ss.accept();
            } else {
                mode = SASL.MODE_CLIENT;
                s = new Socket();
                s.connect(new InetSocketAddress(address.getParameter("host"), Integer.parseInt(address.getParameter("port"))));
            }
            in = s.getInputStream();
            out = s.getOutputStream();
        } else {
            throw new IOException(getString("unknownAddress") + address.getType());
        }

        if (!(new SASL()).auth(mode, types, address.getParameter("guid"), out, in, us)) {
            out.close();
            throw new IOException(getString("errorAuth"));
        }
        if (null != us) {
            if (Debug.debug) Debug.print(Debug.VERBOSE, "Setting timeout to " + timeout + " on Socket");
            if (timeout == 1)
                us.setBlocking(false);
            else
                us.setSoTimeout(timeout);
        }
        if (null != s) {
            if (Debug.debug) Debug.print(Debug.VERBOSE, "Setting timeout to " + timeout + " on Socket");
            s.setSoTimeout(timeout);
        }
        mout = new MessageWriter(out);
        min = new MessageReader(in);
    }

disconnect()

void org.freedesktop.dbus.Transport.disconnect ( ) throws IOException

inline

                                                {
        if (Debug.debug) Debug.print(Debug.INFO, "Disconnecting Transport");
        min.close();
        mout.close();
    }

genGUID()

static String org.freedesktop.dbus.Transport.genGUID ( )

inlinestatic

                                   {
        Random r = new Random();
        byte[] buf = new byte[16];
        r.nextBytes(buf);
        String guid = Hexdump.toHex(buf);
        return guid.replaceAll(" ", "");
    }

メンバ詳解

min

MessageReader org.freedesktop.dbus.Transport.min

mout

MessageWriter org.freedesktop.dbus.Transport.mout

---

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

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