Searched defs:listener (Results 1 - 22 of 22) sorted by relevance

/illumos-gate/usr/src/lib/sun_fc/common/
H A DSun_fcRegisterForAdapterAddEvents.cc58 AdapterAddEventListener *listener = new AdapterAddEventListener( local
62 bridge->addListener(listener);
63 *callbackHandle = (void *)listener;
H A DSun_fcRegisterForAdapterDeviceEvents.cc67 AdapterDeviceEventListener *listener = new AdapterDeviceEventListener( local
71 bridge->addListener(listener, port);
72 *callbackHandle = (void *)listener;
H A DSun_fcRegisterForAdapterEvents.cc61 AdapterEventListener *listener = new AdapterEventListener(hba, local
65 bridge->addListener(listener, hba);
66 *callbackHandle = (void *)listener;
H A DSun_fcRegisterForAdapterPortEvents.cc66 AdapterPortEventListener *listener = new AdapterPortEventListener( local
70 bridge->addListener(listener, port);
71 *callbackHandle = (void *)listener;
H A DSun_fcRegisterForTargetEvents.cc73 TargetEventListener *listener = new TargetEventListener(port, local
78 bridge->addListener(listener, port,
80 *callbackHandle = (void *)listener;
H A DFCSyseventBridge.cc53 void FCSyseventBridge::addListener(AdapterAddEventListener *listener) { argument
57 listener);
65 void FCSyseventBridge::addListener(AdapterEventListener *listener, HBA *hba) { argument
68 adapterEventListeners.insert(adapterEventListeners.begin(), listener);
76 void FCSyseventBridge::addListener(AdapterPortEventListener *listener, argument
81 listener);
89 void FCSyseventBridge::addListener(AdapterDeviceEventListener *listener, argument
94 listener);
102 void FCSyseventBridge::addListener(TargetEventListener *listener, argument
106 targetEventListeners.insert(targetEventListeners.begin(), listener);
115 removeListener(AdapterAddEventListener *listener) argument
134 removeListener(AdapterEventListener *listener) argument
153 removeListener(AdapterPortEventListener *listener) argument
172 removeListener(AdapterDeviceEventListener *listener) argument
191 removeListener(TargetEventListener *listener) argument
[all...]
/illumos-gate/usr/src/lib/libdns_sd/java/com/apple/dnssd/docs/examples/src/
H A DSwingDomainListener.java50 /** Create a listener for DNSSD that will call your listener on the Swing/AWT event thread. */
51 public SwingDomainListener( DomainListener listener) argument
52 { fListener = listener; fErrorCode = 0; }
H A DSwingResolveListener.java53 /** Create a listener for DNSSD that will call your listener on the Swing/AWT event thread. */
54 public SwingResolveListener( ResolveListener listener) argument
55 { fListener = listener; }
H A DSwingBrowseListener.java50 /** Create a listener for DNSSD that will call your listener on the Swing/AWT event thread. */
51 public SwingBrowseListener( BrowseListener listener) argument
52 { fListener = listener; fErrorCode = 0; }
H A DSwingQueryListener.java50 /** Create a listener for DNSSD that will call your listener on the Swing/AWT event thread. */
51 public SwingQueryListener( QueryListener listener) argument
52 { fListener = listener; }
/illumos-gate/usr/src/lib/libresolv2/common/isc/
H A Dev_connects.c57 static void listener(evContext ctx, void *uap, int fd, int evmask);
90 if (evSelectFD(opaqueCtx, fd, EV_READ, listener, new, &new->file) < 0){
230 ret = evSelectFD(opaqueCtx, this->fd, EV_READ, listener, this,
280 listener(evContext opaqueCtx, void *uap, int fd, int evmask) { function
/illumos-gate/usr/src/cmd/cmd-inet/usr.lib/ilbd/
H A Dilbd_main.c173 * function calls exit(2). Hence it always returns a valid listener socket.
588 new_req(int ev_port, int listener, void *ev_obj) argument
599 if ((new_sd = accept(listener, &sa, &sa_len)) == -1) {
661 /* Re-associate the listener with the event port. */
662 if (port_associate(ev_port, PORT_SOURCE_FD, listener, POLLRDNORM,
664 logperror("new_req: port_associate(listener) failed");
777 * asserts that argument 'listener' is a server socket ready to accept() on.
780 main_loop(int listener) argument
795 if (port_associate(ev_port, PORT_SOURCE_FD, listener, POLLRDNORM,
833 assert(ev_port_obj == listener);
[all...]
/illumos-gate/usr/src/uts/common/inet/sctp/
H A Dsctp_conn.c55 sctp_accept_comm(sctp_t *listener, sctp_t *acceptor, mblk_t *cr_pkt, argument
66 sctp_stack_t *sctps = listener->sctp_sctps;
72 lconnp = listener->sctp_connp;
81 err = sctp_get_addrparams(acceptor, listener, cr_pkt, ich,
93 listener->sctp_prsctp_aware && sctps->sctps_prsctp_enabled) {
111 * Copy sctp_secret from the listener in case we need to validate
114 bcopy(listener->sctp_secret, acceptor->sctp_secret, SCTP_SECRET_LEN);
115 bcopy(listener->sctp_old_secret, acceptor->sctp_old_secret,
134 /* Process the COOKIE packet, mp, directed at the listener 'sctp' */
152 * No need to check for duplicate as this is the listener
[all...]
/illumos-gate/usr/src/uts/common/inet/tcp/
H A Dtcp_timers.c667 tcp_t *listener = tcp->tcp_listener; local
669 if (tcp->tcp_syn_rcvd_timeout == 0 && (listener != NULL)) {
672 mutex_enter(&listener->tcp_eager_lock);
673 listener->tcp_syn_rcvd_timeout++;
680 MAKE_DROPPABLE(listener, tcp);
682 if (!listener->tcp_syn_defense &&
683 (listener->tcp_syn_rcvd_timeout >
687 listener->tcp_syn_defense = B_TRUE;
691 ntohs(listener->tcp_connp->conn_lport));
693 listener
[all...]
H A Dtcp_socket.c136 tcp_t *listener, *eager; local
139 * KSSL can move a socket from one listener to another, in which
140 * case `lproto_handle' points to the new listener. To ensure that
141 * the original listener is used the information is obtained from
148 listener = eager->tcp_listener;
149 lconnp = (conn_t *)listener->tcp_connp;
150 ASSERT(listener->tcp_state == TCPS_LISTEN);
169 listener->tcp_connp->conn_netstack);
170 ASSERT(eager->tcp_tcps == listener->tcp_tcps);
184 mutex_enter(&listener
919 tcp_t *listener = eager->tcp_listener; local
1072 tcp_t *listener = tcp->tcp_listener; local
[all...]
H A Dtcp_tpi.c954 * called. In either case, both the eager and listener are in their own
960 tcp_accept_swap(tcp_t *listener, tcp_t *acceptor, tcp_t *eager) argument
964 ASSERT(eager->tcp_connp->conn_rq == listener->tcp_connp->conn_rq);
968 ASSERT(!TCP_IS_SOCKET(listener));
986 mutex_enter(&listener->tcp_eager_lock);
992 mutex_exit(&listener->tcp_eager_lock);
1002 * In the TLI/XTI loopback case, we are inside the listener's squeue,
1065 * Drop the eager's ref on the listener, that was placed when
1220 * Pull a deferred connection indication off of the listener. The caller
1225 tcp_get_def_conn_ind(tcp_t *listener) argument
1292 tcp_tli_accept(tcp_t *listener, mblk_t *mp) argument
1692 tcp_t *listener; local
1873 tcp_t *listener = lconnp->conn_tcp; local
1906 tcp_t *listener = lconnp->conn_tcp; local
[all...]
H A Dtcp.c203 * putting the tcp in acceptor hash since a sockfs listener can never
253 * Minimum number of connections which can be created per listener. Used
254 * when the listener connection count is in effect.
668 * window from the listener. But if there is a metrics
670 * inheriting it from listener. Thus we need to pass this
843 * listener, let tcp_accept_finish() send a discon_ind
844 * to the listener and drop the last reference. If the
845 * listener doesn't even know about the eager i.e. the
871 * The connection is dead. Decrement listener connection counter if
1144 * In the case of listener stream
1265 tcp_t *listener = tcp->tcp_listener; local
[all...]
H A Dtcp_input.c83 * the listener connection counter if needed.
927 * TH_RST if eager is in the fanout table. The listener wants the
939 tcp_t *listener = eager->tcp_listener; local
942 * We could be called because listener is closing. Since
943 * the eager was using listener's queue's, we avoid
960 /* We are here because listener wants this eager gone */
961 if (listener != NULL) {
962 mutex_enter(&listener->tcp_eager_lock);
967 * listener but listener decide
987 tcp_eager_blowoff(tcp_t *listener, t_scalar_t seqnum) argument
1021 tcp_eager_cleanup(tcp_t *listener, boolean_t q0_only) argument
1071 tcp_t *listener = tcp->tcp_listener; local
1273 tcp_t *listener = lconnp->conn_tcp; local
3741 tcp_t *listener = tcp->tcp_listener; local
[all...]
/illumos-gate/usr/src/uts/common/inet/kssl/
H A Dksslfilter.c75 ksslf_t *listener = (ksslf_t *)parg; local
80 if (listener == NULL || listener->ksslf_ent == NULL)
83 * Only way for a fallback listener to receive connections is when
87 if (listener->ksslf_type == KSSL_HAS_PROXY)
99 if (kssl_init_context(listener->ksslf_ent, faddr, SSL3_MAX_RECORD_LEN,
108 new->ksslf_laddr.sin6_port = listener->ksslf_laddr.sin6_port;
109 new->ksslf_listener = listener;
411 ksslf_t *listener = kssl->ksslf_listener; local
427 ASSERT(listener
[all...]
/illumos-gate/usr/src/uts/common/fs/sockfs/
H A Dnl7c.c105 struct sonode *listener; /* listen()er's sonode */ member in struct:nl7c_addr_s
121 if (p->listener == NULL)
122 p->listener = so;
131 return (p->listener);
215 if (p->listener == so) {
218 p->listener = NULL;
260 so = p->listener;
263 addr, port, p->listener ? 1 : 0);
/illumos-gate/usr/src/lib/libdns_sd/java/com/apple/dnssd/
H A DDNSSD.java110 @param listener
118 public static DNSSDService browse( int flags, int ifIndex, String regType, String domain, BrowseListener listener) argument
120 { return getInstance()._makeBrowser( flags, ifIndex, regType, domain, listener); }
128 @param listener
136 public static DNSSDService browse( String regType, BrowseListener listener) argument
138 { return browse( 0, 0, regType, "", listener); }
172 @param listener
181 String domain, ResolveListener listener)
183 { return getInstance()._resolve( flags, ifIndex, serviceName, regType, domain, listener); }
230 @param listener
180 resolve( int flags, int ifIndex, String serviceName, String regType, String domain, ResolveListener listener) argument
238 register( int flags, int ifIndex, String serviceName, String regType, String domain, String host, int port, TXTRecord txtRecord, RegisterListener listener) argument
268 register( String serviceName, String regType, int port, RegisterListener listener) argument
280 createRecordRegistrar( RegisterRecordListener listener) argument
314 queryRecord( int flags, int ifIndex, String serviceName, int rrtype, int rrclass, QueryListener listener) argument
342 enumerateDomains( int flags, int ifIndex, DomainListener listener) argument
437 _makeBrowser( int flags, int ifIndex, String regType, String domain, BrowseListener listener) argument
440 _resolve( int flags, int ifIndex, String serviceName, String regType, String domain, ResolveListener listener) argument
444 _register( int flags, int ifIndex, String serviceName, String regType, String domain, String host, int port, TXTRecord txtRecord, RegisterListener listener) argument
448 _createRecordRegistrar( RegisterRecordListener listener) argument
451 _queryRecord( int flags, int ifIndex, String serviceName, int rrtype, int rrclass, QueryListener listener) argument
455 _enumerateDomains( int flags, int ifIndex, DomainListener listener) argument
575 _createRecordRegistrar( RegisterRecordListener listener) argument
588 _enumerateDomains( int flags, int ifIndex, DomainListener listener) argument
637 AppleService(BaseListener listener) argument
802 AppleRecordRegistrar( RegisterRecordListener listener) argument
[all...]
/illumos-gate/usr/src/stand/lib/tcp/
H A Dtcp.c731 * If we are an eager connection hanging off a listener that hasn't
738 tcp_t *listener = tcp->tcp_listener; local
740 assert(listener != NULL);
749 listener->tcp_conn_req_cnt_q0--;
751 tcp_t **tcpp = &listener->tcp_eager_next_q;
756 if (listener->tcp_eager_last_q == tcp) {
764 if (listener->tcp_eager_last_q ==
765 listener->tcp_eager_next_q) {
766 listener->tcp_eager_last_q =
775 listener
796 tcp_eager_cleanup(tcp_t *listener, boolean_t q0_only, int sock_id) argument
1052 tcp_t *listener; local
1433 tcp_accept_comm(tcp_t *listener, tcp_t *acceptor, mblk_t *cr_pkt, uint_t ip_hdr_len) argument
1886 tcp_lookup_eager_ipv4(tcp_t *listener, struct ip *iph, tcpha_t *tcph) argument
3318 tcp_t *listener = tcp->tcp_listener; local
[all...]

Completed in 1122 milliseconds