admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix timestamp endian error (#11220)

Browse Source 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
This commit is contained in:
godchen 2021-11-05 13:56:58 +08:00 committed by GitHub
parent eb9bbce038
commit 9bf68ac3eb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/util/typeutil/convension.go
View File

@ -12,6 +12,7 @@
package typeutil
import (
"encoding/binary"
"fmt"
"math"
"reflect"
@ -57,13 +58,16 @@ func BytesToUint64(b []byte) (uint64, error) {
return 0, fmt.Errorf("Failed to convert []byte to uint64: invalid data, must 8 bytes, but %d", len(b))
}
return common.Endian.Uint64(b), nil
// do not use little or common endian for compatibility issues(the msgid used in rocksmq is using this)
return binary.BigEndian.Uint64(b), nil
}
// Uint64ToBytes converts uint64 to a byte slice.
func Uint64ToBytes(v uint64) []byte {
b := make([]byte, 8)
common.Endian.PutUint64(b, v)
// do not use little or common endian for compatibility issues(the msgid used in rocksmq is using this)
binary.BigEndian.PutUint64(b, v)
return b
}