Доработки по кодревью

src/Классы/КонтрольСоединенийСерверныхСобытий.os

@@ -50,19 +50,19 @@
 Процедура НайтиИУдалитьСоединения()
 
 	ПулСоеднинений = СоединенияСерверныхСобытий.ПулСоединений();
-	СоединенеияКУдалению = Новый Массив();
+	ИдСоединенийКУдалению = Новый Массив();
 	Для Каждого СтрокаСоединения из ПулСоеднинений Цикл
-		Если НЕ СоединениеАктивно(СтрокаСоединения) Тогда
-			СоединенеияКУдалению.Добавить(СтрокаСоединения);
+		Если НЕ СоединениеАктивно(СтрокаСоединения.Соединение) Тогда
+			ИдСоединенийКУдалению.Добавить(СтрокаСоединения.ИдСоединения);
 		КонецЕсли;
 	КонецЦикла;
 
-	Для Каждого СоединениеКУдалению из СоединенеияКУдалению Цикл
-		СоединенияСерверныхСобытий.УдалитьСтрокуПула(СоединениеКУдалению);
+	Для Каждого ИдСоединения из ИдСоединенийКУдалению Цикл
+		СоединенияСерверныхСобытий.УдалитьСтрокуПулаПоИдСоединения(ИдСоединения);
 	КонецЦикла;
 
 КонецПроцедуры
 
-Функция СоединениеАктивно(СтрокаСоединения)
-	Возврат БрокерСообщенийСобытийСервера.ОтправитьВПопытке(СтрокаСоединения.Соединение, Сообщение);
+Функция СоединениеАктивно(Соединение)
+	Возврат БрокерСообщенийСобытийСервера.ОтправитьВПопытке(Соединение, Сообщение);
 КонецФункции

src/Классы/ОбработчикСоединений.os

@@ -1,12 +1,16 @@
 &Пластилин Перем Настройки;
 &Пластилин Перем МенеджерВходящихСоединений;
 
+Перем ТаймаутЧтения;
+Перем РазмерБуфера;
+
 &ЛогВебСервера 
 Перем Лог;
 
 &Желудь
 Процедура ПриСозданииОбъекта()
-
+	ТаймаутЧтения = 10;
+	РазмерБуфера = 1024;
 КонецПроцедуры
 
 Процедура Обработать(Соединение) Экспорт
@@ -48,8 +52,8 @@
 
 	Попытка
 		Пока Истина Цикл
-			Соединение.ТаймаутЧтения = 10;
-			ДанныеСоединения = Соединение.ПрочитатьДвоичныеДанные(1024);
+			Соединение.ТаймаутЧтения = ТаймаутЧтения;
+			ДанныеСоединения = Соединение.ПрочитатьДвоичныеДанные(РазмерБуфера);
 			Данные.Добавить(ДанныеСоединения);
 		КонецЦикла;
 	Исключение

src/Классы/СерверноеСобытие.os

@@ -4,7 +4,7 @@
 
 Процедура ПриСозданииОбъекта()
 	ТипСобытия = "";
-	Индентификатор = "";
+	Идентификатор = "";
 	Данные = Новый Массив();	
 КонецПроцедуры
 

src/Классы/СоединенияСерверныхСобытий.os

@@ -1,5 +1,8 @@
+#Использовать semaphore
+
 Перем ПулСоединений;
 Перем Подписки;
+Перем Семафор;
 
 &Желудь
 Процедура ПриСозданииОбъекта(&Пластилин ПодпискиСерверныхСобытий)
@@ -12,17 +15,21 @@
 КонецФункции
 
 Функция ПулСоединений() Экспорт
-	Возврат ПулСоединений;
+	Возврат ПулСоединений.Скопировать(,"Соединение, ИдСоединения");
 КонецФункции
 
 Процедура Добавить(Соединение, Идентификатор, Топик) Экспорт
 
+	Семафор.Захватить();
+
 	НовоеСоединение = ПулСоединений.Добавить();
 	НовоеСоединение.Идентификатор = Идентификатор;
 	НовоеСоединение.Топик = Топик;
 	НовоеСоединение.Соединение = Соединение;
 	НовоеСоединение.ИдСоединения = Строка(Новый УникальныйИдентификатор());
 
+	Семафор.Освободить();
+
 	ОповеститьОткрытиеСоединения(Идентификатор, Топик, НовоеСоединение.ИдСоединения);
 
 КонецПроцедуры
@@ -34,8 +41,18 @@
 	КонецЦикла;
 КонецПроцедуры
 
