पता लगाएं कि पाठक नामित पाइप (एफआईएफओ)

Question

क्या बंद करने के लिए कोई तरीका है कि एक पाठक ने नामित पाइप (या बाहर निकला), के के बिना इसे बंद कर दिया है?

मुझे यह जानने की ज़रूरत है क्योंकि पाइप को लिखने वाला प्रारंभिक डेटा अलग है; शेष डेटा आने से पहले पाठक प्रारंभिक शीर्षलेख की अपेक्षा कर रहा है।

वर्तमान में, मुझे यह पता चलता है जब मेरा write()EPIPE के साथ विफल रहता है। फिर मैंने एक ध्वज सेट किया जो कहता है "अगली बार, हेडर भेजें"। हालांकि, कुछ भी लिखने से पहले पाठक को बंद करने और पाइप को फिर से खोलना संभव है। इस मामले में, मुझे कभी नहीं पता कि उसने क्या किया है, और वह जिस हेडर की अपेक्षा कर रहा है उसे न भेजें।

क्या एसिंक घटना प्रकार की कोई चीज है जो यहां मदद कर सकती है? मुझे कोई सिग्नल भेजा नहीं जा रहा है।

_{ध्यान दें कि मैंने कोई भी भाषा टैग शामिल नहीं किया है, क्योंकि इस प्रश्न को भाषा-अज्ञेयवादी माना जाना चाहिए। मेरा कोड पायथन है, लेकिन उत्तर सी, या सिस्टम कॉल-स्तरीय बाइंडिंग के साथ किसी भी अन्य भाषा पर लागू होना चाहिए।}

Answer 1

अजीब तरह से पर्याप्त है, यह प्रकट होता है जब पिछले पाठक पाइप बंद कर देता है, select इंगित करता है कि पाइप पढ़ी जा सकती है:

writer.py

#!/usr/bin/env python 
import os 
import select 
import time 

NAME = 'fifo2' 

os.mkfifo(NAME) 


def select_test(fd, r=True, w=True, x=True): 
    rset = [fd] if r else [] 
    wset = [fd] if w else [] 
    xset = [fd] if x else [] 

    t0 = time.time() 
    r,w,x = select.select(rset, wset, xset) 

    print 'After {0} sec:'.format(time.time() - t0) 
    if fd in r: print ' {0} is readable'.format(fd) 
    if fd in w: print ' {0} is writable'.format(fd) 
    if fd in x: print ' {0} is exceptional'.format(fd) 

try: 
    fd = os.open(NAME, os.O_WRONLY) 
    print '{0} opened for writing'.format(NAME) 

    print 'select 1' 
    select_test(fd) 

    os.write(fd, 'test') 
    print 'wrote data' 

    print 'select 2' 
    select_test(fd) 

    print 'select 3 (no write)' 
    select_test(fd, w=False) 

finally: 
    os.unlink(NAME) 

डेमो:

टर्मिनल 1:

$ ./pipe_example_simple.py 
fifo2 opened for writing 
select 1 
After 1.59740447998e-05 sec: 
3 is writable 
wrote data 
select 2 
After 2.86102294922e-06 sec: 
3 is writable 
select 3 (no write) 
After 2.15910816193 sec: 
3 is readable 

टर्मिनल 2:

$ cat fifo2 
test 
# (wait a sec, then Ctrl+C) 

Answer 2

आप एक घटना पाश कि poll प्रणाली पर आधारित है प्रयोग कर रहे हैं फोन आप एक घटना मुखौटा कि EPOLLERR शामिल साथ पाइप रजिस्टर कर सकते हैं। अजगर, select.poll साथ, में

import select 
fd = open("pipe", "w") 
poller = select.poll() 
poller.register(fd, select.POLLERR) 
poller.poll() 

जब तक पाइप बंद कर दिया है इंतजार करेंगे।

इसका परीक्षण करने के लिए, mkfifo pipe चलाएं, स्क्रिप्ट शुरू करें, और दूसरे टर्मिनल रन में, उदाहरण के लिए, cat pipe। जैसे ही आप cat प्रक्रिया को छोड़ देते हैं, स्क्रिप्ट समाप्त हो जाएगी।

Answer 3

ऐसी कोई प्रक्रिया नहीं है। आम तौर पर, यूनिक्स-मार्ग के अनुसार, किसी भी अंत में, खोलने या बंद करने वाली धाराओं के लिए कोई सिग्नल नहीं होता है। यह केवल उन्हें पढ़ने या लिखने के द्वारा ही पता लगाया जा सकता है (तदनुसार)।

मैं कहूंगा कि यह गलत डिज़ाइन है। वर्तमान में आप रिसीवर को पाइप खोलकर अपनी उपलब्धता को प्राप्त करने की कोशिश कर रहे हैं। तो या तो आप इस सिग्नलिंग को उचित तरीके से कार्यान्वित करते हैं, या पाइप के भेजने वाले भाग में "समापन तर्क" शामिल करते हैं।