File tree Expand file tree Collapse file tree 2 files changed +1
-5
lines changed
providers/dq/task_runner_actor Expand file tree Collapse file tree 2 files changed +1
-5
lines changed Original file line number Diff line number Diff line change 33
44#include < ydb/library/actors/core/actor.h>
55
6- #include < memory>
7-
86namespace NYql ::NDq {
97
108class IDqChannelStorageActor
119{
1210public:
13- using TPtr = std::shared_ptr <IDqChannelStorageActor>;
11+ using TPtr = TIntrusivePtr <IDqChannelStorageActor>;
1412 using TWakeUpCallback = std::function<void ()>;
1513
1614 virtual ~IDqChannelStorageActor () = default ;
Original file line number Diff line number Diff line change @@ -125,7 +125,6 @@ class TOutputChannelReader {
125125 bool changed = false ;
126126 bool isChanFinished = false ;
127127 i64 remain = ToPopSize;
128- ui32 dataSize = 0 ;
129128 bool hasData = true ;
130129 TOutputChannelReadResult result;
131130
@@ -146,7 +145,6 @@ class TOutputChannelReader {
146145 }
147146
148147 hasData = lastPop.GetResult ();
149- dataSize = data.Size ();
150148 isChanFinished = !hasData && Channel->IsFinished ();
151149 changed = changed || hasData || (isChanFinished != WasFinished);
152150 if (hasData) {
You can’t perform that action at this time.
0 commit comments