Searched refs:pending_commands (Results 1 – 2 of 2) sorted by relevance
104 pending_commands: BTreeSet<PendingCommand>, field191 pending_commands: Default::default(), in new()275 .pending_commands in require_input_buffers()280 .pending_commands in require_input_buffers()303 .pending_commands in require_input_buffers()308 .pending_commands in require_input_buffers()468 if self.pending_commands.remove(&PendingCommand::Drain) { in flush_response()477 if self.pending_commands.remove(&PendingCommand::SrcQueueClear) { in flush_response()489 if self.pending_commands.remove(&PendingCommand::DstQueueClear) { in flush_response()592 if stream.pending_commands.contains(&PendingCommand::Drain) { in stream_drain()[all …]
1124 pending_commands: Dict[int, PendingCommand] # Pending commands, by label1152 self.pending_commands = {}1177 self.pending_commands[pending_command.transaction_label] = pending_command1182 del self.pending_commands[pending_command.transaction_label]1551 if not (pending_command := self.pending_commands.get(transaction_label)):1644 if not (pending_command := self.pending_commands.get(transaction_label)):