Fix the topics parse issue when very long topics are given.

fujuntang

2021-08-31 511496a608be4ce2c0189ab0021d05ef2434da89

 src/bus_error.cpp

@@ -11,11 +11,20 @@
static pthread_key_t strerrorKey;


static char *_bus_errlist[_bus_nerr] = {
static const char *_bus_errlist[_bus_nerr] = {
  "\0",
  "timeout",
  "Timed out",
  "The other end is not inline",
  "Key already in use"
  "Key already in use",
  "Network fault",
  "Send to self error",
  "Receive from wrong end",
  "Service stoped",
  "Exceed resource limit",
  "Service not supported",
  "Resource busy",
  "Resource not provide",
  "Invalid parameters"

};

@@ -41,10 +50,13 @@
char *
bus_strerror(int err)
{
  int s, eindex;
  int s;
  char *buf;
  eindex = err - 10000;
  /* Make first caller allocate key for thread-specific data */

  if (err == 0) {
    err = EBUS_BASE;
  }

  s = pthread_once(&once, createKey);
  if (s != 0)
@@ -64,14 +76,31 @@
      err_exit(s, "pthread_setspecific");
  }

  if (eindex < 0 || eindex >= _bus_nerr || _bus_errlist[eindex] == NULL)
  {
    snprintf(buf, MAX_ERROR_LEN, "Unknown error %d", eindex);
  }
  else
  {
    strncpy(buf, _bus_errlist[eindex], MAX_ERROR_LEN - 1);
    buf[MAX_ERROR_LEN - 1] = '\0';          /* Ensure null termination */

  if(err < EBUS_BASE) {
    // libc错误
    if (err < 0 || err >= _sys_nerr || _sys_errlist[err] == NULL)
    {
      snprintf(buf, MAX_ERROR_LEN, "Unknown error %d", err);
    }
    else
    {
      strncpy(buf, _sys_errlist[err], MAX_ERROR_LEN - 1);
      buf[MAX_ERROR_LEN - 1] = '\0';          /* Ensure null termination */
    }
  } else {
    //自定义错误
    err -= EBUS_BASE;
    if (err < 0 || err >= _bus_nerr || _bus_errlist[err] == NULL)
    {
      snprintf(buf, MAX_ERROR_LEN, "Unknown error %d", err);
    }
    else
    {
      strncpy(buf, _bus_errlist[err], MAX_ERROR_LEN - 1);
      buf[MAX_ERROR_LEN - 1] = '\0';          /* Ensure null termination */
    }

  }

  return buf;