Das deutsche Python-Forum

Seit 2002 Diskussionen rund um die Programmiersprache Python
https://www.python-forum.de/

Qemu-Monitor - Problem bei Nutzung über Socket

https://www.python-forum.de/viewtopic.php?t=44203

Seite 1 von 2

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 10:27
von midan23
Hab ich mal ausprobiert ... selbst wenn ich ein "print sock.recv(1000)" einbaue bringt es nichts ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 10:38
von __deets__
Der socat-code ist ziemlich komplex. Auch da wuerde wahrscheinlich strace helfen um zu sehen, was die mit dem fd machen, nachdem das Kommando durchkam.

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 11:30
von midan23
Hab mal "socat" mit "strace" laufen lassen:

Code: Alles auswählen

recvfrom(3, 0x7ffc0239a8e0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
getsockname(5, {sa_family=AF_UNIX}, [112->2]) = 0
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [1 5], [], NULL)       = 3 (in [5], out [1 5])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(5, "QEMU 3.0.0 monitor - type 'help'"..., 8192) = 62
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(1, "QEMU 3.0.0 monitor - type 'help'"..., 62) = 62
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [1], [], NULL)         = 1 (out [1])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [], [], NULL)          = 1 (in [0])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(0, "system_powerdown\n", 8192)     = 17
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(5, "system_powerdown\n", 17)      = 17
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [5], [], NULL)         = 2 (in [5], out [5])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(5, "s\33[K\33[Dsy\33[K\33[D\33[Dsys\33[K\33[D\33[D\33["..., 8192) = 480
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(1, "s\33[K\33[Dsy\33[K\33[D\33[Dsys\33[K\33[D\33[D\33["..., 480) = 480
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [1], [], NULL)         = 2 (in [5], out [1])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(5, "\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33["..., 8192) = 73
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(1, "\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33["..., 73) = 73
recvfrom(3, 0x7ffc0239aca0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [1], [], NULL)         = 1 (out [1])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [], [], NULL)          = 1 (in [0])
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(0, "", 8192)                       = 0
recvfrom(3, 0x7ffc0239a7a0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
shutdown(5, SHUT_WR)                    = 0
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [5], [], [], {tv_sec=0, tv_usec=500000}) = 0 (Timeout)
recvfrom(3, 0x7ffc0239ad10, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
ioctl(0, SNDCTL_TMR_START or TCSETS, {B38400 opost isig icanon echo ...}) = 0
ioctl(1, SNDCTL_TMR_START or TCSETS, {B38400 opost isig icanon echo ...}) = 0
shutdown(5, SHUT_RDWR)                  = 0
recvfrom(3, 0x7ffc0239aff0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
exit_group(0)                           = ?
+++ exited with 0 +++

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 11:35
von __deets__
Also der macht definitiv ein select, und danach ein read. Hast du auch das select gemacht? Wobei ich die Daten, die er dann wirklich liest komisch finde.

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 11:58
von midan23
Wie müsste ich die Funktion ändern, um da ein "select" einzubauen?
Wobei ich ehrlich zugebe, das die ganze Netzwerk-Programmierung für mich Neuland ist ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 12:13
von __deets__
na, du musst halt ein select aus dem Modul select einbauen. Grob so:

Code: Alles auswählen

socket.sendall(...)
readlist = [] # wir wollen nix lesen
writelist = [socket] # ggf. socket.fileno(), aber das sollte so gehen
xlist = [] # wir brauchen keine exceptional conditions
select.select(readlist, writelist, xlist)
Der sollte so lange warten, bis man auf dem socket wieder schreiben kann. Was ggf. eben impliziert, das der "geflusht" ist. An sich ist das alles Standardvorgehen, ich bin mir nur um die Details der Semantik hier mit gepufferten Daten, die dann ggf. noch nicht geschrieben sind auch nicht klar - sowas ist bestimmt in POSIX spezifiziert, aber probieren, studieren, etc...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 13:25
von midan23
Den "select" habe ich mal so eingebaut:

Code: Alles auswählen

def send(path):
    print path
    sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
    sock.connect(path)
    sock.sendall("system_powerdown\n")
    readlist = [sock]
    writelist = [sock]
    xlist = []
    select.select(readlist, writelist, xlist)
    sock.close()
Keine Änderung ... VM läuft weiter ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 15:02
von __deets__
Ich wuerde mal mit readlist und writelist jeweils leer spielen. In deinem Traceback kommt das tatsaechlich nur in der readlist vor.

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 15:16
von midan23
Wenn die "readlist" als einzige nicht leer ist, fährt die VM nicht runter
Wenn alle 3 Listen leer sind schon ... aber das Script durfte ich abbrechen
(Timeout wäre eine nette Idee gewesen, aber da kann ich gleich beim "sleep" bleiben)

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 15:35
von __deets__
Klar, wenn die alle leer sind, dann ist das ein endloses schlafen. Wie gesagt, was genau da der Unterschied ist, finde ich sehr schwer zu erkennen. Ggf. kannst du das socat nochmal tracen ohne den stoerenden output dazwischen. Denn das read kommt doch von einem anderen Prozess, oder?

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 15:40
von Sirius3
@midan23: das select ist überflüssig, denn Du weißt ja, wann Du etwas schreiben willst, und wann du etwas lesen willst.

Was liefert denn `socat` als Ausgabe? Vielleicht war ein `recv` ein bißchen optimistisch. Pack das recv in eine Endlosschleife, denn nach dem Herunterfahren wird ja der Socket definitiv geschlossen:

Code: Alles auswählen

sock.sendall("system_powerdown\n")
while True:
    data = sock.recv(1000)
    if not data:
        break
    print(data) # Debug-Ausgabe
sock.close()

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 15:54
von midan23
__deets__ hat geschrieben: Mittwoch 14. November 2018, 15:35 Klar, wenn die alle leer sind, dann ist das ein endloses schlafen. Wie gesagt, was genau da der Unterschied ist, finde ich sehr schwer zu erkennen. Ggf. kannst du das socat nochmal tracen ohne den stoerenden output dazwischen. Denn das read kommt doch von einem anderen Prozess, oder?
Wüsste nicht von welchem Prozess das "read" kommen sollte ...
Gestartet habe ich es einfach mit

Code: Alles auswählen

socat - UNIX:<pfad>
Dann habe ich einfach "system_powerdown" eingegeben ...

@Sirius3

Socat (gestartet mit "echo "system_powerdown" | socat - UNIX:<pfad>") liefert folgendes:

Code: Alles auswählen

QEMU 3.0.0 monitor - type 'help' for more information
(qemu) system_powerdown
(qemu)
Und wenn ich die "while"-Schleife drinnen habe, liefert das Script folgende Ausgabe:

Code: Alles auswählen

QEMU 3.0.0 monitor - type 'help' for more information
(qemu) 
sy
sys
syst
syste
system
system_
system_p
system_po
system_pow
system_powe
system_power
system_powerd
system_powerdo
system_powerdow
system_powerdown


(qemu)
Ach ja: Und die VM fährt runter ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 16:03
von __deets__
Moment, hast du socat interaktiv benutzt?

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 16:14
von midan23
Hab ich, ja ...
Im erste Post hatte ich ein die Ausgabe von "echo" über eine Pipe nach "socat" geschickt.
Da ich nicht weiss, wie ich das in Verbindung mit "strace" mache, habe ich es interaktiv genutzt ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Mittwoch 14. November 2018, 16:39
von __deets__
na, das macht die Sache strace-maessig natuerlich etwas komplexer, weil er dann einen mainloop aufsetzt etc. Das erklaert dann auch, warum er den string nicht nur schreibt, sondern auch liest - das ist halt deine Eingabe ;)

strace hat auch pipe-support, womit das auch gehen sollte. Wie auch immer genau...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Donnerstag 15. November 2018, 10:05
von midan23
Jetzt hab ich den "socat" mal so aufgerufen:

Code: Alles auswählen

strace -o socat.out socat - UNIX:<pfad> <<EOT
> system_powerdown
> EOT
Und hier die letzten Zeilen der "socat.out":

Code: Alles auswählen

getsockname(5, {sa_family=AF_UNIX}, [112->2]) = 0
recvfrom(3, 0x7ffd249b15b0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [1 5], [], NULL)       = 4 (in [0 5], out [1 5])
recvfrom(3, 0x7ffd249b15b0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(0, "system_powerdown\n", 8192)     = 17
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1540, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(5, "system_powerdown\n", 17)      = 17
recvfrom(3, 0x7ffd249b1540, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(5, "QEMU 3.0.0 monitor - type 'help'"..., 8192) = 326
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1540, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(1, "QEMU 3.0.0 monitor - type 'help'"..., 326) = 326
recvfrom(3, 0x7ffd249b1540, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b15b0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [0 5], [1 5], [], NULL)       = 4 (in [0 5], out [1 5])
recvfrom(3, 0x7ffd249b15b0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(0, "", 8192)                       = 0
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(5, "\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33["..., 8192) = 289
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1540, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
write(1, "\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33[D\33["..., 289) = 289
recvfrom(3, 0x7ffd249b1540, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
shutdown(5, SHUT_WR)                    = 0
recvfrom(3, 0x7ffd249b15b0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
select(6, [5], [1], [], {tv_sec=0, tv_usec=500000}) = 2 (in [5], out [1], left {tv_sec=0, tv_usec=499995})
recvfrom(3, 0x7ffd249b15b0, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
read(5, "", 8192)                       = 0
recvfrom(3, 0x7ffd249b1040, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
shutdown(5, SHUT_WR)                    = 0
ioctl(1, SNDCTL_TMR_START or TCSETS, {B38400 opost isig icanon echo ...}) = 0
shutdown(5, SHUT_RDWR)                  = 0
recvfrom(3, 0x7ffd249b1890, 519, MSG_DONTWAIT, NULL, NULL) = -1 EAGAIN (Die Ressource ist zur Zeit nicht verfügbar)
exit_group(0)                           = ?
+++ exited with 0 +++
Ich seh da ebenfalls einen "select" ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Donnerstag 15. November 2018, 10:49
von __deets__
Na vor allem liest der da ne eine Menge, schreibt auch eine Menge, und dadurch verzoegert sich das ganze ggf. einfach ausreichend lange.

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Donnerstag 15. November 2018, 11:11
von __blackjack__
Insbesondere wird diese ``QEMU 3.0.0 monitor - type 'help'``-Meldung von QEMU gelesen. Vielleicht erwartet QEMU ja, dass diese Meldung rausgeschrieben werden kann bevor es irgendwelche Kommandos verarbeitet.

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Donnerstag 15. November 2018, 11:21
von midan23
Mach leider auch keinen Unterschied ...

Scheint, als ob zwischen "sock.sendall" und "sock.close" eine kurze Wartezeit notwendig ist ...

Hab gerade ein "time.sleep(0.1) versucht ... reicht aus.

Verstehen tu ich es immer noch nicht ... aber da es geht ...

Re: Qemu-Monitor - Problem bei Nutzung über Socket

Verfasst: Donnerstag 15. November 2018, 11:39
von Sirius3
@midan23: ich verstehe nicht, warum Du hier noch herumprobierst, die Lösung habe ich doch schon gestern gepostet: die while-Schleife mit recv. Das ist die einfachste und sauberste Möglichkeit. `select` braucht man nur, wenn nicht bestimmt ist, ob der Server oder der Client sendet, oder beide gleichzeitig. Bei Dir ist aber die Reihenfolge Client sendet -> Server antwortet klar.
Alle Zeiten sind UTC+01:00
Seite 1 von 2

Powered by phpBB® Forum Software © phpBB Limited

Deutsche Übersetzung durch phpBB.de