#include "postgres.h"
#include <math.h>
#include <limits.h>
#include "access/heapam.h"
#include "access/sysattr.h"
#include "catalog/namespace.h"
#include "catalog/pg_type.h"
#include "libpq/pqformat.h"
#include "miscadmin.h"
#include "parser/parsetree.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/rel.h"
#include "utils/snapmgr.h"
#include "utils/tqual.h"
#include "utils/varlena.h"

Include dependency graph for tid.c:

Macros
#define	DatumGetItemPointer(X) ((ItemPointer) DatumGetPointer(X))

#define	ItemPointerGetDatum(X) PointerGetDatum(X)

#define	PG_GETARG_ITEMPOINTER(n) DatumGetItemPointer(PG_GETARG_DATUM(n))

#define	PG_RETURN_ITEMPOINTER(x) return ItemPointerGetDatum(x)

#define	LDELIM '('

#define	RDELIM ')'

#define	DELIM ','

#define	NTIDARGS 2

Functions
Datum	tidin (PG_FUNCTION_ARGS)

Datum	tidout (PG_FUNCTION_ARGS)

Datum	tidrecv (PG_FUNCTION_ARGS)

Datum	tidsend (PG_FUNCTION_ARGS)

Datum	tideq (PG_FUNCTION_ARGS)

Datum	tidne (PG_FUNCTION_ARGS)

Datum	tidlt (PG_FUNCTION_ARGS)

Datum	tidle (PG_FUNCTION_ARGS)

Datum	tidgt (PG_FUNCTION_ARGS)

Datum	tidge (PG_FUNCTION_ARGS)

Datum	bttidcmp (PG_FUNCTION_ARGS)

Datum	tidlarger (PG_FUNCTION_ARGS)

Datum	tidsmaller (PG_FUNCTION_ARGS)

void	setLastTid (const ItemPointer tid)

static Datum	currtid_for_view (Relation viewrel, ItemPointer tid)

Datum	currtid_byreloid (PG_FUNCTION_ARGS)

Datum	currtid_byrelname (PG_FUNCTION_ARGS)

Variables
static ItemPointerData	Current_last_tid = {{0, 0}, 0}

Macro Definition Documentation

#define DatumGetItemPointer ( X ) ((ItemPointer) DatumGetPointer(X))

Definition at line 38 of file tid.c.

#define DELIM ','

Definition at line 45 of file tid.c.

Referenced by tidin().

#define ItemPointerGetDatum ( X ) PointerGetDatum(X)

Definition at line 39 of file tid.c.

#define LDELIM '('

Definition at line 43 of file tid.c.

Referenced by tidin().

#define NTIDARGS 2

Definition at line 46 of file tid.c.

Referenced by tidin().

#define PG_GETARG_ITEMPOINTER ( n ) DatumGetItemPointer(PG_GETARG_DATUM(n))

Definition at line 40 of file tid.c.

Referenced by bttidcmp(), currtid_byrelname(), currtid_byreloid(), tideq(), tidge(), tidgt(), tidlarger(), tidle(), tidlt(), tidne(), tidout(), tidsend(), and tidsmaller().

#define PG_RETURN_ITEMPOINTER ( x ) return ItemPointerGetDatum(x)

Definition at line 41 of file tid.c.

Referenced by currtid_byrelname(), currtid_byreloid(), tidin(), tidlarger(), tidrecv(), and tidsmaller().

#define RDELIM ')'

Definition at line 44 of file tid.c.

Referenced by tidin().

Function Documentation

Datum bttidcmp ( PG_FUNCTION_ARGS )

Definition at line 216 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_INT32.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_INT32(ItemPointerCompare(arg1, arg2));
 }

Datum currtid_byrelname ( PG_FUNCTION_ARGS )

Definition at line 364 of file tid.c.

