Skip to content

Commit b34e77d

Browse files
Changes to ambassador
1 parent 5585029 commit b34e77d

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

src/tiers/cmwA.cc

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ class ioUring{
203203
auto sp=cmwBuf.giveFile();
204204
::io_uring_prep_write(e,fd2,sp.data(),sp.size(),0);
205205
::io_uring_sqe_set_data64(e,SaveOutput);
206-
e->flags=IOSQE_CQE_SKIP_SUCCESS|IOSQE_IO_LINK;
206+
e->flags=IOSQE_CQE_SKIP_SUCCESS|IOSQE_IO_HARDLINK;
207207
e=getSqe();
208208
::io_uring_prep_fsync(e,fd2,0);
209209
::io_uring_sqe_set_data64(e,Fsync);
@@ -367,7 +367,10 @@ int main (int pid,char** av)try{
367367
for(auto const* cq:cqs){
368368
if(cq->res<=0){
369369
::syslog(LOG_ERR,"%d Op failed %llu %d",pid,cq->user_data,cq->res);
370-
if(cq->res<0&&-EPIPE!=cq->res)exitFailure();
370+
if(cq->res<0){
371+
if(::ioUring::SaveOutput==cq->user_data||::ioUring::Fsync==cq->user_data)continue;
372+
if(-EPIPE!=cq->res)exitFailure();
373+
}
371374
frntBuf.reset();
372375
::front::marshal<udpPacketMax>(frntBuf,{"Back tier vanished"});
373376
for(auto& r:requests){frntBuf.send(&r.frnt.addr,r.frnt.len);}

0 commit comments

Comments
 (0)