|
@@ -4029,6 +4029,15 @@ static void master_thread(struct mg_context *ctx) {
|
|
struct socket *sp;
|
|
struct socket *sp;
|
|
int max_fd;
|
|
int max_fd;
|
|
|
|
|
|
|
|
+#if defined(ISSUE_317)
|
|
|
|
+ // Increase priority of the master thread
|
|
|
|
+ struct sched_param sched_param;
|
|
|
|
+ int policy;
|
|
|
|
+ pthread_getschedparam(pthread_self(), &policy, &sched_param);
|
|
|
|
+ sched_param.sched_priority = sched_get_priority_max(policy);
|
|
|
|
+ pthread_setschedparam(pthread_self(), policy, &sched_param);
|
|
|
|
+#endif
|
|
|
|
+
|
|
while (ctx->stop_flag == 0) {
|
|
while (ctx->stop_flag == 0) {
|
|
FD_ZERO(&read_set);
|
|
FD_ZERO(&read_set);
|
|
max_fd = -1;
|
|
max_fd = -1;
|