References AccessShareLock, ACL_KIND_CLASS, ACL_SELECT, aclcheck_error(), ACLCHECK_OK, currtid_for_view(), GetLatestSnapshot(), GetUserId(), heap_close, heap_get_latest_tid(), heap_openrv(), ItemPointerCopy, makeRangeVarFromNameList(), palloc(), pg_class_aclcheck(), PG_GETARG_ITEMPOINTER, PG_GETARG_TEXT_PP, PG_RETURN_ITEMPOINTER, RelationData::rd_rel, RegisterSnapshot(), RelationGetRelationName, RelationGetRelid, RELKIND_VIEW, textToQualifiedNameList(), and UnregisterSnapshot().

 {
     text       *relname = PG_GETARG_TEXT_PP(0);
     ItemPointer tid = PG_GETARG_ITEMPOINTER(1);
     ItemPointer result;
     RangeVar   *relrv;
     Relation    rel;
     AclResult   aclresult;
     Snapshot    snapshot;
 
     relrv = makeRangeVarFromNameList(textToQualifiedNameList(relname));
     rel = heap_openrv(relrv, AccessShareLock);
 
     aclresult = pg_class_aclcheck(RelationGetRelid(rel), GetUserId(),
                                   ACL_SELECT);
     if (aclresult != ACLCHECK_OK)
         aclcheck_error(aclresult, ACL_KIND_CLASS,
                        RelationGetRelationName(rel));
 
     if (rel->rd_rel->relkind == RELKIND_VIEW)
         return currtid_for_view(rel, tid);
 
     result = (ItemPointer) palloc(sizeof(ItemPointerData));
     ItemPointerCopy(tid, result);
 
     snapshot = RegisterSnapshot(GetLatestSnapshot());
     heap_get_latest_tid(rel, snapshot, result);
     UnregisterSnapshot(snapshot);
 
     heap_close(rel, AccessShareLock);
 
     PG_RETURN_ITEMPOINTER(result);
 }

Datum currtid_byreloid ( PG_FUNCTION_ARGS )

Definition at line 325 of file tid.c.

References AccessShareLock, ACL_KIND_CLASS, ACL_SELECT, aclcheck_error(), ACLCHECK_OK, Current_last_tid, currtid_for_view(), GetLatestSnapshot(), GetUserId(), heap_close, heap_get_latest_tid(), heap_open(), ItemPointerCopy, palloc(), pg_class_aclcheck(), PG_GETARG_ITEMPOINTER, PG_GETARG_OID, PG_RETURN_ITEMPOINTER, RelationData::rd_rel, RegisterSnapshot(), RelationGetRelationName, RelationGetRelid, RELKIND_VIEW, and UnregisterSnapshot().

Referenced by currtid_for_view().

 {
     Oid         reloid = PG_GETARG_OID(0);
     ItemPointer tid = PG_GETARG_ITEMPOINTER(1);
     ItemPointer result;
     Relation    rel;
     AclResult   aclresult;
     Snapshot    snapshot;
 
     result = (ItemPointer) palloc(sizeof(ItemPointerData));
     if (!reloid)
     {
         *result = Current_last_tid;
         PG_RETURN_ITEMPOINTER(result);
     }
 
     rel = heap_open(reloid, AccessShareLock);
 
     aclresult = pg_class_aclcheck(RelationGetRelid(rel), GetUserId(),
                                   ACL_SELECT);
     if (aclresult != ACLCHECK_OK)
         aclcheck_error(aclresult, ACL_KIND_CLASS,
                        RelationGetRelationName(rel));
 
     if (rel->rd_rel->relkind == RELKIND_VIEW)
         return currtid_for_view(rel, tid);
 
     ItemPointerCopy(tid, result);
 
     snapshot = RegisterSnapshot(GetLatestSnapshot());
     heap_get_latest_tid(rel, snapshot, result);
     UnregisterSnapshot(snapshot);
 
     heap_close(rel, AccessShareLock);
 
     PG_RETURN_ITEMPOINTER(result);
 }

static Datum currtid_for_view	(	Relation	viewrel,
		ItemPointer	tid
	)

static

Definition at line 263 of file tid.c.

References AccessShareLock, RewriteRule::actions, CMD_SELECT, currtid_byreloid(), DirectFunctionCall2, elog, ERROR, RewriteRule::event, TargetEntry::expr, get_tle_by_resno(), heap_close, i, IS_SPECIAL_VARNO, IsA, linitial, list_length(), NameStr, tupleDesc::natts, RuleLock::numLocks, ObjectIdGetDatum, PointerGetDatum, RelationData::rd_rules, RelationGetDescr, rt_fetch, Query::rtable, RuleLock::rules, SelfItemPointerAttributeNumber, Query::targetList, TIDOID, TupleDescAttr, Var::varattno, and Var::varno.

