aoe.c 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. #include <u.h>
  2. #include <libc.h>
  3. #include <ip.h>
  4. #include "dat.h"
  5. #include "protos.h"
  6. typedef struct{
  7. uchar verflags;
  8. uchar error;
  9. uchar major[2];
  10. uchar minor;
  11. uchar cmd;
  12. uchar tag[4];
  13. }Hdr;
  14. enum{
  15. Hsize = 10,
  16. };
  17. enum{
  18. Omajor,
  19. Ominor,
  20. Ocmd,
  21. };
  22. static Mux p_mux[] = {
  23. {"aoeata", 0},
  24. {"aoecmd", 1},
  25. {0},
  26. };
  27. static Field p_fields[] =
  28. {
  29. {"slot", Fnum, Ominor, "shelf", },
  30. {"shelf", Fnum, Omajor, "slot", },
  31. {"cmd", Fnum, Ocmd, "cmd", },
  32. {0}
  33. };
  34. static void
  35. p_compile(Filter *f)
  36. {
  37. if(f->op == '='){
  38. compile_cmp(aoe.name, f, p_fields);
  39. return;
  40. }
  41. sysfatal("unknown aoe field: %s", f->s);
  42. }
  43. static int
  44. p_filter(Filter *f, Msg *m)
  45. {
  46. Hdr *h;
  47. if(m->pe - m->ps < Hsize)
  48. return 0;
  49. h = (Hdr*)m->ps;
  50. m->ps += Hsize;
  51. switch(f->subop){
  52. case Omajor:
  53. return NetS(h->major) == f->ulv;
  54. case Ominor:
  55. return h->minor == f->ulv;
  56. case Ocmd:
  57. return h->cmd == f->ulv;
  58. }
  59. return 0;
  60. }
  61. static int
  62. p_seprint(Msg *m)
  63. {
  64. Hdr *h;
  65. if(m->pe - m->ps < Hsize)
  66. return 0;
  67. h = (Hdr*)m->ps;
  68. m->ps += Hsize;
  69. demux(p_mux, h->cmd, h->cmd, m, &dump);
  70. m->p = seprint(m->p, m->e, "ver=%d flag=%4b err=%d %d.%d cmd=%ux tag=%ux",
  71. h->verflags >> 4, h->verflags & 0xf, h->error, NetS(h->major),
  72. h->minor, h->cmd, NetL(h->tag));
  73. return 0;
  74. }
  75. Proto aoe =
  76. {
  77. "aoe",
  78. p_compile,
  79. p_filter,
  80. p_seprint,
  81. p_mux,
  82. nil,
  83. p_fields,
  84. defaultframer,
  85. };