mirror of
https://github.com/wader/fq.git
synced 2024-12-02 04:05:35 +03:00
postgres: refactoring
This commit is contained in:
parent
ff4b6fdf14
commit
f224ed000e
@ -57,5 +57,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -58,5 +58,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -58,5 +58,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -58,5 +58,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -60,5 +60,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
DecodePageHeaderDataFn: ee14.DecodePageHeaderData,
|
||||
DecodePageSpecialFn: ee14.DecodePageSpecial,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -79,5 +79,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
DecodePageHeaderDataFn: ee14.DecodePageHeaderData,
|
||||
DecodePageSpecialFn: ee14.DecodePageSpecial,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -60,5 +60,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
DecodePageHeaderDataFn: ee14.DecodePageHeaderData,
|
||||
DecodePageSpecialFn: ee14.DecodePageSpecial,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -60,5 +60,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
DecodePageHeaderDataFn: ee14.DecodePageHeaderData,
|
||||
DecodePageSpecialFn: ee14.DecodePageSpecial,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -87,5 +87,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
DecodePageHeaderDataFn: ee14.DecodePageHeaderData,
|
||||
DecodePageSpecialFn: ee14.DecodePageSpecial,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -70,5 +70,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -70,5 +70,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -51,5 +51,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
@ -164,7 +164,7 @@ type itemIdDataD struct {
|
||||
lpLen uint32
|
||||
}
|
||||
|
||||
func DecodeHeap(d *decode.D, heap *HeapD) any {
|
||||
func DecodeHeap(heap *HeapD, d *decode.D) any {
|
||||
d.SeekAbs(0)
|
||||
decodeHeapPages(heap, d)
|
||||
|
||||
|
@ -24,5 +24,5 @@ func DecodeHeap(d *decode.D) any {
|
||||
PageSize: common.HeapPageSize,
|
||||
DecodePageHeaderDataFn: common14.DecodePageHeaderData,
|
||||
}
|
||||
return common14.DecodeHeap(d, heap)
|
||||
return common14.DecodeHeap(heap, d)
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user