Referenced by currtid_byrelname(), and currtid_byreloid().

 {
     TupleDesc   att = RelationGetDescr(viewrel);
     RuleLock   *rulelock;
     RewriteRule *rewrite;
     int         i,
                 natts = att->natts,
                 tididx = -1;
 
     for (i = 0; i < natts; i++)
     {
         Form_pg_attribute attr = TupleDescAttr(att, i);
 
         if (strcmp(NameStr(attr->attname), "ctid") == 0)
         {
             if (attr->atttypid != TIDOID)
                 elog(ERROR, "ctid isn't of type TID");
             tididx = i;
             break;
         }
     }
     if (tididx < 0)
         elog(ERROR, "currtid cannot handle views with no CTID");
     rulelock = viewrel->rd_rules;
     if (!rulelock)
         elog(ERROR, "the view has no rules");
     for (i = 0; i < rulelock->numLocks; i++)
     {
         rewrite = rulelock->rules[i];
         if (rewrite->event == CMD_SELECT)
         {
             Query      *query;
             TargetEntry *tle;
 
             if (list_length(rewrite->actions) != 1)
                 elog(ERROR, "only one select rule is allowed in views");
             query = (Query *) linitial(rewrite->actions);
             tle = get_tle_by_resno(query->targetList, tididx + 1);
             if (tle && tle->expr && IsA(tle->expr, Var))
             {
                 Var        *var = (Var *) tle->expr;
                 RangeTblEntry *rte;
 
                 if (!IS_SPECIAL_VARNO(var->varno) &&
                     var->varattno == SelfItemPointerAttributeNumber)
                 {
                     rte = rt_fetch(var->varno, query->rtable);
                     if (rte)
                     {
                         heap_close(viewrel, AccessShareLock);
                         return DirectFunctionCall2(currtid_byreloid, ObjectIdGetDatum(rte->relid), PointerGetDatum(tid));
                     }
                 }
             }
             break;
         }
     }
     elog(ERROR, "currtid cannot handle this view");
     return (Datum) 0;
 }

void setLastTid ( const ItemPointer tid )

Definition at line 252 of file tid.c.

Referenced by ExecInsert().

 {
     Current_last_tid = *tid;
 }

Datum tideq ( PG_FUNCTION_ARGS )

Definition at line 162 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_BOOL.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_BOOL(ItemPointerCompare(arg1, arg2) == 0);
 }

Datum tidge ( PG_FUNCTION_ARGS )

Definition at line 207 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_BOOL.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_BOOL(ItemPointerCompare(arg1, arg2) >= 0);
 }

Datum tidgt ( PG_FUNCTION_ARGS )

Definition at line 198 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_BOOL.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_BOOL(ItemPointerCompare(arg1, arg2) > 0);
 }

Datum tidin ( PG_FUNCTION_ARGS )

Definition at line 53 of file tid.c.

References DELIM, ereport, errcode(), errmsg(), ERROR, i, ItemPointerSet, LDELIM, NTIDARGS, palloc(), PG_GETARG_CSTRING, PG_RETURN_ITEMPOINTER, and RDELIM.

Referenced by make_tuple_from_result_row().

 {
     char       *str = PG_GETARG_CSTRING(0);
     char       *p,
                *coord[NTIDARGS];
     int         i;
     ItemPointer result;
     BlockNumber blockNumber;
     OffsetNumber offsetNumber;
     char       *badp;
     int         hold_offset;
 
     for (i = 0, p = str; *p && i < NTIDARGS && *p != RDELIM; p++)
         if (*p == DELIM || (*p == LDELIM && !i))
             coord[i++] = p + 1;
 
     if (i < NTIDARGS)
         ereport(ERROR,
                 (errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
                  errmsg("invalid input syntax for type %s: \"%s\"",
                         "tid", str)));
 
     errno = 0;
     blockNumber = strtoul(coord[0], &badp, 10);
     if (errno || *badp != DELIM)
         ereport(ERROR,
                 (errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
                  errmsg("invalid input syntax for type %s: \"%s\"",
                         "tid", str)));
 
     hold_offset = strtol(coord[1], &badp, 10);
     if (errno || *badp != RDELIM ||
         hold_offset > USHRT_MAX || hold_offset < 0)
         ereport(ERROR,
                 (errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
                  errmsg("invalid input syntax for type %s: \"%s\"",
                         "tid", str)));
 
     offsetNumber = hold_offset;
 
     result = (ItemPointer) palloc(sizeof(ItemPointerData));
 
     ItemPointerSet(result, blockNumber, offsetNumber);
 
     PG_RETURN_ITEMPOINTER(result);
 }

