forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-23 05:06:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

added equue write

Browse source
This commit is contained in:
obscuren 2015-05-12 13:50:28 +02:00
parent 6bf36e5593
commit 9d134b356c
1 changed files with 14 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
miner/gpu_agent.go
View file

@ -10,6 +10,7 @@ import (
"text/template" "text/template"
"unsafe" "unsafe"
"github.com/ethereum/ethash"
"github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common"
"github.com/samuel/go-opencl/cl" "github.com/samuel/go-opencl/cl"
) )
@ -25,11 +26,11 @@ type params struct {
} }
const ( const (
kernelFn = "ethash.cl" kernelFn = "ethash_kernel.cl"
searchBuffSize = 4 searchBuffSize = 4
maxSearchResults = 63 maxSearchResults = 63
searchBatchSize = 1024 searchBatchSize = 1024
dagSize = 128 dagSize = 1024
SIZEOF_UINT32 = 4 SIZEOF_UINT32 = 4
ETHASH_MIX_BYTES = 32 ETHASH_MIX_BYTES = 32
@ -37,6 +38,7 @@ const (
var ( var (
workGroupSize = 256 workGroupSize = 256
pow *ethash.Ethash
) )
type EthashCL struct { type EthashCL struct {
@ -134,6 +136,14 @@ func New() (*EthashCL, error) {
return nil, fmt.Errorf("dag buffer err:", err) return nil, fmt.Errorf("dag buffer err:", err)
} }
pow, err = ethash.NewForTesting()
if err != nil {
return nil, fmt.Errorf("dag err:", err)
}
dag := pow.Full.DAG(0).Ptr()
queue.EnqueueWriteBuffer(dagBuff, true, 0, dagSize, dag, nil)
headerBuff, err := context.CreateEmptyBuffer(cl.MemReadOnly, 32) headerBuff, err := context.CreateEmptyBuffer(cl.MemReadOnly, 32)
if err != nil { if err != nil {
return nil, fmt.Errorf("header buffer err:", err) return nil, fmt.Errorf("header buffer err:", err)
@ -147,7 +157,6 @@ func New() (*EthashCL, error) {
} }
searchBuffers[i] = searchBuff searchBuffers[i] = searchBuff
} }
queue.EnqueueWriteBuffer(dagBuff, true, 0, dagSize, nil, nil)
return &EthashCL{ return &EthashCL{
ctx: context, ctx: context,
@ -238,7 +247,7 @@ func (h *EthashCL) Search(header common.Hash, target uint64, doneFn func([]uint6
func main() { func main() {
fmt.Println("initialising OpenCL miner...") fmt.Println("initialising OpenCL miner...")
ethash, err := New() gpu, err := New()
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
os.Exit(1) os.Exit(1)
@ -246,7 +255,7 @@ func main() {
fmt.Println("OpenCL miner initialised") fmt.Println("OpenCL miner initialised")
fmt.Println("Searching for solution...") fmt.Println("Searching for solution...")
err = ethash.Search(common.Hash{}, 1000000000000, func(res []uint64) bool { err = gpu.Search(common.Hash{}, 1000000000000, func(res []uint64) bool {
fmt.Printf("found: %x\n", res) fmt.Printf("found: %x\n", res)
return true return true
}) })