===================================================================
RCS file: /cvsrepo/anoncvs/cvs/src/usr.bin/tmux/cmd-wait-for.c,v
retrieving revision 1.5
retrieving revision 1.6
diff -c -r1.5 -r1.6
*** src/usr.bin/tmux/cmd-wait-for.c	2014/09/01 21:50:18	1.5
--- src/usr.bin/tmux/cmd-wait-for.c	2014/09/01 21:58:41	1.6
***************
*** 1,4 ****
! /* $OpenBSD: cmd-wait-for.c,v 1.5 2014/09/01 21:50:18 nicm Exp $ */
  
  /*
   * Copyright (c) 2013 Nicholas Marriott <nicm@users.sourceforge.net>
--- 1,4 ----
! /* $OpenBSD: cmd-wait-for.c,v 1.6 2014/09/01 21:58:41 nicm Exp $ */
  
  /*
   * Copyright (c) 2013 Nicholas Marriott <nicm@users.sourceforge.net>
***************
*** 194,196 ****
--- 194,218 ----
  	return (CMD_RETURN_NORMAL);
  }
  
+ void
+ cmd_wait_for_flush(void)
+ {
+ 	struct wait_channel	*wc, *wc1;
+ 	struct cmd_q		*wq, *wq1;
+ 
+ 	RB_FOREACH_SAFE(wc, wait_channels, &wait_channels, wc1) {
+ 		TAILQ_FOREACH_SAFE(wq, &wc->waiters, waitentry, wq1) {
+ 			TAILQ_REMOVE(&wc->waiters, wq, waitentry);
+ 			if (!cmdq_free(wq))
+ 				cmdq_continue(wq);
+ 		}
+ 		while ((wq = TAILQ_FIRST(&wc->lockers)) != NULL) {
+ 			TAILQ_REMOVE(&wc->lockers, wq, waitentry);
+ 			if (!cmdq_free(wq))
+ 				cmdq_continue(wq);
+ 		}
+ 		RB_REMOVE(wait_channels, &wait_channels, wc);
+ 		free((void *)wc->name);
+ 		free(wc);
+ 	}
+ }