|
@@ -54,13 +54,18 @@ type RemoteControl struct {
|
|
config *Configuration
|
|
config *Configuration
|
|
}
|
|
}
|
|
|
|
|
|
-func (rw *RemoteControl) Init(nn *neuralnetwork.NeuralNetwork) {
|
|
|
|
- rw.nn = nn
|
|
|
|
|
|
+func NewRemoteControl() (rw *RemoteControl) {
|
|
|
|
+ rw = &RemoteControl{}
|
|
rw.activationsQueue = make(chan *LayerMatrix, 5)
|
|
rw.activationsQueue = make(chan *LayerMatrix, 5)
|
|
rw.biasesQueue = make(chan *LayerMatrix, 5)
|
|
rw.biasesQueue = make(chan *LayerMatrix, 5)
|
|
rw.weightsQueue = make(chan *LayerMatrix, 5)
|
|
rw.weightsQueue = make(chan *LayerMatrix, 5)
|
|
rw.stateQueue = make(chan int, 2)
|
|
rw.stateQueue = make(chan int, 2)
|
|
rw.config = &Configuration{}
|
|
rw.config = &Configuration{}
|
|
|
|
+ return
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func (rw *RemoteControl) Init(nn *neuralnetwork.NeuralNetwork) {
|
|
|
|
+ rw.nn = nn
|
|
for _, size := range rw.nn.Sizes {
|
|
for _, size := range rw.nn.Sizes {
|
|
rw.config.Sizes = append(rw.config.Sizes, int32(size))
|
|
rw.config.Sizes = append(rw.config.Sizes, int32(size))
|
|
}
|
|
}
|
|
@@ -127,7 +132,6 @@ func (rw *RemoteControl) Activations(_ *None, srv RemoteControl_ActivationsServe
|
|
default:
|
|
default:
|
|
}
|
|
}
|
|
msg := <-rw.activationsQueue
|
|
msg := <-rw.activationsQueue
|
|
- fmt.Println("Send Activations")
|
|
|
|
srv.Send(msg)
|
|
srv.Send(msg)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -141,7 +145,6 @@ func (rw *RemoteControl) Biases(_ *None, srv RemoteControl_BiasesServer) error {
|
|
default:
|
|
default:
|
|
}
|
|
}
|
|
msg := <-rw.biasesQueue
|
|
msg := <-rw.biasesQueue
|
|
- fmt.Println("Send Biases")
|
|
|
|
srv.Send(msg)
|
|
srv.Send(msg)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -155,7 +158,6 @@ func (rw *RemoteControl) Weights(_ *None, srv RemoteControl_WeightsServer) error
|
|
default:
|
|
default:
|
|
}
|
|
}
|
|
msg := <-rw.weightsQueue
|
|
msg := <-rw.weightsQueue
|
|
- fmt.Println("Send Weights")
|
|
|
|
srv.Send(msg)
|
|
srv.Send(msg)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -172,7 +174,6 @@ func (rw *RemoteControl) State(_ *None, srv RemoteControl_StateServer) error {
|
|
msg := &NetworkState{
|
|
msg := &NetworkState{
|
|
State: NetworkState_State(state),
|
|
State: NetworkState_State(state),
|
|
}
|
|
}
|
|
- fmt.Printf("Send state %v %v\n", msg, state)
|
|
|
|
srv.Send(msg)
|
|
srv.Send(msg)
|
|
}
|
|
}
|
|
}
|
|
}
|