stream.c File Reference

Go to the source code of this file.

Data Structures
struct	emit_context_t

Functions
asciichat_error_t	quic_stream_preamble (acip_traffic_class_t traffic_class, uint8_t output[8])
asciichat_error_t	quic_stream_read (quic_stream_reader_t *reader, const void *bytes, size_t length, quic_stream_emit_fn emit, void *context)
asciichat_error_t	quic_stream_finish (quic_stream_reader_t *reader)
void	quic_stream_reset (quic_stream_reader_t *reader)

Function Documentation

quic_stream_finish()

asciichat_error_t quic_stream_finish

(

quic_stream_reader_t *

reader

)

Accept a clean FIN only at a packet boundary after a complete preamble.

Definition at line 74 of file lib/network/quic/stream.c.

                                                                   {
  if (!reader || reader->failed || reader->finished)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC stream finish");
  if (reader->preamble_used != sizeof(reader->preamble) || packet_decoder_pending(&reader->packets)) {
    reader->failed = true;
    return SET_ERRNO(ERROR_NETWORK_PROTOCOL, "Truncated QUIC stream");
  }
  reader->finished = true;
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, ERROR_INVALID_PARAM, ERROR_NETWORK_PROTOCOL, quic_stream_reader_t::failed, quic_stream_reader_t::finished, packet_decoder_pending(), quic_stream_reader_t::packets, quic_stream_reader_t::preamble, quic_stream_reader_t::preamble_used, and SET_ERRNO.

quic_stream_preamble()

asciichat_error_t quic_stream_preamble	(	acip_traffic_class_t	traffic_class,
		uint8_t	output[8] )

Definition at line 9 of file lib/network/quic/stream.c.

                                                                                       {
  if (!output || (unsigned)traffic_class > ACIP_TRAFFIC_VISUAL)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC stream traffic class");
  memcpy(output, stream_magic, sizeof(stream_magic));
  output[4] = 1;
  output[5] = (uint8_t)traffic_class;
  output[6] = output[7] = 0;
  return ASCIICHAT_OK;
}

References ACIP_QUIC_STREAM_PREAMBLE_SIZE, ACIP_TRAFFIC_VISUAL, ASCIICHAT_OK, ERROR_INVALID_PARAM, and SET_ERRNO.

quic_stream_read()

asciichat_error_t quic_stream_read	(	quic_stream_reader_t *	reader,
		const void *	bytes,
		size_t	length,
		quic_stream_emit_fn	emit,
		void *	context )

Feed on the connection's serialized receive lane. The callback borrows each complete packet until it returns. Errors are terminal until reset.

Definition at line 43 of file lib/network/quic/stream.c.

                                                                            {
  if (!reader || (!bytes && length) || !emit || reader->failed || reader->finished)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC stream input");
  const uint8_t *input = bytes;
  if (reader->preamble_used < sizeof(reader->preamble)) {
    size_t take = sizeof(reader->preamble) - reader->preamble_used;
    if (take > length)
      take = length;
    if (take) {
      memcpy(reader->preamble + reader->preamble_used, input, take);
      reader->preamble_used += take;
      input += take;
      length -= take;
    }
    if (reader->preamble_used < sizeof(reader->preamble))
      return ASCIICHAT_OK;
    if (memcmp(reader->preamble, stream_magic, sizeof(stream_magic)) != 0 || reader->preamble[4] != 1 ||
        reader->preamble[5] > ACIP_TRAFFIC_VISUAL || reader->preamble[6] || reader->preamble[7]) {
      reader->failed = true;
      return SET_ERRNO(ERROR_NETWORK_PROTOCOL, "Invalid QUIC stream preamble");
    }
    reader->traffic_class = (acip_traffic_class_t)reader->preamble[5];
  }
  emit_context_t emit_context = {.reader = reader, .emit = emit, .context = context};
  asciichat_error_t result = packet_decoder_feed(&reader->packets, input, length, emit_packet, &emit_context);
  if (result != ASCIICHAT_OK)
    reader->failed = true;
  return result;
}

References ACIP_TRAFFIC_VISUAL, ASCIICHAT_OK, ERROR_INVALID_PARAM, ERROR_NETWORK_PROTOCOL, quic_stream_reader_t::failed, quic_stream_reader_t::finished, packet_decoder_feed(), quic_stream_reader_t::packets, quic_stream_reader_t::preamble, quic_stream_reader_t::preamble_used, SET_ERRNO, and quic_stream_reader_t::traffic_class.

quic_stream_reset()

void quic_stream_reset

(

quic_stream_reader_t *

reader

)

Definition at line 85 of file lib/network/quic/stream.c.

                                                     {
  if (reader) {
    packet_decoder_reset(&reader->packets);
    memset(reader, 0, sizeof(*reader));
  }
}

References packet_decoder_reset(), and quic_stream_reader_t::packets.

Referenced by quic_connection_destroy().