Lines Matching refs:pc_proto
46 struct proto *pc_proto; member
82 conn->pc_proto = proto; in proto_alloc()
98 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_free()
182 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_connect_wait()
183 PJDLOG_ASSERT(conn->pc_proto->prt_connect_wait != NULL); in proto_connect_wait()
186 error = conn->pc_proto->prt_connect_wait(conn->pc_ctx, timeout); in proto_connect_wait()
214 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_accept()
215 PJDLOG_ASSERT(conn->pc_proto->prt_accept != NULL); in proto_accept()
217 newconn = proto_alloc(conn->pc_proto, PROTO_SIDE_SERVER_WORK); in proto_accept()
221 error = conn->pc_proto->prt_accept(conn->pc_ctx, &newconn->pc_ctx); in proto_accept()
240 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_send()
241 PJDLOG_ASSERT(conn->pc_proto->prt_send != NULL); in proto_send()
243 error = conn->pc_proto->prt_send(conn->pc_ctx, data, size, -1); in proto_send()
258 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_recv()
259 PJDLOG_ASSERT(conn->pc_proto->prt_recv != NULL); in proto_recv()
261 error = conn->pc_proto->prt_recv(conn->pc_ctx, data, size, NULL); in proto_recv()
277 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_connection_send()
278 PJDLOG_ASSERT(conn->pc_proto->prt_send != NULL); in proto_connection_send()
281 PJDLOG_ASSERT(mconn->pc_proto != NULL); in proto_connection_send()
284 protoname = mconn->pc_proto->prt_name; in proto_connection_send()
287 error = conn->pc_proto->prt_send(conn->pc_ctx, in proto_connection_send()
318 PJDLOG_ASSERT(newconn->pc_proto->prt_wrap != NULL); in proto_wrap()
319 error = newconn->pc_proto->prt_wrap(fd, client, &newconn->pc_ctx); in proto_wrap()
340 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_connection_recv()
341 PJDLOG_ASSERT(conn->pc_proto->prt_recv != NULL); in proto_connection_recv()
346 error = conn->pc_proto->prt_recv(conn->pc_ctx, in proto_connection_recv()
364 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_descriptor()
365 PJDLOG_ASSERT(conn->pc_proto->prt_descriptor != NULL); in proto_descriptor()
367 return (conn->pc_proto->prt_descriptor(conn->pc_ctx)); in proto_descriptor()
376 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_address_match()
377 PJDLOG_ASSERT(conn->pc_proto->prt_address_match != NULL); in proto_address_match()
379 return (conn->pc_proto->prt_address_match(conn->pc_ctx, addr)); in proto_address_match()
388 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_local_address()
389 PJDLOG_ASSERT(conn->pc_proto->prt_local_address != NULL); in proto_local_address()
391 conn->pc_proto->prt_local_address(conn->pc_ctx, addr, size); in proto_local_address()
400 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_remote_address()
401 PJDLOG_ASSERT(conn->pc_proto->prt_remote_address != NULL); in proto_remote_address()
403 conn->pc_proto->prt_remote_address(conn->pc_ctx, addr, size); in proto_remote_address()
414 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_timeout()
436 PJDLOG_ASSERT(conn->pc_proto != NULL); in proto_close()
437 PJDLOG_ASSERT(conn->pc_proto->prt_close != NULL); in proto_close()
439 conn->pc_proto->prt_close(conn->pc_ctx); in proto_close()