← Back to branch summary

~ubuntu-branches/ubuntu/utopic/haproxy/utopic-proposed

« back to all changes in this revision

Viewing changes to src/proto_uxst.c

  • Committer: Bazaar Package Importer
  • Author(s): Arnaud Cornet
  • Date: 2008-08-30 18:06:31 UTC
  • mfrom: (1.1.4 upstream) (2.1.1 lenny)
  • Revision ID: james.westby@ubuntu.com-20080830180631-l8aev9t9naanfc05
http://bugs.debian.org/497186
New Upstream Version (Closes: #497186).

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/proto_uxst.c
1
1
/*
2
2
 * UNIX SOCK_STREAM protocol layer (uxst)
3
3
 *
4
 
 * Copyright 2000-2007 Willy Tarreau <w@1wt.eu>
 
4
 * Copyright 2000-2008 Willy Tarreau <w@1wt.eu>
5
5
 *
6
6
 * This program is free software; you can redistribute it and/or
7
7
 * modify it under the terms of the GNU General Public License
917
917
                                 */
918
918
                                /* let's try to offer this slot to anybody */
919
919
                                if (may_dequeue_tasks(t->srv, t->be))
920
 
                                        task_wakeup(t->srv->queue_mgt);
 
920
                                        process_srv_queue(t->srv);
921
921
 
922
922
                                if (t->srv)
923
923
                                        t->srv->failed_conns++;
1004
1004
                         * we have to inform the server that it may be used by another session.
1005
1005
                         */
1006
1006
                        if (may_dequeue_tasks(t->srv, t->be))
1007
 
                                task_wakeup(t->srv->queue_mgt);
 
1007
                                process_srv_queue(t->srv);
1008
1008
 
1009
1009
                        return 1;
1010
1010
                }
1112
1112
                         * we have to inform the server that it may be used by another session.
1113
1113
                         */
1114
1114
                        if (may_dequeue_tasks(t->srv, t->be))
1115
 
                                task_wakeup(t->srv->queue_mgt);
 
1115
                                process_srv_queue(t->srv);
1116
1116
 
1117
1117
                        return 1;
1118
1118
                }
1128
1128
                         * we have to inform the server that it may be used by another session.
1129
1129
                         */
1130
1130
                        if (may_dequeue_tasks(t->srv, t->be))
1131
 
                                task_wakeup(t->srv->queue_mgt);
 
1131
                                process_srv_queue(t->srv);
1132
1132
 
1133
1133
                        return 1;
1134
1134
                }
1148
1148
                         * we have to inform the server that it may be used by another session.
1149
1149
                         */
1150
1150
                        if (may_dequeue_tasks(t->srv, t->be))
1151
 
                                task_wakeup(t->srv->queue_mgt);
 
1151
                                process_srv_queue(t->srv);
1152
1152
 
1153
1153
                        return 1;
1154
1154
                }
1187
1187
                         * we have to inform the server that it may be used by another session.
1188
1188
                         */
1189
1189
                        if (may_dequeue_tasks(t->srv, t->be))
1190
 
                                task_wakeup(t->srv->queue_mgt);
 
1190
                                process_srv_queue(t->srv);
1191
1191
 
1192
1192
                        return 1;
1193
1193
                }
1203
1203
                         * we have to inform the server that it may be used by another session.
1204
1204
                         */
1205
1205
                        if (may_dequeue_tasks(t->srv, t->be))
1206
 
                                task_wakeup(t->srv->queue_mgt);
 
1206
                                process_srv_queue(t->srv);
1207
1207
 
1208
1208
                        return 1;
1209
1209
                }
1223
1223
                         * we have to inform the server that it may be used by another session.
1224
1224
                         */
1225
1225
                        if (may_dequeue_tasks(t->srv, t->be))
1226
 
                                task_wakeup(t->srv->queue_mgt);
 
1226
                                process_srv_queue(t->srv);
1227
1227
 
1228
1228
                        return 1;
1229
1229
                }