Lines Matching refs:block
133 raise Exception('Invalid "size of size" in control block')
139 raise Exception('Invalid control block received')
146 raise Exception('Invalid size of control block (%d < %d)' % (
160 block = _ControlBlock(opcode)
164 block.encode = (first_byte >> 2) & 3
165 block.rejected = (first_byte >> 4) & 1
168 block.channel_id = channel_id
174 block.encoded_handshake = encoded_handshake
176 blocks.append(block)
178 block.mux_error = (first_byte >> 4) & 1
181 block.channel_id = channel_id
187 block.reason = reason
189 blocks.append(block)
192 block.channel_id = channel_id
195 block.send_quota = _read_number(data, size_of_quota, pos)
197 blocks.append(block)
201 block.slots = _read_number(data, size_of_slots, pos)
203 block.send_quota = _read_number(data, size_of_quota, pos)
205 blocks.append(block)
421 for block in self._control_blocks:
422 if block.opcode == _MUX_OPCODE_ADD_CHANNEL_RESPONSE:
425 elif block.opcode == _MUX_OPCODE_FLOW_CONTROL:
428 if not block.channel_id in self._logical_channels:
430 'channel id %d' % block.channel_id)
431 self._logical_channels[block.channel_id].send_quota += (
432 block.send_quota)
436 elif block.opcode == _MUX_OPCODE_NEW_CHANNEL_SLOT:
437 self._channel_slots.extend([block.send_quota] * block.slots)
577 for block in self._control_blocks:
578 if block.opcode != _MUX_OPCODE_ADD_CHANNEL_RESPONSE:
580 if block.channel_id == channel_id:
581 response = block