TestFuzzDrdynvc.c

 
#include <stddef.h>
#include <stdint.h>
 
#include <winpr/stream.h>
#include <winpr/wtypes.h>
 
static UINT32 fuzz_var_uint_bytes(UINT8 cbLen)
{
  switch (cbLen)
  {
    case 0:
      return 1;
    case 1:
      return 2;
    default:
      return 4;
  }
}
 
static UINT32 fuzz_read_variable_uint(wStream* s, UINT8 cbLen)
{
  UINT32 value = 0;
 
  switch (cbLen)
  {
    case 0:
      value = Stream_Get_UINT8(s);
      break;
    case 1:
      value = Stream_Get_UINT16(s);
      break;
    default:
      value = Stream_Get_UINT32(s);
      break;
  }
 
  return value;
}
 
enum
{
  CREATE_REQUEST_PDU = 0x01,
  DATA_FIRST_PDU = 0x02,
  DATA_PDU = 0x03,
  CLOSE_REQUEST_PDU = 0x04,
  CAPABILITY_REQUEST_PDU = 0x05,
  DATA_FIRST_COMPRESSED_PDU = 0x06,
  DATA_COMPRESSED_PDU = 0x07
};
 
static int fuzz_process_one_pdu(wStream* s)
{
  const size_t required = 1;
 
  if (!Stream_CheckAndLogRequiredLength("fuzz", s, required))
    return -1;
 
  UINT8 header = Stream_Get_UINT8(s);
  UINT8 command = (header & 0xf0) >> 4;
  UINT8 spacing = (header & 0x0c) >> 2;
  UINT8 cbChId = (header & 0x03);
  size_t needed = fuzz_var_uint_bytes(cbChId);
 
  switch (command)
  {
    case DATA_FIRST_PDU:
    case DATA_FIRST_COMPRESSED_PDU:
      if (!Stream_CheckAndLogRequiredLength("fuzz", s, needed + fuzz_var_uint_bytes(spacing)))
        return -1;
      (void)fuzz_read_variable_uint(s, cbChId);
      (void)fuzz_read_variable_uint(s, spacing);
      break;
    case DATA_PDU:
    case DATA_COMPRESSED_PDU:
    case CLOSE_REQUEST_PDU:
    case CREATE_REQUEST_PDU:
      if (!Stream_CheckAndLogRequiredLength("fuzz", s, needed))
        return -1;
      (void)fuzz_read_variable_uint(s, cbChId);
      break;
    case CAPABILITY_REQUEST_PDU:
      if (!Stream_CheckAndLogRequiredLength("fuzz", s, 2))
        return -1;
      Stream_Seek(s, 2);
      break;
    default:
      break;
  }
 
  if (!Stream_CheckAndLogRequiredLength("fuzz", s, 2))
    return -1;
 
  {
    size_t bodyLen = Stream_Get_UINT16(s);
    const size_t remaining = Stream_GetRemainingLength(s);
    if (bodyLen > remaining)
      bodyLen = remaining;
    Stream_Seek(s, bodyLen);
  }
 
  return 0;
}
 
int LLVMFuzzerTestOneInput(const uint8_t* data, size_t size)
{
  if ((size == 0) || (size > (1u << 20)))
    return 0;
 
  wStream* s = Stream_New((BYTE*)data, size);
  if (!s)
    return 0;
 
  for (size_t index = 0; index < 64; index++)
  {
    if (Stream_GetRemainingLength(s) == 0)
      break;
    if (fuzz_process_one_pdu(s) != 0)
      break;
  }
 
  Stream_Free(s, FALSE);
  return 0;
}