Список задач

И так, предлагаю подытожить то, что нужно сделать и в каком порядке. Задачи сгруппировал по группам ...

2010-12-29T17:20:14Z

И так, предлагаю подытожить то, что нужно сделать и в каком порядке.

Задачи сгруппировал по группам (копировал из соседней ветки http://stocksharp.com/forum/1275/&p=2). Первая группа - самая приоритетная. Без нее делать задачи из следующей бессмысленно. Сами задачи внутри этой группы так же выстроены по очередности.

Базовая группа:

Описать основные метаданные, как это сделано для Квика (DdeSecurityColumns, DdeTradeColumns и т.д.). Я это уже показал на примере класса PlazaFutureColumns, но там колонки не реальные. Предлагаю прямо разобрать по названию таблиц потоков, кто за какие будет отвечать (описывать в коде). Таблицы только основные: инструменты, заявки, сделки и т.д.
Подписываться на произвольные потоки + отписываться.
Получать стаканы. Производная от предыдущей задача. Выделил ее отдельно.
Заявки (регистрация, снятие и перемещение). Я уже сделал через класс Message заполнение полей для отправки транзакций. Это дело надо доделать.
Парсинг ответа от транзакций (внимание! всех транзакций, а не только, что в предыдущем пункте). Я не знаю, в каком виде они приходят, но могу сказать, какой результат должен быть. Это должно быть PlazaException с кодом ошибки (чтобы не мучится сравнение строчек в коде). И код не ввиде числа (что не так уж лучше строчки), а нормального перечисления (enum).

Первую задачу предлагаю сделать сообща. Остальные - разбираем по тем признакам, кто какие таблицы описывал (например, кто описал стакан, тот занимается задачей 3, кто инструменты - задачей 2, кто заявки - задачей 4).

Второстепенная группа:

Дописать все остальные метаданные (позиции, счета, волатильность, маржа, клиринг, доп информация о деривативах, индексы).
Фильтрация потоков. Так как Плаза не дает фильтр (камрад skuvv написал об этом), но в клиентском коде прописывать фильтры дело не благодарное, предлагаю это симулировать через RegisterXXX + UnRegisterXXX.
Возможность задавать глубину стакана (как я понял, это влияет на то, к какому потоку необходимо цепляться).
Поддержка агрегированного стакана и обычного. Для этого можно использовать GroupedQuote (внутри себя он будет содержать не агрегированные котировки).

Третьестепенная группа:

С помощью метаданных научиться строить конфиги ini. Как вариант, через PlazaTable (куда собственно и будут добавляться колонки из пункта 1 пред группы). Сейчас ini файлы программно редактировать нельзя. И если роботу нужны спец колонки нужно менять формат ini схем. Я предлагаю до загрузки этих схем давать возможность менять из программно (парсить и менять ini файлы на лету). + как фича автоматически сканировать директорию при старте и создавать с правильным набором колонок сами PlazaTable. Возможно, здесь поможет TableSet.
Время биржи.
Все остальные транзакции (FutChangeClientMoney, OptChangeExpiration и т.д.).
Составные инструменты.
На форуме доступна x64 версия. Нужна прозрачная поддержка (без перекомпиляции) x86 и x64.
Обертка над роутером (чтобы так же, не ручками править конфиги, а программно).
Документация (как xml, так и обычная). Если нужно сделать как у S#, то необходимо использовать Sandcastle.

Особенности в работе.

Старайтесь писать так, как это принято в .NET и в частности C# коде.
Публичные методы классы и т.д. описывайте xml комментариями (лучше не сочинять, а копировать из документации Плазы, чтобы быть не с планеты Юпитер, а ближе к тем, кто будет это использовать и вторым глазом подглядывать в документацию).
Предлагаю использовать R# как средство для контроля качества кода.
Пишите юнит тесты (заведите отдельный проект в sln).

Я так понимаю, задачу 1 не только выполнили, но и перевыполнили? Тогда корректируем задачи в зависим...

2011-01-17T13:16:24Z

Я так понимаю, задачу 1 не только выполнили, но и перевыполнили? Тогда корректируем задачи в зависимости от силы исполнения. Те, кто хочет остаться на метаданных, пусть дописывает оставшиеся. Только перед этим надо написать здесь, какие именно таблицы хочется дописать, чтобы не получилось дублирования работы.

Далее, задачи с 2 по 5. Задачи 2 и 3 мне кажется схожи. Поэтому, предлагаю стаканы отложить до тех пор, пока не будет закончена задача 2. Если так окажется, что желающих больше чем задач (вряд ли, но все же), то предлагаю спуститься к задачам из третьестепенной группы (второстепенные задачи слишком тесно связаны с первостепенными).

Схема стандартная - пишем кто-что хочет делать и делаем.

Взял 4. Составные инструменты. из Третьестепенная группа:

2011-03-11T13:20:39Z

Взял

Quote:

4. Составные инструменты.

из

Quote:

Третьестепенная группа:

Я думал что это будет или object или object... Это сильно критично через что данные будут передават...

2011-02-16T20:21:33Z

Mikhail Sukhov

Я думал что это будет или object[] или object[][]... Это сильно критично через что данные будут передаваться?

Просто, чтобы понимать куда передавать данные дальше. Сейчас они приходят по одной записи/строчке в методе void OnStreamDataInserted(CP2DataStream stream, string tableName, CP2Record record) класса PlazaStream.

Mikhail Sukhov

2. Тоесть, PlazaTableSerializer восстанавливает из конфига PlazaTable и он уже передается в PlazaStream?

Да, причем, на мой взгляд, клиентскому коду лучше не давать доступа к PlazaTableSerializer. Пускай он это лучше делает через методы Load/Save класса PlazaTable. Формат ini-файлов это внутренность Плазы, и ее лучше, хотя бы на первых порах, инкапсулировать от клиентского кода.

Mikhail Sukhov

3. Распиши, как ты это видишь и где это нужно сделать.

Создать интерфейс IPlazaStreamFilter, у которого будет метод bool Validate(object value) и свойство string ColumnName. В конструктор PlazaTable передавать IEnumerable<IPlazaStreamFilter>, который, в свою очередь будет эту энумерацию передавать в конструктор PlazaStream. Внутри себя PlazaStream в методе void OnStreamDataInserted(CP2DataStream stream, string tableName, CP2Record record) будет перебирать эту энумерацию, вызывать для каждого элемента метод Validate(object Value) и передавать данные, приходящие в потоке репликации, дальше (в клиентский код) только, если все вызовы Validate(object Value) возвращают true. Но это только верхушка айсберга, потому что, оперируя понятиями SQL, мы только реализуем AND связки, например, price>100 AND code_vcb=xyz. А нужно еще предосмотреть, как минимум связку OR, например, price>100 OR code_vcb=xyz. Дальше я пока над этим не думал.

Mikhail Sukhov

4. Как насчет для каждого стрима создавать по отдельному CP2ConnectionClass? Можно пока задачу подвинуть как оптимизациюнную (а следовательно не приоритетную[biggrin])

Да, это точно на потом. Сначала нужно с первыми тремя задачами разобраться.

Похоже я нагородил кучу лишнего. Короче все это нужно отринуть. МИХАИЛ: вопрос, который меня занимае...

2011-02-15T19:56:01Z

aspirant

Похоже я нагородил кучу лишнего. Короче все это нужно отринуть.

МИХАИЛ: вопрос, который меня занимает сейчас больше всего: какой класс будет содержать все себе данные, которые будут приходить в потоках Плазы? Если PlazaStream мы не будем показывать клиентскому коду, тогда, может быть, это будет PlazaTable? А если не он, то что это будет за класс, и как он будет связан с PlazaTable?

Я думал что это будет или object[] или object[][]... Это сильно критично через что данные будут передаваться?

aspirant

По задачам, связанными с подпиской на потоки репликации Плазы я вижу, что нужно сделать следующее:

Создать буфер накопления входящих данных стрима.
Расписать методы Deserialize у PlazaTableSerializer, чтобы можно было инициализировать PlazaStream из ini файлов. Прикрутить инфраструктуру инициализации из файлов к PlazaStreamManager/PlazaTrader.
Фильтрация входящих данных.
Создание пула CP2ConnectionClass'ов для оптимизации и возможности параллельного получения данных по потокам. Сейчас, насколько я понял из тестирования, если данные из нескольких стримов идут по одному CP2ConnectionClass, это происходит порционно, т.е. идет партия данных одного стрима, за ней партия данных другого стрима и т.д.

Я сейчас занимаюсь первым пунктом, а остальные пункты можно разобрать на задачи. Самым сложным и интересным вижу пункт 3.

Ок, тогда по первому задавать вопросы не буду.

2. Тоесть, PlazaTableSerializer восстанавливает из конфига PlazaTable и он уже передается в PlazaStream?
3. Распиши, как ты это видишь и где это нужно сделать.
4. Как насчет для каждого стрима создавать по отдельному CP2ConnectionClass? Можно пока задачу подвинуть как оптимизациюнную (а следовательно не приоритетную[biggrin])

Похоже я нагородил кучу лишнего. Короче все это нужно отринуть. МИХАИЛ: вопрос, который меня занимае...

2011-02-15T19:42:13Z

Создать буфер накопления входящих данных стрима.
Расписать методы Deserialize у PlazaTableSerializer, чтобы можно было инициализировать PlazaStream из ini файлов. Прикрутить инфраструктуру инициализации из файлов к PlazaStreamManager/PlazaTrader.
Фильтрация входящих данных.
Создание пула CP2ConnectionClass'ов для оптимизации и возможности параллельного получения данных по потокам. Сейчас, насколько я понял из тестирования, если данные из нескольких стримов идут по одному CP2ConnectionClass, это происходит порционно, т.е. идет партия данных одного стрима, за ней партия данных другого стрима и т.д.

Не могу сейчас развернуто вникнуть в суть проблемы. 1. Я думаю это неправильно. Иерархия Плазы как р...

2011-02-10T10:57:29Z

Не могу сейчас развернуто вникнуть в суть проблемы.

1. Я думаю это неправильно. Иерархия Плазы как раз сама по себе избыточная (я так понимаю тогда задача стояла сделать что то по быстрому, а не что-то стоящее). Идти за их иерархией - просто повторять их ошибки.

2. PlazaTable - это то что конфигурируется пользователем. PlazaColumns - базовый класс, содержащийся основные поля. Даже не представляю, как одно может заменить другое... Плюс дальше по описанию вижу, что пользователю предлагается вынести управление потоками. Я однозначно понял за последнее время - этого делать не нужно. Лучше придерживать принципа инкапсуляции. Разрушить его можно в любое время (что опять же не очень хорошо).

3. Скажу так, все эти PlazaColumnListBuilder PlazaTableConfiguration говорит о том, что уже начался овер дизайн.[biggrin] Надо как-то проще. Потому что сейчас уже не совсем понятно. Что будет потом? А что будет с теми пользователями, которые захотят переползти с голой Плазы? Одно сложное на другое сложно не меняют.

Что я предлагаю: Сейчас все метаданные описаны классами-наследниками PlazaColumns, что не совсем соо...

2011-02-07T20:42:11Z

Что я предлагаю:

Сейчас все метаданные описаны классами-наследниками PlazaColumns, что не совсем соответствует иерархии метаданных самой Плазы. Я предлагаю создать абстрактный класс PlazaReplicationStream (название можно как-нибудь сократить, например PlazaReplStream), наследники которого будут соответствовать потокам репликации, например, FortsOptTradeReplicationStream - FORTS_OPTTRADE_REPL, RtsIndexReplicationStream - RTS_INDEX_REPL и т.д. По аналогии со структурой PlazaColumns в самом PlazaReplicationStream будут открытые переменные readonly для каждого потока репликации, например
Code
public static readonly FortsOptTradeReplicationStream FortsOptTradeRepl = new FortsOptTradeReplicationStream();
public static readonly RtsIndexReplicationStream RtsIndexRepl = new RtsIndexReplicationStream();
PlazaColumns предалагю переименовать в PlazaTable, потому что это все-таки таблицы, а не наборы колоннок, которые можно между собой смешивать (но это лишь моя интерпретация названия PlazaColumns). В каждом классе потоке репликации будут свои наследники PlazaTable, что будет соответствовать содержанию самих потоков репликации в Плазе. Так, что если в FORTS_OPTTRADE_REPL есть таблицы orders_log, deal, heartbeat, в классе FortsOptTradeReplicationStream будут такие поля:
Code
public readonly PlazaOptionOrdersLogColumns OrdersLog = new PlazaOptionOrdersLogColumns();
public readonly PlazaOptionDealColumns Deal = new PlazaOptionDealColumns();
public readonly PlazaHeartBeatColumns HeartBeat;

Теперь, если нужно подписаться на весь поток FORTS_OPTTRADE_REPL и получать данные по всем таблицам, это можно сделать так:
Code
_plazaStreamManager.AddStream("FortsOptTradeRepl_OrdersLog", PlazaReplicationStream.FortsOptTradeRepl);

А, если нужно подписаться только на одну таблицу, например orders_log, это можно сделать так
Code
_plazaStreamManager.AddStream("FortsOptTradeRepl_OrdersLog", PlazaReplicationStream.FortsOptTradeRepl.OrdersLog);

Если нужно передать только отдельные колонки, то это делатется так:
Code
_plazaStreamManager.AddStream("FortsOptTradeRepl_OrdersLog", PlazaReplicationStream.FortsOptTradeRepl.OrdersLog, columns1);

где columns1 это
Code
var columns1 = new PlazaColumn[]
{
  PlazaReplicationStream.FortsOptTradeRepl.OrdersLog.ReplId,
  PlazaReplicationStream.FortsOptTradeRepl.OrdersLog.ReplRev,
  PlazaReplicationStream.FortsOptTradeRepl.OrdersLog.ReplAct,
  PlazaReplicationStream.FortsOptTradeRepl.OrdersLog.Price,
  PlazaReplicationStream.FortsOptTradeRepl.OrdersLog.Hedge
};

Кстати, уже сейчас по ходу написания родилась мысль, что в последнем примере вместо IEnumerable<PlazaColumn> можно будет передавать новый класс, называющийся, например, PlazaColumnListBuilder, который, во-первых, будет за клиента автоматом добавлять первыми тремя колонками служебные колонки ReplId, ReplRev, ReplAct (это обязательно, иначе не подключишься), а, во-вторых, будет проверять, чтобы все колонки были одной таблицы.
Нынешний PlazaTable предлагаю переименовать в PlazaTableConfiguration. Он будет уметь сохранять заданную конфигурацию таблицы (читай нужный набор колоннок) в ini-файле в формате Плазы, а также создаваться из таких файлов для последующего подключения к потокам репликации.
PlazaTableTypes нужно, наверное, либо прицепить к наследникам PlazaReplicationStream, либо убрать вообще.

Если мои предложения принимаются, я могу начать вносить изменения. Также беру на себя рефакторинг всех наследников PlazaColumns. Постараюсь сделать на этой неделе до конца выходных.

Хочу предложить серьезные изменения в структуре метаданных. Вместе с обоснованием хочу для наглядно...

2011-02-06T12:25:46Z

aspirant

Хочу предложить серьезные изменения в структуре метаданных. Вместе с обоснованием хочу для наглядности выложить пример на WPF. Как это лучше сделать?

Написать сюда или картинку вставить.

aspirant

Еще, если я залью на сервер изменения, я так понимаю, их же можно будет потом назад откатить?

Можно, но муторно как и любой откат.

Михаил, Хочу предложить серьезные изменения в структуре метаданных. Вместе с обоснованием хочу для н...

2011-02-06T11:49:32Z

Михаил,

Хочу предложить серьезные изменения в структуре метаданных. Вместе с обоснованием хочу для наглядности выложить пример на WPF. Как это лучше сделать?

Еще, если я залью на сервер изменения, я так понимаю, их же можно будет потом назад откатить?

А где теперь делать проверку, что в таблицу попала правильная колонка? Предлагаю у PlazaColumn сдела...

2011-02-02T19:08:19Z

Mikhail Sukhov

А где теперь делать проверку, что в таблицу попала правильная колонка?

Предлагаю у PlazaColumn сделать readonly поле Owner типа PlazaColumns, инициализировать его в конструкторе PlazaColumn. В конструкторе PlazaTable перебирать IEnumerable<PlazaColumn> columns и сравнивать у каждого элемента Owner.ReplicationStream, Owner.ReplicationScheme и Owner.Table c replicationStream, replicationScheme, переданными в конструктор PlazaTable.

Как вариант, можно убрать из параметров конструктора PlazaTable параметры ReplicationStream replicationStream, ReplicationScheme replicationScheme, string name вообще и считать, что правильные параметры ReplicationStream, ReplicationScheme, [Table]name указаны в первом элементе IEnumerable<PlazaColumn> columns. Соответственно, проверку на правильность остальных элементов IEnumerable<PlazaColumn> columns проводить с значениями полей первого элемента.

Не знаю, какой вариант правильнее?

public abstract ReplicationStream ReplicationStream { get; } public virtual ReplicationScheme Repli...

2011-02-01T06:42:54Z

aspirant

public abstract ReplicationStream ReplicationStream { get; }
public virtual ReplicationScheme ReplicationScheme { get { return ReplicationScheme.CustReplScheme; } }
public abstract string Table { get; }

У каждой таблицы потока репликации, т.е. наследника PlazaColumns, своя уникальная неизменная комбинация ReplicationStream + ReplicationScheme + Table. Она мне нужна для создания ini-файла.

Букв много. Надеюсь, что не запутал окончательно.

Стало чуть понятнее. А где теперь делать проверку, что в таблицу попала правильная колонка?

Но мне не понятно эта иерархия. Стрим - репликация - таблица. Это реально нужная вещь, без которой П...

2011-01-31T20:18:16Z

Mikhail Sukhov

Но мне не понятно эта иерархия. Стрим - репликация - таблица. Это реально нужная вещь, без которой Плаза не взлетит? Пока выглядит как избыточность.

Это не мои изобретения. Выдача данных клиентов Плазой строится следующим образом: есть несколько потоков репликации (FORTS_OPTINFO_REPL и т.д.). У каждого потока есть dbscheme. Вроде у каждого потока она одна, но пока не успел проверить точно. Зачем она нужна, если она одна, - ума не приложу. И наконец в каждом потоке есть от одной до несколько таблиц. Это их мы описывали наследниками PlazaColumns.

Чтобы подписаться на потоки и получать данные, я могу просто указать имя потока (второй конструктор PlazaStream). В этом случае будут приходить ВСЕ данные потока, т.е. если в нем несколько таблиц, например в FORTS_FUTINFO_REPL их 17 штук, их данные будут приходить через событие CP2DataStreamClass.StreamDataInserted вперемешку. Второй вариант - это, когда я отправляю на сервер содержимое ini-файла таблицы с обязательным указанием потока репликации, dbscheme, именем таблицы и списка нужных колонок запрашиваемой таблицы. В этом случае, понятно, приходят только запрошенные колонки запрошенной таблицы.

Из-за того, что процесс подписки на потоки построен именно таким образом, я считаю необходимым добавить в PlazaColumns

public abstract ReplicationStream ReplicationStream { get; }
public virtual ReplicationScheme ReplicationScheme { get { return ReplicationScheme.CustReplScheme; } }
public abstract string Table { get; }

У каждой таблицы потока репликации, т.е. наследника PlazaColumns, своя уникальная неизменная комбинация ReplicationStream + ReplicationScheme + Table. Она мне нужна для создания ini-файла.

Букв много. Надеюсь, что не запутал окончательно.

Вопрос: еще раз хотел вернуться, потому что не совсем для себя уяснил. Как вам видится (изначально ...

2011-01-31T08:42:55Z

aspirant

Вопрос: еще раз хотел вернуться, потому что не совсем для себя уяснил. Как вам видится (изначально виделась) работа клиентского кода с PlazaTrader в применении к плазовским стримам (потоками репликации). При запуске PlazaTrader из клиентского кода, PlazaTrader подключается

к стримам, чьи схемы расписаны в ini-файлах специальной папке?
и/или клиентский код создает схемы программным путем на лету?

И то и другое. При старте настройки PlazaTable берутся из уже созданных ini файлов. Если их нет, то создается минимально допустимый набор метаданных (как это было сделано с Quik таблицами) и по свеже созданным таблицам создаются соответствующие ini файлы. Если клиентский код модифицирует PlazaTable, его действия так же применяются и к ini файлам.

Но мне не понятно эта иерархия. Стрим - репликация - таблица. Это реально нужная вещь, без которой Плаза не взлетит? Пока выглядит как избыточность.

aspirant

Но тогда подразумевается, что в PlazaTable можно передать колонки из разных наследников PlazaColumns, но с одинаковым PlazaTableTypes.

Я думаю, неправильно было изначально делать разные PlazaColumns с одинаковыми PlazaTableTypes. Я же не знал, что для одной сущности в Плазе триллион таблиц соответствует. Потому и написал изначально, Position Portfolio и т.д. Так что да, или его переделывать, или его выкидывать.

Михаил, Вопрос и комментарий. Вопрос: еще раз хотел вернуться, потому что не совсем для себя уяснил....

2011-01-31T05:47:15Z

Михаил,

Вопрос и комментарий.

Вопрос: еще раз хотел вернуться, потому что не совсем для себя уяснил. Как вам видится (изначально виделась) работа клиентского кода с PlazaTrader в применении к плазовским стримам (потоками репликации). При запуске PlazaTrader из клиентского кода, PlazaTrader подключается

к стримам, чьи схемы расписаны в ini-файлах специальной папке?
и/или клиентский код создает схемы программным путем на лету?

Во втором случае это будет происходить через создание экземпляра PlazaTable и передачу его в PlazaTrader или мы оставим PlazaStreamManager public? Сейчас он сделан public только в целях тестирования (чтобы можно было вызывать напрямую из тестового проекта).

Комментарий: наверное, перечисление PlazaTableTypes будет лишним. Как я понимаю, оно сделано для проверки совместимости PlazaTable и PlazaColumn (см. внизу)

Mikhail Sukhov

Для чего нужен тип таблицы. Для того, чтобы предотвращать в пользовательском коде такие вещи:

plazaTrader.SecuritiesTable.Columns.Add(PlazaColumns.OrdersColumns.Direction)

и выбрасывать исключения при запуске программы.

Но тогда подразумевается, что в PlazaTable можно передать колонки из разных наследников PlazaColumns, но с одинаковым PlazaTableTypes. А это не пройдет. Еще раз повторюсь: "синтетические" схемы из колонок разных плазовских схем (PlazaColumns) создавать нельзя. Корректным при наполненни PlazaTable набором PlazaColumn'ов будет проверять каждую PlazaColumn на одинаковость с PlazaTable по ReplicationStream, ReplicationScheme и Table(Name).

Что вы на этот счет думаете?

Добавил класс с кодами ошибок плазы - PlazaErrors парсит код ошибки и возвращает текст ps ктото нача...

2011-01-30T21:35:57Z

Mikhail Sukhov

skuvv

Добавил класс с кодами ошибок плазы - PlazaErrors
парсит код ошибки и возвращает текст
ps ктото начал заниматься ошибками - пользуйтесь

Я этим занимаюсь[blush]. Но пока нет времени доделать, так что большое спасибо, что помогли. Но раз уж сделали, вот и Вам code review:

1. public class Errors. Его не нужно сделать статическим? Нужен ли он для public?
2. Error_Code. Лучше параметры называть в C# стиле.
3. Dictionary<int, List<string>> List. Конечно же, это никакой не Лист. Но и Дикшинари тоже будет неправильно назвать. У этого поля должно быть осмысленное имя.
4. List.ElementAt(i) - лучше использовать List[i]. Так быстрее, особенно если это Dictionary.
5. BitConverter.GetBytes(Error_Code)[i] Можно написать проще - Error_Code.To<byte[]>()[i].

Просто готовый был класс [smile]
насчет 4. в Dictionary таким способом (List[i]) доступ к ключу не получить вроде

Увидел такую подписку: plazaStream.DataBegin += (p) => OnPlazaStreamDataBegin(key, p); Она плоха тем...

2011-01-30T20:59:57Z

Mikhail Sukhov

Увидел такую подписку:

Code

plazaStream.DataBegin += (p) => OnPlazaStreamDataBegin(key, p);

Она плоха тем, что при таком подписывании нельзя будет отписаться от события и объект будет продолжать висеть в памяти (не так страшно при существующих гигабайтах, но все же). Лямбда выражения создают "на лету" метод обработчик, от которого потом не отписаться. Чтобы производить правильное освобождение ресурсов, нужно от них отказать вообще и писать по старинке:

Code

plazaStream.DataBegin += OnPlazaStreamDataBegin;

Я думаю, лучше сразу проговорить для чего вообще нужны лямбда. Они появились тогда, когда в .NET начал входить функциональный стиль. Для этого и только для этого их и придумали (явный пример - это LINQ). Я в своих примерах использовал лямбду не потому что так правильно. А потому что мне было лень писать правильно, и быстрее + короче написать как это сделали Вы. Но внутри S# я так конечно же не делаю, к чему призываю делать и в ПлазаТрейдере.[laugh]

Это пока временный вариант, потому что я пока еще не определился с окончательным набором параметров событий. По ходу написания добавил string key, а поскольку хотелось залить первый черновой вариант, оставил как есть.

Свои делегаты я убрал вообще. Вы правы, они лишние. Все вызовы событий передал через SafeInvoke.

1. Плохой код. try { _dataStream.Close(); } catch (System.Runtime.InteropServices.COMException e) {...

2011-01-30T20:38:19Z

Mikhail Sukhov

1. Плохой код.

Code

try
{
  _dataStream.Close();
}
catch (System.Runtime.InteropServices.COMException e)
{
  // Исправить обработку исключения
  System.Diagnostics.Trace.WriteLine("Exception {0:X}: {1}".Put(e.ErrorCode, e.Message));
}

Исключения нужно перехватывать как можно выше. Кто будет вызывать Close, тот пусть и этим занимается. А так ошибка просто проглотиться.

Я пока сделал такую заплату, чтобы можно было тестировать код (поэтому и оставил для себя комментарий). Вообще мне кажется, COMException нужно везде перехватывать и выдавать свои исключения, чтобы внешнему коду не видеть внутреннюю кухню. Если внешний код имеет дело с PlazaStream, то он и должен оперировать понятиями (читай методами, статусами и т.д.) PlazaStream.

Mikhail Sukhov

Code

_dataStream.TableSet.set_rev(plazaTable.Name, _currentRevision++);

Это меняется на более элегантное, как подсказал R#:

Code

_dataStream.TableSet.rev[plazaTable.Name] = _currentRevision++;

исправлю.

Mikhail Sukhov

4. ReplicationStream и ReplicationScheme явно как то не так используется. Это же уровень метаданных, а именно таблица PlazaTable (таблица олицетворяет стрим данных, PlazaStream по этом олицетворению производит подключение). А получилось так, что эти два перечисления размазались по всем практически классам в Плазе. Нехорошо. Конструктора PlazaStream(PlazaTable plazaTable, TRequestType requestType) более чем достаточно. Зачем нужен еще один я не понял.

5. public void AddStream(string key, PlazaColumns schema, IEnumerable<PlazaColumn> columns) Выглядит как то не так. Зачем столько аргументов? Можно же ведь передать один PlazaTable и уже по нему создать стрим, и уже оперировать им в дальнейшем.

Иерархия данных в потоках репликации: ReplicationStream -> ReplicationScheme -> Table -> Field, т,е. у каждой плазовской таблицы (в PlazaTrader это PlazaColumns) есть только одно значение ReplicationStream и ReplicationScheme, поэтому я и счел нужным добавить эти поля в PlazaColumns, чтобы при создании PlazaStream значения ReplicationStream и ReplicationScheme можно было вычислить из PlazaColumns.

Есть два варианта получения данных репликации. Во-первых, можно передать Плазе полный или урезанный набор полей какой-то таблицы (создавать "свои" таблицы с полями из нескольких таблиц нельзя). Второй вариант запроса данных - без указания схемы (см. P2ClientGate.doc стр. 18: "Клиент также может не указывать никакой схемы при открытии потока, в этом случае сервер будет отдавать все данные, которые публикуются в потоке (далее этот режим будет называться «получение данных по схеме сервера»)". Поскольку такой вариант подключения существует, я предусмотрел второй конструктор PlazaStream, в котором только передается ReplicationStream. При таком подключении при получении данных через события нужно будет проверять название таблицы, именно поэтому у CP2DataStreamClass второй параметр событий StreamDataInserted, StreamDataUpdated и StreamDataDeleted - это string tableName.

AddStream(string key, PlazaColumns schema, IEnumerable<PlazaColumn> columns) я исправлю на AddStream(string key, PlazaTable plazaTable)

Добавил класс с кодами ошибок плазы - PlazaErrors парсит код ошибки и возвращает текст ps ктото нача...

2011-01-30T17:16:11Z

skuvv

Увидел такую подписку: plazaStream.DataBegin += (p) => OnPlazaStreamDataBegin(key, p); Она плоха тем...

2011-01-30T17:04:22Z

Увидел такую подписку:

Code

plazaStream.DataBegin += (p) => OnPlazaStreamDataBegin(key, p);

Code

plazaStream.DataBegin += OnPlazaStreamDataBegin;