Error Reading File Queue From Disk
Contents |
all board cookies • All times are UTC Powered by phpBB Forum Software © phpBB Group Forum web-hosting by SourceForge
Sign in Pricing Blog Support Search GitHub This repository Watch 3 Star 4 Fork 9 tmm1/nzbget Code Issues 0 Pull requests 0 Projects 0 Wiki Pulse Graphs Permalink Branch: master Switch branches/tags Branches Tags master mine Nothing to show Nothing to show Find file Copy path nzbget/DiskState.cpp Fetching contributors… Cannot retrieve contributors at this time Raw Blame History 1432 lines (1193 sloc) 37.8 KB /* * This file is part http://forum.nzbget.net/viewtopic.php?f=3&t=1653 of nzbget * * Copyright (C) 2007-2013 Andrey Prygunkov
Sign in Pricing Blog Support Search GitHub This repository Watch 498 Star 7,468 Fork 948 nsqio/nsq Code Issues 41 Pull https://github.com/nsqio/nsq/blob/master/nsqd/diskqueue.go requests 7 Projects 0 Pulse Graphs Permalink Branch: master Switch branches/tags Branches Tags dev master Nothing to show v0.3.8 v0.3.7 v0.3.6 v0.3.5 v0.3.4 v0.3.3 v0.3.2 v0.3.1 v0.3.0 v0.2.31 v0.2.30 http://support.novell.com/docs/Tids/Solutions/10025564.html v0.2.29 v0.2.28 v0.2.27 v0.2.26 v0.2.25 v0.2.24 v0.2.23 v0.2.22 v0.2.21 v0.2.20 v0.2.19 v0.2.18 v0.2.17 v0.2.16 v0.2.15 Nothing to show Find file Copy path nsq/nsqd/diskqueue.go Fetching contributors… Cannot retrieve contributors error reading at this time Raw Blame History 635 lines (529 sloc) 14.3 KB package nsqd import ( "bufio" "bytes" "encoding/binary" "errors" "fmt" "io" "math/rand" "os" "path" "sync" "sync/atomic" "time" ) // diskQueue implements the BackendQueue interface // providing a filesystem backed FIFO queue type diskQueue struct { // 64bit atomic vars need to be first for proper error reading file alignment on 32bit platforms // run-time state (also persisted to disk) readPos int64 writePos int64 readFileNum int64 writeFileNum int64 depth int64 sync.RWMutex // instantiation time metadata name string dataPath string maxBytesPerFile int64 // currently this cannot change once created minMsgSize int32 maxMsgSize int32 syncEvery int64 // number of writes per fsync syncTimeout time.Duration // duration of time per fsync exitFlag int32 needSync bool // keeps track of the position where we have read // (but not yet sent over readChan) nextReadPos int64 nextReadFileNum int64 readFile *os.File writeFile *os.File reader *bufio.Reader writeBuf bytes.Buffer // exposed via ReadChan() readChan chan []byte // internal channels writeChan chan []byte writeResponseChan chan error emptyChan chan int emptyResponseChan chan error exitChan chan int exitSyncChan chan int logger Logger } // newDiskQueue instantiates a new instance of diskQueue, retrieving metadata // from the filesystem and starting the read ahead goroutine func newDiskQueue(name string, dataPath string, maxBytesPerFile int64, minMsgSize int32, maxMsgSize int32, syncEvery int64, syncTimeout time.Duration, logger Logger) BackendQueue { d := diskQueue{ name: name, dataPa
Error while reading from target, Error: -642 the iteration handle is invalid. Using SBACKUP to backup Directory Services. When trying to backup context gets error "Backing up Dataset: