Searched refs:worker (Results 1 - 25 of 41) sorted by relevance

12

/macosx-10.10/apache-793/httpd/modules/proxy/balancers/
H A Dmod_lbmethod_bybusyness.c26 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 Dmod_lbmethod_bytraffic.c26 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 Dmod_lbmethod_byrequests.c26 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 Dmod_lbmethod_heartbeat.c35 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 DPoll.c44 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 Dmod_lbmethod_rr.c46 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 DNullTransactionRunner.java23 public void run(TransactionWorker worker) argument
27 worker.doWork();
/macosx-10.10/WebCore-7600.1.25/workers/
H A DSharedWorker.cpp62 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 DWorker.cpp82 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 DSharedWorkerRepository.cpp44 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 DDefaultSharedWorkerRepository.cpp95 // 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 Dmod_proxy_balancer.c32 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 Dmod_proxy_balancer.c.orig32 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 Dproxy_util.c878 * 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 Dmod_proxy.c59 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 Dmod_proxy_ajp.c218 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 Dmod_proxy.h138 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 Dmod_proxy_wstunnel.c167 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 DJSWorkerCustom.cpp64 RefPtr<Worker> worker = Worker::create(*window.document(), scriptURL, ec); local
70 return JSValue::encode(asObject(toJS(exec, jsConstructor->globalObject(), worker.release())));
H A DJSSharedWorkerCustom.cpp68 // 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 DTransactionRunner.java216 public void run(TransactionWorker worker) argument
229 worker.doWork();
268 worker.doWork();
/macosx-10.10/ruby-106/ruby/lib/test/
H A Dunit.rb372 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 DHelloDatabaseWorld.java61 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 DRepmgrElectionTest.java57 // 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 DThreaded.pm37 my $child=threads->new(\&worker,$proxy,$conn);
56 sub worker { subroutine

Completed in 241 milliseconds

12