プログラマ専用SNS ミクプラ

コード:

typedef struct{
	short nCol;
	char szHeader[1024];
	char szResult[1024*5];
}SQLRESULT;

コード:

//送信データの入った構造体
SQLRESULT Result;

//省略
//送信側
nRet = send(s,(char *)&Result,sizeof(SQLRESULT),0);

//受信するための構造体
SQLRESULT RecvResult;
//受信側
nRet = recv(s,(char *)&RecvResult,sizeof(SQLRESULT),0)

コード:

//送信側
int server::senddata(WPARAM wParam){
	int i,nRet,nSendSize = 0;
	int dwSize;					//送信するバイト数
	char *lptr;					//構造体の先頭アドレスを格納するポインタ

	dwSize = sizeof(SQLRESULT);//送信バイト数の計算
	lptr = (char *)&Result;    //構造体の先頭アドレスを代入

	for(i = 0;i < nConnectCount;++i){
		if((SOCKET)wParam == MemData[i].s){
			while(nSendSize <= sizeof(SQLRESULT)){
				nRet = send(MemData[i].s,lptr,dwSize,0);
				dwSize -= nRet;//送信したバイト数を減算
				lptr += nRet;  //送信した分だけポインタを進める
				nSendSize += nRet;
				if(nRet == SOCKET_ERROR)
					return -1;
			}
		}
	}
	return 0;
};

コード:

//受信側
int client::rcvData(){
	int nRcv = 0;
	char *recvptr = (char *)&Result;//ポインタの代入
	int nRcvSize = 0;
	int dwSize;

	while(nRcvSize <= sizeof(SQLRESULT)){
		nRcv = recv(s,(char *)recvptr,sizeof(SQLRESULT),0);
		nRcvSize += nRcv;			//受信バイト数を貯蓄
		recvptr += nRcv;			//受信した分ポインタを進める
		if(nRcv == SOCKET_ERROR)
			return -1;
	}
	return 0;
}

コード:

int client::rcvData(){
	int nRcv = 0;
	char *recvptr = (char *)&Result;//ポインタの代入
	int nRcvSize = 0;

	Sleep(1000);

	while(nRcvSize < sizeof(SQLRESULT)){
			nRcv = recv(s,recvptr,sizeof(SQLRESULT)-nRcvSize,0);
			if(nRcv == SOCKET_ERROR)
				return -1;
			nRcvSize += nRcv;			//受信バイト数を貯蓄
			recvptr += nRcv;			//受信した分ポインタを進める
	}
	//debug
	char szDebug[256];
	wsprintf(szDebug,"dwSize = %d, sizeof(SQLRESULT) = %d",nRcvSize,sizeof(SQLRESULT));
	MessageBox(NULL,szDebug,"クライアント側",MB_OK);
	return 0;
}

コード:

case FD_READ://データ受信通知
{
	cl.rcvData();//データ受信関数を呼び出し。これが前述したコードになります
}

コード:

case FD_READ://データ受信通知
{
     MessageBox(NULL,"debug","",MB_OK);    //MsgBox関数をrcvDataの前で呼び出す
     Sleep(50)  //もしくはスリープ関数を呼び出す
	cl.rcvData();//データ受信関数を呼び出し。これが前述したコードになります
}

コード:

	while(nRcvSize < sizeof(SQLRESULT)){
			nRcv = recv(s,recvptr,sizeof(SQLRESULT)-nRcvSize,0);
			if(nRcv == 0)				//此処を追加
				return 0;
			if(nRcv == SOCKET_ERROR)
				return -1;
			nRcvSize += nRcv;			//受信バイト数を貯蓄
			recvptr += nRcv;			//受信した分ポインタを進める
	}

コード:

//受信側
int client::rcvData(){
	int nRcv = 0;
	char *recvptr = (char *)&Result;//ポインタの代入
	int nRcvSize = 0,;
	while(nRcvSize < sizeof(SQLRESULT)){
			nRcv = recv(s,recvptr,sizeof(SQLRESULT)-nRcvSize,0);
			if(nRcv == 0){				//nRcvが0ならばループを抜ける
				break;
			}
			if(nRcv == SOCKET_ERROR){	//WSAEWOULDBLOCKでなければエラーを表示する		
				if(WSAGetLastError() != WSAEWOULDBLOCK){
					MessageBox(NULL,"データの受信でエラーが発生しました","確認",MB_OK);
					return -1;
				
				}
			}else{//エラー以外ならば処理を施す
				nRcvSize += nRcv;			//受信バイト数を貯蓄
				recvptr += nRcv;			//受信した分ポインタを進める
			}
	}
	DlgInfomation::nRcvSize = nRcvSize;		//読み込んだ値をデバックウインドウに渡す
	return 0;
}

コード:

///////////////////////////////////////////////////////////////////
//FD_READ
//
///////////////////////////////////////////////////////////////////
int client::rcvData(){
	char *rcvptr;
	int nRcv;
	int nError;
	int dwSize;
	static int nRecved;		//どこまで受信したかを記憶する変数

	//既にバッファを全て読み込んでいたら変数を初期化
	if(nRecved == sizeof(SQLRESULT)){
		nRecved = 0;
	}

	//受信バッファのポインタの代入
	rcvptr = (char *)&Result;

	//受信
	nRcv = recv(s,rcvptr + nRecved,sizeof(SQLRESULT) - nRecved,0);
	
	//ソケットエラー処理
	if(nRcv == SOCKET_ERROR){
		//エラーの取得
		nError = WSAGetLastError();
			//WSAEWOULDBLOCK以外なら-1を返して関数を抜ける
			if(nError != WSAEWOULDBLOCK)
				return -1;
			//WSAEWOULDBLOCKなら-2を返して関数を抜ける
			if(nError == WSAEWOULDBLOCK)
				return -2;
	//無事に受信できたらスタティック変数に読み込み量を追加
	}else{
		nRecved += nRcv;
	}

	//デバック情報を渡す
	DlgInfomation::nRcvSize = nRecved;

	return 0;
}