SelfAwareness.hpp 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  1. /*
  2. * ZeroTier One - Network Virtualization Everywhere
  3. * Copyright (C) 2011-2016 ZeroTier, Inc. https://www.zerotier.com/
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. */
  18. #ifndef ZT_SELFAWARENESS_HPP
  19. #define ZT_SELFAWARENESS_HPP
  20. #include "Constants.hpp"
  21. #include "InetAddress.hpp"
  22. #include "Hashtable.hpp"
  23. #include "Address.hpp"
  24. #include "Mutex.hpp"
  25. namespace ZeroTier {
  26. class RuntimeEnvironment;
  27. /**
  28. * Tracks changes to this peer's real world addresses
  29. */
  30. class SelfAwareness
  31. {
  32. public:
  33. SelfAwareness(const RuntimeEnvironment *renv);
  34. ~SelfAwareness();
  35. /**
  36. * Called when a trusted remote peer informs us of our external network address
  37. *
  38. * @param reporter ZeroTier address of reporting peer
  39. * @param receivedOnLocalAddress Local address on which report was received
  40. * @param reporterPhysicalAddress Physical address that reporting peer seems to have
  41. * @param myPhysicalAddress Physical address that peer says we have
  42. * @param trusted True if this peer is trusted as an authority to inform us of external address changes
  43. * @param now Current time
  44. */
  45. void iam(const Address &reporter,const InetAddress &receivedOnLocalAddress,const InetAddress &reporterPhysicalAddress,const InetAddress &myPhysicalAddress,bool trusted,uint64_t now);
  46. /**
  47. * Clean up database periodically
  48. *
  49. * @param now Current time
  50. */
  51. void clean(uint64_t now);
  52. /**
  53. * If we appear to be behind a symmetric NAT, get predictions for possible external endpoints
  54. *
  55. * @return Symmetric NAT predictions or empty vector if none
  56. */
  57. std::vector<InetAddress> getSymmetricNatPredictions();
  58. private:
  59. struct PhySurfaceKey
  60. {
  61. Address reporter;
  62. InetAddress receivedOnLocalAddress;
  63. InetAddress reporterPhysicalAddress;
  64. InetAddress::IpScope scope;
  65. PhySurfaceKey() : reporter(),scope(InetAddress::IP_SCOPE_NONE) {}
  66. PhySurfaceKey(const Address &r,const InetAddress &rol,const InetAddress &ra,InetAddress::IpScope s) : reporter(r),receivedOnLocalAddress(rol),reporterPhysicalAddress(ra),scope(s) {}
  67. inline unsigned long hashCode() const throw() { return ((unsigned long)reporter.toInt() + (unsigned long)scope); }
  68. inline bool operator==(const PhySurfaceKey &k) const throw() { return ((reporter == k.reporter)&&(receivedOnLocalAddress == k.receivedOnLocalAddress)&&(reporterPhysicalAddress == k.reporterPhysicalAddress)&&(scope == k.scope)); }
  69. };
  70. struct PhySurfaceEntry
  71. {
  72. InetAddress mySurface;
  73. uint64_t ts;
  74. PhySurfaceEntry() : mySurface(),ts(0) {}
  75. PhySurfaceEntry(const InetAddress &a,const uint64_t t) : mySurface(a),ts(t) {}
  76. };
  77. const RuntimeEnvironment *RR;
  78. Hashtable< PhySurfaceKey,PhySurfaceEntry > _phy;
  79. Mutex _phy_m;
  80. };
  81. } // namespace ZeroTier
  82. #endif