diff options
Diffstat (limited to 'meta/lib/oe/prservice.py')
| -rw-r--r-- | meta/lib/oe/prservice.py | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/meta/lib/oe/prservice.py b/meta/lib/oe/prservice.py index 0054f954cc..32dfc15e88 100644 --- a/meta/lib/oe/prservice.py +++ b/meta/lib/oe/prservice.py | |||
| @@ -1,7 +1,7 @@ | |||
| 1 | 1 | ||
| 2 | def prserv_make_conn(d, check = False): | 2 | def prserv_make_conn(d, check = False): |
| 3 | import prserv.serv | 3 | import prserv.serv |
| 4 | host_params = list([_f for _f in (d.getVar("PRSERV_HOST", True) or '').split(':') if _f]) | 4 | host_params = list([_f for _f in (d.getVar("PRSERV_HOST") or '').split(':') if _f]) |
| 5 | try: | 5 | try: |
| 6 | conn = None | 6 | conn = None |
| 7 | conn = prserv.serv.PRServerConnection(host_params[0], int(host_params[1])) | 7 | conn = prserv.serv.PRServerConnection(host_params[0], int(host_params[1])) |
| @@ -15,11 +15,11 @@ def prserv_make_conn(d, check = False): | |||
| 15 | return conn | 15 | return conn |
| 16 | 16 | ||
| 17 | def prserv_dump_db(d): | 17 | def prserv_dump_db(d): |
| 18 | if not d.getVar('PRSERV_HOST', True): | 18 | if not d.getVar('PRSERV_HOST'): |
| 19 | bb.error("Not using network based PR service") | 19 | bb.error("Not using network based PR service") |
| 20 | return None | 20 | return None |
| 21 | 21 | ||
| 22 | conn = d.getVar("__PRSERV_CONN", True) | 22 | conn = d.getVar("__PRSERV_CONN") |
| 23 | if conn is None: | 23 | if conn is None: |
| 24 | conn = prserv_make_conn(d) | 24 | conn = prserv_make_conn(d) |
| 25 | if conn is None: | 25 | if conn is None: |
| @@ -27,18 +27,18 @@ def prserv_dump_db(d): | |||
| 27 | return None | 27 | return None |
| 28 | 28 | ||
| 29 | #dump db | 29 | #dump db |
| 30 | opt_version = d.getVar('PRSERV_DUMPOPT_VERSION', True) | 30 | opt_version = d.getVar('PRSERV_DUMPOPT_VERSION') |
| 31 | opt_pkgarch = d.getVar('PRSERV_DUMPOPT_PKGARCH', True) | 31 | opt_pkgarch = d.getVar('PRSERV_DUMPOPT_PKGARCH') |
| 32 | opt_checksum = d.getVar('PRSERV_DUMPOPT_CHECKSUM', True) | 32 | opt_checksum = d.getVar('PRSERV_DUMPOPT_CHECKSUM') |
| 33 | opt_col = ("1" == d.getVar('PRSERV_DUMPOPT_COL', True)) | 33 | opt_col = ("1" == d.getVar('PRSERV_DUMPOPT_COL')) |
| 34 | return conn.export(opt_version, opt_pkgarch, opt_checksum, opt_col) | 34 | return conn.export(opt_version, opt_pkgarch, opt_checksum, opt_col) |
| 35 | 35 | ||
| 36 | def prserv_import_db(d, filter_version=None, filter_pkgarch=None, filter_checksum=None): | 36 | def prserv_import_db(d, filter_version=None, filter_pkgarch=None, filter_checksum=None): |
| 37 | if not d.getVar('PRSERV_HOST', True): | 37 | if not d.getVar('PRSERV_HOST'): |
| 38 | bb.error("Not using network based PR service") | 38 | bb.error("Not using network based PR service") |
| 39 | return None | 39 | return None |
| 40 | 40 | ||
| 41 | conn = d.getVar("__PRSERV_CONN", True) | 41 | conn = d.getVar("__PRSERV_CONN") |
| 42 | if conn is None: | 42 | if conn is None: |
| 43 | conn = prserv_make_conn(d) | 43 | conn = prserv_make_conn(d) |
| 44 | if conn is None: | 44 | if conn is None: |
| @@ -58,7 +58,7 @@ def prserv_import_db(d, filter_version=None, filter_pkgarch=None, filter_checksu | |||
| 58 | (filter_checksum and filter_checksum != checksum): | 58 | (filter_checksum and filter_checksum != checksum): |
| 59 | continue | 59 | continue |
| 60 | try: | 60 | try: |
| 61 | value = int(d.getVar(remain + '$' + version + '$' + pkgarch + '$' + checksum, True)) | 61 | value = int(d.getVar(remain + '$' + version + '$' + pkgarch + '$' + checksum)) |
| 62 | except BaseException as exc: | 62 | except BaseException as exc: |
| 63 | bb.debug("Not valid value of %s:%s" % (v,str(exc))) | 63 | bb.debug("Not valid value of %s:%s" % (v,str(exc))) |
| 64 | continue | 64 | continue |
| @@ -72,8 +72,8 @@ def prserv_import_db(d, filter_version=None, filter_pkgarch=None, filter_checksu | |||
| 72 | def prserv_export_tofile(d, metainfo, datainfo, lockdown, nomax=False): | 72 | def prserv_export_tofile(d, metainfo, datainfo, lockdown, nomax=False): |
| 73 | import bb.utils | 73 | import bb.utils |
| 74 | #initilize the output file | 74 | #initilize the output file |
| 75 | bb.utils.mkdirhier(d.getVar('PRSERV_DUMPDIR', True)) | 75 | bb.utils.mkdirhier(d.getVar('PRSERV_DUMPDIR')) |
| 76 | df = d.getVar('PRSERV_DUMPFILE', True) | 76 | df = d.getVar('PRSERV_DUMPFILE') |
| 77 | #write data | 77 | #write data |
| 78 | lf = bb.utils.lockfile("%s.lock" % df) | 78 | lf = bb.utils.lockfile("%s.lock" % df) |
| 79 | f = open(df, "a") | 79 | f = open(df, "a") |
| @@ -114,7 +114,7 @@ def prserv_export_tofile(d, metainfo, datainfo, lockdown, nomax=False): | |||
| 114 | bb.utils.unlockfile(lf) | 114 | bb.utils.unlockfile(lf) |
| 115 | 115 | ||
| 116 | def prserv_check_avail(d): | 116 | def prserv_check_avail(d): |
| 117 | host_params = list([_f for _f in (d.getVar("PRSERV_HOST", True) or '').split(':') if _f]) | 117 | host_params = list([_f for _f in (d.getVar("PRSERV_HOST") or '').split(':') if _f]) |
| 118 | try: | 118 | try: |
| 119 | if len(host_params) != 2: | 119 | if len(host_params) != 2: |
| 120 | raise TypeError | 120 | raise TypeError |
