jjzjj

tcp - LwIP Netconn API + FreeRTOS TCP 客户端缓冲区问题

coder 2023-09-18 原文

我一直在尝试在 STM32F4DISCOVERY 板中使用 LwIP 修改 tcp 服务器示例。我必须编写一个不一定必须回复服务器响应的发件人。例如,它可以以 100 毫秒的频率发送数据。

首先TCP服务器的例子是这样的:

static void tcpecho_thread(void *arg)
{
  struct netconn *conn, *newconn;
  err_t err;

  LWIP_UNUSED_ARG(arg);

  /* Create a new connection identifier. */
  conn = netconn_new(NETCONN_TCP);

  if (conn!=NULL) {  
    /* Bind connection to well known port number 7. */
    err = netconn_bind(conn, NULL, DEST_PORT);

    if (err == ERR_OK) {
      /* Tell connection to go into listening mode. */
      netconn_listen(conn);

      while (1) {
        /* Grab new connection. */
        newconn = netconn_accept(conn);

        /* Process the new connection. */
        if (newconn) {
          struct netbuf *buf;
          void *data;
          u16_t len;

          while ((buf = netconn_recv(newconn)) != NULL) {
            do {
              netbuf_data(buf, &data, &len);

              //Incoming package
              .....

              //Check for data
              if (DATA IS CORRECT) 
              {
                //Reply
                data = "OK";
                len = 2;

                netconn_write(newconn, data, len, NETCONN_COPY);
              }

            } while (netbuf_next(buf) >= 0);

            netbuf_delete(buf);
          }

          /* Close connection and discard connection identifier. */
          netconn_close(newconn);
          netconn_delete(newconn);
        }
      }
    } else {
      printf(" can not bind TCP netconn");
    }
  } else {
    printf("can not create TCP netconn");
  }
}

我修改了这段代码以获得客户端版本,这是我目前得到的:

static void tcpecho_thread(void *arg)
{
  struct netconn *xNetConn = NULL;

  struct ip_addr local_ip; 
  struct ip_addr remote_ip; 
  int rc1, rc2; 

  struct netbuf *Gonderilen_Buf = NULL;
  struct netbuf *gonderilen_buf = NULL;
  void *b_data;
  u16_t b_len;

  IP4_ADDR( &local_ip, IP_ADDR0, IP_ADDR1, IP_ADDR2, IP_ADDR3 );  
  IP4_ADDR( &remote_ip, DEST_IP_ADDR0, DEST_IP_ADDR1, DEST_IP_ADDR2, DEST_IP_ADDR3 );

  xNetConn = netconn_new ( NETCONN_TCP );  
  rc1 = netconn_bind ( xNetConn, &local_ip, DEST_PORT ); 
  rc2 = netconn_connect ( xNetConn, &remote_ip, DEST_PORT );

  b_data = "+24C"; // Data to be send
  b_len = sizeof ( b_data );  

   while(1)
   {
     if ( rc1 == ERR_OK )
      {
        // If button pressed, send data "+24C" to server
        if (GPIO_ReadInputDataBit (GPIOA, GPIO_Pin_0) == Bit_SET)
        {

          Buf = netbuf_new();
          netbuf_alloc(Buf, 4); // 4 bytes of buffer
          Buf->p->payload = "+24C";
          Buf->p->len = 4;

          netconn_write(xNetConn, Buf->p->payload, b_len, NETCONN_COPY);
          vTaskDelay(100); // To see the result easily in Comm Operator

          netbuf_delete(Buf);
        }
    }
    if ( rc1 != ERR_OK || rc2 != ERR_OK )
    {
      netconn_delete ( xNetConn );
    }
  }
}

当写操作工作时,netconn_write 发送其缓冲区中的内容。它不关心 b_data 是否为 NULL。我通过添加行 b_data = NULL;

对其进行了测试

所以 Comm Operator 中的结果输出是这样的:

Rec:(02:47:27)+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C+24C

但是,我希望它像这样工作:

Rec:(02:47:22)+24C
Rec:(02:47:27)+24C 
Rec:(02:57:12)+24C 
Rec:(02:58:41)+24C

当我等待大约 8 秒后再再次按下按钮时,就会发生所需的写入操作。

由于 netconn_write 函数不允许写入缓冲区,我无法清除它。并且 netconn_send 只允许用于 UDP 连接。

我需要一些指导来理解问题并为其生成解决方案。 任何帮助将不胜感激。

最佳答案

这只是以正确方式打印结果的问题。

你可以尝试在netbuf数据结构写入之前加入这部分代码:

char buffer[20]; 

sprintf(buffer,"24+ \n");

Buf->p->payload = "+24C";

关于tcp - LwIP Netconn API + FreeRTOS TCP 客户端缓冲区问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21164367/

