-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.go
114 lines (103 loc) · 2.59 KB
/
server.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package main
import (
st "statquery"
"fmt"
"errors"
"log"
"net"
"net/rpc"
"math/rand"
"sync/atomic"
"time"
)
type Datastore [][]byte
// stats
var sentQ uint64 = 0
var hardness uint64 = 0
var widthS uint64 = 0
var concReqs int64 = 0
func (ds *Datastore) GetIds(pars st.FbackParameters, data *[]uint32) error {
atomic.AddInt64(&concReqs, 1)
calculate(pars.Hardness)
rlen := pars.IdCount
// time.Sleep(time.Millisecond*time.Duration(rand.Intn(1)))
// fmt.Println(ids)
*data = make([]uint32,rlen,rlen)
var width uint64 = 0
for i := 0; i < rlen; i++ {
var blocksize uint32 = 1 << uint32(pars.SizeLower+rand.Intn(pars.SizeUpper-pars.SizeLower))
(*data)[i] = blocksize+4
width += 1
}
atomic.AddUint64(&sentQ, 1)
atomic.AddUint64(&hardness, uint64(pars.Hardness))
atomic.AddUint64(&widthS, width)
atomic.AddInt64(&concReqs, -1)
return nil
}
func Report() {
for {
sentqlocal := atomic.LoadUint64(&sentQ)
if sentqlocal > 0 {
fmt.Println(sentqlocal,atomic.LoadUint64(&hardness),atomic.LoadUint64(&widthS)/sentqlocal,atomic.LoadInt64(&concReqs))
}
//reset
atomic.StoreUint64(&sentQ,0)
atomic.StoreUint64(&hardness,0)
atomic.StoreUint64(&widthS,0)
time.Sleep(time.Millisecond*1000)
}
}
func main() {
var USIZE int = 17
fmt.Println("starting")
// create some data blocks
ds := make(Datastore,USIZE,USIZE)
var idx uint32 = 0
for ; idx < uint32(USIZE); idx++ {
var blocksize uint32 = 1 << idx
ds[idx] = make([]byte,blocksize,blocksize)
}
fmt.Println("created data")
// start report
go Report()
// connection
ltuple, err := net.ResolveTCPAddr("tcp", "0.0.0.0:37001")
if err != nil {
log.Fatal(err)
}
lsocket, err := net.ListenTCP("tcp", ltuple)
if err != nil {
log.Fatal(err)
}
rpc.Register(&ds)
fmt.Println("server started")
rpc.Accept(lsocket)
}
// matric product
func dot(x, y [][]float32) ([][]float32, error) {
if len(x[0]) != len(y) {
return nil, errors.New("wrong matrix format")
}
out := make([][]float32, len(x))
for i := 0; i < len(x); i += 1 {
for j := 0; j < len(y); j += 1 {
if len(out[i]) < 1 {
out[i] = make([]float32, len(y))
}
out[i][j] += x[i][j] * y[j][i]
}
}
return out, nil
}
func calculate(hardness int) {
X := make([][]float32,hardness,hardness)
for i:=0; i<hardness; i++ {
X[i] = make([]float32,hardness,hardness)
}
Y := make([][]float32,hardness,hardness)
for i:=0; i<hardness; i++ {
Y[i] = make([]float32,hardness,hardness)
}
dot(X, Y)
}