| | |
| | | return |
| | | } |
| | | if sqlUe.Owner != a.conf.NodeName { |
| | | //results, err := ExecuteWriteSql(sqlArr) |
| | | |
| | | evTime := uint64(ev.LTime) |
| | | logger.Info("ev.LTime:",evTime,",SqlUserEvent.sql:",sqlUe.Sql) |
| | | |
| | | flag, _ := ExecuteSqlByGorm(sqlUe.Sql) |
| | | logger.Info("userEvent exec ",sqlUe.Sql,",Result:",flag) |
| | | } |
| | | } else if ev.Name == UserEventSyncDbTablePersonCache { |
| | | logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload)) |
| | | SyncDbTablePersonCacheChan <- ev.Payload |
| | | } |
| | | |
| | |
| | | // Stop serf agent |
| | | func (a *Agent) Stop() { |
| | | if a.errorCh != nil { |
| | | a.Leave() |
| | | a.Shutdown() |
| | | logger.Info("a.Shutdown()", a.Leave()) |
| | | logger.Info("a.Shutdown()", a.Shutdown()) |
| | | close(a.errorCh) |
| | | a.errorCh = nil |
| | | } |