Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit f2aa91b5 authored by Treehugger Robot's avatar Treehugger Robot Committed by Automerger Merge Worker
Browse files

Merge "Properly clear pfds in btif_sock_thread" am: 8253ea30 am: 030df0ac... 

Merge "Properly clear pfds in btif_sock_thread" am: 8253ea30 am: 030df0ac am: 94f9e481 am: a4b24462

Original change: https://android-review.googlesource.com/c/platform/packages/modules/Bluetooth/+/2122377



Change-Id: Ief73bc7ccf4e0c563d1e9e349b461e449f380fcb
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents f21f646c a4b24462

system/btif/src/btif_sock_thread.cc

+8 −6
Original line number Diff line number Diff line
@@ -46,6 +46,7 @@ 
#include <time.h>

#include <unistd.h>



#include <array>

#include <mutex>

#include <optional>

#include <string>
@@ -480,7 +481,6 @@ static void prepare_poll_fds(int h, struct pollfd* pfds) { 
  int ps_i = 0;

  int pfd_i = 0;

  asrt(ts[h].poll_count <= MAX_POLL);

  memset(pfds, 0, sizeof(pfds[0]) * ts[h].poll_count);

  while (count < ts[h].poll_count) {

    if (ps_i >= MAX_POLL) {

      APPL_TRACE_ERROR(
@@ -499,13 +499,14 @@ static void prepare_poll_fds(int h, struct pollfd* pfds) { 
  }

}

static void* sock_poll_thread(void* arg) {

  struct pollfd pfds[MAX_POLL];

  memset(pfds, 0, sizeof(pfds));

  std::array<struct pollfd, MAX_POLL> pfds;



  int h = (intptr_t)arg;

  for (;;) {

    prepare_poll_fds(h, pfds);

    pfds = {};

    prepare_poll_fds(h, pfds.data());

    int ret;

    OSI_NO_INTR(ret = poll(pfds, ts[h].poll_count, -1));

    OSI_NO_INTR(ret = poll(pfds.data(), ts[h].poll_count, -1));

    if (ret == -1) {

      APPL_TRACE_ERROR("poll ret -1, exit the thread, errno:%d, err:%s", errno,

                       strerror(errno));
@@ -526,7 +527,8 @@ static void* sock_poll_thread(void* arg) { 
        else

          ret--;  // exclude the cmd fd

      }

      if (need_process_data_fd) process_data_sock(h, pfds, pfds_count, ret);

      if (need_process_data_fd)

        process_data_sock(h, pfds.data(), pfds_count, ret);

    } else {

      LOG_INFO("no data, select ret: %d", ret);

    };