summaryrefslogtreecommitdiffstats
path: root/build/cache.sh
blob: d4b2c45ddb8bc5d44856156c2d284a905880fb5d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
#!/bin/bash
##############################################################################
# Copyright (c) 2015 Ericsson AB and others.
# stefan.k.berg@ericsson.com
# jonas.bjurel@ericsson.com
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################


exit_trap() {
    if [ -d "$TMPDIR" ]; then
        rm -rf $TMPDIR
    fi
}

trap exit_trap EXIT

CACHETRANSPORT=${CACHETRANSPORT:-"curl --silent"}
CACHEMAXAGE=${CACHEMAXAGE:-$[14*24*3600]}
CACHEDEBUG=${CACHEDEBUG:-1}
PLUGINS_MATCH="${BUILD_BASE}/f_isoroot/*/"

debugmsg () {
    if [ "$CACHEDEBUG" -eq 1 ]; then
        echo "$@" >&2
    fi
}

errorexit () {
    echo "$@" >&2
    exit 1
}

# Generate a unique number every two weeks - a service routine that
# can be used when generating the SHA1 to make sure that the cache is
# rebuilt bi-weekly even if no pruning of the cache is taking place.
getbiweek () {
  echo "$(date +'%G')$[10#$(date +'%V')/2]"
}

# Get a SHA1 based on what's piped into the cache command
getid() {
    debugmsg "Generating sha1sum"
    sha1sum | sed 's/ .*//'
}


# Put in cache
put() {
    if check $1; then
       debugmsg "SHA1 $1 already in cache, skipping storage"
    else
        debugmsg "Storing SHA1 $1 in cache"
        ${CACHETRANSPORT} -T - ${CACHEBASE}/$1.blob
        echo "Expires: $[`date +"%s"` + $CACHEMAXAGE]" | ${CACHETRANSPORT} -T - ${CACHEBASE}/$1.meta
    fi
    exit 0
}

# Get from cache
get() {
    local rc

    ${CACHETRANSPORT} -o - ${CACHEBASE}/$1.blob 2>/dev/null
    rc=$?

    if [ $rc -eq 0 ]; then
        echo "Got SHA1 $1 from cache" 2>/dev/null
    else
        echo "Tried to get SHA1 $1 from cache but failed" 2>/dev/null
    fi

    return $?
}

# Check if in cache
check() {
    local rc

    ${CACHETRANSPORT} ${CACHEBASE}/$1.meta &>/dev/null
    rc=$?

    if [ $rc -eq 0 ]; then
        debugmsg "Checking for SHA1 $1 in cache and found it, rc = $rc"
    else
        debugmsg "Checking for SHA1 $1 in cache and failed, rc = $rc"
    fi

    return $rc
}

# Verify that SHA1 seems to be a SHA1...
validSHA1() {
    if [ $(echo $1 | wc -c) -ne 41 ]; then
        return 1
    else
        return 0
    fi
}

# Figure out commit ID from URI and tag/branch/commit ID
getcommitid() {
    if echo $2 | grep -q '^refs/changes/'; then
        REF=`echo $2 | sed "s,refs\/changes\/\(.*\),\1,"`
    else
        REF=$2
    fi

    echo "Repo is $1, ref is ${REF}" >&2

    HEADMATCH=`git ls-remote $1 | grep "refs/heads/${REF}$" | awk '{ print $1 }'`
    TAGMATCH=`git ls-remote $1 | grep "refs/tags/${REF}$" | awk '{ print $1 }'`
    CHANGEMATCH=`git ls-remote $1 | grep "refs/changes/${REF}$" | awk '{ print $1 }'`

    if [ -n "$HEADMATCH" ]; then
        echo "$HEADMATCH"
    elif [ -n "$TAGMATCH" ]; then
        echo "$TAGMATCH"
    elif [ -n "$CHANGEMATCH" ]; then
        echo "Warning: ${REF} is a change!" >&2
        TMPDIR=`mktemp -d /tmp/cacheXXXXX`
        cd $TMPDIR
        git clone $1 &>/dev/null || errorexit "Could not clone $1"
        cd * || errorexit "Could not enter clone of $1"
	git fetch $1 refs/changes/$REF &>/dev/null || errorexit "Could not fetch change"
	git checkout FETCH_HEAD &>/dev/null || errorexit "Could not checkout FETCH_HEAD"
        git show HEAD &>/dev/null || errorexit "Could not find commit $2"
        git show HEAD | head -1 | awk '{ print $2 }'
    else
        TMPDIR=`mktemp -d /tmp/cacheXXXXX`
        cd $TMPDIR
        git clone $1 &>/dev/null || errorexit "Could not clone $1"
        cd * || errorexit "Could not enter clone of $1"
        git show $2 &>/dev/null || errorexit "Could not find commit $2"
        git show $2 | head -1 | awk '{ print $2 }'
    fi
}

