测试
This commit is contained in:
parent
f6d4097018
commit
1402f1957b
4
tap.go
4
tap.go
@ -29,7 +29,7 @@ type RPCClient struct {
|
|||||||
|
|
||||||
func (cli *RPCClient) connect() {
|
func (cli *RPCClient) connect() {
|
||||||
log.Println("rpcclient start")
|
log.Println("rpcclient start")
|
||||||
defer log.Println("rpcclient exit")
|
// defer log.Println("rpcclient exit")
|
||||||
|
|
||||||
conn, err := grpc.Dial(*othersAddr,
|
conn, err := grpc.Dial(*othersAddr,
|
||||||
grpc.WithTransportCredentials(insecure.NewCredentials()),
|
grpc.WithTransportCredentials(insecure.NewCredentials()),
|
||||||
@ -45,7 +45,7 @@ func (cli *RPCClient) connect() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (cli *RPCClient) run() {
|
func (cli *RPCClient) run() {
|
||||||
|
defer log.Println("rpcclient exit")
|
||||||
defer func() {
|
defer func() {
|
||||||
if err := recover(); err != nil {
|
if err := recover(); err != nil {
|
||||||
log.Println("recover")
|
log.Println("recover")
|
||||||
|
Loading…
x
Reference in New Issue
Block a user