org.freedesktop.dbus.RemoteInvocationHandler クラス

org.freedesktop.dbus.RemoteInvocationHandler の継承関係図

org.freedesktop.dbus.RemoteInvocationHandler 連携図

公開メンバ関数
	RemoteInvocationHandler (AbstractConnection conn, RemoteObject remote)
Object	invoke (Object proxy, Method method, Object[] args) throws Throwable

静的公開メンバ関数
static Object	convertRV (String sig, Object[] rp, Method m, AbstractConnection conn) throws DBusException
static Object	executeRemoteMethod (RemoteObject ro, Method m, AbstractConnection conn, int syncmethod, CallbackHandler callback, Object... args) throws DBusExecutionException

静的公開変数類
static final int	CALL_TYPE_SYNC = 0
static final int	CALL_TYPE_ASYNC = 1
static final int	CALL_TYPE_CALLBACK = 2

変数
AbstractConnection	conn
RemoteObject	remote

詳解

構築子と解体子

RemoteInvocationHandler()

org.freedesktop.dbus.RemoteInvocationHandler.RemoteInvocationHandler ( AbstractConnection  conn, RemoteObject  remote  )

inline

                                                                                 {
        this.remote = remote;
        this.conn = conn;
    }

関数詳解

convertRV()

static Object org.freedesktop.dbus.RemoteInvocationHandler.convertRV ( String  sig, Object []  rp, Method  m, AbstractConnection  conn  ) throws DBusException

inlinestatic

                                                                                                                    {
        Class<? extends Object> c = m.getReturnType();

        if (null == rp) {
            if (null == c || Void.TYPE.equals(c)) return null;
            else throw new DBusExecutionException(getString("voidReturnType"));
        } else {
            try {
                if (Debug.debug)
                    Debug.print(Debug.VERBOSE, "Converting return parameters from " + Arrays.deepToString(rp) + " to type " + m.getGenericReturnType());
                rp = Marshalling.deSerializeParameters(rp,
                        new Type[]{m.getGenericReturnType()}, conn);
            } catch (Exception e) {
                if (AbstractConnection.EXCEPTION_DEBUG && Debug.debug) Debug.print(Debug.ERR, e);
                throw new DBusExecutionException(MessageFormat.format(getString("invalidReturnType"), new Object[]{e.getMessage()}));
            }
        }

        switch (rp.length) {
            case 0:
                if (null == c || Void.TYPE.equals(c))
                    return null;
                else throw new DBusExecutionException(getString("voidReturnType"));
            case 1:
                return rp[0];
            default:

                // check we are meant to return multiple values
                if (!Tuple.class.isAssignableFrom(c))
                    throw new DBusExecutionException(getString("tupleReturnType"));

                Constructor<? extends Object> cons = c.getConstructors()[0];
                try {
                    return cons.newInstance(rp);
                } catch (Exception e) {
                    if (AbstractConnection.EXCEPTION_DEBUG && Debug.debug) Debug.print(Debug.ERR, e);
                    throw new DBusException(e.getMessage());
                }
        }
    }

executeRemoteMethod()

static Object org.freedesktop.dbus.RemoteInvocationHandler.executeRemoteMethod ( RemoteObject  ro, Method  m, AbstractConnection  conn, int  syncmethod, CallbackHandler  callback, Object...  args  ) throws DBusExecutionException

