chiark
/
gitweb
/
~mdw
/
disorder
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Complete Disobedience transition to event_ from _monitor.
[disorder]
/
disobedience
/
disobedience.c
diff --git
a/disobedience/disobedience.c
b/disobedience/disobedience.c
index 76ea604a87766140dd46278362a32da81b74d8e9..ac5f4e8b5b297fbfc8538e11bc8abaa0c7a95dbc 100644
(file)
--- a/
disobedience/disobedience.c
+++ b/
disobedience/disobedience.c
@@
-342,10
+342,10
@@
static gboolean maybe_send_nop(gpointer attribute((unused)) data) {
disorder_eclient_nop(client, nop_completed, 0);
}
if(rtp_supported) {
disorder_eclient_nop(client, nop_completed, 0);
}
if(rtp_supported) {
- const int
old_state
= rtp_is_running;
+ const int
rtp_was_running
= rtp_is_running;
rtp_is_running = rtp_running();
rtp_is_running = rtp_running();
- if(
old_state
!= rtp_is_running)
-
control_monitor(
0);
+ if(
rtp_was_running
!= rtp_is_running)
+
event_raise("rtp-changed",
0);
}
return TRUE; /* keep call me please */
}
}
return TRUE; /* keep call me please */
}
@@
-355,6
+355,8
@@
static void got_rtp_address(void attribute((unused)) *v,
const char *error,
int attribute((unused)) nvec,
char attribute((unused)) **vec) {
const char *error,
int attribute((unused)) nvec,
char attribute((unused)) **vec) {
+ const int rtp_was_running = rtp_is_running;
+
++suppress_actions;
rtp_address_in_flight = 0;
if(error) {
++suppress_actions;
rtp_address_in_flight = 0;
if(error) {
@@
-364,9
+366,9
@@
static void got_rtp_address(void attribute((unused)) *v,
} else {
rtp_supported = 1;
rtp_is_running = rtp_running();
} else {
rtp_supported = 1;
rtp_is_running = rtp_running();
- control_monitor(0);
}
}
- control_monitor(0);
+ if(rtp_is_running != rtp_was_running)
+ event_raise("rtp-changed", 0);
--suppress_actions;
}
--suppress_actions;
}