🚀 go-pugleaf

On Dec 21, 4:06 pm, królewna <krole...@ee.pl> wrote:
> Czy jest jakaś możliwość aby multiprocessing.connection.Client podczas
> tworzenia połączenia miał podawany parametr działający na zasadzie
> timeout?

Może klasycznie uniksowe rozwiązanie:

http://www.python.org/doc/2.6.4/library/signal.html#example

On Dec 21, 4:35 pm, Bart Ogryczak <b.ogryc...@gmail.com> wrote:
> On Dec 21, 4:06 pm, królewna <krole...@ee.pl> wrote:
>
> > Czy jest jakaś możliwość aby multiprocessing.connection.Client podczas
> > tworzenia połączenia miał podawany parametr działający na zasadzie
> > timeout?
>
> Może klasycznie uniksowe rozwiązanie:
>
> http://www.python.org/doc/2.6.4/library/signal.html#example

Jak widać nie pomyśleli o tym, ale można użyć
http://docs.python.org/library/socket.html#socket.setdefaulttimeout
tuż przed wywołaniem Client(). Powinno to ustawić timeout na sockecie,
który stworzy SocketClient(). PipeClient() wydaje się mieć ustawiony
na sztywno timeout 1000ms.

W dniu 21.12.2009 17:30, Łukasz Rekucki pisze:

> Jak widać nie pomyśleli o tym, ale można użyć
> http://docs.python.org/library/socket.html#socket.setdefaulttimeout
> tuż przed wywołaniem Client(). Powinno to ustawić timeout na sockecie,
> który stworzy SocketClient(). PipeClient() wydaje się mieć ustawiony
> na sztywno timeout 1000ms.

Przyznam, że nie rozumiem w jaki sposób to działa. Tworzę nowy obiekt 
klasy socket zupełnie nie związany z obiektem klasy Client, zmieniam na 
nim timeout i to działa na obiekcie Clienta. Jaka jest zasada działania 
tego? Czyli jak zmienię na jednym obiekcie klasy socket np timeout to 
ten timeout zmienia się na wszystkich?

królewna

On Dec 22, 10:24 am, królewna <krole...@ee.pl> wrote:
> W dniu 21.12.2009 17:30, Łukasz Rekucki pisze:
>
> > Jak widać nie pomyśleli o tym, ale można użyć
> >http://docs.python.org/library/socket.html#socket.setdefaulttimeout
> > tuż przed wywołaniem Client(). Powinno to ustawić timeout na sockecie,
> > który stworzy SocketClient(). PipeClient() wydaje się mieć ustawiony
> > na sztywno timeout 1000ms.
>
> Przyznam, że nie rozumiem w jaki sposób to działa. Tworzę nowy obiekt
> klasy socket zupełnie nie związany z obiektem klasy Client, zmieniam na
> nim timeout i to działa na obiekcie Clienta. Jaka jest zasada działania
> tego? Czyli jak zmienię na jednym obiekcie klasy socket np timeout to
> ten timeout zmienia się na wszystkich?

Nie. Importujesz moduł socket. Zmieniasz domyślny timeout. Wszystkie
sockety utworzone po tej zmianie będą miały taki timeout.
Np.

import socket
socket.setdefaulttimeout(twój_timeout)
...

klient = multiprocessing.connection.Client() # ten klient będzie miał
twój timeout.

W dniu 22.12.2009 10:29, Bart Ogryczak pisze:

>
> Nie. Importujesz moduł socket. Zmieniasz domyślny timeout. Wszystkie
> sockety utworzone po tej zmianie będą miały taki timeout.
> Np.
>
> import socket
> socket.setdefaulttimeout(twój_timeout)
> ...
>
> klient = multiprocessing.connection.Client() # ten klient będzie miał
> twój timeout.

Oh, przepraszam. Byłam prawie pewna, że właśnie zrobiłam tak jak 
napisałam i zadziałało więc mnie to zdziwiło. Ale najwidoczniej 
napisałam tak jak radziłeś bo teraz sprawdzam i rzeczywiście działa tak 
jak opisujesz.