inlinestatic

                                                                                                                                                                                         {
        Type[] ts = m.getGenericParameterTypes();
        String sig = null;
        if (ts.length > 0) try {
            sig = Marshalling.getDBusType(ts);
            args = Marshalling.convertParameters(args, ts, conn);
        } catch (DBusException DBe) {
            throw new DBusExecutionException(getString("contructDBusTypeFailure") + DBe.getMessage());
        }
        MethodCall call;
        byte flags = 0;
        if (!ro.autostart) flags |= Message.Flags.NO_AUTO_START;
        if (syncmethod == CALL_TYPE_ASYNC) flags |= Message.Flags.ASYNC;
        if (m.isAnnotationPresent(DBus.Method.NoReply.class)) flags |= Message.Flags.NO_REPLY_EXPECTED;
        try {
            String name;
            if (m.isAnnotationPresent(DBusMemberName.class))
                name = m.getAnnotation(DBusMemberName.class).value();
            else
                name = m.getName();
            if (null == ro.iface)
                call = new MethodCall(ro.busname, ro.objectpath, null, name, flags, sig, args);
            else {
                if (null != ro.iface.getAnnotation(DBusInterfaceName.class)) {
                    call = new MethodCall(ro.busname, ro.objectpath, ro.iface.getAnnotation(DBusInterfaceName.class).value(), name, flags, sig, args);
                } else
                    call = new MethodCall(ro.busname, ro.objectpath, AbstractConnection.dollar_pattern.matcher(ro.iface.getName()).replaceAll("."), name, flags, sig, args);
            }
        } catch (DBusException DBe) {
            if (AbstractConnection.EXCEPTION_DEBUG && Debug.debug) Debug.print(Debug.ERR, DBe);
            throw new DBusExecutionException(getString("constructOutgoingMethodCallFailure") + DBe.getMessage());
        }
        if (null == conn.outgoing) throw new NotConnected(getString("notConnected"));

        switch (syncmethod) {
            case CALL_TYPE_ASYNC:
                conn.queueOutgoing(call);
                return new DBusAsyncReply(call, m, conn);
            case CALL_TYPE_CALLBACK:
                synchronized (conn.pendingCallbacks) {
                    if (Debug.debug) Debug.print(Debug.VERBOSE, "Queueing Callback " + callback + " for " + call);
                    conn.pendingCallbacks.put(call, callback);
                    conn.pendingCallbackReplys.put(call, new DBusAsyncReply(call, m, conn));
                }
                conn.queueOutgoing(call);
                return null;
            case CALL_TYPE_SYNC:
                conn.queueOutgoing(call);
                break;
        }

        // get reply
        if (m.isAnnotationPresent(DBus.Method.NoReply.class)) return null;

        Message reply = call.getReply();
        if (null == reply) throw new DBus.Error.NoReply(getString("notReplyWithSpecifiedTime"));

        if (reply instanceof Error)
            ((Error) reply).throwException();

        try {
            return convertRV(reply.getSig(), reply.getParameters(), m, conn);
        } catch (DBusException e) {
            if (AbstractConnection.EXCEPTION_DEBUG && Debug.debug) Debug.print(Debug.ERR, e);
            throw new DBusExecutionException(e.getMessage());
        }
    }

invoke()

Object org.freedesktop.dbus.RemoteInvocationHandler.invoke ( Object  proxy, Method  method, Object []  args  ) throws Throwable

inline

                                                                                      {
        if (method.getName().equals("isRemote")) return true;
        else if (method.getName().equals("clone")) return null;
        else if (method.getName().equals("equals")) {
            try {
                if (1 == args.length)
                    return new Boolean(remote.equals(((RemoteInvocationHandler) Proxy.getInvocationHandler(args[0])).remote));
            } catch (IllegalArgumentException IAe) {
                return Boolean.FALSE;
            }
        } else if (method.getName().equals("finalize")) return null;
        else if (method.getName().equals("getClass")) return DBusInterface.class;
        else if (method.getName().equals("hashCode")) return remote.hashCode();
        else if (method.getName().equals("notify")) {
            remote.notify();
            return null;
        } else if (method.getName().equals("notifyAll")) {
            remote.notifyAll();
            return null;
        } else if (method.getName().equals("wait")) {
            if (0 == args.length) remote.wait();
            else if (1 == args.length
                    && args[0] instanceof Long) remote.wait((Long) args[0]);
            else if (2 == args.length
                    && args[0] instanceof Long
                    && args[1] instanceof Integer)
                remote.wait((Long) args[0], (Integer) args[1]);
            if (args.length <= 2)
                return null;
        } else if (method.getName().equals("toString"))
            return remote.toString();

        return executeRemoteMethod(remote, method, conn, CALL_TYPE_SYNC, null, args);
    }

メンバ詳解

CALL_TYPE_ASYNC

final int org.freedesktop.dbus.RemoteInvocationHandler.CALL_TYPE_ASYNC = 1

static

CALL_TYPE_CALLBACK

final int org.freedesktop.dbus.RemoteInvocationHandler.CALL_TYPE_CALLBACK = 2

static

CALL_TYPE_SYNC

final int org.freedesktop.dbus.RemoteInvocationHandler.CALL_TYPE_SYNC = 0

static

conn

AbstractConnection org.freedesktop.dbus.RemoteInvocationHandler.conn

package

remote

RemoteObject org.freedesktop.dbus.RemoteInvocationHandler.remote

package

---

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

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