type waitMessage struct { msg map[string]chan *structure.Message mu sync.Mutex } func (w *waitMessage) Set(msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() w.msg[msg.ID] = make(chan structure.Message,1) w.msg[msg.ID] <- msg } func (w *waitMessage) Get(id string) (msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() defer delete(w.msg,id) msg <- w.msg[id] return }

его нельзя копировать

так поэтому и указатель) чтобы не колпировать а гарантированно иметь только один

разве не так?

чем плох указатель на мьютекс?

или это говно

так поэтому и указатель) чтобы не колпировать а гарантированно иметь только один

его не надо копировать просто

чем плох указатель на мьютекс?

+

тем что это bad practice

его не надо копировать просто

а если стурктуру передадут по занчению?

тем что это bad practice

не спорю, но почему?

а если стурктуру передадут по занчению?

Тоже интересует этот вопрос.

ну вообще он будет сокрыт в структуре для других пакето поэтому можно ссылку и не использовать

ну вообще он будет сокрыт в структуре для других пакето поэтому можно ссылку и не использовать

проблемы возникают когда кто-то внешний объект передаст по значению, а мапа сама по себе ссылочный тип и будет коллизия/гонка/конкуррентный доступ

обычно это случается при развитии кода, когда новые люди что-то дописывают

что не отрицает что это может быть bad practice

но я хочу узнать откуда такое мение

окей гайс у меня проблема и не понимание остались почему у меня ошибка

var TLSConnActive map[string]client_tls type waitMessage struct { msg map[string]chan *structure.Message mu *sync.Mutex } func (w *waitMessage) Set(msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() w.msg[msg.ID] = make(chan structure.Message,1) w.msg[msg.ID] <- msg } func (w *waitMessage) Get(id string) (msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() defer delete(w.msg,id) msg <- w.msg[id] return }

var TLSConnActive map[string]client_tls type waitMessage struct { msg map[string]chan *structure.Message mu *sync.Mutex } func (w *waitMessage) Set(msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() w.msg[msg.ID] = make(chan structure.Message,1) w.msg[msg.ID] <- msg } func (w *waitMessage) Get(id string) (msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() defer delete(w.msg,id) msg <- w.msg[id] return }

# region45/obereg_video/tls_server tls_server/users.go:20:19: cannot use make(chan structure.Message, 1) (type chan structure.Message) as type chan *structure.Message in assignment tls_server/users.go:21:19: cannot use msg (type structure.Message) as type *structure.Message in send tls_server/users.go:28:9: invalid operation: msg <- w.msg[id] (send to non-chan type structure.Message) tls_server/users.go:74:17: invalid operation: c.write <- msg (send to non-chan type *chan interface {}) tls_server/users.go:78:1: missing return at end of function # region45/obereg_video/web_server web_server/web_server.go:61:5: undefined: tls_conn_active

я тут в одного пишу и мне обсудить не скем даже

убери звезду func (w *waitMessage) Set(msg structure.Message) {

тип же разнй

func (w waitMessage) Set(msg structure.Message) {

func (w waitMessage) Set(msg structure.Message) {

вот тогда точно нужен указател на мьютекс)

хотя не, не убирай)

иначе это уже другой будет мьютекс

type waitMessage struct { msg map[string]chan *structure.Message mu *sync.Mutex } func (w *waitMessage) Set(msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() w.msg[msg.ID] = make(chan *structure.Message,1) w.msg[msg.ID] <- msg } func (w *waitMessage) Get(id string) (msg structure.Message) { w.mu.Lock() defer w.mu.Unlock() defer delete(w.msg,id) msg <- *w.msg[id] return }

я не заметил, что он тип на структуру поменял

w.msg[msg.ID] = make(chan structure.Message,1) w.msg[msg.ID] = make(chan *structure.Message,1)

вот тут звездока нужна

и еще, ты каждывй раз заменяешь

или тут Set только для нового?

а вот тут по моуму не нужна msg <- *w.msg[id]

У мьютекса все методы по указателю. Какой вообще по значению?

У мьютекса все методы по указателю. Какой вообще по значению?

что?

У мьютекса все методы по указателю. Какой вообще по значению?

какая разница

для гета еще можно было бы подумать

так последняя ошибка осталась

func (w waitMessage) Get(id string) (msg *structure.Message) { w.mu.Lock() defer w.mu.Unlock() defer delete(w.msg,id) msg <- w.msg[id] return }

на этом msg <- w.msg[id]

https://play.golang.org/p/rQ0iCVpeXGq

вот тут вроде все норм

на этом msg <- w.msg[id]

msg = <-

У мьютекса все методы по указателю. Какой вообще по значению?

а сам мьютекс уже другой, если его скопировали не по указателю

а точно

а точно

я ссылку скинал, ага) там починено)

вери сенкс

прям счастье

Самые отзывчивые посонны.

@Nixolay https://play.golang.org/p/D4oURfTzIoB я бы от чего-то такого отталкивался

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

@Nixolay https://play.golang.org/p/D4oURfTzIoB я бы от чего-то такого отталкивался

+, очень правильный код

@Nixolay https://play.golang.org/p/D4oURfTzIoB я бы от чего-то такого отталкивался

спсибо

я не уверен что идея базовая ок, но я считаю что это проблема автора идеи

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

Расскажи как отдать видео с 4 камер за серым ip на веб морду клиента за серым ip

это все без единого белого?

да

а как TCP сессия устанавливается?

Расскажи как отдать видео с 4 камер за серым ip на веб морду клиента за серым ip

сочувствую что у тебя камеры ) я лет 10 назад был бедным голодным студентом, наелся с ними на халтурках

сочувствую что у тебя камеры ) я лет 10 назад был бедным голодным студентом, наелся с ними на халтурках

Расскажи как отдать видео с 4 камер за серым ip на веб морду клиента за серым ip

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

кажется что топорно, но таки должно работать

Так. А объясните как вообще пакеты доходят без белых IP? @Nixolay

Так. А объясните как вообще пакеты доходят без белых IP? @Nixolay

На машине стоит малинка она устанавливает соединение с сервером мои, написанным на го

малинка режит на чанки видео и шлет мне

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

Ну так белый все таки есть.

подразумевается что по запросу веб морды она будет запрашивать у машины по tls а машина отправлять нужные чанки и плейлиист

Кто-то вот это использовал: github.com/docker/docker/client

сейчас там метод client.NewEnvClient() стал деприкейтет, и как теперь это использовать не очень понятно

сейчас там метод client.NewEnvClient() стал деприкейтет, и как теперь это использовать не очень понятно

use NewClientWithOpts(FromEnv) там написано

find usage по коду - находишь пример использования

спс!

https://play.golang.org/p/TvtrMfZDdEr подскажите, почему так работает? и как создать такого бесконечного слушателя правильно?

зачем ты несколько раз вытаскиваешь значение из канала в одной и той же итерации?

https://play.golang.org/p/taYj__NQ08m