Lines Matching refs:vsp

49 	struct vtc_sess		*vsp;  member
57 struct vtc_sess *vsp; in Sess_New() local
59 ALLOC_OBJ(vsp, VTC_SESS_MAGIC); in Sess_New()
60 AN(vsp); in Sess_New()
61 vsp->vl = vl; in Sess_New()
62 REPLACE(vsp->name, name); in Sess_New()
63 vsp->repeat = 1; in Sess_New()
64 return (vsp); in Sess_New()
70 struct vtc_sess *vsp; in Sess_Destroy() local
72 TAKE_OBJ_NOTNULL(vsp, vspp, VTC_SESS_MAGIC); in Sess_Destroy()
73 REPLACE(vsp->name, NULL); in Sess_Destroy()
74 FREE_OBJ(vsp); in Sess_Destroy()
78 Sess_GetOpt(struct vtc_sess *vsp, char * const **avp) in Sess_GetOpt() argument
83 CHECK_OBJ_NOTNULL(vsp, VTC_SESS_MAGIC); in Sess_GetOpt()
89 vsp->rcvbuf = atoi(av[1]); in Sess_GetOpt()
94 vsp->repeat = atoi(av[1]); in Sess_GetOpt()
98 vsp->keepalive = 1; in Sess_GetOpt()
106 sess_process(struct vtclog *vl, struct vtc_sess *vsp, in sess_process() argument
111 CHECK_OBJ_NOTNULL(vsp, VTC_SESS_MAGIC); in sess_process()
113 rv = http_process(vl, vsp, spec, sock, sfd, addr, vsp->rcvbuf); in sess_process()
121 struct vtc_sess *vsp; in sess_thread() local
129 vsp = ta.vsp; in sess_thread()
130 CHECK_OBJ_NOTNULL(vsp, VTC_SESS_MAGIC); in sess_thread()
131 vl = vtc_logopen("%s", vsp->name); in sess_thread()
134 assert(vsp->repeat > 0); in sess_thread()
136 vsp->repeat, vsp->keepalive ? " using keepalive" : ""); in sess_thread()
137 for (i = 0; i < vsp->repeat; i++) { in sess_thread()
139 if (! vsp->keepalive) in sess_thread()
140 fd = sess_process(vl, ta.vsp, ta.spec, fd, ta.asocket, ta.listen_addr); in sess_thread()
142 while (fd >= 0 && i++ < vsp->repeat) in sess_thread()
143 fd = sess_process(vl, ta.vsp, ta.spec, fd, in sess_thread()
156 struct vtc_sess *vsp, in Sess_Start_Thread() argument
168 CHECK_OBJ_NOTNULL(vsp, VTC_SESS_MAGIC); in Sess_Start_Thread()
175 ta->vsp = vsp; in Sess_Start_Thread()