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

Commit 581edc1b authored by Mark Salyzyn's avatar Mark Salyzyn
Browse files

set /proc/sys/net/unix/max_dgram_qlen to large value 

- init: set /proc/sys/net/unix/max_dgram_qlen to 300
- libsysutils: Add listen backlog argument to startListener
- logd: set listen backlog to 300

Change-Id: Id6d37d6c937ba2d221e76258d89c9516619caeec
parent ba23d539

include/sysutils/SocketListener.h

+1 −0
Original line number Original line Diff line number Diff line
@@ -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);

libsysutils/src/SocketListener.cpp

+5 −1
Original line number Original line Diff line number Diff line
@@ -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");
@@ -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)

logd/main.cpp

+2 −1
Original line number Original line Diff line number Diff line
@@ -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);

    }

    }

rootdir/init.rc

+1 −0
Original line number Original line Diff line number Diff line
@@ -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