On Thu, 2009-11-26 at 07:13 +1300, angus salkeld wrote: > This is to be used later for totem patch. > > -Angus > > > Signed-off-by: Angus Salkeld <[email protected]> > --- > exec/coroipcs.c | 54 ++++++++++++++++++++++++++++++++------- > exec/main.c | 10 +++++++ > include/corosync/coroipc_ipc.h | 5 +++ > lib/coroipcc.c | 6 ++-- > 4 files changed, 62 insertions(+), 13 deletions(-) > > diff --git a/exec/coroipcs.c b/exec/coroipcs.c > index 065a355..2e816e6 100644 > --- a/exec/coroipcs.c > +++ b/exec/coroipcs.c > @@ -139,6 +139,7 @@ struct conn_info { > unsigned int service; > enum conn_state state; > int notify_flow_control_enabled; > + int flow_control_state; > int refcount; > hdb_handle_t stats_handle; > #if _POSIX_THREAD_PROCESS_SHARED < 1 > @@ -1188,6 +1189,36 @@ static void memcpy_dwrap (struct conn_info *conn_info, > void *msg, unsigned int l > conn_info->control_buffer->write = (write_idx + len) % > conn_info->dispatch_size; > } > > +/** > + * simulate the behaviour in coroipcc.c > + */ > +static int send_flow_control_event(struct conn_info *conn_info, char event) > +
flow_control_event_send (verb always last in coding style) otherwise good for merge regards -steve _______________________________________________ Openais mailing list [email protected] https://lists.linux-foundation.org/mailman/listinfo/openais
