Dotaz: Python otevření | pípy

[filbar]

Mám problém s otevřením | pípy v Pythonu:

os.mkfifo('/tmp/.powerman_fifo');
self.pipe=os.open('/tmp/.powerman_fifo', os.O_WRONLY|os.O_NONBLOCK);

Když spustím tento kód, tak mi to hlásí:

Traceback (most recent call last):
  File "/media/JOOMLADEV/eclipse-src/python/PowerMan/src/powermangui.py", line 160, in <module>
    pg=PowerManGui();
  File "/media/JOOMLADEV/eclipse-src/python/PowerMan/src/powermangui.py", line 15, in __init__
    self.pipe=os.open('/tmp/.powerman_fifo', os.O_WRONLY|os.O_NONBLOCK);
OSError: [Errno 6] No such device or address: '/tmp/.powerman_fifo'

Přitom ta pipe existuje:

ls -al /tmp/.powerman_fifo 
prw-r--r-- 1 bartmann bartmann 0 2009-06-28 17:33 /tmp/.powerman_fifo

Nevíte kde dělám chybu?

Za rady předem děkuji.

Odpovědi

[12345]

man 7 fifo říká tohle:

A process can open a FIFO in non-blocking mode. In this case, opening for read only will succeed even if no-one has opened on the write side yet; opening for write only will fail with ENXIO (no such device or address) unless the other end has already been opened.

OSError 6 je opravdu ENXIO:

>>> import errno
>>> errno.ENXIO
6

[filbar]

Tak jsem o kousek pokročil:

self.state=os.read(self.pipe, 1000);
OSError: [Errno 11] Resource temporarily unavailable

Přitom na mám rouru v rodiči otevřenou a v dokumentaci jsem vyčetl, že při čtení z neblokující roury má vrátit 0 bytů.

Postupuju, tak že si nejprve vytvořím instanci třídy PowerMan, v jejímž konstruktoru otvírám PIPU pro čteční, následně otevírám rouru pro zápis, volám fork() a v potomkovi volám metodu PowerMan.run, kde ve while 1: z roury čtu:

if os.path.exists('/tmp/.powerman_fifo')==False:
			os.mkfifo('/tmp/.powerman_fifo');
		pm=powerman.PowerMan();
		self.pipe=os.open('/tmp/.powerman_fifo', os.O_WRONLY|os.O_NONBLOCK);
		self.state=True;
		pid=os.fork();
		if pid==0:
			pm.run();

Metoda run() třídy PowerMan:

def run(self):
		while 1:
			self.state=os.read(self.pipe, 1000);
			print self.state;
                        #Zpracovat obsah PIPE
			if self.quit==True:
				break;
			if self.state==True:
				self.get_idle();
				self.get_idle_workaround();
				if int(self.idle)>=int(self.stime):
					pid=os.fork();
					if pid==0:
						self.idle=0;
						os.execl(self.prog);
					else:
						os.wait();
			time.sleep(1);

[12345]

Jestli jde jen o komunikaci rodičovského procesu s potomkem, není k tomu potřeba named pipe. Taková jednoduchá jednosměrná komunikace:

import fcntl, os, time

(rd, wr) = os.pipe()

if os.fork() == 0:
	os.close(wr)
	fcntl.fcntl(rd, fcntl.F_SETFL, os.O_NONBLOCK)
	print 'child: waiting for input'
	while True:
		try:
			data = os.read(rd, 1000)
			if data:
				print 'child: received:', data
		except OSError:
			pass
else:
	os.close(rd)
	while True:
		data = raw_input('parent:> ')
		os.write(wr, data)
		time.sleep(.3) # aby se nesleval vystup potomka s rodicem

Ukázka:

$ python pipe.py
child: waiting for input
parent:> hello
child: received: hello
parent:> how are you?
child: received: how are you?
parent:>                         

OSError 11 je v pořádku, je to obyčejné EAGAIN/EWOULDBLOCK (viz www.gnu.org/s/libc/manual/html_node/Error-Codes.html#index-EAGAIN-97).

[Marcel]

Zdravím pánové, již je sice pozdě a asi nebudu přímo k věci, ale chtěl bych zde uvést svůj web pro další návštěvníky, kde jsem rozebíral základy této problematiky.

Na webu http://networks.ic.cz průběžně aktualizuji věci které se týkají programování a webu a v sekci Python rozebírám jednotlivé moduly. Takže se kdyžtak mrkněte

Modul subproces

Modul fcntl