Użytkownik "Łukasz Rekucki" <lrekucki@gmail.com> napisał w wiadomości 
news:5e45a27a-4515-40c1-b098-f5f2724be64c@r24g2000yqd.googlegroups.com...

> Jak widać nie pomyśleli o tym, ale można użyć
> http://docs.python.org/library/socket.html#socket.setdefaulttimeout

Z zastrzeżeniem, że to jest zmiana globalna - na wszystkie wątki. 

On 23.12.2009, William Bonawentura <news@ipartners.pl> wrote:
>> Jak widać nie pomyśleli o tym, ale można użyć
>> http://docs.python.org/library/socket.html#socket.setdefaulttimeout
> Z zastrzeżeniem, że to jest zmiana globalna - na wszystkie wątki. 
Dlatego najlepiej timeouty implementować na select.select lub select.*Poll,
np. (piszę z pamięci, więc może nie działać, ale ogólną zasadę Królewna
wyczai):


sock = socket.socket(<co tam potrzeba>)
sock.setblocking(0)
poller = select.poll()
poller.register(sock.fileno(), select.POLLOUT)
try:
    sock.connect(<co tam potrzeba>)
except socket.error, e:
    if e.args[0] not in (errno.EINPROGRESS, errno.EALREADY, errno.EWOULDBLOCK):
	sock.close()
        raise
    else:
        pass
except:
    sock.close()
    raise
events = poller.poll(<wybrany timeout>)
if not events:
    sock.close()
    raise JakiśTamWyjątek('Connect timeout')
sock.setblocking(1)


W Pythonie 3.0 już są AFAIR timeouty per obiekt gniazda, a nie
globalne, ale nie pamiętam czy obejmowały one przekroczenia czasu
połączenia, czy tylko timout transferu danych.



Pozdrawiam
Beorn

-- 
Daniel 'Beorn' Mróz <beorn@alpha.pl>    http://127.0.0.1/beorn
[GIT d s:- a-@ C++++ UL++++$ P+ L++++ E--- W+ N+++ o? K- w---]
[O- M- V!  PS+ PE++ Y+ PGP++ t- 5  X R !tv b+ DI D++ G++ e h*]
[                          r++  y+                           ]

Użytkownik "Daniel Mróz" <beorn@alpha.pl> napisał w wiadomości 
news:slrnhjchh0.h9g.beorn@pino.cyberdeck.pl...
>
>
> W Pythonie 3.0 już są AFAIR timeouty per obiekt gniazda, a nie
> globalne, ale nie pamiętam czy obejmowały one przekroczenia czasu

Są i w 2.6 

On Dec 30, 8:01 am, "William Bonawentura" <n...@ipartners.pl> wrote:
> Użytkownik "Daniel Mróz" <be...@alpha.pl> napisał w wiadomościnews:slrnhjchh0.h9g.beorn@pino.cyberdeck.pl...
>
>
>
> > W Pythonie 3.0 już są AFAIR timeouty per obiekt gniazda, a nie
> > globalne, ale nie pamiętam czy obejmowały one przekroczenia czasu
>
> Są i w 2.6

W każdej wersji gdzie jest setsockopt()! Ale w ogóle nie o to tu
chodziło. Problem był taki, że konstruktor klasy
http://docs.python.org/library/multiprocessing.html#multiprocessing.connection.Client
, który wewnętrznie tworzy sobie socket do którego nie masz dostępu,
nie przyjmuję takiej opcji.


>> Jak widać nie pomyśleli o tym, ale można użyć
>> http://docs.python.org/library/socket.html#socket.setdefaulttimeout

> Z zastrzeżeniem, że to jest zmiana globalna - na wszystkie wątki.
W kontekście multiprocessing, jakoś bym się tym nie martwił ;), ale
tak - należy o tym pamiętać