| /dports/multimedia/camserv/camserv-0.5.1/camserv/ |
| H A D | main_loop.c | 281 sockset_hold( writeset, cinfo->socket ); in write_regular_client()
289 sockset_hold( writeset, cinfo->socket ); in write_regular_client()
376 SockSet *readset = NULL, *writeset = NULL; in main_loop() local
391 (writeset = sockset_new()) == NULL ) in main_loop()
395 if( writeset ) sockset_dest( writeset ); in main_loop()
406 sockset_dest( writeset ); in main_loop()
421 sockset_dest( writeset ); in main_loop()
445 sockset_reset( writeset ); in main_loop()
524 sockset_unhold_all( writeset ); in main_loop()
532 sockset_unhold_all( writeset ); in main_loop()
[all …]
|
| /dports/x11-toolkits/py-xlib/python-xlib-0.27/utils/ |
| H A D | tcpbug.py | 28 writeset = []
30 writeset.append(client)
32 writeset.append(server)
34 writeset.append(outputfd)
36 readset, writeset, e = select.select(readset, writeset, [])
54 if client in writeset:
58 if server in writeset:
62 if outputfd in writeset:
|
| /dports/multimedia/camserv/camserv-0.5.1/common/ |
| H A D | sock_field.c | 27 SockSet *readset, *writeset; /* Read and writesets */ member
47 if( (sfdata->writeset = sockset_new()) == NULL ){ in sock_field_init_data()
70 sockset_dest( sfdata->writeset ); in sock_field_dest_data()
136 sockset_unhold_all( sfdata->writeset ); in sock_field_service_writesocks()
181 sockset_unhold_all( sfdata->writeset ); in sock_field_service_readsocks()
182 sockset_del_fd( sfdata->writeset, sfield->socket ); in sock_field_service_readsocks()
193 sockset_unhold_all( sfdata->writeset ); in sock_field_unhold_write()
197 if( sockset_hold( sfdata->writeset, socket ) == -1 ){ in sock_field_hold_write()
245 sockset_reset( sfdata.writeset ); in sock_field()
248 sfdata.writeset, &real_timeout ); in sock_field()
[all …]
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/apr/poll/unix/ |
| H A D | select.c | 36 fd_set readset, writeset, exceptset; in apr_poll() local
54 FD_ZERO(&writeset); in apr_poll()
102 FD_SET(fd, &writeset); in apr_poll()
154 if (FD_ISSET(fd, &writeset)) { in apr_poll()
178 fd_set readset, writeset, exceptset; member
207 FD_ZERO(&((*pollset)->writeset)); in apr_pollset_create()
275 FD_SET(fd, &(pollset->writeset)); in apr_pollset_add()
321 FD_CLR(fd, &(pollset->writeset)); in apr_pollset_remove()
341 fd_set readset, writeset, exceptset; in apr_pollset_poll() local
353 memcpy(&writeset, &(pollset->writeset), sizeof(fd_set)); in apr_pollset_poll()
[all …]
|
| /dports/devel/apr1/apr-1.7.0/poll/unix/ |
| H A D | select.c | 36 fd_set readset, writeset, exceptset; in apr_poll() local
69 FD_ZERO(&writeset); in apr_poll()
117 FD_SET(fd, &writeset); in apr_poll()
169 if (FD_ISSET(fd, &writeset)) { in apr_poll()
187 fd_set readset, writeset, exceptset; member
214 FD_ZERO(&(pollset->p->writeset)); in impl_pollset_create()
281 FD_SET(fd, &(pollset->p->writeset)); in impl_pollset_add()
327 FD_CLR(fd, &(pollset->p->writeset)); in impl_pollset_remove()
347 fd_set readset, writeset, exceptset; in impl_pollset_poll() local
376 memcpy(&writeset, &(pollset->p->writeset), sizeof(fd_set)); in impl_pollset_poll()
[all …]
|
| /dports/x11-toolkits/wxgtk28-contrib-common/wxGTK-2.8.12/src/common/ |
| H A D | socketevtdispatch.cpp | 127 int wxSocketEventDispatcher::FillSets(fd_set* readset, fd_set* writeset) in FillSets() argument
132 wxFD_ZERO(writeset); in FillSets()
150 wxFD_SET(entry->m_fdOutput, writeset); in FillSets()
161 void wxSocketEventDispatcher::AddEvents(fd_set* readset, fd_set* writeset) in AddEvents() argument
180 if (entry->m_fdOutput != -1 && wxFD_ISSET(entry->m_fdOutput, writeset)) in AddEvents()
193 fd_set writeset; in RunLoop() local
195 int max_fd = FillSets( &readset, &writeset); in RunLoop()
196 if (select( max_fd+1, &readset, &writeset, NULL, &tv ) == 0) in RunLoop()
203 AddEvents(&readset, &writeset); in RunLoop()
|
| /dports/x11-toolkits/wxgtk28-common/wxGTK-2.8.12/src/common/ |
| H A D | socketevtdispatch.cpp | 127 int wxSocketEventDispatcher::FillSets(fd_set* readset, fd_set* writeset) in FillSets() argument
132 wxFD_ZERO(writeset); in FillSets()
150 wxFD_SET(entry->m_fdOutput, writeset); in FillSets()
161 void wxSocketEventDispatcher::AddEvents(fd_set* readset, fd_set* writeset) in AddEvents() argument
180 if (entry->m_fdOutput != -1 && wxFD_ISSET(entry->m_fdOutput, writeset)) in AddEvents()
193 fd_set writeset; in RunLoop() local
195 int max_fd = FillSets( &readset, &writeset); in RunLoop()
196 if (select( max_fd+1, &readset, &writeset, NULL, &tv ) == 0) in RunLoop()
203 AddEvents(&readset, &writeset); in RunLoop()
|
| /dports/x11-toolkits/wxgtk28/wxGTK-2.8.12/src/common/ |
| H A D | socketevtdispatch.cpp | 127 int wxSocketEventDispatcher::FillSets(fd_set* readset, fd_set* writeset) in FillSets() argument
132 wxFD_ZERO(writeset); in FillSets()
150 wxFD_SET(entry->m_fdOutput, writeset); in FillSets()
161 void wxSocketEventDispatcher::AddEvents(fd_set* readset, fd_set* writeset) in AddEvents() argument
180 if (entry->m_fdOutput != -1 && wxFD_ISSET(entry->m_fdOutput, writeset)) in AddEvents()
193 fd_set writeset; in RunLoop() local
195 int max_fd = FillSets( &readset, &writeset); in RunLoop()
196 if (select( max_fd+1, &readset, &writeset, NULL, &tv ) == 0) in RunLoop()
203 AddEvents(&readset, &writeset); in RunLoop()
|
| /dports/x11-toolkits/wxgtk28-contrib/wxGTK-2.8.12/src/common/ |
| H A D | socketevtdispatch.cpp | 127 int wxSocketEventDispatcher::FillSets(fd_set* readset, fd_set* writeset) in FillSets() argument
132 wxFD_ZERO(writeset); in FillSets()
150 wxFD_SET(entry->m_fdOutput, writeset); in FillSets()
161 void wxSocketEventDispatcher::AddEvents(fd_set* readset, fd_set* writeset) in AddEvents() argument
180 if (entry->m_fdOutput != -1 && wxFD_ISSET(entry->m_fdOutput, writeset)) in AddEvents()
193 fd_set writeset; in RunLoop() local
195 int max_fd = FillSets( &readset, &writeset); in RunLoop()
196 if (select( max_fd+1, &readset, &writeset, NULL, &tv ) == 0) in RunLoop()
203 AddEvents(&readset, &writeset); in RunLoop()
|
| /dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/common/util/ |
| H A D | socket_io.cpp | 153 fd_set writeset; in write_socket() local
154 FD_ZERO(&writeset); in write_socket()
155 FD_SET(socket, &writeset); in write_socket()
162 const int selectRes = select(socket + 1, 0, &writeset, 0, &timeout); in write_socket()
181 FD_ZERO(&writeset); in write_socket()
182 FD_SET(socket, &writeset); in write_socket()
187 const int selectRes2 = select(socket + 1, 0, &writeset, 0, &timeout); in write_socket()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
| H A D | rpl_trx_tracking.cc | 191 std::set<uint64> *writeset= write_set_ctx->get_write_set(); in get_dependency() local
196 DBUG_ASSERT(writeset->size() == 0); in get_dependency()
208 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
230 m_writeset_history.size() + writeset->size() > m_opt_max_history_size; in get_dependency()
238 for (std::set<uint64>::iterator it= writeset->begin(); in get_dependency()
239 it != writeset->end(); ++it) in get_dependency()
|
| /dports/comms/owfs/owfs-3.2p4/module/owlib/src/c/ |
| H A D | ow_com_write.c | 154 fd_set writeset; in COM_write_once() local
160 FD_ZERO(&writeset); in COM_write_once()
161 FD_SET( fd, &writeset); in COM_write_once()
163 select_result = select( fd + 1, NULL, &writeset, NULL, &tv); in COM_write_once()
167 if (FD_ISSET( fd, &writeset) == 0) { in COM_write_once()
|
| H A D | ow_w1_dispatch.c | 51 fd_set writeset ; in W1_write_pipe() local
52 FD_ZERO(&writeset) ; in W1_write_pipe()
53 FD_SET(file_descriptor,&writeset) ; in W1_write_pipe()
55 select_value = select(file_descriptor+1,NULL,&writeset,NULL,&tv) ; in W1_write_pipe()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | rpl_trx_tracking.cc | 191 std::set<uint64> *writeset= write_set_ctx->get_write_set(); in get_dependency() local
196 assert(writeset->size() == 0); in get_dependency()
208 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
232 m_writeset_history.size() + writeset->size() > get_opt_max_history_size(); in get_dependency()
240 for (std::set<uint64>::iterator it= writeset->begin(); in get_dependency()
241 it != writeset->end(); ++it) in get_dependency()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
| H A D | rpl_trx_tracking.cc | 191 std::set<uint64> *writeset= write_set_ctx->get_write_set(); in get_dependency() local
196 assert(writeset->size() == 0); in get_dependency()
208 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
232 m_writeset_history.size() + writeset->size() > get_opt_max_history_size(); in get_dependency()
240 for (std::set<uint64>::iterator it= writeset->begin(); in get_dependency()
241 it != writeset->end(); ++it) in get_dependency()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | rpl_trx_tracking.cc | 191 std::set<uint64> *writeset= write_set_ctx->get_write_set(); in get_dependency() local
196 assert(writeset->size() == 0); in get_dependency()
208 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
232 m_writeset_history.size() + writeset->size() > get_opt_max_history_size(); in get_dependency()
240 for (std::set<uint64>::iterator it= writeset->begin(); in get_dependency()
241 it != writeset->end(); ++it) in get_dependency()
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/ |
| H A D | rpl_trx_tracking.cc | 191 std::set<uint64> *writeset= write_set_ctx->get_write_set(); in get_dependency() local
196 assert(writeset->size() == 0); in get_dependency()
208 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
232 m_writeset_history.size() + writeset->size() > get_opt_max_history_size(); in get_dependency()
240 for (std::set<uint64>::iterator it= writeset->begin(); in get_dependency()
241 it != writeset->end(); ++it) in get_dependency()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
| H A D | rpl_trx_tracking.cc | 215 std::vector<uint64> *writeset = write_set_ctx->get_write_set(); in get_dependency() local
220 DBUG_ASSERT(writeset->size() == 0); in get_dependency()
232 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
254 m_writeset_history.size() + writeset->size() > m_opt_max_history_size; in get_dependency()
262 for (std::vector<uint64>::iterator it = writeset->begin(); in get_dependency()
263 it != writeset->end(); ++it) { in get_dependency()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | rpl_trx_tracking.cc | 191 std::set<uint64> *writeset= write_set_ctx->get_write_set(); in get_dependency() local
196 assert(writeset->size() == 0); in get_dependency()
208 (writeset->size() != 0 || write_set_ctx->get_has_missing_keys() || in get_dependency()
232 m_writeset_history.size() + writeset->size() > get_opt_max_history_size(); in get_dependency()
240 for (std::set<uint64>::iterator it= writeset->begin(); in get_dependency()
241 it != writeset->end(); ++it) in get_dependency()
|
| /dports/graphics/mesa-devel/mesa-22.0-branchpoint-2059-ge8a63cf61ec/src/broadcom/vulkan/ |
| H A D | v3dv_descriptor_set.c | 1046 const VkWriteDescriptorSet *writeset = &pDescriptorWrites[i]; in v3dv_UpdateDescriptorSets() local
1047 V3DV_FROM_HANDLE(v3dv_descriptor_set, set, writeset->dstSet); in v3dv_UpdateDescriptorSets()
1050 set->layout->binding + writeset->dstBinding; in v3dv_UpdateDescriptorSets()
1062 descriptor += writeset->dstArrayElement; in v3dv_UpdateDescriptorSets()
1063 descriptor_count = writeset->descriptorCount; in v3dv_UpdateDescriptorSets()
1069 switch(writeset->descriptorType) { in v3dv_UpdateDescriptorSets()
1089 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1100 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1110 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1117 writeset->pTexelBufferView[j]); in v3dv_UpdateDescriptorSets()
[all …]
|
| /dports/sysutils/ah-tty/ah-tty-0.3.12/src/ |
| H A D | monitor.c | 125 fd_set readset, writeset; /* read set - from the shell or terminal */ in P_dispatch() local
130 FD_ZERO(&writeset); in P_dispatch()
131 P_fds(&readset, &writeset, &UsrBuf); in P_dispatch()
132 P_fds(&readset, &writeset, &ShBuf); in P_dispatch()
135 switch (select(Fds, &readset, &writeset, NULL, TPtr)) in P_dispatch()
142 P_do(&readset, &writeset, &ShBuf); in P_dispatch()
148 P_do(&readset, &writeset, &UsrBuf); in P_dispatch()
|
| /dports/lang/clover/mesa-21.3.6/src/broadcom/vulkan/ |
| H A D | v3dv_descriptor_set.c | 972 const VkWriteDescriptorSet *writeset = &pDescriptorWrites[i]; in v3dv_UpdateDescriptorSets() local
973 V3DV_FROM_HANDLE(v3dv_descriptor_set, set, writeset->dstSet); in v3dv_UpdateDescriptorSets()
976 set->layout->binding + writeset->dstBinding; in v3dv_UpdateDescriptorSets()
981 descriptor += writeset->dstArrayElement; in v3dv_UpdateDescriptorSets()
983 for (uint32_t j = 0; j < writeset->descriptorCount; ++j) { in v3dv_UpdateDescriptorSets()
984 switch(writeset->descriptorType) { in v3dv_UpdateDescriptorSets()
1004 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1015 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1025 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1032 writeset->pTexelBufferView[j]); in v3dv_UpdateDescriptorSets()
[all …]
|
| /dports/graphics/libosmesa-gallium/mesa-21.3.6/src/broadcom/vulkan/ |
| H A D | v3dv_descriptor_set.c | 972 const VkWriteDescriptorSet *writeset = &pDescriptorWrites[i]; in v3dv_UpdateDescriptorSets() local
973 V3DV_FROM_HANDLE(v3dv_descriptor_set, set, writeset->dstSet); in v3dv_UpdateDescriptorSets()
976 set->layout->binding + writeset->dstBinding; in v3dv_UpdateDescriptorSets()
981 descriptor += writeset->dstArrayElement; in v3dv_UpdateDescriptorSets()
983 for (uint32_t j = 0; j < writeset->descriptorCount; ++j) { in v3dv_UpdateDescriptorSets()
984 switch(writeset->descriptorType) { in v3dv_UpdateDescriptorSets()
1004 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1015 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1025 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1032 writeset->pTexelBufferView[j]); in v3dv_UpdateDescriptorSets()
[all …]
|
| /dports/graphics/mesa-libs/mesa-21.3.6/src/broadcom/vulkan/ |
| H A D | v3dv_descriptor_set.c | 972 const VkWriteDescriptorSet *writeset = &pDescriptorWrites[i]; in v3dv_UpdateDescriptorSets() local
973 V3DV_FROM_HANDLE(v3dv_descriptor_set, set, writeset->dstSet); in v3dv_UpdateDescriptorSets()
976 set->layout->binding + writeset->dstBinding; in v3dv_UpdateDescriptorSets()
981 descriptor += writeset->dstArrayElement; in v3dv_UpdateDescriptorSets()
983 for (uint32_t j = 0; j < writeset->descriptorCount; ++j) { in v3dv_UpdateDescriptorSets()
984 switch(writeset->descriptorType) { in v3dv_UpdateDescriptorSets()
1004 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1015 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1025 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1032 writeset->pTexelBufferView[j]); in v3dv_UpdateDescriptorSets()
[all …]
|
| /dports/graphics/mesa-gallium-va/mesa-21.3.6/src/broadcom/vulkan/ |
| H A D | v3dv_descriptor_set.c | 972 const VkWriteDescriptorSet *writeset = &pDescriptorWrites[i]; in v3dv_UpdateDescriptorSets() local
973 V3DV_FROM_HANDLE(v3dv_descriptor_set, set, writeset->dstSet); in v3dv_UpdateDescriptorSets()
976 set->layout->binding + writeset->dstBinding; in v3dv_UpdateDescriptorSets()
981 descriptor += writeset->dstArrayElement; in v3dv_UpdateDescriptorSets()
983 for (uint32_t j = 0; j < writeset->descriptorCount; ++j) { in v3dv_UpdateDescriptorSets()
984 switch(writeset->descriptorType) { in v3dv_UpdateDescriptorSets()
1004 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1015 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1025 writeset->dstArrayElement + j); in v3dv_UpdateDescriptorSets()
1032 writeset->pTexelBufferView[j]); in v3dv_UpdateDescriptorSets()
[all …]
|