summaryrefslogtreecommitdiffabout
path: root/test/RP.cc
authorMichael Krelin <hacker@klever.net>2008-02-11 21:17:44 (UTC)
committer Michael Krelin <hacker@klever.net>2008-02-11 21:17:44 (UTC)
commita3eba4c33fee80fcf152dcbd198586e12b687e54 (patch) (side-by-side diff)
tree1059019be6d1b83f3336872d7fe054e5faa48d20 /test/RP.cc
parent947098ee2ab09c340e6822f2bfce7570388c86b4 (diff)
downloadlibopkele-a3eba4c33fee80fcf152dcbd198586e12b687e54.zip
libopkele-a3eba4c33fee80fcf152dcbd198586e12b687e54.tar.gz
libopkele-a3eba4c33fee80fcf152dcbd198586e12b687e54.tar.bz2
more cleanup
Signed-off-by: Michael Krelin <hacker@klever.net>
Diffstat (limited to 'test/RP.cc') (more/less context) (ignore whitespace changes)
-rw-r--r--test/RP.cc1
1 files changed, 0 insertions, 1 deletions
diff --git a/test/RP.cc b/test/RP.cc
index 813b9b7..35ee71d 100644
--- a/test/RP.cc
+++ b/test/RP.cc
@@ -227,49 +227,48 @@ class example_rp_t : public opkele::prequeue_RP {
db.get_table(S,T,&nr,&nc);
if(nr<1)
throw opkele::exception(OPKELE_CP_ "No more endpoints queued");
assert(nr==1); assert(nc==3);
eqtop.uri = T.get(1,0,nc);
eqtop.claimed_id = T.get(1,1,nc);
eqtop.local_id = T.get(1,2,nc);
have_eqtop = true;
}
return eqtop;
}
void next_endpoint() {
assert(as_id>=0);
get_endpoint();
have_eqtop = false;
sqlite3_mem_t<char*> S = sqlite3_mprintf(
"DELETE FROM endpoints_queue"
" WHERE as_id=%ld AND eq_uri=%Q AND eq_local_id=%Q",
htc.get_value().c_str(),as_id,
eqtop.uri.c_str());
db.exec(S);
}
- mutable string _cid;
mutable string _nid;
void set_normalized_id(const string& nid) {
assert(as_id>=0);
sqlite3_mem_t<char*> S = sqlite3_mprintf(
"UPDATE auth_sessions"
" SET as_normalized_id=%Q"
" WHERE hts_id=%Q and as_id=%ld",
nid.c_str(),
htc.get_value().c_str(),as_id);
db.exec(S);
_nid = nid;
}
const string get_normalized_id() const {
assert(as_id>=0);
if(_nid.empty()) {
sqlite3_mem_t<char*> S = sqlite3_mprintf(
"SELECT as_normalized_id"
" FROM"
" auth_sessions"
" WHERE"
" hts_id=%Q AND as_id=%ld",
htc.get_value().c_str(),as_id);
sqlite3_table_t T; int nr,nc;