- Timestamp:
- Apr 7, 2020, 7:54:24 PM (5 years ago)
- Location:
- trunk
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/logger.go
r247 r248 12 12 13 13 type messageLogger struct { 14 conn *upstreamConn15 entity string14 network *network 15 entity string 16 16 17 17 path string … … 19 19 } 20 20 21 func newMessageLogger( uc *upstreamConn, entity string) *messageLogger {21 func newMessageLogger(network *network, entity string) *messageLogger { 22 22 return &messageLogger{ 23 conn: uc,24 entity: entity,23 network: network, 24 entity: entity, 25 25 } 26 26 } … … 47 47 // TODO: handle non-monotonic clock behaviour 48 48 now := time.Now() 49 path := logPath(ml. conn.network, ml.entity, now)49 path := logPath(ml.network, ml.entity, now) 50 50 if ml.path != path { 51 51 if ml.file != nil { -
trunk/upstream.go
r246 r248 1286 1286 ml, ok := uc.messageLoggers[entity] 1287 1287 if !ok { 1288 ml = newMessageLogger(uc , entity)1288 ml = newMessageLogger(uc.network, entity) 1289 1289 uc.messageLoggers[entity] = ml 1290 1290 }
Note:
See TracChangeset
for help on using the changeset viewer.