overflow_backup_2018_0455/overflow_server_app
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bug fix

Browse Source
This commit is contained in:
crusader 2017-08-23 18:47:15 +09:00
parent cdd1f00d01
commit 34c7fef3cc
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
main.go
View File

@ -17,6 +17,8 @@ func main() {
s := server.New() s := server.New()
grpcPool, err := backend.NewPool(backend.Options{ grpcPool, err := backend.NewPool(backend.Options{
InitCapacity: 2,
MaxCapacity: 4,
Dial: func() (*grpc.ClientConn, error) { Dial: func() (*grpc.ClientConn, error) {
return grpc.Dial("192.168.1.101:50006", grpc.WithInsecure()) return grpc.Dial("192.168.1.101:50006", grpc.WithInsecure())
}, },

3
module/member/signin.go
View File

@ -12,12 +12,15 @@ import (
func SignIn(sctx *server.ServerContext, ctx *fasthttp.RequestCtx) { func SignIn(sctx *server.ServerContext, ctx *fasthttp.RequestCtx) {
grpcPool := sctx.Value("grpc").(backend.Pool) grpcPool := sctx.Value("grpc").(backend.Pool)
fmt.Fprintf(ctx, "avail: %d\n", grpcPool.Available())
c, err := grpcPool.Get() c, err := grpcPool.Get()
if nil != err { if nil != err {
} }
defer c.Close() defer c.Close()
fmt.Fprintf(ctx, "avail: %d\n", grpcPool.Available())
signinId := string(ctx.FormValue("signinId")) signinId := string(ctx.FormValue("signinId"))
signinPw := string(ctx.FormValue("signinPw")) signinPw := string(ctx.FormValue("signinPw"))