On 21.02.2018 05:55, Georg Chini wrote:
> On 20.02.2018 22:34, Raman Shishniou wrote:
>> On 02/20/2018 11:04 PM, Georg Chini wrote:
>>> On 20.02.2018 19:49, Raman Shishniou wrote:
>>>> On 02/20/2018 07:02 PM, Georg Chini wrote:
>>>>> On 20.02.2018 16:38, Raman Shyshniou wrote:
>>>>>> Currently the pipe-source will remain running even if no
>>>>>> writer is connected and therefore no data is produced.
>>>>>> This patch adds the autosuspend=<bool> option to prevent this.
>>>>>> Source will stay suspended if no writer is connected.
>>>>>> This option is enabled by default.
>>>>>> ---
>>>>>> Â Â Â src/modules/module-pipe-source.c | 279
>>>>>> +++++++++++++++++++++++++++++----------
>>>>>> Â Â Â 1 file changed, 212 insertions(+), 67 deletions(-)
>>>>>>
>>>> I think I need post a simple pseudo code of new thread loop because it
>>>> was completely rewritten. There are too many changes in one patch.
>>>> It can be difficult to see the whole picture of new main loop.
>>> Well, I applied the patch and looked at the result. I still don't
>>> like the approach.
>>>
>>> I would propose this:
>>>
>>> auto_suspended = false;
>>> revents = 0
>>> events = POLLIN
>>>
>>> for (;;) {
>>>
>>> Â Â Â Â Â Â /* This is the part that is run when the source is opened
>>> Â Â Â Â Â Â Â * or auto suspended
>>> Â Â Â Â Â Â if (SOURCE_IS_OPENED(source) || auto_suspended) {
>>>
>>> Â Â Â Â Â Â Â Â Â Â /* Check if we wake up from user suspend */
>>> Â Â Â Â Â Â Â Â Â Â if (corkfd >= 0 && !auto_suspended) {
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â len = 0
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â close pipe for writing
>>> Â Â Â Â Â Â Â Â Â Â }
>>>
>>> Â Â Â Â Â Â Â Â Â Â /* We received POLLIN or POLLHUP or both */
>>> Â Â Â Â Â Â Â Â Â Â if (revents) {
>>>
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â /* Read data from pipe */
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â len = read data
>>>
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â /* Got data, post it */
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â if (len > 0) {
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â if (auto_suspend) {
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â send unsuspend message
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â auto_suspend = false
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â }
>>> Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â Â post data
>> We cannot post data here because source still suspended. Sending
>> resume message is not enough
>> to immediately resume the source. We need to wait several poll runs
>> until it will be resumed.
>> (source->thread_info.state changed in this thread, i.e. during poll
>> run). But we will see
>> POLLIN and/or POLLHUP each run if we don't remove pipe fd from polling.
>
> Why do we have to wait? The source will be unsuspended on the next
> rtpollrun.
> I do not see why we cannot already push data. Or does something get lost?
Why would we receive POLLIN on each run? We read the data from the pipe.
If you think the data should not be posted, you can just skip posting
and discard
the data. According to your pseudo-code it is done like tis in your
previous patch.
