Home
last modified time | relevance | path

Searched refs:e (Results 1 – 25 of 72) sorted by relevance

123

/unit/src/
H A Dnxt_sha1.c25 ctx->e = 0xc3d2e1f0; in nxt_sha1_init()
110 result[16] = (u_char) (ctx->e >> 24); in nxt_sha1_final()
111 result[17] = (u_char) (ctx->e >> 16); in nxt_sha1_final()
112 result[18] = (u_char) (ctx->e >> 8); in nxt_sha1_final()
113 result[19] = (u_char) ctx->e; in nxt_sha1_final()
158 uint32_t a, b, c, d, e, temp; in nxt_sha1_body() local
170 e = ctx->e; in nxt_sha1_body()
177 saved_e = e; in nxt_sha1_body()
194 STEP(F1, a, b, c, d, e, words[0], 0x5a827999); in nxt_sha1_body()
282 e += saved_e; in nxt_sha1_body()
[all …]
H A Dnxt_lvlhsh.c100 (((e)[0] | (e)[1]) != 0)
104 (void *) (((uintptr_t) (e)[1] << 32) + (e)[0])
113 (e)[2]
117 (e)[2] = n
122 ((e)[0] != 0)
126 (void *) (e)[0]
134 (e)[1]
138 (e)[1] = n
237 e = bucket; in nxt_lvlhsh_bucket_find()
366 e = bucket; in nxt_lvlhsh_bucket_insert()
[all …]
H A Dnxt_app_nncq.h104 nxt_app_nncq_atomic_t n, t, e, j; in nxt_app_nncq_enqueue() local
109 e = q->entries[j]; in nxt_app_nncq_enqueue()
111 e_cycle = nxt_app_nncq_cycle(q, e); in nxt_app_nncq_enqueue()
125 if (nxt_atomic_cmp_set(&q->entries[j], e, n)) { in nxt_app_nncq_enqueue()
138 nxt_app_nncq_atomic_t h, j, e; in nxt_app_nncq_dequeue() local
143 e = q->entries[j]; in nxt_app_nncq_dequeue()
145 e_cycle = nxt_app_nncq_cycle(q, e); in nxt_app_nncq_dequeue()
161 return nxt_app_nncq_index(q, e); in nxt_app_nncq_dequeue()
H A Dnxt_nncq.h101 nxt_nncq_atomic_t n, t, e, j; in nxt_nncq_enqueue() local
106 e = q->entries[j]; in nxt_nncq_enqueue()
108 e_cycle = nxt_nncq_cycle(q, e); in nxt_nncq_enqueue()
122 if (nxt_atomic_cmp_set(&q->entries[j], e, n)) { in nxt_nncq_enqueue()
135 nxt_nncq_atomic_t h, j, e; in nxt_nncq_dequeue() local
140 e = q->entries[j]; in nxt_nncq_dequeue()
142 e_cycle = nxt_nncq_cycle(q, e); in nxt_nncq_dequeue()
158 return nxt_nncq_index(q, e); in nxt_nncq_dequeue()
H A Dnxt_nvbcq.h116 nxt_nvbcq_atomic_t h, t, i, e; in nxt_nvbcq_dequeue() local
123 e = q->entries[i]; in nxt_nvbcq_dequeue()
125 if (e < NXT_NVBCQ_SIZE in nxt_nvbcq_dequeue()
126 && nxt_atomic_cmp_set(&q->entries[i], e, NXT_NVBCQ_SIZE)) in nxt_nvbcq_dequeue()
130 return e; in nxt_nvbcq_dequeue()
H A Dnxt_conn.h278 nxt_event_engine_t *e = engine; \
280 c->socket.read_work_queue = &e->read_work_queue; \
282 nxt_work_queue_add(&e->read_work_queue, c->io->read, \
289 nxt_event_engine_t *e = engine; \
291 c->socket.write_work_queue = &e->write_work_queue; \
293 nxt_work_queue_add(&e->write_work_queue, c->io->write, \
300 nxt_event_engine_t *e = engine; \
302 nxt_queue_insert_head(&e->idle_connections, &c->link); \
305 e->idle_conns_cnt++; \
311 nxt_event_engine_t *e = engine; \
[all …]
/unit/src/java/nginx/unit/
H A DSession.java128 HttpSessionBindingEvent e = new HttpSessionBindingEvent(this, s); in setAttribute() local
130 l.valueBound(e); in setAttribute()
143 HttpSessionBindingEvent e = new HttpSessionBindingEvent(this, s); in setAttribute() local
145 l.valueUnbound(e); in setAttribute()
155 attr_listener.attributeRemoved(e); in setAttribute()
163 attr_listener.attributeReplaced(e); in setAttribute()
166 attr_listener.attributeAdded(e); in setAttribute()
190 l.valueUnbound(e); in removeAttribute()
197 HttpSessionBindingEvent e = new HttpSessionBindingEvent(this, s, o); in removeAttribute() local
198 attr_listener.attributeRemoved(e); in removeAttribute()
[all …]
H A DContext.java977 } catch (Throwable e) { in service()
1573 } catch(Exception e) {
2688 throw e;
2690 throw e;
2724 throw e;
2726 throw e;
2812 throw e;
2814 throw e;
2845 throw e;
2847 throw e;
[all …]
/unit/src/java/nginx/unit/websocket/server/
H A DDefaultServerEndpointConfigurator.java37 } catch (InstantiationException e) { in getEndpointInstance()
38 throw e; in getEndpointInstance()
39 } catch (ReflectiveOperationException e) { in getEndpointInstance()
41 ie.initCause(e); in getEndpointInstance()
64 for (Extension e : installed) { in getNegotiatedExtensions()
65 installedNames.add(e.getName()); in getNegotiatedExtensions()
H A DWsSci.java87 } catch (ReflectiveOperationException e) { in onStartup()
88 throw new ServletException(e); in onStartup()
122 } catch (DeploymentException e) { in onStartup()
123 throw new ServletException(e); in onStartup()
H A DWsHttpUpgradeHandler.java125 } catch (DeploymentException e) { in init()
126 throw new IllegalArgumentException(e); in init()
141 } catch (Exception e) { in destroy()
142 log.error(sm.getString("wsHttpUpgradeHandler.destroyFailed"), e); in destroy()
/unit/auto/modules/
H A Dperl11 -*=*) value=`echo "$nxt_option" | sed -e 's/[-_a-zA-Z0-9]*=//'` ;;
57 if /bin/sh -c "$NXT_PERL -MConfig -e 'print \"Perl version: \",
60 NXT_PERL_CFLAGS=`$NXT_PERL -MExtUtils::Embed -e ccflags | sed -e 's/^ //;s/ $//'`
61 NXT_PERL_INCLUDE=`$NXT_PERL -MExtUtils::Embed -e perl_inc | sed -e 's/^ //;s/ $//'`
62 NXT_PERL_LDOPTS=`$NXT_PERL -MExtUtils::Embed -e ldopts | sed -e 's/^ //;s/ $//'`
67 | sed -e 's/-arch i386//' -e 's/-arch x86_64//'`
83 char argv[] = \"\\0-e\\00\";
H A Druby11 -*=*) value=`echo "$nxt_option" | sed -e 's/[-_a-zA-Z0-9]*=//'` ;;
60 NXT_RUBY_RUBYHDRDIR=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["rubyhdrdir"]'`
61 NXT_RUBY_ARCHHDRDIR=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["rubyarchhdrdir"]'`
62 NXT_RUBY_SITEDIR=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["sitedir"]'`
63 NXT_RUBY_LIBDIR=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["rubylibdir"]'`
64 NXT_RUBY_TOPDIR=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["topdir"]'`
65 NXT_RUBY_PREFIXDIR=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["rubylibprefix"]'`
67 NXT_RUBY_GEMPATH=`$NXT_RUBY -rrubygems -e 'print Gem.default_path().join(":")'`
71 NXT_RUBY_LIBNAME=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["RUBY_SO_NAME"]'`
72 NXT_RUBY_LIBSCONF=`$NXT_RUBY -rrbconfig -e 'print RbConfig::CONFIG["LIBS"]'`
[all …]
/unit/src/java/nginx/unit/websocket/
H A DWsFrameClient.java53 } catch (IOException e) { in startInputProcessing()
54 close(e); in startInputProcessing()
210 } catch (IOException e) { in resumeProcessing()
219 log.debug(sm.getString("wsFrameClient.ioe"), e); in resumeProcessing()
221 close(e); in resumeProcessing()
224 close(e); in resumeProcessing()
H A DWsRemoteEndpointImplClient.java63 } catch (InterruptedException | ExecutionException | TimeoutException e) { in doWrite()
64 handler.onResult(new SendResult(e)); in doWrite()
H A DUtil.java152 } catch (NoSuchAlgorithmException e) { in generateMask()
252 } catch (ClassNotFoundException e) { in getGenericType()
253 throw new IllegalArgumentException(e); in getGenericType()
346 } catch (ReflectiveOperationException e) { in getDecoders()
349 decoderClazz.getName()), e); in getDecoders()
469 } catch (DeploymentException e) { in matchDecoders()
470 throw new IllegalArgumentException(e); in matchDecoders()
557 } catch (NoSuchMethodException | SecurityException e) { in getOnMessageMethod()
559 sm.getString("util.invalidMessageHandler"), e); in getOnMessageMethod()
566 } catch (NoSuchMethodException | SecurityException e) { in getOnMessagePartialMethod()
[all …]
/unit/test/ruby/errors_write_to_s_custom/
H A Dconfig.ru9 e = Custom.new()
11 env['rack.errors'].write(e)
/unit/auto/
H A Dmake312 sed -e "s|%%ERROR_LOG_PATH%%|$NXT_LOG|" \\
313 -e "s|%%PID_PATH%%|$NXT_PID|" \\
314 -e "s|%%SOCKET_PATH%%|$NXT_CONTROL|" \\
444 sed -e "s|@PREFIX@|$NXT_PREFIX|" \\
445 -e "s|@LIBDIR@|$NXT_LIBDIR|" \\
446 -e "s|@CFLAGS@|-I$NXT_INCLUDEDIR|" \\
447 -e "s|@VERSION@|\$(NXT_VERSION)|" \\
449 -e "s|@CONFARGS@|$(echo $NXT_CONFIGURE_OPTIONS | sed -e 's| -pie||' -e 's| --njs||')|" \\
450 -e "s|@MODULESDIR@|$NXT_MODULESDIR|" \\
457 -e "s|@VERSION@|\$(NXT_VERSION)|" \\
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp195 } catch (exception &e) { in init() local
196 napi.throw_error(e); in init()
237 } catch (exception &e) { in create() local
238 napi.throw_error(e); in create()
261 } catch (exception &e) { in create_server() local
262 napi.throw_error(e); in create_server()
338 } catch (exception &e) { in request_handler() local
379 } catch (exception &e) { in websocket_handler() local
424 } catch (exception &e) { in close_handler() local
464 } catch (exception &e) { in shm_ack_handler() local
[all …]
H A Dwebsocket_server.js166 catch(e) {
168 e.httpCode ? e.httpCode : 400,
169 e.message,
170 e.headers
/unit/test/go/404/
H A Dapp.go11 b, e := ioutil.ReadFile("404.html")
13 if e == nil {
/unit/go/
H A Dobservable.go23 func (o *observable) notify(e int) {
28 v <- e
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoEndpointBase.java69 } catch (IllegalAccessException e) { in doOnOpen()
73 pojo.getClass().getName()), e); in doOnOpen()
74 handleOnOpenOrCloseError(session, e); in doOnOpen()
75 } catch (InvocationTargetException e) { in doOnOpen()
76 Throwable cause = e.getCause(); in doOnOpen()
H A DPojoEndpointServer.java46 } catch (InstantiationException e) { in onOpen()
49 sec.getEndpointClass().getName()), e); in onOpen()
/unit/test/java/websockets_mirror/
H A Dapp.java24 } catch (IOException e) { in echoTextMessage()
39 } catch (IOException e) { in echoBinaryMessage()

123