| | |
| | | import ( |
| | | "basic.com/valib/c_bhomebus.git/proto/source/bhome_msg" |
| | | "context" |
| | | "encoding/json" |
| | | "errors" |
| | | "fmt" |
| | | jsoniter "github.com/json-iterator/go" |
| | | "os" |
| | | "sync" |
| | | "time" |
| | |
| | | |
| | | ms.printLog("1:", time.Since(t)) |
| | | t = time.Now() |
| | | var json = jsoniter.ConfigCompatibleWithStandardLibrary |
| | | rb, _ := json.Marshal(request) |
| | | msgR := &bhome_msg.MsgRequestTopic{ |
| | | Topic: []byte(request.Path), |
| | |
| | | } |
| | | |
| | | func (ms *MicroNode) RequestTopic(serverId string, request Request, milliSecs int) (*Reply, error) { |
| | | var json = jsoniter.ConfigCompatibleWithStandardLibrary |
| | | rb, _ := json.Marshal(request) |
| | | msgR := &bhome_msg.MsgRequestTopic{ |
| | | Topic: []byte(request.Path), |
| | |
| | | if ms.handlers == nil { |
| | | return |
| | | } |
| | | var json = jsoniter.ConfigCompatibleWithStandardLibrary |
| | | |
| | | var reqBody Request |
| | | var ri *Reply |