tests: testtrace.[ch] provides debug callback for libtest usage

/***************************************************************************

 *                                  _   _ ____  _

 *  Project                     ___| | | |  _ \| |

 *                             / __| | | | |_) | |

 *                            | (__| |_| |  _ <| |___

 *                             \___|\___/|_| \_\_____|

 *

 * Copyright (C) 1998 - 2012, Daniel Stenberg, <daniel@haxx.se>, et al.

 *

 * This software is licensed as described in the file COPYING, which

 * you should have received as part of this distribution. The terms

 * are also available at http://curl.haxx.se/docs/copyright.html.

 *

 * You may opt to use, copy, modify, merge, publish, distribute and/or sell

 * copies of the Software, and permit persons to whom the Software is

 * furnished to do so, under the terms of the COPYING file.

 *

 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY

 * KIND, either express or implied.

 *

 ***************************************************************************/

#include "test.h"

#include "testutil.h"

#include "testtrace.h"

#include "memdebug.h"

struct libtest_trace_cfg libtest_debug_config;

static time_t epoch_offset; /* for test time tracing */

static int    known_offset; /* for test time tracing */

static 

void libtest_debug_dump(const char *timebuf, const char *text, FILE *stream,

                        const unsigned char *ptr, size_t size, int nohex)

{

  size_t i;

  size_t c;

  unsigned int width = 0x10;

  if(nohex)

    /* without the hex output, we can fit more on screen */

    width = 0x40;

  fprintf(stream, "%s%s, %d bytes (0x%x)\n", timebuf, text,

          (int)size, (int)size);

  for(i = 0; i < size; i += width) {

    fprintf(stream, "%04x: ", (int)i);

    if(!nohex) {

      /* hex not disabled, show it */

      for(c = 0; c < width; c++)

        if(i+c < size)

          fprintf(stream, "%02x ", ptr[i+c]);

        else

          fputs("   ", stream);

    }

    for(c = 0; (c < width) && (i+c < size); c++) {

      /* check for 0D0A; if found, skip past and start a new line of output */

      if(nohex &&

         (i+c+1 < size) && (ptr[i+c] == 0x0D) && (ptr[i+c+1] == 0x0A)) {

        i += (c+2-width);

        break;

      }

      fprintf(stream, "%c", ((ptr[i+c] >= 0x20) && (ptr[i+c] < 0x80)) ?

              ptr[i+c] : '.');

      /* check again for 0D0A, to avoid an extra \n if it's at width */

      if(nohex &&

         (i+c+2 < size) && (ptr[i+c+1] == 0x0D) && (ptr[i+c+2] == 0x0A)) {

        i += (c+3-width);

        break;

      }

    }

    fputc('\n', stream); /* newline */

  }

  fflush(stream);

}

int libtest_debug_cb(CURL *handle, curl_infotype type,

                     unsigned char *data, size_t size,

                     void *userp)

{

  struct libtest_trace_cfg *trace_cfg = userp;

  const char *text;

  struct timeval tv;

  struct tm *now;

  char timebuf[20];

  time_t secs;

  (void)handle;

  timebuf[0] = '\0';

  if(trace_cfg->tracetime) {

    tv = tutil_tvnow();

    if(!known_offset) {

      epoch_offset = time(NULL) - tv.tv_sec;

      known_offset = 1;

    }

    secs = epoch_offset + tv.tv_sec;

    now = localtime(&secs);  /* not thread safe but we don't care */

    snprintf(timebuf, sizeof(timebuf), "%02d:%02d:%02d.%06ld ",

             now->tm_hour, now->tm_min, now->tm_sec, (long)tv.tv_usec);

  }

  switch (type) {

  case CURLINFO_TEXT:

    fprintf(stderr, "%s== Info: %s", timebuf, data);

  default: /* in case a new one is introduced to shock us */

    return 0;

  case CURLINFO_HEADER_OUT:

    text = "=> Send header";

    break;

  case CURLINFO_DATA_OUT:

    text = "=> Send data";

    break;

  case CURLINFO_SSL_DATA_OUT:

    text = "=> Send SSL data";

    break;

  case CURLINFO_HEADER_IN:

    text = "<= Recv header";

    break;

  case CURLINFO_DATA_IN:

    text = "<= Recv data";

    break;

  case CURLINFO_SSL_DATA_IN:

    text = "<= Recv SSL data";

    break;

  }

  libtest_debug_dump(timebuf, text, stderr, data, size, trace_cfg->nohex);

  return 0;

}

#ifndef HEADER_LIBTEST_TESTTRACE_H

#define HEADER_LIBTEST_TESTTRACE_H

/***************************************************************************

 *                                  _   _ ____  _

 *  Project                     ___| | | |  _ \| |

 *                             / __| | | | |_) | |

 *                            | (__| |_| |  _ <| |___

 *                             \___|\___/|_| \_\_____|

 *

 * Copyright (C) 1998 - 2012, Daniel Stenberg, <daniel@haxx.se>, et al.

 *

 * This software is licensed as described in the file COPYING, which

 * you should have received as part of this distribution. The terms

 * are also available at http://curl.haxx.se/docs/copyright.html.

 *

 * You may opt to use, copy, modify, merge, publish, distribute and/or sell

 * copies of the Software, and permit persons to whom the Software is

 * furnished to do so, under the terms of the COPYING file.

 *

 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY

 * KIND, either express or implied.

 *

 ***************************************************************************/

struct libtest_trace_cfg {

  int tracetime;  /* 0 represents FALSE, anything else TRUE */

  int nohex;      /* 0 represents FALSE, anything else TRUE */

};

extern struct libtest_trace_cfg libtest_debug_config;

int libtest_debug_cb(CURL *handle, curl_infotype type,

                     unsigned char *data, size_t size,

                     void *userp);

#endif /* HEADER_LIBTEST_TESTTRACE_H */