1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
package roadrunner
import (
"errors"
"net"
"strings"
"time"
"os/exec"
)
const (
FactoryPipes = iota
FactorySocket
)
// Server config combines factory, pool and cmd configurations.
type ServerConfig struct {
// Command includes command strings with all the parameters, example: "php worker.php pipes". This config section
// // must not change on re-configuration.
Command string
// User specifies what user to run command under, for Unix systems only. Support both UID and name options. Keep
// empty to use current user.This config section must not change on re-configuration.
User string
// Group specifies what group to run command under, for Unix systems only. Support GID or name options. Keep empty
// to use current user.This config section must not change on re-configuration.
Group string
// Relay defines connection method and factory to be used to connect to workers:
// "pipes", "tcp://:6001", "unix://rr.sock"
// This config section must not change on re-configuration.
Relay string
// FactoryTimeout defines for how long socket factory will be waiting for worker connection. This config section
// must not change on re-configuration.
FactoryTimeout time.Duration
// Pool defines worker pool configuration, number of workers, timeouts and etc. This config section might change
// while server is running.
Pool *Config
}
func (f *ServerConfig) makeCommand() (func() *exec.Cmd, error) {
return nil, nil
}
// makeFactory creates and connects new factory instance based on given parameters.
func (f *ServerConfig) makeFactory() (Factory, error) {
if f.Relay == "pipes" || f.Relay == "pipe" {
return NewPipeFactory(), nil
}
dsn := strings.Split(f.Relay, "://")
if len(dsn) != 2 {
return nil, errors.New("invalid relay DSN (pipes, tcp://:6001, unix://rr.sock)")
}
ln, err := net.Listen(dsn[0], dsn[1])
if err != nil {
return nil, nil
}
return NewSocketFactory(ln, time.Second*f.FactoryTimeout), nil
}
|
