• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1  /*
2   * Copyright (C) 2008 The Android Open Source Project
3   *
4   * Licensed under the Apache License, Version 2.0 (the "License");
5   * you may not use this file except in compliance with the License.
6   * You may obtain a copy of the License at
7   *
8   *      http://www.apache.org/licenses/LICENSE-2.0
9   *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  #include <errno.h>
17  
18  #include <sys/types.h>
19  #include <sys/socket.h>
20  #include <linux/netlink.h>
21  #include <string.h>
22  
23  #define LOG_TAG "NetlinkListener"
24  #include <cutils/log.h>
25  #include <cutils/uevent.h>
26  
27  #include <sysutils/NetlinkEvent.h>
28  
29  #if 1
30  /* temporary version until we can get Motorola to update their
31   * ril.so.  Their prebuilt ril.so is using this private class
32   * so changing the NetlinkListener() constructor breaks their ril.
33   */
NetlinkListener(int socket)34  NetlinkListener::NetlinkListener(int socket) :
35                              SocketListener(socket, false) {
36      mFormat = NETLINK_FORMAT_ASCII;
37  }
38  #endif
39  
NetlinkListener(int socket,int format)40  NetlinkListener::NetlinkListener(int socket, int format) :
41                              SocketListener(socket, false), mFormat(format) {
42  }
43  
onDataAvailable(SocketClient * cli)44  bool NetlinkListener::onDataAvailable(SocketClient *cli)
45  {
46      int socket = cli->getSocket();
47      ssize_t count;
48      uid_t uid = -1;
49  
50      bool require_group = true;
51      if (mFormat == NETLINK_FORMAT_BINARY_UNICAST) {
52          require_group = false;
53      }
54  
55      count = TEMP_FAILURE_RETRY(uevent_kernel_recv(socket,
56              mBuffer, sizeof(mBuffer), require_group, &uid));
57      if (count < 0) {
58          if (uid > 0)
59              LOG_EVENT_INT(65537, uid);
60          SLOGE("recvmsg failed (%s)", strerror(errno));
61          return false;
62      }
63  
64      NetlinkEvent *evt = new NetlinkEvent();
65      if (evt->decode(mBuffer, count, mFormat)) {
66          onEvent(evt);
67      } else if (mFormat != NETLINK_FORMAT_BINARY) {
68          // Don't complain if parseBinaryNetlinkMessage returns false. That can
69          // just mean that the buffer contained no messages we're interested in.
70          SLOGE("Error decoding NetlinkEvent");
71      }
72  
73      delete evt;
74      return true;
75  }
76