mirror of
https://github.com/balena-os/balena-supervisor.git
synced 2025-06-01 07:10:48 +00:00
Merge pull request #999 from balena-io/reparallel-image-code
Re-parallelise current image retrieval code
This commit is contained in:
commit
118d052022
@ -219,15 +219,15 @@ export class Images extends (EventEmitter as new () => ImageEventEmitter) {
|
|||||||
private async withImagesFromDockerAndDB<T>(
|
private async withImagesFromDockerAndDB<T>(
|
||||||
cb: (dockerImages: NormalisedDockerImage[], composeImages: Image[]) => T,
|
cb: (dockerImages: NormalisedDockerImage[], composeImages: Image[]) => T,
|
||||||
) {
|
) {
|
||||||
const images = await this.docker.listImages({ digests: true });
|
const [normalisedImages, dbImages] = await Promise.all([
|
||||||
const newImages = await Bluebird.map(images, async image => {
|
Bluebird.map(this.docker.listImages({ digests: true }), async image => {
|
||||||
const newImage = _.clone(image) as NormalisedDockerImage;
|
const newImage = _.clone(image) as NormalisedDockerImage;
|
||||||
newImage.NormalisedRepoTags = await this.getNormalisedTags(image);
|
newImage.NormalisedRepoTags = await this.getNormalisedTags(image);
|
||||||
return newImage;
|
return newImage;
|
||||||
});
|
}),
|
||||||
|
this.db.models('images').select(),
|
||||||
const dbImages = await this.db.models('images').select();
|
]);
|
||||||
return cb(newImages, dbImages);
|
return cb(normalisedImages, dbImages);
|
||||||
}
|
}
|
||||||
|
|
||||||
private addImageFailure(imageName: string, time = process.hrtime()) {
|
private addImageFailure(imageName: string, time = process.hrtime()) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user