equal
deleted
inserted
replaced
153 virtual void processVersionSupported(Message& m) { |
153 virtual void processVersionSupported(Message& m) { |
154 versionsSupported.push_back(m.parameters[0]); |
154 versionsSupported.push_back(m.parameters[0]); |
155 } |
155 } |
156 |
156 |
157 virtual void processWaitingForVersion(Message& m) { |
157 virtual void processWaitingForVersion(Message& m) { |
158 // TODO: check that 1 is supported |
158 for (std::wstring v : versionsSupported) if (v == L"1") return write({S::VERSION_ACCEPTED, L"1"}); |
159 write({S::VERSION_ACCEPTED, L"1"}); |
159 write({S::STREAMLET_ERROR, L"INCOMPATIBLE_VERSION", L"Only version 1 is supported by this streamlet."}); |
160 } |
160 } |
161 |
161 |
162 virtual void processRelationStart(Message& m) { |
162 virtual void processRelationStart(Message& m) { |
163 currentRelation = m.parameters[0]; |
163 currentRelation = m.parameters[0]; |
164 } |
164 } |