Hex Artifact Content
Not logged in

Artifact 04f12f463d783c6d1361258e052e2f9f5e980db7:


0000: 2f 2a 0a 20 2a 20 43 6f 70 79 72 69 67 68 74 20  /*. * Copyright 
0010: 28 63 29 20 32 30 30 33 2d 32 30 30 35 20 54 68  (c) 2003-2005 Th
0020: 6f 6d 65 72 20 4d 2e 20 47 69 6c 20 28 74 68 6f  omer M. Gil (tho
0030: 6d 65 72 40 63 73 61 69 6c 2e 6d 69 74 2e 65 64  mer@csail.mit.ed
0040: 75 29 0a 20 2a 20 20 20 20 20 20 20 20 20 20 20  u). *           
0050: 20 20 20 20 20 20 20 20 20 52 6f 62 65 72 74 20           Robert 
0060: 4d 6f 72 72 69 73 20 28 72 74 6d 40 63 73 61 69  Morris (rtm@csai
0070: 6c 2e 6d 69 74 2e 65 64 75 29 2e 0a 20 2a 20 20  l.mit.edu).. *  
0080: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
0090: 20 20 4d 61 73 73 61 63 68 75 73 65 74 74 73 20    Massachusetts 
00a0: 49 6e 73 74 69 74 75 74 65 20 6f 66 20 54 65 63  Institute of Tec
00b0: 68 6e 6f 6c 6f 67 79 0a 20 2a 20 0a 20 2a 20 50  hnology. * . * P
00c0: 65 72 6d 69 73 73 69 6f 6e 20 69 73 20 68 65 72  ermission is her
00d0: 65 62 79 20 67 72 61 6e 74 65 64 2c 20 66 72 65  eby granted, fre
00e0: 65 20 6f 66 20 63 68 61 72 67 65 2c 20 74 6f 20  e of charge, to 
00f0: 61 6e 79 20 70 65 72 73 6f 6e 20 6f 62 74 61 69  any person obtai
0100: 6e 69 6e 67 0a 20 2a 20 61 20 63 6f 70 79 20 6f  ning. * a copy o
0110: 66 20 74 68 69 73 20 73 6f 66 74 77 61 72 65 20  f this software 
0120: 61 6e 64 20 61 73 73 6f 63 69 61 74 65 64 20 64  and associated d
0130: 6f 63 75 6d 65 6e 74 61 74 69 6f 6e 20 66 69 6c  ocumentation fil
0140: 65 73 20 28 74 68 65 0a 20 2a 20 22 53 6f 66 74  es (the. * "Soft
0150: 77 61 72 65 22 29 2c 20 74 6f 20 64 65 61 6c 20  ware"), to deal 
0160: 69 6e 20 74 68 65 20 53 6f 66 74 77 61 72 65 20  in the Software 
0170: 77 69 74 68 6f 75 74 20 72 65 73 74 72 69 63 74  without restrict
0180: 69 6f 6e 2c 20 69 6e 63 6c 75 64 69 6e 67 0a 20  ion, including. 
0190: 2a 20 77 69 74 68 6f 75 74 20 6c 69 6d 69 74 61  * without limita
01a0: 74 69 6f 6e 20 74 68 65 20 72 69 67 68 74 73 20  tion the rights 
01b0: 74 6f 20 75 73 65 2c 20 63 6f 70 79 2c 20 6d 6f  to use, copy, mo
01c0: 64 69 66 79 2c 20 6d 65 72 67 65 2c 20 70 75 62  dify, merge, pub
01d0: 6c 69 73 68 2c 0a 20 2a 20 64 69 73 74 72 69 62  lish,. * distrib
01e0: 75 74 65 2c 20 73 75 62 6c 69 63 65 6e 73 65 2c  ute, sublicense,
01f0: 20 61 6e 64 2f 6f 72 20 73 65 6c 6c 20 63 6f 70   and/or sell cop
0200: 69 65 73 20 6f 66 20 74 68 65 20 53 6f 66 74 77  ies of the Softw
0210: 61 72 65 2c 20 61 6e 64 20 74 6f 0a 20 2a 20 70  are, and to. * p
0220: 65 72 6d 69 74 20 70 65 72 73 6f 6e 73 20 74 6f  ermit persons to
0230: 20 77 68 6f 6d 20 74 68 65 20 53 6f 66 74 77 61   whom the Softwa
0240: 72 65 20 69 73 20 66 75 72 6e 69 73 68 65 64 20  re is furnished 
0250: 74 6f 20 64 6f 20 73 6f 2c 20 73 75 62 6a 65 63  to do so, subjec
0260: 74 20 74 6f 0a 20 2a 20 74 68 65 20 66 6f 6c 6c  t to. * the foll
0270: 6f 77 69 6e 67 20 63 6f 6e 64 69 74 69 6f 6e 73  owing conditions
0280: 3a 0a 20 2a 20 0a 20 2a 20 54 68 65 20 61 62 6f  :. * . * The abo
0290: 76 65 20 63 6f 70 79 72 69 67 68 74 20 6e 6f 74  ve copyright not
02a0: 69 63 65 20 61 6e 64 20 74 68 69 73 20 70 65 72  ice and this per
02b0: 6d 69 73 73 69 6f 6e 20 6e 6f 74 69 63 65 20 73  mission notice s
02c0: 68 61 6c 6c 20 62 65 0a 20 2a 20 69 6e 63 6c 75  hall be. * inclu
02d0: 64 65 64 20 69 6e 20 61 6c 6c 20 63 6f 70 69 65  ded in all copie
02e0: 73 20 6f 72 20 73 75 62 73 74 61 6e 74 69 61 6c  s or substantial
02f0: 20 70 6f 72 74 69 6f 6e 73 20 6f 66 20 74 68 65   portions of the
0300: 20 53 6f 66 74 77 61 72 65 2e 0a 20 2a 20 0a 20   Software.. * . 
0310: 2a 20 54 48 45 20 53 4f 46 54 57 41 52 45 20 49  * THE SOFTWARE I
0320: 53 20 50 52 4f 56 49 44 45 44 20 22 41 53 20 49  S PROVIDED "AS I
0330: 53 22 2c 20 57 49 54 48 4f 55 54 20 57 41 52 52  S", WITHOUT WARR
0340: 41 4e 54 59 20 4f 46 20 41 4e 59 20 4b 49 4e 44  ANTY OF ANY KIND
0350: 2c 0a 20 2a 20 45 58 50 52 45 53 53 20 4f 52 20  ,. * EXPRESS OR 
0360: 49 4d 50 4c 49 45 44 2c 20 49 4e 43 4c 55 44 49  IMPLIED, INCLUDI
0370: 4e 47 20 42 55 54 20 4e 4f 54 20 4c 49 4d 49 54  NG BUT NOT LIMIT
0380: 45 44 20 54 4f 20 54 48 45 20 57 41 52 52 41 4e  ED TO THE WARRAN
0390: 54 49 45 53 20 4f 46 0a 20 2a 20 4d 45 52 43 48  TIES OF. * MERCH
03a0: 41 4e 54 41 42 49 4c 49 54 59 2c 20 46 49 54 4e  ANTABILITY, FITN
03b0: 45 53 53 20 46 4f 52 20 41 20 50 41 52 54 49 43  ESS FOR A PARTIC
03c0: 55 4c 41 52 20 50 55 52 50 4f 53 45 20 41 4e 44  ULAR PURPOSE AND
03d0: 0a 20 2a 20 4e 4f 4e 49 4e 46 52 49 4e 47 45 4d  . * NONINFRINGEM
03e0: 45 4e 54 2e 20 49 4e 20 4e 4f 20 45 56 45 4e 54  ENT. IN NO EVENT
03f0: 20 53 48 41 4c 4c 20 54 48 45 20 41 55 54 48 4f   SHALL THE AUTHO
0400: 52 53 20 4f 52 20 43 4f 50 59 52 49 47 48 54 20  RS OR COPYRIGHT 
0410: 48 4f 4c 44 45 52 53 20 42 45 0a 20 2a 20 4c 49  HOLDERS BE. * LI
0420: 41 42 4c 45 20 46 4f 52 20 41 4e 59 20 43 4c 41  ABLE FOR ANY CLA
0430: 49 4d 2c 20 44 41 4d 41 47 45 53 20 4f 52 20 4f  IM, DAMAGES OR O
0440: 54 48 45 52 20 4c 49 41 42 49 4c 49 54 59 2c 20  THER LIABILITY, 
0450: 57 48 45 54 48 45 52 20 49 4e 20 41 4e 20 41 43  WHETHER IN AN AC
0460: 54 49 4f 4e 0a 20 2a 20 4f 46 20 43 4f 4e 54 52  TION. * OF CONTR
0470: 41 43 54 2c 20 54 4f 52 54 20 4f 52 20 4f 54 48  ACT, TORT OR OTH
0480: 45 52 57 49 53 45 2c 20 41 52 49 53 49 4e 47 20  ERWISE, ARISING 
0490: 46 52 4f 4d 2c 20 4f 55 54 20 4f 46 20 4f 52 20  FROM, OUT OF OR 
04a0: 49 4e 20 43 4f 4e 4e 45 43 54 49 4f 4e 0a 20 2a  IN CONNECTION. *
04b0: 20 57 49 54 48 20 54 48 45 20 53 4f 46 54 57 41   WITH THE SOFTWA
04c0: 52 45 20 4f 52 20 54 48 45 20 55 53 45 20 4f 52  RE OR THE USE OR
04d0: 20 4f 54 48 45 52 20 44 45 41 4c 49 4e 47 53 20   OTHER DEALINGS 
04e0: 49 4e 20 54 48 45 20 53 4f 46 54 57 41 52 45 2e  IN THE SOFTWARE.
04f0: 0a 20 2a 2f 0a 0a 23 69 66 6e 64 65 66 20 5f 5f  . */..#ifndef __
0500: 50 41 43 4b 45 54 5f 48 0a 23 64 65 66 69 6e 65  PACKET_H.#define
0510: 20 5f 5f 50 41 43 4b 45 54 5f 48 0a 0a 23 69 6e   __PACKET_H..#in
0520: 63 6c 75 64 65 20 22 6c 69 62 74 61 73 6b 2f 74  clude "libtask/t
0530: 61 73 6b 2e 68 22 0a 23 69 6e 63 6c 75 64 65 20  ask.h".#include 
0540: 22 70 32 70 73 69 6d 2e 68 22 0a 75 73 69 6e 67  "p2psim.h".using
0550: 20 6e 61 6d 65 73 70 61 63 65 20 73 74 64 3b 0a   namespace std;.
0560: 0a 2f 2f 20 54 68 65 20 6f 6e 6c 79 20 74 68 69  .// The only thi
0570: 6e 67 20 50 61 63 6b 65 74 20 69 73 20 75 73 65  ng Packet is use
0580: 66 75 6c 20 66 6f 72 20 69 73 20 74 6f 20 73 65  ful for is to se
0590: 6e 64 20 52 50 43 73 2c 0a 2f 2f 20 61 73 20 6d  nd RPCs,.// as m
05a0: 61 6e 61 67 65 64 20 62 79 20 4e 6f 64 65 3a 3a  anaged by Node::
05b0: 5f 64 6f 52 50 43 28 29 20 61 6e 64 20 4e 6f 64  _doRPC() and Nod
05c0: 65 3a 3a 52 65 63 65 69 76 65 28 29 2e 0a 63 6c  e::Receive()..cl
05d0: 61 73 73 20 50 61 63 6b 65 74 20 7b 0a 70 75 62  ass Packet {.pub
05e0: 6c 69 63 3a 0a 20 20 50 61 63 6b 65 74 28 29 3b  lic:.  Packet();
05f0: 0a 20 20 7e 50 61 63 6b 65 74 28 29 3b 0a 0a 20  .  ~Packet();.. 
0600: 20 49 50 41 64 64 72 65 73 73 20 73 72 63 28 29   IPAddress src()
0610: 20 7b 20 72 65 74 75 72 6e 20 5f 73 72 63 3b 20   { return _src; 
0620: 7d 0a 20 20 49 50 41 64 64 72 65 73 73 20 64 73  }.  IPAddress ds
0630: 74 28 29 20 7b 20 72 65 74 75 72 6e 20 5f 64 73  t() { return _ds
0640: 74 3b 20 7d 0a 20 20 43 68 61 6e 6e 65 6c 20 2a  t; }.  Channel *
0650: 63 68 61 6e 6e 65 6c 28 29 20 7b 20 72 65 74 75  channel() { retu
0660: 72 6e 20 5f 63 3b 20 7d 0a 20 20 62 6f 6f 6c 20  rn _c; }.  bool 
0670: 72 65 70 6c 79 28 29 20 7b 20 72 65 74 75 72 6e  reply() { return
0680: 20 5f 66 6e 20 3d 3d 20 30 3b 20 7d 0a 20 20 75   _fn == 0; }.  u
0690: 6e 73 69 67 6e 65 64 20 69 64 28 29 20 7b 20 72  nsigned id() { r
06a0: 65 74 75 72 6e 20 5f 69 64 3b 20 7d 0a 20 20 62  eturn _id; }.  b
06b0: 6f 6f 6c 20 6f 6b 28 29 20 20 20 20 20 7b 20 72  ool ok()     { r
06c0: 65 74 75 72 6e 20 5f 6f 6b 3b 20 7d 0a 20 20 54  eturn _ok; }.  T
06d0: 69 6d 65 20 74 69 6d 65 6f 75 74 28 29 20 7b 20  ime timeout() { 
06e0: 72 65 74 75 72 6e 20 5f 74 69 6d 65 6f 75 74 3b  return _timeout;
06f0: 20 7d 0a 0a 70 72 69 76 61 74 65 3a 0a 20 20 2f   }..private:.  /
0700: 2f 20 52 50 43 20 66 75 6e 63 74 69 6f 6e 20 61  / RPC function a
0710: 6e 64 20 61 72 67 75 6d 65 6e 74 73 2e 0a 20 20  nd arguments..  
0720: 2f 2f 20 4e 6f 20 65 78 70 6c 69 63 69 74 20 72  // No explicit r
0730: 65 70 6c 79 3b 20 70 75 74 20 69 74 20 69 6e 20  eply; put it in 
0740: 74 68 65 20 61 72 67 73 2e 0a 20 20 76 6f 69 64  the args..  void
0750: 20 28 2a 5f 66 6e 29 28 76 6f 69 64 20 2a 29 3b   (*_fn)(void *);
0760: 0a 20 20 76 6f 69 64 20 28 2a 5f 6b 69 6c 6c 6d  .  void (*_killm
0770: 65 29 28 76 6f 69 64 20 2a 29 3b 0a 20 20 76 6f  e)(void *);.  vo
0780: 69 64 20 2a 5f 61 72 67 73 3b 0a 0a 20 20 66 72  id *_args;..  fr
0790: 69 65 6e 64 20 63 6c 61 73 73 20 4e 6f 64 65 3b  iend class Node;
07a0: 0a 20 20 66 72 69 65 6e 64 20 63 6c 61 73 73 20  .  friend class 
07b0: 4e 65 74 77 6f 72 6b 3b 0a 20 20 54 69 6d 65 20  Network;.  Time 
07c0: 5f 71 75 65 75 65 5f 64 65 6c 61 79 3b 0a 0a 20  _queue_delay;.. 
07d0: 20 43 68 61 6e 6e 65 6c 20 2a 5f 63 3b 20 20 20   Channel *_c;   
07e0: 20 20 20 20 20 20 20 20 20 2f 2f 20 77 68 65 72           // wher
07f0: 65 20 74 6f 20 73 65 6e 64 20 74 68 65 20 72 65  e to send the re
0800: 70 6c 79 0a 20 20 49 50 41 64 64 72 65 73 73 20  ply.  IPAddress 
0810: 5f 73 72 63 3b 0a 20 20 49 50 41 64 64 72 65 73  _src;.  IPAddres
0820: 73 20 5f 64 73 74 3b 0a 20 20 62 6f 6f 6c 20 5f  s _dst;.  bool _
0830: 6f 6b 3b 20 20 20 20 20 20 20 20 20 20 20 20 20  ok;             
0840: 20 20 2f 2f 20 77 61 73 20 74 68 65 20 74 61 72    // was the tar
0850: 67 65 74 20 6e 6f 64 65 20 61 76 61 69 6c 61 62  get node availab
0860: 6c 65 3f 0a 20 20 75 6e 73 69 67 6e 65 64 20 5f  le?.  unsigned _
0870: 69 64 3b 0a 20 20 54 69 6d 65 20 5f 74 69 6d 65  id;.  Time _time
0880: 6f 75 74 3b 20 20 20 20 20 20 20 20 20 20 2f 2f  out;          //
0890: 20 69 66 20 73 65 74 2c 20 61 66 74 65 72 20 68   if set, after h
08a0: 6f 77 20 6c 6f 6e 67 20 74 68 69 73 20 52 50 43  ow long this RPC
08b0: 20 73 68 6f 75 6c 64 20 74 69 6d 65 20 6f 75 74   should time out
08c0: 0a 20 20 73 74 61 74 69 63 20 75 6e 73 69 67 6e  .  static unsign
08d0: 65 64 20 5f 75 6e 69 71 75 65 3b 0a 7d 3b 0a 0a  ed _unique;.};..
08e0: 23 65 6e 64 69 66 20 2f 2f 20 5f 5f 50 41 43 4b  #endif // __PACK
08f0: 45 54 5f 48 0a                                   ET_H.