/macosx-10.10/apache-793/httpd/modules/proxy/balancers/ |
H A D | mod_lbmethod_bybusyness.c | 26 proxy_worker *worker, server_rec *s) = NULL; 33 proxy_worker **worker; local 61 worker = (proxy_worker **)balancer->workers->elts; 62 for (i = 0; i < balancer->workers->nelts; i++, worker++) { 64 if ((*worker)->s->lbset > max_lbset) 65 max_lbset = (*worker)->s->lbset; 68 ((*worker)->s->lbset != cur_lbset) || 69 (checking_standby ? !PROXY_WORKER_IS_STANDBY(*worker) : PROXY_WORKER_IS_STANDBY(*worker)) || 70 (PROXY_WORKER_IS_DRAINING(*worker)) 125 proxy_worker **worker; local [all...] |
H A D | mod_lbmethod_bytraffic.c | 26 proxy_worker *worker, server_rec *s) = NULL; 32 * worker. We normalize that traffic by each workers' weight. So assuming 35 * worker a b c 38 * the scheduler will allow worker c to handle 3 times the 51 proxy_worker **worker; local 75 worker = (proxy_worker **)balancer->workers->elts; 76 for (i = 0; i < balancer->workers->nelts; i++, worker++) { 78 if ((*worker)->s->lbset > max_lbset) 79 max_lbset = (*worker)->s->lbset; 82 ((*worker) 127 proxy_worker **worker; local [all...] |
H A D | mod_lbmethod_byrequests.c | 26 proxy_worker *worker, server_rec *s) = NULL; 31 * lbfactor is "how much we expect this worker to work", or "the worker's 34 * lbstatus is "how urgent this worker has to work to fulfill its quota 37 * We distribute each worker's work quota to the worker, and then look 39 * worker is then selected for work, and its lbstatus reduced by the 48 * worker a b c d 57 * worker a b c d 63 * worker 79 proxy_worker **worker; local 154 proxy_worker **worker; local [all...] |
H A D | mod_lbmethod_heartbeat.c | 35 proxy_worker *worker, server_rec *s) = NULL; 56 proxy_worker *worker; member in struct:hb_server_t 265 proxy_worker **worker; local 302 worker = &APR_ARRAY_IDX(balancer->workers, i, proxy_worker *); 303 server = apr_hash_get(servers, (*worker)->s->hostname, APR_HASH_KEY_STRING); 307 "lb_heartbeat: No server for worker %s", (*worker)->s->name); 311 if (!PROXY_WORKER_IS_USABLE(*worker)) { 312 ap_proxy_retry_worker_fn("BALANCER", *worker, r->server); 315 if (PROXY_WORKER_IS_USABLE(*worker)) { [all...] |
/macosx-10.10/mDNSResponder-561.1.1/mDNSWindows/ |
H A D | Poll.c | 44 struct Worker_struct *worker; member in struct:PollSource_struct 52 HANDLE thread; // NULL for main worker 53 unsigned id; // 0 for main worker 55 HANDLE start; // NULL for main worker 56 HANDLE stop; // NULL for main worker 57 BOOL done; // Not used for main worker 90 mDNSlocal void PollRemoveWorker( Worker *worker ); 97 mDNSlocal mStatus WorkerInit( Worker *worker ); 98 mDNSlocal void WorkerFree( Worker *worker ); 99 mDNSlocal void WorkerRegisterSource( Worker *worker, PollSourc 310 Worker *worker = NULL; local 392 Worker *worker; local 435 Worker *worker; local 517 WorkerRegisterSource( Worker *worker, PollSource *source ) argument 527 WorkerSourceToIndex( Worker *worker, PollSource *source ) argument 549 WorkerUnregisterSource( Worker *worker, PollSource *source ) argument 685 Worker *worker = ( Worker* ) inParam; local [all...] |
/macosx-10.10/apache-793/httpd/modules/proxy/examples/ |
H A D | mod_lbmethod_rr.c | 46 proxy_worker **worker; local 73 worker = (proxy_worker **)balancer->workers->elts; 75 for (i = 0; i < balancer->workers->nelts; i++, worker++) { 79 (checking_standby ? !PROXY_WORKER_IS_STANDBY(*worker) : PROXY_WORKER_IS_STANDBY(*worker)) || 80 (PROXY_WORKER_IS_DRAINING(*worker)) 84 if (!PROXY_WORKER_IS_USABLE(*worker)) 85 ap_proxy_retry_worker("BALANCER", *worker, r->server); 86 if (PROXY_WORKER_IS_USABLE(*worker)) { 87 mycandidate = *worker; [all...] |
/macosx-10.10/BerkeleyDB-21/db/test/scr024/src/com/sleepycat/collections/test/ |
H A D | NullTransactionRunner.java | 23 public void run(TransactionWorker worker) argument 27 worker.doWork();
|
/macosx-10.10/WebCore-7600.1.25/workers/ |
H A D | SharedWorker.cpp | 62 RefPtr<SharedWorker> worker = adoptRef(new SharedWorker(context)); local 65 worker->m_port = channel->port1(); 69 worker->suspendIfNeeded(); 71 URL scriptURL = worker->resolveURL(url, ec); 80 SharedWorkerRepository::connect(worker.get(), WTF::move(remotePort), scriptURL, name, ec); 82 return worker.release();
|
H A D | Worker.cpp | 82 RefPtr<Worker> worker = adoptRef(new Worker(context)); local 84 worker->suspendIfNeeded(); 86 URL scriptURL = worker->resolveURL(url, ec); 90 // The worker context does not exist while loading, so we must ensure that the worker object is not collected, nor are its event listeners. 91 worker->setPendingActivity(worker.get()); 93 worker->m_scriptLoader = WorkerScriptLoader::create(); 94 worker->m_scriptLoader->loadAsynchronously(&context, scriptURL, DenyCrossOriginRequests, worker [all...] |
H A D | SharedWorkerRepository.cpp | 44 void SharedWorkerRepository::connect(PassRefPtr<SharedWorker> worker, std::unique_ptr<MessagePortChannel> port, const URL& url, const String& name, ExceptionCode& ec) argument 46 DefaultSharedWorkerRepository::instance().connectToWorker(worker, WTF::move(port), url, name, ec);
|
H A D | DefaultSharedWorkerRepository.cpp | 95 // Updates the list of the worker's documents, per section 4.5 of the WebWorkers spec. 100 // Removes a detached document from the list of worker's documents. May set the closing flag if this is the last document in the list. 103 GroupSettings* groupSettings() const; // Page GroupSettings used by worker thread. 116 // Ensures exclusive access to the worker documents. Must not grab any other locks (such as the DefaultSharedWorkerRepository lock) while holding this one. 250 // Stop the worker thread - the proxy will stay around until we get workerThreadExited() notification. 272 // Loads the script on behalf of a worker. 289 SharedWorkerScriptLoader::SharedWorkerScriptLoader(PassRefPtr<SharedWorker> worker, std::unique_ptr<MessagePortChannel> port, PassRefPtr<SharedWorkerProxy> proxy) argument 290 : m_worker(worker) 317 // Hand off the just-loaded code to the repository to start up the worker thread. 391 void DefaultSharedWorkerRepository::connectToWorker(PassRefPtr<SharedWorker> worker, st argument [all...] |
/macosx-10.10/apache-793/httpd/modules/proxy/ |
H A D | mod_proxy_balancer.c | 32 proxy_worker *worker, server_rec *s) = NULL; 119 proxy_worker *worker = *workers; local 122 ap_proxy_worker_name(p, worker)); 123 worker_is_initialized = PROXY_WORKER_IS_INITIALIZED(worker); 125 ap_proxy_initialize_worker(worker, s, p); 202 /* Find the worker that has the 'route' defined 217 proxy_worker *worker = *workers; local 218 if ( (checking_standby ? !PROXY_WORKER_IS_STANDBY(worker) : PROXY_WORKER_IS_STANDBY(worker)) ) 220 if (*(worker 275 proxy_worker *worker = NULL; local 386 rewrite_url(request_rec *r, proxy_worker *worker, char **url) argument 411 proxy_worker **worker; local 444 proxy_worker *worker = worker_; local 453 proxy_balancer_pre_request(proxy_worker **worker, proxy_balancer **balancer, request_rec *r, proxy_server_conf *conf, char **url) argument 621 proxy_balancer_post_request(proxy_worker *worker, proxy_balancer *balancer, request_rec *r, proxy_server_conf *conf) argument 813 proxy_worker *worker; local 988 proxy_worker *worker, *wsel = NULL; local [all...] |
H A D | mod_proxy_balancer.c.orig | 32 proxy_worker *worker, server_rec *s) = NULL; 119 proxy_worker *worker = *workers; 122 ap_proxy_worker_name(p, worker)); 123 worker_is_initialized = PROXY_WORKER_IS_INITIALIZED(worker); 125 ap_proxy_initialize_worker(worker, s, p); 202 /* Find the worker that has the 'route' defined 217 proxy_worker *worker = *workers; 218 if ( (checking_standby ? !PROXY_WORKER_IS_STANDBY(worker) : PROXY_WORKER_IS_STANDBY(worker)) ) 220 if (*(worker [all...] |
H A D | proxy_util.c | 878 * find the particulars of the actual worker which may 885 proxy_worker **worker = (proxy_worker **)balancer->workers->elts; local 899 l2 = strlen((*worker)->s->name); 902 if ((*worker)->s->name[l2 - 1] == '/') 905 && strncasecmp((*worker)->s->name, url, l2) == 0 912 else if (l1 >= l2 && strncasecmp((*worker)->s->name, url, l2) == 0) { 921 worker++; 1276 * mutex and then attach to the shared worker shm 1321 proxy_worker *worker = (proxy_worker *)theworker; local 1322 if (worker 1328 init_conn_pool(apr_pool_t *p, proxy_worker *worker) argument 1353 proxy_worker *worker = conn->worker; local 1450 proxy_worker *worker = (proxy_worker *)params; local 1497 ap_proxy_worker_name(apr_pool_t *p, proxy_worker *worker) argument 1512 proxy_worker *worker; local 1596 ap_proxy_define_worker(apr_pool_t *p, proxy_worker **worker, proxy_balancer *balancer, proxy_server_conf *conf, const char *url, int do_malloc) argument 1871 ap_proxy_retry_worker(const char *proxy_function, proxy_worker *worker, server_rec *s) argument 1895 ap_proxy_pre_request(proxy_worker **worker, proxy_balancer **balancer, request_rec *r, proxy_server_conf *conf, char **url) argument 1953 ap_proxy_post_request(proxy_worker *worker, proxy_balancer *balancer, request_rec *r, proxy_server_conf *conf) argument 2052 ap_proxy_acquire_connection(const char *proxy_function, proxy_conn_rec **conn, proxy_worker *worker, server_rec *s) argument 2139 ap_proxy_determine_connection(apr_pool_t *p, request_rec *r, proxy_server_conf *conf, proxy_worker *worker, proxy_conn_rec *conn, apr_uri_t *uri, char **url, const char *proxyname, apr_port_t proxyport, char *server_portstr, int server_portstr_size) argument 2519 ap_proxy_connect_backend(const char *proxy_function, proxy_conn_rec *conn, proxy_worker *worker, server_rec *s) argument 2959 proxy_worker *worker = *workers; local 2999 ap_proxy_find_workershm(ap_slotmem_provider_t *storage, ap_slotmem_instance_t *slot, proxy_worker *worker, unsigned int *index) argument 3108 ap_proxy_create_hdrbrgd(apr_pool_t *p, apr_bucket_brigade *header_brigade, request_rec *r, proxy_conn_rec *p_conn, proxy_worker *worker, proxy_server_conf *conf, apr_uri_t *uri, char *url, char *server_portstr, char **old_cl_val, char **old_te_val) argument [all...] |
H A D | mod_proxy.c | 59 proxy_worker *worker, 71 worker->s->lbfactor = atoi(val); 72 if (worker->s->lbfactor < 1 || worker->s->lbfactor > 100) 76 /* If set it will give the retry timeout for the worker 83 worker->s->retry = apr_time_from_sec(ival); 84 worker->s->retry_set = 1; 93 worker->s->ttl = apr_time_from_sec(ival); 101 worker->s->min = ival; 109 worker 58 set_worker_param(apr_pool_t *p, proxy_worker *worker, const char *key, const char *val) argument 925 proxy_worker *worker = NULL; local 1604 proxy_worker *worker = ap_proxy_get_worker(cmd->temp_pool, NULL, conf, de_socketfy(cmd->pool, r)); local 2028 proxy_worker *worker; local 2128 proxy_worker *worker = NULL; local 2226 proxy_worker *worker = NULL; local 2501 proxy_worker **worker = NULL; local 2595 proxy_worker *worker; local [all...] |
H A D | mod_proxy_ajp.c | 218 conn->worker->cp->addr, 219 conn->worker->s->hostname); 227 * case we can dare to retry it with a different worker if we are 302 conn->worker->cp->addr, 303 conn->worker->s->hostname); 310 conn->worker->s->transferred += bufsiz; 342 conn->worker->cp->addr, 343 conn->worker->s->hostname); 347 * but doesn't affect the whole worker. 349 if (APR_STATUS_IS_TIMEUP(status) && conn->worker 696 proxy_ajp_handler(request_rec *r, proxy_worker *worker, proxy_server_conf *conf, char *url, const char *proxyname, apr_port_t proxyport) argument [all...] |
H A D | mod_proxy.h | 138 proxy_worker *forward; /* forward proxy worker */ 139 proxy_worker *reverse; /* reverse "module-driven" proxy worker */ 241 proxy_worker *worker; /* Connection pool this connection belongs to */ member in struct:__anon6341 273 /* worker status bits */ 284 /* worker status flags */ 308 /* default worker retry timeout in seconds */ 341 /* Runtime worker status informations. Shared in scoreboard */ 349 char uds_path[PROXY_WORKER_MAX_NAME_SIZE]; /* path to worker's unix domain socket if applicable */ 351 int retries; /* number of retries on this worker */ 359 proxy_hashes hash; /* hash of worker nam [all...] |
H A D | mod_proxy_wstunnel.c | 167 proxy_worker *worker, 195 worker, conf, uri, url, server_portstr, 322 static int proxy_wstunnel_handler(request_rec *r, proxy_worker *worker, argument 351 status = ap_proxy_acquire_connection(scheme, &backend, worker, 368 status = ap_proxy_determine_connection(p, r, conf, worker, backend, 377 if (ap_proxy_connect_backend(scheme, backend, worker, r->server)) { 392 status = ap_proxy_wstunnel_request(p, r, backend, worker, conf, uri, locurl, 165 ap_proxy_wstunnel_request(apr_pool_t *p, request_rec *r, proxy_conn_rec *conn, proxy_worker *worker, proxy_server_conf *conf, apr_uri_t *uri, char *url, char *server_portstr) argument
|
/macosx-10.10/WebCore-7600.1.25/bindings/js/ |
H A D | JSWorkerCustom.cpp | 64 RefPtr<Worker> worker = Worker::create(*window.document(), scriptURL, ec); local 70 return JSValue::encode(asObject(toJS(exec, jsConstructor->globalObject(), worker.release())));
|
H A D | JSSharedWorkerCustom.cpp | 68 // FIXME: We need to use both the dynamic scope and the lexical scope (dynamic scope for resolving the worker URL) 72 RefPtr<SharedWorker> worker = SharedWorker::create(*window.document(), scriptURL, name, ec); local 78 return JSValue::encode(asObject(toJS(exec, jsConstructor->globalObject(), worker.release())));
|
/macosx-10.10/BerkeleyDB-21/db/java/src/com/sleepycat/collections/ |
H A D | TransactionRunner.java | 216 public void run(TransactionWorker worker) argument 229 worker.doWork(); 268 worker.doWork();
|
/macosx-10.10/ruby-106/ruby/lib/test/ |
H A D | unit.rb | 372 def after_worker_down(worker, e=nil, c=false) 378 warn "Some worker was crashed. It seems ruby interpreter's bug" 449 def after_worker_quit(worker) 452 @workers.delete(worker) 453 @dead_workers << worker 459 worker = Worker.launch(@options[:ruby],@args) 463 worker.hook(:dead) do |w,info| 465 after_worker_down w, *info if !info.empty? && !worker.quit_called 467 @workers << worker 468 @ios << worker [all...] |
/macosx-10.10/BerkeleyDB-21/db/examples_java/src/collections/hello/ |
H A D | HelloDatabaseWorld.java | 61 HelloDatabaseWorld worker = new HelloDatabaseWorld(env); 65 runner.run(worker); 68 worker.close();
|
/macosx-10.10/BerkeleyDB-21/db/test/scr016/src/com/sleepycat/db/test/ |
H A D | RepmgrElectionTest.java | 57 // start the worker threads 59 RepmgrElectionTest worker = new RepmgrElectionTest(i); 60 worker.run(); 61 workers.add(worker); 92 TestUtils.DEBUGOUT(1, "Creating worker: " + threadNumber); 188 * End worker thread implementation
|
/macosx-10.10/CPANInternal-159.1/HTTP-Proxy-0.25/lib/HTTP/Proxy/Engine/ |
H A D | Threaded.pm | 37 my $child=threads->new(\&worker,$proxy,$conn); 56 sub worker { subroutine
|