2016-03-04 18:29 GMT+01:00 Kane Kim <[email protected]>:
> I can help to reproduce it with omfwd or omtesting

It would be great if you could create a scenario where omfwd fails. We
already have some test cases for this in the testbench, and if we know
a failure scenario (or even better craft a test), we would be much
better off. omtesting would be my fallback scenario.

Any contribution would be very welcome.

Rainer
>
> 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.
_______________________________________________
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