summaryrefslogtreecommitdiff
path: root/source3/lib
diff options
context:
space:
mode:
authorVolker Lendecke <vl@samba.org>2009-09-23 15:21:40 +0200
committerVolker Lendecke <vl@samba.org>2009-09-23 18:50:33 +0200
commit76d95b9a2dcfff9df1865ffff74f0e9c32bce609 (patch)
tree885a46adcfeccb1b8b3cf631f9f0bdc58dee676d /source3/lib
parentadf66e75c060e6462b9f8819944d0f8ff1ef2c1b (diff)
downloadsamba-76d95b9a2dcfff9df1865ffff74f0e9c32bce609.tar.gz
samba-76d95b9a2dcfff9df1865ffff74f0e9c32bce609.tar.bz2
samba-76d95b9a2dcfff9df1865ffff74f0e9c32bce609.zip
s3:gencache: Add a "was_expired" argument to gencache_get_data_blob
This is set to true if the routine returns failure due to an existing but expired entry.
Diffstat (limited to 'source3/lib')
-rw-r--r--source3/lib/gencache.c29
1 files changed, 19 insertions, 10 deletions
diff --git a/source3/lib/gencache.c b/source3/lib/gencache.c
index ee1f4b70b3..5c030cddab 100644
--- a/source3/lib/gencache.c
+++ b/source3/lib/gencache.c
@@ -273,24 +273,25 @@ static bool gencache_pull_timeout(char *val, time_t *pres, char **pendptr)
**/
bool gencache_get_data_blob(const char *keystr, DATA_BLOB *blob,
- time_t *timeout)
+ time_t *timeout, bool *was_expired)
{
TDB_DATA databuf;
time_t t;
char *endptr;
+ bool expired = false;
if (keystr == NULL) {
- return false;
+ goto fail;
}
if (tdb_data_cmp(string_term_tdb_data(keystr),
last_stabilize_key()) == 0) {
DEBUG(10, ("Can't get %s as a key\n", keystr));
- return false;
+ goto fail;
}
if (!gencache_init()) {
- return False;
+ goto fail;
}
databuf = tdb_fetch_bystring(cache_notrans, keystr);
@@ -302,12 +303,12 @@ bool gencache_get_data_blob(const char *keystr, DATA_BLOB *blob,
if (databuf.dptr == NULL) {
DEBUG(10, ("Cache entry with key = %s couldn't be found \n",
keystr));
- return False;
+ goto fail;
}
if (!gencache_pull_timeout((char *)databuf.dptr, &t, &endptr)) {
SAFE_FREE(databuf.dptr);
- return False;
+ goto fail;
}
DEBUG(10, ("Returning %s cache entry: key = %s, value = %s, "
@@ -317,7 +318,7 @@ bool gencache_get_data_blob(const char *keystr, DATA_BLOB *blob,
if (t == 0) {
/* Deleted */
SAFE_FREE(databuf.dptr);
- return False;
+ goto fail;
}
if (t <= time(NULL)) {
@@ -331,7 +332,9 @@ bool gencache_get_data_blob(const char *keystr, DATA_BLOB *blob,
gencache_set(keystr, "", 0);
SAFE_FREE(databuf.dptr);
- return False;
+
+ expired = true;
+ goto fail;
}
if (blob != NULL) {
@@ -341,7 +344,7 @@ bool gencache_get_data_blob(const char *keystr, DATA_BLOB *blob,
if (blob->data == NULL) {
SAFE_FREE(databuf.dptr);
DEBUG(0, ("memdup failed\n"));
- return False;
+ goto fail;
}
}
@@ -352,6 +355,12 @@ bool gencache_get_data_blob(const char *keystr, DATA_BLOB *blob,
}
return True;
+
+fail:
+ if (was_expired != NULL) {
+ *was_expired = expired;
+ }
+ return false;
}
struct stabilize_state {
@@ -503,7 +512,7 @@ bool gencache_get(const char *keystr, char **value, time_t *ptimeout)
DATA_BLOB blob;
bool ret = False;
- ret = gencache_get_data_blob(keystr, &blob, ptimeout);
+ ret = gencache_get_data_blob(keystr, &blob, ptimeout, NULL);
if (!ret) {
return false;
}