Форум РадиоКот

Код: Выделить всё

int32_t tcp_http_mt(uint8_t sn, uint8_t* buf, uint16_t port)
{
   int32_t ret;
   uint32_t size = 0;
   char *url,*p;

   switch(getSn_SR(sn))
   {
      case SOCK_ESTABLISHED :

         if(getSn_IR(sn) & Sn_IR_CON)
         {
            setSn_IR(sn,Sn_IR_CON);
         }

         if((size = getSn_RX_RSR(sn)) > 0)
         {
            if(size > DATA_BUF_SIZE)
            {
            	size = DATA_BUF_SIZE;
            }

            ret = recv(sn,buf,size);

            HTTP_reset(sn);

            if(ret <= 0)
            {
            	return ret;
            }

            url =(char*) buf + 4;

            if((http_state[sn]==HTTP_IDLE)&&(memcmp(buf, "GET ", 4)==0)&&((p = strchr(url, ' '))))  // extract URL from request header
            {
              *(p++) = 0;   //making zeroed url string

              sentsize[sn]=0;

              if(strcmp(url,"/")==0)
              {
                strcpy((char*)buf,http_200);
                strcat((char*)buf, http_server);
                strcat((char*)buf,"Content-Type: text/html; charset=windows-1251\r\n");
                strcat((char*)buf,"Cache-Control: no-cache\r\n");
                strcat((char*)buf,http_connection_close);
                strcat((char*)buf, http_header_end);
                strcat((char*)buf,site);
                size=strlen((char*)buf);
                http_state[sn]=HTTP_SENDING;
              }

              if(strcmp(url,"/test.png")==0)
                            {
                              strcpy((char*)buf,http_200);
                              strcat((char*)buf, http_server);
                              strcat((char*)buf,"Content-Type: image/png\r\n");
                              //
                              strcat((char*)buf,"Content-Lenght: 205\r\n");
                              strcat((char*)buf,"Connection: keep-alive\r\n");
                              strcat((char*)buf,"Keep-Alive: timeout=20\r\n");
                              strcat((char*)buf,"Accept-Ranges: bytes\r\n");
                              strcat((char*)buf,"Cache-Control: no-cache\r\n");
                              strcat((char*)buf, http_header_end);
                              strcat((char*)buf,Img);
                              size=strlen((char*)buf);
                              http_state[sn]=HTTP_SENDING;
                            }
            }

/*
           Отправляем данные пока размер отправленных данных sentsize[sn] не сравняется с размером данных size
           которые мы подготовили для отправки

... вроде бы...
*/
           if(http_state[sn]==HTTP_SENDING)
            {
        	   while (sentsize[sn] < size)
        	   {
        		  //DATA_BUF_SIZE

        		ret = send(sn,buf,size);
        	    if(ret < 0)
        	    {
        	     close(sn);
        	     return ret;
        	    }
        	    sentsize[sn] += ret; // Don't care SOCKERR_BUSY, because it is zero.
        	   }
        	  HTTP_reset(sn);
        	  disconnect(sn);
            }
          }

         break;

      case SOCK_CLOSE_WAIT :

    	  HTTP_reset(sn);

         if((ret=disconnect(sn)) != SOCK_OK)
         return ret;

         break;
      case SOCK_INIT :

    	  HTTP_reset(sn);

         if( (ret = listen(sn)) != SOCK_OK) return ret;
         break;
      case SOCK_CLOSED:

    	  HTTP_reset(sn);

         if((ret=socket(sn,Sn_MR_TCP,port,0x00)) != sn)
         return ret;

         break;

      default:
    	  HTTP_reset(sn);
         break;
   }
   return 1;
}