修改bug
This commit is contained in:
parent
828f3af1fa
commit
948e113bd8
@ -1,9 +1,16 @@
|
|||||||
package ipb
|
package ipb
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"crypto/md5"
|
||||||
|
"fmt"
|
||||||
"testing"
|
"testing"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestWipeWarn(t *testing.T) {
|
func TestWipeWarn(t *testing.T) {
|
||||||
t.Log(MakeMsg("serviceName", 1, 2, 3, []byte("hello world")))
|
t.Log(MakeMsg("serviceName", 1, 2, 3, []byte("hello world")))
|
||||||
|
username := fmt.Sprintf("test%04d", 1)
|
||||||
|
t.Log(username)
|
||||||
|
|
||||||
|
password := fmt.Sprintf("%x", md5.Sum([]byte(username)))
|
||||||
|
t.Log(password)
|
||||||
}
|
}
|
||||||
|
@ -34,13 +34,13 @@ func (h *Processor) RegisterMessages(metas RegisterMetas) {
|
|||||||
func (h *Processor) RegisterMessage(cmd int32, msg, delegate any) {
|
func (h *Processor) RegisterMessage(cmd int32, msg, delegate any) {
|
||||||
h.types[cmd] = reflect.TypeOf(msg)
|
h.types[cmd] = reflect.TypeOf(msg)
|
||||||
h.delegates[cmd] = reflect.ValueOf(delegate)
|
h.delegates[cmd] = reflect.ValueOf(delegate)
|
||||||
log.DebugF("Unregister message %v", cmd)
|
log.DebugF("processor register message %v", cmd)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Processor) UnregisterMessage(cmd int32) {
|
func (h *Processor) UnregisterMessage(cmd int32) {
|
||||||
delete(h.types, cmd)
|
delete(h.types, cmd)
|
||||||
delete(h.delegates, cmd)
|
delete(h.delegates, cmd)
|
||||||
log.DebugF("Unregister message %v", cmd)
|
log.DebugF("processor unregister message %v", cmd)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Processor) GetMessageType(cmd int32) reflect.Type {
|
func (h *Processor) GetMessageType(cmd int32) reflect.Type {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user