search for: unix_socket

...x 22/3/96 to make it fit the AF_UNIX socket problem. * If it doesn''t work blame me, it worked when Barak sent it. * *************** *** 59,68 **** /* Internal data structures and random procedures: */ - - #define MAX_STACK 1000 /* Maximum depth of tree (about 1 page) */ static unix_socket **stack; /* stack of objects to mark */ static int in_stack = 0; /* first free entry in stack */ ! extern inline unix_socket *unix_get_socket(struct file *filp) { - --- 69,77 ---- /* Internal data structures and random procedures: */ static unix_socket **stack; /* stack of objects to m...

...ke this: disk.id = '45d1a30c-82c0-4b00-8bfb-c4d628dbf72d' hw_id = '81F716C4-4D19-CB35-82F7-94C691189FEB' host.id = '87daa64d-b27e-4336-a156-973544be708b' transfer.id = '5ffea7fa-966c-42a4-a77a-3efd6dc45c34' imageio features: flush=True trim=False zero=True unix_socket='\x00/org/ovirt/imageio' optimizing connection using unix socket '\x00/org/ovirt/imageio' Rich.

...imization was used because you will see this in the debug output: disk.id = 'c5bb72bf-b9ab-4797-9ecf-fcbf79679742' host.id = '87daa64d-b27e-4336-a156-973544be708b' transfer.id = '2207ddda-00fd-4caf-b02c-e025e8173da9' imageio features: flush=True trim=False zero=True unix_socket='\x00/org/ovirt/imageio' optimizing connection using unix socket '\x00/org/ovirt/imageio' (Note are the references to the unix socket.) This requires the absolute latest versions of imageio (1.4.0) and ovirt-engine (4.2.4-5) in order to get the optimization. However it should w...

...disk = types.Disk(id = disk.id), > + host = host, > inactivity_timeout = 3600, > ) > Nice! > ) > @@ -170,6 +195,7 @@ def open(readonly): > can_flush = False > can_trim = False > can_zero = False > + unix_socket = None > > http.putrequest("OPTIONS", destination_url.path) > http.putheader("Authorization", transfer.signed_ticket) > @@ -186,6 +212,7 @@ def open(readonly): > can_flush = "flush" in j['features'] > can_trim = &qu...

...ypes.ImageTransfer( disk = types.Disk(id = disk.id), + host = types.Host(id = host.id) if host else None, inactivity_timeout = 3600, ) ) @@ -170,6 +191,7 @@ def open(readonly): can_flush = False can_trim = False can_zero = False + unix_socket = None http.putrequest("OPTIONS", destination_url.path) http.putheader("Authorization", transfer.signed_ticket) @@ -184,6 +206,7 @@ def open(readonly): can_flush = "flush" in j['features'] can_trim = "trim" in j['feat...

...er = transfers_service.add( types.ImageTransfer( disk = types.Disk(id = disk.id), + host = host, inactivity_timeout = 3600, ) ) @@ -170,6 +195,7 @@ def open(readonly): can_flush = False can_trim = False can_zero = False + unix_socket = None http.putrequest("OPTIONS", destination_url.path) http.putheader("Authorization", transfer.signed_ticket) @@ -186,6 +212,7 @@ def open(readonly): can_flush = "flush" in j['features'] can_trim = "trim" in j['feat...

...ansfer( disk = types.Disk(id = disk.id), + host = types.Host(id = host.id) if host is not None else None, inactivity_timeout = 3600, ) ) @@ -170,6 +191,7 @@ def open(readonly): can_flush = False can_trim = False can_zero = False + unix_socket = None http.putrequest("OPTIONS", destination_url.path) http.putheader("Authorization", transfer.signed_ticket) @@ -184,6 +206,7 @@ def open(readonly): can_flush = "flush" in j['features'] can_trim = "trim" in j['feat...

v1 was here: https://www.redhat.com/archives/libguestfs/2018-June/msg00099.html v2: - Just fixes the two problems noted in the review of the previous version. Rich.

...host = host, >> inactivity_timeout = 3600, >> ) >> > > Nice! > > >> ) >> @@ -170,6 +195,7 @@ def open(readonly): >> can_flush = False >> can_trim = False >> can_zero = False >> + unix_socket = None >> >> http.putrequest("OPTIONS", destination_url.path) >> http.putheader("Authorization", transfer.signed_ticket) >> @@ -186,6 +212,7 @@ def open(readonly): >> can_flush = "flush" in j['features'] >>...

This series extract oVirt SDK and imageio code to make it eaiser to follow the code and improve error handing in open() and close(). Tested with virt-v2v master. Changes since v1: - Rebase on merged patches from v1 - Fix regression introduced by "rhv-upload: Fix cleanup after errors" - Remove "rhv-upload: Try to remove disk on timeout" since it cannot succeed - Add more

