mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Code Activity

changed time format

Browse source
This commit is contained in:
postmannen 2021-08-27 12:27:38 +02:00
parent 11e50db47a
commit ebbca59eb7
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ringbuffer.go
View file

@ -267,7 +267,7 @@ func (r *ringBuffer) processBufferMessages(samValueBucket string, outCh chan sam
// it out of the K/V Store.
r.deleteKeyFromBucket(samValueBucket, strconv.Itoa(v.ID))
r.permStore <- fmt.Sprintf("%v : %+v\n", time.Now().UTC(), v)
r.permStore <- fmt.Sprintf("%v : %+v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), v)
// TODO: REMOVE: Dump the whole KV store
// err := r.printBucketContent(samValueBucket)

2
server.go
View file

@ -295,7 +295,7 @@ func sendErrorLogMessage(metrics *metrics, newMessagesCh chan<- []subjectAndMess
// of the error
func createErrorMsgContent(FromNode Node, theError error) subjectAndMessage {
// Add time stamp
er := fmt.Sprintf("%v, %v\n", time.Now().UTC(), theError.Error())
er := fmt.Sprintf("%v, %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), theError.Error())
sam := subjectAndMessage{
Subject: newSubject(REQErrorLog, "errorCentral"),

8
subscriber_method_types.go
View file

@ -346,7 +346,7 @@ func (m methodREQOpCommand) handler(proc process, message Message, nodeName stri
// be returned in the reply message.
for _, idMap := range proc.processes.active {
for _, v := range idMap {
s := fmt.Sprintf("%v, proc: %v, id: %v, name: %v, allowed from: %s\n", time.Now().UTC(), v.processKind, v.processID, v.subject.name(), v.allowedReceivers)
s := fmt.Sprintf("%v, proc: %v, id: %v, name: %v, allowed from: %s\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), v.processKind, v.processID, v.subject.name(), v.allowedReceivers)
sb := []byte(s)
out = append(out, sb...)
}
@ -625,7 +625,7 @@ func (m methodREQHello) getKind() CommandOrEvent {
// Handler for receiving hello messages.
func (m methodREQHello) handler(proc process, message Message, node string) ([]byte, error) {
data := fmt.Sprintf("Received hello from %#v\n", message.FromNode)
data := fmt.Sprintf("%v, Received hello from %#v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), message.FromNode)
fileName := message.FileName
folderTree := filepath.Join(proc.configuration.SubscribersDataFolder, message.Directory, string(message.FromNode), string(message.Method))
@ -787,7 +787,7 @@ func (m methodREQPing) handler(proc process, message Message, node string) ([]by
defer f.Close()
// And write the data
d := fmt.Sprintf("%v, ping received from %v\n", time.Now().UTC(), message.FromNode)
d := fmt.Sprintf("%v, ping received from %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), message.FromNode)
_, err = f.Write([]byte(d))
f.Sync()
if err != nil {
@ -865,7 +865,7 @@ func (m methodREQPong) handler(proc process, message Message, node string) ([]by
defer f.Close()
// And write the data
d := fmt.Sprintf("%v, pong received from %v\n", time.Now().UTC(), message.PreviousMessage.ToNode)
d := fmt.Sprintf("%v, pong received from %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), message.PreviousMessage.ToNode)
_, err = f.Write([]byte(d))
f.Sync()
if err != nil {