* @brief 設(shè)置Socket作為服務(wù)器等待遠(yuǎn)程主機的連接
*當(dāng)本機Socket工作在服務(wù)器模式時,引用該程序,等等遠(yuǎn)程主機的連接
*
*該程序只調(diào)用一次,就使W5100設(shè)置為服務(wù)器模式
* @return 如果設(shè)置成功則返回true, 否則返回false
**/
unsigned char Socket_Listen(SOCKET s)
{
Write_W5100((W5100_S0_MR+s*0x100), S_MR_TCP); /*設(shè)置socket為TCP模式 */
Write_W5100(W5100_S0_PORT,S0_Port[0]); /* Set source Socket Port number */
Write_W5100(W5100_S0_PORT+1,S0_Port[1]);
Write_W5100((W5100_S0_CR+s*0x100), S_CR_OPEN); /*打開Socket*/
if(Read_W5100(W5100_S0_SSR+s*0x100)!=S_SSR_INIT)
{
Write_W5100((W5100_S0_CR+s*0x100),S_CR_CLOSE); /*打開不成功,關(guān)閉Socket,然后返回*/
return FALSE;
}
Write_W5100((W5100_S0_CR+s*0x100), S_CR_LISTEN); /*設(shè)置Socket為偵聽模式*/
if(Read_W5100(W5100_S0_SSR+s*0x100)!=S_SSR_LISTEN)
{
Write_W5100((W5100_S0_CR+s*0x100), S_CR_CLOSE); /*設(shè)置不成功,關(guān)閉Socket,然后返回*/
return FALSE;
}
return TRUE;
/*至此完成了Socket的打開和設(shè)置偵聽工作,至于遠(yuǎn)程客戶端是否與它建立連接,則需要等待Socket中斷,
以判斷Socket的連接是否成功。參考W5100數(shù)據(jù)手冊的Socket中斷狀態(tài)
在服務(wù)器偵聽模式不需要設(shè)置目的IP和目的端口號*/
}
/**
* @brief 設(shè)置Socket為UDP模式
*如果Socket工作在UDP模式,引用該程序。在UDP模式下,Socket通信不需要建立連接
*該程序只調(diào)用一次,就使W5100設(shè)置為UDP模式
* @return 如果設(shè)置成功則返回true, 否則返回false
**/
unsigned char Socket_UDP(SOCKET s)
{
Write_W5100((W5100_S0_MR+s*0x100), S_MR_UDP); /*設(shè)置Socket為UDP模式*/
Write_W5100((W5100_S0_CR+s*0x100), S_CR_OPEN); /*打開Socket*/
if(Read_W5100(W5100_S0_SSR+s*0x100)!=S_SSR_UDP)
{
Write_W5100((W5100_S0_CR+s*0x100), S_CR_CLOSE); /*打開不成功,關(guān)閉Socket,然后返回*/
return FALSE;
}
else
return TRUE;
/*至此完成了Socket的打開和UDP模式設(shè)置,在這種模式下它不需要與遠(yuǎn)程主機建立連接
因為Socket不需要建立連接,所以在發(fā)送數(shù)據(jù)前都可以設(shè)置目的主機IP和目的Socket的端口號
如果目的主機IP和目的Socket的端口號是固定的,在運行過程中沒有改變,那么也可以在這里設(shè)置*/
}
/**
* @brief 處理Socket接收和發(fā)送的數(shù)據(jù)
*如果Socket產(chǎn)生接收數(shù)據(jù)的中斷,則引用該程序進行處理
*該程序?qū)ocket的接收到的數(shù)據(jù)緩存到Rx_buffer數(shù)組中,并返回接收的數(shù)據(jù)字節(jié)數(shù)
* @return 數(shù)據(jù)長度
**/
unsigned short S_rx_process(SOCKET s)
{
unsigned short i,j;
unsigned short rx_size,rx_offset;
/*讀取接收數(shù)據(jù)的字節(jié)數(shù)*/
rx_size=Read_W5100(W5100_S0_RX_RSR+s*0x100);
rx_size*=256;
rx_size+=Read_W5100(W5100_S0_RX_RSR+s*0x100+1);
/*讀取接收緩沖區(qū)的偏移量*/
rx_offset=Read_W5100(W5100_S0_RX_RR+s*0x100);
rx_offset*=256;
rx_offset+=Read_W5100(W5100_S0_RX_RR+s*0x100+1);
i=rx_offset/S_RX_SIZE; /*計算實際的物理偏移量,S0_RX_SIZE需要在前面#define中定義*/
/*注意S_RX_SIZE的值在W5100_Init()函數(shù)的W5100_RMSR中確定*/
rx_offset=rx_offset-i*S_RX_SIZE;
j=W5100_RX+s*S_RX_SIZE+rx_offset; /*實際物理地址為W5100_RX+rx_offset*/
for(i=0;i《rx_size;i++)
{
if(rx_offset》=S_RX_SIZE)
{
j=W5100_RX+s*S_RX_SIZE;
rx_offset=0;
}
Rx_Buffer=Read_W5100(j); /*將數(shù)據(jù)緩存到Rx_buffer數(shù)組中*/
j++;
rx_offset++;
}
/*計算下一次偏移量*/
rx_offset=Read_W5100(W5100_S0_RX_RR+s*0x100);
rx_offset*=256;
rx_offset+=Read_W5100(W5100_S0_RX_RR+s*0x100+1);
rx_offset+=rx_size;
Write_W5100((W5100_S0_RX_RR+s*0x100), (rx_offset/256));
Write_W5100((W5100_S0_RX_RR+s*0x100+1), rx_offset);
Write_W5100((W5100_S0_CR+s*0x100), S_CR_RECV); /*設(shè)置RECV命令,等等下一次接收*/
return rx_size; /*返回接收的數(shù)據(jù)字節(jié)數(shù)*/
}
/**
* @brief 如果要通過Socket發(fā)送數(shù)據(jù),則引用該程序
*要發(fā)送的數(shù)據(jù)緩存在Tx_buffer中, size則是要發(fā)送的字節(jié)長度
* @author stmsky
* @param[in] socket nummber
* @param[out] none
* @return
* @note
**/
unsigned char S_tx_process(SOCKET s, unsigned int size)
{
unsigned short i,j;
unsigned short tx_free_size,tx_offset;
/*如果是UDP模式,可以在此設(shè)置目的主機的IP和端口號*/
if((Read_W5100(W5100_S0_MR+s*0x100)&0x0f)==0x02)
{
for(i=0;i《4;i++) /* 設(shè)置目的主機IP*/
Write_W5100((W5100_S0_DIPR+s*0x100+i), UDP_DIPR);
Write_W5100((W5100_S0_DPORT+s*0x100), UDP_DPORT[0]);
Write_W5100((W5100_S0_DPORT+s*0x100+1), UDP_DPORT[1]);
}
/*讀取緩沖區(qū)剩余的長度*/
tx_free_size=Read_W5100(W5100_S0_TX_FSR+s*0x100);
tx_free_size*=256;
tx_free_size+=Read_W5100(W5100_S0_TX_FSR+s*0x100+1);
if(tx_free_size《size) /*如果剩余的字節(jié)長度小于發(fā)送字節(jié)長度,則返回*/
return FALSE;
/*讀取發(fā)送緩沖區(qū)的偏移量*/
tx_offset=Read_W5100(W5100_S0_TX_WR+s*0x100);
tx_offset*=256;
tx_offset+=Read_W5100(W5100_S0_TX_WR+s*0x100+1);
i=tx_offset/S_TX_SIZE; /*計算實際的物理偏移量,S0_TX_SIZE需要在前面#define中定義*/
/*注意S0_TX_SIZE的值在W5100_Init()函數(shù)的W5100_TMSR中確定*/
tx_offset=tx_offset-i*S_TX_SIZE;
j=W5100_TX+s*S_TX_SIZE+tx_offset; /*實際物理地址為W5100_TX+tx_offset*/
for(i=0;i《size;i++)
{
if(tx_offset》=S_TX_SIZE)
{
j=W5100_TX+s*S_TX_SIZE;
tx_offset=0;
}
Write_W5100(j,Tx_Buffer); /*將Tx_buffer緩沖區(qū)中的數(shù)據(jù)寫入到發(fā)送緩沖區(qū)*/
j++;
tx_offset++;
}
/*計算下一次的偏移量*/
tx_offset=Read_W5100(W5100_S0_TX_WR+s*0x100);
tx_offset*=256;
tx_offset+=Read_W5100(W5100_S0_TX_WR+s*0x100+1);
tx_offset+=size;
Write_W5100((W5100_S0_TX_WR+s*0x100),(tx_offset/256));
Write_W5100((W5100_S0_TX_WR+s*0x100+1),tx_offset);
Write_W5100((W5100_S0_CR+s*0x100), S_CR_SEND); /*設(shè)置SEND命令,啟動發(fā)送*/
return TRUE; /*返回成功*/
}
/**
* @brief W5100中斷處理程序框架
* @note
**/
void W5100_Interrupt_Process(void)
{
unsigned char i,j;
W5100_Interrupt=0;
i=Read_W5100(W5100_IR);
Write_W5100(W5100_IR, (i&0xf0)); /*回寫清除中斷標(biāo)志*/
//GPIO_SetBits(GPIOB, GPIO_Pin_0);
if((i & IR_CONFLICT) == IR_CONFLICT) /*IP地址沖突異常處理,自己添加代碼*/
{
}
if((i & IR_UNREACH) == IR_UNREACH) /*UDP模式下地址無法到達異常處理,自己添加代碼*/
{
}
/* Socket事件處理 */
if((i & IR_S0_INT) == IR_S0_INT)
{
j=Read_W5100(W5100_S0_IR);
Write_W5100(W5100_S0_IR, j); /* 回寫清中斷標(biāo)志 */
if(j&S_IR_CON) /* 在TCP模式下,Socket0成功連接 */
{
S0_State|=S_CONN;
}
if(j&S_IR_DISCON) /* 在TCP模式下Socket斷開連接處理,自己添加代碼 */
{
Write_W5100(W5100_S0_CR, S_CR_CLOSE); /* 關(guān)閉端口,等待重新打開連接 */
S0_State=0;
}
if(j&S_IR_SENDOK) /* Socket0數(shù)據(jù)發(fā)送完成,可以再次啟動S_tx_process()函數(shù)發(fā)送數(shù)據(jù) */
{
S0_Data|=S_TRANSMITOK;
}
if(j&S_IR_RECV) /* Socket接收到數(shù)據(jù),可以啟動S_rx_process()函數(shù) */
{
S0_Data|=S_RECEIVE;
}
if(j&S_IR_TIMEOUT) /* Socket連接或數(shù)據(jù)傳輸超時處理 */
{
Write_W5100(W5100_S0_CR, S_CR_CLOSE); /* 關(guān)閉端口,等待重新打開連接 */
S0_State=0;
}
}
/* Socket1事件處理 */
if((i&IR_S1_INT)==IR_S1_INT)
{
j=Read_W5100(W5100_S1_IR);
Write_W5100(W5100_S1_IR, j); /* 回寫清中斷標(biāo)志 */
}
/* Socket2事件處理 */
if((i&IR_S2_INT)==IR_S2_INT)
{
j=Read_W5100(W5100_S2_IR);
Write_W5100(W5100_S2_IR, j); /*回寫清中斷標(biāo)志 */
}
/* Socket3事件處理 */
if((i&IR_S3_INT)==IR_S3_INT)
{
j=Read_W5100(W5100_S3_IR);
Write_W5100(W5100_S3_IR, j); /* 回寫清中斷標(biāo)志 */
}
}
void main(void)
{
W5100_Init();
Socket_Init(0);
Socket_Listen(0);
while(1)
{
W5100_Interrupt_Process();
if(S0_State==S_CONN) break;
}
while(1)
{
}
}
評論
查看更多