I can help to reproduce it with omfwd or omtesting

On Fri, Mar 4, 2016 at 9:24 AM, Rainer Gerhards <[email protected]>
wrote:

> 2016-03-04 18:17 GMT+01:00 Kane Kim <[email protected]>:
> > hey David, did you have a chance to look at it? Rainer can you please
> help
> > here too?
>
> I have already assigned a release goal to the github tracker. It's
> probably hard to track down and I am right now busy crafting the
> release (which means it can't go into 8.17 anyways). I am sure it's
> not a new regression, because that code area hasn't been touched at
> least for 6 month, I guess even longer.
>
> When I begin to really work on it, I need to find a way to make it
> fail with an action that I can test easily, like omfwd (I don't have
> kafka know how and so I do not know how to craft a consistent test
> case for it). If that fails, I'll write a testing plugin just for that
> purpose (or extend omtesting, to be seen).
>
> Just FYI,
> Rainer
> >
> > On Wed, Mar 2, 2016 at 10:03 PM, Kane Kim <[email protected]> wrote:
> >
> >> This is with latest master
> >> On Mar 2, 2016 9:27 PM, "David Lang" <[email protected]> wrote:
> >>
> >>> is this with 8.16 or with the git tree? (what will be 8.17 next week)
> >>>
> >>> David Lang
> >>>
> >>> On Wed, 2 Mar 2016, Kane Kim wrote:
> >>>
> >>> Date: Wed, 2 Mar 2016 15:08:39 -0800
> >>>> From: Kane Kim <[email protected]>
> >>>> Reply-To: rsyslog-users <[email protected]>
> >>>> To: rsyslog-users <[email protected]>
> >>>> Subject: Re: [rsyslog] retry if output module returns RS_RET_SUSPENDED
> >>>>
> >>>> Hey David, here is the full log, it starts at idle state, then I send
> one
> >>>> line and shutdown rsyslog. commitTransaction never returns at this
> point,
> >>>> queue is deleted from disk and rsyslog starts with empty queue.
> >>>> commitTransaction has this:
> >>>>
> >>>> dbgprintf("omsgkafka: committransaction called\n");
> >>>> for(;;) {
> >>>>   srSleep(1500, 0);
> >>>> }
> >>>>
> >>>> iRet = RS_RET_SUSPENDED;
> >>>>
> >>>> dbgprintf("omsgkafka: committransaction end\n");
> >>>>
> >>>>
> >>>> 9774.080804647:imuxsock.c     : Message from UNIX socket: #6
> >>>> 9774.080828380:imuxsock.c     : main Q: qqueueAdd: entry added, size
> now
> >>>> log 1, phys 1 entries
> >>>> 9774.080835155:imuxsock.c     : main Q: EnqueueMsg advised worker
> start
> >>>> 9774.080839004:imuxsock.c     : --------imuxsock calling select,
> active
> >>>> file descriptors (max 6): 6
> >>>> 9774.080850186:main Q:Reg/w0  : wti 0x1333800: worker awoke from idle
> >>>> processing
> >>>> 9774.080854144:main Q:Reg/w0  : DeleteProcessedBatch: we deleted 0
> >>>> objects
> >>>> and enqueued 0 objects
> >>>> 9774.080857193:main Q:Reg/w0  : doDeleteBatch: delete batch from
> store,
> >>>> new
> >>>> sizes: log 1, phys 1
> >>>> 9774.080860918:main Q:Reg/w0  : processBATCH: batch of 1 elements
> must be
> >>>> processed
> >>>> 9774.080863557:main Q:Reg/w0  : processBATCH: next msg 0: <190>Mar  2
> >>>> 23:02:54 logger: test1
> >>>> 9774.080866845:main Q:Reg/w0  :     PRIFILT 'local7.*'
> >>>> 9774.080872187:main Q:Reg/w0  :     pmask:  X  X  X  X  X  X  X  X  X
> >>>> X  X
> >>>> X  X  X  X  X  X  X  X  X  X  X  X FF  X  X
> >>>> 9774.080923618:main Q:Reg/w0  : PRIFILT condition result is 1
> >>>> 9774.080926256:main Q:Reg/w0  :     ACTION 0
> >>>> [omsgkafka:action(type="omsgkafka" ...)]
> >>>> 9774.080932370:main Q:Reg/w0  : executing action 0
> >>>> 9774.080935598:main Q:Reg/w0  : action 'kafka_action': called,
> logging to
> >>>> omsgkafka (susp 0/0, direct q 0)
> >>>> 9774.080955281:main Q:Reg/w0  : strm 0x13272d0: file
> >>>> -1(prism_kafka_queue)
> >>>> flush, buflen 405
> >>>> 9774.080958942:main Q:Reg/w0  : strmPhysWrite, stream 0x13272d0, len
> 405
> >>>> 9774.081005185:main Q:Reg/w0  : file
> >>>> '/var/spool/rsyslog/prism_kafka_queue.00000001' opened as #7 with mode
> >>>> 384
> >>>> 9774.081014114:main Q:Reg/w0  : strm 0x13272d0: opened file
> >>>> '/var/spool/rsyslog/prism_kafka_queue.00000001' for WRITE as 7
> >>>> 9774.081026793:main Q:Reg/w0  : strm 0x13272d0: file 7 write wrote 405
> >>>> bytes
> >>>> 9774.081030432:main Q:Reg/w0  : kafka_action queue: write wrote 405
> >>>> octets
> >>>> to disk, queue disk size now 405 octets, EnqOnly:0
> >>>> 9774.081033284:main Q:Reg/w0  : kafka_action queue: qqueueAdd: entry
> >>>> added,
> >>>> size now log 1, phys 1 entries
> >>>> 9774.081036576:main Q:Reg/w0  : kafka_action queue:Reg: high activity
> -
> >>>> starting 1 additional worker thread(s).
> >>>> 9774.081057367:main Q:Reg/w0  : kafka_action queue:Reg: started with
> >>>> state
> >>>> 0, num workers now 1
> >>>> 9774.081061235:main Q:Reg/w0  : kafka_action queue: EnqueueMsg advised
> >>>> worker start
> >>>> 9774.081119073:main Q:Reg/w0  : action 'kafka_action': set suspended
> >>>> state
> >>>> to 0
> >>>> 9774.081124496:main Q:Reg/w0  :     PRIFILT 'local0.*'
> >>>> 9774.081130002:main Q:Reg/w0  :     pmask:  X  X  X  X  X  X  X  X  X
> >>>> X  X
> >>>> X  X  X  X  X FF  X  X  X  X  X  X  X  X  X
> >>>> 9774.081179409:main Q:Reg/w0  : PRIFILT condition result is 0
> >>>> 9774.081183488:main Q:Reg/w0  :     PRIFILT '*.emerg'
> >>>> 9774.081192108:main Q:Reg/w0  :     pmask:  1  1  1  1  1  1  1  1  1
> >>>> 1  1
> >>>> 1  1  1  1  1  1  1  1  1  1  1  1  1  1  1
> >>>> 9774.081236853:main Q:Reg/w0  : PRIFILT condition result is 0
> >>>> 9774.081239405:main Q:Reg/w0  : END batch execution phase, entering to
> >>>> commit phase [processed 1 of 1 messages]
> >>>> 9774.081242411:main Q:Reg/w0  : processBATCH: batch of 1 elements has
> >>>> been
> >>>> processed
> >>>> 9774.081245359:main Q:Reg/w0  : regular consumer finished, iret=0,
> szlog
> >>>> 0
> >>>> sz phys 1
> >>>> 9774.081249143:main Q:Reg/w0  : DeleteProcessedBatch: we deleted 1
> >>>> objects
> >>>> and enqueued 0 objects
> >>>> 9774.081251772:main Q:Reg/w0  : doDeleteBatch: delete batch from
> store,
> >>>> new
> >>>> sizes: log 0, phys 0
> >>>> 9774.081254445:main Q:Reg/w0  : regular consumer finished, iret=4,
> szlog
> >>>> 0
> >>>> sz phys 0
> >>>> 9774.081257074:main Q:Reg/w0  : main Q:Reg/w0: worker IDLE, waiting
> for
> >>>> work.
> >>>> 9774.082767917:7f08827fc700: thread created, tid 20310, name
> >>>> 'rs:kafka_action queue:R'
> >>>> 9774.083158670:kafka_action queue:Reg/w0: wti 0x1327ab0: worker
> starting
> >>>> 9774.083452008:kafka_action queue:Reg/w0: DeleteProcessedBatch: we
> >>>> deleted
> >>>> 0 objects and enqueued 0 objects
> >>>> 9774.083764135:kafka_action queue:Reg/w0: doDeleteBatch: delete batch
> >>>> from
> >>>> store, new sizes: log 1, phys 1
> >>>> 9774.083928382:kafka_action queue:Reg/w0: file
> >>>> '/var/spool/rsyslog/prism_kafka_queue.00000001' opened as #8 with mode
> >>>> 384
> >>>> 9774.084086546:kafka_action queue:Reg/w0: strm 0x1327570: opened file
> >>>> '/var/spool/rsyslog/prism_kafka_queue.00000001' for READ as 8
> >>>> 9774.084098247:kafka_action queue:Reg/w0: strm 0x1327570: file 8 read
> 405
> >>>> bytes
> >>>> 9774.084121083:kafka_action queue:Reg/w0: string to match for regex
> is:
> >>>> test1
> >>>> 9774.084129965:kafka_action queue:Reg/w0: source file msg.c requested
> >>>> reference for module 'lmregexp', reference count now 2
> >>>> 9774.084146981:kafka_action queue:Reg/w0: regexec return is 1
> >>>> 9774.084151588:kafka_action queue:Reg/w0: regex: end search, found 0
> >>>> 9774.084298127:kafka_action queue:Reg/w0: action 'kafka_action': is
> >>>> transactional - executing in commit phase
> >>>> 9774.084304450:kafka_action queue:Reg/w0: wti 0x1327ab0: we need to
> >>>> create
> >>>> a new action worker instance for action 0
> >>>> 9774.084316690:kafka_action queue:Reg/w0: wti 0x1327ab0: created
> action
> >>>> worker instance 1 for action 0
> >>>> 9774.084322447:kafka_action queue:Reg/w0: omsgkafka: beginTransaction
> >>>> called
> >>>> 9774.084327347:kafka_action queue:Reg/w0: Action 0 transitioned to
> state:
> >>>> itx
> >>>> 9774.084332329:kafka_action queue:Reg/w0: doTransaction: have
> >>>> commitTransaction IF, using that, pWrkrInfo 0x1327b60
> >>>> 9774.084337162:kafka_action queue:Reg/w0: entering
> >>>> actionCallCommitTransaction(), state: itx, actionNbr 0, nMsgs 1
> >>>> 9774.084341794:kafka_action queue:Reg/w0: omsgkafka: committransaction
> >>>> called
> >>>> ^C9777.756010044:main thread    : DoDie called.
> >>>> DoDie called.
> >>>> 9777.757077361:main thread    : exiting on signal 2
> >>>> 9777.757445698:main thread    : Terminating input threads...
> >>>> 9777.757936794:main thread    : request term via SIGTTIN for input
> thread
> >>>> 'imuxsock' 0x837fe700
> >>>> 9777.758371952:imuxsock.c     : thrdStarter: usrThrdMain imuxsock -
> >>>> 0x7f08837fe700 returned with iRet 0, exiting now.
> >>>> 9777.758931583:imuxsock.c     : destructor for debug call stack
> >>>> 0x7f08740008c0 called
> >>>> 9777.759216811:main thread    : input thread term: thread imuxsock
> >>>> returned
> >>>> normally and is terminated
> >>>> 9777.759495668:main thread    : non-cancel input thread termination
> >>>> succeeded for thread imuxsock 0x837fe700
> >>>> 9777.759850405:main thread    : imuxsock: unlinking unix socket
> file[0]
> >>>> /dev/log
> >>>> 9777.760098055:main thread    : main Q: qqueueAdd: entry added, size
> now
> >>>> log 1, phys 1 entries
> >>>> 9777.760440595:main thread    : main Q: EnqueueMsg advised worker
> start
> >>>> 9777.760618052:main Q:Reg/w0  : wti 0x1333800: worker awoke from idle
> >>>> processing
> >>>> 9777.760627213:main Q:Reg/w0  : DeleteProcessedBatch: we deleted 0
> >>>> objects
> >>>> and enqueued 0 objects
> >>>> 9777.760633556:main Q:Reg/w0  : doDeleteBatch: delete batch from
> store,
> >>>> new
> >>>> sizes: log 1, phys 1
> >>>> 9777.760640207:main Q:Reg/w0  : processBATCH: batch of 1 elements
> must be
> >>>> processed
> >>>> 9777.760646078:main Q:Reg/w0  : processBATCH: next msg 0:  [origin
> >>>> software="rsyslogd" swVersion="8.17.0.master" x-pid="20303" x-info="
> >>>> http://www.rsyslog.com";] exiting on signal 2.
> >>>> 9777.760652377:main Q:Reg/w0  :     PRIFILT 'local7.*'
> >>>> 9777.760663339:main Q:Reg/w0  :     pmask:  X  X  X  X  X  X  X  X  X
> >>>> X  X
> >>>> X  X  X  X  X  X  X  X  X  X  X  X FF  X  X
> >>>> 9777.760979712:main Q:Reg/w0  : PRIFILT condition result is 0
> >>>> 9777.760985069:main Q:Reg/w0  :     PRIFILT 'local0.*'
> >>>> 9777.760995436:main Q:Reg/w0  :     pmask:  X  X  X  X  X  X  X  X  X
> >>>> X  X
> >>>> X  X  X  X  X FF  X  X  X  X  X  X  X  X  X
> >>>> 9777.761073220:main Q:Reg/w0  : PRIFILT condition result is 0
> >>>> 9777.761077680:main Q:Reg/w0  :     PRIFILT '*.emerg'
> >>>> 9777.761087341:main Q:Reg/w0  :     pmask:  1  1  1  1  1  1  1  1  1
> >>>> 1  1
> >>>> 1  1  1  1  1  1  1  1  1  1  1  1  1  1  1
> >>>> 9777.761485735:main Q:Reg/w0  : PRIFILT condition result is 0
> >>>> 9777.761494678:main Q:Reg/w0  : END batch execution phase, entering to
> >>>> commit phase [processed 1 of 1 messages]
> >>>> 9777.761504212:main Q:Reg/w0  : processBATCH: batch of 1 elements has
> >>>> been
> >>>> processed
> >>>> 9777.761513699:main Q:Reg/w0  : regular consumer finished, iret=0,
> szlog
> >>>> 0
> >>>> sz phys 1
> >>>> 9777.761532517:main Q:Reg/w0  : DeleteProcessedBatch: we deleted 1
> >>>> objects
> >>>> and enqueued 0 objects
> >>>> 9777.761542961:main Q:Reg/w0  : doDeleteBatch: delete batch from
> store,
> >>>> new
> >>>> sizes: log 0, phys 0
> >>>> 9777.761552408:main Q:Reg/w0  : regular consumer finished, iret=4,
> szlog
> >>>> 0
> >>>> sz phys 0
> >>>> 9777.761561267:main Q:Reg/w0  : main Q:Reg/w0: worker IDLE, waiting
> for
> >>>> work.
> >>>> 9777.761575630:main thread    : Terminating main queue...
> >>>> 9777.761586414:main thread    : main Q: initiating worker thread
> shutdown
> >>>> sequence
> >>>> 9777.761595699:main thread    : main Q: trying shutdown of regular
> >>>> workers
> >>>> 9777.761612563:main thread    : sent SIGTTIN to worker thread
> 0x82ffd700
> >>>> 9777.762033112:main thread    : main Q:Reg: waiting 1500ms on worker
> >>>> thread
> >>>> termination, 1 still running
> >>>> 9777.762471004:main Q:Reg/w0  : wti 0x1333800: worker awoke from idle
> >>>> processing
> >>>> 9777.762479524:main Q:Reg/w0  : DeleteProcessedBatch: we deleted 0
> >>>> objects
> >>>> and enqueued 0 objects
> >>>> 9777.762485366:main Q:Reg/w0  : doDeleteBatch: delete batch from
> store,
> >>>> new
> >>>> sizes: log 0, phys 0
> >>>> 9777.762490722:main Q:Reg/w0  : regular consumer finished, iret=4,
> szlog
> >>>> 0
> >>>> sz phys 0
> >>>> 9777.762495761:main Q:Reg/w0  : wti 0x1333800: terminating worker
> >>>> terminateRet=5, bInactivityTOOccured=0
> >>>> 9777.762501491:main Q:Reg/w0  : DDDD: wti 0x1333800: worker cleanup
> >>>> action
> >>>> instances
> >>>> 9777.762507021:main Q:Reg/w0  : wti 0x1333800, action 0, ptr (nil)
> >>>> 9777.762511754:main Q:Reg/w0  : wti 0x1333800, action 1, ptr (nil)
> >>>> 9777.762516385:main Q:Reg/w0  : wti 0x1333800, action 2, ptr (nil)
> >>>> 9777.762521291:main Q:Reg/w0  : wti 0x1333800: worker exiting
> >>>> 9777.762526603:main Q:Reg/w0  : main Q:Reg: Worker thread 1333800,
> >>>> terminated, num workers now 0
> >>>> 9777.762543503:main Q:Reg/w0  : destructor for debug call stack
> >>>> 0x7f087c0008c0 called
> >>>> 9777.762586045:main thread    : main Q: regular queue workers shut
> down.
> >>>> 9777.762595242:main thread    : main Q: checking to see if we need to
> >>>> cancel any worker threads of the primary queue
> >>>> 9777.762600740:main thread    : main Q: worker threads terminated,
> >>>> remaining queue size log 0, phys 0.
> >>>> 9777.762612320:main thread    : main Q: queue (type 0) will lose 0
> >>>> messages, destroying...
> >>>> 9777.762626917:main thread    : Terminating outputs...
> >>>> 9777.762635743:main thread    : destructing ruleset 0x131b150, name
> >>>> 0x131b190
> >>>> 9777.762642271:main thread    : kafka_action queue: initiating worker
> >>>> thread shutdown sequence
> >>>> 9777.762647400:main thread    : kafka_action queue: trying shutdown of
> >>>> regular workers
> >>>> 9777.762656067:main thread    : sent SIGTTIN to worker thread
> 0x827fc700
> >>>> 9777.762669071:main thread    : kafka_action queue:Reg: waiting 0ms on
> >>>> worker thread termination, 1 still running
> >>>> 9777.762947979:main thread    : kafka_action queue:Reg: timeout
> waiting
> >>>> on
> >>>> worker thread termination
> >>>> 9777.762972263:main thread    : sent SIGTTIN to worker thread
> 0x827fc700
> >>>> 9777.763088721:main thread    : kafka_action queue: regular shutdown
> >>>> timed
> >>>> out on primary queue (this is OK)
> >>>> 9777.763185618:main thread    : kafka_action queue: trying to shutdown
> >>>> workers within Action Timeoutsetting EnqOnly mode
> >>>> 9777.763196692:main thread    : kafka_action queue: trying immediate
> >>>> shutdown of regular workers (if any)
> >>>> 9777.763214555:main thread    : sent SIGTTIN to worker thread
> 0x827fc700
> >>>> 9777.763226359:main thread    : kafka_action queue:Reg: waiting
> 1000ms on
> >>>> worker thread termination, 1 still running
> >>>> 9778.763307260:main thread    : kafka_action queue:Reg: timeout
> waiting
> >>>> on
> >>>> worker thread termination
> >>>> 9778.763833144:main thread    : sent SIGTTIN to worker thread
> 0x827fc700
> >>>> 9778.764176150:main thread    : kafka_action queue: immediate shutdown
> >>>> timed out on primary queue (this is acceptable and triggers
> cancellation)
> >>>> 9778.764569596:main thread    : kafka_action queue: checking to see
> if we
> >>>> need to cancel any worker threads of the primary queue
> >>>> 9778.765029132:main thread    : sent SIGTTIN to worker thread
> 0x827fc700,
> >>>> giving it a chance to terminate
> >>>> 9778.775504248:main thread    : cooperative worker termination failed,
> >>>> using cancellation...
> >>>> 9778.775932612:main thread    : wti 0x1327ab0: canceling worker thread
> >>>> 9778.776268161:kafka_action queue:Reg/w0: kafka_action queue:Reg/w0:
> >>>> cancelation cleanup handler called.
> >>>> 9778.776647913:kafka_action queue:Reg/w0: DeleteProcessedBatch: we
> >>>> deleted
> >>>> 1 objects and enqueued 0 objects
> >>>> 9778.776910344:kafka_action queue:Reg/w0: doDeleteBatch: delete batch
> >>>> from
> >>>> store, new sizes: log 0, phys 0
> >>>> 9778.777190970:kafka_action queue:Reg/w0: kafka_action queue:Reg/w0:
> done
> >>>> cancelation cleanup handler.
> >>>> 9778.777532500:kafka_action queue:Reg/w0: kafka_action queue:Reg:
> Worker
> >>>> thread 1327ab0 requested to be cancelled.
> >>>> 9778.777748314:kafka_action queue:Reg/w0: kafka_action queue:Reg:
> Worker
> >>>> thread 1327ab0, terminated, num workers now 0
> >>>> 9778.777955651:kafka_action queue:Reg/w0: destructor for debug call
> stack
> >>>> 0x7f08780008c0 called
> >>>> 9778.778248027:main thread    : kafka_action queue: worker threads
> >>>> terminated, remaining queue size log 0, phys 0.
> >>>> 9778.778262197:main thread    : kafka_action queue: persisting queue
> to
> >>>> disk, 0 entries...
> >>>> 9778.778269955:main thread    : strm 0x13272d0: file
> 7(prism_kafka_queue)
> >>>> closing
> >>>> 9778.778284655:main thread    : strm 0x13272d0: file
> 7(prism_kafka_queue)
> >>>> flush, buflen 0 (no need to flush)
> >>>> 9778.778298933:main thread    : strm 0x1327570: file
> 8(prism_kafka_queue)
> >>>> closing
> >>>> 9778.778435180:main thread    : strm 0x1327810: file
> >>>> -1(prism_kafka_queue)
> >>>> closing
> >>>> 9778.778442428:main thread    : strmCloseFile: deleting
> >>>> '/var/spool/rsyslog/prism_kafka_queue.00000001'
> >>>> 9778.778499467:main thread    : omsgkafka: freeInstance called
> >>>> 9778.778513906:main thread    : all primary multi-thread sources have
> >>>> been
> >>>> terminated - now doing aux cleanup...
> >>>> 9778.778519118:main thread    : destructing current config...
> >>>> 9778.778524283:main thread    : calling freeCnf(0x13191e0) for module
> >>>> 'builtin:omfile'
> >>>> 9778.778529272:main thread    : calling freeCnf(0x13193a0) for module
> >>>> 'builtin:ompipe'
> >>>> 9778.778534707:main thread    : calling freeCnf(0x131a3a0) for module
> >>>> 'builtin:omfwd'
> >>>> 9778.778540278:main thread    : calling freeCnf(0x1329b00) for module
> >>>> 'imuxsock'
> >>>> 9778.778545633:main thread    : calling freeCnf(0x132ac70) for module
> >>>> 'imklog'
> >>>> 9778.778729757:main thread    : destructing parser 'rsyslog.rfc5424'
> >>>> 9778.778736340:main thread    : destructing parser 'rsyslog.rfc3164'
> >>>> 9778.778741419:main thread    : pmrfc3164: free parser instance
> 0x131a8b0
> >>>> 9778.778810084:main thread    : file rsyslogd.c released module
> 'lmnet',
> >>>> reference count now 2
> >>>> 9778.778970064:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 2
> >>>> 9778.778976042:main thread    : Unloading module builtin:omfile
> >>>> 9778.778981773:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 2
> >>>> 9778.778986410:main thread    : Unloading module builtin:ompipe
> >>>> 9778.778991284:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 2
> >>>> 9778.778996016:main thread    : Unloading module builtin-shell
> >>>> 9778.779000666:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 2
> >>>> 9778.779005245:main thread    : Unloading module builtin:omdiscard
> >>>> 9778.779010169:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 2
> >>>> 9778.779014765:main thread    : Unloading module builtin:omfwd
> >>>> 9778.779020701:main thread    : file omfwd.c released module 'lmnet',
> >>>> reference count now 1
> >>>> 9778.779025970:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779030535:main thread    : Unloading module builtin:omusrmsg
> >>>> 9778.779035196:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779039750:main thread    : Unloading module builtin:pmrfc5424
> >>>> 9778.779044623:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779049166:main thread    : Unloading module builtin:pmrfc3164
> >>>> 9778.779053994:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779058499:main thread    : Unloading module builtin:smfile
> >>>> 9778.779063115:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779067650:main thread    : Unloading module builtin:smtradfile
> >>>> 9778.779072340:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779080829:main thread    : Unloading module builtin:smfwd
> >>>> 9778.779085950:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779090579:main thread    : Unloading module builtin:smtradfwd
> >>>> 9778.779095331:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779099910:main thread    : Unloading module imuxsock
> >>>> 9778.779127532:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779134318:main thread    : Unloading module imklog
> >>>> 9778.779149232:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.779452603:main thread    : module lmregexp NOT unloaded because
> it
> >>>> still has a refcount of 2
> >>>> 9778.779458039:main thread    : Unloading module omsgkafka
> >>>> 9778.779853849:main thread    : module lmnet NOT unloaded because it
> >>>> still
> >>>> has a refcount of 1
> >>>> 9778.780141515:main thread    : module lmregexp NOT unloaded because
> it
> >>>> still has a refcount of 2
> >>>> 9778.780157201:main thread    : file conf.c released module 'lmnet',
> >>>> reference count now 0
> >>>> 9778.780297378:main thread    : module 'lmnet' has zero reference
> count,
> >>>> unloading...
> >>>> 9778.780438764:main thread    : Unloading module lmnet
> >>>> 9778.780664790:main thread    : rsyslog runtime de-initialized,
> current
> >>>> users 0
> >>>> 9778.780921611:main thread    : Clean shutdown completed, bye
> >>>>
> >>>>
> >>>>
> >>>> On Thu, Feb 25, 2016 at 4:58 PM, David Lang <[email protected]> wrote:
> >>>>
> >>>> On Thu, 25 Feb 2016, Kane Kim wrote:
> >>>>>
> >>>>> Btw, I've tried it with latest master - I have following:
> >>>>>
> >>>>>>
> >>>>>> BEGINcommitTransaction
> >>>>>>   CODESTARTcommitTransaction
> >>>>>>   dbgprintf("omsgkafka: committransaction called\n");
> >>>>>>   srSleep(1500, 0);
> >>>>>>
> >>>>>> .....
> >>>>>>
> >>>>>> Then I send 3 log lines and restart rsyslog 3 times in a row (while
> >>>>>> commitTransaction is still sleeping). After 3rd restart queue file
> >>>>>> disappears from disk.
> >>>>>>
> >>>>>>
> >>>>>> prior to this, what does the debug log say is happening to the log
> >>>>> message? it should show the message being read from the queue and
> then
> >>>>> ...
> >>>>>
> >>>>>
> >>>>> David Lang
> >>>>> _______________________________________________
> >>>>> rsyslog mailing list
> >>>>> http://lists.adiscon.net/mailman/listinfo/rsyslog
> >>>>> http://www.rsyslog.com/professional-services/
> >>>>> What's up with rsyslog? Follow https://twitter.com/rgerhards
> >>>>> NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a
> myriad
> >>>>> of sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if
> you
> >>>>> DON'T LIKE THAT.
> >>>>>
> >>>>> _______________________________________________
> >>>> rsyslog mailing list
> >>>> http://lists.adiscon.net/mailman/listinfo/rsyslog
> >>>> http://www.rsyslog.com/professional-services/
> >>>> What's up with rsyslog? Follow https://twitter.com/rgerhards
> >>>> NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a
> myriad
> >>>> of sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you
> >>>> DON'T LIKE THAT.
> >>>>
> >>>> _______________________________________________
> >>> rsyslog mailing list
> >>> http://lists.adiscon.net/mailman/listinfo/rsyslog
> >>> http://www.rsyslog.com/professional-services/
> >>> What's up with rsyslog? Follow https://twitter.com/rgerhards
> >>> NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a
> myriad
> >>> of sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you
> >>> DON'T LIKE THAT.
> >>>
> >>
> > _______________________________________________
> > rsyslog mailing list
> > http://lists.adiscon.net/mailman/listinfo/rsyslog
> > http://www.rsyslog.com/professional-services/
> > What's up with rsyslog? Follow https://twitter.com/rgerhards
> > NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a myriad
> of sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you
> DON'T LIKE THAT.
> _______________________________________________
> rsyslog mailing list
> http://lists.adiscon.net/mailman/listinfo/rsyslog
> http://www.rsyslog.com/professional-services/
> What's up with rsyslog? Follow https://twitter.com/rgerhards
> NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a myriad
> of sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you
> DON'T LIKE THAT.
>
_______________________________________________
rsyslog mailing list
http://lists.adiscon.net/mailman/listinfo/rsyslog
http://www.rsyslog.com/professional-services/
What's up with rsyslog? Follow https://twitter.com/rgerhards
NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a myriad of 
sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you DON'T LIKE 
THAT.

Reply via email to