| /dports/www/osrm-backend/osrm-backend-5.26.0/src/server/ |
| H A D | request_handler.cpp | 74 current_reply.status = http::reply::bad_request; in HandleRequest()
93 current_reply.status = http::reply::bad_request; in HandleRequest()
103 current_reply.headers.emplace_back("Access-Control-Allow-Headers", in HandleRequest()
108 current_reply.headers.emplace_back("Content-Disposition", in HandleRequest()
116 current_reply.content.resize(buffer.GetSize()); in HandleRequest()
119 current_reply.content.begin()); in HandleRequest()
121 current_reply.headers.emplace_back( in HandleRequest()
127 current_reply.content.resize(result.get<std::string>().size()); in HandleRequest()
130 current_reply.content.begin()); in HandleRequest()
136 current_reply.headers.emplace_back("Content-Length", in HandleRequest()
[all …]
|
| H A D | connection.cpp | 83 request_handler.HandleRequest(current_request, current_reply); in handle_read()
87 current_reply.headers.emplace_back("Connection", "close"); in handle_read()
92 current_reply.headers.emplace_back("Connection", "keep-alive"); in handle_read()
101 current_reply.headers.insert(current_reply.headers.begin(), in handle_read()
105 output_buffer = current_reply.headers_to_buffers(); in handle_read()
110 current_reply.headers.insert(current_reply.headers.begin(), in handle_read()
114 output_buffer = current_reply.headers_to_buffers(); in handle_read()
119 current_reply.set_uncompressed_size(); in handle_read()
120 output_buffer = current_reply.to_buffers(); in handle_read()
135 current_reply.to_buffers(), in handle_read()
[all …]
|
| /dports/www/kristall/kristall-6b39f244/src/protocols/ |
| H A D | webclient.cpp | 9 current_reply(nullptr) in WebClient()
31 if(this->current_reply != nullptr) in startRequest()
59 this->current_reply = manager.get(request); in startRequest()
60 if(this->current_reply == nullptr) in startRequest()
75 return (this->current_reply != nullptr); in isInProgress()
80 if(this->current_reply != nullptr) in cancelRequest()
82 this->current_reply->abort(); in cancelRequest()
83 this->current_reply = nullptr; in cancelRequest()
112 auto * const reply = this->current_reply; in on_finished()
113 this->current_reply = nullptr; in on_finished()
[all …]
|
| H A D | webclient.hpp | 38 QNetworkReply * current_reply; member in WebClient
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/ssl_session_reuse/src/ |
| H A D | subscriber.cc | 155 ::redisReply *current_reply(nullptr); in run()
165 …current_reply = static_cast<redisReply *>(::redisCommand(my_context, "PSUBSCRIBE %s", m_channel.c_… in run()
167 if (!current_reply || (REDIS_REPLY_ERROR == current_reply->type)) { in run()
174 ::freeReplyObject(current_reply); in run()
178 …s.shutdown && REDIS_OK == ::redisGetReply(my_context, reinterpret_cast<void **>(¤t_reply))) { in run()
180 std::string channel(current_reply->element[2]->str, current_reply->element[2]->len); in run()
181 std::string data(current_reply->element[3]->str, current_reply->element[3]->len); in run()
211 ::freeReplyObject(current_reply); in run()
|
| H A D | publish.cc | 182 ::redisReply *current_reply(nullptr); in send_publish()
197 if (!current_reply) { in send_publish()
202 } else if (REDIS_REPLY_ERROR == current_reply->type) { in send_publish()
204 clear_reply(current_reply); in send_publish()
205 current_reply = nullptr; in send_publish()
212 return current_reply; in send_publish()
237 ::redisReply *current_reply(nullptr); in runWorker()
276 if (!current_reply) { in runWorker()
295 clear_reply(current_reply); in runWorker()
296 current_reply = nullptr; in runWorker()
[all …]
|
| /dports/net/samba412/samba-4.12.15/source3/auth/ |
| H A D | pampass.c | 290 fstring current_reply;
339 fstrcpy(current_reply, t->reply);
340 DEBUG(10,("smb_pam_passchange_conv: PAM_PROMPT_ECHO_ON: We sent: %s\n", current_reply));
341 pwd_sub(current_reply, udp->PAM_username, udp->PAM_password, udp->PAM_newpassword);
343 … DEBUG(100,("smb_pam_passchange_conv: PAM_PROMPT_ECHO_ON: We actually sent: %s\n", current_reply));
347 current_reply);
371 fstrcpy(current_reply, t->reply);
372 DEBUG(10,("smb_pam_passchange_conv: PAM_PROMPT_ECHO_OFF: We sent: %s\n", current_reply));
373 pwd_sub(current_reply, udp->PAM_username, udp->PAM_password, udp->PAM_newpassword);
376 current_reply);
[all …]
|
| /dports/x11/libxcb/libxcb-1.14/src/ |
| H A D | xcb_in.c | 200 if(c->in.current_reply) in read_packet()
202 _xcb_map_put(c->in.replies, lastread, c->in.current_reply); in read_packet()
203 c->in.current_reply = 0; in read_packet()
204 c->in.current_reply_tail = &c->in.current_reply; in read_packet()
425 else if(request == c->in.request_read && c->in.current_reply) in poll_for_reply()
427 head = c->in.current_reply; in poll_for_reply()
428 c->in.current_reply = head->next; in poll_for_reply()
430 c->in.current_reply_tail = &c->in.current_reply; in poll_for_reply()
896 in->current_reply_tail = &in->current_reply; in _xcb_in_init()
906 free_reply_list(in->current_reply); in _xcb_in_destroy()
|
| H A D | xcbint.h | 140 struct reply_list *current_reply; member
|
| /dports/www/osrm-backend/osrm-backend-5.26.0/include/server/ |
| H A D | request_handler.hpp | 29 void HandleRequest(const http::request ¤t_request, http::reply ¤t_reply);
|
| H A D | connection.hpp | 70 http::reply current_reply; member in osrm::server::Connection
|
| /dports/games/stendhal/stendhal-1.35/tests/games/stendhal/server/maps/quests/ |
| H A D | AntivenomRingTest.java | 497 String current_reply; in testQuestActive() local
501 current_reply = getReply(apothecary); in testQuestActive()
503 …assertTrue(current_reply.startsWith("I am still waiting for you to bring me") && current_reply.end… in testQuestActive()
507 current_reply = getReply(apothecary); in testQuestActive()
509 …assertTrue(current_reply.startsWith("I need") && current_reply.endsWith("Did you bring something?"… in testQuestActive()
|
| /dports/x11/libxcb/libxcb-1.14/ |
| H A D | ChangeLog | 7171 …Replace current_reply generic queue with hand-written version. No generic queues remain so delete …
|