自学教程：C++ GetMessageType函数代码示例

// SMsgDirG2ModifyService::Unpack// Virtual method from SmallMessage.  Extracts data from message buffer.voidSMsgDirG2ModifyService::Unpack(void){	WTRACE("SMsgDirG2ModifyService::Unpack");	SetKeyType(KT_SERVICE);	SetExtended((GetMessageType() != WONMsg::DirG2ModifyService), (GetMessageType() == WONMsg::DirG2ModifyServiceEx));	SMsgDirG2UpdateExtendBase::Unpack();	if ((GetServiceType() != WONMsg::SmallDirServerG2) ||	    ((GetMessageType() != WONMsg::DirG2ModifyService) &&	     (GetMessageType() != WONMsg::DirG2ModifyServiceEx) &&		 (GetMessageType() != WONMsg::DirG2ModifyServiceExObsolete)))	{		WDBG_AH("SMsgDirG2ModifyService::Unpack Not a DirG2ModifyService(Ex) message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a DirG2ModifyService(Ex) message.");	}	mEntityFlags = ReadByte();	UnpackKey(*this);	ReadWString(mNewName);	unsigned char aLen = ReadByte();	WDBG_LL("SMsgDirG2ModifyService::Unpack Read New Addr len=" << aLen);	if (aLen > 0)		mNewNetAddress.assign(reinterpret_cast<const unsigned char*>(ReadBytes(aLen)), aLen);	ReadWString(mNewDisplayName);	mNewLifespan = ReadLong();	UnpackExtended();	UnpackPeerData();}

// SMsgDirG2ClearDataObjects::Unpack// Virtual method from SmallMessage.  Extracts data from message buffer.voidSMsgDirG2ClearDataObjects::Unpack(void){	WTRACE("SMsgDirG2ClearDataObjects::Unpack");	mClearTypes.clear();	mKeyType = (GetMessageType() == WONMsg::DirG2ServiceClearDataObjects ? KT_SERVICE : KT_DIRECTORY);	SMsgDirG2UpdateBase::Unpack();	if ((GetServiceType() != WONMsg::SmallDirServerG2) ||	    ((GetMessageType() != WONMsg::DirG2DirectoryClearDataObjects) &&	     (GetMessageType() != WONMsg::DirG2ServiceClearDataObjects)))	{		WDBG_AH("SMsgDirG2ClearDataObjects::Unpack Not a DirG2ClearDataObjects message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a DirG2ClearDataObjects message.");	}	UnpackKey(*this);	unsigned short aCt = ReadShort();	WDBG_LL("SMsgDirG2ClearDataObjects::Unpack Reading " << aCt << " entries.");	for (int i=0; i < aCt; i++)	{		DataObject anObj;		unsigned char aLen = ReadByte();		if (aLen > 0)			anObj.GetDataType().assign(reinterpret_cast<const unsigned char*>(ReadBytes(aLen)), aLen);		mClearTypes.insert(anObj);	}	UnpackPeerData();}

void xf_process_cliprdr_event(xfInfo* xfi, wMessage* event){	switch (GetMessageType(event->id))	{		case CliprdrChannel_MonitorReady:			xf_cliprdr_process_cb_monitor_ready_event(xfi);			break;		case CliprdrChannel_FormatList:			xf_cliprdr_process_cb_format_list_event(xfi, (RDP_CB_FORMAT_LIST_EVENT*) event);			break;		case CliprdrChannel_DataRequest:			xf_cliprdr_process_cb_data_request_event(xfi, (RDP_CB_DATA_REQUEST_EVENT*) event);			break;		case CliprdrChannel_DataResponse:			xf_cliprdr_process_cb_data_response_event(xfi, (RDP_CB_DATA_RESPONSE_EVENT*) event);			break;		default:			DEBUG_X11_CLIPRDR("unknown event type %d", GetMessageType(event->id));			break;	}}