packages() {
    local PLUGINS_SHA1=''

    # globbing expansion is alphabetical
    for plugin in $PLUGINS_MATCH ; do
        if [ -f "${plugin}packages.yaml" ]
        then
            PLUGINS_SHA1+=$(sha1sum ${plugin}packages.yaml)
        fi
    done

    if [ -n "${PLUGINS_SHA1}" ]
    then
        echo -n $PLUGINS_SHA1 | sha1sum
    fi
}

if [ -z "$CACHEBASE" ]; then
  errorexit "CACHEBASE not set - exiting..."
fi

case $1 in
    getbiweek)
        if [ $# -ne 1 ]; then
            errorexit "No arguments can be given to getbiweek!"
        fi
        getbiweek
        ;;
    getcommitid)
        if [ $# -ne 3 ]; then
            errorexit "Arg 1 needs to be URI and arg 2 tag/branch/commit"
        fi
        shift
        getcommitid $@
        ;;
    getid)
        if [ $# -ne 1 ]; then
            errorexit "No arguments can be given to getid!"
        fi
        getid
        ;;
    get|check|put)
        if [ $# -ne 2 ]; then
            errorexit "Only one argument, the SHA1 sum, can be given to getid!"
        else
            if ! validSHA1 $2; then
                errorexit "Invalid SHA1 format!"
            fi
        fi

        $1 $2
        exit $rc
        ;;
    packages)
        if [ $# -ne 1 ]; then
            errorexit "No arguments can be given to packages!"
        fi
        packages
        ;;
    *)
        errorexit "I only know about getcommitid, getid, check, get and put!"
esac
span class="o">= stdio_register(&logdev); return (rc == 0) ? 1 : rc; } static void logbuff_putc(const char c) { char buf[2]; buf[0] = c; buf[1] = '\0'; logbuff_printk(buf); } static void logbuff_puts(const char *s) { logbuff_printk (s); } void logbuff_log(char *msg) { if ((gd->flags & GD_FLG_LOGINIT)) { logbuff_printk(msg); } else { /* * Can happen only for pre-relocated errors as logging * at that stage should be disabled */ puts (msg); } } /* * Subroutine: do_log * * Description: Handler for 'log' command.. * * Inputs: argv[1] contains the subcommand * * Return: None * */ int do_log(cmd_tbl_t *cmdtp, int flag, int argc, char * const argv[]) { char *s; unsigned long i, start, size; if (strcmp(argv[1], "append") == 0) { /* Log concatenation of all arguments separated by spaces */ for (i = 2; i < argc; i++) { logbuff_printk(argv[i]); logbuff_putc((i < argc - 1) ? ' ' : '\n'); } return 0; } switch (argc) { case 2: if (strcmp(argv[1], "show") == 0) { if (log_version == 2) { start = log->v2.start; size = log->v2.end - log->v2.start; } else { start = log->v1.start; size = log->v1.size; } if (size > LOGBUFF_LEN) size = LOGBUFF_LEN; for (i = 0; i < size; i++) { s = lbuf + ((start + i) & LOGBUFF_MASK); putc(*s); } return 0; } else if (strcmp(argv[1], "reset") == 0) { logbuff_reset(); return 0; } else if (strcmp(argv[1], "info") == 0) { printf("Logbuffer at %08lx\n", (unsigned long)lbuf); if (log_version == 2) { printf("log_start = %08lx\n", log->v2.start); printf("log_end = %08lx\n", log->v2.end); printf("log_con = %08lx\n", log->v2.con); printf("logged_chars = %08lx\n", log->v2.chars); } else { printf("log_start = %08lx\n", log->v1.start); printf("log_size = %08lx\n", log->v1.size); printf("logged_chars = %08lx\n", log->v1.chars); } return 0; } return CMD_RET_USAGE; default: return CMD_RET_USAGE; } } U_BOOT_CMD( log, 255, 1, do_log, "manipulate logbuffer", "info - show pointer details\n" "log reset - clear contents\n" "log show - show contents\n" "log append <msg> - append <msg> to the logbuffer" ); static int logbuff_printk(const char *line) { int i; char *msg, *p, *buf_end; int line_feed; static signed char msg_level = -1; strcpy(buf + 3, line); i = strlen(line); buf_end = buf + 3 + i; for (p = buf + 3; p < buf_end; p++) { msg = p; if (msg_level < 0) { if ( p[0] != '<' || p[1] < '0' || p[1] > '7' || p[2] != '>' ) { p -= 3; p[0] = '<'; p[1] = default_message_loglevel + '0'; p[2] = '>'; } else { msg += 3; } msg_level = p[1] - '0'; } line_feed = 0; for (; p < buf_end; p++) { if (log_version == 2) { lbuf[log->v2.end & LOGBUFF_MASK] = *p; log->v2.end++; if (log->v2.end - log->v2.start > LOGBUFF_LEN) log->v2.start++; log->v2.chars++; } else { lbuf[(log->v1.start + log->v1.size) & LOGBUFF_MASK] = *p; if (log->v1.size < LOGBUFF_LEN) log->v1.size++; else log->v1.start++; log->v1.chars++; } if (*p == '\n') { line_feed = 1; break; } } if (msg_level < console_loglevel) { printf("%s", msg); } if (line_feed) msg_level = -1; } return i; }