Home
last modified time | relevance | path

Searched refs:rtm (Results 1 – 25 of 1893) sorted by relevance

12345678910>>...76

/dports/security/vuls/vuls-0.13.7/vendor/github.com/nlopes/slack/
H A Dwebsocket_managed_conn.go40 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 Dwebsocket.go61 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 Dwebsocket_managed_conn.go40 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 Dwebsocket.go61 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 Dgetdate.c95 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 Dwebsocket_managed_conn.go37 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 Dwebsocket.go71 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 Dwebsocket_managed_conn.go43 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 Dwebsocket.go59 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 Dwebsocket_managed_conn.go43 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 Dwebsocket.go59 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 Dwebsocket_managed_conn.go32 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 Darp-bsd.c128 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 Darp.c117 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 Droute.c55 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 Darp.c117 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 Droute.c55 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 DbsdRouteMgr.cpp367 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 Drasqal_triples_source.c250 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 Droute.c29 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 Dkernel_routes.c110 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 Dlocaltime.cxx70 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 Dgetrt.c15 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 Dlocaltime.cxx70 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 DTableLayoutManagerTestCase.java69 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 …]

12345678910>>...76