get, put, delete don't use sessions, only cursors so don't fetch the
shared session.
This commit is contained in:
parent
83bca853f3
commit
7a148b9f19
1 changed files with 0 additions and 21 deletions
|
@ -1039,13 +1039,6 @@ ASYNC_NIF_DECL(
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
WT_SESSION *session = NULL;
|
|
||||||
int rc = __session_for(args->conn_handle, worker_id, &session);
|
|
||||||
if (rc != 0) {
|
|
||||||
ASYNC_NIF_REPLY(__strerror_term(env, rc));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
WT_CURSOR *cursor = NULL;
|
WT_CURSOR *cursor = NULL;
|
||||||
rc = __retain_cursor(args->conn_handle, worker_id, args->uri, &cursor);
|
rc = __retain_cursor(args->conn_handle, worker_id, args->uri, &cursor);
|
||||||
if (rc != 0) {
|
if (rc != 0) {
|
||||||
|
@ -1101,13 +1094,6 @@ ASYNC_NIF_DECL(
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
WT_SESSION *session = NULL;
|
|
||||||
int rc = __session_for(args->conn_handle, worker_id, &session);
|
|
||||||
if (rc != 0) {
|
|
||||||
ASYNC_NIF_REPLY(__strerror_term(env, rc));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
WT_CURSOR *cursor = NULL;
|
WT_CURSOR *cursor = NULL;
|
||||||
rc = __retain_cursor(args->conn_handle, worker_id, args->uri, &cursor);
|
rc = __retain_cursor(args->conn_handle, worker_id, args->uri, &cursor);
|
||||||
if (rc != 0) {
|
if (rc != 0) {
|
||||||
|
@ -1186,13 +1172,6 @@ ASYNC_NIF_DECL(
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
WT_SESSION *session = NULL;
|
|
||||||
int rc = __session_for(args->conn_handle, worker_id, &session);
|
|
||||||
if (rc != 0) {
|
|
||||||
ASYNC_NIF_REPLY(__strerror_term(env, rc));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
WT_CURSOR *cursor = NULL;
|
WT_CURSOR *cursor = NULL;
|
||||||
rc = __retain_cursor(args->conn_handle, worker_id, args->uri, &cursor);
|
rc = __retain_cursor(args->conn_handle, worker_id, args->uri, &cursor);
|
||||||
if (rc != 0) {
|
if (rc != 0) {
|
||||||
|
|
Loading…
Reference in a new issue