diff options
Diffstat (limited to 'openbsc/src/bsc_msc.c')
| -rw-r--r-- | openbsc/src/bsc_msc.c | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/openbsc/src/bsc_msc.c b/openbsc/src/bsc_msc.c index 3ecd13170..362450fa5 100644 --- a/openbsc/src/bsc_msc.c +++ b/openbsc/src/bsc_msc.c @@ -163,6 +163,13 @@ int bsc_msc_connect(struct bsc_msc_connection *con) /* make it non blocking */ setnonblocking(fd); + /* set the socket priority */ + ret = setsockopt(fd->fd, IPPROTO_IP, IP_TOS, + &con->prio, sizeof(con->prio)); + if (ret != 0) + LOGP(DMSC, LOGL_ERROR, "Failed to set prio to %d. %s\n", + con->prio, strerror(errno)); + memset(&sin, 0, sizeof(sin)); sin.sin_family = AF_INET; sin.sin_port = htons(con->port); @@ -201,7 +208,7 @@ int bsc_msc_connect(struct bsc_msc_connection *con) } -struct bsc_msc_connection *bsc_msc_create(const char *ip, int port) +struct bsc_msc_connection *bsc_msc_create(const char *ip, int port, int prio) { struct bsc_msc_connection *con; @@ -213,6 +220,7 @@ struct bsc_msc_connection *bsc_msc_create(const char *ip, int port) con->ip = ip; con->port = port; + con->prio = prio; write_queue_init(&con->write_queue, 100); con->write_queue.except_cb = bsc_msc_except; return con; |