Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 54) sorted by relevance

123

/f-stack/freebsd/contrib/ngatm/netnatm/api/
H A Dcc_conn.c149 r->conn = conn; in cc_send_uni()
153 conn->port->cc->funcs->send_uni(conn, conn->port->uarg, op, in cc_send_uni()
228 conn = CCZALLOC(sizeof(*conn)); in cc_conn_create()
288 if (r->conn == conn) { in cc_conn_flush_cookies()
345 party->conn = conn; in cc_party_create()
935 do_release_response(conn, 0, conn->cause); in cc_conn_sig_handle()
984 conn->blli[conn->blli_selector - 1]; in cc_conn_sig_handle()
1138 do_release_request(conn, conn->cause); in cc_conn_sig_handle()
1157 do_release_request(conn, conn->cause); in cc_conn_sig_handle()
1818 do_release_request(conn, conn->cause); in cc_conn_sig_handle()
[all …]
H A Dcc_user.c160 struct ccconn *conn; in cc_user_abort() local
176 memset(conn->cause, 0, sizeof(conn->cause)); in cc_user_abort()
255 struct ccconn *conn; in do_arrival() local
436 memcpy(ptr, &conn->blli[conn->blli_selector - in cc_attr_query()
698 memcpy(&conn->blli[conn->blli_selector - 1], ptr, len); in cc_attr_set()
1044 if (conn == NULL) { in cc_user_sig_handle()
1308 memset(&conn->cause[1], 0, sizeof(conn->cause[1])); in cc_user_sig_handle()
1678 memset(&conn->cause[1], 0, sizeof(conn->cause[1])); in cc_user_sig_handle()
1735 if (conn == NULL) { in cc_user_sig_handle()
1754 if (conn == NULL) { in cc_user_sig_handle()
[all …]
H A Dcc_sig.c155 s = sig_alloc(conn->cc, SIG_CONN, conn, has_msg, sig, arg, 0); in sig_conn()
159 if (conn->port != NULL) { in sig_conn()
162 if (r->conn == conn) in sig_conn()
168 cc_conn_sigtab[sig], conn); in sig_conn()
172 cc_conn_sigtab[sig], conn); in sig_conn()
202 s = sig_alloc(conn->cc, SIG_CONN, conn, (msg != NULL), sig, msg, 0); in cc_conn_sig_msg_nodef()
208 cc_conn_sigtab[sig], conn); in cc_conn_sig_msg_nodef()
222 s = sig_alloc(conn->cc, SIG_CONN, conn, 0, sig, NULL, in cc_conn_resp()
230 cc_conn_sigtab[sig], conn); in cc_conn_resp()
299 cc_sig_log(conn->cc, "flushing signals to conn %p", conn); in cc_conn_sig_flush()
[all …]
H A Dcc_data.c126 const struct ccconn *conn; in cc_get_extended_status() local
184 if (conn->user != NULL) in cc_get_extended_status()
185 strcpy(econn->ep, conn->user->name); in cc_get_extended_status()
188 econn->state = conn->state; in cc_get_extended_status()
189 econn->cref = conn->cref.cref; in cc_get_extended_status()
190 if (conn->cref.flag) in cc_get_extended_status()
207 if (conn->user != NULL) in cc_get_extended_status()
208 strcpy(econn->ep, conn->user->name); in cc_get_extended_status()
211 econn->state = conn->state; in cc_get_extended_status()
212 econn->cref = conn->cref.cref; in cc_get_extended_status()
[all …]
H A Dcc_port.c507 struct ccconn *conn; in cc_uni_response() local
520 conn = req->conn; in cc_uni_response()
526 return (cc_conn_resp(conn, CONN_SIG_OK, in cc_uni_response()
536 struct ccconn *conn; in find_cref() local
539 if (conn->cref.cref == cref->cref && in find_cref()
540 conn->cref.flag == cref->flag) in find_cref()
541 return (conn); in find_cref()
554 struct ccconn *conn; in cc_uni_signal() local
585 conn = req->conn; in cc_uni_signal()
592 cc_conn_ins_port(conn, port); in cc_uni_signal()
[all …]
H A Dcc_dump.c188 struct ccconn *conn; in cc_dump_user() local
202 TAILQ_FOREACH(conn, &user->connq, connq_link) in cc_dump_user()
203 cc_dumpf(d, "%p", conn); in cc_dump_user()
227 cc_dumpf(d, "%sconn(%p): %s\n", pfx, conn, in cc_dump_conn()
228 cc_conn_state2str(conn->state)); in cc_dump_conn()
230 conn->user, conn->cref.cref, conn->cref.flag, in cc_dump_conn()
231 conn->acceptor); in cc_dump_conn()
235 LIST_FOREACH(party, &conn->parties, link) in cc_dump_conn()
304 struct ccconn *conn; in cc_dump() local
326 LIST_FOREACH(conn, &cc->orphaned_conns, port_link) in cc_dump()
[all …]
/f-stack/dpdk/examples/ip_pipeline/
H A Dconn.c22 struct conn { struct
41 struct conn *conn; in conn_init() local
62 conn = calloc(1, sizeof(struct conn)); in conn_init()
132 conn_free(struct conn *conn) in conn_free() argument
151 conn_poll_for_conn(struct conn *conn) in conn_poll_for_conn() argument
209 data_event_handle(struct conn *conn, in data_event_handle() argument
233 conn->msg_in[conn->msg_in_len] = 0; in data_event_handle()
236 conn->msg_handle(conn->msg_in, in data_event_handle()
251 conn->msg_in[conn->msg_in_len] = conn->buf[i]; in data_event_handle()
275 control_event_handle(struct conn *conn, in control_event_handle() argument
[all …]
H A Dconn.h10 struct conn;
35 struct conn *
39 conn_free(struct conn *conn);
42 conn_poll_for_conn(struct conn *conn);
45 conn_poll_for_msg(struct conn *conn);
H A Dmain.c37 struct conn_params conn; member
40 .conn = {
95 app.conn.addr = strdup(optarg); in parse_args()
96 if (app.conn.addr == NULL) { in parse_args()
149 struct conn *conn; in main() local
165 conn = conn_init(&app.conn); in main()
166 if (conn == NULL) { in main()
258 app.conn.msg_in_len_max, in main()
259 app.conn.msg_out_len_max); in main()
263 conn_poll_for_conn(conn); in main()
[all …]
/f-stack/dpdk/examples/pipeline/
H A Dconn.c22 struct conn { struct
42 struct conn *conn; in conn_init() local
63 conn = calloc(1, sizeof(struct conn)); in conn_init()
134 conn_free(struct conn *conn) in conn_free() argument
153 conn_poll_for_conn(struct conn *conn) in conn_poll_for_conn() argument
211 data_event_handle(struct conn *conn, in data_event_handle() argument
235 conn->msg_in[conn->msg_in_len] = 0; in data_event_handle()
238 conn->msg_handle(conn->msg_in, in data_event_handle()
254 conn->msg_in[conn->msg_in_len] = conn->buf[i]; in data_event_handle()
278 control_event_handle(struct conn *conn, in control_event_handle() argument
[all …]
H A Dmain.c23 struct conn_params conn; member
26 .conn = {
83 if (app.conn.addr == NULL) { in parse_args()
136 struct conn *conn; in main() local
174 app.conn.msg_in_len_max, in main()
175 app.conn.msg_out_len_max, in main()
179 app.conn.msg_handle_arg = obj; in main()
180 conn = conn_init(&app.conn); in main()
181 if (!conn) { in main()
189 conn_poll_for_conn(conn); in main()
[all …]
H A Dconn.h10 struct conn;
38 struct conn *
42 conn_free(struct conn *conn);
45 conn_poll_for_conn(struct conn *conn);
48 conn_poll_for_msg(struct conn *conn);
/f-stack/dpdk/drivers/net/softnic/
H A Dconn.c64 if (conn == NULL) in softnic_conn_init()
130 return conn; in softnic_conn_init()
149 free(conn); in softnic_conn_free()
192 conn->welcome, in softnic_conn_poll_for_conn()
200 conn->prompt, in softnic_conn_poll_for_conn()
219 conn->buf, in data_event_handle()
235 conn->msg_in[conn->msg_in_len] = 0; in data_event_handle()
238 conn->msg_handle(conn->msg_in, in data_event_handle()
253 } else if (conn->msg_in_len < conn->msg_in_len_max) { in data_event_handle()
254 conn->msg_in[conn->msg_in_len] = conn->buf[i]; in data_event_handle()
[all …]
H A Dconn.h41 softnic_conn_free(struct softnic_conn *conn);
44 softnic_conn_poll_for_conn(struct softnic_conn *conn);
47 softnic_conn_poll_for_msg(struct softnic_conn *conn);
/f-stack/app/micro_thread/
H A Dmt_connection.cpp496 TcpKeepConn* conn = NULL; in GetTcpKeepConn() local
508 if (conn) { in GetTcpKeepConn()
516 conn->IdleDetach(); in GetTcpKeepConn()
519 return conn; in GetTcpKeepConn()
539 conn->IdleDetach(); in RemoveTcpKeepConn()
585 conn->Reset(); in FreeTcpKeepConn()
593 conn->Reset(); in FreeTcpKeepConn()
743 if (!conn) { in FreeConnection()
751 conn->Reset(); in FreeConnection()
760 conn->Reset(); in FreeConnection()
[all …]
H A Dmt_connection.h255 void InsertConn(TcpKeepConn* conn) { in InsertConn() argument
256 if (conn->_keep_flag & TCP_KEEP_IN_LIST) { in InsertConn()
259 TAILQ_INSERT_TAIL(&_keep_list, conn, _keep_entry); in InsertConn()
260 conn->_keep_flag |= TCP_KEEP_IN_LIST; in InsertConn()
263 void RemoveConn(TcpKeepConn* conn) { in RemoveConn() argument
264 if (!(conn->_keep_flag & TCP_KEEP_IN_LIST)) { in RemoveConn()
267 TAILQ_REMOVE(&_keep_list, conn, _keep_entry); in RemoveConn()
268 conn->_keep_flag &= ~TCP_KEEP_IN_LIST; in RemoveConn()
294 bool CacheTcpKeepConn(TcpKeepConn* conn);
296 bool RemoveTcpKeepConn(TcpKeepConn* conn);
[all …]
H A Dmt_net.cpp278 if (NULL == conn) in WaitConnect()
291 if (conn->Connect()) in WaitConnect()
310 if (conn->Connected()) in WaitConnect()
325 if (NULL == conn) in WaitSend()
373 if (NULL == conn) in WaitRecv()
474 this->_conn_ptr = conn; in Link()
490 if (NULL == conn) in SwitchToConn()
505 if (NULL == conn) in SwitchToSend()
520 if (NULL == conn) in SwitchToRecv()
535 if (NULL == conn) in SwitchToIdle()
[all …]
H A Dmt_api.cpp130 if (NULL == conn) in mt_tcp_get_keep_conn()
136 conn->SetNtfyObj(ntfy_obj); in mt_tcp_get_keep_conn()
138 int osfd = conn->CreateSocket(); in mt_tcp_get_keep_conn()
147 return conn; in mt_tcp_get_keep_conn()
226 TcpKeepConn* conn = mt_tcp_get_keep_conn(dst, sock); in mt_tcpsendrcv() local
227 if ((conn == NULL) || (sock < 0)) in mt_tcpsendrcv()
266 if (conn != NULL) in mt_tcpsendrcv()
350 if ((conn == NULL) || (sock < 0)) in mt_tcpsend()
379 if (conn != NULL) in mt_tcpsend()
882 if ((conn == NULL) || (sock < 0)) in mt_tcpsendrcv()
[all …]
H A Dmt_notify.cpp197 IMtConnection* conn = session->GetSessionConn(); in InputNotify() local
199 if (!thread || !conn || !conn->GetNtfyObj()) in InputNotify()
202 session, thread, conn); in InputNotify()
207 MtMsgBuf* msg = conn->GetMtMsgBuff(); in InputNotify()
211 conn->SetMtMsgBuff(_msg_buff); in InputNotify()
214 conn->GetNtfyObj()->SetRcvEvents(KQ_EVENT_READ); in InputNotify()
/f-stack/app/nginx-1.16.1/src/core/
H A Dngx_syslog.c69 peer->conn.fd = (ngx_socket_t) -1; in ngx_syslog_process_conf()
71 peer->conn.read = &ngx_syslog_dummy_event; in ngx_syslog_process_conf()
72 peer->conn.write = &ngx_syslog_dummy_event; in ngx_syslog_process_conf()
289 if (peer->conn.fd == (ngx_socket_t) -1) { in ngx_syslog_send()
296 peer->conn.log = ngx_cycle->log; in ngx_syslog_send()
299 n = ngx_send(&peer->conn, buf, len); in ngx_syslog_send()
313 peer->conn.fd = (ngx_socket_t) -1; in ngx_syslog_send()
344 peer->conn.fd = fd; in ngx_syslog_init_peer()
347 peer->conn.write->ready = 1; in ngx_syslog_init_peer()
370 if (peer->conn.fd == (ngx_socket_t) -1) { in ngx_syslog_cleanup()
[all …]
/f-stack/dpdk/lib/librte_vhost/
H A Dsocket.c213 conn = malloc(sizeof(*conn)); in vhost_user_add_connection()
214 if (conn == NULL) { in vhost_user_add_connection()
256 conn->connfd = fd; in vhost_user_add_connection()
257 conn->vsocket = vsocket; in vhost_user_add_connection()
258 conn->vid = vid; in vhost_user_add_connection()
260 NULL, conn); in vhost_user_add_connection()
282 free(conn); in vhost_user_add_connection()
331 free(conn); in vhost_user_read_cb()
1027 conn != NULL; in rte_vhost_driver_unregister()
1028 conn = next) { in rte_vhost_driver_unregister()
[all …]
/f-stack/dpdk/examples/ipsec-secgw/
H A Devent_helper.c385 conn = &(adapter->conn[conn_id]); in eh_set_default_conf_rx_adapter()
388 conn->ethdev_id = i; in eh_set_default_conf_rx_adapter()
392 conn->ethdev_rx_qid = -1; in eh_set_default_conf_rx_adapter()
486 conn = &(tx_adapter->conn[conn_id]); in eh_set_default_conf_tx_adapter()
489 conn->ethdev_id = i; in eh_set_default_conf_tx_adapter()
772 conn = &(adapter->conn[j]); in eh_rx_adapter_configure()
781 conn->ethdev_id, conn->ethdev_rx_qid, in eh_rx_adapter_configure()
1136 conn = &(adapter->conn[j]); in eh_tx_adapter_configure()
1140 conn->ethdev_id, conn->ethdev_tx_qid); in eh_tx_adapter_configure()
1300 conn = &(adapter->conn[j]); in eh_display_rx_adapter_conf()
[all …]
/f-stack/dpdk/doc/guides/prog_guide/
H A Devent_timer_adapter.rst202 rte_mempool_get(event_timer_pool, (void **)&conn->evtim);
203 if (conn->evtim == NULL) { ... }
206 conn->evtim->ev.op = RTE_EVENT_OP_NEW;
207 conn->evtim->ev.queue_id = event_queue_id;
208 conn->evtim->ev.sched_type = RTE_SCHED_TYPE_ATOMIC;
210 conn->evtim->ev.event_type = RTE_EVENT_TYPE_TIMER;
211 conn->evtim->ev.event_ptr = conn;
212 conn->evtim->state = RTE_EVENT_TIMER_NOT_ARMED;
253 rte_event_timer_cancel_burst(adapter, &conn->timer, 1);
287 conn = ev.event_ptr;
[all …]
/f-stack/app/nginx-1.16.1/src/stream/
H A Dngx_stream_limit_conn_module.c16 u_short conn; member
35 ngx_uint_t conn; member
188 lc->conn = 1; in ngx_stream_limit_conn_handler()
197 if ((ngx_uint_t) lc->conn >= limits[i].conn) { in ngx_stream_limit_conn_handler()
209 lc->conn++; in ngx_stream_limit_conn_handler()
213 "limit conn: %08Xi %d", node->key, lc->conn); in ngx_stream_limit_conn_handler()
333 "limit conn cleanup: %08Xi %d", node->key, lc->conn); in ngx_stream_limit_conn_cleanup()
335 lc->conn--; in ngx_stream_limit_conn_cleanup()
337 if (lc->conn == 0) { in ngx_stream_limit_conn_cleanup()
623 limit->conn = n; in ngx_stream_limit_conn()
/f-stack/app/nginx-1.16.1/src/http/modules/
H A Dngx_http_limit_conn_module.c16 u_short conn; member
35 ngx_uint_t conn; member
210 lc->conn = 1; in ngx_http_limit_conn_handler()
219 if ((ngx_uint_t) lc->conn >= limits[i].conn) { in ngx_http_limit_conn_handler()
231 lc->conn++; in ngx_http_limit_conn_handler()
235 "limit conn: %08Xi %d", node->key, lc->conn); in ngx_http_limit_conn_handler()
354 "limit conn cleanup: %08Xi %d", node->key, lc->conn); in ngx_http_limit_conn_cleanup()
356 lc->conn--; in ngx_http_limit_conn_cleanup()
358 if (lc->conn == 0) { in ngx_http_limit_conn_cleanup()
647 limit->conn = n; in ngx_http_limit_conn()

123