From 22af1ed535b4afc8db3804e72bc5adb1a1b28d60 Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Fri, 25 Nov 2016 08:27:06 +0100 Subject: Added the flush command. Instead of trying to actually flush queues, we send a special command through the same queues as the other commands and can thus guarantee that the respective commands have been processed without blocking anything. --- common/commands/flush.fbs | 8 ++++++++ 1 file changed, 8 insertions(+) create mode 100644 common/commands/flush.fbs (limited to 'common/commands/flush.fbs') diff --git a/common/commands/flush.fbs b/common/commands/flush.fbs new file mode 100644 index 0000000..179f760 --- /dev/null +++ b/common/commands/flush.fbs @@ -0,0 +1,8 @@ +namespace Sink.Commands; + +table Flush { + id: string; + type: int; //See flush.h +} + +root_type Flush; -- cgit v1.2.3