f33f7b5c29
+ Refactored all imports + Fixed a bug for the logging regarding removing \n \t \r + Updated to current MGO release + Changed the name of ICCC
71 lines
2.3 KiB
Go
71 lines
2.3 KiB
Go
package NumGen
|
|
|
|
import (
|
|
"github.com/SommerEngineering/Ocean/Log"
|
|
LM "github.com/SommerEngineering/Ocean/Log/Meta"
|
|
"github.com/SommerEngineering/Ocean/Shutdown"
|
|
"gopkg.in/mgo.v2/bson"
|
|
"time"
|
|
)
|
|
|
|
func producer(name string) {
|
|
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSTARTUP, `The NumGen producer is now starting.`, `name=`+name)
|
|
|
|
// Get my channel:
|
|
myChannel := requestChannel4Name(name)
|
|
|
|
// Read my next free number:
|
|
currentNextFreeNumber := nextFreeNumberFromDatabase(name)
|
|
|
|
// Where is the next "reload"?
|
|
nextReload := currentNextFreeNumber + int64(channelBufferSize)
|
|
|
|
// Set the next free number to the database:
|
|
updateNextFreeNumber2Database(name, nextReload)
|
|
|
|
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSTARTUP, `The NumGen producer is now running.`, `name=`+name)
|
|
for nextNumber := currentNextFreeNumber; true; {
|
|
if Shutdown.IsDown() {
|
|
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSHUTDOWN, `The NumGen producer is now down.`, `name=`+name)
|
|
return
|
|
}
|
|
|
|
if nextNumber > nextReload {
|
|
nextReload = nextReload + int64(channelBufferSize)
|
|
updateNextFreeNumber2Database(name, nextReload)
|
|
|
|
// Enables the administrator to monitor the frequence of chunks and is able to reconfigure the settings:
|
|
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelDEBUG, LM.MessageNamePRODUCER, `The NumGen producer creates the next chunk.`, `name=`+name)
|
|
}
|
|
|
|
// Enqueue the next number:
|
|
select {
|
|
case myChannel <- nextNumber:
|
|
nextNumber++
|
|
case <-time.After(time.Millisecond * 500):
|
|
}
|
|
}
|
|
}
|
|
|
|
func nextFreeNumberFromDatabase(name string) (result int64) {
|
|
selection := bson.D{{`Name`, name}}
|
|
searchResult := NumberGenScheme{}
|
|
|
|
count, _ := collectionNumGen.Find(selection).Count()
|
|
if count == 1 {
|
|
collectionNumGen.Find(selection).One(&searchResult)
|
|
result = searchResult.NextFreeNumber
|
|
} else {
|
|
searchResult.Name = name
|
|
searchResult.NextFreeNumber = startValue64
|
|
collectionNumGen.Insert(searchResult)
|
|
result = searchResult.NextFreeNumber
|
|
}
|
|
return
|
|
}
|
|
|
|
func updateNextFreeNumber2Database(name string, nextFreeNumber int64) {
|
|
selection := bson.D{{`Name`, name}}
|
|
collectionNumGen.Update(selection, NumberGenScheme{Name: name, NextFreeNumber: nextFreeNumber})
|
|
}
|