но это происходит где-то в недрах рефлексии

почему на tasks грешишь, не очевидно

Previous write at 0x00c0001b802c by goroutine 56: github.com/qbeon/webwire-go.(*connection).deregisterTask() D:/go-workspace/src/github.com/qbeon/webwire-go/connection.go:114 +0x7f

вот опять произошёл при десятой попытке

вот опять произошёл при десятой попытке

Ну это рейс

У тебя запись в одно место возможна параллельно

Где то забыл лок

вот теперь все прояснилось

Трейс есть же

Значит что в другом месте Лок не берешь или не тот берешь

Или рано отпускаешь

Где то забыл лок

так я-ж говорю, тот код на который он ругается вообще-то под мутексом (previous write) а read в рефлекте из-под testify/assert

вот полный лог

так я-ж говорю, тот код на который он ругается вообще-то под мутексом (previous write) а read в рефлекте из-под testify/assert

Ну так у тебя мьютекс должны брать все

Значит вокруг ассерта тоже

мне кажется тут во всём виновата рефлексия которая лезет в недры защищённой структуры и пытается её прочитать параллельно с штатной записью

и думаю с этим вообще ничего не поделать

и думаю с этим вообще ничего не поделать

Мьютекс вокруг рефлексии

Тот же

Мьютекс вокруг рефлексии

дак как я это сделаю то?)) рефлексия происходит в коде тестов внутри assert'а от testify. а изменения внутренностей объекта который реализует интерфейс Connection происходит в недрах библиотеки и защищена своим мутексом

понимаешь?

дак как я это сделаю то?)) рефлексия происходит в коде тестов внутри assert'а от testify. а изменения внутренностей объекта который реализует интерфейс Connection происходит в недрах библиотеки и защищена своим мутексом

Так тестифай значит тоже под мьютекс

понимаешь?

Я не понимаю в чём проблема тогда тестифай тоже обернуть

Так тестифай значит тоже под мьютекс

дак они не могут делить мутекс))) смотри... - есть объект соединения, в нём сокет и каунтер задач которые на этом соединении обрабатываются - при завершении обработки запроса каунтер декредментируется - при новом запросе - инкрементируется - эта операция защищена мутексом, каждый connection это thread-safe object - структура connection реализует интерфейс Connection, который я выдаю наружу библиотеки а тесты в этот интерфейс лезут с рефлексией и следственно в защищённые внутренности объекта и видимо поэтому происходит data race

дак они не могут делить мутекс))) смотри... - есть объект соединения, в нём сокет и каунтер задач которые на этом соединении обрабатываются - при завершении обработки запроса каунтер декредментируется - при новом запросе - инкрементируется - эта операция защищена мутексом, каждый connection это thread-safe object - структура connection реализует интерфейс Connection, который я выдаю наружу библиотеки а тесты в этот интерфейс лезут с рефлексией и следственно в защищённые внутренности объекта и видимо поэтому происходит data race

Ну так что мешает принять соединение, потом взять мьютекс и только потом дёрнуть ассерт на результат

т.е. решить это наверное можно так: вместо: require.Len(t, affectedConnections, 0) пишем так require.True(t, len(affectedConnections) == 0) таким образом он в недры интерфейса лезть не должен а лишь проверить размер списка, что от него и ожидалось

Ну так что мешает принять соединение, потом взять мьютекс и только потом дёрнуть ассерт на результат

ты немнго не понял проблему) тут синхронизировать тест и конекшны просто невозможно и это было бы даже неправильно. Они не могут делить мутекс. Проблема именно в баловстве с рефлексией, которая вопреки мутекста лезет в недры реализации интерфейса видимо, потому-что про мутекс ничего не знает

т.е. решить это наверное можно так: вместо: require.Len(t, affectedConnections, 0) пишем так require.True(t, len(affectedConnections) == 0) таким образом он в недры интерфейса лезть не должен а лишь проверить размер списка, что от него и ожидалось

что можно предотвратить вот так, я думаю

