apache / servicecomb-mesher / 511

Committed 16 Sep 2020 11:52AM UTC coverage: 76.428%. First build

Build # 511

Build Type

Pull #126

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/apache/servicecomb-mesher/commit/<a class=hub.com/apache/servicecomb-mesher/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/servicecomb-mesher/commit/eb2eb40f36f96effdf9d10da5433ba77a15c6513">eb2eb40f3">&lt;a href=&quot;https://github.com/apache/servicecomb-mesher/commit/</a><a class="double-link" href="https://github.com/apache/servicecomb-mesher/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/servicecomb-mesher/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/servicecomb-mesher/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/servicecomb-mesher/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/servicecomb-mesher/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/servicecomb-mesher/commit/eb2eb40f36f96effdf9d10da5433ba77a15c6513">eb2eb40f3</a><a href="https://github.com/apache/servicecomb-mesher/commit/eb2eb40f36f96effdf9d10da5433ba77a15c6513">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/apache/servicecomb-mesher/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/servicecomb-mesher/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/servicecomb-mesher/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/servicecomb-mesher/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/servicecomb-mesher/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/servicecomb-mesher/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/servicecomb-mesher/commit/eb2eb40f36f96effdf9d10da5433ba77a1... (continued)

Pull Request Pull Request #126: upgrade go chassis

Run Details

107 of 107 new or added lines in 28 files covered. (100.0%)

2448 of 3203 relevant lines covered (76.43%)

2.14 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

86.49

/proxy/protocol/dubbo/simpleRegistry/simple_registry_server.go

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package simpleregistry

import (
        "github.com/apache/servicecomb-mesher/proxy/protocol/dubbo/dubbo"
        "github.com/apache/servicecomb-mesher/proxy/protocol/dubbo/proxy"
        "github.com/apache/servicecomb-mesher/proxy/protocol/dubbo/utils"
        "github.com/go-chassis/go-chassis/v2/core/server"
        "github.com/go-chassis/openlog"
        "net"
        "sync"
)

const (
        NAME = "dubboSimpleRegistry"
)

func init() {
        server.InstallPlugin(NAME, newServer)
}

func newServer(opts server.Options) server.ProtocolServer {

        return &SimDubboRegistryServer{
                opts: opts,
        }
}

//SimDubboRegistryServer is a struct
type SimDubboRegistryServer struct {
        opts       server.Options
        mux        sync.RWMutex
        exit       chan chan error
        routineMgr *util.RoutineManager
}

func (d *SimDubboRegistryServer) String() string {
        return NAME
}

//Init is a method which initialized server config
func (d *SimDubboRegistryServer) Init(opts ...server.Options) error {
        openlog.Info("Dubbo Simple Registry server init.")
        return nil
}

//Register is a method to register schema to that server
func (d *SimDubboRegistryServer) Register(schema interface{}, options ...server.RegisterOption) (string, error) {
        return "", nil
}

//Stop is a method to stop the server
func (d *SimDubboRegistryServer) Stop() error {
        return nil
}

//Start is a method to start the server
func (d *SimDubboRegistryServer) Start() error {
        err := d.Init()
        if err != nil {
                return err
        }
        host, _, err := net.SplitHostPort(d.opts.Address)
        if err != nil {
                return err
        }
        ip := net.ParseIP(host)
        if ip == nil {
                return &util.BaseError{ErrMsg: "invalid host"}
        }
        tcpAddr, err := net.ResolveTCPAddr("tcp", d.opts.Address)
        if err != nil {
                openlog.Error("ResolveTCPAddr err: " + err.Error())
                return err
        }
        l, err := net.ListenTCP("tcp", tcpAddr)
        if err != nil {
                openlog.Error("listening falied, reason: " + err.Error())
                return err
        }
        go d.AcceptLoop(l)
        return nil
}

//AcceptLoop is a method to receive data in loop
func (d *SimDubboRegistryServer) AcceptLoop(l *net.TCPListener) {
        for {
                for {
                        conn, err := l.Accept()
                        if err != nil {
                                openlog.Error("tcp conn error: " + err.Error())
                                continue
                        }

                        openlog.Debug("Received message")

                        go handleConn(conn)
                }

        }
        defer l.Close()
}

func handleConn(conn net.Conn) {
        defer conn.Close()
        var buf []byte
        buf = make([]byte, 1024)
        for {
                _, err := conn.Read(buf)
                if err != nil {
                        return
                }
                req := &dubbo.Request{}
                codec := dubbo.DubboCodec{}

                var bodyLen int
                codec.DecodeDubboReqHead(req, buf[0:dubbo.HeaderLength], &bodyLen)

                SendVoidRespond(conn, req)
        }
}

