diff options
| -rw-r--r-- | bitbake/contrib/vim/syntax/bitbake.vim | 120 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/__init__.py | 175 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/bk.py | 40 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/cvs.py | 214 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/git.py | 165 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/local.py | 61 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/svn.py | 189 | ||||
| -rw-r--r-- | bitbake/lib/bb/fetch/wget.py | 167 |
8 files changed, 1131 insertions, 0 deletions
diff --git a/bitbake/contrib/vim/syntax/bitbake.vim b/bitbake/contrib/vim/syntax/bitbake.vim new file mode 100644 index 0000000000..5d2bc633e1 --- /dev/null +++ b/bitbake/contrib/vim/syntax/bitbake.vim | |||
| @@ -0,0 +1,120 @@ | |||
| 1 | " Vim syntax file | ||
| 2 | " | ||
| 3 | " Copyright (C) 2004 Chris Larson <kergoth@handhelds.org> | ||
| 4 | " This file is licensed under the MIT license, see COPYING.MIT in | ||
| 5 | " this source distribution for the terms. | ||
| 6 | " | ||
| 7 | " Language: BitBake | ||
| 8 | " Maintainer: Chris Larson <kergoth@handhelds.org> | ||
| 9 | " Filenames: *.bb, *.bbclass | ||
| 10 | |||
| 11 | if version < 600 | ||
| 12 | syntax clear | ||
| 13 | elseif exists("b:current_syntax") | ||
| 14 | finish | ||
| 15 | endif | ||
| 16 | |||
| 17 | syn case match | ||
| 18 | |||
| 19 | |||
| 20 | " Catch incorrect syntax (only matches if nothing else does) | ||
| 21 | " | ||
| 22 | syn match bbUnmatched "." | ||
| 23 | |||
| 24 | |||
| 25 | " Other | ||
| 26 | |||
| 27 | syn match bbComment "^#.*$" display contains=bbTodo | ||
| 28 | syn keyword bbTodo TODO FIXME XXX contained | ||
| 29 | syn match bbDelimiter "[(){}=]" contained | ||
| 30 | syn match bbQuote /['"]/ contained | ||
| 31 | syn match bbArrayBrackets "[\[\]]" contained | ||
| 32 | |||
| 33 | |||
| 34 | " BitBake strings | ||
| 35 | |||
| 36 | syn match bbContinue "\\$" | ||
| 37 | syn region bbString matchgroup=bbQuote start=/"/ skip=/\\$/ excludenl end=/"/ contained keepend contains=bbTodo,bbContinue,bbVarDeref | ||
| 38 | syn region bbString matchgroup=bbQuote start=/'/ skip=/\\$/ excludenl end=/'/ contained keepend contains=bbTodo,bbContinue,bbVarDeref | ||
| 39 | |||
| 40 | |||
| 41 | " BitBake variable metadata | ||
| 42 | |||
| 43 | syn keyword bbExportFlag export contained nextgroup=bbIdentifier skipwhite | ||
| 44 | syn match bbVarDeref "${[a-zA-Z0-9\-_\.]\+}" contained | ||
| 45 | syn match bbVarDef "^\(export\s*\)\?\([a-zA-Z0-9\-_\.]\+\(_[${}a-zA-Z0-9\-_\.]\+\)\?\)\s*\(\(:=\)\|\(+=\)\|\(=+\)\|\(?=\)\|=\)\@=" contains=bbExportFlag,bbIdentifier,bbVarDeref nextgroup=bbVarEq | ||
| 46 | |||
| 47 | syn match bbIdentifier "[a-zA-Z0-9\-_\.]\+" display contained | ||
| 48 | "syn keyword bbVarEq = display contained nextgroup=bbVarValue | ||
| 49 | syn match bbVarEq "\(:=\)\|\(+=\)\|\(=+\)\|\(?=\)\|=" contained nextgroup=bbVarValue | ||
| 50 | syn match bbVarValue ".*$" contained contains=bbString,bbVarDeref | ||
| 51 | |||
| 52 | |||
| 53 | " BitBake variable metadata flags | ||
| 54 | syn match bbVarFlagDef "^\([a-zA-Z0-9\-_\.]\+\)\(\[[a-zA-Z0-9\-_\.]\+\]\)\@=" contains=bbIdentifier nextgroup=bbVarFlagFlag | ||
| 55 | syn region bbVarFlagFlag matchgroup=bbArrayBrackets start="\[" end="\]\s*\(=\)\@=" keepend excludenl contained contains=bbIdentifier nextgroup=bbVarEq | ||
| 56 | "syn match bbVarFlagFlag "\[\([a-zA-Z0-9\-_\.]\+\)\]\s*\(=\)\@=" contains=bbIdentifier nextgroup=bbVarEq | ||
| 57 | |||
| 58 | |||
| 59 | " Functions! | ||
| 60 | syn match bbFunction "\h\w*" display contained | ||
| 61 | |||
| 62 | |||
| 63 | " BitBake python metadata | ||
| 64 | syn include @python syntax/python.vim | ||
| 65 | if exists("b:current_syntax") | ||
| 66 | unlet b:current_syntax | ||
| 67 | endif | ||
| 68 | |||
| 69 | syn keyword bbPythonFlag python contained nextgroup=bbFunction | ||
| 70 | syn match bbPythonFuncDef "^\(python\s\+\)\(\w\+\)\?\(\s*()\s*\)\({\)\@=" contains=bbPythonFlag,bbFunction,bbDelimiter nextgroup=bbPythonFuncRegion skipwhite | ||
| 71 | syn region bbPythonFuncRegion matchgroup=bbDelimiter start="{\s*$" end="^}\s*$" keepend contained contains=@python | ||
| 72 | "hi def link bbPythonFuncRegion Comment | ||
| 73 | |||
| 74 | |||
| 75 | " BitBake shell metadata | ||
| 76 | syn include @shell syntax/sh.vim | ||
| 77 | if exists("b:current_syntax") | ||
| 78 | unlet b:current_syntax | ||
| 79 | endif | ||
| 80 | |||
| 81 | syn keyword bbFakerootFlag fakeroot contained nextgroup=bbFunction | ||
| 82 | syn match bbShellFuncDef "^\(fakeroot\s*\)\?\(\w\+\)\(python\)\@<!\(\s*()\s*\)\({\)\@=" contains=bbFakerootFlag,bbFunction,bbDelimiter nextgroup=bbShellFuncRegion skipwhite | ||
| 83 | syn region bbShellFuncRegion matchgroup=bbDelimiter start="{\s*$" end="^}\s*$" keepend contained contains=@shell | ||
| 84 | "hi def link bbShellFuncRegion Comment | ||
| 85 | |||
| 86 | |||
| 87 | " BitBake 'def'd python functions | ||
| 88 | syn keyword bbDef def contained | ||
| 89 | syn region bbDefRegion start='^def\s\+\w\+\s*([^)]*)\s*:\s*$' end='^\(\s\|$\)\@!' contains=@python | ||
| 90 | |||
| 91 | |||
| 92 | " BitBake statements | ||
| 93 | syn keyword bbStatement include inherit addtask addhandler EXPORT_FUNCTIONS display contained | ||
| 94 | syn match bbStatementLine "^\(include\|inherit\|addtask\|addhandler\|EXPORT_FUNCTIONS\)\s\+" contains=bbStatement nextgroup=bbStatementRest | ||
| 95 | syn match bbStatementRest ".*$" contained contains=bbString,bbVarDeref | ||
| 96 | |||
| 97 | " Highlight | ||
| 98 | " | ||
| 99 | hi def link bbArrayBrackets Statement | ||
| 100 | hi def link bbUnmatched Error | ||
| 101 | hi def link bbVarDeref String | ||
| 102 | hi def link bbContinue Special | ||
| 103 | hi def link bbDef Statement | ||
| 104 | hi def link bbPythonFlag Type | ||
| 105 | hi def link bbExportFlag Type | ||
| 106 | hi def link bbFakerootFlag Type | ||
| 107 | hi def link bbStatement Statement | ||
| 108 | hi def link bbString String | ||
| 109 | hi def link bbTodo Todo | ||
| 110 | hi def link bbComment Comment | ||
| 111 | hi def link bbOperator Operator | ||
| 112 | hi def link bbError Error | ||
| 113 | hi def link bbFunction Function | ||
| 114 | hi def link bbDelimiter Delimiter | ||
| 115 | hi def link bbIdentifier Identifier | ||
| 116 | hi def link bbVarEq Operator | ||
| 117 | hi def link bbQuote String | ||
| 118 | hi def link bbVarValue String | ||
| 119 | |||
| 120 | let b:current_syntax = "bb" | ||
diff --git a/bitbake/lib/bb/fetch/__init__.py b/bitbake/lib/bb/fetch/__init__.py new file mode 100644 index 0000000000..da5b10c4b6 --- /dev/null +++ b/bitbake/lib/bb/fetch/__init__.py | |||
| @@ -0,0 +1,175 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' implementations | ||
| 6 | |||
| 7 | Classes for obtaining upstream sources for the | ||
| 8 | BitBake build tools. | ||
| 9 | |||
| 10 | Copyright (C) 2003, 2004 Chris Larson | ||
| 11 | |||
| 12 | This program is free software; you can redistribute it and/or modify it under | ||
| 13 | the terms of the GNU General Public License as published by the Free Software | ||
| 14 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 15 | version. | ||
| 16 | |||
| 17 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 18 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 19 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 20 | |||
| 21 | You should have received a copy of the GNU General Public License along with | ||
| 22 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 23 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 24 | |||
| 25 | Based on functions from the base bb module, Copyright 2003 Holger Schurig | ||
| 26 | """ | ||
| 27 | |||
| 28 | import os, re | ||
| 29 | import bb | ||
| 30 | from bb import data | ||
| 31 | |||
| 32 | class FetchError(Exception): | ||
| 33 | """Exception raised when a download fails""" | ||
| 34 | |||
| 35 | class NoMethodError(Exception): | ||
| 36 | """Exception raised when there is no method to obtain a supplied url or set of urls""" | ||
| 37 | |||
| 38 | class MissingParameterError(Exception): | ||
| 39 | """Exception raised when a fetch method is missing a critical parameter in the url""" | ||
| 40 | |||
| 41 | class MD5SumError(Exception): | ||
| 42 | """Exception raised when a MD5SUM of a file does not match the expected one""" | ||
| 43 | |||
| 44 | def uri_replace(uri, uri_find, uri_replace, d): | ||
| 45 | # bb.note("uri_replace: operating on %s" % uri) | ||
| 46 | if not uri or not uri_find or not uri_replace: | ||
| 47 | bb.debug(1, "uri_replace: passed an undefined value, not replacing") | ||
| 48 | uri_decoded = list(bb.decodeurl(uri)) | ||
| 49 | uri_find_decoded = list(bb.decodeurl(uri_find)) | ||
| 50 | uri_replace_decoded = list(bb.decodeurl(uri_replace)) | ||
| 51 | result_decoded = ['','','','','',{}] | ||
| 52 | for i in uri_find_decoded: | ||
| 53 | loc = uri_find_decoded.index(i) | ||
| 54 | result_decoded[loc] = uri_decoded[loc] | ||
| 55 | import types | ||
| 56 | if type(i) == types.StringType: | ||
| 57 | import re | ||
| 58 | if (re.match(i, uri_decoded[loc])): | ||
| 59 | result_decoded[loc] = re.sub(i, uri_replace_decoded[loc], uri_decoded[loc]) | ||
| 60 | if uri_find_decoded.index(i) == 2: | ||
| 61 | if d: | ||
| 62 | localfn = bb.fetch.localpath(uri, d) | ||
| 63 | if localfn: | ||
| 64 | result_decoded[loc] = os.path.dirname(result_decoded[loc]) + "/" + os.path.basename(bb.fetch.localpath(uri, d)) | ||
| 65 | # bb.note("uri_replace: matching %s against %s and replacing with %s" % (i, uri_decoded[loc], uri_replace_decoded[loc])) | ||
| 66 | else: | ||
| 67 | # bb.note("uri_replace: no match") | ||
| 68 | return uri | ||
| 69 | # else: | ||
| 70 | # for j in i.keys(): | ||
| 71 | # FIXME: apply replacements against options | ||
| 72 | return bb.encodeurl(result_decoded) | ||
| 73 | |||
| 74 | methods = [] | ||
| 75 | |||
| 76 | def init(urls = [], d = None): | ||
| 77 | if d == None: | ||
| 78 | bb.debug(2,"BUG init called with None as data object!!!") | ||
| 79 | return | ||
| 80 | |||
| 81 | for m in methods: | ||
| 82 | m.urls = [] | ||
| 83 | |||
| 84 | for u in urls: | ||
| 85 | for m in methods: | ||
| 86 | m.data = d | ||
| 87 | if m.supports(u, d): | ||
| 88 | m.urls.append(u) | ||
| 89 | |||
| 90 | def go(d): | ||
| 91 | """Fetch all urls""" | ||
| 92 | for m in methods: | ||
| 93 | if m.urls: | ||
| 94 | m.go(d) | ||
| 95 | |||
| 96 | def localpaths(d): | ||
| 97 | """Return a list of the local filenames, assuming successful fetch""" | ||
| 98 | local = [] | ||
| 99 | for m in methods: | ||
| 100 | for u in m.urls: | ||
| 101 | local.append(m.localpath(u, d)) | ||
| 102 | return local | ||
| 103 | |||
| 104 | def localpath(url, d): | ||
| 105 | for m in methods: | ||
| 106 | if m.supports(url, d): | ||
| 107 | return m.localpath(url, d) | ||
| 108 | return url | ||
| 109 | |||
| 110 | class Fetch(object): | ||
| 111 | """Base class for 'fetch'ing data""" | ||
| 112 | |||
| 113 | def __init__(self, urls = []): | ||
| 114 | self.urls = [] | ||
| 115 | for url in urls: | ||
| 116 | if self.supports(bb.decodeurl(url), d) is 1: | ||
| 117 | self.urls.append(url) | ||
| 118 | |||
| 119 | def supports(url, d): | ||
| 120 | """Check to see if this fetch class supports a given url. | ||
| 121 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 122 | """ | ||
| 123 | return 0 | ||
| 124 | supports = staticmethod(supports) | ||
| 125 | |||
| 126 | def localpath(url, d): | ||
| 127 | """Return the local filename of a given url assuming a successful fetch. | ||
| 128 | """ | ||
| 129 | return url | ||
| 130 | localpath = staticmethod(localpath) | ||
| 131 | |||
| 132 | def setUrls(self, urls): | ||
| 133 | self.__urls = urls | ||
| 134 | |||
| 135 | def getUrls(self): | ||
| 136 | return self.__urls | ||
| 137 | |||
| 138 | urls = property(getUrls, setUrls, None, "Urls property") | ||
| 139 | |||
| 140 | def setData(self, data): | ||
| 141 | self.__data = data | ||
| 142 | |||
| 143 | def getData(self): | ||
| 144 | return self.__data | ||
| 145 | |||
| 146 | data = property(getData, setData, None, "Data property") | ||
| 147 | |||
| 148 | def go(self, urls = []): | ||
| 149 | """Fetch urls""" | ||
| 150 | raise NoMethodError("Missing implementation for url") | ||
| 151 | |||
| 152 | def getSRCDate(d): | ||
| 153 | """ | ||
| 154 | Return the SRC Date for the component | ||
| 155 | |||
| 156 | d the bb.data module | ||
| 157 | """ | ||
| 158 | return data.getVar("SRCDATE", d, 1) or data.getVar("CVSDATE", d, 1) or data.getVar("DATE", d, 1 ) | ||
| 159 | getSRCDate = staticmethod(getSRCDate) | ||
| 160 | |||
| 161 | #if __name__ == "__main__": | ||
| 162 | |||
| 163 | import bk | ||
| 164 | import cvs | ||
| 165 | import git | ||
| 166 | import local | ||
| 167 | import svn | ||
| 168 | import wget | ||
| 169 | |||
| 170 | methods.append(bk.Bk()) | ||
| 171 | methods.append(cvs.Cvs()) | ||
| 172 | methods.append(git.Git()) | ||
| 173 | methods.append(local.Local()) | ||
| 174 | methods.append(svn.Svn()) | ||
| 175 | methods.append(wget.Wget()) | ||
diff --git a/bitbake/lib/bb/fetch/bk.py b/bitbake/lib/bb/fetch/bk.py new file mode 100644 index 0000000000..6bd6c018fb --- /dev/null +++ b/bitbake/lib/bb/fetch/bk.py | |||
| @@ -0,0 +1,40 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' implementations | ||
| 6 | |||
| 7 | Classes for obtaining upstream sources for the | ||
| 8 | BitBake build tools. | ||
| 9 | |||
| 10 | Copyright (C) 2003, 2004 Chris Larson | ||
| 11 | |||
| 12 | This program is free software; you can redistribute it and/or modify it under | ||
| 13 | the terms of the GNU General Public License as published by the Free Software | ||
| 14 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 15 | version. | ||
| 16 | |||
| 17 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 18 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 19 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 20 | |||
| 21 | You should have received a copy of the GNU General Public License along with | ||
| 22 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 23 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 24 | |||
| 25 | Based on functions from the base bb module, Copyright 2003 Holger Schurig | ||
| 26 | """ | ||
| 27 | |||
| 28 | import os, re | ||
| 29 | import bb | ||
| 30 | from bb import data | ||
| 31 | from bb.fetch import Fetch | ||
| 32 | |||
| 33 | class Bk(Fetch): | ||
| 34 | def supports(url, d): | ||
| 35 | """Check to see if a given url can be fetched via bitkeeper. | ||
| 36 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 37 | """ | ||
| 38 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 39 | return type in ['bk'] | ||
| 40 | supports = staticmethod(supports) | ||
diff --git a/bitbake/lib/bb/fetch/cvs.py b/bitbake/lib/bb/fetch/cvs.py new file mode 100644 index 0000000000..461a2f50f9 --- /dev/null +++ b/bitbake/lib/bb/fetch/cvs.py | |||
| @@ -0,0 +1,214 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' implementations | ||
| 6 | |||
| 7 | Classes for obtaining upstream sources for the | ||
| 8 | BitBake build tools. | ||
| 9 | |||
| 10 | Copyright (C) 2003, 2004 Chris Larson | ||
| 11 | |||
| 12 | This program is free software; you can redistribute it and/or modify it under | ||
| 13 | the terms of the GNU General Public License as published by the Free Software | ||
| 14 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 15 | version. | ||
| 16 | |||
| 17 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 18 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 19 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 20 | |||
| 21 | You should have received a copy of the GNU General Public License along with | ||
| 22 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 23 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 24 | |||
| 25 | Based on functions from the base bb module, Copyright 2003 Holger Schurig | ||
| 26 | """ | ||
| 27 | |||
| 28 | import os, re | ||
| 29 | import bb | ||
| 30 | from bb import data | ||
| 31 | from bb.fetch import Fetch | ||
| 32 | from bb.fetch import FetchError | ||
| 33 | from bb.fetch import MissingParameterError | ||
| 34 | |||
| 35 | class Cvs(Fetch): | ||
| 36 | """Class to fetch a module or modules from cvs repositories""" | ||
| 37 | def supports(url, d): | ||
| 38 | """Check to see if a given url can be fetched with cvs. | ||
| 39 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 40 | """ | ||
| 41 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 42 | return type in ['cvs', 'pserver'] | ||
| 43 | supports = staticmethod(supports) | ||
| 44 | |||
| 45 | def localpath(url, d): | ||
| 46 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 47 | if "localpath" in parm: | ||
| 48 | # if user overrides local path, use it. | ||
| 49 | return parm["localpath"] | ||
| 50 | |||
| 51 | if not "module" in parm: | ||
| 52 | raise MissingParameterError("cvs method needs a 'module' parameter") | ||
| 53 | else: | ||
| 54 | module = parm["module"] | ||
| 55 | if 'tag' in parm: | ||
| 56 | tag = parm['tag'] | ||
| 57 | else: | ||
| 58 | tag = "" | ||
| 59 | if 'date' in parm: | ||
| 60 | date = parm['date'] | ||
| 61 | else: | ||
| 62 | if not tag: | ||
| 63 | date = Fetch.getSRCDate(d) | ||
| 64 | else: | ||
| 65 | date = "" | ||
| 66 | |||
| 67 | return os.path.join(data.getVar("DL_DIR", d, 1),data.expand('%s_%s_%s_%s.tar.gz' % ( module.replace('/', '.'), host, tag, date), d)) | ||
| 68 | localpath = staticmethod(localpath) | ||
| 69 | |||
| 70 | def go(self, d, urls = []): | ||
| 71 | """Fetch urls""" | ||
| 72 | if not urls: | ||
| 73 | urls = self.urls | ||
| 74 | |||
| 75 | localdata = data.createCopy(d) | ||
| 76 | data.setVar('OVERRIDES', "cvs:%s" % data.getVar('OVERRIDES', localdata), localdata) | ||
| 77 | data.update_data(localdata) | ||
| 78 | |||
| 79 | for loc in urls: | ||
| 80 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(loc, localdata)) | ||
| 81 | if not "module" in parm: | ||
| 82 | raise MissingParameterError("cvs method needs a 'module' parameter") | ||
| 83 | else: | ||
| 84 | module = parm["module"] | ||
| 85 | |||
| 86 | dlfile = self.localpath(loc, localdata) | ||
| 87 | dldir = data.getVar('DL_DIR', localdata, 1) | ||
| 88 | # if local path contains the cvs | ||
| 89 | # module, consider the dir above it to be the | ||
| 90 | # download directory | ||
| 91 | # pos = dlfile.find(module) | ||
| 92 | # if pos: | ||
| 93 | # dldir = dlfile[:pos] | ||
| 94 | # else: | ||
| 95 | # dldir = os.path.dirname(dlfile) | ||
| 96 | |||
| 97 | # setup cvs options | ||
| 98 | options = [] | ||
| 99 | if 'tag' in parm: | ||
| 100 | tag = parm['tag'] | ||
| 101 | else: | ||
| 102 | tag = "" | ||
| 103 | |||
| 104 | if 'date' in parm: | ||
| 105 | date = parm['date'] | ||
| 106 | else: | ||
| 107 | if not tag: | ||
| 108 | date = Fetch.getSRCDate(d) | ||
| 109 | else: | ||
| 110 | date = "" | ||
| 111 | |||
| 112 | if "method" in parm: | ||
| 113 | method = parm["method"] | ||
| 114 | else: | ||
| 115 | method = "pserver" | ||
| 116 | |||
| 117 | if "localdir" in parm: | ||
| 118 | localdir = parm["localdir"] | ||
| 119 | else: | ||
| 120 | localdir = module | ||
| 121 | |||
| 122 | cvs_rsh = None | ||
| 123 | if method == "ext": | ||
| 124 | if "rsh" in parm: | ||
| 125 | cvs_rsh = parm["rsh"] | ||
| 126 | |||
| 127 | tarfn = data.expand('%s_%s_%s_%s.tar.gz' % (module.replace('/', '.'), host, tag, date), localdata) | ||
| 128 | data.setVar('TARFILES', dlfile, localdata) | ||
| 129 | data.setVar('TARFN', tarfn, localdata) | ||
| 130 | |||
| 131 | dl = os.path.join(dldir, tarfn) | ||
| 132 | if os.access(dl, os.R_OK): | ||
| 133 | bb.debug(1, "%s already exists, skipping cvs checkout." % tarfn) | ||
| 134 | continue | ||
| 135 | |||
| 136 | pn = data.getVar('PN', d, 1) | ||
| 137 | cvs_tarball_stash = None | ||
| 138 | if pn: | ||
| 139 | cvs_tarball_stash = data.getVar('CVS_TARBALL_STASH_%s' % pn, d, 1) | ||
| 140 | if cvs_tarball_stash == None: | ||
| 141 | cvs_tarball_stash = data.getVar('CVS_TARBALL_STASH', d, 1) | ||
| 142 | if cvs_tarball_stash: | ||
| 143 | fetchcmd = data.getVar("FETCHCOMMAND_wget", d, 1) | ||
| 144 | uri = cvs_tarball_stash + tarfn | ||
| 145 | bb.note("fetch " + uri) | ||
| 146 | fetchcmd = fetchcmd.replace("${URI}", uri) | ||
| 147 | ret = os.system(fetchcmd) | ||
| 148 | if ret == 0: | ||
| 149 | bb.note("Fetched %s from tarball stash, skipping checkout" % tarfn) | ||
| 150 | continue | ||
| 151 | |||
| 152 | if date: | ||
| 153 | options.append("-D %s" % date) | ||
| 154 | if tag: | ||
| 155 | options.append("-r %s" % tag) | ||
| 156 | |||
| 157 | olddir = os.path.abspath(os.getcwd()) | ||
| 158 | os.chdir(data.expand(dldir, localdata)) | ||
| 159 | |||
| 160 | # setup cvsroot | ||
| 161 | if method == "dir": | ||
| 162 | cvsroot = path | ||
| 163 | else: | ||
| 164 | cvsroot = ":" + method + ":" + user | ||
| 165 | if pswd: | ||
| 166 | cvsroot += ":" + pswd | ||
| 167 | cvsroot += "@" + host + ":" + path | ||
| 168 | |||
| 169 | data.setVar('CVSROOT', cvsroot, localdata) | ||
| 170 | data.setVar('CVSCOOPTS', " ".join(options), localdata) | ||
| 171 | data.setVar('CVSMODULE', module, localdata) | ||
| 172 | cvscmd = data.getVar('FETCHCOMMAND', localdata, 1) | ||
| 173 | cvsupdatecmd = data.getVar('UPDATECOMMAND', localdata, 1) | ||
| 174 | |||
| 175 | if cvs_rsh: | ||
| 176 | cvscmd = "CVS_RSH=\"%s\" %s" % (cvs_rsh, cvscmd) | ||
| 177 | cvsupdatecmd = "CVS_RSH=\"%s\" %s" % (cvs_rsh, cvsupdatecmd) | ||
| 178 | |||
| 179 | # create module directory | ||
| 180 | bb.debug(2, "Fetch: checking for module directory") | ||
| 181 | pkg=data.expand('${PN}', d) | ||
| 182 | pkgdir=os.path.join(data.expand('${CVSDIR}', localdata), pkg) | ||
| 183 | moddir=os.path.join(pkgdir,localdir) | ||
| 184 | if os.access(os.path.join(moddir,'CVS'), os.R_OK): | ||
| 185 | bb.note("Update " + loc) | ||
| 186 | # update sources there | ||
| 187 | os.chdir(moddir) | ||
| 188 | myret = os.system(cvsupdatecmd) | ||
| 189 | else: | ||
| 190 | bb.note("Fetch " + loc) | ||
| 191 | # check out sources there | ||
| 192 | bb.mkdirhier(pkgdir) | ||
| 193 | os.chdir(pkgdir) | ||
| 194 | bb.debug(1, "Running %s" % cvscmd) | ||
| 195 | myret = os.system(cvscmd) | ||
| 196 | |||
| 197 | if myret != 0: | ||
| 198 | try: | ||
| 199 | os.rmdir(moddir) | ||
| 200 | except OSError: | ||
| 201 | pass | ||
| 202 | raise FetchError(module) | ||
| 203 | |||
| 204 | os.chdir(moddir) | ||
| 205 | os.chdir('..') | ||
| 206 | # tar them up to a defined filename | ||
| 207 | myret = os.system("tar -czf %s %s" % (os.path.join(dldir,tarfn), os.path.basename(moddir))) | ||
| 208 | if myret != 0: | ||
| 209 | try: | ||
| 210 | os.unlink(tarfn) | ||
| 211 | except OSError: | ||
| 212 | pass | ||
| 213 | os.chdir(olddir) | ||
| 214 | del localdata | ||
diff --git a/bitbake/lib/bb/fetch/git.py b/bitbake/lib/bb/fetch/git.py new file mode 100644 index 0000000000..296b926392 --- /dev/null +++ b/bitbake/lib/bb/fetch/git.py | |||
| @@ -0,0 +1,165 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' git implementation | ||
| 6 | |||
| 7 | Copyright (C) 2005 Richard Purdie | ||
| 8 | |||
| 9 | This program is free software; you can redistribute it and/or modify it under | ||
| 10 | the terms of the GNU General Public License as published by the Free Software | ||
| 11 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 12 | version. | ||
| 13 | |||
| 14 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 15 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 16 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 17 | |||
| 18 | You should have received a copy of the GNU General Public License along with | ||
| 19 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 20 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 21 | """ | ||
| 22 | |||
| 23 | import os, re | ||
| 24 | import bb | ||
| 25 | from bb import data | ||
| 26 | from bb.fetch import Fetch | ||
| 27 | from bb.fetch import FetchError | ||
| 28 | |||
| 29 | def prunedir(topdir): | ||
| 30 | # Delete everything reachable from the directory named in 'topdir'. | ||
| 31 | # CAUTION: This is dangerous! | ||
| 32 | for root, dirs, files in os.walk(topdir, topdown=False): | ||
| 33 | for name in files: | ||
| 34 | os.remove(os.path.join(root, name)) | ||
| 35 | for name in dirs: | ||
| 36 | os.rmdir(os.path.join(root, name)) | ||
| 37 | |||
| 38 | def rungitcmd(cmd,d): | ||
| 39 | |||
| 40 | bb.debug(1, "Running %s" % cmd) | ||
| 41 | |||
| 42 | # Need to export PATH as git is likely to be in metadata paths | ||
| 43 | # rather than host provided | ||
| 44 | pathcmd = 'export PATH=%s; %s' % (data.expand('${PATH}', d), cmd) | ||
| 45 | |||
| 46 | myret = os.system(pathcmd) | ||
| 47 | |||
| 48 | if myret != 0: | ||
| 49 | raise FetchError("Git: %s failed" % pathcmd) | ||
| 50 | |||
| 51 | def gettag(parm): | ||
| 52 | if 'tag' in parm: | ||
| 53 | tag = parm['tag'] | ||
| 54 | else: | ||
| 55 | tag = "" | ||
| 56 | if not tag: | ||
| 57 | tag = "master" | ||
| 58 | |||
| 59 | return tag | ||
| 60 | |||
| 61 | class Git(Fetch): | ||
| 62 | """Class to fetch a module or modules from git repositories""" | ||
| 63 | def supports(url, d): | ||
| 64 | """Check to see if a given url can be fetched with cvs. | ||
| 65 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 66 | """ | ||
| 67 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 68 | return type in ['git'] | ||
| 69 | supports = staticmethod(supports) | ||
| 70 | |||
| 71 | def localpath(url, d): | ||
| 72 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 73 | |||
| 74 | #if user sets localpath for file, use it instead. | ||
| 75 | if "localpath" in parm: | ||
| 76 | return parm["localpath"] | ||
| 77 | |||
| 78 | tag = gettag(parm) | ||
| 79 | |||
| 80 | localname = data.expand('git_%s%s_%s.tar.gz' % (host, path.replace('/', '.'), tag), d) | ||
| 81 | |||
| 82 | return os.path.join(data.getVar("DL_DIR", d, 1),data.expand('%s' % (localname), d)) | ||
| 83 | |||
| 84 | localpath = staticmethod(localpath) | ||
| 85 | |||
| 86 | def go(self, d, urls = []): | ||
| 87 | """Fetch urls""" | ||
| 88 | if not urls: | ||
| 89 | urls = self.urls | ||
| 90 | |||
| 91 | for loc in urls: | ||
| 92 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(loc, d)) | ||
| 93 | |||
| 94 | tag = gettag(parm) | ||
| 95 | |||
| 96 | gitsrcname = '%s%s' % (host, path.replace('/', '.')) | ||
| 97 | |||
| 98 | repofile = os.path.join(data.getVar("DL_DIR", d, 1), 'git_%s.tar.gz' % (gitsrcname)) | ||
| 99 | repodir = os.path.join(data.expand('${GITDIR}', d), gitsrcname) | ||
| 100 | |||
| 101 | coname = '%s' % (tag) | ||
| 102 | codir = os.path.join(repodir, coname) | ||
| 103 | |||
| 104 | cofile = self.localpath(loc, d) | ||
| 105 | |||
| 106 | # Always update to current if tag=="master" | ||
| 107 | #if os.access(cofile, os.R_OK) and (tag != "master"): | ||
| 108 | if os.access(cofile, os.R_OK): | ||
| 109 | bb.debug(1, "%s already exists, skipping git checkout." % cofile) | ||
| 110 | continue | ||
| 111 | |||
| 112 | # Still Need to add GIT_TARBALL_STASH Support... | ||
| 113 | # pn = data.getVar('PN', d, 1) | ||
| 114 | # cvs_tarball_stash = None | ||
| 115 | # if pn: | ||
| 116 | # cvs_tarball_stash = data.getVar('CVS_TARBALL_STASH_%s' % pn, d, 1) | ||
| 117 | # if cvs_tarball_stash == None: | ||
| 118 | # cvs_tarball_stash = data.getVar('CVS_TARBALL_STASH', d, 1) | ||
| 119 | # if cvs_tarball_stash: | ||
| 120 | # fetchcmd = data.getVar("FETCHCOMMAND_wget", d, 1) | ||
| 121 | # uri = cvs_tarball_stash + tarfn | ||
| 122 | # bb.note("fetch " + uri) | ||
| 123 | # fetchcmd = fetchcmd.replace("${URI}", uri) | ||
| 124 | # ret = os.system(fetchcmd) | ||
| 125 | # if ret == 0: | ||
| 126 | # bb.note("Fetched %s from tarball stash, skipping checkout" % tarfn) | ||
| 127 | # continue | ||
| 128 | |||
| 129 | #if os.path.exists(repodir): | ||
| 130 | #prunedir(repodir) | ||
| 131 | |||
| 132 | bb.mkdirhier(repodir) | ||
| 133 | os.chdir(repodir) | ||
| 134 | |||
| 135 | #print("Changing to %s" % repodir) | ||
| 136 | |||
| 137 | if os.access(repofile, os.R_OK): | ||
| 138 | rungitcmd("tar -xzf %s" % (repofile),d) | ||
| 139 | else: | ||
| 140 | rungitcmd("git clone rsync://%s%s %s" % (host, path, repodir),d) | ||
| 141 | |||
| 142 | rungitcmd("rsync -a --verbose --stats --progress rsync://%s%s/ %s" % (host, path, os.path.join(repodir, ".git", "")),d) | ||
| 143 | |||
| 144 | #print("Changing to %s" % repodir) | ||
| 145 | os.chdir(repodir) | ||
| 146 | rungitcmd("git pull rsync://%s%s" % (host, path),d) | ||
| 147 | |||
| 148 | #print("Changing to %s" % repodir) | ||
| 149 | os.chdir(repodir) | ||
| 150 | rungitcmd("tar -czf %s %s" % (repofile, os.path.join(".", ".git", "*") ),d) | ||
| 151 | |||
| 152 | if os.path.exists(codir): | ||
| 153 | prunedir(codir) | ||
| 154 | |||
| 155 | #print("Changing to %s" % repodir) | ||
| 156 | bb.mkdirhier(codir) | ||
| 157 | os.chdir(repodir) | ||
| 158 | rungitcmd("git read-tree %s" % (tag),d) | ||
| 159 | |||
| 160 | rungitcmd("git checkout-index -q -f --prefix=%s -a" % (os.path.join(codir, "git", "")),d) | ||
| 161 | |||
| 162 | #print("Changing to %s" % codir) | ||
| 163 | os.chdir(codir) | ||
| 164 | rungitcmd("tar -czf %s %s" % (cofile, os.path.join(".", "*") ),d) | ||
| 165 | |||
diff --git a/bitbake/lib/bb/fetch/local.py b/bitbake/lib/bb/fetch/local.py new file mode 100644 index 0000000000..51938f823e --- /dev/null +++ b/bitbake/lib/bb/fetch/local.py | |||
| @@ -0,0 +1,61 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' implementations | ||
| 6 | |||
| 7 | Classes for obtaining upstream sources for the | ||
| 8 | BitBake build tools. | ||
| 9 | |||
| 10 | Copyright (C) 2003, 2004 Chris Larson | ||
| 11 | |||
| 12 | This program is free software; you can redistribute it and/or modify it under | ||
| 13 | the terms of the GNU General Public License as published by the Free Software | ||
| 14 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 15 | version. | ||
| 16 | |||
| 17 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 18 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 19 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 20 | |||
| 21 | You should have received a copy of the GNU General Public License along with | ||
| 22 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 23 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 24 | |||
| 25 | Based on functions from the base bb module, Copyright 2003 Holger Schurig | ||
| 26 | """ | ||
| 27 | |||
| 28 | import os, re | ||
| 29 | import bb | ||
| 30 | from bb import data | ||
| 31 | from bb.fetch import Fetch | ||
| 32 | |||
| 33 | class Local(Fetch): | ||
| 34 | def supports(url, d): | ||
| 35 | """Check to see if a given url can be fetched in the local filesystem. | ||
| 36 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 37 | """ | ||
| 38 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 39 | return type in ['file','patch'] | ||
| 40 | supports = staticmethod(supports) | ||
| 41 | |||
| 42 | def localpath(url, d): | ||
| 43 | """Return the local filename of a given url assuming a successful fetch. | ||
| 44 | """ | ||
| 45 | path = url.split("://")[1] | ||
| 46 | newpath = path | ||
| 47 | if path[0] != "/": | ||
| 48 | filespath = data.getVar('FILESPATH', d, 1) | ||
| 49 | if filespath: | ||
| 50 | newpath = bb.which(filespath, path) | ||
| 51 | if not newpath: | ||
| 52 | filesdir = data.getVar('FILESDIR', d, 1) | ||
| 53 | if filesdir: | ||
| 54 | newpath = os.path.join(filesdir, path) | ||
| 55 | return newpath | ||
| 56 | localpath = staticmethod(localpath) | ||
| 57 | |||
| 58 | def go(self, urls = []): | ||
| 59 | """Fetch urls (no-op for Local method)""" | ||
| 60 | # no need to fetch local files, we'll deal with them in place. | ||
| 61 | return 1 | ||
diff --git a/bitbake/lib/bb/fetch/svn.py b/bitbake/lib/bb/fetch/svn.py new file mode 100644 index 0000000000..ac5eebf5c0 --- /dev/null +++ b/bitbake/lib/bb/fetch/svn.py | |||
| @@ -0,0 +1,189 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' implementations | ||
| 6 | |||
| 7 | Classes for obtaining upstream sources for the | ||
| 8 | BitBake build tools. | ||
| 9 | |||
| 10 | Copyright (C) 2003, 2004 Chris Larson | ||
| 11 | |||
| 12 | This program is free software; you can redistribute it and/or modify it under | ||
| 13 | the terms of the GNU General Public License as published by the Free Software | ||
| 14 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 15 | version. | ||
| 16 | |||
| 17 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 18 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 19 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 20 | |||
| 21 | You should have received a copy of the GNU General Public License along with | ||
| 22 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 23 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 24 | |||
| 25 | Based on functions from the base bb module, Copyright 2003 Holger Schurig | ||
| 26 | """ | ||
| 27 | |||
| 28 | import os, re | ||
| 29 | import bb | ||
| 30 | from bb import data | ||
| 31 | from bb.fetch import Fetch | ||
| 32 | from bb.fetch import FetchError | ||
| 33 | from bb.fetch import MissingParameterError | ||
| 34 | |||
| 35 | class Svn(Fetch): | ||
| 36 | """Class to fetch a module or modules from svn repositories""" | ||
| 37 | def supports(url, d): | ||
| 38 | """Check to see if a given url can be fetched with svn. | ||
| 39 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 40 | """ | ||
| 41 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 42 | return type in ['svn'] | ||
| 43 | supports = staticmethod(supports) | ||
| 44 | |||
| 45 | def localpath(url, d): | ||
| 46 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 47 | if "localpath" in parm: | ||
| 48 | # if user overrides local path, use it. | ||
| 49 | return parm["localpath"] | ||
| 50 | |||
| 51 | if not "module" in parm: | ||
| 52 | raise MissingParameterError("svn method needs a 'module' parameter") | ||
| 53 | else: | ||
| 54 | module = parm["module"] | ||
| 55 | if 'rev' in parm: | ||
| 56 | revision = parm['rev'] | ||
| 57 | else: | ||
| 58 | revision = "" | ||
| 59 | |||
| 60 | date = Fetch.getSRCDate(d) | ||
| 61 | |||
| 62 | return os.path.join(data.getVar("DL_DIR", d, 1),data.expand('%s_%s_%s_%s_%s.tar.gz' % ( module.replace('/', '.'), host, path.replace('/', '.'), revision, date), d)) | ||
| 63 | localpath = staticmethod(localpath) | ||
| 64 | |||
| 65 | def go(self, d, urls = []): | ||
| 66 | """Fetch urls""" | ||
| 67 | if not urls: | ||
| 68 | urls = self.urls | ||
| 69 | |||
| 70 | localdata = data.createCopy(d) | ||
| 71 | data.setVar('OVERRIDES', "svn:%s" % data.getVar('OVERRIDES', localdata), localdata) | ||
| 72 | data.update_data(localdata) | ||
| 73 | |||
| 74 | for loc in urls: | ||
| 75 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(loc, localdata)) | ||
| 76 | if not "module" in parm: | ||
| 77 | raise MissingParameterError("svn method needs a 'module' parameter") | ||
| 78 | else: | ||
| 79 | module = parm["module"] | ||
| 80 | |||
| 81 | dlfile = self.localpath(loc, localdata) | ||
| 82 | dldir = data.getVar('DL_DIR', localdata, 1) | ||
| 83 | # if local path contains the svn | ||
| 84 | # module, consider the dir above it to be the | ||
| 85 | # download directory | ||
| 86 | # pos = dlfile.find(module) | ||
| 87 | # if pos: | ||
| 88 | # dldir = dlfile[:pos] | ||
| 89 | # else: | ||
| 90 | # dldir = os.path.dirname(dlfile) | ||
| 91 | |||
| 92 | # setup svn options | ||
| 93 | options = [] | ||
| 94 | if 'rev' in parm: | ||
| 95 | revision = parm['rev'] | ||
| 96 | else: | ||
| 97 | revision = "" | ||
| 98 | |||
| 99 | date = Fetch.getSRCDate(d) | ||
| 100 | |||
| 101 | if "method" in parm: | ||
| 102 | method = parm["method"] | ||
| 103 | else: | ||
| 104 | method = "pserver" | ||
| 105 | |||
| 106 | if "proto" in parm: | ||
| 107 | proto = parm["proto"] | ||
| 108 | else: | ||
| 109 | proto = "svn" | ||
| 110 | |||
| 111 | svn_rsh = None | ||
| 112 | if method == "ext": | ||
| 113 | if "rsh" in parm: | ||
| 114 | svn_rsh = parm["rsh"] | ||
| 115 | |||
| 116 | tarfn = data.expand('%s_%s_%s_%s_%s.tar.gz' % (module.replace('/', '.'), host, path.replace('/', '.'), revision, date), localdata) | ||
| 117 | data.setVar('TARFILES', dlfile, localdata) | ||
| 118 | data.setVar('TARFN', tarfn, localdata) | ||
| 119 | |||
| 120 | dl = os.path.join(dldir, tarfn) | ||
| 121 | if os.access(dl, os.R_OK): | ||
| 122 | bb.debug(1, "%s already exists, skipping svn checkout." % tarfn) | ||
| 123 | continue | ||
| 124 | |||
| 125 | svn_tarball_stash = data.getVar('CVS_TARBALL_STASH', d, 1) | ||
| 126 | if svn_tarball_stash: | ||
| 127 | fetchcmd = data.getVar("FETCHCOMMAND_wget", d, 1) | ||
| 128 | uri = svn_tarball_stash + tarfn | ||
| 129 | bb.note("fetch " + uri) | ||
| 130 | fetchcmd = fetchcmd.replace("${URI}", uri) | ||
| 131 | ret = os.system(fetchcmd) | ||
| 132 | if ret == 0: | ||
| 133 | bb.note("Fetched %s from tarball stash, skipping checkout" % tarfn) | ||
| 134 | continue | ||
| 135 | |||
| 136 | olddir = os.path.abspath(os.getcwd()) | ||
| 137 | os.chdir(data.expand(dldir, localdata)) | ||
| 138 | |||
| 139 | # setup svnroot | ||
| 140 | # svnroot = ":" + method + ":" + user | ||
| 141 | # if pswd: | ||
| 142 | # svnroot += ":" + pswd | ||
| 143 | svnroot = host + path | ||
| 144 | |||
| 145 | data.setVar('SVNROOT', svnroot, localdata) | ||
| 146 | data.setVar('SVNCOOPTS', " ".join(options), localdata) | ||
| 147 | data.setVar('SVNMODULE', module, localdata) | ||
| 148 | svncmd = data.getVar('FETCHCOMMAND', localdata, 1) | ||
| 149 | svncmd = "svn co -r {%s} %s://%s/%s" % (date, proto, svnroot, module) | ||
| 150 | |||
| 151 | if revision: | ||
| 152 | svncmd = "svn co -r %s %s://%s/%s" % (revision, proto, svnroot, module) | ||
| 153 | if svn_rsh: | ||
| 154 | svncmd = "svn_RSH=\"%s\" %s" % (svn_rsh, svncmd) | ||
| 155 | |||
| 156 | # create temp directory | ||
| 157 | bb.debug(2, "Fetch: creating temporary directory") | ||
| 158 | bb.mkdirhier(data.expand('${WORKDIR}', localdata)) | ||
| 159 | data.setVar('TMPBASE', data.expand('${WORKDIR}/oesvn.XXXXXX', localdata), localdata) | ||
| 160 | tmppipe = os.popen(data.getVar('MKTEMPDIRCMD', localdata, 1) or "false") | ||
| 161 | tmpfile = tmppipe.readline().strip() | ||
| 162 | if not tmpfile: | ||
| 163 | bb.error("Fetch: unable to create temporary directory.. make sure 'mktemp' is in the PATH.") | ||
| 164 | raise FetchError(module) | ||
| 165 | |||
| 166 | # check out sources there | ||
| 167 | os.chdir(tmpfile) | ||
| 168 | bb.note("Fetch " + loc) | ||
| 169 | bb.debug(1, "Running %s" % svncmd) | ||
| 170 | myret = os.system(svncmd) | ||
| 171 | if myret != 0: | ||
| 172 | try: | ||
| 173 | os.rmdir(tmpfile) | ||
| 174 | except OSError: | ||
| 175 | pass | ||
| 176 | raise FetchError(module) | ||
| 177 | |||
| 178 | os.chdir(os.path.join(tmpfile, os.path.dirname(module))) | ||
| 179 | # tar them up to a defined filename | ||
| 180 | myret = os.system("tar -czf %s %s" % (os.path.join(dldir,tarfn), os.path.basename(module))) | ||
| 181 | if myret != 0: | ||
| 182 | try: | ||
| 183 | os.unlink(tarfn) | ||
| 184 | except OSError: | ||
| 185 | pass | ||
| 186 | # cleanup | ||
| 187 | os.system('rm -rf %s' % tmpfile) | ||
| 188 | os.chdir(olddir) | ||
| 189 | del localdata | ||
diff --git a/bitbake/lib/bb/fetch/wget.py b/bitbake/lib/bb/fetch/wget.py new file mode 100644 index 0000000000..e47a8859be --- /dev/null +++ b/bitbake/lib/bb/fetch/wget.py | |||
| @@ -0,0 +1,167 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | """ | ||
| 5 | BitBake 'Fetch' implementations | ||
| 6 | |||
| 7 | Classes for obtaining upstream sources for the | ||
| 8 | BitBake build tools. | ||
| 9 | |||
| 10 | Copyright (C) 2003, 2004 Chris Larson | ||
| 11 | |||
| 12 | This program is free software; you can redistribute it and/or modify it under | ||
| 13 | the terms of the GNU General Public License as published by the Free Software | ||
| 14 | Foundation; either version 2 of the License, or (at your option) any later | ||
| 15 | version. | ||
| 16 | |||
| 17 | This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 18 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 19 | FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 20 | |||
| 21 | You should have received a copy of the GNU General Public License along with | ||
| 22 | this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 23 | Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 24 | |||
| 25 | Based on functions from the base bb module, Copyright 2003 Holger Schurig | ||
| 26 | """ | ||
| 27 | |||
| 28 | import os, re | ||
| 29 | import bb | ||
| 30 | from bb import data | ||
| 31 | from bb.fetch import Fetch | ||
| 32 | from bb.fetch import FetchError | ||
| 33 | from bb.fetch import MD5SumError | ||
| 34 | from bb.fetch import uri_replace | ||
| 35 | |||
| 36 | class Wget(Fetch): | ||
| 37 | """Class to fetch urls via 'wget'""" | ||
| 38 | def supports(url, d): | ||
| 39 | """Check to see if a given url can be fetched using wget. | ||
| 40 | Expects supplied url in list form, as outputted by bb.decodeurl(). | ||
| 41 | """ | ||
| 42 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 43 | return type in ['http','https','ftp'] | ||
| 44 | supports = staticmethod(supports) | ||
| 45 | |||
| 46 | def localpath(url, d): | ||
| 47 | # strip off parameters | ||
| 48 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(url, d)) | ||
| 49 | if "localpath" in parm: | ||
| 50 | # if user overrides local path, use it. | ||
| 51 | return parm["localpath"] | ||
| 52 | url = bb.encodeurl([type, host, path, user, pswd, {}]) | ||
| 53 | |||
| 54 | return os.path.join(data.getVar("DL_DIR", d), os.path.basename(url)) | ||
| 55 | localpath = staticmethod(localpath) | ||
| 56 | |||
| 57 | def go(self, d, urls = []): | ||
| 58 | """Fetch urls""" | ||
| 59 | |||
| 60 | def md5_sum(parm, d): | ||
| 61 | """ | ||
| 62 | Return the MD5SUM associated with the to be downloaded | ||
| 63 | file. | ||
| 64 | It can return None if no md5sum is associated | ||
| 65 | """ | ||
| 66 | try: | ||
| 67 | return parm['md5sum'] | ||
| 68 | except: | ||
| 69 | return None | ||
| 70 | |||
| 71 | def verify_md5sum(wanted_sum, got_sum): | ||
| 72 | """ | ||
| 73 | Verify the md5sum we wanted with the one we got | ||
| 74 | """ | ||
| 75 | if not wanted_sum: | ||
| 76 | return True | ||
| 77 | |||
| 78 | return wanted_sum == got_sum | ||
| 79 | |||
| 80 | def fetch_uri(uri, basename, dl, md5, parm, d): | ||
| 81 | # the MD5 sum we want to verify | ||
| 82 | wanted_md5sum = md5_sum(parm, d) | ||
| 83 | if os.path.exists(dl): | ||
| 84 | # file exists, but we didnt complete it.. trying again.. | ||
| 85 | fetchcmd = data.getVar("RESUMECOMMAND", d, 1) | ||
| 86 | else: | ||
| 87 | fetchcmd = data.getVar("FETCHCOMMAND", d, 1) | ||
| 88 | |||
| 89 | bb.note("fetch " + uri) | ||
| 90 | fetchcmd = fetchcmd.replace("${URI}", uri) | ||
| 91 | fetchcmd = fetchcmd.replace("${FILE}", basename) | ||
| 92 | bb.debug(2, "executing " + fetchcmd) | ||
| 93 | ret = os.system(fetchcmd) | ||
| 94 | if ret != 0: | ||
| 95 | return False | ||
| 96 | |||
| 97 | # check if sourceforge did send us to the mirror page | ||
| 98 | dl_dir = data.getVar("DL_DIR", d, True) | ||
| 99 | if not os.path.exists(dl): | ||
| 100 | os.system("rm %s*" % dl) # FIXME shell quote it | ||
| 101 | bb.debug(2,"sourceforge.net send us to the mirror on %s" % basename) | ||
| 102 | return False | ||
| 103 | |||
| 104 | # supposedly complete.. write out md5sum | ||
| 105 | if bb.which(data.getVar('PATH', d), 'md5sum'): | ||
| 106 | try: | ||
| 107 | md5pipe = os.popen('md5sum ' + dl) | ||
| 108 | md5data = (md5pipe.readline().split() or [ "" ])[0] | ||
| 109 | md5pipe.close() | ||
| 110 | except OSError: | ||
| 111 | md5data = "" | ||
| 112 | |||
| 113 | # verify the md5sum | ||
| 114 | if not verify_md5sum(wanted_md5sum, md5data): | ||
| 115 | raise MD5SumError(uri) | ||
| 116 | |||
| 117 | md5out = file(md5, 'w') | ||
| 118 | md5out.write(md5data) | ||
| 119 | md5out.close() | ||
| 120 | return True | ||
| 121 | |||
| 122 | if not urls: | ||
| 123 | urls = self.urls | ||
| 124 | |||
| 125 | localdata = data.createCopy(d) | ||
| 126 | data.setVar('OVERRIDES', "wget:" + data.getVar('OVERRIDES', localdata), localdata) | ||
| 127 | data.update_data(localdata) | ||
| 128 | |||
| 129 | for uri in urls: | ||
| 130 | completed = 0 | ||
| 131 | (type, host, path, user, pswd, parm) = bb.decodeurl(data.expand(uri, localdata)) | ||
| 132 | basename = os.path.basename(path) | ||
| 133 | dl = self.localpath(uri, d) | ||
| 134 | dl = data.expand(dl, localdata) | ||
| 135 | md5 = dl + '.md5' | ||
| 136 | |||
| 137 | if os.path.exists(md5): | ||
| 138 | # complete, nothing to see here.. | ||
| 139 | continue | ||
| 140 | |||
| 141 | premirrors = [ i.split() for i in (data.getVar('PREMIRRORS', localdata, 1) or "").split('\n') if i ] | ||
| 142 | for (find, replace) in premirrors: | ||
| 143 | newuri = uri_replace(uri, find, replace, d) | ||
| 144 | if newuri != uri: | ||
| 145 | if fetch_uri(newuri, basename, dl, md5, parm, localdata): | ||
| 146 | completed = 1 | ||
| 147 | break | ||
| 148 | |||
| 149 | if completed: | ||
| 150 | continue | ||
| 151 | |||
| 152 | if fetch_uri(uri, basename, dl, md5, parm, localdata): | ||
| 153 | continue | ||
| 154 | |||
| 155 | # try mirrors | ||
| 156 | mirrors = [ i.split() for i in (data.getVar('MIRRORS', localdata, 1) or "").split('\n') if i ] | ||
| 157 | for (find, replace) in mirrors: | ||
| 158 | newuri = uri_replace(uri, find, replace, d) | ||
| 159 | if newuri != uri: | ||
| 160 | if fetch_uri(newuri, basename, dl, md5, parm, localdata): | ||
| 161 | completed = 1 | ||
| 162 | break | ||
| 163 | |||
| 164 | if not completed: | ||
| 165 | raise FetchError(uri) | ||
| 166 | |||
| 167 | del localdata | ||
