/dports/security/vuls/vuls-0.13.7/vendor/github.com/nlopes/slack/ |
H A D | websocket_managed_conn.go | 40 if info, conn, err = rtm.connect(connectionCount, rtm.useRTMStart); err != nil { 43 rtm.disconnect() 49 rtm.mu.Lock() 50 rtm.conn = conn 51 rtm.info = info 52 rtm.mu.Unlock() 65 rtm.handleEvents() 195 dialer = rtm.dialer 213 if rtm.conn != nil { 220 rtm.disconnect() [all …]
|
H A D | websocket.go | 61 func (rtm *RTM) disconnect() { 62 rtm.disconnectedm.Do(func() { 63 close(rtm.disconnected) 68 func (rtm *RTM) Disconnect() error { 73 case rtm.killChannel <- true: 75 case <-rtm.disconnected: 83 func (rtm *RTM) GetInfo() *Info { 84 return rtm.info 96 rtm.outgoingMessages <- *msg 99 func (rtm *RTM) resetDeadman() { [all …]
|
/dports/www/beehive/beehive-0.4.0/vendor/github.com/nlopes/slack/ |
H A D | websocket_managed_conn.go | 40 if info, conn, err = rtm.connect(connectionCount, rtm.useRTMStart); err != nil { 43 rtm.disconnect() 49 rtm.mu.Lock() 50 rtm.conn = conn 51 rtm.info = info 52 rtm.mu.Unlock() 65 rtm.handleEvents() 195 dialer = rtm.dialer 213 if rtm.conn != nil { 220 rtm.disconnect() [all …]
|
H A D | websocket.go | 61 func (rtm *RTM) disconnect() { 62 rtm.disconnectedm.Do(func() { 63 close(rtm.disconnected) 68 func (rtm *RTM) Disconnect() error { 73 case rtm.killChannel <- true: 75 case <-rtm.disconnected: 83 func (rtm *RTM) GetInfo() *Info { 84 return rtm.info 96 rtm.outgoingMessages <- *msg 99 func (rtm *RTM) resetDeadman() { [all …]
|
/dports/misc/rump/buildrump.sh-b914579/src/lib/libc/time/ |
H A D | getdate.c | 95 rtm.tm_sec = rtm.tm_min = rtm.tm_hour = TMSENTINEL; in getdate() 96 rtm.tm_mday = rtm.tm_mon = rtm.tm_year = TMSENTINEL; in getdate() 97 rtm.tm_wday = rtm.tm_yday = rtm.tm_isdst = TMSENTINEL; in getdate() 141 if (rtm.tm_wday != TMSENTINEL && rtm.tm_year == TMSENTINEL && in getdate() 142 rtm.tm_mon == TMSENTINEL && rtm.tm_mday == TMSENTINEL) { in getdate() 186 rtm.tm_min == TMSENTINEL && rtm.tm_sec == TMSENTINEL) { in getdate() 196 rtm.tm_year == TMSENTINEL && rtm.tm_mon == TMSENTINEL && in getdate() 212 rtm.tm_min = 0; in getdate() 222 rtm.tm_mon == TMSENTINEL && rtm.tm_mday == TMSENTINEL) { in getdate() 240 rtm.tm_mday += (rtm.tm_wday - tm.tm_wday + 7) % 7; in getdate() [all …]
|
/dports/net-im/slack-term/slack-term-0.4.1/vendor/github.com/nlopes/slack/ |
H A D | websocket_managed_conn.go | 37 if info, conn, err = rtm.connect(connectionCount, rtm.useRTMStart); err != nil { 45 rtm.mu.Lock() 46 rtm.conn = conn 47 rtm.isConnected = true 48 rtm.info = info 49 rtm.mu.Unlock() 166 dialer = rtm.dialer 183 if rtm.isConnected { 214 err := rtm.ping() 220 err := rtm.ping() [all …]
|
H A D | websocket.go | 71 func (rtm *RTM) Disconnect() error { 73 rtm.mu.Lock() 74 defer rtm.mu.Unlock() 80 case rtm.disconnected <- struct{}{}: 84 if !rtm.isConnected { 88 rtm.killChannel <- true 96 func (rtm *RTM) GetInfo() *Info { 97 return rtm.info 109 rtm.outgoingMessages <- *msg 112 func (rtm *RTM) resetDeadman() { [all …]
|
/dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/slack-go/slack/ |
H A D | websocket_managed_conn.go | 43 if info, conn, err = rtm.connect(connectionCount, rtm.useRTMStart); err != nil { 46 rtm.disconnect() 52 rtm.mu.Lock() 53 rtm.conn = conn 54 rtm.info = info 55 rtm.mu.Unlock() 202 if rtm.dialer != nil { 203 dialer = rtm.dialer 221 if rtm.conn != nil { 228 rtm.disconnect() [all …]
|
H A D | websocket.go | 59 func (rtm *RTM) disconnect() { 60 rtm.disconnectedm.Do(func() { 61 close(rtm.disconnected) 66 func (rtm *RTM) Disconnect() error { 71 case rtm.killChannel <- true: 73 case <-rtm.disconnected: 81 func (rtm *RTM) GetInfo() *Info { 82 return rtm.info 94 rtm.outgoingMessages <- *msg 97 func (rtm *RTM) resetDeadman() { [all …]
|
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/slack-go/slack/ |
H A D | websocket_managed_conn.go | 43 if info, conn, err = rtm.connect(connectionCount, rtm.useRTMStart); err != nil { 46 rtm.disconnect() 52 rtm.mu.Lock() 53 rtm.conn = conn 54 rtm.info = info 55 rtm.mu.Unlock() 202 if rtm.dialer != nil { 203 dialer = rtm.dialer 221 if rtm.conn != nil { 228 rtm.disconnect() [all …]
|
H A D | websocket.go | 59 func (rtm *RTM) disconnect() { 60 rtm.disconnectedm.Do(func() { 61 close(rtm.disconnected) 66 func (rtm *RTM) Disconnect() error { 71 case rtm.killChannel <- true: 73 case <-rtm.disconnected: 81 func (rtm *RTM) GetInfo() *Info { 82 return rtm.info 94 rtm.outgoingMessages <- *msg 97 func (rtm *RTM) resetDeadman() { [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/nlopes/slack/ |
H A D | websocket_managed_conn.go | 32 info, conn, err := rtm.connect(connectionCount, rtm.useRTMStart) 38 rtm.info = info 44 rtm.conn = conn 45 rtm.isConnected = true 57 if rtm.wasIntentional { 141 if rtm.isConnected { 144 rtm.isConnected = false 167 err := rtm.ping() 172 case <-rtm.forcePing: 173 err := rtm.ping() [all …]
|
/dports/security/nmap/nmap-7.91/libdnet-stripped/src/ |
H A D | arp-bsd.c | 128 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_add() 131 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_add() 136 if (msg.rtm.rtm_msglen < (int)sizeof(msg.rtm) + in arp_add() 162 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_add() 168 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sin->sin_len + sa->sa_len; in arp_add() 192 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_delete() 195 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_delete() 200 if (msg.rtm.rtm_msglen < (int)sizeof(msg.rtm) + in arp_delete() 238 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_get() 242 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_get() [all …]
|
/dports/net/py-libdnet/libdnet-1.13/src/ |
H A D | arp.c | 117 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_add() 120 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_add() 125 if (msg.rtm.rtm_msglen < (int)sizeof(msg.rtm) + in arp_add() 151 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_add() 157 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sin->sin_len + sa->sa_len; in arp_add() 181 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_delete() 184 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_delete() 189 if (msg.rtm.rtm_msglen < (int)sizeof(msg.rtm) + in arp_delete() 227 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_get() 231 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_get() [all …]
|
H A D | route.c | 55 rtm->rtm_version, rtm->rtm_type, rtm->rtm_flags, in route_msg_print() 56 rtm->rtm_addrs, rtm->rtm_pid, rtm->rtm_seq); in route_msg_print() 64 struct rt_msghdr *rtm; in route_msg() local 75 rtm->rtm_flags = RTF_UP; in route_msg() 76 rtm->rtm_addrs = RTA_DST; in route_msg() 77 rtm->rtm_seq = ++r->seq; in route_msg() 104 route_msg_print(rtm); in route_msg() 115 if (rtm->rtm_type == type && rtm->rtm_pid == pid && in route_msg() 117 if (rtm->rtm_errno) { in route_msg() 118 errno = rtm->rtm_errno; in route_msg() [all …]
|
/dports/net/libdnet/libdnet-1.13/src/ |
H A D | arp.c | 117 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_add() 120 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_add() 125 if (msg.rtm.rtm_msglen < (int)sizeof(msg.rtm) + in arp_add() 151 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_add() 157 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sin->sin_len + sa->sa_len; in arp_add() 181 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_delete() 184 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_delete() 189 if (msg.rtm.rtm_msglen < (int)sizeof(msg.rtm) + in arp_delete() 227 memset(&msg.rtm, 0, sizeof(msg.rtm)); in arp_get() 231 msg.rtm.rtm_msglen = sizeof(msg.rtm) + sizeof(*sin); in arp_get() [all …]
|
H A D | route.c | 55 rtm->rtm_version, rtm->rtm_type, rtm->rtm_flags, in route_msg_print() 56 rtm->rtm_addrs, rtm->rtm_pid, rtm->rtm_seq); in route_msg_print() 64 struct rt_msghdr *rtm; in route_msg() local 75 rtm->rtm_flags = RTF_UP; in route_msg() 76 rtm->rtm_addrs = RTA_DST; in route_msg() 77 rtm->rtm_seq = ++r->seq; in route_msg() 104 route_msg_print(rtm); in route_msg() 115 if (rtm->rtm_type == type && rtm->rtm_pid == pid && in route_msg() 117 if (rtm->rtm_errno) { in route_msg() 118 errno = rtm->rtm_errno; in route_msg() [all …]
|
/dports/net/norm/norm-1.5r6/protolib/src/bsd/ |
H A D | bsdRouteMgr.cpp | 367 rtm->rtm_pid = pid; in SetRoute() 369 rtm->rtm_seq = seq; in SetRoute() 440 int result = send(descriptor, rtm, rtm->rtm_msglen, 0); in SetRoute() 446 result = send(descriptor, rtm, rtm->rtm_msglen, 0); in SetRoute() 594 rtm->rtm_flags = 0; in DeleteRoute() 632 rtm->rtm_pid = pid; in DeleteRoute() 634 rtm->rtm_seq = seq; in DeleteRoute() 703 int result = send(descriptor, rtm, rtm->rtm_msglen, 0); in DeleteRoute() 709 result = send(descriptor, rtm, rtm->rtm_msglen, 0); in DeleteRoute() 860 rtm->rtm_flags = 0; in GetRoute() [all …]
|
/dports/textproc/rasqal/rasqal-0.9.33/src/ |
H A D | rasqal_triples_source.c | 250 if(!rtm) in rasqal_free_triples_match() 254 rtm->finish(rtm, rtm->user_data); in rasqal_free_triples_match() 270 rtm = RASQAL_CALLOC(rasqal_triples_match*, 1, sizeof(*rtm)); in rasqal_new_triples_match() 271 if(rtm) { in rasqal_new_triples_match() 285 rtm = NULL; in rasqal_new_triples_match() 292 rtm = NULL; in rasqal_new_triples_match() 297 return rtm; in rasqal_new_triples_match() 307 if(rtm->is_exact) in rasqal_triples_match_bind_match() 310 return rtm->bind_match(rtm, rtm->user_data, bindings, parts); in rasqal_triples_match_bind_match() 322 rtm->next_match(rtm, rtm->user_data); in rasqal_triples_match_next_match() [all …]
|
/dports/security/fragrouter/fragrouter-1.6/Libnet-0.99b/src/ |
H A D | route.c | 29 struct rt_msghdr *rtm; in libnet_get_next_hop() local 41 rtm=(struct rt_msghdr *)buf; in libnet_get_next_hop() 44 rtm->rtm_version=RTM_VERSION; in libnet_get_next_hop() 45 rtm->rtm_type=RTM_GET; in libnet_get_next_hop() 46 rtm->rtm_addrs=RTA_DST; in libnet_get_next_hop() 47 rtm->rtm_pid=pid=getpid(); in libnet_get_next_hop() 54 n=write(fd, rtm, rtm->rtm_msglen); in libnet_get_next_hop() 61 if (n!=rtm->rtm_msglen) in libnet_get_next_hop() 71 } while (rtm->rtm_type != RTM_GET || rtm->rtm_seq != seq || in libnet_get_next_hop() 74 rtm=(struct rt_msghdr *)buf; in libnet_get_next_hop() [all …]
|
/dports/net/olsrd/olsrd-0.9.8/src/bsd/ |
H A D | kernel_routes.c | 110 rtm = (struct rt_msghdr *)buff; in add_del_route() 116 rtm->rtm_pid = OLSR_PID; in add_del_route() 117 rtm->rtm_seq = ++seq; in add_del_route() 139 rtm->rtm_addrs = RTA_DST; in add_del_route() 249 rtm->rtm_seq = ++seq; in add_del_route() 273 struct rt_msghdr *rtm; in add_del_route6() local 308 rtm->rtm_index = 0; in add_del_route6() 310 rtm->rtm_pid = OLSR_PID; in add_del_route6() 311 rtm->rtm_seq = ++seq; in add_del_route6() 323 rtm->rtm_addrs = RTA_DST; in add_del_route6() [all …]
|
/dports/editors/libreoffice6/libreoffice-6.4.7.2/lotuswordpro/source/filter/ |
H A D | localtime.cxx | 70 bool LtgGmTime(long rtime,LtTm& rtm) in LtgGmTime() argument 119 rtm.tm_year = tmptim; in LtgGmTime() 125 caltim -= rtm.tm_yday * DAY_SEC; in LtgGmTime() 145 rtm.tm_mon = --tmptim; in LtgGmTime() 147 rtm.tm_mday = rtm.tm_yday - mdays[tmptim]; in LtgGmTime() 157 caltim -= rtm.tm_hour * 3600; in LtgGmTime() 160 rtm.tm_sec = static_cast<long>(caltim - (rtm.tm_min) * 60); in LtgGmTime() 163 rtm.tm_year += 1900; in LtgGmTime() 164 ++(rtm.tm_mon); in LtgGmTime() 169 bool LtgLocalTime(long rtime,LtTm& rtm) in LtgLocalTime() argument [all …]
|
/dports/net/libunp/unpv12e/route/ |
H A D | getrt.c | 15 struct rt_msghdr *rtm; in main() local 26 rtm = (struct rt_msghdr *) buf; in main() 28 rtm->rtm_version = RTM_VERSION; in main() 29 rtm->rtm_type = RTM_GET; in main() 30 rtm->rtm_addrs = RTA_DST; in main() 31 rtm->rtm_pid = pid = getpid(); in main() 32 rtm->rtm_seq = SEQ; in main() 38 Write(sockfd, rtm, rtm->rtm_msglen); in main() 41 n = Read(sockfd, rtm, BUFLEN); in main() 42 } while (rtm->rtm_type != RTM_GET || rtm->rtm_seq != SEQ || in main() [all …]
|
/dports/editors/libreoffice/libreoffice-7.2.6.2/lotuswordpro/source/filter/ |
H A D | localtime.cxx | 70 bool LtgGmTime(tools::Long rtime, LtTm& rtm) in LtgGmTime() argument 119 rtm.tm_year = tmptim; in LtgGmTime() 125 caltim -= rtm.tm_yday * DAY_SEC; in LtgGmTime() 146 rtm.tm_mon = --tmptim; in LtgGmTime() 148 rtm.tm_mday = rtm.tm_yday - mdays[tmptim]; in LtgGmTime() 158 caltim -= rtm.tm_hour * 3600; in LtgGmTime() 161 rtm.tm_sec = static_cast<tools::Long>(caltim - (rtm.tm_min) * 60); in LtgGmTime() 164 rtm.tm_year += 1900; in LtgGmTime() 165 ++(rtm.tm_mon); in LtgGmTime() 169 bool LtgLocalTime(tools::Long rtime, LtTm& rtm) in LtgLocalTime() argument [all …]
|
/dports/textproc/fop/fop-2.6/fop-core/src/test/java/org/apache/fop/layoutmgr/table/ |
H A D | TableLayoutManagerTestCase.java | 69 when(rtm.getRetrieveClassName()).thenReturn("A"); in testResolveRetrieveTableMarker() 73 when(pv.resolveMarker(rtm)).thenReturn(m); in testResolveRetrieveTableMarker() 95 assertEquals(rtm, tlm.resolveRetrieveTableMarker(rtm)); in testResolveRetrieveTableMarker() 96 verify(rtm, never()).getBoundary(); in testResolveRetrieveTableMarker() 101 assertNull(tlm.resolveRetrieveTableMarker(rtm)); in testResolveRetrieveTableMarker() 102 verify(rtm).getBoundary(); in testResolveRetrieveTableMarker() 107 assertEquals(rtm, tlm.resolveRetrieveTableMarker(rtm)); in testResolveRetrieveTableMarker() 110 verify(pv).resolveMarker(rtm); in testResolveRetrieveTableMarker() 112 when(pv.resolveMarker(rtm)).thenReturn(null); in testResolveRetrieveTableMarker() 113 assertNull(tlm.resolveRetrieveTableMarker(rtm)); in testResolveRetrieveTableMarker() [all …]
|