service_logger.c 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. #include "skynet.h"
  2. #include <stdio.h>
  3. #include <stdlib.h>
  4. #include <stdint.h>
  5. struct logger {
  6. FILE * handle;
  7. int close;
  8. };
  9. struct logger *
  10. jmlogger_create(void) {
  11. struct logger * inst = skynet_malloc(sizeof(*inst));
  12. inst->handle = NULL;
  13. inst->close = 0;
  14. return inst;
  15. }
  16. void
  17. jmlogger_release(struct logger * inst) {
  18. if (inst->close) {
  19. fclose(inst->handle);
  20. }
  21. skynet_free(inst);
  22. }
  23. static int
  24. _logger(struct skynet_context * context, void *ud, int type, int session, uint32_t source, const void * msg, size_t sz) {
  25. struct logger * inst = ud;
  26. if (type == 0) {
  27. // fprintf(inst->handle, "[:%08x] ",source);
  28. }
  29. fwrite(msg, sz , 1, inst->handle);
  30. if (type == 0) {
  31. fprintf(inst->handle, "\n");
  32. }
  33. fflush(inst->handle);
  34. return 0;
  35. }
  36. int
  37. jmlogger_init(struct logger * inst, struct skynet_context *ctx, const char * parm) {
  38. if (parm) {
  39. inst->handle = fopen(parm,"a+");
  40. if (inst->handle == NULL) {
  41. return 1;
  42. }
  43. inst->close = 1;
  44. } else {
  45. inst->handle = stdout;
  46. }
  47. if (inst->handle) {
  48. skynet_callback(ctx, inst, _logger);
  49. // skynet_command(ctx, "REG", ".logger");
  50. return 0;
  51. }
  52. return 1;
  53. }