Lines Matching refs:p
47 func add_port(p *port) {
54 old := port_registry_.m[p.key]
57 port_registry_.m[p.key] = p
63 func (p *port) Close() {
64 if p.rcv != nil {
65 p.rcv.Close()
68 if p.snd != nil {
69 p.snd.Close()
97 func nxt_go_add_port(ctx *C.nxt_unit_ctx_t, p *C.nxt_unit_port_t) C.int {
101 pid: int(p.id.pid),
102 id: int(p.id.id),
104 rcv: getUnixConn(int(p.in_fd)),
105 snd: getUnixConn(int(p.out_fd)),
110 p.in_fd = -1
111 p.out_fd = -1
127 p *C.nxt_unit_port_t) {
130 pid: int(p.id.pid),
131 id: int(p.id.id),
151 p := find_port(key)
153 if p == nil {
158 n, oobn, err := p.snd.WriteMsgUnix(GoBytes(buf, buf_size),
179 p := find_port(key)
181 if p == nil {
186 n, oobn, _, _, err := p.rcv.ReadMsgUnix(GoBytes(buf, buf_size),