package main

import (
        "context"
        "log"
        "time"
        //"strings"

        flatbuffers "github.com/google/flatbuffers/go"

        "github.com/smfrpc/smf-go/example/demo"
        "github.com/smfrpc/smf-go/example/demo_gen"
        "github.com/smfrpc/smf-go/src/smf"
)

//var xreq = strings.Repeat("x", 11)
var xreq = string([]byte{0,3,23,41})

func buildRequest() []byte {
        builder := flatbuffers.NewBuilder(0)
        name := builder.CreateString(xreq)
        demo.RequestStart(builder)
        demo.RequestAddName(builder, name)
        resp := demo.RequestEnd(builder)
        builder.Finish(resp)
        return builder.FinishedBytes()
}

func main() {
        client, err := smf.Dial("tcp", "127.0.0.1:20766")
        if err != nil {
                log.Fatal(err)
        }

        store := demo_gen.NewSmfStorageClient(client)
        //resp, err := store.Get(context.TODO(), buildRequest())
        start := time.Now()
        for i:=0;i<100000;i++ {
                go func() {
                        resp, err := store.Get(context.TODO(), buildRequest())
                        if err != nil {
        //                      log.Fatal(err)
                        }
                        log.Printf("Response: [ name=%q ]", resp.Name())
                }()
        }
        client.Close()

        elapsed := time.Since(start)
        log.Printf("Binomial took %s", elapsed)
        time.Sleep(100*time.Second)

}

	"github.com/crackcomm/go-smf/example/demo"
	"github.com/crackcomm/go-smf/example/demo_gen"
	"github.com/crackcomm/go-smf/smf"