| 836 | } |
| 837 | |
| 838 | static void servers_open(const char *addrs, int fdtype, int nthreads) |
| 839 | { |
| 840 | const char *pri = !strcmp(acl_var_fiber_master_private, "y") ? |
| 841 | "private" : "public"; |
| 842 | char *unix_path = acl_concatenate(acl_var_fiber_queue_dir, "/", |
| 843 | pri, NULL); |
| 844 | ACL_ARGV* tokens = acl_search_addrs(addrs, unix_path); |
| 845 | int i; |
| 846 | |
| 847 | acl_myfree(unix_path); |
| 848 | |
| 849 | if (tokens == NULL) { |
| 850 | acl_msg_fatal("%s(%d), %s: can't find valid addrs from %s", |
| 851 | __FILE__, __LINE__, __FUNCTION__, addrs); |
| 852 | } |
| 853 | |
| 854 | __servers = servers_alloc(nthreads, tokens->argc, fdtype); |
| 855 | |
| 856 | for (i = 0; i < nthreads; i++) { |
| 857 | server_open(__servers[i], tokens); |
| 858 | } |
| 859 | |
| 860 | acl_argv_free(tokens); |
| 861 | } |
| 862 | |
| 863 | static void servers_start(FIBER_SERVER **servers, int nthreads) |
| 864 | { |
no test coverage detected
searching dependent graphs…