VirtualTable.cpp

/*
 * The contents of this file are subject to the Initial
 * Developer's Public License Version 1.0 (the "License");
 * you may not use this file except in compliance with the
 * License. You may obtain a copy of the License at
 * http://www.ibphoenix.com/main.nfs?a=ibphoenix&page=ibp_idpl.
 *
 * Software distributed under the License is distributed AS IS,
 * WITHOUT WARRANTY OF ANY KIND, either express or implied.
 * See the License for the specific language governing rights
 * and limitations under the License.
 *
 * The Original Code was created by Dmitry Yemanov
 * for the Firebird Open Source RDBMS project.
 *
 * Copyright (c) 2006 Dmitry Yemanov <dimitr@users.sf.net>
 * and all contributors signed below.
 *
 * All Rights Reserved.
 * Contributor(s): ______________________________________.
 * Adriano dos Santos Fernandes
*/

#include"firebird.h"
#include"../common/dsc.h"
#include"../jrd/constants.h"
#include"../jrd/jrd.h"
#include"../jrd/exe.h"
#include"../jrd/ids.h"
#include"../jrd/ini.h"
#include"../jrd/req.h"
#include"../jrd/val.h"
#include"../jrd/cmp_proto.h"
#include"../jrd/err_proto.h"
#include"../jrd/evl_proto.h"
#include"../jrd/lck_proto.h"
#include"../jrd/met_proto.h"
#include"../jrd/mov_proto.h"
#include"../jrd/vio_proto.h"

#include"../jrd/Monitoring.h"
#include"../jrd/RecordBuffer.h"
#include"../jrd/VirtualTable.h"

usingnamespaceJrd;
usingnamespaceFirebird;


voidVirtualTable::erase(thread_db* tdbb, record_param* rpb)
{
SET_TDBB(tdbb);

 Database* dbb = tdbb->getDatabase();
fb_assert(dbb);

 jrd_rel* relation = rpb->rpb_relation;
fb_assert(relation);

 dsc desc;
lck_t lock_type;

if (relation->rel_id == rel_mon_attachments)
 {
// Get attachment id
if (!EVL_field(relation, rpb->rpb_record, f_mon_att_id, &desc))
return;

// Ignore attempt to stop system attachment
 dsc sysFlag;
if (EVL_field(relation, rpb->rpb_record, f_mon_att_sys_flag, &sysFlag) &&
MOV_get_long(tdbb, &sysFlag, 0) != 0)
 {
return;
 }

 lock_type = LCK_attachment;
 }
elseif (relation->rel_id == rel_mon_statements)
 {
// Get attachment id
if (!EVL_field(relation, rpb->rpb_record, f_mon_stmt_att_id, &desc))
return;
 lock_type = LCK_cancel;
 }
else
 {
ERR_post(Arg::Gds(isc_read_only));
return;
 }

const SINT64 id = MOV_get_int64(tdbb, &desc, 0);

// Post a blocking request
 Lock temp_lock(tdbb, sizeof(SINT64), lock_type);
 temp_lock.setKey(id);

 ThreadStatusGuard temp_status(tdbb);

if (LCK_lock(tdbb, &temp_lock, LCK_EX, -1))
LCK_release(tdbb, &temp_lock);
}


voidVirtualTable::modify(thread_db* /*tdbb*/, record_param* /*org_rpb*/, record_param* /*new_rpb*/)
{
ERR_post(Arg::Gds(isc_read_only));
}


voidVirtualTable::store(thread_db* /*tdbb*/, record_param* /*rpb*/)
{
ERR_post(Arg::Gds(isc_read_only));
}