本文整理汇总了Golang中github.com/golang/glog.Errorln函数的典型用法代码示例。如果您正苦于以下问题:Golang Errorln函数的具体用法?Golang Errorln怎么用?Golang Errorln使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Errorln函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: decodeMsg
// decodes an nntp message and writes it to a section of the file.
func decodeMsg(c *nntp.Conn, f *file, groups []string, MsgID string) {
defer f.Done()
g, err := findGroup(c, groups)
if err != nil {
putBroken(c)
glog.Errorf("switching to group %s: %s", g, err)
return
}
rc, err := c.GetMessage(MsgID)
if err != nil {
glog.Errorf("getting message %s from group %s: %s", MsgID, g, err)
if _, ok := err.(*textproto.Error); ok {
putConn(c)
} else {
putBroken(c)
}
return
}
putConn(c)
yread, err := yenc.NewPart(bytes.NewReader(rc))
if err != nil {
glog.Errorln(err)
return
}
wr := f.WriterAt(yread.Begin)
_, err = io.Copy(wr, yread)
if err != nil {
glog.Errorln(err)
}
}
开发者ID:splack,项目名称:gonzbee,代码行数:32,代码来源:gonzbee.go
示例2: connectionHandler
func (i *instance) connectionHandler(c *net.UnixConn) {
defer c.Close()
for {
req, err := readRequest(c)
if err == io.EOF {
return // Client closed the connection.
}
if err != nil {
glog.Errorln("Failed to read a message from socket:", err)
}
f, t := funcMap[req.Type]
if t != true {
sendError(c, fmt.Errorf("unknown request type"))
continue
}
resp, err := f(i, req)
if err != nil {
sendError(c, err)
continue
}
err = writeResponse(c, resp)
if err != nil {
glog.Errorln("Failed to write a message to socket:", err)
return
}
}
}
开发者ID:akramer,项目名称:lateral,代码行数:27,代码来源:server.go
示例3: createNewLevelDB
func createNewLevelDB(path string, _ graph.Options) error {
opts := &opt.Options{}
db, err := leveldb.OpenFile(path, opts)
if err != nil {
glog.Errorf("Error: could not create database: %v", err)
return err
}
defer db.Close()
qs := &QuadStore{}
qs.db = db
qs.writeopts = &opt.WriteOptions{
Sync: true,
}
qs.readopts = &opt.ReadOptions{}
_, err = qs.db.Get([]byte(horizonKey), qs.readopts)
if err != nil && err != leveldb.ErrNotFound {
glog.Errorln("couldn't read from leveldb during init")
return err
}
if err != leveldb.ErrNotFound {
return graph.ErrDatabaseExists
}
// Write some metadata
if err = setVersion(qs.db, latestDataVersion, qs.writeopts); err != nil {
glog.Errorln("couldn't write leveldb version during init")
return err
}
qs.Close()
return nil
}
开发者ID:dennwc,项目名称:cayley,代码行数:30,代码来源:quadstore.go
示例4: Dispatch
// Main loop for dispatching SyncQueue
// TODO exit
func Dispatch() {
var err error
for {
select {
case si := <-SyncQueue:
if si.FullSync {
syncAlbum(si)
} else if si, err = NewSyncItemPhoto(si.Filename); err != nil {
glog.Errorln(err)
} else {
syncAlbum(si)
}
case ai := <-AlbumQueue:
switch {
case ai.MetaUpdate:
glog.Infoln("Updating Album meta")
if err = updateMeta(ai.AlbumId); err != nil {
glog.Errorln(err)
} else {
glog.Infof("Metainfo was updated for albumId", ai.AlbumId)
}
case ai.StatusUpdate:
glog.Infoln("Reloading albums")
if err = updateAlbums(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("Albums were reloaded")
}
}
}
}
}
开发者ID:sergeyfast,项目名称:eazyphotod,代码行数:34,代码来源:sync.go
示例5: Push
func (p *pusher) Push(entry *protolog.Entry) error {
if entry.Level == protolog.Level_LEVEL_DEBUG && !p.logDebug {
return nil
}
dataBytes, err := p.marshaller.Marshal(entry)
if err != nil {
return err
}
data := string(dataBytes)
switch entry.Level {
case protolog.Level_LEVEL_DEBUG, protolog.Level_LEVEL_INFO:
glog.Infoln(data)
case protolog.Level_LEVEL_WARN:
glog.Warningln(data)
case protolog.Level_LEVEL_ERROR:
glog.Errorln(data)
case protolog.Level_LEVEL_FATAL:
// cannot use fatal since this will exit before logging completes,
// which is particularly important for a multi-pusher
glog.Errorln(data)
case protolog.Level_LEVEL_PANIC:
// cannot use panic since this will panic before logging completes,
// which is particularly important for a multi-pusher
glog.Errorln(data)
}
return nil
}
开发者ID:angelabier1,项目名称:pachyderm,代码行数:27,代码来源:pusher.go
示例6: realUpTask
func (this *TaskType) realUpTask() {
for {
one := this.buff[1].Front()
if one == nil {
time.Sleep(100 * time.Millisecond)
continue
}
t := one.Value.(*TaskInfo2DB)
if t.sign == 'A' {
_, err := newTask2DB(this.Name, t.taskInfo.Tid, t.taskInfo.Rid, t.taskInfo.Info, t.stat)
if err != nil {
glog.Errorln("NEWTASK2DB:", err.Error())
} else if t.stat == 2 {
this.lock[0].Lock()
this.buff[0].PushBack(t.taskInfo) // 直接入分发队列
this.lock[0].Unlock()
}
} else if t.sign == 'U' {
_, err := upTask2DB(this.Name, t.taskInfo.Tid, t.rapper, t.msg, t.stat)
if err != nil {
glog.Errorln("UPTASK2DB:", err.Error())
}
}
this.lock[1].Lock()
this.buff[1].Remove(one)
this.lock[1].Unlock()
}
}
开发者ID:houzhenggang,项目名称:easyTask,代码行数:30,代码来源:task.go
示例7: init
func init() {
if client, err := db.Client(); err != nil {
glog.Errorln(err)
} else {
defer db.Release(client)
{
if len(config.Cfg.Metrics.AddScript) > 0 {
if addSha, err = client.Cmd("SCRIPT", "LOAD", config.Cfg.Metrics.AddScript).Str(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("ADD SHA", addSha)
}
}
if len(config.Cfg.Metrics.GetScript) > 0 {
if getSha, err = client.Cmd("SCRIPT", "LOAD", config.Cfg.Metrics.GetScript).Str(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("GET SHA", getSha)
}
}
if len(config.Cfg.Metrics.TtlScript) > 0 {
if ttlSha, err = client.Cmd("SCRIPT", "LOAD", config.Cfg.Metrics.TtlScript).Str(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("TTL SHA", ttlSha)
}
}
}
}
}
开发者ID:EyckWigo,项目名称:yag,代码行数:32,代码来源:metrics.go
示例8: writePump
func (r *Remote) writePump(outbound chan interface{}) {
ticker := time.NewTicker(pingPeriod)
defer func() {
ticker.Stop()
}()
for {
select {
case message, ok := <-outbound:
if !ok {
r.ws.WriteMessage(websocket.CloseMessage, []byte{})
return
}
b, err := json.Marshal(message)
if err != nil {
glog.Errorln(err)
return
}
glog.V(2).Infoln(string(b))
if err := r.ws.WriteMessage(websocket.TextMessage, b); err != nil {
glog.Errorln(err)
return
}
case <-ticker.C:
if err := r.ws.WriteMessage(websocket.PingMessage, []byte{}); err != nil {
glog.Errorln(err)
return
}
}
}
}
开发者ID:robcat,项目名称:ripple,代码行数:30,代码来源:remote.go
示例9: GetSession
// GetSession returns a SeverSession from the database.
// It checks memcached/redis first, and then falls back on the
// database.
func GetSession(id string) (*ServerSession, error) {
conn := database.Pool.Get()
defer conn.Close()
var ss ServerSession
reply, err := conn.Do("GET", id)
if reply != nil && err == nil {
b, ok := reply.([]byte)
if ok {
err = ss.UnmarshalJSON(b)
if err != nil {
glog.Errorln(err)
}
}
} else {
err = database.DB.QueryRow(`SELECT *
FROM sessions
WHERE session_id=$1`, id).
Scan(&ss.ID, &ss.AuthToken, &ss.CSRFToken, &ss.Email, &ss.School, &ss.Date)
}
if err != nil {
if err == sql.ErrNoRows {
err = ErrNoSession
} else {
glog.Errorln(err)
}
}
return &ss, err
}
开发者ID:EricLagergren,项目名称:pnwconference,代码行数:36,代码来源:session_funcs.go
示例10: Main
func Main() {
var (
SQS *sqs.SQS
getUserQueueUrlOutput *sqs.GetQueueUrlOutput
getContainerQueueUrlOutput *sqs.GetQueueUrlOutput
UserQueueUrl *string
ContainerQueueUrl *string
Dynamo *dynamodb.DynamoDB
socialWorker *workers.SocialWorker
)
SQS = sqs.New(&aws.Config{Region: aws.String("cn-north-1")})
getUserQueueUrlOutput, err := SQS.GetQueueUrl(&sqs.GetQueueUrlInput{QueueName: aws.String(USER_QUEUE_NAME)})
if err != nil {
glog.Errorln("Error on connect user queue url:", err.Error())
return
}
UserQueueUrl = getUserQueueUrlOutput.QueueUrl
getContainerQueueUrlOutput, err = SQS.GetQueueUrl(&sqs.GetQueueUrlInput{QueueName: aws.String(CONTAINER_QUEUE_NAME)})
if err != nil {
glog.Errorln("Error on connect container queue url:", err.Error())
return
}
ContainerQueueUrl = getContainerQueueUrlOutput.QueueUrl
Dynamo = dynamodb.New(&aws.Config{Region: aws.String("cn-north-1")})
socialWorker = workers.NewSocialWorker(SQS, UserQueueUrl, ContainerQueueUrl, Dynamo)
socialWorker.Start()
}
开发者ID:luzh0422,项目名称:spider-docker,代码行数:32,代码来源:hypervisor.go
示例11: Start
func (m *Manager) Start() {
m.started = time.Now()
tick := time.NewTicker(time.Minute)
for {
select {
case <-tick.C:
glog.Infoln("Manager:", m.String())
case in := <-m.Incoming:
switch v := in.(type) {
case *data.Ledger:
m.stats["ledgers"]++
wait := m.ledgers.Set(v.LedgerSequence)
glog.V(2).Infof("Manager: Received: %d %0.04f/secs ", v.LedgerSequence, wait.Seconds())
if err := m.db.Insert(v); err != nil {
glog.Errorln("Manager: Ledger Insert:", err.Error())
}
case data.Transaction:
m.stats["transactions"]++
if err := m.db.Insert(v); err != nil {
glog.Errorln("Manager: Transaction Insert:", err.Error())
}
}
case missing := <-m.Missing:
m.ledgers.Extend(missing.Request.End)
missing.Response <- m.ledgers.TakeMiddle(missing.Request)
}
}
}
开发者ID:robcat,项目名称:ripple,代码行数:28,代码来源:manager.go
示例12: handleGetPagination
func handleGetPagination(w http.ResponseWriter, r *http.Request) {
var err error
switch r.Method {
case "GET":
engine, statuses := getJobsQueryParams(r)
var minID int64
if s := r.URL.Query().Get("min-id"); s != "" {
if minID, err = strconv.ParseInt(s, 0, 64); err != nil {
glog.Errorf("Failed to parse min-id (%s): %s", s, err)
http.Error(w, "Invalid Param(s)", http.StatusBadRequest)
return
}
}
pagination, err := db.GetPagination(engine, statuses, minID)
if err != nil || len(pagination) != 1 {
glog.Errorln("Error getting pagination info from DB", err)
error500(w)
return
}
if res, err := json.Marshal(pagination[0]); err != nil {
glog.Errorln("Error Marshalling pagination JSON:", err)
error500(w)
return
} else {
w.Write(res)
}
}
}
开发者ID:ibm-security-innovation,项目名称:menagerie,代码行数:28,代码来源:frontend.go
示例13: processSend
func (context *clientContext) processSend() {
if err := context.sendInitialize(); err != nil {
glog.Errorln(err.Error())
return
}
buf := make([]byte, 1024)
for {
size, err := context.pty.Read(buf)
if err != nil {
glog.Errorf("Command exited for: %s", context.request.RemoteAddr)
return
}
context.record(append([]byte{rec.Output}, buf[:size]...))
safeMessage := base64.StdEncoding.EncodeToString([]byte(buf[:size]))
if errs := context.write(append([]byte{rec.Output},
[]byte(safeMessage)...)); len(errs) > 0 {
for _, e := range errs {
glog.Errorln(e.err.Error())
context.close(e.key)
}
if len(*context.connections) == 0 {
return
}
}
}
}
开发者ID:yubo,项目名称:gotty,代码行数:28,代码来源:client_context.go
示例14: upgradeLevelDB
func upgradeLevelDB(path string, opts graph.Options) error {
db, err := leveldb.OpenFile(path, &opt.Options{})
defer db.Close()
if err != nil {
glog.Errorln("Error, couldn't open! ", err)
return err
}
version, err := getVersion(db)
if err != nil {
glog.Errorln("error:", err)
return err
}
if version == latestDataVersion {
fmt.Printf("Already at latest version: %d\n", latestDataVersion)
return nil
}
if version > latestDataVersion {
err := fmt.Errorf("Unknown data version: %d -- upgrade this tool", version)
glog.Errorln("error:", err)
return err
}
for i := version; i < latestDataVersion; i++ {
err := migrateFunctions[i](db)
if err != nil {
return err
}
setVersion(db, i+1, nil)
}
return nil
}
开发者ID:dennwc,项目名称:cayley,代码行数:35,代码来源:migrate.go
示例15: handleUpload
func (s *queueServer) handleUpload(w http.ResponseWriter, r *http.Request) {
defer logPanic()
file, header, err := r.FormFile("upload")
if err != nil {
glog.Errorln("Couldn't create job", err)
error500(w)
return
}
jid, err := db.JobCreate(s.Name, header.Filename)
if err != nil {
glog.Errorln("Couldn't create job", err)
error500(w)
return
}
if err = s.doUpload(w, file, jid, header.Filename); err != nil {
if err = db.JobSetError(jid, "Error starting job"); err != nil {
glog.Errorf("Error setting job %d error: %s", jid, err)
}
} else {
if err = db.JobSetStarted(jid); err != nil {
glog.Errorf("Error setting job %d to running: %s", jid, err)
}
}
glog.Infof("Job %d (%s) created successfully", jid, s.Name)
}
开发者ID:ibm-security-innovation,项目名称:menagerie,代码行数:26,代码来源:frontend.go
示例16: makeCursor
func (it *AllIterator) makeCursor() {
var cursor *sql.Rows
var err error
if it.cursor != nil {
it.cursor.Close()
}
if it.table == "quads" {
cursor, err = it.qs.db.Query(`SELECT
subject_hash,
predicate_hash,
object_hash,
label_hash
FROM quads;`)
if err != nil {
glog.Errorln("Couldn't get cursor from SQL database: %v", err)
cursor = nil
}
} else {
glog.V(4).Infoln("sql: getting node query")
cursor, err = it.qs.db.Query(`SELECT hash FROM nodes;`)
if err != nil {
glog.Errorln("Couldn't get cursor from SQL database: %v", err)
cursor = nil
}
glog.V(4).Infoln("sql: got node query")
}
it.cursor = cursor
}
开发者ID:dennwc,项目名称:cayley,代码行数:28,代码来源:all_iterator.go
示例17: Listen
func Listen(m *Manager, port string) {
addr, err := net.ResolveTCPAddr("tcp", fmt.Sprintf(":%s", port))
if err != nil {
glog.Fatalln("HandleIncoming:", err)
}
l, err := net.ListenTCP("tcp", addr)
if err != nil {
glog.Fatalln("HandleIncoming:", err)
}
defer l.Close()
for {
conn, err := l.AcceptTCP()
if err != nil {
glog.Errorln("HandleIncoming:", err)
continue
}
host, port, err := net.SplitHostPort(conn.RemoteAddr().String())
if err != nil {
glog.Errorln("HandleIncoming:", err)
continue
}
glog.Infoln("Incoming Host: %s Port: %s", host, port)
m.AddPeer(host, port, false, conn)
}
}
开发者ID:Zoramite,项目名称:ripple,代码行数:25,代码来源:conn.go
示例18: tryFlushResponse
// tryFlushResponse flushes the response buffer (if not empty); returns true if flush succeeded
func (d *httpDecoder) tryFlushResponse(out *bytes.Buffer) {
log.V(2).Infof(d.idtag+"try-flush-responses: %d bytes to flush", out.Len())
// set a write deadline here so that we don't block for very long.
err := d.setWriteTimeout()
if err != nil {
// this is a problem because if we can't set the timeout then we can't guarantee
// how long a write op might block for. Log the error and skip this response.
log.Errorln("failed to set write deadline, aborting response:", err.Error())
} else {
_, err = out.WriteTo(d.rw.Writer)
if err != nil {
if neterr, ok := err.(net.Error); ok && neterr.Timeout() && out.Len() > 0 {
// we couldn't fully write before timing out, return rch and hope that
// we have better luck next time.
return
}
// we don't really know how to deal with other kinds of errors, so
// log it and skip the rest of the response.
log.Errorln("failed to write response buffer:", err.Error())
}
err = d.rw.Flush()
if err != nil {
if neterr, ok := err.(net.Error); ok && neterr.Timeout() && out.Len() > 0 {
return
}
log.Errorln("failed to flush response buffer:", err.Error())
}
}
}
开发者ID:XiaoningDing,项目名称:UbernetesPOC,代码行数:30,代码来源:decoder.go
示例19: doGet
func (this *SayhiHandler) doGet(w http.ResponseWriter, r *http.Request) {
const USAGE = "GET /sayhi?type=typename&name=rappername"
r.ParseForm()
ttype, name := r.FormValue("type"), r.FormValue("name")
if ttype == "" || name == "" {
glog.Errorln("sayhi ERR:", ttype, name)
w.WriteHeader(http.StatusBadRequest)
w.Write([]byte(USAGE))
return
}
taskTypeOne, rapperOne := GetRapper(ttype, name)
if taskTypeOne == nil {
glog.Errorln("sayhi to nil type:", ttype)
w.WriteHeader(http.StatusBadRequest)
w.Write([]byte("no such task type."))
return
}
if rapperOne == nil {
taskTypeOne.AddRapper(name, NewRapper(name))
} else {
taskTypeOne.ResetRapper(rapperOne)
rapperOne.Beat(true)
}
w.Write([]byte("OK"))
return
}
开发者ID:houzhenggang,项目名称:easyTask,代码行数:30,代码来源:sayhi.go
示例20: streamLedgerData
func (r *Remote) streamLedgerData(ledger interface{}, c chan data.LedgerEntrySlice) {
defer close(c)
cmd := newBinaryLedgerDataCommand(ledger, nil)
for ; ; cmd = newBinaryLedgerDataCommand(ledger, cmd.Result.Marker) {
r.outgoing <- cmd
<-cmd.Ready
if cmd.CommandError != nil {
glog.Errorln(cmd.Error())
return
}
les := make(data.LedgerEntrySlice, len(cmd.Result.State))
for i, state := range cmd.Result.State {
b, err := hex.DecodeString(state.Data + state.Index)
if err != nil {
glog.Errorln(cmd.Error())
return
}
les[i], err = data.ReadLedgerEntry(bytes.NewReader(b), data.Hash256{})
if err != nil {
glog.Errorln(err.Error())
return
}
}
c <- les
if cmd.Result.Marker == nil {
return
}
}
}
开发者ID:askk,项目名称:ripple,代码行数:29,代码来源:remote.go
注:本文中的github.com/golang/glog.Errorln函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论