Changeset 815cd26 for fedd


Ignore:
Timestamp:
May 25, 2012 10:24:56 AM (7 years ago)
Author:
Ted Faber <faber@…>
Branches:
compt_changes, master
Children:
17c2f7b
Parents:
5ae9d94
Message:

Add timeout and extra debug logging.

Location:
fedd/federation
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • fedd/federation/emulab_access.py

    raada25c r815cd26  
    656656            self.log.debug("Retrieving %s" % s)
    657657            try:
    658                 get_url(s, certfile, softdir)
     658                get_url(s, certfile, softdir, log=self.log)
    659659            except:
    660660                t, v, st = sys.exc_info()
     
    700700                    self.log.debug("Retrieving %s from %s" % \
    701701                            (a['attribute'], a['value']))
    702                     get_url(a['value'], certfile, tmpdir)
     702                    get_url(a['value'], certfile, tmpdir, log=self.log)
    703703                except:
    704704                    t, v, st = sys.exc_info()
  • fedd/federation/util.py

    r6bedbdba r815cd26  
    204204    d.close()
    205205
    206 def get_url(url, cf, destdir, fn=None, max_retries=5):
     206def get_url(url, cf, destdir, fn=None, max_retries=5, log=None):
    207207    """
    208208    Get data from a federated data store.  This presents the client cert/fedid
     
    217217    while not ok and retries < 5:
    218218        try:
     219            if log:
     220                log.debug('Creating HTTPSConnection')
    219221            conn = httplib.HTTPSConnection(po.hostname, port=po.port,
    220                     cert_file=cf, key_file=cf)
     222                    cert_file=cf, key_file=cf, timeout=30)
    221223            conn.putrequest('GET', po.path)
    222224            conn.endheaders()
     225            if log:
     226                log.debug('Connecting')
    223227            response = conn.getresponse()
     228            if log:
     229                log.debug('Connected')
    224230
    225231            lf = open("%s/%s" % (destdir, fn), "w")
     232            if log:
     233                log.debug('initial read')
    226234            buf = response.read(4096)
    227235            while buf:
    228236                lf.write(buf)
     237                if log:
     238                    log.debug('loop read')
    229239                buf = response.read(4096)
    230240            lf.close()
Note: See TracChangeset for help on using the changeset viewer.