Lines Matching refs:first_byte
181 first_byte = (opcode << 5) | (flags << 2) | bytes_of_length
185 return (chr(first_byte) + _encode_channel_id(channel_id) +
218 first_byte = ((_MUX_OPCODE_FLOW_CONTROL << 5) |
220 payload = (_encode_channel_id(_CONTROL_CHANNEL_ID) + chr(first_byte) +
234 first_byte = ((_MUX_OPCODE_NEW_CHANNEL_SLOT << 5) |
236 payload = (_encode_channel_id(_CONTROL_CHANNEL_ID) + chr(first_byte) +
385 def _read_add_channel_request(self, first_byte, control_block):
386 reserved = (first_byte >> 4) & 0x1
387 encoding = (first_byte >> 2) & 0x3
388 size_of_handshake_size = (first_byte & 0x3) + 1
398 def _read_flow_control(self, first_byte, control_block):
399 quota_size = (first_byte & 0x3) + 1
404 def _read_drop_channel(self, first_byte, control_block):
405 mux_error = (first_byte >> 4) & 0x1
406 reserved = (first_byte >> 2) & 0x3
407 size_of_reason_size = (first_byte & 0x3) + 1
420 def _read_new_channel_slot(self, first_byte, control_block):
437 first_byte = ord(self._data[self._read_position])
439 opcode = (first_byte >> 5) & 0x7
442 yield self._read_add_channel_request(first_byte, control_block)
444 yield self._read_flow_control(first_byte, control_block)
446 yield self._read_drop_channel(first_byte, control_block)
448 yield self._read_new_channel_slot(first_byte, control_block)
675 first_byte = (end << 7) | opcode
677 chr(first_byte) + payload)