有关tcp - LwIP Netconn API + FreeRTOS TCP 客户端缓冲区问题的更多相关文章

  1. ruby-on-rails - 如何优雅地重启 thin + nginx? - 2

    我的瘦服务器配置了nginx,我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例,但找不到好的解决方案。有没有人能做到这一点? 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器,例如server{listen80;server

  2. ruby - 使用 `+=` 和 `send` 方法 - 2

    如何将send与+=一起使用?a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法,而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:

  3. ruby - 如何计算 Liquid 中的变量 +1 - 2

    我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止,这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量,我

  4. arrays - Ruby 数组 += vs 推送 - 2

    我有一个数组数组,想将元素附加到子数组。+=做我想做的,但我想了解为什么push不做。我期望的行为(并与+=一起工作):b=Array.new(3,[])b[0]+=["apple"]b[1]+=["orange"]b[2]+=["frog"]b=>[["苹果"],["橙子"],["Frog"]]通过推送,我将推送的元素附加到每个子数组(为什么?):a=Array.new(3,[])a[0].push("apple")a[1].push("orange")a[2].push("frog")a=>[[“苹果”、“橙子”、“Frog”]、[“苹果”、“橙子”、“Frog”]、[“苹果”、“

  5. += 的 Ruby 方法 - 2

    有没有办法让Ruby能够做这样的事情?classPlane@moved=0@x=0defx+=(v)#thisiserror@x+=v@moved+=1enddefto_s"moved#{@moved}times,currentxis#{@x}"endendplane=Plane.newplane.x+=5plane.x+=10putsplane.to_s#moved2times,currentxis15 最佳答案 您不能在Ruby中覆盖复合赋值运算符。任务在内部处理。您应该覆盖+,而不是+=。plane.a+=b与plane.a=

  6. ruby - Sinatra + Heroku + Datamapper 使用 dm-sqlite-adapter 部署问题 - 2

    出于某种原因,heroku尝试要求dm-sqlite-adapter,即使它应该在这里使用Postgres。请注意,这发生在我打开任何URL时-而不是在gitpush本身期间。我构建了一个默认的Facebook应用程序。gem文件:source:gemcuttergem"foreman"gem"sinatra"gem"mogli"gem"json"gem"httparty"gem"thin"gem"data_mapper"gem"heroku"group:productiondogem"pg"gem"dm-postgres-adapter"endgroup:development,:t

  7. ruby - 在 TCPServer (Ruby) 中,我如何从客户端获取 IP/MAC? - 2

    我想在Ruby的TCPServer中获取客户端的IP地址。以及(如果可能的话)MAC地址。例如,Ruby中的时间服务器,请参阅评论。tcpserver=TCPServer.new("",80)iftcpserverputs"Listening"loopdosocket=tcpserver.acceptifsocketThread.newdoputs"Connectedfrom"+#HERE!HowcanigettheIPAddressfromtheclient?socket.write(Time.now.to_s)socket.closeendendendend非常感谢!

  8. ruby - Ruby 中字符串运算符 + 和 << 的区别 - 2

    我是Ruby和这个网站的新手。下面两个函数是不同的,一个在函数外修改变量,一个不修改。defm1(x)x我想确保我理解正确-当调用m1时,对str的引用被复制并传递给将其视为x的函数。运算符当调用m2时,对str的引用被复制并传递给将其视为x的函数。运算符+创建一个新字符串,赋值x=x+"4"只是将x重定向到新字符串,而原始str变量保持不变。对吧?谢谢 最佳答案 String#+::str+other_str→new_strConcatenation—ReturnsanewStringcontainingother_strconc

  9. ruby - rails 3.2.2(或 3.2.1)+ Postgresql 9.1.3 + Ubuntu 11.10 连接错误 - 2

    我正在使用PostgreSQL9.1.3(x86_64-pc-linux-gnu上的PostgreSQL9.1.3,由gcc-4.6.real(Ubuntu/Linaro4.6.1-9ubuntu3)4.6.1,64位编译)和在ubuntu11.10上运行3.2.2或3.2.1。现在,我可以使用以下命令连接PostgreSQLsupostgres输入密码我可以看到postgres=#我将以下详细信息放在我的config/database.yml中并执行“railsdb”,它工作正常。开发:adapter:postgresqlencoding:utf8reconnect:falsedat

  10. ruby - 在 Ruby + Chef 中检查现有目录失败 - 2

    这是我在ChefRecipe中的一blockRuby:#ifdatadirdoesn'texist,moveoverthedefaultoneif!File.exist?("/vol/postgres/data")execute"mv/var/lib/postgresql/9.1/main/vol/postgres/data"end结果是:Executingmv/var/lib/postgresql/9.1/main/vol/postgres/datamv:inter-devicemovefailed:`/var/lib/postgresql/9.1/main'to`/vol/post

随机推荐