//SendVoidRespond is a method to send void respose
func SendVoidRespond(conn net.Conn, req *dubbo.Request) {
        dubboproxy.IsProvider = true
        var rsp dubbo.DubboRsp
        var wBuf util.WriteBuffer
        wBuf = util.WriteBuffer{}
        wBuf.Init(1024)
        rsp = dubbo.DubboRsp{}
        rsp.Init()
        rsp.SetEvent(req.IsEvent())
        rsp.SetID(req.GetMsgID())
        rsp.SetValue(nil)
        codec := dubbo.DubboCodec{}
        codec.EncodeDubboRsp(&rsp, &wBuf)
        conn.Write(wBuf.GetValidData())
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18	package simpleregistry
19
20	import (
21	"github.com/apache/servicecomb-mesher/proxy/protocol/dubbo/dubbo"
22	"github.com/apache/servicecomb-mesher/proxy/protocol/dubbo/proxy"
23	"github.com/apache/servicecomb-mesher/proxy/protocol/dubbo/utils"
24	"github.com/go-chassis/go-chassis/v2/core/server"
25	"github.com/go-chassis/openlog"
26	"net"
27	"sync"
28	)
29
30	const (
31	NAME = "dubboSimpleRegistry"
32	)
33
34	func init() {	1✔
35	server.InstallPlugin(NAME, newServer)	1✔
36	}	1✔
37
38	func newServer(opts server.Options) server.ProtocolServer {	5✔
39		5✔
40	return &SimDubboRegistryServer{	5✔
41	opts: opts,	5✔
42	}	5✔
43	}	5✔
44
45	//SimDubboRegistryServer is a struct
46	type SimDubboRegistryServer struct {
47	opts server.Options
48	mux sync.RWMutex
49	exit chan chan error
50	routineMgr *util.RoutineManager
51	}
52
53	func (d *SimDubboRegistryServer) String() string {	1✔
54	return NAME	1✔
55	}	1✔
56
57	//Init is a method which initialized server config
58	func (d *SimDubboRegistryServer) Init(opts ...server.Options) error {	5✔
59	openlog.Info("Dubbo Simple Registry server init.")	5✔
60	return nil	5✔
61	}	5✔
62
63	//Register is a method to register schema to that server
64	func (d *SimDubboRegistryServer) Register(schema interface{}, options ...server.RegisterOption) (string, error) {	1✔
65	return "", nil	1✔
66	}	1✔
67
68	//Stop is a method to stop the server
69	func (d *SimDubboRegistryServer) Stop() error {	2✔
70	return nil	2✔
71	}	2✔
72
73	//Start is a method to start the server
74	func (d *SimDubboRegistryServer) Start() error {	5✔
75	err := d.Init()	5✔
76	if err != nil {	5✔
77	return err	×
78	}	×
79	host, _, err := net.SplitHostPort(d.opts.Address)	5✔
80	if err != nil {	6✔
81	return err	1✔
82	}	1✔
83	ip := net.ParseIP(host)	4✔
84	if ip == nil {	5✔
85	return &util.BaseError{ErrMsg: "invalid host"}	1✔
86	}	1✔
87	tcpAddr, err := net.ResolveTCPAddr("tcp", d.opts.Address)	3✔
88	if err != nil {	3✔
89	openlog.Error("ResolveTCPAddr err: " + err.Error())	×
90	return err	×
91	}	×
92	l, err := net.ListenTCP("tcp", tcpAddr)	3✔
93	if err != nil {	4✔
94	openlog.Error("listening falied, reason: " + err.Error())	1✔
95	return err	1✔
96	}	1✔
97	go d.AcceptLoop(l)	2✔
98	return nil	2✔
99	}
100
101	//AcceptLoop is a method to receive data in loop
102	func (d SimDubboRegistryServer) AcceptLoop(l net.TCPListener) {	2✔
103	for {	4✔
104	for {	5✔
105	conn, err := l.Accept()	3✔
106	if err != nil {	3✔
107	openlog.Error("tcp conn error: " + err.Error())	×
108	continue	×
109	}
110
111	openlog.Debug("Received message")	1✔
112		1✔
113	go handleConn(conn)	1✔
114	}
115
116	}
117	defer l.Close()	×
118	}
119
120	func handleConn(conn net.Conn) {	1✔
121	defer conn.Close()	1✔
122	var buf []byte	1✔
123	buf = make([]byte, 1024)	1✔
124	for {	3✔
125	_, err := conn.Read(buf)	2✔
126	if err != nil {	2✔
127	return	×
128	}	×
129	req := &dubbo.Request{}	1✔
130	codec := dubbo.DubboCodec{}	1✔
131		1✔
132	var bodyLen int	1✔
133	codec.DecodeDubboReqHead(req, buf[0:dubbo.HeaderLength], &bodyLen)	1✔
134		1✔
135	SendVoidRespond(conn, req)	1✔
136	}
137	}
138
139	//SendVoidRespond is a method to send void respose
140	func SendVoidRespond(conn net.Conn, req *dubbo.Request) {
141	dubboproxy.IsProvider = true
142	var rsp dubbo.DubboRsp
143	var wBuf util.WriteBuffer
144	wBuf = util.WriteBuffer{}
145	wBuf.Init(1024)
146	rsp = dubbo.DubboRsp{}
147	rsp.Init()
148	rsp.SetEvent(req.IsEvent())
149	rsp.SetID(req.GetMsgID())
150	rsp.SetValue(nil)
151	codec := dubbo.DubboCodec{}
152	codec.EncodeDubboRsp(&rsp, &wBuf)
153	conn.Write(wBuf.GetValidData())
154	}

apache / servicecomb-mesher / 511

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous