Home
last modified time | relevance | path

Searched refs:READ_TRIGGER (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/
H A Dclient_trans_tcp_direct_listener.c116 return AddTrigger(DIRECT_CHANNEL_CLIENT, fd, READ_TRIGGER); in TransTdcCreateListener()
151 DelTrigger(DIRECT_CHANNEL_CLIENT, fd, READ_TRIGGER); in TransTdcCloseFd()
161 DelTrigger(DIRECT_CHANNEL_CLIENT, fd, READ_TRIGGER); in TransTdcReleaseFd()
171 return DelTrigger(DIRECT_CHANNEL_CLIENT, fd, READ_TRIGGER); in TransTdcStopRead()
H A Dclient_trans_tcp_direct_manager.c292 DelTrigger(DIRECT_CHANNEL_CLIENT, channel->fd, READ_TRIGGER); in ClientTransTdcHandleListener()
300 AddTrigger(DIRECT_CHANNEL_CLIENT, channel->fd, READ_TRIGGER); in ClientTransTdcHandleListener()
/ohos5.0/foundation/communication/dsoftbus/core/connection/interface/
H A Dsoftbus_base_listener.h32 READ_TRIGGER = 1, enumerator
35 RW_TRIGGER = READ_TRIGGER | WRITE_TRIGGER,
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_listener.c200 ret = AddTrigger(module, fd, READ_TRIGGER); in CreateSessionConnNode()
291 DelTrigger(module, fd, READ_TRIGGER); in TransProcDataRes()
321 if (AddTrigger(conn->listenMod, fd, READ_TRIGGER) != SOFTBUS_OK) { in ProcessSocketOutEvent()
340 DelTrigger(conn->listenMod, fd, READ_TRIGGER); in ProcessSocketOutEvent()
369 DelTrigger((ListenerModule)i, fd, READ_TRIGGER); in TdcOnDataEvent()
H A Dtrans_tcp_direct_message.c1210 DelTrigger(module, node->fd, READ_TRIGGER); in TransTdcSrvProcData()
/ohos5.0/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_tcp_connection.c186 (void)DelTrigger(module, fd, READ_TRIGGER); in RecvPacketHead()
219 if (AddTrigger(module, fd, READ_TRIGGER) != SOFTBUS_OK) { in ProcessSocketOutEvent()
231 (void)DelTrigger(module, fd, READ_TRIGGER); in ProcessSocketOutEvent()
292 if (AddTrigger(module, cfd, READ_TRIGGER) != SOFTBUS_OK) { in OnConnectEvent()
301 (void)DelTrigger(module, cfd, READ_TRIGGER); in OnConnectEvent()
398 TriggerType triggerMode = isBlockMode ? READ_TRIGGER : WRITE_TRIGGER; in SocketConnectInner()
446 TriggerType triggerMode = isBlockMode ? READ_TRIGGER : WRITE_TRIGGER; in SocketConnectDevice()
494 TriggerType triggerMode = isBlockMode ? READ_TRIGGER : WRITE_TRIGGER; in NipSocketConnectDevice()
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/common/unittest/
H A Dsoftbus_conn_common_test.cpp138 for (triggerType = READ_TRIGGER; triggerType <= RW_TRIGGER; triggerType++) {
143 for (triggerType = READ_TRIGGER; triggerType <= RW_TRIGGER; triggerType++) {
164 for (triggerType = READ_TRIGGER; triggerType <= RW_TRIGGER; triggerType++) {
200 for (triggerType = READ_TRIGGER; triggerType <= RW_TRIGGER; triggerType++) {
/ohos5.0/foundation/communication/dsoftbus/adapter/common/bus_center/network/
H A Dlnn_netlink_monitor.c215 if (AddTrigger(NETLINK, sockFd, READ_TRIGGER) != SOFTBUS_OK) { in LnnInitNetlinkMonitorImpl()
/ohos5.0/foundation/communication/dsoftbus/core/connection/tcp/src/
H A Dsoftbus_tcp_connect_manager.c251 if (AddTrigger(module, cfd, READ_TRIGGER) != SOFTBUS_OK) { in TcpOnConnectEvent()
264 (void)DelTrigger(module, cfd, READ_TRIGGER); in TcpOnConnectEvent()
354 (void)AddTrigger((ListenerModule)(tcpInfo.info.socketInfo.moduleId), fd, READ_TRIGGER); in TcpOnDataEventOut()
/ohos5.0/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_base_listener.c594 case READ_TRIGGER: in IsValidTriggerType()
1017 … if ((fdArray[i].triggerSet & READ_TRIGGER) != 0 && SoftBusSocketFdIsset(fdArray[i].fd, readSet)) { in ProcessSpecifiedListenerNodeEvent()
1076 if ((it->triggerSet & READ_TRIGGER) != 0) { in CollectSpecifiedModuleListenerEvents()