From 9e154b053f290b3fe8eb8e7584a566378326b646 Mon Sep 17 00:00:00 2001 From: Philip Monk Date: Fri, 9 Aug 2019 11:52:42 -0700 Subject: [PATCH] kick write queue on |cancel --- pkg/arvo/sys/vane/clay.hoon | 20 +++++++++----------- 1 file changed, 9 insertions(+), 11 deletions(-) diff --git a/pkg/arvo/sys/vane/clay.hoon b/pkg/arvo/sys/vane/clay.hoon index 66a3c8692e..9a8d4dcab0 100644 --- a/pkg/arvo/sys/vane/clay.hoon +++ b/pkg/arvo/sys/vane/clay.hoon @@ -4158,17 +4158,15 @@ [[[hen %slip %d %flog req] ~] ..^$] :: %drop - ?: =(~ act.ruf) - ~& %clay-idle - [~ ..^$] - ~& :- %clay-cancelling - ?> ?=(^ act.ruf) - [hen -.req -.eval-data]:u.act.ruf - =. act.ruf ~ - ?~ cue.ruf - [~ ..^$] - =/ =duct duct:(need ~(top to cue.ruf)) - [[duct %pass /queued-request %b %wait now]~ ..^$] + ~? =(~ act.ruf) + [%clay-idle cue-length=~(wyt in cue.ruf)] + ~? ?=(^ act.ruf) + [%clay-cancelling hen -.req -.eval-data]:u.act.ruf + =. act.ruf ~ + ?~ cue.ruf + [~ ..^$] + =/ =duct duct:(need ~(top to cue.ruf)) + [[duct %pass /queued-request %b %wait now]~ ..^$] :: %info ?: =(%$ des.req)