2 * Copyright (c) 1993, 1994, 1995, 1996
3 * The Regents of the University of California. All rights reserved.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that: (1) source code distributions
7 * retain the above copyright notice and this paragraph in its entirety, (2)
8 * distributions including binary code include the above copyright notice and
9 * this paragraph in its entirety in the documentation or other materials
10 * provided with the distribution, and (3) all advertising materials mentioning
11 * features or use of this software display the following acknowledgement:
12 * ``This product includes software developed by the University of California,
13 * Lawrence Berkeley Laboratory and its contributors.'' Neither the name of
14 * the University nor the names of its contributors may be used to endorse
15 * or promote products derived from this software without specific prior
17 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR IMPLIED
18 * WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES OF
19 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
23 static const char rcsid[] =
24 "@(#) $Header: print-wb.c,v 1.24 96/12/31 21:27:44 leres Exp $ (LBL)";
27 #include <sys/types.h>
30 #include <netinet/in.h>
34 #include "interface.h"
35 #include "addrtoname.h"
37 /* XXX need to add byte-swapping macros! */
40 * Largest packet size. Everything should fit within this space.
41 * For instance, multiline objects are sent piecewise.
43 #define MAXFRAMESIZE 1024
46 * Multiple drawing ops can be sent in one packet. Each one starts on a
47 * an even multiple of DOP_ALIGN bytes, which must be a power of two.
50 #define DOP_ROUNDUP(x) ((((int)(x)) + (DOP_ALIGN - 1)) & ~(DOP_ALIGN - 1))
52 ((struct dophdr *)((u_char *)(d) + \
53 DOP_ROUNDUP(ntohs((d)->dh_len) + sizeof(*(d)))))
56 * Format of the whiteboard packet header.
57 * The transport level header.
60 u_int32_t ph_src; /* site id of source */
61 u_int32_t ph_ts; /* time stamp (for skew computation) */
62 u_short ph_version; /* version number */
63 u_char ph_type; /* message type */
64 u_char ph_flags; /* message flags */
68 #define PT_DRAWOP 0 /* drawing operation */
69 #define PT_ID 1 /* announcement packet */
70 #define PT_RREQ 2 /* repair request */
71 #define PT_RREP 3 /* repair reply */
72 #define PT_KILL 4 /* terminate participation */
73 #define PT_PREQ 5 /* page vector request */
74 #define PT_PREP 7 /* page vector reply */
77 #define PF_USER 0x01 /* hint that packet has interactive data */
78 #define PF_VIS 0x02 /* only visible ops wanted */
81 u_int32_t p_sid; /* session id of initiator */
82 u_int32_t p_uid; /* page number */
86 u_int32_t dh_ts; /* sender's timestamp */
87 u_short dh_len; /* body length */
89 u_char dh_type; /* body type */
93 * Drawing op sub-types.
109 #define DT_MAXTYPE 15
112 * A drawing operation.
115 struct PageID pd_page; /* page that operations apply to */
116 u_int32_t pd_sseq; /* start sequence number */
117 u_int32_t pd_eseq; /* end sequence number */
118 /* drawing ops follow */
125 u_int32_t pr_id; /* source id of drawops to be repaired */
126 struct PageID pr_page; /* page of drawops */
127 u_int32_t pr_sseq; /* start seqno */
128 u_int32_t pr_eseq; /* end seqno */
135 u_int32_t pr_id; /* original site id of ops */
136 struct pkt_dop pr_dop;
137 /* drawing ops follow */
154 * An announcement packet.
158 struct PageID pi_mpage; /* current page */
159 struct pgstate pi_ps;
161 /* null-terminated site name */
165 struct PageID pp_page;
171 u_int32_t pp_n; /* size of pageid array */
172 /* pgstate's follow */
176 wb_id(const struct pkt_id *id, u_int len)
180 const struct id_off *io;
185 if (len < sizeof(*id) || (u_char *)(id + 1) > snapend)
189 printf(" %u/%s:%u (max %u/%s:%u) ",
190 (u_int32_t)ntohl(id->pi_ps.slot),
191 ipaddr_string(&id->pi_ps.page.p_sid),
192 (u_int32_t)ntohl(id->pi_ps.page.p_uid),
193 (u_int32_t)ntohl(id->pi_mslot),
194 ipaddr_string(&id->pi_mpage.p_sid),
195 (u_int32_t)ntohl(id->pi_mpage.p_uid));
197 nid = ntohs(id->pi_ps.nid);
198 len -= sizeof(*io) * nid;
199 io = (struct id_off *)(id + 1);
200 cp = (char *)(io + nid);
201 if ((u_char *)cp + len <= snapend) {
203 (void)fn_print((u_char *)cp, (u_char *)cp + len);
208 for (i = 0; i < nid && (u_char *)io < snapend; ++io, ++i) {
210 c, ipaddr_string(&io->id), (u_int32_t)ntohl(io->off));
221 wb_rreq(const struct pkt_rreq *rreq, u_int len)
224 if (len < sizeof(*rreq) || (u_char *)(rreq + 1) > snapend)
227 printf(" please repair %s %s:%u<%u:%u>",
228 ipaddr_string(&rreq->pr_id),
229 ipaddr_string(&rreq->pr_page.p_sid),
230 (u_int32_t)ntohl(rreq->pr_page.p_uid),
231 (u_int32_t)ntohl(rreq->pr_sseq),
232 (u_int32_t)ntohl(rreq->pr_eseq));
237 wb_preq(const struct pkt_preq *preq, u_int len)
240 if (len < sizeof(*preq) || (u_char *)(preq + 1) > snapend)
243 printf(" need %u/%s:%u",
244 (u_int32_t)ntohl(preq->pp_low),
245 ipaddr_string(&preq->pp_page.p_sid),
246 (u_int32_t)ntohl(preq->pp_page.p_uid));
251 wb_prep(const struct pkt_prep *prep, u_int len)
254 const struct pgstate *ps;
255 const u_char *ep = snapend;
258 if (len < sizeof(*prep)) {
261 n = ntohl(prep->pp_n);
262 ps = (const struct pgstate *)(prep + 1);
263 while (--n >= 0 && (u_char *)ps < ep) {
264 const struct id_off *io, *ie;
268 (u_int32_t)ntohl(ps->slot),
269 ipaddr_string(&ps->page.p_sid),
270 (u_int32_t)ntohl(ps->page.p_uid));
271 io = (struct id_off *)(ps + 1);
272 for (ie = io + ps->nid; io < ie && (u_char *)io < ep; ++io) {
273 printf("%c%s:%u", c, ipaddr_string(&io->id),
274 (u_int32_t)ntohl(io->off));
278 ps = (struct pgstate *)io;
280 return ((u_char *)ps <= ep? 0 : -1);
304 wb_dops(const struct dophdr *dh, u_int32_t ss, u_int32_t es)
307 for ( ; ss <= es; ++ss) {
308 register int t = dh->dh_type;
311 printf(" dop-%d!", t);
313 printf(" %s", dopstr[t]);
314 if (t == DT_SKIP || t == DT_HOLE) {
315 int ts = ntohl(dh->dh_ts);
316 printf("%d", ts - ss + 1);
317 if (ss > ts || ts > es) {
326 if ((u_char *)dh > snapend) {
336 wb_rrep(const struct pkt_rrep *rrep, u_int len)
338 const struct pkt_dop *dop = &rrep->pr_dop;
341 if (len < sizeof(*rrep) || (u_char *)(rrep + 1) > snapend)
343 len -= sizeof(*rrep);
345 printf(" for %s %s:%u<%u:%u>",
346 ipaddr_string(&rrep->pr_id),
347 ipaddr_string(&dop->pd_page.p_sid),
348 (u_int32_t)ntohl(dop->pd_page.p_uid),
349 (u_int32_t)ntohl(dop->pd_sseq),
350 (u_int32_t)ntohl(dop->pd_eseq));
353 return (wb_dops((const struct dophdr *)(dop + 1),
354 ntohl(dop->pd_sseq), ntohl(dop->pd_eseq)));
359 wb_drawop(const struct pkt_dop *dop, u_int len)
362 if (len < sizeof(*dop) || (u_char *)(dop + 1) > snapend)
366 printf(" %s:%u<%u:%u>",
367 ipaddr_string(&dop->pd_page.p_sid),
368 (u_int32_t)ntohl(dop->pd_page.p_uid),
369 (u_int32_t)ntohl(dop->pd_sseq),
370 (u_int32_t)ntohl(dop->pd_eseq));
373 return (wb_dops((const struct dophdr *)(dop + 1),
374 ntohl(dop->pd_sseq), ntohl(dop->pd_eseq)));
379 * Print whiteboard multicast packets.
382 wb_print(register const void *hdr, register u_int len)
384 register const struct pkt_hdr *ph;
386 ph = (const struct pkt_hdr *)hdr;
387 if (len < sizeof(*ph) || (u_char *)(ph + 1) > snapend) {
395 switch (ph->ph_type) {
402 if (wb_id((struct pkt_id *)(ph + 1), len) >= 0)
407 if (wb_rreq((struct pkt_rreq *)(ph + 1), len) >= 0)
412 if (wb_rrep((struct pkt_rrep *)(ph + 1), len) >= 0)
417 if (wb_drawop((struct pkt_dop *)(ph + 1), len) >= 0)
422 if (wb_preq((struct pkt_preq *)(ph + 1), len) >= 0)
427 if (wb_prep((struct pkt_prep *)(ph + 1), len) >= 0)
432 printf(" wb-%d!", ph->ph_type);