мб баг просто

удялял его, естественно не работало. открывал новый терминал по 100 раз - все так же

можешь в личку env кинуть?

скажите, а обязательно тут передавать структуру? можно ли просто маппинг передать ? t, _ := template.ParseFiles("index.html") t.Execute(w, &page{Title: "Just page", Msg: "Hello World"})

птом что для каждой страницы делать отдельную структуру... не понимаю зачем такое нужно

мб попробуеш ручками перебить го path?

а попробуй ради интереса export GOPATH=$PWD

ну это не решение же

ну это не решение же

если заработает можно двигаться дальше чтоб решить

ну это не решение же

просто скорми ему по такой сылке путь до go

Всем привет. Как к дате вида 12.04.2018 прибавить 7 дней, что бы получилось 19.04.2018?

time.AddDate

прием как указать свою маску подсети для расчета

package main import ( "fmt" "net" ) func main() { ip := net.ParseIP("172.24.1.1") mask := ip.DefaultMask() # тут хочется указать свою маску подсети но не знаю как network := ip.Mask(mask) fmt.Println(network.String()) }

необходимо из 172.24.1.1 255.255.255.0 получить 172.24.1.0/24

@Amplitudo здравствуйте, всё вышло, но у меня нет buf.Flush()

а buf.Reset() что то не особо радует

вообще точнее

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

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

defer file.Close() в цикле не надо делать, он у вас бесконечный

так файл же типа каждый раз другой

нет?

Defer будет выполняться только после завершения функции

ааа

извиняюсь

вот так оно

буфер не стирается

буфер не стирается

https://golang.org/pkg/io/#CopyN https://golang.org/pkg/io/#LimitedReader там хитрее надо может что-то из этого подойдёт лучше

так по времени нужно (

а не по размеру

https://habr.com/post/306914/

не всегда выйдет узнать сколько нужно байтов для n секунд

100%-й точности я сходу не скажу как добиться примерной - можно

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

а куда читать? bytes.Buffer?)

и как его сбрасивать?)

вот что я делаю не так...

Reset resets the buffer to be empty, but it retains the underlying storage for use by future writes.

да, в буфер сброс таймера смотрите в доке

вы в отдельной горутине это делаете

да

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

оно не горнутино безопасно там внутри

получаеться нормально

просто не чиститься буфер

хм

кидайте body в bytes buffer и по тику кидайте содержимое буффера buffer.Bytes() в канал, далее buffer.Flush() и пишите туда заново, канал читает другая горутина и пишет каждую пачку байт в новый файл

как мне говорили

оно не горнутино безопасно там внутри

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

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

доку читать и исходники

Эх, щас бы в 2к18 исходники читать для определения потокобезопасности

https://golang.org/src/bytes/buffer.go ctrl+f вводим sync не находим

https://golang.org/src/bytes/buffer.go ctrl+f вводим sync не находим

:D

вот бляха

что же делать то...

@Amplitudo здравствуйте, всё вышло, но у меня нет buf.Flush()

Да, напутал, flush это для пишущего

https://stackoverflow.com/q/19646717

Тут есть неплохой пример как сделать потокобезопасным, и не все функции вам нужны, но хз подойдёт ли такое

а как мне буфер очищать?

оно походу и в правду не работает

из за того что в горутине

Так и очищать как в примере, обернуть в враппер и использовать мьютексы

Либо не используйте readFrom, и сами читайте в цикле

Тут вам поможет конструкция select case default

t := time.Now() ticker := 1 out, _ := os.Create("test0.ts") defer out.Close() for { io.CopyN(out, resp.Body, 1000) if time.Since(t)-time.Second*6 >= time.Second { t = time.Now() out, _ = os.Create("test" + strconv.Itoa(ticker) + ".ts") log.Println("Ss") ticker++ } }

ERROR: S client not available

это вообще гавно?

Case слушает тик, пишет в файл и очищает буфет

А default читает из поток по N байт, так же как это делает readfrom

И тогда reset будет работать

Сейчас reset не работает, потому что буфет используется двумя потоками, первый внутри readfrom, второй горутина

А что значит по н байт?

Это сколько?

func (b *Buffer) ReadFrom(r io.Reader) (n int64, err error) { b.lastRead = opInvalid for { i := b.grow(MinRead) m, e := r.Read(b.buf[i:cap(b.buf)]) if m < 0 { panic(errNegativeRead) } b.buf = b.buf[:i+m] n += int64(m) if e == io.EOF { return n, nil // e is EOF, so return nil explicitly } if e != nil { return n, e } } } не конца вдупляю

Для ReadFrom это MinRead

У вас может быть что-то другое, меньше, больше

а подскажите на сколько это плохой варик? Просто работает идеально func dumpTS2HLS(url string, name string) error { resp, err := http.Get(url) if err != nil { return err } defer resp.Body.Close() t := time.Now() ticker := 1 out, _ := os.Create(name + "0.ts") defer out.Close() for { io.CopyN(out, resp.Body, 512) if time.Since(t)-time.Second*6 >= time.Second { READY++ log.Println(name + " ready: " + strconv.Itoa(READY)) t = time.Now() out, _ = os.Create(name + strconv.Itoa(ticker) + ".ts") ticker++ } } }

то есть io.Copy(out, resp.Body) но нужно out менять на лету

https://play.golang.org/p/WTTEZSvvYMx как-то так должно работать

Наверно

ООО

блин

пишет пустые файлы

Ээ

в принципе

вроде понял

в чем ошибка

мб выйдет даже пофиксить

очень благодарен

это выглядит уже адекватно

я сам новичок, так что пардон за нерабочий код, так и не понял в чём ошибка ?

о

вот

добавил перед io.Copy out.UpdateFile("test" + strconv.Itoa(0) + ".ts")

)

и тикер изначално 1

по сути там нет файла же в начале