Home
last modified time | relevance | path

Searched refs:add (Results 1 – 25 of 37) sorted by relevance

12

/unit/src/
H A Dnxt_atomic.h37 #define nxt_atomic_fetch_add(value, add) \ argument
38 __sync_fetch_and_add(value, add)
83 #define nxt_atomic_fetch_add(value, add) \ argument
84 (atomic_add_long_nv(value, add) - add)
185 #define nxt_atomic_fetch_add(value, add) \ argument
186 __fetch_and_addlp(value, add)
212 #define nxt_atomic_fetch_add(value, add) \ argument
213 __fetch_and_add(value, add)
H A Dnxt_timer.c164 nxt_timer_change_t *ch, *end, *add, *add_end; in nxt_timer_changes_commit() local
173 add = ch; in nxt_timer_changes_commit()
174 add_end = add; in nxt_timer_changes_commit()
212 while (add < add_end) { in nxt_timer_changes_commit()
213 timer = add->timer; in nxt_timer_changes_commit()
221 add++; in nxt_timer_changes_commit()
H A Dnxt_conf.h98 nxt_bool_t add);
/unit/src/java/nginx/unit/websocket/
H A DUtil.java163 randoms.add(sr); in generateMask()
353 result.add(entry); in getDecoders()
374 results.add(result); in getMessageHandlers()
379 results.add(result); in getMessageHandlers()
384 results.add(result); in getMessageHandlers()
398 results.add(result); in getMessageHandlers()
406 results.add(result); in getMessageHandlers()
414 results.add(result); in getMessageHandlers()
427 results.add(result); in getMessageHandlers()
436 results.add(result); in getMessageHandlers()
[all …]
H A DPerMessageDeflate.java275 params.add(new WsExtensionParameter(SERVER_NO_CONTEXT_TAKEOVER, null)); in getExtensionResponse()
278 params.add(new WsExtensionParameter(SERVER_MAX_WINDOW_BITS, in getExtensionResponse()
282 params.add(new WsExtensionParameter(CLIENT_NO_CONTEXT_TAKEOVER, null)); in getExtensionResponse()
285 params.add(new WsExtensionParameter(CLIENT_MAX_WINDOW_BITS, in getExtensionResponse()
327 allCompressedParts.add(uncompressedPart); in sendMessagePart()
331 allCompressedParts.add(uncompressedPart); in sendMessagePart()
429 compressedParts.add(compressedPart); in sendMessagePart()
H A DWsExtension.java34 parameters.add(parameter); in addParameter()
H A DWsWebSocketContainer.java272 originValues.add(Constants.DEFAULT_ORIGIN_HEADER_VALUE); in connectToServerRecursive()
469 wrapper.add(extension.getParameters()); in connectToServerRecursive()
596 wsSessions.add(wsSession); in registerSession()
648 hostValues.add(host); in createRequestHeaders()
650 hostValues.add(host + ':' + port); in createRequestHeaders()
657 upgradeValues.add(Constants.UPGRADE_HEADER_VALUE); in createRequestHeaders()
662 connectionValues.add(Constants.CONNECTION_HEADER_VALUE); in createRequestHeaders()
667 wsVersionValues.add(Constants.WS_VERSION_HEADER_VALUE); in createRequestHeaders()
672 wsKeyValues.add(generateWsKeyValue()); in createRequestHeaders()
704 result.add(header.toString()); in generateExtensionHeaders()
[all …]
H A DConstants.java150 installed.add(new WsExtension("permessage-deflate")); in installed.add()
H A DBackgroundProcessManager.java68 processes.add(process); in register()
H A DWsSession.java313 result.add(binaryMessageHandler); in getMessageHandlers()
316 result.add(textMessageHandler); in getMessageHandlers()
319 result.add(pongMessageHandler); in getMessageHandlers()
/unit/test/
H A Dtest_proxy_chunked.py56 add = ''
60 add = m1.group(1) * int(m1.group(2))
62 add = line
64 req = req + add + '\r\n'
H A Dtest_perl_application.py285 threads.add(resp['headers']['X-Thread'])
H A Dtest_python_procman.py28 pids.add(re.search(r'^\s*(\d+)', m).group(1))
H A Dtest_asgi_application.py413 threads.add(resp['headers']['x-thread'])
/unit/src/java/nginx/unit/
H A DJspPropertyGroup.java35 url_patterns_.add(node.getTextContent().trim()); in JspPropertyGroup()
60 include_preludes_.add(node.getTextContent().trim()); in JspPropertyGroup()
65 include_codas_.add(node.getTextContent().trim()); in JspPropertyGroup()
H A DContext.java383 url_list.add(u); in loadApp()
1229 filters_.add(reg); in processWebXml()
1337 servlets_.add(reg); in processWebXml()
1627 dtypes.add(d);
2093 filters_.add(fmap);
2953 res.add(r);
3127 filters_.add(reg);
3140 filters_.add(reg);
3153 filters_.add(reg);
3169 servlets_.add(reg);
[all …]
/unit/src/java/nginx/unit/websocket/server/
H A DWsSci.java74 serverApplicationConfigs.add( in onStartup()
81 scannedEndpointClazzes.add(endpoint); in onStartup()
84 scannedPojoEndpoints.add(clazz); in onStartup()
H A DDefaultServerEndpointConfigurator.java65 installedNames.add(e.getName()); in getNegotiatedExtensions()
70 result.add(request); in getNegotiatedExtensions()
H A DUpgradeUtil.java142 negotiatedExtensionsPhase2.add(t.getExtensionResponse()); in doUpgrade()
209 preferences.add(extension.getParameters()); in createTransformations()
216 result.add(transformation); in createTransformations()
273 result.add(token.trim()); in getTokensFromHeader()
H A DUriTemplate.java83 if (!paramNames.add(segment)) { in UriTemplate()
94 this.segments.add(new Segment(index, segment)); in UriTemplate()
H A DWsWriteTimeout.java85 boolean result = endpoints.add(endpoint); in register()
H A DWsServerContainer.java164 if (!templateMatches.add(new TemplatePathMatch(sec, uriTemplate))) { in addEndpoint()
376 wsSessions.add(wsSession); in registerAuthenticatedSession()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMethodMapping.java660 results.add(mh); in getMessageHandlers()
665 results.add(mh); in getMessageHandlers()
670 results.add(mh); in getMessageHandlers()
675 results.add(mh); in getMessageHandlers()
680 results.add(mh); in getMessageHandlers()
688 results.add(mh); in getMessageHandlers()
695 results.add(mh); in getMessageHandlers()
700 results.add(mh); in getMessageHandlers()
708 results.add(mh); in getMessageHandlers()
713 results.add(mh); in getMessageHandlers()
[all …]
H A DPojoMessageHandlerWholeBinary.java71 decoders.add(decoder); in PojoMessageHandlerWholeBinary()
77 decoders.add(decoder); in PojoMessageHandlerWholeBinary()
H A DPojoMessageHandlerWholeText.java80 decoders.add(decoder); in PojoMessageHandlerWholeText()
86 decoders.add(decoder); in PojoMessageHandlerWholeText()

12