+Процедура УдалитьСтрокуПулаПоИдСоединения(ИдСоединения) Экспорт
+	Соединения = ПолучитьСоединениеПоИдСоединения(ИдСоединения);
+
+	Если Соединения.Количество() > 0 Тогда
+		УдалитьСтрокуПула(Соединения[0]);
+	КонецЕсли;
+КонецПроцедуры
+
 Процедура УдалитьСтрокуПула(СтрокаСоединения) Экспорт
 
+	Семафор.Захватить();
+
 	Идентификатор = СтрокаСоединения.Идентификатор;
 	Топик = СтрокаСоединения.Топик;
 	ИдСоединения = СтрокаСоединения.ИдСоединения;
@@ -44,6 +61,8 @@
 	ОсвободитьОбъект(СтрокаСоединения.Соединение);
 	ПулСоединений.Удалить(СтрокаСоединения);
 
+	Семафор.Освободить();
+
 	ОповеститьЗакрытиеСоединения(Идентификатор, Топик, ИдСоединения);
 КонецПроцедуры
 
@@ -90,11 +109,18 @@
 КонецФункции
 
 Процедура Инициализация()
+	Семафор = Новый Семафор();
 	ПулСоединений = Новый ТаблицаЗначений();
 	ПулСоединений.Колонки.Добавить("Идентификатор");
 	ПулСоединений.Колонки.Добавить("Топик");
 	ПулСоединений.Колонки.Добавить("Соединение");
 	ПулСоединений.Колонки.Добавить("ИдСоединения");
+
+	ПулСоединений.Индексы.Добавить("Топик");
+	ПулСоединений.Индексы.Добавить("ИдСоединения");
+	ПулСоединений.Индексы.Добавить("Идентификатор");
+	ПулСоединений.Индексы.Добавить("Топик, Идентификатор");
+
 КонецПроцедуры
 
 Процедура ЗакрытьСоединениеВПопытке(Соединение) Экспорт

tests/alltest.os

@@ -38,7 +38,7 @@
 КонецФункции
 
 Функция ПроизвольныйГетЗапрос(АдресТеста, Заголовки = Неопределено)
-	Соединение = Новый HTTPСоединение("http://localhost",3333,,,,);
+	Соединение = Новый HTTPСоединение("http://localhost",3333,,,,5);
 	Запрос = Новый HTTPЗапрос(АдресТеста);
 	Если Не Заголовки = Неопределено Тогда
 		Запрос.Заголовки = Заголовки;
@@ -665,9 +665,9 @@
 	// Дано
 	КонтролССЕ = Поделка.НайтиЖелудь("КонтролССЕ");
 	КонтролССЕ.ИнициализироватьСостояния();
-	ССЕКлиент1 = Новый ССЕКлиент("localhost", 3333, "/sse/test1");
-	ССЕКлиент2 = Новый ССЕКлиент("localhost", 3333, "/sse/test1");
-	ССЕКлиент3 = Новый ССЕКлиент("localhost", 3333, "/sse/test1");
+	ССЕКлиент1 = Новый ССЕКлиент("localhost", 3333, "/sse/testsub");
+	ССЕКлиент2 = Новый ССЕКлиент("localhost", 3333, "/sse/testsub");
+	ССЕКлиент3 = Новый ССЕКлиент("localhost", 3333, "/sse/testsub");
 
 	// Когда
 

tests/app/КонтролССЕ.os

@@ -14,9 +14,10 @@
 	Лог = Логирование.ПолучитьЛог("oscript.app.winow.test.ssecontrol");
 
 	ИмяТопика = "/sse/test1";
+	ТопикиСерверныхСобытий.Добавить(ИмяТопика, Новый Действие(ЭтотОбъект, "НовоеПодключениеССЕ"));
 
-	ТопикиСерверныхСобытий.Добавить(ИмяТопика,
-									Новый Действие(ЭтотОбъект, "НовоеПодключениеССЕ"),
+	ТопикиСерверныхСобытий.Добавить("/sse/testsub",
+									Новый Действие(ЭтотОбъект, "ПодключенияКУдалению"),
 									Новый Действие(ЭтотОбъект, "ОтключениеССЕ"));
 
 	ИнициализироватьСостояния();
@@ -33,6 +34,12 @@
 
 КонецПроцедуры
 
+Процедура ПодключенияКУдалению(Сессия, ИД) Экспорт
+
+	Лог.Отладка("Подключился " + Ид);
+
+КонецПроцедуры
+
 Процедура ОтключениеССЕ(Сессия, ИД) Экспорт
 
 	Лог.Отладка("Отключился " + Ид);