Преглед изворни кода

[change]Send,Receive-> MS_Receive, MM_Receive

master
jaehoon_kim пре 4 година
родитељ
комит
d84006fab4
1 измењених фајлова са 21 додато и 8 уклоњено
  1. 21
    8
      src/broker/modules/init.go

+ 21
- 8
src/broker/modules/init.go Прегледај датотеку

30
 	secure_mng secure_manager
30
 	secure_mng secure_manager
31
 }
31
 }
32
 
32
 
33
-// Send - rpc를 이용하여 msg전송
34
-func (moscato *Moscato)Send(ipaddr string, message MsgUnit, reply []byte)([]byte, error) {
35
-	reply,err:=message.ConvertToJson()
36
-	return reply,err
33
+type MicroService struct {
34
+	receivemsg *SubscriptionMsg
37
 }
35
 }
38
 
36
 
39
-// Recieve - rpc를 이용하여 msg전달 받음(rpc call)
40
-func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
37
+//MM_Recieve - MM가 msg전달 받음
38
+func (moscato *Moscato) MM_Recieve(msg MsgUnit) (MsgUnit, error) {
41
 	msg_type := msg.CheckType()
39
 	msg_type := msg.CheckType()
42
 
40
 
43
 	//메세지 타입에 따라 다르게 처리
41
 	//메세지 타입에 따라 다르게 처리
54
 	case RM: //Register msg
52
 	case RM: //Register msg
55
 		//var newmsg RegisterMsg
53
 		//var newmsg RegisterMsg
56
 		var newmsg = msg.(*RegisterMsg)
54
 		var newmsg = msg.(*RegisterMsg)
57
-		newNode := MSnode{newmsg.from, newmsg.from}
55
+		newNode := MSnode{newmsg.From(), newmsg.From()}
58
 		moscato.ms_mng.add_microservice(newNode)
56
 		moscato.ms_mng.add_microservice(newNode)
59
 
57
 
60
 	case WM: //Withdraw msg
58
 	case WM: //Withdraw msg
61
-		moscato.ms_mng.remove_microservice(msg.(*WithdrawMsg).from)
59
+		moscato.ms_mng.remove_microservice(msg.(*WithdrawMsg).From())
62
 
60
 
63
 	default:
61
 	default:
64
 		return nil, errors.New("Message type Error: Not registered message type")
62
 		return nil, errors.New("Message type Error: Not registered message type")
67
 	return msg, nil
65
 	return msg, nil
68
 }
66
 }
69
 
67
 
68
+//MS_Receive - MicorService가 msg 받음
69
+func (ms *MicroService)MS_Receive(msg MsgUnit)error{
70
+	msg_type:=msg.CheckType()
71
+
72
+	switch msg_type{
73
+	case KGM://Key Gen Msg
74
+
75
+	case KSM://Key Share Msg
76
+
77
+	case SM://Subscription Msg
78
+		ms.receivemsg=msg.(*SubscriptionMsg)
79
+	}
80
+	return nil
81
+}
82
+
70
 func (moscato *Moscato) Run() {
83
 func (moscato *Moscato) Run() {
71
 	//모스카토 구조체 변수 초기화
84
 	//모스카토 구조체 변수 초기화
72
 	moscato.queue.queue_init()
85
 	moscato.queue.queue_init()

Loading…
Откажи
Сачувај