* @brief 設置Socket作為服務器等待遠程主機的連接
*當本機Socket工作在服務器模式時,引用該程序,等等遠程主機的連接
*
*該程序只調用一次,就使W5100設置為服務器模式
* @return 如果設置成功則返回true, 否則返回false
**/
unsigned char Socket_Listen(SOCKET s)
{
Write_W5100((W5100_S0_MR+s*0x100), S_MR_TCP); /*設置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); /*打開不成功,關閉Socket,然后返回*/
return FALSE;
}
Write_W5100((W5100_S0_CR+s*0x100), S_CR_LISTEN); /*設置Socket為偵聽模式*/
if(Read_W5100(W5100_S0_SSR+s*0x100)!=S_SSR_LISTEN)
{
Write_W5100((W5100_S0_CR+s*0x100), S_CR_CLOSE); /*設置不成功,關閉Socket,然后返回*/
return FALSE;
}
return TRUE;
/*至此完成了Socket的打開和設置偵聽工作,至于遠程客戶端是否與它建立連接,則需要等待Socket中斷,
以判斷Socket的連接是否成功。參考W5100數據手冊的Socket中斷狀態
在服務器偵聽模式不需要設置目的IP和目的端口號*/
}
/**
* @brief 設置Socket為UDP模式
*如果Socket工作在UDP模式,引用該程序。在UDP模式下,Socket通信不需要建立連接
*該程序只調用一次,就使W5100設置為UDP模式
* @return 如果設置成功則返回true, 否則返回false
**/
unsigned char Socket_UDP(SOCKET s)
{
Write_W5100((W5100_S0_MR+s*0x100), S_MR_UDP); /*設置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); /*打開不成功,關閉Socket,然后返回*/
return FALSE;
}
else
return TRUE;
/*至此完成了Socket的打開和UDP模式設置,在這種模式下它不需要與遠程主機建立連接
因為Socket不需要建立連接,所以在發送數據前都可以設置目的主機IP和目的Socket的端口號
如果目的主機IP和目的Socket的端口號是固定的,在運行過程中沒有改變,那么也可以在這里設置*/
}
/**
* @brief 處理Socket接收和發送的數據
*如果Socket產生接收數據的中斷,則引用該程序進行處理
*該程序將Socket的接收到的數據緩存到Rx_buffer數組中,并返回接收的數據字節數
* @return 數據長度
**/
unsigned short S_rx_process(SOCKET s)
{
unsigned short i,j;
unsigned short rx_size,rx_offset;
/*讀取接收數據的字節數*/
rx_size=Read_W5100(W5100_S0_RX_RSR+s*0x100);
rx_size*=256;
rx_size+=Read_W5100(W5100_S0_RX_RSR+s*0x100+1);
/*讀取接收緩沖區的偏移量*/
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()函數的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); /*將數據緩存到Rx_buffer數組中*/
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); /*設置RECV命令,等等下一次接收*/
return rx_size; /*返回接收的數據字節數*/
}
/**
* @brief 如果要通過Socket發送數據,則引用該程序
*要發送的數據緩存在Tx_buffer中, size則是要發送的字節長度
* @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模式,可以在此設置目的主機的IP和端口號*/
if((Read_W5100(W5100_S0_MR+s*0x100)&0x0f)==0x02)
{
for(i=0;i《4;i++) /* 設置目的主機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]);
}
/*讀取緩沖區剩余的長度*/
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) /*如果剩余的字節長度小于發送字節長度,則返回*/
return FALSE;
/*讀取發送緩沖區的偏移量*/
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()函數的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緩沖區中的數據寫入到發送緩沖區*/
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); /*設置SEND命令,啟動發送*/
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)); /*回寫清除中斷標志*/
//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); /* 回寫清中斷標志 */
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); /* 關閉端口,等待重新打開連接 */
S0_State=0;
}
if(j&S_IR_SENDOK) /* Socket0數據發送完成,可以再次啟動S_tx_process()函數發送數據 */
{
S0_Data|=S_TRANSMITOK;
}
if(j&S_IR_RECV) /* Socket接收到數據,可以啟動S_rx_process()函數 */
{
S0_Data|=S_RECEIVE;
}
if(j&S_IR_TIMEOUT) /* Socket連接或數據傳輸超時處理 */
{
Write_W5100(W5100_S0_CR, S_CR_CLOSE); /* 關閉端口,等待重新打開連接 */
S0_State=0;
}
}
/* Socket1事件處理 */
if((i&IR_S1_INT)==IR_S1_INT)
{
j=Read_W5100(W5100_S1_IR);
Write_W5100(W5100_S1_IR, j); /* 回寫清中斷標志 */
}
/* Socket2事件處理 */
if((i&IR_S2_INT)==IR_S2_INT)
{
j=Read_W5100(W5100_S2_IR);
Write_W5100(W5100_S2_IR, j); /*回寫清中斷標志 */
}
/* Socket3事件處理 */
if((i&IR_S3_INT)==IR_S3_INT)
{
j=Read_W5100(W5100_S3_IR);
Write_W5100(W5100_S3_IR, j); /* 回寫清中斷標志 */
}
}
void main(void)
{
W5100_Init();
Socket_Init(0);
Socket_Listen(0);
while(1)
{
W5100_Interrupt_Process();
if(S0_State==S_CONN) break;
}
while(1)
{
}
}
評論
查看更多