Commit 00036ba5 by lancet

some cleanups on obsolete code

parent 3c6e13dd
...@@ -4,19 +4,6 @@ import ( ...@@ -4,19 +4,6 @@ import (
"time" "time"
) )
// cleaner - уничтожаем устаревшие ключи
func (store *Store) cleaner() {
reply := make(chan Message)
for {
msg := Message{Action: "POP", Reply: reply}
store.exchange <- msg
got := <-reply
if got.Error == true {
time.Sleep(1 * time.Second)
}
}
}
// control - управление хранилищем // control - управление хранилищем
func (store *Store) control() { func (store *Store) control() {
tick := time.Tick(time.Second) // Каждую секунду ставим в очередь разделитель "вёдер" tick := time.Tick(time.Second) // Каждую секунду ставим в очередь разделитель "вёдер"
...@@ -33,13 +20,6 @@ func (store *Store) control() { ...@@ -33,13 +20,6 @@ func (store *Store) control() {
case request := <-store.exchange: case request := <-store.exchange:
reply := Message{} reply := Message{}
switch request.Action { switch request.Action {
/*
case "POP": // внутренний метод, часть механизма устаревания. Недоступен клиентам.
err := store.popNode()
if err != nil {
reply.Error = true
}
*/
case "SET": case "SET":
err := store.setNode(request.Key, request.Value) err := store.setNode(request.Key, request.Value)
reply.Key = request.Key reply.Key = request.Key
......
...@@ -25,9 +25,7 @@ func (store *Store) init() { ...@@ -25,9 +25,7 @@ func (store *Store) init() {
} }
go store.control() // запускаем управление хранилищем go store.control() // запускаем управление хранилищем
//go store.cleaner() // запускаем устаревание записей
store.isInit = true store.isInit = true
} }
// addNode - добавляем новый узел в хвост очереди. // addNode - добавляем новый узел в хвост очереди.
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment