mobilepricing/Client.py at master · ccxcxd/mobilepricing · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
import random
import Application

class Client( object ):
    def __init__( self, id, startPosition, speed ):
        self.id = id
        self.position = startPosition # 1 = 1 km
        self.speed = speed # 1 = 1 km/h
        self.previousPosition = None
        self.applications = []
        random.seed()

    def positionUpdate( self, i ):
        # interval is 5 min
        divide = 12.0
        self.previousPosition = self.position[:]
        speedLength = len( self.speed )
        i = i % speedLength # if not long enough or use constant speed
        self.position = [ self.position[0] + self.speed[i][0] / divide,
                          self.position[1] + self.speed[i][1] / divide
                          ]
        return [ self.previousPosition, self.position ]

    def getPosition( self ):
        return self.position

    def predictBs( self, baseStation, slot ):
        predictSpeed = self.predictSpeed( slot )
        potentialBs = self.predictPotentialBs( baseStation, predictSpeed ) # delete some impossible choice to decrease computation overhead
        predict = self.traversalPredictBs( predictSpeed, potentialBs )
        if predict[0] is None:
            pass
            #print "No new BS within 1 hour"
        else:
            pass
            #print "Predict to reach " + predict[0].id + " in " + str( predict[1] * 5 ) + "mins"
        return predict

    def predictSpeed( self, slot ):
        weight = [ 0.6, 0.3, 0.1 ] # choose randomly... only the sum need to be 1
        predictSpeed = [ 0, 0 ]
        speedLength = len( self.speed )
        for i in xrange( len( weight ) ):
            if i > slot: # no previous speed when start
                pass
            predictSpeed = [ predictSpeed[0] + self.speed[ ( slot - i ) % speedLength ][0] * weight[ i ], predictSpeed[1] + self.speed[ ( slot - i ) % speedLength ][1] * weight[ i ] ]

        return predictSpeed

    def predictPotentialBs( self, baseStation, predictSpeed ):
        potentialBs = {}
        for station in baseStation.nearbyBs.iteritems():
            if ( station[1].getXPosition() - baseStation.getXPosition() ) * predictSpeed[0] < 0:
                continue
            if ( station[1].getYPosition() - baseStation.getYPosition() ) * predictSpeed[1] < 0:
                continue
            potentialBs[ station[0] ] = station[1]

        return potentialBs

    def traversalPredictBs( self, predictSpeed, potentialBs ):
        maxSlot = 12 # only care for the prediction within 1 hour ( 1 slot = 5 min )
        start = self.position[:] # avoid using same data
        for i in xrange( maxSlot ):
            start[0] = start[0] + predictSpeed[0] / 12
            start[1] = start[1] + predictSpeed[1] / 12
            minDistance = None
            nextBs = None
            for station in potentialBs.iteritems():
                if station[1].isInRange( start ):
                    distance = station[1].distanceFromCenter( start )
                    if ( minDistance is None ) or ( distance < minDistance ):
                        minDistance = distance
                        nextBs = station[1]
            if nextBs is not None:
                break
        return [ nextBs, i + 1 ]

    def generateTraffic( self, predict ):
        traffic = []
        for app in self.applications:
            newTraffic = app.generateTraffic( self.station, predict )
            traffic.append(newTraffic)
        return traffic

    def intervalCommunication( self, baseStation, slot ):
        self.station = baseStation

        predict = self.predictBs( baseStation, slot )
        self.clientUpdate()
        traffic = self.generateTraffic( predict )
        self.station.recordTraffic(traffic)

    def generateClient( self ):
        TIMap = [ [ 0.5, 1.25 ], [ 1.25, 2.25 ], [ 2.25, 3 ] ]

        appType = random.randint( 1, 3 )
        appTI = random.uniform( TIMap[ appType - 1 ][0], TIMap[ appType - 1 ][1] )
        appSize = random.randint( 75*3, 75*50 ) # 75 is the minimum traffic for application to consumpe in one slot
        appID = len( self.applications )
        return Application.Application( appID, appType, appSize, appTI )

    def clientUpdate( self ):
        threshold = 0.5

        while( 1 ):
            if( random.random() < threshold ):
                self.applications.append( self.generateClient() )
            else:
                break

        #print self.applications

    def clearApps( self ):
        self.applications = []