Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 1 | ## -*- Mode: python; py-indent-offset: 4; indent-tabs-mode: nil; coding: utf-8; -*- |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 2 | # |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 3 | # Copyright (c) 2011-2013, Regents of the University of California |
| 4 | # Alexander Afanasyev |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 5 | # |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 6 | # GNU 3.0 license, See the LICENSE file for more information |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 7 | # |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 8 | # Author: Alexander Afanasyev <alexander.afanasyev@ucla.edu> |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 9 | # |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 10 | |
| 11 | # |
| 12 | # Based on PyCCN code, copyrighted and licensed as follows |
| 13 | # |
| 14 | # Copyright (c) 2011-2013, Regents of the University of California |
| 15 | # BSD license, See the COPYING file for more information |
| 16 | # Written by: Derek Kulinski <takeda@takeda.tk> |
| 17 | # Jeff Burke <jburke@ucla.edu> |
| 18 | # |
| 19 | |
| 20 | import ns.core |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 21 | import ns.network |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 22 | import ns.ndnSIM |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 23 | from Data import Data |
| 24 | from Interest import Interest |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 25 | from Name import Name |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 26 | |
| 27 | import functools |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 28 | |
Alexander Afanasyev | 76b1157 | 2013-07-16 21:49:50 -0700 | [diff] [blame] | 29 | class Face (ns.ndnSIM.ndn.ApiFace): |
| 30 | def __init__(self): |
| 31 | self.nodeId = ns.core.Simulator.GetContext () |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 32 | self.node = ns.network.NodeList.GetNode (self.nodeId) |
Alexander Afanasyev | 76b1157 | 2013-07-16 21:49:50 -0700 | [diff] [blame] | 33 | super(Face, self).__init__ (self.node) |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 34 | |
| 35 | def connect (self): |
| 36 | pass |
| 37 | |
| 38 | def disconnect (self): |
Alexander Afanasyev | 76b1157 | 2013-07-16 21:49:50 -0700 | [diff] [blame] | 39 | self.Shutdown () |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 40 | |
| 41 | def defer_verification (self, deferVerification = True): |
| 42 | pass |
| 43 | |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 44 | def expressInterest (self, name, onData, onTimeout, template = None): |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 45 | """ |
| 46 | onData: void <interest, name> |
| 47 | onTimeout: void <interest> |
| 48 | """ |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 49 | |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 50 | interest = Interest (interest = template) |
| 51 | interest.name = name |
| 52 | |
| 53 | class OnDataConvert: |
| 54 | def __init__ (self, onData): |
| 55 | self.onData = onData |
| 56 | def __call__ (self, interest, data): |
| 57 | if self.onData: |
| 58 | return self.onData (Interest (interest=interest), Data (data = data)) |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 59 | |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 60 | class OnTimeoutConvert: |
| 61 | def __init__ (self, onTimeout): |
| 62 | self.onTimeout = onTimeout |
| 63 | def __call__ (self, interest): |
| 64 | if self.onTimeout: |
| 65 | self.onTimeout (Interest (interest=interest)) |
| 66 | |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 67 | self.ExpressInterest (interest._interest, OnDataConvert (onData), OnTimeoutConvert (onTimeout)) |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 68 | |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 69 | def setInterestFilter (self, name, onInterest, flags = None): |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 70 | """ |
| 71 | onInterest: void <name, interest> |
| 72 | """ |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 73 | |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 74 | class OnInterestConvert: |
| 75 | def __init__ (self, onInterest): |
| 76 | self.onInterest = onInterest |
| 77 | def __call__ (self, name, interest): |
| 78 | if self.onInterest: |
| 79 | self.onInterest (Name (name = name), Interest (interest = interest)) |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 80 | |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 81 | if isinstance (name, Name): |
| 82 | name = name._name |
| 83 | elif isinstance (name, ns.ndnSIM.ndn.Name): |
| 84 | pass |
| 85 | else: |
| 86 | raise TypeError ("Wrong type for 'name' parameter [%s]" % type (name)) |
| 87 | |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 88 | self.SetInterestFilter (name, OnInterestConvert (onInterest)) |
Alexander Afanasyev | 5ba9036 | 2013-07-15 19:58:38 -0700 | [diff] [blame] | 89 | |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 90 | def clearInterestFilter (self, name): |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 91 | if isinstance (name, Name): |
| 92 | name = name._name |
| 93 | elif isinstance (name, ns.ndnSIM.ndn.Name): |
| 94 | pass |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 95 | else: |
| 96 | raise TypeError ("Wrong type for 'name' parameter [%s]" % type (name)) |
| 97 | |
Alexander Afanasyev | fce5bbd | 2013-08-07 18:50:00 -0700 | [diff] [blame^] | 98 | self.ClearInterestFilter (name) |
| 99 | |
Alexander Afanasyev | 39f5316 | 2013-07-18 16:24:31 -0700 | [diff] [blame] | 100 | def get (self, name, template = None, timeoutms = 3000): |
| 101 | raise NotImplementedError ("NS-3 simulation cannot have syncrhonous operations") |
| 102 | |
| 103 | def put (self, data): |
Alexander Afanasyev | 76b1157 | 2013-07-16 21:49:50 -0700 | [diff] [blame] | 104 | self.Put (data) |