Searched refs:pendingUnprotectedWrites (Results 1 – 1 of 1) sorted by relevance
45 private PendingWriteQueue pendingUnprotectedWrites; field in TsiFrameHandler52 assert pendingUnprotectedWrites == null; in handlerAdded()53 pendingUnprotectedWrites = new PendingWriteQueue(checkNotNull(ctx)); in handlerAdded()94 pendingUnprotectedWrites.add(msg, promise); in write()99 if (!pendingUnprotectedWrites.isEmpty()) { in handlerRemoved0()100 pendingUnprotectedWrites.removeAndFailAll( in handlerRemoved0()107 pendingUnprotectedWrites.removeAndFailAll(cause); in exceptionCaught()149 new ProtectedPromise(ctx.channel(), ctx.executor(), pendingUnprotectedWrites.size()); in flush()151 List<ByteBuf> bufs = new ArrayList<>(pendingUnprotectedWrites.size()); in flush()153 if (pendingUnprotectedWrites.isEmpty()) { in flush()[all …]