⭐ 欢迎来到虫虫下载站! | 📦 资源下载 📁 资源专辑 ℹ️ 关于我们
⭐ 虫虫下载站

📄 mgrbaseclient.cpp

📁 1)安装sp2补丁. 2)安装中文语言包. 3)关闭除系统盘除外的系统还原 4)控制面板->区域和语言选项->区域选项 选择中国,位置:选择中国.高级选项卡 非unicode程序的语
💻 CPP
📖 第 1 页 / 共 5 页
字号:


	if(Call("mgrbaseif_FSCacheGetModifySize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;

}

superint_ut MGRBaseClient::FSCacheGetMemSize()
{
	NetDataTuple arg,res;


	if(Call("mgrbaseif_FSCacheGetMemSize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::DatabaseGetMemSize(LPCSTR dbname)
{
	NetDataTuple arg,res;


	arg.AddItems(1);
	arg.SetItemString(0,dbname);

	if(Call("mgrbaseif_DatabaseGetMemSize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::DatabaseGetModifySize(LPCSTR dbname)
{
	NetDataTuple arg,res;


	arg.AddItems(1);
	arg.SetItemString(0,dbname);

	if(Call("mgrbaseif_DatabaseGetModifySize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::TableGetModifySize(LPCSTR dbname,LPCSTR tblname)
{
	NetDataTuple arg,res;


	arg.AddItems(2);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,tblname);

	if(Call("mgrbaseif_TableGetModifySize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::TableGetMemSize(LPCSTR dbname,LPCSTR tblname)
{
	NetDataTuple arg,res;


	arg.AddItems(2);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,tblname);

	if(Call("mgrbaseif_TableGetMemSize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::IndexGetModifySize(LPCSTR dbname,LPCSTR idxname)
{
	NetDataTuple arg,res;


	arg.AddItems(2);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,idxname);

	if(Call("mgrbaseif_IndexGetModifySize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::IndexGetMemSize(LPCSTR dbname,LPCSTR idxname)
{
	NetDataTuple arg,res;


	arg.AddItems(2);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,idxname);

	if(Call("mgrbaseif_IndexGetMemSize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::SortGetModifySize(LPCSTR dbname,LPCSTR sortname)
{
	NetDataTuple arg,res;


	arg.AddItems(2);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,sortname);

	if(Call("mgrbaseif_SortGetModifySize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}

superint_ut MGRBaseClient::SortGetMemSize(LPCSTR dbname,LPCSTR sortname)
{
	NetDataTuple arg,res;


	arg.AddItems(2);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,sortname);

	if(Call("mgrbaseif_SortGetMemSize",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);

	}

	return 0;
}


BOOL MGRBaseClient::GetCurrentProcs(NetTable *procs)
{
	NetDataTuple arg,res;

	if(Call("mgrbaseif_GetCurrentProcs",NULL,&arg,&res))
	{
		res.GetItemNetTable(0)->CopyTo(procs);
		return TRUE;

	}

	return FALSE;
}

BOOL MGRBaseClient::DumpThreadStack(HANDLE threadid,NetTable *stack)
{
	NetDataTuple arg,res;


	arg.AddItems(1);
	arg.SetItemSuperLong(0,(superint_ut)threadid);

	if(Call("mgrbaseif_DumpThreadStack",NULL,&arg,&res))
	{
		if(res.GetItemLong(0))
		{
			res.GetItemNetTable(1)->CopyTo(stack);
			return TRUE;
		}

	}

	return FALSE;
}


BOOL  MGRBaseClient::MemoryFileCreate(LPCSTR name,superint_ut size)
{
	NetDataTuple arg,res;

	arg.AddItems(2);
	arg.SetItemString(0,name);
	arg.SetItemSuperLong(1,size);

	if(Call("mgrbaseif_MemoryFileCreate",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return FALSE;

}

BOOL  MGRBaseClient::MemoryFileDrop(LPCSTR name)
{
	NetDataTuple arg,res;

	arg.AddItems(1);
	arg.SetItemString(0,name);

	if(Call("mgrbaseif_MemoryFileDrop",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return FALSE;
}

int   MGRBaseClient::MemoryFileRead(LPCSTR name,superint_ut pos,BYTE *buf,int bufsize)
{
	NetDataTuple arg,res;
	BYTE *p;
	int size,c;

	arg.AddItems(3);
	arg.SetItemString(0,name);
	arg.SetItemSuperLong(1,pos);
	arg.SetItemLong(2,bufsize);

	if(Call("mgrbaseif_MemoryFileRead",NULL,&arg,&res))
	{
		p=res.GetItemBinary(0,&size);

		c=min(size,bufsize);
		memcpy(buf,p,c);

		return c;

	}

	return 0;
}

int   MGRBaseClient::MemoryFileWrite(LPCSTR name,superint_ut pos,BYTE *buf,int bufsize)
{
	NetDataTuple arg,res;
	int c;

	arg.AddItems(3);
	arg.SetItemString(0,name);
	arg.SetItemSuperLong(1,pos);
	arg.SetItemBinary(2,buf,bufsize);

	if(Call("mgrbaseif_MemoryFileWrite",NULL,&arg,&res))
	{
		c=res.GetItemLong(0);

		return c;

	}

	return 0;
}

superint_ut  MGRBaseClient::MemoryFileGetLength(LPCSTR name)
{
	NetDataTuple arg,res;

	arg.AddItems(1);
	arg.SetItemString(0,name);

	if(Call("mgrbaseif_MemoryFileGetLength",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);
	}

	return 0;
}

BOOL  MGRBaseClient::MemoryFileIsExist(LPCSTR name)
{
	NetDataTuple arg,res;

	arg.AddItems(1);
	arg.SetItemString(0,name);

	if(Call("mgrbaseif_MemoryFileIsExist",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return FALSE;
}

BOOL  MGRBaseClient::MemoryFileList(NetTable *nt)
{

	NetDataTuple arg,res;


	if(Call("mgrbaseif_MemoryFileList",NULL,&arg,&res))
	{
		res.GetItemNetTable(0)->CopyTo(nt);

		return TRUE;
	}

	return FALSE;
}


BOOL MGRBaseClient::LogLoadClientConfig()
{
	NetDataTuple arg,res;


	if(Call("mgrbaseif_LogLoadClientConfig",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return FALSE;
}


superint_ut MGRBaseClient::PipePoolCountFreeSpace()
{
	NetDataTuple arg,res;


	if(Call("mgrbaseif_PipePoolCountFreeSpace",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);
	}

	return 0;
}

superint_ut MGRBaseClient::PipePoolCountTotalSpace()
{
	NetDataTuple arg,res;


	if(Call("mgrbaseif_PipePoolCountTotalSpace",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);
	}

	return 0;
}

int         MGRBaseClient::PipePoolCountActivePipe()
{
	NetDataTuple arg,res;


	if(Call("mgrbaseif_PipePoolCountActivePipe",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

superint_ut MGRBaseClient::PipeOpen(LPCSTR dbname,LPCSTR tblname,superint_ut rowid,LPCSTR colname)
{
	NetDataTuple arg,res;

	arg.SetItemCount(4);
	arg.SetItemString(0,dbname);
	arg.SetItemString(1,tblname);
	arg.SetItemSuperLong(2,rowid);
	arg.SetItemString(3,colname);

	if(Call("mgrbaseif_PipeOpen",NULL,&arg,&res))
	{
		return res.GetItemSuperLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeClose(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeClose",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeIsValid(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeIsValid",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

int         MGRBaseClient::PipeRead(superint_ut pipe,BYTE *buf,int bufsize)
{
	NetDataTuple arg,res;
	BYTE *p;
	int size;

	arg.SetItemCount(2);
	arg.SetItemSuperLong(0,pipe);
	arg.SetItemLong(1,bufsize);

	if(Call("mgrbaseif_PipeRead",NULL,&arg,&res))
	{
		p=res.GetItemBinary(0,&size);
		memcpy(buf,p,min(size,bufsize));
		return size;
	}

	return 0;
}

int         MGRBaseClient::PipeTryRead(superint_ut pipe,BYTE *buf,int bufsize)
{
	NetDataTuple arg,res;
	BYTE *p;
	int size;

	arg.SetItemCount(2);
	arg.SetItemSuperLong(0,pipe);
	arg.SetItemLong(1,bufsize);

	if(Call("mgrbaseif_PipeTryRead",NULL,&arg,&res))
	{
		p=res.GetItemBinary(0,&size);
		memcpy(buf,p,min(size,bufsize));
		return size;
	}

	return 0;
}

int         MGRBaseClient::PipeSkipRead(superint_ut pipe,int size)
{
	NetDataTuple arg,res;

	arg.SetItemCount(2);
	arg.SetItemSuperLong(0,pipe);
	arg.SetItemLong(1,size);

	if(Call("mgrbaseif_PipeSkipRead",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeWrite(superint_ut pipe,BYTE *buf,int bufsize)
{
	NetDataTuple arg,res;

	arg.SetItemCount(2);
	arg.SetItemSuperLong(0,pipe);
	arg.SetItemBinary(1,buf,bufsize);

	if(Call("mgrbaseif_PipeWrite",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeWriteEnd(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeWriteEnd",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;

}

BOOL        MGRBaseClient::PipeWriteBack(superint_ut pipe,BYTE *buf,int bufsize)
{
	NetDataTuple arg,res;

	arg.SetItemCount(2);
	arg.SetItemSuperLong(0,pipe);
	arg.SetItemBinary(1,buf,bufsize);

	if(Call("mgrbaseif_PipeWriteBack",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeAbort(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeAbort",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeIsAbort(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeIsAbort",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeIsWriteEnd(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeIsWriteEnd",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeIsFinished(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeIsFinished",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

int         MGRBaseClient::PipeCountReadableData(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeCountReadableData",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeIsEmpty(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeIsEmpty",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeCanRead(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeCanRead",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

BOOL        MGRBaseClient::PipeCanWrite(superint_ut pipe)
{
	NetDataTuple arg,res;

	arg.SetItemCount(1);
	arg.SetItemSuperLong(0,pipe);

	if(Call("mgrbaseif_PipeCanWrite",NULL,&arg,&res))
	{
		return res.GetItemLong(0);
	}

	return 0;
}

////////////////////////////////////////////////////////////////////////////////////////////
MLongBinaryFile::MLongBinaryFile(MGRBaseClient *client)
{
	m_client=client;
	m_pos=0;
}

MLongBinaryFile::~MLongBinaryFile()
{
}


BOOL MLongBinaryFile::Open(LPCSTR dbname,LPCSTR tblname,superint_ut rowid,LPCSTR colname)
{
	NetTable cols;

	m_dbname=dbname;
	m_tblname=tblname;
	m_rowid=rowid;
	m_colname=colname;

	if(!m_client->TableRowIsExist(dbname,tblname,rowid))
		return FALSE;

	m_client->TableGetCols(dbname,tblname,&cols);

	if(cols.GetColIndex(colname)==-1)
		return FALSE;

	if(cols.GetColType(colname)!=NET_LONGBINARY)
		return FALSE;

	return TRUE;
}

superint_ut MLongBinaryFile::GetPosition() {	return m_pos;}superint_ut MLongBinaryFile::Seek(superint_ut lOff, UINT nFrom){   superint_ut length;

   length=GetLength();

	switch(nFrom)
	{
	case CFile::begin:
			m_pos=lOff;
		break;
	case CFile::current:
			m_pos+=lOf

⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -