| 137 | extern bool g_crashOnError; |
| 138 | |
| 139 | Future<Void> processRequest(Reference<ExtConnection> ec, |
| 140 | ExtMsgHeader* header, |
| 141 | const uint8_t* body, |
| 142 | Promise<Void> finished) { |
| 143 | try { |
| 144 | Reference<ExtMsg> msg = ExtMsg::create(header, body, finished); |
| 145 | if (verboseLogging) |
| 146 | TraceEvent("BD_processRequest").detail("Message", msg->toString()).detail("connId", ec->connectionId); |
| 147 | if (verboseConsoleOutput) |
| 148 | fprintf(stderr, "C -> S: %s\n\n", msg->toString().c_str()); |
| 149 | return msg->run(ec); |
| 150 | } catch (Error& e) { |
| 151 | TraceEvent(SevError, "UnhandledRequestFailure").detail("opcode", header->opCode).error(e); |
| 152 | return Void(); |
| 153 | } |
| 154 | } |
| 155 | |
| 156 | ACTOR Future<Void> popDisposedMessages(Reference<BufferedConnection> bc, |
| 157 | FutureStream<std::pair<int, Future<Void>>> msg_size_inuse) { |
no test coverage detected