@@ -900,8 +900,8 @@ private class Reader extends Thread {
900900 byte msg_type ;
901901 byte msg_flags ;
902902 byte msg_ver ;
903- int body_len ;
904- int serial ;
903+ int msg_body_length ;
904+ int msg_serial ;
905905 int field_size ;
906906 ArrayList <Field > fields = new ArrayList <>();
907907 public void run () {
@@ -938,8 +938,8 @@ public void run() {
938938 msg_type = read_byte ();
939939 msg_flags = read_byte ();
940940 msg_ver = read_byte ();
941- body_len = read_int ();
942- serial = read_int ();
941+ msg_body_length = read_int ();
942+ msg_serial = read_int ();
943943 field_size = read_int ();
944944 if (debug ) {
945945 JFLog .log ("msg:" + msg_names [msg_type ]);
@@ -1050,11 +1050,11 @@ private void method_call() throws Exception {
10501050 switch (member ) {
10511051 case "subscribe" :
10521052 signal_add_client (sender , signal );
1053- write_msg (MSG_RETURN , sender , nextSerial (), serial , member , new Object [] {true });
1053+ write_msg (MSG_RETURN , sender , nextSerial (), msg_serial , member , new Object [] {true });
10541054 break ;
10551055 case "unsubscribe" :
10561056 signal_remove_client (sender , signal );
1057- write_msg (MSG_RETURN , sender , nextSerial (), serial , member , new Object [] {true });
1057+ write_msg (MSG_RETURN , sender , nextSerial (), msg_serial , member , new Object [] {true });
10581058 break ;
10591059 }
10601060 } else {
@@ -1065,16 +1065,17 @@ private void method_call() throws Exception {
10651065 public void run () {
10661066 try {
10671067 Object ret = ep .dispatch (_member , args );
1068- write_msg (MSG_RETURN , _sender , nextSerial (), serial , _member , new Object [] {ret });
1068+ write_msg (MSG_RETURN , _sender , nextSerial (), msg_serial , _member , new Object [] {ret });
10691069 } catch (Exception e ) {
10701070 if (debug ) JFLog .log (e );
1071+ write_msg (MSG_ERROR , _sender , nextSerial (), msg_serial , _member , new Object [] {e .toString ()});
10711072 }
10721073 }
10731074 }.start ();
10741075 }
10751076 } catch (Exception e ) {
10761077 if (debug ) JFLog .log (e );
1077- write_msg (MSG_ERROR , sender , nextSerial (), serial , member , new Object [] {e .toString ()});
1078+ write_msg (MSG_ERROR , sender , nextSerial (), msg_serial , member , new Object [] {e .toString ()});
10781079 }
10791080 }
10801081 private boolean isSignalRequest (String member , Object [] args ) {
@@ -1090,7 +1091,6 @@ private void method_return(byte msg_type) throws Exception {
10901091 String sender = null ;
10911092 String member = null ;
10921093 String sign = null ;
1093- boolean dbus = false ;
10941094 int reply_serial = -1 ;
10951095 int cnt = fields .size ();
10961096 for (int a =0 ;a <cnt ;a ++) {
@@ -1107,9 +1107,6 @@ private void method_return(byte msg_type) throws Exception {
11071107 break ;
11081108 case FIELD_SENDER :
11091109 sender = (String )field .value ;
1110- if (sender .equals (DBusMessageBus )) {
1111- dbus = true ;
1112- }
11131110 break ;
11141111 case FIELD_REPLY_SERIAL :
11151112 reply_serial = (Integer )field .value ;
0 commit comments