#include "db_config.h"
#include "db_int.h"
#ifdef HAVE_SYSTEM_INCLUDE_FILES
#include <tcl.h>
#endif
#include "dbinc/tcl_db.h"
#include "dbinc/db_page.h"
#include "dbinc/db_am.h"
#define GLOB_CHAR(c) ((c) == '*' || (c) == '?')
DBTCL_INFO *
_NewInfo(interp, anyp, name, type)
Tcl_Interp *interp;
void *anyp;
char *name;
enum INFOTYPE type;
{
DBTCL_INFO *p;
int ret;
if ((ret = __os_calloc(NULL, sizeof(DBTCL_INFO), 1, &p)) != 0) {
Tcl_SetResult(interp, db_strerror(ret), TCL_STATIC);
return (NULL);
}
if ((ret = __os_strdup(NULL, name, &p->i_name)) != 0) {
Tcl_SetResult(interp, db_strerror(ret), TCL_STATIC);
__os_free(NULL, p);
return (NULL);
}
p->i_interp = interp;
p->i_anyp = anyp;
p->i_type = type;
LIST_INSERT_HEAD(&__db_infohead, p, entries);
return (p);
}
void *
_NameToPtr(name)
CONST char *name;
{
DBTCL_INFO *p;
LIST_FOREACH(p, &__db_infohead, entries)
if (strcmp(name, p->i_name) == 0)
return (p->i_anyp);
return (NULL);
}
DBTCL_INFO *
_PtrToInfo(ptr)
CONST void *ptr;
{
DBTCL_INFO *p;
LIST_FOREACH(p, &__db_infohead, entries)
if (p->i_anyp == ptr)
return (p);
return (NULL);
}
DBTCL_INFO *
_NameToInfo(name)
CONST char *name;
{
DBTCL_INFO *p;
LIST_FOREACH(p, &__db_infohead, entries)
if (strcmp(name, p->i_name) == 0)
return (p);
return (NULL);
}
void
_SetInfoData(p, data)
DBTCL_INFO *p;
void *data;
{
if (p == NULL)
return;
p->i_anyp = data;
return;
}
void
_DeleteInfo(p)
DBTCL_INFO *p;
{
if (p == NULL)
return;
LIST_REMOVE(p, entries);
if (p->i_lockobj.data != NULL)
__os_free(NULL, p->i_lockobj.data);
if (p->i_err != NULL && p->i_err != stderr && p->i_err != stdout) {
(void)fclose(p->i_err);
p->i_err = NULL;
}
if (p->i_errpfx != NULL)
__os_free(NULL, p->i_errpfx);
if (p->i_compare != NULL)
Tcl_DecrRefCount(p->i_compare);
if (p->i_dupcompare != NULL)
Tcl_DecrRefCount(p->i_dupcompare);
if (p->i_hashproc != NULL)
Tcl_DecrRefCount(p->i_hashproc);
if (p->i_second_call != NULL)
Tcl_DecrRefCount(p->i_second_call);
if (p->i_rep_eid != NULL)
Tcl_DecrRefCount(p->i_rep_eid);
if (p->i_rep_send != NULL)
Tcl_DecrRefCount(p->i_rep_send);
if (p->i_event != NULL)
Tcl_DecrRefCount(p->i_event);
__os_free(NULL, p->i_name);
__os_free(NULL, p);
return;
}
int
_SetListElem(interp, list, elem1, e1cnt, elem2, e2cnt)
Tcl_Interp *interp;
Tcl_Obj *list;
void *elem1, *elem2;
u_int32_t e1cnt, e2cnt;
{
Tcl_Obj *myobjv[2], *thislist;
int myobjc;
myobjc = 2;
myobjv[0] = Tcl_NewByteArrayObj((u_char *)elem1, (int)e1cnt);
myobjv[1] = Tcl_NewByteArrayObj((u_char *)elem2, (int)e2cnt);
thislist = Tcl_NewListObj(myobjc, myobjv);
if (thislist == NULL)
return (TCL_ERROR);
return (Tcl_ListObjAppendElement(interp, list, thislist));
}
int
_SetListElemInt(interp, list, elem1, elem2)
Tcl_Interp *interp;
Tcl_Obj *list;
void *elem1;
long elem2;
{
Tcl_Obj *myobjv[2], *thislist;
int myobjc;
myobjc = 2;
myobjv[0] =
Tcl_NewByteArrayObj((u_char *)elem1, (int)strlen((char *)elem1));
myobjv[1] = Tcl_NewLongObj(elem2);
thislist = Tcl_NewListObj(myobjc, myobjv);
if (thislist == NULL)
return (TCL_ERROR);
return (Tcl_ListObjAppendElement(interp, list, thislist));
}
#ifdef HAVE_64BIT_TYPES
int
_SetListElemWideInt(interp, list, elem1, elem2)
Tcl_Interp *interp;
Tcl_Obj *list;
void *elem1;
int64_t elem2;
{
Tcl_Obj *myobjv[2], *thislist;
int myobjc;
myobjc = 2;
myobjv[0] =
Tcl_NewByteArrayObj((u_char *)elem1, (int)strlen((char *)elem1));
myobjv[1] = Tcl_NewWideIntObj(elem2);
thislist = Tcl_NewListObj(myobjc, myobjv);
if (thislist == NULL)
return (TCL_ERROR);
return (Tcl_ListObjAppendElement(interp, list, thislist));
}
#endif
int
_SetListRecnoElem(interp, list, elem1, elem2, e2size)
Tcl_Interp *interp;
Tcl_Obj *list;
db_recno_t elem1;
u_char *elem2;
u_int32_t e2size;
{
Tcl_Obj *myobjv[2], *thislist;
int myobjc;
myobjc = 2;
myobjv[0] = Tcl_NewWideIntObj((Tcl_WideInt)elem1);
myobjv[1] = Tcl_NewByteArrayObj(elem2, (int)e2size);
thislist = Tcl_NewListObj(myobjc, myobjv);
if (thislist == NULL)
return (TCL_ERROR);
return (Tcl_ListObjAppendElement(interp, list, thislist));
}
int
_Set3DBTList(interp, list, elem1, is1recno, elem2, is2recno, elem3)
Tcl_Interp *interp;
Tcl_Obj *list;
DBT *elem1, *elem2, *elem3;
int is1recno, is2recno;
{
Tcl_Obj *myobjv[3], *thislist;
if (is1recno)
myobjv[0] = Tcl_NewWideIntObj(
(Tcl_WideInt)*(db_recno_t *)elem1->data);
else
myobjv[0] = Tcl_NewByteArrayObj(
(u_char *)elem1->data, (int)elem1->size);
if (is2recno)
myobjv[1] = Tcl_NewWideIntObj(
(Tcl_WideInt)*(db_recno_t *)elem2->data);
else
myobjv[1] = Tcl_NewByteArrayObj(
(u_char *)elem2->data, (int)elem2->size);
myobjv[2] = Tcl_NewByteArrayObj(
(u_char *)elem3->data, (int)elem3->size);
thislist = Tcl_NewListObj(3, myobjv);
if (thislist == NULL)
return (TCL_ERROR);
return (Tcl_ListObjAppendElement(interp, list, thislist));
}
int
_SetMultiList(interp, list, key, data, type, flag)
Tcl_Interp *interp;
Tcl_Obj *list;
DBT *key, *data;
DBTYPE type;
u_int32_t flag;
{
db_recno_t recno;
u_int32_t dlen, klen;
int result;
void *pointer, *dp, *kp;
recno = 0;
dlen = 0;
kp = NULL;
DB_MULTIPLE_INIT(pointer, data);
result = TCL_OK;
if (type == DB_RECNO || type == DB_QUEUE)
recno = *(db_recno_t *) key->data;
else
kp = key->data;
klen = key->size;
do {
if (flag & DB_MULTIPLE_KEY) {
if (type == DB_RECNO || type == DB_QUEUE)
DB_MULTIPLE_RECNO_NEXT(pointer,
data, recno, dp, dlen);
else
DB_MULTIPLE_KEY_NEXT(pointer,
data, kp, klen, dp, dlen);
} else
DB_MULTIPLE_NEXT(pointer, data, dp, dlen);
if (pointer == NULL)
break;
if (type == DB_RECNO || type == DB_QUEUE) {
result =
_SetListRecnoElem(interp, list, recno, dp, dlen);
recno++;
if (recno == 0)
recno++;
} else
result = _SetListElem(interp, list, kp, klen, dp, dlen);
} while (result == TCL_OK);
return (result);
}
int
_GetGlobPrefix(pattern, prefix)
char *pattern;
char **prefix;
{
int i, j;
char *p;
if (__os_strdup(NULL, pattern, prefix) != 0)
return (1);
p = *prefix;
for (i = 0, j = 0; p[i] && !GLOB_CHAR(p[i]); i++, j++)
if (p[i] == '\\' && p[i+1]) {
p[j] = p[i+1];
i++;
} else
p[j] = p[i];
p[j] = 0;
return (0);
}
int
_ReturnSetup(interp, ret, ok, errmsg)
Tcl_Interp *interp;
int ret, ok;
char *errmsg;
{
char *msg;
if (ret > 0)
return (_ErrorSetup(interp, ret, errmsg));
if (ret == 0) {
Tcl_SetResult(interp, "0", TCL_STATIC);
return (TCL_OK);
}
msg = db_strerror(ret);
Tcl_AppendResult(interp, msg, NULL);
if (ok)
return (TCL_OK);
else {
Tcl_SetErrorCode(interp, "BerkeleyDB", msg, NULL);
return (TCL_ERROR);
}
}
int
_ErrorSetup(interp, ret, errmsg)
Tcl_Interp *interp;
int ret;
char *errmsg;
{
Tcl_SetErrno(ret);
Tcl_AppendResult(interp, errmsg, ":", Tcl_PosixError(interp), NULL);
return (TCL_ERROR);
}
void
_ErrorFunc(dbenv, pfx, msg)
const DB_ENV *dbenv;
CONST char *pfx;
const char *msg;
{
DBTCL_INFO *p;
Tcl_Interp *interp;
size_t size;
char *err;
COMPQUIET(dbenv, NULL);
p = _NameToInfo(pfx);
if (p == NULL)
return;
interp = p->i_interp;
size = strlen(pfx) + strlen(msg) + 4;
if (__os_malloc(NULL, size, &err) != 0) {
Tcl_AddErrorInfo(interp, msg);
Tcl_AppendResult(interp, msg, "\n", NULL);
return;
}
snprintf(err, size, "%s: %s", pfx, msg);
Tcl_AddErrorInfo(interp, err);
Tcl_AppendResult(interp, err, "\n", NULL);
__os_free(NULL, err);
return;
}
void
_EventFunc(dbenv, event, info)
DB_ENV *dbenv;
u_int32_t event;
void *info;
{
#define TCLDB_EVENTITEMS 2
#define TCLDB_SENDEVENT 3
DBTCL_INFO *ip;
Tcl_Interp *interp;
Tcl_Obj *event_o, *origobj;
Tcl_Obj *myobjv[TCLDB_EVENTITEMS], *objv[TCLDB_SENDEVENT];
int i, myobjc, result;
ip = (DBTCL_INFO *)dbenv->app_private;
interp = ip->i_interp;
if (ip->i_event == NULL)
return;
objv[0] = ip->i_event;
objv[1] = NewStringObj(ip->i_name, strlen(ip->i_name));
myobjv[1] = NULL;
myobjc = 1;
switch (event) {
case DB_EVENT_PANIC:
myobjv[0] = NewStringObj("panic", strlen("panic"));
myobjv[myobjc++] = Tcl_NewIntObj(*(int *)info);
break;
case DB_EVENT_REP_CLIENT:
myobjv[0] = NewStringObj("rep_client", strlen("rep_client"));
break;
case DB_EVENT_REP_ELECTED:
myobjv[0] = NewStringObj("elected", strlen("elected"));
break;
case DB_EVENT_REP_MASTER:
myobjv[0] = NewStringObj("rep_master", strlen("rep_master"));
break;
case DB_EVENT_REP_NEWMASTER:
myobjv[0] = NewStringObj("newmaster", strlen("newmaster"));
myobjv[myobjc++] = Tcl_NewIntObj(*(int *)info);
break;
case DB_EVENT_REP_PERM_FAILED:
myobjv[0] = NewStringObj("perm_failed", strlen("perm_failed"));
break;
case DB_EVENT_REP_STARTUPDONE:
myobjv[0] = NewStringObj("startupdone", strlen("startupdone"));
break;
case DB_EVENT_WRITE_FAILED:
myobjv[0] =
NewStringObj("write_failed", strlen("write_failed"));
break;
default:
__db_errx(dbenv, "Tcl unknown event %lu", (u_long)event);
return;
}
for (i = 0; i < myobjc; i++)
Tcl_IncrRefCount(myobjv[i]);
event_o = Tcl_NewListObj(myobjc, myobjv);
Tcl_IncrRefCount(event_o);
objv[2] = event_o;
origobj = Tcl_GetObjResult(interp);
Tcl_IncrRefCount(origobj);
result = Tcl_EvalObjv(interp, TCLDB_SENDEVENT, objv, 0);
if (result != TCL_OK) {
__db_errx(dbenv, "Tcl event failure");
__os_abort();
}
Tcl_SetObjResult(interp, origobj);
Tcl_DecrRefCount(origobj);
for (i = 0; i < myobjc; i++)
Tcl_DecrRefCount(myobjv[i]);
Tcl_DecrRefCount(event_o);
return;
}
#define INVALID_LSNMSG "Invalid LSN with %d parts. Should have 2.\n"
int
_GetLsn(interp, obj, lsn)
Tcl_Interp *interp;
Tcl_Obj *obj;
DB_LSN *lsn;
{
Tcl_Obj **myobjv;
char msg[MSG_SIZE];
int myobjc, result;
u_int32_t tmp;
result = Tcl_ListObjGetElements(interp, obj, &myobjc, &myobjv);
if (result == TCL_ERROR)
return (result);
if (myobjc != 2) {
result = TCL_ERROR;
snprintf(msg, MSG_SIZE, INVALID_LSNMSG, myobjc);
Tcl_SetResult(interp, msg, TCL_VOLATILE);
return (result);
}
result = _GetUInt32(interp, myobjv[0], &tmp);
if (result == TCL_ERROR)
return (result);
lsn->file = tmp;
result = _GetUInt32(interp, myobjv[1], &tmp);
lsn->offset = tmp;
return (result);
}
int
_GetUInt32(interp, obj, resp)
Tcl_Interp *interp;
Tcl_Obj *obj;
u_int32_t *resp;
{
int result;
long ltmp;
result = Tcl_GetLongFromObj(interp, obj, <mp);
if (result != TCL_OK)
return (result);
if ((unsigned long)ltmp != (u_int32_t)ltmp) {
if (interp != NULL) {
Tcl_ResetResult(interp);
Tcl_AppendToObj(Tcl_GetObjResult(interp),
"integer value too large for u_int32_t", -1);
}
return (TCL_ERROR);
}
*resp = (u_int32_t)ltmp;
return (TCL_OK);
}
Tcl_Obj *
_GetFlagsList(interp, flags, fnp)
Tcl_Interp *interp;
u_int32_t flags;
const FN *fnp;
{
Tcl_Obj *newlist, *newobj;
int result;
newlist = Tcl_NewObj();
if (fnp == NULL)
return (newlist);
for (; fnp->mask != 0; ++fnp)
if (LF_ISSET(fnp->mask)) {
newobj = NewStringObj(fnp->name, strlen(fnp->name));
result =
Tcl_ListObjAppendElement(interp, newlist, newobj);
DB_ASSERT(NULL, result == TCL_OK);
}
return (newlist);
}
int __debug_stop, __debug_on, __debug_print, __debug_test;
void
_debug_check()
{
if (__debug_on == 0)
return;
if (__debug_print != 0) {
printf("\r%7d:", __debug_on);
(void)fflush(stdout);
}
if (__debug_on++ == __debug_test || __debug_stop)
__db_loadme();
}
int
_CopyObjBytes(interp, obj, newp, sizep, freep)
Tcl_Interp *interp;
Tcl_Obj *obj;
void *newp;
u_int32_t *sizep;
int *freep;
{
void *tmp, *new;
int i, len, ret;
*freep = 0;
ret = Tcl_GetIntFromObj(interp, obj, &i);
tmp = Tcl_GetByteArrayFromObj(obj, &len);
*sizep = (u_int32_t)len;
if (ret == TCL_ERROR) {
Tcl_ResetResult(interp);
*(void **)newp = tmp;
return (0);
}
if ((ret = __os_malloc(NULL, (size_t)len, &new)) != 0)
return (ret);
memcpy(new, tmp, (size_t)len);
*(void **)newp = new;
*freep = 1;
return (0);
}