Loading include/sysutils/SocketListener.h +1 −0 Original line number Original line Diff line number Diff line Loading @@ -38,6 +38,7 @@ public: virtual ~SocketListener(); virtual ~SocketListener(); int startListener(); int startListener(); int startListener(int backlog); int stopListener(); int stopListener(); void sendBroadcast(int code, const char *msg, bool addErrno); void sendBroadcast(int code, const char *msg, bool addErrno); Loading libsysutils/src/SocketListener.cpp +5 −1 Original line number Original line Diff line number Diff line Loading @@ -70,6 +70,10 @@ SocketListener::~SocketListener() { } } int SocketListener::startListener() { int SocketListener::startListener() { return startListener(4); } int SocketListener::startListener(int backlog) { if (!mSocketName && mSock == -1) { if (!mSocketName && mSock == -1) { SLOGE("Failed to start unbound listener"); SLOGE("Failed to start unbound listener"); Loading @@ -84,7 +88,7 @@ int SocketListener::startListener() { SLOGV("got mSock = %d for %s", mSock, mSocketName); SLOGV("got mSock = %d for %s", mSock, mSocketName); } } if (mListen && listen(mSock, 4) < 0) { if (mListen && listen(mSock, backlog) < 0) { SLOGE("Unable to listen on socket (%s)", strerror(errno)); SLOGE("Unable to listen on socket (%s)", strerror(errno)); return -1; return -1; } else if (!mListen) } else if (!mListen) Loading logd/main.cpp +2 −1 Original line number Original line Diff line number Diff line Loading @@ -105,7 +105,8 @@ int main() { // and LogReader is notified to send updates to connected clients. // and LogReader is notified to send updates to connected clients. LogListener *swl = new LogListener(logBuf, reader); LogListener *swl = new LogListener(logBuf, reader); if (swl->startListener()) { // Backlog and /proc/sys/net/unix/max_dgram_qlen set to large value if (swl->startListener(300)) { exit(1); exit(1); } } Loading rootdir/init.rc +1 −0 Original line number Original line Diff line number Diff line Loading @@ -100,6 +100,7 @@ loglevel 3 write /proc/sys/kernel/dmesg_restrict 1 write /proc/sys/kernel/dmesg_restrict 1 write /proc/sys/vm/mmap_min_addr 32768 write /proc/sys/vm/mmap_min_addr 32768 write /proc/sys/net/ipv4/ping_group_range "0 2147483647" write /proc/sys/net/ipv4/ping_group_range "0 2147483647" write /proc/sys/net/unix/max_dgram_qlen 300 write /proc/sys/kernel/sched_rt_runtime_us 950000 write /proc/sys/kernel/sched_rt_runtime_us 950000 write /proc/sys/kernel/sched_rt_period_us 1000000 write /proc/sys/kernel/sched_rt_period_us 1000000 Loading Loading
include/sysutils/SocketListener.h +1 −0 Original line number Original line Diff line number Diff line Loading @@ -38,6 +38,7 @@ public: virtual ~SocketListener(); virtual ~SocketListener(); int startListener(); int startListener(); int startListener(int backlog); int stopListener(); int stopListener(); void sendBroadcast(int code, const char *msg, bool addErrno); void sendBroadcast(int code, const char *msg, bool addErrno); Loading
libsysutils/src/SocketListener.cpp +5 −1 Original line number Original line Diff line number Diff line Loading @@ -70,6 +70,10 @@ SocketListener::~SocketListener() { } } int SocketListener::startListener() { int SocketListener::startListener() { return startListener(4); } int SocketListener::startListener(int backlog) { if (!mSocketName && mSock == -1) { if (!mSocketName && mSock == -1) { SLOGE("Failed to start unbound listener"); SLOGE("Failed to start unbound listener"); Loading @@ -84,7 +88,7 @@ int SocketListener::startListener() { SLOGV("got mSock = %d for %s", mSock, mSocketName); SLOGV("got mSock = %d for %s", mSock, mSocketName); } } if (mListen && listen(mSock, 4) < 0) { if (mListen && listen(mSock, backlog) < 0) { SLOGE("Unable to listen on socket (%s)", strerror(errno)); SLOGE("Unable to listen on socket (%s)", strerror(errno)); return -1; return -1; } else if (!mListen) } else if (!mListen) Loading
logd/main.cpp +2 −1 Original line number Original line Diff line number Diff line Loading @@ -105,7 +105,8 @@ int main() { // and LogReader is notified to send updates to connected clients. // and LogReader is notified to send updates to connected clients. LogListener *swl = new LogListener(logBuf, reader); LogListener *swl = new LogListener(logBuf, reader); if (swl->startListener()) { // Backlog and /proc/sys/net/unix/max_dgram_qlen set to large value if (swl->startListener(300)) { exit(1); exit(1); } } Loading
rootdir/init.rc +1 −0 Original line number Original line Diff line number Diff line Loading @@ -100,6 +100,7 @@ loglevel 3 write /proc/sys/kernel/dmesg_restrict 1 write /proc/sys/kernel/dmesg_restrict 1 write /proc/sys/vm/mmap_min_addr 32768 write /proc/sys/vm/mmap_min_addr 32768 write /proc/sys/net/ipv4/ping_group_range "0 2147483647" write /proc/sys/net/ipv4/ping_group_range "0 2147483647" write /proc/sys/net/unix/max_dgram_qlen 300 write /proc/sys/kernel/sched_rt_runtime_us 950000 write /proc/sys/kernel/sched_rt_runtime_us 950000 write /proc/sys/kernel/sched_rt_period_us 1000000 write /proc/sys/kernel/sched_rt_period_us 1000000 Loading