From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1753391AbaBYLkn (ORCPT ); Tue, 25 Feb 2014 06:40:43 -0500 Received: from mail-wi0-f177.google.com ([209.85.212.177]:52441 "EHLO mail-wi0-f177.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1753098AbaBYLiP (ORCPT ); Tue, 25 Feb 2014 06:38:15 -0500 From: Sergey Senozhatsky To: Minchan Kim Cc: Andrew Morton , Jerome Marchand , Nitin Gupta , linux-kernel@vger.kernel.org, Sergey Senozhatsky Subject: [PATCHv7 3/7] zram: factor out single stream compression Date: Tue, 25 Feb 2014 14:34:29 +0300 Message-Id: <1393328073-12313-4-git-send-email-sergey.senozhatsky@gmail.com> X-Mailer: git-send-email 1.9.0.291.g027825b In-Reply-To: <1393328073-12313-1-git-send-email-sergey.senozhatsky@gmail.com> References: <1393328073-12313-1-git-send-email-sergey.senozhatsky@gmail.com> Sender: linux-kernel-owner@vger.kernel.org List-ID: X-Mailing-List: linux-kernel@vger.kernel.org This is preparation patch to add multi stream support to zcomp. Introduce struct zcomp_strm_single and a set of functions to manage zcomp_strm stream access. zcomp_strm_single implements single compession stream, same way as current zcomp implementation. This moves zcomp_strm stream control and locking from zcomp, so compressing backend zcomp is not aware of required locking (single and multi streams require different locking schemes). The following set of functions added: - zcomp_strm_single_get()/zcomp_strm_single_put() get and put compression stream, implement required locking - zcomp_strm_single_create()/zcomp_strm_single_destroy() create and destroy zcomp_strm_single New ->strm_get() and ->strm_put() callbacks added to zcomp, which are set to zcomp_strm_single_get() and zcomp_strm_single_put() during initialisation. Instead of direct locking and zcomp_strm access from zcomp_strm_get() and zcomp_strm_put(), zcomp now calls ->strm_get() and ->strm_put() correspondingly. Signed-off-by: Sergey Senozhatsky --- drivers/block/zram/zcomp.c | 65 +++++++++++++++++++++++++++++++++++++++------- drivers/block/zram/zcomp.h | 7 +++-- 2 files changed, 61 insertions(+), 11 deletions(-) diff --git a/drivers/block/zram/zcomp.c b/drivers/block/zram/zcomp.c index 947efe3..e20054b 100644 --- a/drivers/block/zram/zcomp.c +++ b/drivers/block/zram/zcomp.c @@ -15,6 +15,14 @@ #include "zcomp.h" +/* + * single zcomp_strm backend + */ +struct zcomp_strm_single { + struct mutex strm_lock; + struct zcomp_strm *zstrm; +}; + extern struct zcomp_backend zcomp_lzo; static struct zcomp_backend *find_backend(const char *compress) @@ -55,17 +63,58 @@ static struct zcomp_strm *zcomp_strm_alloc(struct zcomp *comp) return zstrm; } +static struct zcomp_strm *zcomp_strm_single_get(struct zcomp *comp) +{ + struct zcomp_strm_single *zs = comp->stream; + mutex_lock(&zs->strm_lock); + return zs->zstrm; +} + +static void zcomp_strm_single_put(struct zcomp *comp, struct zcomp_strm *zstrm) +{ + struct zcomp_strm_single *zs = comp->stream; + mutex_unlock(&zs->strm_lock); +} + +static void zcomp_strm_single_destroy(struct zcomp *comp) +{ + struct zcomp_strm_single *zs = comp->stream; + zcomp_strm_free(comp, zs->zstrm); + kfree(zs); +} + +static int zcomp_strm_single_create(struct zcomp *comp) +{ + struct zcomp_strm_single *zs; + + comp->destroy = zcomp_strm_single_destroy; + comp->strm_get = zcomp_strm_single_get; + comp->strm_put = zcomp_strm_single_put; + zs = kmalloc(sizeof(struct zcomp_strm_single), GFP_KERNEL); + comp->stream = zs; + if (!zs) + return -ENOMEM; + + mutex_init(&zs->strm_lock); + zs->zstrm = zcomp_strm_alloc(comp); + if (!zs->zstrm) { + zcomp_strm_single_destroy(comp); + return -ENOMEM; + } + return 0; +} + struct zcomp_strm *zcomp_strm_get(struct zcomp *comp) { - mutex_lock(&comp->strm_lock); - return comp->zstrm; + return comp->strm_get(comp); } void zcomp_strm_put(struct zcomp *comp, struct zcomp_strm *zstrm) { - mutex_unlock(&comp->strm_lock); + comp->strm_put(comp, zstrm); } +/* compress page */ int zcomp_compress(struct zcomp *comp, struct zcomp_strm *zstrm, const unsigned char *src, size_t *dst_len) { @@ -73,6 +122,7 @@ int zcomp_compress(struct zcomp *comp, struct zcomp_strm *zstrm, zstrm->private); } +/* decompress page */ int zcomp_decompress(struct zcomp *comp, const unsigned char *src, size_t src_len, unsigned char *dst) { @@ -81,7 +131,7 @@ int zcomp_decompress(struct zcomp *comp, const unsigned char *src, void zcomp_destroy(struct zcomp *comp) { - zcomp_strm_free(comp, comp->zstrm); + comp->destroy(comp); kfree(comp); } @@ -105,11 +155,8 @@ struct zcomp *zcomp_create(const char *compress) return NULL; comp->backend = backend; - mutex_init(&comp->strm_lock); - - comp->zstrm = zcomp_strm_alloc(comp); - if (!comp->zstrm) { - kfree(comp); + if (zcomp_strm_single_create(comp) != 0) { + zcomp_destroy(comp); return NULL; } return comp; diff --git a/drivers/block/zram/zcomp.h b/drivers/block/zram/zcomp.h index 5106f8e..861e04d 100644 --- a/drivers/block/zram/zcomp.h +++ b/drivers/block/zram/zcomp.h @@ -34,9 +34,12 @@ struct zcomp_backend { /* dynamic per-device compression frontend */ struct zcomp { - struct mutex strm_lock; - struct zcomp_strm *zstrm; + void *stream; struct zcomp_backend *backend; + + struct zcomp_strm *(*strm_get)(struct zcomp *comp); + void (*strm_put)(struct zcomp *comp, struct zcomp_strm *zstrm); + void (*destroy)(struct zcomp *comp); }; struct zcomp *zcomp_create(const char *comp); -- 1.9.0.291.g027825b