[plus]comment

src/broker/modules/init.go

@@ -27,11 +27,11 @@ type myType struct {
 	err     error
 }
 
-type Reply struct {
-	CompleteLog string
+type Reply struct { //RPC리턴값
+	CompleteLog string //제대로 받았는지 확인하는 로그
 }
 
-type Receiver struct {
+type Receiver struct { //RPC 서버에 등록하기 위한 변수
 	moscato *Moscato
 }
 
@@ -40,8 +40,20 @@ type Args struct { // 매개변수
 	Kind    int
 }
 
-func (receiver Receiver) MmReceive(args Args, reply *Reply) error {
-	// 메세지 별로 나눠서 언마샬하면 됨
+/*
+MS→MM
+
+-MM 실행되면 MM서버는 열려있음(MS은 자동으로 Client)(포트 8150)
+
+-Send2MM 호출 → rpc call로 MmReceive호출해서 MM로 전달(json형식)
+
+-MmReceive에서 msgType 검사 후 그것에 맞게 msgUnit으로 MM의 Receive로 보냄
+
+-MM의 Receive에서 해당 Message를 처리
+ */
+
+func (receiver Receiver) MmReceive(args Args, reply *Reply) error {//
+	// 메세지 별로 나눠서 언마샬
 	switch args.Kind {
 
 	case KSM:
@@ -213,7 +225,20 @@ func (moscato *Moscato) Receive(msg MsgUnit) (MsgUnit, error) {
 	return msg, nil
 }
 
-//Ms로 보낼때 쓸 함수
+//MS로 보낼때 쓸 함수
+
+/*
+MM→MS
+
+-MS 실행되면 MS서버는 열려있음(MM은 자동으로 Client)(포트 8160)
+
+-Send2MS 호출 → rpc call로 MsReceive호출해서 MS로 전달(json형식)
+
+-MsReceive에서 msgType 검사 후 그것에 맞게 msgUnit으로 MS의 Receive로 보냄
+
+-MS의 Receive에서 해당 Message를 처리
+ */
+
 func (moscato *Moscato) Send2MS(ipaddress string, msg MsgUnit) {
 	client, err := rpc.Dial("tcp", ipaddress+":8150")
 	if err != nil {
@@ -279,25 +304,21 @@ func (moscato *Moscato) Run() {
 }
 
 func Listen() {
-	//l, err := net.Listen("tcp", fmt.Sprintf(":%v", 8160))
-	l, err1 := net.Listen("tcp", ":8160") //MS로 부터 받는거
-	//l2, err2 := net.Listen("tcp","0.0.0.0:8150")
+	/*
+	MS→MM일때 ⇒ port : 8160으로 열기
+
+	(MM이 Server, MS가 Client)
+	*/
+
+	l, err1 := net.Listen("tcp", ":8160")
+
 	if err1 != nil {
 		log.Fatal(fmt.Sprintf("Unable to listen on given port: %s", err1))
 	}
 	defer l.Close()
 
-	/*if err2 != nil {
-		log.Fatal(fmt.Sprintf("Unable to listen on given port: %s", err2))
-	}
-	defer l2.Close()*/
-
 	for {
 		conn, _ := l.Accept()
 		go rpc.ServeConn(conn)
 	}
-	/*for {
-		conn, _ := l2.Accept()
-		go rpc.ServeConn(conn)
-	}*/
-}
+}