| 1042 | } |
| 1043 | |
| 1044 | void TFileProcessor::processChunk() { |
| 1045 | shared_ptr<TProtocol> inputProtocol = inputProtocolFactory_->getProtocol(inputTransport_); |
| 1046 | shared_ptr<TProtocol> outputProtocol = outputProtocolFactory_->getProtocol(outputTransport_); |
| 1047 | |
| 1048 | uint32_t curChunk = inputTransport_->getCurChunk(); |
| 1049 | |
| 1050 | while (1) { |
| 1051 | // bad form to use exceptions for flow control but there is really |
| 1052 | // no other way around it |
| 1053 | try { |
| 1054 | processor_->process(inputProtocol, outputProtocol, nullptr); |
| 1055 | if (curChunk != inputTransport_->getCurChunk()) { |
| 1056 | break; |
| 1057 | } |
| 1058 | } catch (TEOFException&) { |
| 1059 | break; |
| 1060 | } catch (TException& te) { |
| 1061 | cerr << te.what() << '\n'; |
| 1062 | break; |
| 1063 | } |
| 1064 | } |
| 1065 | } |
| 1066 | } |
| 1067 | } |
| 1068 | } // apache::thrift::transport |
nothing calls this directly
no test coverage detected