Подскажите, а можно как-то легко проверить что glide.lock содержит пакеты соответствующие glide.yml? Ну или после glide install проверить, что установленные пакеты удовлетворяют glide.yml

А лок разве не после успешного инстала генерится? Или ты не доверяешь ему?

Лок после апдейта

Хочу его в гит коммитить

Чтобы версии фиксировать

Ну и ямль ведь в репозитории?

Ну да

Не ты значит кто другой сгенерил по ямлю лок

Ну да. Я хочу исключить ситуацию, что разработчик ямл изменил, а Лок не обновил

Если он изменил ямль а лок не сгенерил, значит останется старая версия и все будет работать хорошо

Понятно, что в большинстве случаев сборка упадет, но хочется более явно и надёжно

Если он изменил ямль а лок не сгенерил, значит останется старая версия и все будет работать хорошо

Не. Он мог не просто так его поменять. Например, новую зависимость добавить или минимальную версию поднять из-за бага

Не надо ходить в крайности. Не доверяйшь сам сгенери вчегда новый лок когда пришло изменение в ямл

Но я бы на твоем месте так не делал бы

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

Вопрос не в доверии а подстраховке

Что ж за люди тас у вас? Поменял версию и забыл поставить пакет?

Да всяко бывает. Поспешил, задумался. И на ревью не заметишь такое

Обычная человеческая ошибка.

Да я, если честно, даже у джунов такого не встречал

Ну а вы тоже Лок коммитите или всю папку вендор? Или генерируете его?

Да я, если честно, даже у джунов такого не встречал

Соответственно, оно редко и тем сложнее понять

Лок

Помогите пожалуйста уже не могу понять. в шаблоне после вызова цикла больше ничего не выводится. что в цикле и дальше не выводиться. вот тут https://github.com/sashaaro/docker-container-proxy/blob/master/network.html#L48 то есть выводиться последним тегом последний открытый тег <td> перед циклом

Предлагаю вам выкинуть html/template, она отвратительная. Для генерирования html используйте https://github.com/valyala/quicktemplate в которой html шаблоны пишутся на Го-подобном языке с функциями и интерфейсами. Сэкономите много нервов

Соответственно, оно редко и тем сложнее понять

Я просто не понимаю как можно указать новую версию и забыть ее поставить. Человек ведь работает дальше, если он воспользуется чем-то обратно несовместимым, то билд не соберется, а если нет, то код будет работать как и раньше и в таком случае не надо париться

Я просто не понимаю как можно указать новую версию и забыть ее поставить. Человек ведь работает дальше, если он воспользуется чем-то обратно несовместимым, то билд не соберется, а если нет, то код будет работать как и раньше и в таком случае не надо париться

Так не поставить. Забыть закоммитить ещё один файл.

Хуже если соберётся.

Какой файл? Лок что ли?

Да

Либо я тебя не понимаю, либы ты меня

Что за. Он же висеть будет в измененных. Ваши люди комитят не все изменения?

Имхо, если можно автоматизировать проверку, надо автоматизировать. Если нельзя - ну и фиг с ней, потратим пять минут, решим руками

Что за. Он же висеть будет в измененных. Ваши люди комитят не все изменения?

Конечно не все. git add -p это обязательно

Ну то есть скорее всего почти все, но мало ли

Предлагаю вам выкинуть html/template, она отвратительная. Для генерирования html используйте https://github.com/valyala/quicktemplate в которой html шаблоны пишутся на Го-подобном языке с функциями и интерфейсами. Сэкономите много нервов

Посмотрю возможно. Но у меня проект не особо большой пока всего два шаблона и стандартного вроде хватает. А проблема наверное очевидная а я уже 2 день не могу решить

Помогите пожалуйста уже не могу понять. в шаблоне после вызова цикла больше ничего не выводится. что в цикле и дальше не выводиться. вот тут https://github.com/sashaaro/docker-container-proxy/blob/master/network.html#L48 то есть выводиться последним тегом последний открытый тег <td> перед циклом

.selectedTargets внутри .containers?

Вижу что нет. Ну вот оно так не будет работать, потому что он после вызова for ставит . на элемент массива