Datum tidlarger ( PG_FUNCTION_ARGS )

Definition at line 225 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_ITEMPOINTER.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_ITEMPOINTER(ItemPointerCompare(arg1, arg2) >= 0 ? arg1 : arg2);
 }

Datum tidle ( PG_FUNCTION_ARGS )

Definition at line 189 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_BOOL.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_BOOL(ItemPointerCompare(arg1, arg2) <= 0);
 }

Datum tidlt ( PG_FUNCTION_ARGS )

Definition at line 180 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_BOOL.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_BOOL(ItemPointerCompare(arg1, arg2) < 0);
 }

Datum tidne ( PG_FUNCTION_ARGS )

Definition at line 171 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_BOOL.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_BOOL(ItemPointerCompare(arg1, arg2) != 0);
 }

Datum tidout ( PG_FUNCTION_ARGS )

Definition at line 105 of file tid.c.

References buf, ItemPointerGetBlockNumberNoCheck, ItemPointerGetOffsetNumberNoCheck, PG_GETARG_ITEMPOINTER, PG_RETURN_CSTRING, pstrdup(), and snprintf().

Referenced by pgrowlocks().

 {
     ItemPointer itemPtr = PG_GETARG_ITEMPOINTER(0);
     BlockNumber blockNumber;
     OffsetNumber offsetNumber;
     char        buf[32];
 
     blockNumber = ItemPointerGetBlockNumberNoCheck(itemPtr);
     offsetNumber = ItemPointerGetOffsetNumberNoCheck(itemPtr);
 
     /* Perhaps someday we should output this as a record. */
     snprintf(buf, sizeof(buf), "(%u,%u)", blockNumber, offsetNumber);
 
     PG_RETURN_CSTRING(pstrdup(buf));
 }

Datum tidrecv ( PG_FUNCTION_ARGS )

Definition at line 125 of file tid.c.

References buf, ItemPointerSet, palloc(), PG_GETARG_POINTER, PG_RETURN_ITEMPOINTER, and pq_getmsgint().

 {
     StringInfo  buf = (StringInfo) PG_GETARG_POINTER(0);
     ItemPointer result;
     BlockNumber blockNumber;
     OffsetNumber offsetNumber;
 
     blockNumber = pq_getmsgint(buf, sizeof(blockNumber));
     offsetNumber = pq_getmsgint(buf, sizeof(offsetNumber));
 
     result = (ItemPointer) palloc(sizeof(ItemPointerData));
 
     ItemPointerSet(result, blockNumber, offsetNumber);
 
     PG_RETURN_ITEMPOINTER(result);
 }

Datum tidsend ( PG_FUNCTION_ARGS )

Definition at line 146 of file tid.c.

References buf, ItemPointerGetBlockNumberNoCheck, ItemPointerGetOffsetNumberNoCheck, PG_GETARG_ITEMPOINTER, PG_RETURN_BYTEA_P, pq_begintypsend(), pq_endtypsend(), pq_sendint16(), and pq_sendint32().

 {
     ItemPointer itemPtr = PG_GETARG_ITEMPOINTER(0);
     StringInfoData buf;
 
     pq_begintypsend(&buf);
     pq_sendint32(&buf, ItemPointerGetBlockNumberNoCheck(itemPtr));
     pq_sendint16(&buf, ItemPointerGetOffsetNumberNoCheck(itemPtr));
     PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
 }

Datum tidsmaller ( PG_FUNCTION_ARGS )

Definition at line 234 of file tid.c.

References ItemPointerCompare(), PG_GETARG_ITEMPOINTER, and PG_RETURN_ITEMPOINTER.

 {
     ItemPointer arg1 = PG_GETARG_ITEMPOINTER(0);
     ItemPointer arg2 = PG_GETARG_ITEMPOINTER(1);
 
     PG_RETURN_ITEMPOINTER(ItemPointerCompare(arg1, arg2) <= 0 ? arg1 : arg2);
 }

Variable Documentation

ItemPointerData Current_last_tid = {{0, 0}, 0}

static

Definition at line 249 of file tid.c.

Referenced by currtid_byreloid().

Macros

Functions

Variables

Macro Definition Documentation

Function Documentation

Variable Documentation