📄 mgrbaseclient.cpp
字号:
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 + -