Lines Matching refs:conn
200 etm_bad_acc_to_sec = 0; /* sleep timeout (in sec) after bad conn accept */
761 etm_xport_conn_t conn; /* connection to return */
764 if ((conn = etm_xport_open(hdl, addr)) == NULL) {
771 *connp = conn;
785 etm_conn_close(fmd_hdl_t *hdl, char *err_substr, etm_xport_conn_t conn)
789 if (etm_xport_close(hdl, conn) == NULL) {
812 etm_io_op(fmd_hdl_t *hdl, char *err_substr, etm_xport_conn_t conn,
828 if ((conn == NULL) || (buf == NULL)) {
851 if ((n = etm_xport_get_opt(hdl, conn, ETM_XPORT_OPT_MTU_SZ)) < 0) {
868 while ((n = (*io_func_ptr)(hdl, conn, datap, io_sz)) ==
940 etm_magic_read(fmd_hdl_t *hdl, etm_xport_conn_t conn, uint32_t *magic_ptr)
959 conn, &buf5[j], 1, ETM_IO_OP_RD)) < 0) {
1012 etm_hdr_read(fmd_hdl_t *hdl, etm_xport_conn_t conn, size_t *szp)
1030 if ((n = etm_magic_read(hdl, conn, &pp.pp_magic_num)) < 0) {
1039 conn, &pp.pp_proto_ver, sizeof (pp) - sizeof (pp.pp_magic_num),
1106 conn, lenp, sizeof (*lenp), ETM_IO_OP_RD)) < 0) {
1138 conn, &ctl_hdrp->ctl_len, sizeof (ctl_hdrp->ctl_len),
1166 conn, &resp_hdrp->resp_code,
1196 conn, &sa_hdrp->sa_priority,
1239 etm_hdr_write(fmd_hdl_t *hdl, etm_xport_conn_t conn, nvlist_t *evp,
1294 conn, hdrp, hdr_sz, ETM_IO_OP_WR)) < 0) {
1423 etm_xport_conn_t conn; /* connection to other end */
1469 if (etm_conn_open(hdl, "bad conn open during ver negot",
1470 addrv[i], &conn) < 0) {
1474 conn, ctl_hdrp, hdr_sz + body_sz, ETM_IO_OP_WR) >= 0) {
1478 (void) etm_conn_close(hdl, "bad conn close during ver negot",
1479 conn);
2059 etm_maybe_enq_response(fmd_hdl_t *hdl, etm_xport_conn_t conn,
2091 rqe.rqe_conn = conn;
2128 etm_send_response(fmd_hdl_t *hdl, etm_xport_conn_t conn,
2184 rv = etm_io_op(hdl, "bad io write on resp msg", conn,
2239 etm_handle_new_conn(fmd_hdl_t *hdl, etm_xport_conn_t conn)
2264 etm_show_time(hdl, "ante conn handle");
2266 fmd_hdl_debug(hdl, "info: handling new conn %p\n", conn);
2281 if ((ev_hdrp = etm_hdr_read(hdl, conn, &hdr_sz)) == NULL) {
2319 "bad io read on event bodies", conn, body_buf, body_sz,
2330 * now that we've read the entire ETM msg from the conn,
2337 enq_rv = etm_maybe_enq_response(hdl, conn,
2352 enq_rv = etm_maybe_enq_response(hdl, conn,
2436 enq_rv = etm_maybe_enq_response(hdl, conn,
2466 conn, body_buf, body_sz, ETM_IO_OP_RD)) < 0) {
2489 enq_rv = etm_maybe_enq_response(hdl, conn,
2506 conn, body_buf, body_sz, ETM_IO_OP_RD)) < 0) {
2550 conn, body_buf, body_sz, ETM_IO_OP_RD)) < 0) {
2558 * now that we've read the entire ETM msg from the conn,
2565 enq_rv = etm_maybe_enq_response(hdl, conn,
2578 enq_rv = etm_maybe_enq_response(hdl, conn,
2585 etm_show_time(hdl, "post conn handle");
2589 * if no responder ele was enqueued, close the conn now
2595 (void) etm_conn_close(hdl, "bad conn close after msg recv",
2596 conn);
2619 fmd_hdl_debug(hdl, "error: bad conn accept errno %d\n", (-nev));
2637 etm_xport_conn_t conn; /* connection handle */
2653 if ((conn = etm_xport_accept(hdl, NULL)) == NULL) {
2665 etm_handle_new_conn(hdl, conn);
2719 * closing its associated conn and freeing its hdr
2743 (void) etm_conn_close(hdl, "bad conn close after resp",
2770 (void) etm_conn_close(hdl, "bad conn close after deq",
3937 etm_xport_conn_t conn; /* connection handle */
4027 "bad conn open on new ev", addrv[i], &conn)) < 0) {
4036 if ((hdrp = etm_hdr_write(hdl, conn, evp, NV_ENCODE_XDR,
4042 "bad conn close per bad hdr wr", conn);
4055 "bad io write on event", conn,
4059 "bad conn close per bad body wr", conn);
4073 (void) etm_conn_close(hdl, "bad conn close after event send",
4074 conn);