static void cliprdr_process_event(rdpSvcPlugin* plugin, wMessage* event){	switch (GetMessageType(event->id))	{		case CliprdrChannel_FormatList:			cliprdr_process_format_list_event((cliprdrPlugin*) plugin, (RDP_CB_FORMAT_LIST_EVENT*) event);			break;		case CliprdrChannel_DataRequest:			cliprdr_process_format_data_request_event((cliprdrPlugin*) plugin, (RDP_CB_DATA_REQUEST_EVENT*) event);			break;		case CliprdrChannel_DataResponse:			cliprdr_process_format_data_response_event((cliprdrPlugin*) plugin, (RDP_CB_DATA_RESPONSE_EVENT*) event);			break;		case CliprdrChannel_FilecontentsRequest:			cliprdr_process_filecontents_request_event((cliprdrPlugin*) plugin, (RDP_CB_FILECONTENTS_REQUEST_EVENT*) event);			break;		case CliprdrChannel_FilecontentsResponse:			cliprdr_process_filecontents_response_event((cliprdrPlugin*) plugin, (RDP_CB_FILECONTENTS_RESPONSE_EVENT*) event);			break;		case CliprdrChannel_LockClipdata:			cliprdr_process_lock_clipdata_event((cliprdrPlugin*) plugin, (RDP_CB_LOCK_CLIPDATA_EVENT*) event);			break;		case CliprdrChannel_UnLockClipdata:			cliprdr_process_unlock_clipdata_event((cliprdrPlugin*) plugin, (RDP_CB_UNLOCK_CLIPDATA_EVENT*) event);			break;		case CliprdrChannel_TemporaryDirectory:			cliprdr_process_tempdir_event((cliprdrPlugin*) plugin, (RDP_CB_TEMPDIR_EVENT*) event);			break;		default:			WLog_ERR(TAG, "unknown event type %d", GetMessageType(event->id));			break;	}	freerdp_event_free(event);}

