| /dports/www/squid/squid-4.15/src/esi/ |
| H A D | Include.cc | 80 assert (receivedData.length <= sizeof(esiStream->localbuffer->buf)); in esiBufferRecipient()
83 …debugs (86,5, HERE << "rep " << rep << " body " << receivedData.data << " len " << receivedData.le… in esiBufferRecipient()
84 assert (node->readBuffer.offset == receivedData.offset || receivedData.length == 0); in esiBufferRecipient()
109 if (receivedData.data && receivedData.length) { in esiBufferRecipient()
110 http->out.offset += receivedData.length; in esiBufferRecipient()
112 if (receivedData.data >= esiStream->localbuffer->buf && in esiBufferRecipient()
116 if (receivedData.data != esiStream->localbuffer->buf) { in esiBufferRecipient()
118 memmove(esiStream->localbuffer->buf, receivedData.data, receivedData.length); in esiBufferRecipient()
121 esiStream->localbuffer->len = receivedData.length; in esiBufferRecipient()
124 esiStream->buffer->len = receivedData.length; in esiBufferRecipient()
[all …]
|
| H A D | Esi.cc | 715 (int) receivedData.offset << " length " << in esiProcessStream()
716 (unsigned int)receivedData.length); in esiProcessStream()
724 if (receivedData.data) { in esiProcessStream()
726 assert (receivedData.length <= HTTP_REQBUF_SZ); in esiProcessStream()
728 …bugs (86,5, "esiProcessStream found " << receivedData.length << " bytes of body data at offset " <… in esiProcessStream()
741 size_t len = min (space, receivedData.length); in esiProcessStream()
755 if (len != receivedData.length) { in esiProcessStream()
757 memcpy(context->incoming->buf, &receivedData.data[len], receivedData.length - len); in esiProcessStream()
762 context->readpos += receivedData.length; in esiProcessStream()
774 context->readpos += receivedData.length; in esiProcessStream()
[all …]
|
| /dports/www/squid/squid-4.15/src/ |
| H A D | Downloader.cc | 98 HttpReply * rep, StoreIOBuffer receivedData) in downloaderRecipient() argument
115 context->downloader->handleReply(node, http, rep, receivedData); in downloaderRecipient()
184 …ply(clientStreamNode * node, ClientHttpRequest *http, HttpReply *reply, StoreIOBuffer receivedData) in handleReply() argument
190 debugs(33, 4, "Received " << receivedData.length << in handleReply()
191 " object data, offset: " << receivedData.offset << in handleReply()
192 " error flag:" << receivedData.flags.error); in handleReply()
194 const bool failed = receivedData.flags.error; in handleReply()
204 ((maxSize - object_.length()) < receivedData.length); in handleReply()
211 object_.append(receivedData.data, receivedData.length); in handleReply()
212 http->out.size += receivedData.length; in handleReply()
[all …]
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/hashicorp/consul-template/template/ |
| H A D | brain.go | 20 receivedData map[string]struct{} member
28 receivedData: make(map[string]struct{}),
40 b.receivedData[d.String()] = struct{}{}
49 if _, ok := b.receivedData[d.String()]; !ok {
63 b.receivedData[hashCode] = struct{}{}
73 delete(b.receivedData, d.String())
|
| /dports/misc/concourse/vault-bdd38fca2cff/vendor/github.com/hashicorp/consul-template/template/ |
| H A D | brain.go | 20 receivedData map[string]struct{} member
28 receivedData: make(map[string]struct{}),
40 b.receivedData[d.String()] = struct{}{}
49 if _, ok := b.receivedData[d.String()]; !ok {
63 b.receivedData[hashCode] = struct{}{}
73 delete(b.receivedData, d.String())
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/github.com/hashicorp/consul-template/template/ |
| H A D | brain.go | 20 receivedData map[string]struct{} member
28 receivedData: make(map[string]struct{}),
40 b.receivedData[d.String()] = struct{}{}
49 if _, ok := b.receivedData[d.String()]; !ok {
63 b.receivedData[hashCode] = struct{}{}
73 delete(b.receivedData, d.String())
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/github.com/hashicorp/consul-template/template/ |
| H A D | brain.go | 20 receivedData map[string]struct{} member
28 receivedData: make(map[string]struct{}),
40 b.receivedData[d.String()] = struct{}{}
49 if _, ok := b.receivedData[d.String()]; !ok {
63 b.receivedData[hashCode] = struct{}{}
73 delete(b.receivedData, d.String())
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul-template/template/ |
| H A D | brain.go | 20 receivedData map[string]struct{} member
28 receivedData: make(map[string]struct{}),
40 b.receivedData[d.String()] = struct{}{}
49 if _, ok := b.receivedData[d.String()]; !ok {
63 b.receivedData[hashCode] = struct{}{}
73 delete(b.receivedData, d.String())
|
| /dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/hashicorp/consul-template/template/ |
| H A D | brain.go | 20 receivedData map[string]struct{} member
28 receivedData: make(map[string]struct{}),
40 b.receivedData[d.String()] = struct{}{}
49 if _, ok := b.receivedData[d.String()]; !ok {
63 b.receivedData[hashCode] = struct{}{}
73 delete(b.receivedData, d.String())
|
| /dports/www/squid/squid-4.15/src/servers/ |
| H A D | FtpServer.h | 98 virtual void handleReply(HttpReply *header, StoreIOBuffer receivedData) override;
167 void handleFeatReply(const HttpReply *header, StoreIOBuffer receivedData);
168 void handlePasvReply(const HttpReply *header, StoreIOBuffer receivedData);
169 void handlePortReply(const HttpReply *header, StoreIOBuffer receivedData);
170 void handleErrorReply(const HttpReply *header, StoreIOBuffer receivedData);
171 void handleDataReply(const HttpReply *header, StoreIOBuffer receivedData);
172 void handleUploadReply(const HttpReply *header, StoreIOBuffer receivedData);
173 void handleEprtReply(const HttpReply *header, StoreIOBuffer receivedData);
174 void handleEpsvReply(const HttpReply *header, StoreIOBuffer receivedData);
|
| /dports/lang/intel-compute-runtime/compute-runtime-21.52.22081/shared/test/unit_test/program/ |
| H A D | program_info_from_patchtokens_tests.cpp | 174 const void *receivedData = nullptr; in TEST() local
177 receivedData = data; in TEST()
185 …<void *>(symbolTableTokenStorage.data() + sizeof(iOpenCL::SPatchFunctionTableInfo)), receivedData); in TEST()
231 std::vector<const void *> receivedData; in TEST() local
235 receivedData.push_back(data); in TEST()
242 ASSERT_EQ(2U, receivedData.size()); in TEST()
246 …d *>(symbolTableATokenStorage.data() + sizeof(iOpenCL::SPatchFunctionTableInfo)), receivedData[0]); in TEST()
247 …d *>(symbolTableBTokenStorage.data() + sizeof(iOpenCL::SPatchFunctionTableInfo)), receivedData[1]); in TEST()
282 std::vector<const void *> receivedData; in TEST() local
286 receivedData.push_back(data); in TEST()
[all …]
|
| /dports/devel/bullet/bullet3-3.21/test/clsocket/ |
| H A D | EchoServer.cpp | 30 bool receivedData = false; in main() local
42 receivedData = true; in main()
49 if (!receivedData) in main()
|
| /dports/devel/py-bullet3/bullet3-3.21/test/clsocket/ |
| H A D | EchoServer.cpp | 30 bool receivedData = false; in main() local
42 receivedData = true; in main()
49 if (!receivedData) in main()
|
| /dports/www/kdsoap/kdsoap-1.9.0/unittests/wsdl_rpc/ |
| H A D | test_wsdl_rpc.cpp | 124 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testRequest()
125 …QCOMPARE(QString::fromUtf8(server.receivedData().constData()), QString::fromUtf8(expectedRequestXm… in testRequest()
143 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testRequest()
157 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testRequest()
200 QVERIFY(xmlBufferCompare(server.receivedData(), expectedCountryRequest())); in testSimpleType()
201 …QCOMPARE(QString::fromUtf8(server.receivedData().constData()), QString::fromUtf8(expectedCountryRe… in testSimpleType()
254 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testByteArrays()
|
| /dports/www/kdsoap/kdsoap-1.9.0/unittests/builtinhttp/ |
| H A D | builtinhttp.cpp | 59 QVERIFY(xmlBufferCompare(server.receivedData(), expectedCountryRequest())); in testAsyncCall()
152 QVERIFY(xmlBufferCompare(server.receivedData(), expectedCountryRequest())); in testAsyncCallWithAuth()
171 QVERIFY(xmlBufferCompare(server.receivedData(), expectedCountryRequest())); in testAsyncCallRefusedAuth()
212 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testCorrectHttpHeader()
231 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml12)); in testCorrectHttpHeader()
259 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testCallNoReply()
269 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testCallNoReply()
281 QVERIFY(server.receivedData().isEmpty()); in testCallNoReply()
353 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml + expectedRequestBody)); in testRequestXml()
359 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml + expectedRequestBody)); in testRequestXml()
[all …]
|
| /dports/games/supertuxkart/SuperTuxKart-1.2-src/src/network/protocols/ |
| H A D | connect_to_server.cpp | 401 host->receivedData[0] == 0xFF && host->receivedData[1] == 0xFF && in interceptCallback()
402 host->receivedData[2] == 0x09 && host->receivedData[3] == 'a' && in interceptCallback()
403 host->receivedData[4] == 'l' && host->receivedData[5] == 'o' && in interceptCallback()
404 host->receivedData[6] == 'h' && host->receivedData[7] == 'a' && in interceptCallback()
405 host->receivedData[8] == '-' && host->receivedData[9] == 's' && in interceptCallback()
406 host->receivedData[10] == 't' && host->receivedData[11] == 'k') in interceptCallback()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/ios/web/webui/ |
| H A D | crw_web_ui_scheme_handler_unittest.mm | 35 @property(nonatomic, assign) BOOL receivedData; property
48 self.receivedData = YES;
139 EXPECT_TRUE(url_scheme_task.receivedData);
159 EXPECT_FALSE(url_scheme_task.receivedData);
169 EXPECT_FALSE(url_scheme_task.receivedData);
188 EXPECT_TRUE(url_scheme_task.receivedData);
206 EXPECT_FALSE(url_scheme_task.receivedData);
225 EXPECT_FALSE(url_scheme_task.receivedData);
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/plugins/base/ |
| H A D | plugin_test.go | 116 var receivedData []byte
125 receivedData = cfg.PluginConfig
154 require.Equal(cdata, receivedData)
158 require.NoError(structs.Decode(receivedData, &actual))
|
| /dports/sysutils/nomad/nomad-1.1.0/plugins/base/ |
| H A D | plugin_test.go | 116 var receivedData []byte
125 receivedData = cfg.PluginConfig
154 require.Equal(cdata, receivedData)
158 require.NoError(structs.Decode(receivedData, &actual))
|
| /dports/www/kdsoap/kdsoap-1.9.0/unittests/msexchange_wsdl/ |
| H A D | msexchange_wsdl.cpp | 95 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testExchangeMessage()
124 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testNoParentFolderIds()
181 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testSyncFolder()
240 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testGetFolder()
290 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testCreateItem()
349 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testUpdateItem()
562 QVERIFY(xmlBufferCompare(server.receivedData(), expectedRequestXml)); in testAttachmentMessage()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/media/base/android/java/src/test/org/chromium/media/ |
| H A D | AudioTrackOutputStreamTest.java | 159 List<Byte> receivedData = provider.getReceivedData(); in playSimpleBitstream() local
162 assertArrayEquals(generatedData.toArray(), receivedData.toArray()); in playSimpleBitstream()
182 List<Byte> receivedData = provider.getReceivedData(); in playPiecewiseBitstream() local
185 assertArrayEquals(generatedData.toArray(), receivedData.toArray()); in playPiecewiseBitstream()
|
| /dports/graphics/urho3d/Urho3D-1.7.1/Source/ThirdParty/kNet/src/ |
| H A D | Socket.cpp | 468 OverlappedTransferBuffer *receivedData = *queuedReceiveBuffers.Front(); in GetOverlappedReceiveEvent() local
469 assert(receivedData); in GetOverlappedReceiveEvent()
471 return Event(receivedData->overlapped.hEvent, EventWaitRead); in GetOverlappedReceiveEvent()
519 OverlappedTransferBuffer *receivedData = *queuedReceiveBuffers.Front(); in BeginReceive() local
521 …BOOL ret = WSAGetOverlappedResult(connectSocket, &receivedData->overlapped, (LPDWORD)&receivedData… in BeginReceive()
529 if (receivedData->bytesContains == 0) in BeginReceive()
531 DeleteOverlappedTransferBuffer(receivedData); in BeginReceive()
545 return receivedData; in BeginReceive()
550 DeleteOverlappedTransferBuffer(receivedData); in BeginReceive()
564 DeleteOverlappedTransferBuffer(receivedData); in BeginReceive()
|
| /dports/devel/pecl-swoole/swoole-4.8.5/tests/swoole_runtime/ |
| H A D | nonblock.phpt | 21 $receivedData = fread($socket, 1);
22 Assert::assert($receivedData === '');
|
| /dports/devel/qt5-uitools/kde-qttools-5.15.2p17/src/assistant/assistant/ |
| H A D | stdinlistener.cpp | 42 this, &StdInListener::receivedData); in StdInListener()
55 void StdInListener::receivedData() in receivedData() function in StdInListener
|
| /dports/x11-toolkits/qt5-uiplugin/kde-qttools-5.15.2p17/src/assistant/assistant/ |
| H A D | stdinlistener.cpp | 42 this, &StdInListener::receivedData); in StdInListener()
55 void StdInListener::receivedData() in receivedData() function in StdInListener
|