154                  << "' can not be handled in the state " << toString(mState);  in populateReplyWrongState()
170         mState = StreamDescriptor::State::ERROR;  in cycle()
204             if (mState == StreamDescriptor::State::STANDBY ||  in cycle()
205                 mState == StreamDescriptor::State::DRAINING) {  in cycle()
208                     mState = mState == StreamDescriptor::State::STANDBY  in cycle()
213                     mState = StreamDescriptor::State::ERROR;  in cycle()
223                 if (mState == StreamDescriptor::State::IDLE ||  in cycle()
224                     mState == StreamDescriptor::State::ACTIVE ||  in cycle()
225                     mState == StreamDescriptor::State::PAUSED ||  in cycle()
226                     mState == StreamDescriptor::State::DRAINING) {  in cycle()
228                         mState = StreamDescriptor::State::ERROR;  in cycle()
230                     if (mState == StreamDescriptor::State::IDLE ||  in cycle()
231                         mState == StreamDescriptor::State::PAUSED) {  in cycle()
232                         mState = StreamDescriptor::State::ACTIVE;  in cycle()
233                     } else if (mState == StreamDescriptor::State::DRAINING) {  in cycle()
239                         mState = StreamDescriptor::State::STANDBY;  in cycle()
251                 if (mState == StreamDescriptor::State::ACTIVE) {  in cycle()
255                         mState = StreamDescriptor::State::DRAINING;  in cycle()
258                         mState = StreamDescriptor::State::ERROR;  in cycle()
268             if (mState == StreamDescriptor::State::IDLE) {  in cycle()
271                     mState = StreamDescriptor::State::STANDBY;  in cycle()
274                     mState = StreamDescriptor::State::ERROR;  in cycle()
281             if (mState == StreamDescriptor::State::ACTIVE) {  in cycle()
284                     mState = StreamDescriptor::State::PAUSED;  in cycle()
287                     mState = StreamDescriptor::State::ERROR;  in cycle()
294             if (mState == StreamDescriptor::State::PAUSED) {  in cycle()
297                     mState = StreamDescriptor::State::STANDBY;  in cycle()
300                     mState = StreamDescriptor::State::ERROR;  in cycle()
307     reply.state = mState;  in cycle()
311         mState = StreamDescriptor::State::ERROR;  in cycle()
363     if (mState == StreamDescriptor::State::DRAINING ||  in cycle()
364         mState == StreamDescriptor::State::TRANSFERRING) {  in cycle()
371                 mState = StreamDescriptor::State::IDLE;  in cycle()
375                 if (mState == StreamDescriptor::State::DRAINING) {  in cycle()
376                     mState = StreamDescriptor::State::IDLE;  in cycle()
382                     mState = StreamDescriptor::State::ACTIVE;  in cycle()
390                 LOG(DEBUG) << __func__ << ": switched to state " << toString(mState)  in cycle()
399         mState = StreamDescriptor::State::ERROR;  in cycle()
435             switch (mState) {  in cycle()
456                         mState = *nextState;  in cycle()
462                     mState = StreamDescriptor::State::ERROR;  in cycle()
470                 if (mState != StreamDescriptor::State::ERROR &&  in cycle()
471                     mState != StreamDescriptor::State::TRANSFERRING &&  in cycle()
472                     mState != StreamDescriptor::State::TRANSFER_PAUSED) {  in cycle()
474                         mState = StreamDescriptor::State::ERROR;  in cycle()
477                     if (mState == StreamDescriptor::State::STANDBY ||  in cycle()
478                         mState == StreamDescriptor::State::DRAIN_PAUSED ||  in cycle()
479                         mState == StreamDescriptor::State::PAUSED) {  in cycle()
481                             mState != StreamDescriptor::State::DRAIN_PAUSED) {  in cycle()
482                             mState = StreamDescriptor::State::PAUSED;  in cycle()
484                             mState = StreamDescriptor::State::TRANSFER_PAUSED;  in cycle()
486                     } else if (mState == StreamDescriptor::State::IDLE ||  in cycle()
487                                mState == StreamDescriptor::State::DRAINING ||  in cycle()
488                                mState == StreamDescriptor::State::ACTIVE) {  in cycle()
490                             mState = StreamDescriptor::State::ACTIVE;  in cycle()
506                 if (mState == StreamDescriptor::State::ACTIVE ||  in cycle()
507                     mState == StreamDescriptor::State::TRANSFERRING) {  in cycle()
511                         if (mState == StreamDescriptor::State::ACTIVE &&  in cycle()
513                             mState = StreamDescriptor::State::IDLE;  in cycle()
519                         mState = StreamDescriptor::State::ERROR;  in cycle()
521                 } else if (mState == StreamDescriptor::State::TRANSFER_PAUSED) {  in cycle()
522                     mState = StreamDescriptor::State::DRAIN_PAUSED;  in cycle()
532             if (mState == StreamDescriptor::State::IDLE) {  in cycle()
535                     mState = StreamDescriptor::State::STANDBY;  in cycle()
538                     mState = StreamDescriptor::State::ERROR;  in cycle()
546             switch (mState) {  in cycle()
562                     mState = nextState.value();  in cycle()
565                     mState = StreamDescriptor::State::ERROR;  in cycle()
570             if (mState == StreamDescriptor::State::PAUSED ||  in cycle()
571                 mState == StreamDescriptor::State::DRAIN_PAUSED ||  in cycle()
572                 mState == StreamDescriptor::State::TRANSFER_PAUSED) {  in cycle()
575                     mState = StreamDescriptor::State::IDLE;  in cycle()
578                     mState = StreamDescriptor::State::ERROR;  in cycle()
585     reply.state = mState;  in cycle()
589         mState = StreamDescriptor::State::ERROR;  in cycle()