forked from KRSSG/robocup
-
Notifications
You must be signed in to change notification settings - Fork 0
/
test_fsm.py
63 lines (51 loc) · 1.92 KB
/
test_fsm.py
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
from role import _GoToPoint
from kubs import kubs, cmd_node
from velocity.run import *
import rospy,sys
from krssg_ssl_msgs.msg import point_2d
from krssg_ssl_msgs.msg import BeliefState
from krssg_ssl_msgs.msg import gr_Commands
from krssg_ssl_msgs.msg import gr_Robot_Command
from krssg_ssl_msgs.msg import point_SF
from utils.config import *
from utils.geometry import *
import memcache
shared = memcache.Client(['127.0.0.1:11211'], debug = False)
import sys
BOT_ID = int(sys.argv[1])
print "bot_id received",BOT_ID
pub = rospy.Publisher('/grsim_data', gr_Commands, queue_size=1000)
state = None
kub = None
points = [
Vector2D(-2400.79174805,-1560.16650391),Vector2D(-2400.79174805,500.04296875) ,Vector2D(-300.57901001,500.04296875),
Vector2D(-300.57901001,-1560.16650391)
]
curr_pt = 0
def BS_callback(BState):
global pub,BOT_ID,state,kub,start_time, curr_pt
global points
# BState = shared.get('state')
if not state:
print("__________________________________")
state = BState
kub = kubs.kubs(BOT_ID, BState, pub)
_GoToPoint.init(kub, points[0],0)
print(kub.kubs_id)
print "gfsdfj,fhjgcvkubvgfkhjub_______________________________"
print("distance s",points[curr_pt].dist(Vector2D(BState.homePos[0].x,BState.homePos[0].y)))
if points[curr_pt].dist(Vector2D(BState.homePos[0].x,BState.homePos[0].y)) < 300:
curr_pt = (curr_pt+1)%4
print("updates index",curr_pt)
_GoToPoint.init(kub, points[curr_pt],0)
kub.update_state(BState)
print ("point index",curr_pt)
_GoToPoint.execute(start_time,200,BState)
if __name__ == "__main__":
global start_time
rospy.init_node('node_new',anonymous=False)
start_time = rospy.Time.now()
start_time = 1.0*start_time.secs + 1.0*start_time.nsecs/pow(10,9)
# BS_callback(start_time)
rospy.Subscriber('/belief_state', BeliefState, BS_callback, queue_size=1000)
rospy.spin()