...d) if host is not None else > None, > We could use here: host = find_host() > inactivity_timeout = 3600, > ) > ) > @@ -170,6 +191,7 @@ def open(readonly): > can_flush = False > can_trim = False > can_zero = False > + unix_socket = None > > http.putrequest("OPTIONS", destination_url.path) > http.putheader("Authorization", transfer.signed_ticket) > @@ -184,6 +206,7 @@ def open(readonly): > can_flush = "flush" in j['features'] > can_trim = &qu...

This series extract oVirt SDK and imageio code to make it eaiser to follow the code and improve error handing in open() and close(). The first small patches can be consider as fixes for downstream. Tested based on libguestfs v1.41.5, since I had trouble building virt-v2v and libguestfs from master. Nir Soffer (18): rhv-upload: Remove unused exception class rhv-upload: Check status more

...afile'], + secure=not params['insecure'], + proxy_url=transfer.proxy_url) except: cancel_transfer(connection, transfer) raise - debug("imageio features: flush=%(can_flush)r trim=%(can_trim)r " - "zero=%(can_zero)r unix_socket=%(unix_socket)r" - % options) - # Save everything we need to make requests in the handle. return { - 'can_flush': options['can_flush'], - 'can_trim': options['can_trim'], - 'can_zero': options['can_zero'],...

...ive=False, ) if len(hosts) == 0: + # This oVirt host is not registered with engine. + debug("cannot find host with hw_id=%r, using any host" % vdsm_id) return None host = hosts[0] @@ -233,9 +238,12 @@ def open(readonly): if host is not None and unix_socket is not None: try: http = UnixHTTPConnection(unix_socket) + except Exception as e: + # Very unlikely failure, but we can recover by using the https + # connection. + debug("cannot create unix socket connection, using https: %s"...

...# The first request is to fetch the features of the server. + + # Authentication was needed only for GET and PUT requests when + # communicating with old imageio-proxy. needs_auth = not params['rhv_direct'] + can_flush = False can_trim = False can_zero = False unix_socket = None - http.putrequest("OPTIONS", destination_url.path) - http.putheader("Authorization", transfer.signed_ticket) - http.endheaders() - + http.request("OPTIONS", destination_url.path) r = http.getresponse() data = r.read() @@ -298,7 +299,6 @...

...o mysql with the line from my test-program. this is the patched code: i_info("ok... connecting to mysql: host='%s', user='%s', pass='%s', db='%s', port='%i', sock='%s'", host, db->user, db->password, db->dbname, db->port, unix_socket); /* failed = mysql_real_connect(conn->mysql, host, db->user, db->password, db->dbname, db->port, unix_socket, db->client_flags) == NULL; */ failed = mysql_real_connect(conn->mysql, NULL, "ro...

...s False and they will be emulated. + elif r.status == 405 or r.status == 204: + pass + + else: + raise RuntimeError("could not use OPTIONS request: %d: %s" % + (r.status, r.reason)) + + debug("imageio features: flush=%r trim=%r zero=%r unix_socket=%r" % + (can_flush, can_trim, can_zero, unix_socket)) + # Save everything we need to make requests in the handle. return { - 'can_flush': False, - 'can_trim': False, - 'can_zero': False, + 'can_flush': can_flush, +...

...l see this > in the debug output: > > disk.id = 'c5bb72bf-b9ab-4797-9ecf-fcbf79679742' > host.id = '87daa64d-b27e-4336-a156-973544be708b' > transfer.id = '2207ddda-00fd-4caf-b02c-e025e8173da9' > imageio features: flush=True trim=False zero=True > unix_socket='\x00/org/ovirt/imageio' > optimizing connection using unix socket '\x00/org/ovirt/imageio' > > (Note are the references to the unix socket.) > > This requires the absolute latest versions of imageio (1.4.0) and > ovirt-engine (4.2.4-5) in order to get the optimi...

...of the server. > + > + # Authentication was needed only for GET and PUT requests when > + # communicating with old imageio-proxy. > needs_auth = not params['rhv_direct'] > + > can_flush = False > can_trim = False > can_zero = False > unix_socket = None > > - http.putrequest("OPTIONS", destination_url.path) > - http.putheader("Authorization", transfer.signed_ticket) > - http.endheaders() > - > + http.request("OPTIONS", destination_url.path) > r = http.getresponse() >...

...db->dbname(%s) ....); before mysql_real_connect(), then see the maillog, the db->user/password/dbname is correct maillog: auth-worker(default): conn->mysql is NOT NULL auth-worker(default): host((null)), db->user(db_user), db->password(db_pw), db->dbname(dbname), db->port(0), unix_socket(/mysql.sock), db->client_flags(0) auth-worker(default): failed: (1) auth-worker(default): mysql: Connect failed to (null) (dbname): Access denied for user 'db_user'@'localhost' (using password: YES) - waiting for 1 seconds before retry i wrote a small c program to test, it can s...