Code Review
/
src
/
xds
/
xds-agent.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Added new SDKs management support
[src/xds/xds-agent.git]
/
lib
/
agent
/
events.go
diff --git
a/lib/agent/events.go
b/lib/agent/events.go
index
df7015a
..
678f116
100644
(file)
--- a/
lib/agent/events.go
+++ b/
lib/agent/events.go
@@
-88,14
+88,14
@@
func (e *Events) UnRegister(evName, sessionID string) error {
}
// Emit Used to manually emit an event
}
// Emit Used to manually emit an event
-func (e *Events) Emit(evName string, data interface{},fromSid string) error {
+func (e *Events) Emit(evName string, data interface{},
fromSid string) error {
var firstErr error
if _, ok := e.eventsMap[evName]; !ok {
return fmt.Errorf("Unsupported event type")
}
var firstErr error
if _, ok := e.eventsMap[evName]; !ok {
return fmt.Errorf("Unsupported event type")
}
-
e.LogSillyf("Emit Event %s: %v", evName, data)
+ e.LogSillyf("Emit Event %s: %v", evName, data)
firstErr = nil
evm := e.eventsMap[evName]
firstErr = nil
evm := e.eventsMap[evName]
@@
-113,7
+113,7
@@
func (e *Events) Emit(evName string, data interface{},fromSid string) error {
Type: evName,
Data: data,
}
Type: evName,
Data: data,
}
- e.Log.Debugf("Emit Event %s: %v", evName, sid)
+
if err := (*so).Emit(evName, msg); err != nil {
e.Log.Errorf("WS Emit %v error : %v", evName, err)
if firstErr == nil {
if err := (*so).Emit(evName, msg); err != nil {
e.Log.Errorf("WS Emit %v error : %v", evName, err)
if firstErr == nil {