本文整理汇总了Golang中github.com/donnie4w/go-logger/logger.Error函数的典型用法代码示例。如果您正苦于以下问题:Golang Error函数的具体用法?Golang Error怎么用?Golang Error使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Error函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: copyFile
/*复制文件 如果存在则不再复制*/
func copyFile(src, dest string) error {
srcFile, e := os.Open(src)
if e != nil {
logger.Error("copyFile:", e.Error())
return e
}
defer srcFile.Close()
df, e := os.Open(dest)
defer df.Close()
if e != nil && os.IsNotExist(e) {
logger.Info("desIniFile:", dest, "file not exist!")
destFile, e := os.Create(dest)
if e != nil {
logger.Error("copyFile destFile:", e.Error())
return e
}
defer destFile.Close()
io.Copy(destFile, srcFile)
logger.Info("copy file from :", src, " to ", dest)
} else {
logger.Info("desIniFile:", dest, "已存在")
}
return nil
}
开发者ID:dcmsy,项目名称:receive,代码行数:27,代码来源:receive_file.go
示例2: RunSingleDataPipe
/*执行数据同步读取直接写入 single data 单次执行可变的业务数据 */
func (xmlInfo *XmlInfo) RunSingleDataPipe(dbIni *DBini) {
logger.Info("All run begin >>>>>>>>>>>>>>>>")
logger.Info("dbIni.F_DbType:", dbIni.F_DbType, "dbIni.T_DbType:", dbIni.T_DbType)
if !StartFlag {
return
}
defer func() {
if err := recover(); err != nil {
logger.Error("查询数据库失败", err)
}
}()
f_pwd, _ := Base64Dec(dbIni.F_Password)
t_pwd, _ := Base64Dec(dbIni.T_Password)
dbIni.F_Db.Db_open(dbIni.F_DbType, dbIni.F_User, f_pwd, dbIni.F_Ip, dbIni.F_Port, dbIni.F_Dbname)
dbIni.T_Db.Db_open(dbIni.T_DbType, dbIni.T_User, t_pwd, dbIni.T_Ip, dbIni.T_Port, dbIni.T_Dbname)
//关闭数据库
defer dbIni.F_Db.db.Close()
defer dbIni.T_Db.db.Close()
if dbIni.F_Db.db == nil || dbIni.T_Db.db == nil {
logger.Error("无法链接两方数据库")
panic("无法链接两方数据库")
return
}
DataSinglePipe(dbIni, xmlInfo)
Updater(dbIni, xmlInfo)
ExecProc(dbIni, xmlInfo)
logger.Info("All run end >>>>>>>>>>>>>>>>")
time.Sleep(5 * time.Second)
}
开发者ID:dcmsy,项目名称:receive,代码行数:31,代码来源:receive_single_pipe.go
示例3: Check
/*判断是否需要查询数据*/
func Check(dbIni *DBini, xmlInfo *XmlInfo) {
if strings.EqualFold(xmlInfo.IsValData, "true") {
xmlInfo.CheckFlag = true
return
}
if len(xmlInfo.CheckRowSQL) > 0 {
defer func() {
if err := recover(); err != nil {
logger.Error("查询数据库失败", err)
}
}()
f_pwd, _ := Base64Dec(dbIni.F_Password)
dbIni.F_Db.Db_open(dbIni.F_DbType, dbIni.F_User, f_pwd, dbIni.F_Ip, dbIni.F_Port, dbIni.F_Dbname)
defer dbIni.F_Db.db.Close()
query, err := dbIni.F_Db.db.Query(strings.Replace(xmlInfo.CheckRowSQL, "@[dbname]", dbIni.F_Dbname, -1)) //查询数据库
defer query.Close()
if err != nil {
logger.Error("查询数据库失败", err.Error())
xmlInfo.CheckFlag = false
panic(err)
return
}
cols, _ := query.Columns()
values := make([][]byte, len(cols)) //values是每个列的值
scans := make([]interface{}, len(cols)) //query.Scan的参数 用len(cols)定住当次查询的长度
for i := range values { //让每一行数据都填充到[][]byte里面
scans[i] = &values[i]
}
dbRows := 0
if query.Next() {
//判断是否与上次的数据一致,如果不一致则查询数据库,否则不查询
if err := query.Scan(scans...); err != nil { //query.Scan查询出来的不定长值放到scans[i] = &values[i],也就是每行都放在values里
logger.Error(err)
xmlInfo.CheckFlag = false
return
}
for _, v := range values {
intV, err := strconv.Atoi(string(v))
if err != nil {
xmlInfo.CheckFlag = false
} else {
dbRows = intV
}
}
if dbRows != 0 && dbRows != xmlInfo.RowNum { //获取reader 如何获取到数据则置为0,如果获取不到了则赋予全局GobalNum
xmlInfo.RowNum = dbRows
xmlInfo.GobalNum = dbRows
xmlInfo.CheckFlag = true
} else {
xmlInfo.CheckFlag = false
}
} else {
xmlInfo.CheckFlag = true
}
} else {
logger.Info(xmlInfo.Remark, "无需查询系统库行记录是否变化")
xmlInfo.CheckFlag = true
}
}
开发者ID:dcmsy,项目名称:datapost,代码行数:61,代码来源:datapost_pipe.go
示例4: insertStdOrgMap
/*添加待匹配组织机构*/
func insertStdOrgMap(dbIni *DBini, noneOrgMap map[string]string) {
stdOrgMapStmt, err := dbIni.T_Db.db.Prepare(StdOrgMapInsertSQL)
defer stdOrgMapStmt.Close()
if err != nil {
logger.Error(err)
return
}
for deptname, _ := range noneOrgMap {
if len(deptname) == 0 {
continue
}
stdOrgMapQuery, err := dbIni.T_Db.db.Query(StdOrgMapQuerySQL, deptname)
if err != nil {
logger.Error("查询数据库失败", err.Error())
return
}
defer stdOrgMapQuery.Close()
if stdOrgMapQuery.Next() { //如果存在 则判断是否需要更新 sysnames
cols, _ := stdOrgMapQuery.Columns()
colsLength := len(cols)
values := make([][]byte, colsLength)
scans := make([]interface{}, colsLength)
for i := range values {
scans[i] = &values[i]
}
if err := stdOrgMapQuery.Scan(scans...); err != nil {
logger.Error(err)
return
}
row := make(map[string]string) //每行数据
for k, v := range values {
key := cols[k]
row[key] = string(v)
}
id := row["id"]
sysnames := row["sysnames"]
if len(sysnames) > 0 && len(dbIni.SysName) > 0 && !strings.Contains(sysnames, dbIni.SysName) {
updateStmt, err := dbIni.T_Db.db.Prepare(UpdateSQL)
defer updateStmt.Close()
if err != nil {
logger.Error(err)
return
}
updateScans := make([]interface{}, 2)
updateScans[0] = sysnames + "," + dbIni.SysName
updateScans[1] = id
updateStmt.Exec(updateScans...)
}
} else { //insert
stdOrgScans := make([]interface{}, 4)
stdOrgScans[0] = deptname
stdOrgScans[1] = dbIni.SysId
stdOrgScans[2] = dbIni.SysName
stdOrgScans[3] = dbIni.SysName
stdOrgMapStmt.Exec(stdOrgScans...)
}
}
}
开发者ID:dcmsy,项目名称:receive,代码行数:59,代码来源:receive_orgmatch.go
示例5: StartOrgSync
/*启动组织机构同步服务*/
func (configinfo *ConfigInfo) StartOrgSync() {
logger.Info(" StartOrgSync is run... ")
var orgVersionUrl = "http://" + configinfo.core_ip + ":" + configinfo.core_port + configinfo.orgversion_url
var allOrgUrl = "http://" + configinfo.core_ip + ":" + configinfo.core_port + configinfo.allorg_url
logger.Info("orgVersionUrl start >>>>>>>>>>>>>>>>", orgVersionUrl)
logger.Info("allOrgUrl start >>>>>>>>>>>>>>>>", allOrgUrl)
//发起链接访问,获取返回的json数据
for {
var return_orgs []byte
var return_version []byte
var tmpOrgVersion string = ""
if response, err := http.Get(orgVersionUrl); err != nil {
logger.Error(" err = ", err)
} else {
defer response.Body.Close()
if return_version, err = ioutil.ReadAll(response.Body); err != nil {
logger.Error(" err = ", err)
}
tmpOrgVersion = string(return_version)
}
logger.Info(" return_version = ", tmpOrgVersion)
if len(OrgVersion) == 0 || (len(tmpOrgVersion) > 0 && !strings.EqualFold(tmpOrgVersion, OrgVersion)) {
OrgVersion = tmpOrgVersion
//重新加载组织机构
if response, err := http.Get(allOrgUrl); err != nil {
logger.Error(" err = ", err)
} else {
defer response.Body.Close()
if return_orgs, err = ioutil.ReadAll(response.Body); err != nil {
logger.Error(" err = ", err)
}
}
var orgInfos []OrgInfo
err := json.Unmarshal(return_orgs, &orgInfos)
if err != nil {
logger.Error(" err = ", err)
}
if len(orgInfos) > 0 {
for k, _ := range OrgMap {
delete(OrgMap, k)
}
for k, _ := range OrgNameMap {
delete(OrgNameMap, k)
}
for i := range orgInfos {
org := &orgInfos[i]
OrgMap[org.Org_path] = org.Id
OrgMap[org.Name] = org.Id
OrgNameMap[org.Id] = org.Name
}
}
}
time.Sleep(Time_interval * time.Second)
}
}
开发者ID:dcmsy,项目名称:receive,代码行数:56,代码来源:receive_orgmatch.go
示例6: InitXmlInfo
/*读取xml信息初始化xmlinfo*/
func InitXmlInfo(dirName string) XmlInfo {
content, err := ioutil.ReadFile("xml/HostAudit/repeatetimer_主机审计日志.xml")
if err != nil {
logger.Error(err)
}
var result XmlInfo
err = xml.Unmarshal(content, &result)
if err != nil {
logger.Error(err)
}
return result
}
开发者ID:dcmsy,项目名称:datapost,代码行数:13,代码来源:datapost_pipe.go
示例7: TestReadXml
/*测试读取xml*/
func TestReadXml() {
content, err := ioutil.ReadFile("xml/HostAudit/repeatetimer_主机审计日志.xml")
if err != nil {
logger.Error(err)
}
var result XmlInfo
err = xml.Unmarshal(content, &result)
if err != nil {
logger.Error(err)
}
logger.Debug(result.FileName)
}
开发者ID:dcmsy,项目名称:datapost,代码行数:13,代码来源:datapost_util.go
示例8: ConServer
func ConServer(hostport string) (*net.TCPConn, error) {
remoteAddr, err_r := net.ResolveTCPAddr("tcp4", hostport)
if err_r != nil {
log.Error("Conn error,ResolveTCPAddr:", hostport)
return nil, err_r
}
conn, err := net.DialTCP("tcp4", nil, remoteAddr)
if err != nil {
log.Error("Conn error,connect to", hostport)
return nil, err
}
return conn, nil
}
开发者ID:markman101,项目名称:Ginger,代码行数:14,代码来源:tcpsocket.go
示例9: Db_open
/*获取数据库连接 支持mysql mssql mongodb*/
func (f *My_db) Db_open(dbtype string, dbusername string, dbpassowrd string, dbhostsip string, dbport string, dbname string) {
var connString string
if strings.EqualFold(dbtype, "mysql") { //root:@tcp(localhost:3306)/go?charset=utf8
connString = fmt.Sprintf("%s:%[email protected](%s:%s)/%s?charset=utf8", dbusername, dbpassowrd, dbhostsip, dbport, dbname)
} else if strings.EqualFold(dbtype, "mssql") {
connString = fmt.Sprintf("server=%s;user id=%s;password=%s;port=%s;database=%s;encrypt=disable;", dbhostsip, dbusername, dbpassowrd, dbport, dbname)
}
Odb, err := sql.Open(dbtype, connString)
if err != nil {
logger.Error(err)
logger.Error("链接失败 >dbusername:%s dbpassowrd:%s dbhostsip:%s dbname:%s", dbusername, dbpassowrd, dbhostsip, dbname)
f.db = nil
}
f.db = Odb
}
开发者ID:dcmsy,项目名称:datapost,代码行数:16,代码来源:datapost_util.go
示例10: Decode_pack
func (protocol *TransProtocolComm) Decode_pack(data []byte) (*Packet, int) {
log.Info("Enter Decode_pack")
decodeLen := 0
pack := &Packet{}
dataLen := len(data)
offset := 0
headLen := binary.Size(pack._header)
//1.get packhader
//= not cause out of memory so >= is needed
for offset = 0; dataLen-offset >= headLen; offset++ {
pack._header._ver = int16(binary.BigEndian.Uint16(data[offset : offset+2]))
pack._header._seq = int32(binary.BigEndian.Uint32(data[offset+2 : offset+6]))
pack._header._type = int16(binary.BigEndian.Uint16(data[offset+6 : offset+8]))
pack._header._bodyLen = int32(binary.BigEndian.Uint32(data[offset+8 : offset+12]))
//get pack header successful
if int16(VER) == pack._header._ver && pack._header._bodyLen < int32(MAX_PACK_SIZE) {
break
}
}
//2.check is a complete Packet
if dataLen-offset < headLen || dataLen-offset < int(pack._header._bodyLen) {
//can't find VER in data Slice or is not a complete pack.
log.Error("[PACK_NOT_COMPLETE],pack bodyLen is", pack._header._bodyLen)
return nil, 0
}
//3.get a complete pack
pack._data = make([]byte, pack._header._bodyLen)
copy(pack._data, data[offset:])
decodeLen = offset + headLen + int(pack._header._bodyLen)
return pack, decodeLen
}
开发者ID:markman101,项目名称:Ginger,代码行数:32,代码来源:transprotocol.go
示例11: copyIniFiles
/**复制所有ini文件*/
func copyIniFiles() error {
var rootName string = "xml_ini"
var desRootName string = "xml"
var suffix string = ".ini"
var rootPath string = "xml_ini//xml_ini.ini"
var fileFilter string = "/"
s := []string{rootName, fileFilter}
var path = strings.Join(s, "")
results := make(map[string]string)
err := filepath.Walk(path, func(path string, f os.FileInfo, err error) error {
if f == nil {
return err
}
if f.IsDir() {
iniFile := path + fileFilter + f.Name() + suffix
desIniFile := strings.Replace(path, rootName, desRootName, -1) + fileFilter + f.Name() + suffix
if !strings.EqualFold(iniFile, rootPath) && strings.HasSuffix(iniFile, suffix) {
results[desIniFile] = iniFile
copyFile(iniFile, desIniFile)
}
}
return nil
})
if err != nil {
logger.Error("filepath.Walk() returned %v\n", err)
}
return err
}
开发者ID:dcmsy,项目名称:receive,代码行数:29,代码来源:receive_file.go
示例12: log
func log(i int) {
logger.Debug("Debug>>>>>>>>>>>>>>>>>>>>>>" + strconv.Itoa(i))
logger.Info("Info>>>>>>>>>>>>>>>>>>>>>>>>>" + strconv.Itoa(i))
logger.Warn("Warn>>>>>>>>>>>>>>>>>>>>>>>>>" + strconv.Itoa(i))
logger.Error("Error>>>>>>>>>>>>>>>>>>>>>>>>>" + strconv.Itoa(i))
logger.Fatal("Fatal>>>>>>>>>>>>>>>>>>>>>>>>>" + strconv.Itoa(i))
}
开发者ID:EastQ,项目名称:go-logger,代码行数:7,代码来源:logger_test.go
示例13: Writer
/*将数据写入数据库*/
func Writer(dbIni *DBini, xmlInfo *XmlInfo) {
logger.Info("***************************")
logger.Info("Writer begin >>>>>>>>>>>>>>>>")
if len(xmlInfo.Datas) == 0 {
logger.Info("Writer end >>>>>>>>>>>>>>>>")
return
}
stmt, err := dbIni.T_Db.db.Prepare(xmlInfo.InsertSQL)
defer stmt.Close()
if err != nil {
logger.Error(err)
return
}
colsLength := len(xmlInfo.Columns)
c := 0
arrIds := make([]string, len(xmlInfo.Datas))
for _, v := range xmlInfo.Datas {
scans := make([]interface{}, colsLength+2)
for i := range xmlInfo.Columns {
scans[i] = v[xmlInfo.Columns[i]]
}
scans[colsLength] = dbIni.SysId
scans[colsLength+1] = dbIni.SysName
arrIds[c] = v[xmlInfo.Columns[0]]
stmt.Exec(scans...)
c++
}
xmlInfo.Datas = nil
xmlInfo.Ids = arrIds
logger.Info("Writer end >>>>>>>>>>>>>>>>")
}
开发者ID:dcmsy,项目名称:datapost,代码行数:32,代码来源:datapost_pipe.go
示例14: DataLog
/**
*记录数据日志
*------ flag 1 成功 0 失败
*------jobname dataname syscode sysname platform producer beginTime flag endTime errmsg
*/
func DataLog(dbIni *DBini, xmlInfo *XmlInfo, begtime string, err error) {
stmt, err := dbIni.T_Db.db.Prepare(LogInsertSQL)
defer stmt.Close()
if err != nil {
logger.Error(err)
return
}
scans := make([]interface{}, 10)
var flag string = "1"
var msg string
if err != nil {
flag = "0"
msg = string(err.Error())
}
scans[0] = xmlInfo.Remark
scans[1] = xmlInfo.Remark
scans[2] = dbIni.SysId
scans[3] = dbIni.SysName
scans[4] = dbIni.Platform
scans[5] = dbIni.Company
scans[6] = begtime
scans[7] = flag
scans[8] = NowTime()
scans[9] = msg
stmt.Exec(scans...)
}
开发者ID:dcmsy,项目名称:receive,代码行数:31,代码来源:receive_log.go
示例15: StdOrgSync
/*已匹配组织机构信息*/
func (sys *SysIni) StdOrgSync() {
logger.Info("StdOrgSync start >>>>>>>>>>>>>>>>")
defer func() {
if err := recover(); err != nil {
logger.Error("查询数据库失败", err)
}
}()
for {
dbIni := &sys.dbini
t_pwd, _ := Base64Dec(dbIni.T_Password)
dbIni.T_Db.Db_open(dbIni.T_DbType, dbIni.T_User, t_pwd, dbIni.T_Ip, dbIni.T_Port, dbIni.T_Dbname)
defer dbIni.T_Db.db.Close()
query, err := dbIni.T_Db.db.Query(MapQuerySQL) //查询数据库
if err != nil {
logger.Error("查询数据库失败", err.Error())
panic(err)
return
}
defer query.Close()
for k, _ := range StdOrgMap {
delete(StdOrgMap, k)
}
cols, _ := query.Columns()
colsLength := len(cols)
values := make([][]byte, colsLength)
scans := make([]interface{}, colsLength)
for i := range values {
scans[i] = &values[i]
}
for query.Next() { //循环
if err := query.Scan(scans...); err != nil {
logger.Error(err)
return
}
row := make(map[string]string) //每行数据
for k, v := range values {
key := cols[k]
row[key] = string(v)
}
StdOrgMap[row["map_deptname"]] = row["std_deptid"]
}
time.Sleep(Time_interval * time.Second)
}
}
开发者ID:dcmsy,项目名称:receive,代码行数:46,代码来源:receive_orgmatch.go
示例16: Run
func (p *Workshop) Run() {
LOOP:
for {
select {
case cmd := <-p.upCtrlChan:
if cmd == CMD_EXIT {
close(p.msgChan) // will send an empty msg to its receivers
p.closeSubRoutines(p.PRCtrlChan, p.PRReportChan, p.processorNum)
p.closeSubRoutines(p.CLCtrlChan, p.CLReportChan, p.collectorNum)
break LOOP
} else if cmd == CMD_TICK {
// logger.Debug("run_routine tick")
p.sendCtrlInfo(p.PRCtrlChan, cmd, p.processorNum)
p.sendCtrlInfo(p.CLCtrlChan, cmd, p.collectorNum)
p.cronTick++
if p.cronTick > p.cronTickInterval {
p.Tick()
p.cronTick = 0
}
} else {
logger.Error(" WorkShop receive a un-expected cmd ", cmd)
}
default:
messages, err := p.provider.GetNextMsg()
if err != nil {
logger.Error("src provider get msg err occur with ", len(messages), " msgs, err: ", err)
}
if messages == nil || len(messages) == 0 {
continue
}
for _, v := range messages {
if len(v) > 0 {
logger.Info("emit!")
p.msgChan <- string(v)
}
}
logger.Debug("main routine receive ", len(messages), " msgs from srcProvider")
p.processedLine += len(messages)
p.provider.Ack()
}
}
p.provider.Destory()
p.upReportChan <- RET_EXIT_SUCCESS
}
开发者ID:last-time,项目名称:della,代码行数:44,代码来源:workshop.go
示例17: RegisterSys
/*
*注册组织机构信息
*/
func (sys *SysIni) RegisterSys() {
if !StartFlag {
return
}
dbIni := &sys.dbini
t_pwd, _ := Base64Dec(dbIni.T_Password)
dbIni.T_Db.Db_open(dbIni.T_DbType, dbIni.T_User, t_pwd, dbIni.T_Ip, dbIni.T_Port, dbIni.T_Dbname)
defer dbIni.T_Db.db.Close()
query, err := dbIni.T_Db.db.Query(RegisterQuerySQL, dbIni.SysName) //查询数据库
if err != nil {
logger.Error("查询数据库失败", err.Error())
return
}
defer query.Close()
stmt, err := dbIni.T_Db.db.Prepare(RegisterInsertSQL)
defer stmt.Close()
if err != nil {
logger.Error(err)
return
}
if !query.Next() {
scans := make([]interface{}, 6)
scans[0] = dbIni.SysId
scans[1] = dbIni.SysName
scans[2] = dbIni.SysName
scans[3] = dbIni.Platform
scans[4] = dbIni.Company
scans[5] = dbIni.SysType
stmt.Exec(scans...)
}
//调用http服务进行系统注册
var configInfo ConfigInfo = InitConfigInfo()
var rstUrl = "http://" + configInfo.core_ip + ":" + configInfo.core_port + configInfo.register_url
if response, err := http.Get(rstUrl); err != nil {
logger.Error(" err = ", err)
} else {
defer response.Body.Close()
if _, err := ioutil.ReadAll(response.Body); err != nil {
logger.Error(" err = ", err)
}
}
}
开发者ID:dcmsy,项目名称:receive,代码行数:45,代码来源:receive_register.go
示例18: InitXmlInfoes
/*读取xml信息 初始化xmlinfo*/
func InitXmlInfoes(dirName string, filter string) []XmlInfo {
fileNames := GetXmlFileNames(dirName, filter)
var values = make([]XmlInfo, len(fileNames))
var i = 0
for _, v := range fileNames {
content, err := ioutil.ReadFile(v)
if err != nil {
logger.Error(err)
}
var result XmlInfo
err = xml.Unmarshal(content, &result)
if err != nil {
logger.Error(err)
}
values[i] = result
values[i].CheckFlag = true
i++
}
return values
}
开发者ID:dcmsy,项目名称:datapost,代码行数:21,代码来源:datapost_pipe.go
示例19: main
/*主入口*/
func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
//指定是否控制台打印,默认为true
logger.SetConsole(true)
//指定日志级别 ALL,DEBUG,INFO,WARN,ERROR,FATAL,OFF 级别由低到高
logger.SetLevel(logger.INFO)
logger.SetRollingFile("./log", "datapostlog.log", 100, 50, logger.MB)
if beego.AppConfig.String("runmode") == "dev" {
orm.Debug = true
}
//支持异构版本升级
pipe.Upgrade()
time.Sleep(3 * time.Second)
//配置文件初始化
err := pipe.InitFile()
if err != nil {
logger.Error("InitFile():", err)
}
//注册运行服务
ServiceHandle(cSvcName, cSvcName, cSvcName, func() {
//初始化运行参数
pipe.InitConfigMap()
//运行参数管理UI服务
beego.Router("/", &pipe.IndexInfo{}, "*:Index")
beego.Router("/index/list", &pipe.IndexInfo{}, "*:List")
beego.Router("/index/edit", &pipe.IndexInfo{}, "*:Edit")
beego.Router("/index/test", &pipe.IndexInfo{}, "*:Test")
beego.Router("/index/help", &pipe.IndexInfo{}, "*:Help")
beego.Router("/index/treedata", &pipe.IndexInfo{}, "*:TreeData")
//启动数据同步
go pipe.StartAllSys()
//启动https服务
go pipe.Https_start()
//启动参数管理UI 服务
beego.Run()
logger.Info("DaemonName=", cSvcName, "Daemon started.")
for {
time.Sleep(time.Hour)
}
}, func() {
Stop()
logger.Info("DaemonName=", cSvcName, "Daemon stoped.")
})
}
开发者ID:dcmsy,项目名称:datapost,代码行数:55,代码来源:datapost_main.go
示例20: to_write
func (sock *TcpSocket) to_write() {
var pack *packet.Packet
for ESTABLISHED == sock._socketState {
pack = <-sock._writerChannel
if pack == nil {
log.Error("get pack error")
continue
}
data := pack.Serialize()
n, err := sock._conn.Write(data)
if err != nil {
if io.ErrShortWrite != err {
log.Error("write err close--", n)
sock.closeSock()
break
}
}
log.Info("send data success")
}
}
开发者ID:markman101,项目名称:Ginger,代码行数:20,代码来源:tcpsocket.go
注:本文中的github.com/donnie4w/go-logger/logger.Error函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论