https://[::]:9090/ это-ж у нас невалидный URL?

https://www.freeformatter.com/url-parser-query-string-splitter.html вроде говорит мол валидный

https://[::]:9090/ это-ж у нас невалидный URL?

Мне кажется в таком хосте хотя бы одна шестандцатиричная цифра должна быть

Хотя могу ошибаться

Мне кажется в таком хосте хотя бы одна шестандцатиричная цифра должна быть

ну это по сути ipv6 localhost

ну это по сути ipv6 localhost

Скорее any, не?

Аналог 0.0.0.0?

Скорее any, не?

эээ, я гребу, да, any, не localhost

Ну в урле это странно

у меня есть библиотека на плюсах, которая делает манипуляции с массивом байт. Если я напишу TCP клиент на Go и буду в цикле (по мере поступления инфы из сети) буду вызывать cgo, как это отразится на производительность?

Тесты дадут ответ на все вопросы.

блин, это какой-то анекдот, проверил всё тщательнейшим образом локально, протестировал всё досконально, и GOMAXPROCS=1 и GOMAXPROCS=12, и с race detecter'ом и без, и все тесты, и только отдельные.. локально всё работает отлично. Пушаю в master, запускается CI и фейлится 4 раза подряд на одной и той-же строке с DATA RACE WARNING ? ну вот как? ?

GOCACHE=off естественно, но всё-равно никак не могу воспроизвести data race локально, а на CI она стабильно возникает

блин, это какой-то анекдот, проверил всё тщательнейшим образом локально, протестировал всё досконально, и GOMAXPROCS=1 и GOMAXPROCS=12, и с race detecter'ом и без, и все тесты, и только отдельные.. локально всё работает отлично. Пушаю в master, запускается CI и фейлится 4 раза подряд на одной и той-же строке с DATA RACE WARNING ? ну вот как? ?

Не тот код небось

Не тот код небось

тот тот, я теперь таки после двадцатого запуска смог воспроизвести гонку проблема вот тут: https://github.com/qbeon/webwire-go/blob/master/socketImpl.go#L111

и проблема очевидна и глупа, я конкурентно мутирую глобальную переменную пакета gorilla/websocket

.selectedTargets внутри .containers?

Нет это отдельный параметр в объекте который я передаю в шаблон вот https://github.com/sashaaro/docker-container-proxy/blob/e45e5aaf075add82dbe2e7fbd452fed1cdad7af5/dashboard.go#L66

Та же фигня

Ну да, та же фигня 32-я строка for { message, err := bufio.NewReader(conn).ReadString('\n') Я правильно понимаю, что вы на каждую строку новый bufio.NewReader создаете? Т.е. вы берете стрим, создаете ридер из него, читаете строку, дропаете ридер, берете стрим, создаете ридер - и так по кругу... Я ведь правильно понимаю, что у вас задача - тупо запустить cmd локально и stdOut отдать на удаленную сторону, а то, что пришло оттуда - засунуть в stdIn? Есть такая штука io.Copy(), вот она вам нужна

привет А насколько плохо давать двум страктам пустой метод, чтобы по нему исключительно загнать их в один интерфейс?

Это норм, если метод нигде не вызывается

нигде, естественно

В нормальных языках можно интерфейс без метода делать — называется интерфейс маркёр.

я бы задумался, если возникает такая ситуация - точно ли эти два стракта попадают под один интерфейс?

Ну естественно надо подумать. Но переделать если что всегда можно ?

я бы задумался, если возникает такая ситуация - точно ли эти два стракта попадают под один интерфейс?

это стракт и слайс таких страктов на самом деле, я тут унификацией поиска в монге развлекаюсь

привет А насколько плохо давать двум страктам пустой метод, чтобы по нему исключительно загнать их в один интерфейс?

Для джавы/С# это норм, для Го звучит как бред сумасшедшего. Зачем вам такое понадобилось?

для жавы и шарпа вообще интерфейсы явно задают.

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

Зачем понадобился "пустой метод" и нафига искусственно загонять в один интерфейс?