void android_process_cliprdr_event(freerdp* inst, wMessage* event){	androidContext* ctx = (androidContext*)inst->context;	clipboardContext* cb = (clipboardContext*) ctx->clipboard_context;		if (!cb)	{		return;	}		switch (GetMessageType(event->id))	{		case CliprdrChannel_MonitorReady:			android_cliprdr_process_cb_monitor_ready_event(cb);			break;		case CliprdrChannel_FormatList:			android_cliprdr_process_cb_format_list_event(cb, (RDP_CB_FORMAT_LIST_EVENT*) event);			break;		case CliprdrChannel_DataRequest:			android_cliprdr_process_cb_data_request_event(cb, (RDP_CB_DATA_REQUEST_EVENT*) event);			break;		case CliprdrChannel_DataResponse:			android_cliprdr_process_cb_data_response_event(cb, (RDP_CB_DATA_RESPONSE_EVENT*) event);			break;		default:			DEBUG_ANDROID("unknown event type %d", GetMessageType(event->id));			break;	}}

		void InfoReporter::Post()		{			MojingPlatformBase* pPlatform = MojingPlatformBase::GetPlatform();			if (pPlatform == NULL)				return;			String data = "ltype=";#ifdef MJ_OS_ANDROID			if (GetMessageType() == MSGTYPE_ACTIVE)				data += "mjsdk_active_android";			else				data += "mjsdk_error_android";#else			if (GetMessageType() == MSGTYPE_ACTIVE)				data += "mjsdk_active_ios";			else				data += "mjsdk_error_ios";#endif			char buf[32];			data += "&pid=";#ifdef REPORTER_URL_ENCRYPT 			data += BaofengEnc(pPlatform->GetAppID());			data += "&uid=";			data += BaofengEnc(pPlatform->GetUserID());			data += "&rid=";			data += BaofengEnc(pPlatform->GetRunID());			data += "&ver=";			data += BaofengEnc(pPlatform->GetAppName());			data += "&sid=";			data += BaofengEnc(pPlatform->GetChannelID());			data += "&type=";			sprintf(buf, "%d", GetReportType());			data += BaofengEnc(buf);			data += "&msg=";			data += BaofengEnc(GetReportMsg());			data += "&enc=1";#else			data += pPlatform->GetAppID(); 			data += "&uid=";			data += pPlatform->GetUserID();			data += "&rid=";			data += pPlatform->GetRunID();			data += "&ver=";			data += ConvertToUrlEncode(pPlatform->GetAppName());			data += "&sid=";			data += ConvertToUrlEncode(pPlatform->GetChannelID());			data += "&type=";			sprintf(buf, "%d", GetReportType());			data += buf;			data += "&msg=";			data += ConvertToUrlEncode(GetReportMsg());#endif			// post by thread 			ProfileThreadMGR::UpdateInternetProfile(GetClassName(), data, Profile_SAVE, InternetInfoPostCallBack, this);		}

void MMsgRoutingModifyDataObject::Unpack(void){	WTRACE("MMsgRoutingModifyDataObject::Unpack");	RoutingServerMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingModifyDataObject)	{		WDBG_AH("MMsgRoutingModifyDataObject::Unpack Not a RoutingModifyDataObject message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingModifyDataObject message.");	}	// read in the client/group id	mLinkId = ReadClientOrGroupId();		// read in the datatype size and then the datatype itself	unsigned char aDataTypeSize = ReadByte();	mDataType.assign((unsigned char*)ReadBytes(aDataTypeSize), aDataTypeSize);	// read in the offset	mOffset = ReadShort();	// read in the IsInsert flag	mIsInsert = ReadBool();		// read in the data length followed by the data itself	unsigned short aDataSize = ReadShort();	mData.assign((unsigned char*)ReadBytes(aDataSize), aDataSize);	WDBG_LL("MMsgRoutingModifyDataObject::Unpack Reading message data");}

void MMsgRoutingSendData::Unpack(void){	WTRACE("MMsgRoutingSendData::Unpack");	RoutingServerMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingSendData)	{		WDBG_AH("MMsgRoutingSendData::Unpack Not a RoutingSendData message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingSendData message.");	}	WDBG_LL("MMsgRoutingSendData::Unpack Reading message data");	// read in the flags	unsigned char aFlags = ReadByte();	mShouldSendReply     = ((aFlags & 0x01) != 0);	mIncludeExcludeFlag  = ((aFlags & 0x02) != 0);	// read in the message data	unsigned short aDataSize = ReadShort();	mData.assign(reinterpret_cast<const unsigned char*>(ReadBytes(aDataSize)), aDataSize);	// read in the address list	ReadAddresseeList(this);}

// MMsgObsSubscribeById::Unpack// Virtual method from MiniMessage.  Extracts data from message buffer.voidMMsgObsSubscribeById::Unpack(void){	WTRACE("MMsgObsSubscribeById::Unpack");	MiniMessage::Unpack();	if ((GetServiceType() != WONMsg::MiniObsServer) ||	    (GetMessageType() != WONMsg::ObsMsg_SubscribeById))	{		WDBG_AH("MMsgObsSubscribeById::Unpack Not a ObsSubscribeById message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a ObsSubscribeById message.");	}	WDBG_LL("MMsgObsSubscribeById::Unpack Reading message data");	mPublicationId = ReadLong();	mSubscriberId = ReadLong();	if (!mSubscriberId) // Optional parameters follow	{		ReadString(mSubscriberName);		ReadWString(mSubscriberDescription);		mConnectionType = (ConnectionTypeEnum)ReadShort();		ReadString(mSubscriberAddress);	}}

bool QProcessResponseThread::ParseMultipleResponseData( QByteArray &byResponse ){    bool bRet = false;    qint32 nIndex = byResponse.indexOf( Protocol::byToken );    if ( -1 == nIndex ) {        byResponse.clear( );        return bRet; // No Head    }    if ( 0 < nIndex) { // Remove        byResponse.remove( 0, nIndex );    }    qint32 nLen = Protocol::nTokenLength;    if ( nLen == byResponse.length( ) ) {        return bRet;    }    nLen += sizeof ( quint8 ); // MessageType    nLen += sizeof ( quint32 ); // TcpStreamLength    if ( nLen >= byResponse.length( ) ) {        return bRet;    }    quint32 nTotal = GetStreamLength( byResponse );    if ( nTotal > byResponse.length( ) ) {        return bRet;    }    switch ( GetMessageType( byResponse ) ) {    case Protocol::ResponseBallotSenseState :        //nLen += 2;        break;    case Protocol::ResponseGateSenseState :        //nLen += 2;        break;    case Protocol::ResponseInfraredState :        //nLen += 2;        break;    case Protocol::ResponsePlateData :        //nLen += 2;        break;    case Protocol::ResponseActiveSend :        //nLen += 2;        break;    }    ParseResponseData( byResponse );    byResponse.remove( 0, nTotal ); // Remove one Request    bRet = ( 0 < byResponse.length( ) );    return bRet;}

void MMsgRoutingUnsubscribeDataObject::Unpack(void){	WTRACE("MMsgRoutingUnsubscribeDataObject::Unpack");	RoutingServerMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingUnsubscribeDataObject)	{		WDBG_AH("MMsgRoutingUnsubscribeDataObject::Unpack Not a RoutingUnsubscribeDataObject message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingUnsubscribeDataObject message.");	}	// read in the client/group id	mLinkId = ReadClientOrGroupId();		// read in the datatype length followed by the datatype itself	unsigned char aDataTypeSize = ReadByte();	mDataType.assign((unsigned char*)ReadBytes(aDataTypeSize), aDataTypeSize);		// read in the flags	unsigned char aFlags = ReadByte();	mExactOrRecursiveFlag = ((aFlags & 0x01) != 0);	mGroupOrMembersFlag   = ((aFlags & 0x02) != 0);		WDBG_LL("MMsgRoutingUnsubscribeDataObject::Unpack Reading message data");}

// TMsgAuth1LoginRequest2::Unpack// Virtual method from TMessage.  Extracts data from message buffer.// Note: call ForceRawBufOwn() to force ownership of the data buffers.voidTMsgAuth1LoginRequest2::Unpack(void){	WTRACE("TMsgAuth1LoginRequest2::Unpack");	TMsgAuth1LoginBase2::Unpack();	if ((GetServiceType() != WONMsg::Auth1Login) ||	    (GetMessageType() != WONMsg::Auth1LoginRequest2      && GetMessageType() != WONMsg::Auth1LoginRequest223 ))	{		WDBG_AH("TMsgAuth1LoginRequest2::Unpack Not a Auth1LoginRequest message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a Auth1LoginRequest2 message.");	}}

void MMsgRoutingGetUserListReply::Unpack(void){	WTRACE("MMsgRoutingGetUserListReply::Unpack");	RoutingServerMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingGetUserListReply)	{		WDBG_AH("MMsgRoutingGetUserListReply::Unpack Not a RoutingGetUserListReply message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingGetUserListReply message.");	}	WDBG_LL("MMsgRoutingGetUserListReply::Unpack Reading message data");	// read in the status	mStatus = ReadShort();	// read in the user count	unsigned short aNumUsers = ReadShort();	// read in the user list	mUserList.clear();	for (int iUser = 0; iUser < aNumUsers; iUser++)	{		UserData aUser;		ReadUserName(aUser.mUserName);		mUserList.push_back(aUser);	}}

// TMsgDirGetDirContents::Unpack// Virtual method from TMessage.  Extracts data from message buffer.voidTMsgDirGetDirContentsReply::Unpack(void){	WTRACE("TMsgDirGetDirContentsReply::Unpack");	TMessage::Unpack();	if ((GetServiceType() != WONMsg::DirServer) ||	    (GetMessageType() != WONMsg::DirGetDirContentsReply))	{		WDBG_AH("TMsgDirGetDirContentsReply::Unpack Not a DirGetDirContentsReply message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a DirGetDirContentsReply message.");	}	WDBG_LL("TMsgDirGetDirContentsReply::Unpack Reading message data");	mStatus = static_cast<ServerStatus>(static_cast<short>(ReadShort()));	unsigned short anEntryCt = ReadShort();	WDBG_LL("TMsgDirGetDirContentsReply::Unpack Reading " << anEntryCt << "entries.");	mEntries.clear();	for (int i=0; i < anEntryCt; i++)	{		DirServerEntry anEntry;		UnpackEntry(anEntry);		mEntries.push_back(anEntry);	}}

void wf_process_cliprdr_event(wfContext *wfc, wMessage *event){	switch (GetMessageType(event->id))	{		case CliprdrChannel_ClipCaps:			wf_cliprdr_process_cb_clip_caps_event(wfc, (RDP_CB_CLIP_CAPS *)event);			break;		case CliprdrChannel_MonitorReady:			wf_cliprdr_process_cb_monitor_ready_event(wfc, (RDP_CB_MONITOR_READY_EVENT *)event);			break;		case CliprdrChannel_FormatList:			wf_cliprdr_process_cb_format_list_event(wfc, (RDP_CB_FORMAT_LIST_EVENT *) event);			break;		case CliprdrChannel_DataRequest:			wf_cliprdr_process_cb_data_request_event(wfc, (RDP_CB_DATA_REQUEST_EVENT *) event);			break;		case CliprdrChannel_DataResponse:			wf_cliprdr_process_cb_data_response_event(wfc, (RDP_CB_DATA_RESPONSE_EVENT *) event);			break;		default:			break;	}}

// SMsgDirG2GetNumEntitiesReply::Unpack// Virtual method from SmallMessage.  Extracts data from message buffer.voidSMsgDirG2GetNumEntitiesReply::Unpack(void){	WTRACE("SMsgDirG2GetNumEntitiesReply::Unpack");	SmallMessage::Unpack();	if ((GetServiceType() != WONMsg::SmallDirServerG2) ||	    (GetMessageType() != WONMsg::DirG2GetNumEntitiesReply))	{		WDBG_AH("SMsgDirG2GetNumEntitiesReply::Unpack Not a DirG2GetNumEntitiesReply message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a DirG2GetNumEntitiesReply message.");	}	WDBG_LL("SMsgDirG2GetNumEntitiesReply::Unpack Reading message data");	unsigned short anEntryCt = ReadShort();	WDBG_LL("SMsgDirG2GetNumEntitiesReply::Unpack Reading " << anEntryCt << " entries.");	mEntries.clear();	for (int i=0; i < anEntryCt; i++)	{		NumEntriesData anEntry;		mEntries.push_back(anEntry);		mEntries.back().first  = static_cast<short>(ReadShort());		mEntries.back().second = ReadShort();	}}

void MMsgRoutingCreateGroup::Unpack(void){	WTRACE("MMsgRoutingCreateGroup::Unpack");	RoutingServerMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingCreateGroup)	{		WDBG_AH("MMsgRoutingCreateGroup::Unpack Not a RoutingCreateGroup message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingCreateGroup message.");	}	WDBG_LL("MMsgRoutingCreateGroup::Unpack Reading message data");	// read in group name	ReadGroupName(mGroupName);		// read in flags	unsigned char aFlags = ReadByte();	mIsPublic             = ((aFlags & 0x01) != 0);	mAnnounceGroupChanges = ((aFlags & 0x02) != 0);	// read in client count	unsigned short aNumClients = ReadShort();	// read in client list	mClientList.clear();	for (int iClient = 0; iClient < aNumClients; iClient++)		mClientList.push_back(ReadClientId());}

// TMsgDirFindServiceReply::Unpack// Virtual method from TMessage.  Extracts data from message buffer.voidTMsgDirFindServiceReply::Unpack(void){	WTRACE("TMsgDirFindServiceReply::Unpack");	TMessage::Unpack();	if ((GetServiceType() != WONMsg::DirServer) ||	    (GetMessageType() != WONMsg::DirFindServiceReply))	{		WDBG_AH("TMsgDirFindServiceReply::Unpack Not a DirFindServiceReply message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a DirFindServiceReply message.");	}	WDBG_LL("TMsgDirFindServiceReply::Unpack Reading message data");	mStatus = static_cast<ServerStatus>(static_cast<short>(ReadShort()));	// Service data only present if status is success	if (mStatus == WONMsg::StatusCommon_Success)	{		mService.mType = DirServerEntry::EntryTypeService;		ReadWString(mService.mPath);		ReadWString(mService.mName);		ReadWString(mService.mDisplayName);		ReadWString(mService.mVersion);		ReadWString(mService.mProtoName);		ReadWString(mService.mProtoVersion);		ReadWString(mService.mNetAddress);		mService.mLifespan = ReadLong();		mService.mCreated  = ReadLong();		unsigned short aLen = ReadShort();		mService.SetBlob(ReadBytes(aLen), aLen);	}}

void CDataParser::ProcessResponse( QByteArray &byStream ){    QByteArray byToken = GetToken( byStream );    if ( byToken != Protocol::byToken ) {        return;    }    Protocol::RequestType nMessageType = ( Protocol::RequestType ) GetMessageType( byStream );    switch ( nMessageType ) {    case Protocol::ResponseBallotSenseState :        ProcessBallotSenseResponse( byStream );        break;    case Protocol::ResponseGateSenseState :        ProcessGateSenseResponse( byStream );        break;    case Protocol::ResponseInfraredState :        ProcessInfraredResponse( byStream );        break;    case Protocol::ResponsePlateData :        ProcessPlateResponse( byStream );        break;    case Protocol::ResponseActiveSend :        ProcessActiveSendResponse( byStream );        break;    }}

// TMsgCommQueryOptions::unpack// Virtual method from TMessage.  Extracts data from message buffer.voidTMsgCommQueryOptions::Unpack(void){	WTRACE("TMsgCommQueryOptions::Unpack");	mOptionList.clear();	TMessage::Unpack();	if ((GetServiceType() != WONMsg::CommonService) ||	    (GetMessageType() != WONMsg::CommQueryOptions))	{		WDBG_AH("TMsgCommRehupOptions::Unpack Not a CommQueryOptions message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a CommQueryOptions message.");	}	// Get num options	unsigned short aCt = ReadShort();	WDBG_LL("TMsgCommQueryOptions::Unpack Reading " << aCt << "entries.");	for (int i=0; i < aCt; i++)	{		string aBuf;		ReadString(aBuf);		mOptionList.push_back(aBuf);	}}

static int dvcman_push_event(IWTSVirtualChannelManager *pChannelMgr, wMessage *pEvent){	int status;	DVCMAN *dvcman = (DVCMAN *) pChannelMgr;	assert(dvcman);	status = drdynvc_push_event(dvcman->drdynvc, pEvent);	if (status == 0)	{		DEBUG_DVC("event_type %d pushed.", GetMessageType(pEvent->id));	}	else	{		DEBUG_WARN("event_type %d push failed.", GetMessageType(pEvent->id));	}	return status;}

// TMsgAuth1LoginRequest::Unpack// Virtual method from TMessage.  Extracts data from message buffer.voidTMsgAuth1LoginRequest::Unpack(void){	WTRACE("TMsgAuth1LoginRequest::Unpack");	TMsgAuth1LoginBase::Unpack();	if ((GetServiceType() != WONMsg::Auth1Login) ||	  (  GetMessageType() != WONMsg::Auth1LoginRequest	  && GetMessageType() != WONMsg::Auth1LoginRequest23))	{		WDBG_AH("TMsgAuth1LoginBase::Unpack Not a Auth1LoginRequest message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__,		                              "Not a Auth1LoginRequest message.");	}	WDBG_LL("TMsgAuth1LoginBase::Unpack Reading message data");	UnpackRawBuf();}

ssize_t RcvStandardMessage(type_t type) {		CLEAR(standardMessage);	int x = Msgrcv(SERVER_QUEUE_ID, &standardMessage, sizeof(standardMessage), type, IPC_NOWAIT);	if (x > 0) {		Printf("Recieved standard message of type %s [%s]", GetMessageType(type), standardMessage.content.sender);		} 	return x;}

ssize_t RcvCompactMessage(type_t type) {		// printf("Recieving meessage of type %d, queue id is %d/n", type, SERVER_QUEUE_ID);	CLEAR(compactMessage);	ssize_t x = Msgrcv(SERVER_QUEUE_ID, &compactMessage, sizeof(compactMessage), type, IPC_NOWAIT);	if (x > 0) {		Printf("Recieved compact message of type %s [%s]", GetMessageType(type), compactMessage.content.sender);		} 	return x;}

ssize_t Rcv(void *structure, int size, long type) {	memset(structure, 0, size);	ssize_t x = Msgrcv(SERVER_QUEUE_ID, structure, size, type, IPC_NOWAIT);	if (x > 0) {		Printf("Recieved special message of type %s", GetMessageType(type));		} 	return x;}

void SMsgCommDumpStatistics::Unpack(void){	WTRACE("SMsgCommDumpStatistics::Unpack");	SmallMessage::Unpack();	if (GetServiceType() != WONMsg::SmallCommonService ||	    GetMessageType() != WONMsg::SmallCommDumpStatistics)	{		WDBG_AH("SMsgCommDumpStatistics::Unpack Not a SMsgCommDumpStatistics message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a SMsgCommDumpStatistics message.");	}}

void MMsgRoutingInviteClient::Unpack(void){	WTRACE("MMsgRoutingInviteClient::Unpack");	RoutingServerClientNameFlagMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingInviteClient)	{		WDBG_AH("MMsgRoutingInviteClient::Unpack Not a RoutingInviteClient message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingInviteClient message.");	}}

void MMsgRoutingBecomeModerator::Unpack(void){	WTRACE("MMsgRoutingBecomeModerator::Unpack");	RoutingServerClientIdFlagMessage::Unpack();	if (GetServiceType() != WONMsg::MiniRoutingServer ||         GetMessageType() != WONMsg::RoutingBecomeModerator)	{		WDBG_AH("MMsgRoutingBecomeModerator::Unpack Not a RoutingBecomeModerator message!");		throw WONMsg::BadMsgException(*this, __LINE__, __FILE__, "Not a RoutingBecomeModerator message.");	}}