| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ack-tracker/ |
| H A D | consecutive_ack_tracker.c | 124 _ack_records_untrack_msg(ConsecutiveAckTracker *self, LogMessage *msg, AckType ack_type) in _ack_records_untrack_msg() argument
129 if (ack_type != AT_ABORTED && _is_bookmark_saving_enabled(self)) in _ack_records_untrack_msg()
140 consecutive_ack_tracker_manage_msg_ack(AckTracker *s, LogMessage *msg, AckType ack_type) in consecutive_ack_tracker_manage_msg_ack() argument
146 if (ack_type == AT_SUSPENDED) in consecutive_ack_tracker_manage_msg_ack()
151 guint32 ack_range_length = _ack_records_untrack_msg(self, msg, ack_type); in consecutive_ack_tracker_manage_msg_ack()
154 if (ack_type == AT_SUSPENDED) in consecutive_ack_tracker_manage_msg_ack()
|
| H A D | ack_tracker.h | 38 void (*manage_msg_ack)(AckTracker *self, LogMessage *msg, AckType ack_type);
73 ack_tracker_manage_msg_ack(AckTracker *self, LogMessage *msg, AckType ack_type) in ack_tracker_manage_msg_ack() argument
75 self->manage_msg_ack(self, msg, ack_type); in ack_tracker_manage_msg_ack()
|
| H A D | instant_ack_tracker_bookmarkless.c | 59 _manage_msg_ack(AckTracker *s, LogMessage *msg, AckType ack_type) in _manage_msg_ack() argument
65 if (ack_type == AT_SUSPENDED) in _manage_msg_ack()
|
| H A D | instant_ack_tracker.c | 78 _manage_msg_ack(AckTracker *s, LogMessage *msg, AckType ack_type) in _manage_msg_ack() argument
86 if (ack_type == AT_SUSPENDED) in _manage_msg_ack()
|
| H A D | batched_ack_tracker.c | 268 _manage_msg_ack(AckTracker *s, LogMessage *msg, AckType ack_type) in _manage_msg_ack() argument
274 if (ack_type == AT_SUSPENDED) in _manage_msg_ack()
277 if (ack_type != AT_ABORTED) in _manage_msg_ack()
|
| /dports/www/kannel/gateway-1.4.4/wap/ |
| H A D | wtp_pack.h | 115 WAPEvent *wtp_pack_ack(long ack_type, int rid_flag, long tid,
121 WAPEvent *wtp_pack_sar_ack(long ack_type, long tid, WAPAddrTuple *address, int psn);
|
| H A D | wtp_pack.c | 243 WAPEvent *wtp_pack_ack(long ack_type, int rid_flag, long tid, in wtp_pack_ack() argument
251 pdu->u.Ack.tidverify = ack_type; in wtp_pack_ack()
263 WAPEvent *wtp_pack_sar_ack(long ack_type, long tid, WAPAddrTuple *address, int psn) in wtp_pack_sar_ack() argument
271 pdu->u.Ack.tidverify = ack_type; in wtp_pack_sar_ack()
|
| H A D | wtp_init.c | 152 static void send_ack(WTPInitMachine *machine, long ack_type, int rid_flag);
579 static void send_ack(WTPInitMachine *machine, long ack_type, int rid_flag) in send_ack() argument
583 e = wtp_pack_ack(ack_type, rid_flag, machine->tid, machine->addr_tuple); in send_ack()
|
| H A D | wtp_resp.c | 202 static void send_ack(WTPRespMachine *machine, long ack_type, int rid_flag);
654 event->u.TR_Invoke_Ind.ack_type = sm->u_ack; in create_tr_invoke_ind()
744 static void send_ack(WTPRespMachine *machine, long ack_type, int rid_flag) in send_ack() argument
748 e = wtp_pack_ack(ack_type, rid_flag, machine->tid, machine->addr_tuple); in send_ack()
|
| /dports/devel/dulwich/dulwich-0.19.16/dulwich/tests/ |
| H A D | test_protocol.py | 36 ack_type,
235 self.assertEqual(SINGLE_ACK, ack_type([b'foo', b'bar']))
236 self.assertEqual(MULTI_ACK, ack_type([b'foo', b'bar', b'multi_ack']))
238 ack_type([b'foo', b'bar', b'multi_ack_detailed']))
241 ack_type([b'foo', b'bar', b'multi_ack',
|
| /dports/net/pwnat/pwnat-5de412c/ |
| H A D | client.c | 322 int client_got_ack(client_t *client, uint8_t ack_type) in client_got_ack() argument
324 if(ack_type == MSG_TYPE_ACK0 && client->tcp2udp_state == CLIENT_WAIT_ACK0) in client_got_ack()
331 if(ack_type == MSG_TYPE_ACK1 && client->tcp2udp_state == CLIENT_WAIT_ACK1) in client_got_ack()
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/third_party/dulwich/ |
| H A D | server.py | 107 ack_type,
586 self.set_ack_type(ack_type(caps))
676 def send_ack(self, sha, ack_type=b''): argument
677 if ack_type:
678 ack_type = b' ' + ack_type
679 self.proto.write_pkt_line(b'ACK ' + sha + ack_type + b'\n')
700 def set_ack_type(self, ack_type): argument
706 self._impl = impl_classes[ack_type](self)
|
| /dports/devel/dulwich/dulwich-0.19.16/dulwich/ |
| H A D | server.py | 108 ack_type,
597 self.set_ack_type(ack_type(caps))
689 def send_ack(self, sha, ack_type=b''): argument
690 if ack_type:
691 ack_type = b' ' + ack_type
692 self.proto.write_pkt_line(b'ACK ' + sha + ack_type + b'\n')
714 def set_ack_type(self, ack_type): argument
720 self._impl = impl_classes[ack_type](self)
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/huawei/hinic/ |
| H A D | hinic_hw_mgmt.c | 128 enum msg_ack_type ack_type, in prepare_header() argument
137 HINIC_MSG_HEADER_SET(ack_type, NO_ACK) | in prepare_header()
203 enum msg_ack_type ack_type, in send_msg_to_mgmt() argument
214 header = prepare_header(pf_to_mgmt, data_len, mod, ack_type, in send_msg_to_mgmt()
218 header = prepare_header(pf_to_mgmt, data_len, mod, ack_type, in send_msg_to_mgmt()
|
| H A D | hinic_hw_cmdq.c | 183 enum hinic_cmd_ack_type ack_type, in cmdq_prepare_wqe_ctrl() argument
212 HINIC_CMDQ_CTRL_SET(ack_type, ACK_TYPE); in cmdq_prepare_wqe_ctrl()
252 enum hinic_cmd_ack_type ack_type, in cmdq_set_lcmd_wqe() argument
269 cmdq_prepare_wqe_ctrl(wqe, wrapped, ack_type, mod, cmd, in cmdq_set_lcmd_wqe()
280 enum hinic_cmd_ack_type ack_type, in cmdq_set_direct_wqe() argument
300 cmdq_prepare_wqe_ctrl(wqe, wrapped, ack_type, mod, cmd, prod_idx, in cmdq_set_direct_wqe()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/huawei/hinic/ |
| H A D | hinic_hw_mgmt.c | 128 enum msg_ack_type ack_type, in prepare_header() argument
137 HINIC_MSG_HEADER_SET(ack_type, NO_ACK) | in prepare_header()
203 enum msg_ack_type ack_type, in send_msg_to_mgmt() argument
214 header = prepare_header(pf_to_mgmt, data_len, mod, ack_type, in send_msg_to_mgmt()
218 header = prepare_header(pf_to_mgmt, data_len, mod, ack_type, in send_msg_to_mgmt()
|
| H A D | hinic_hw_cmdq.c | 183 enum hinic_cmd_ack_type ack_type, in cmdq_prepare_wqe_ctrl() argument
212 HINIC_CMDQ_CTRL_SET(ack_type, ACK_TYPE); in cmdq_prepare_wqe_ctrl()
252 enum hinic_cmd_ack_type ack_type, in cmdq_set_lcmd_wqe() argument
269 cmdq_prepare_wqe_ctrl(wqe, wrapped, ack_type, mod, cmd, in cmdq_set_lcmd_wqe()
280 enum hinic_cmd_ack_type ack_type, in cmdq_set_direct_wqe() argument
300 cmdq_prepare_wqe_ctrl(wqe, wrapped, ack_type, mod, cmd, prod_idx, in cmdq_set_direct_wqe()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/huawei/hinic/ |
| H A D | hinic_hw_mgmt.c | 128 enum msg_ack_type ack_type, in prepare_header() argument
137 HINIC_MSG_HEADER_SET(ack_type, NO_ACK) | in prepare_header()
203 enum msg_ack_type ack_type, in send_msg_to_mgmt() argument
214 header = prepare_header(pf_to_mgmt, data_len, mod, ack_type, in send_msg_to_mgmt()
218 header = prepare_header(pf_to_mgmt, data_len, mod, ack_type, in send_msg_to_mgmt()
|
| H A D | hinic_hw_cmdq.c | 183 enum hinic_cmd_ack_type ack_type, in cmdq_prepare_wqe_ctrl() argument
212 HINIC_CMDQ_CTRL_SET(ack_type, ACK_TYPE); in cmdq_prepare_wqe_ctrl()
252 enum hinic_cmd_ack_type ack_type, in cmdq_set_lcmd_wqe() argument
269 cmdq_prepare_wqe_ctrl(wqe, wrapped, ack_type, mod, cmd, in cmdq_set_lcmd_wqe()
280 enum hinic_cmd_ack_type ack_type, in cmdq_set_direct_wqe() argument
300 cmdq_prepare_wqe_ctrl(wqe, wrapped, ack_type, mod, cmd, prod_idx, in cmdq_set_direct_wqe()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logmsg/ |
| H A D | logmsg.c | 1257 log_msg_clone_ack(LogMessage *msg, AckType ack_type) in log_msg_clone_ack() argument
1263 log_msg_ack(msg->original, &path_options, ack_type); in log_msg_clone_ack()
1451 log_msg_drop(LogMessage *msg, const LogPathOptions *path_options, AckType ack_type) in log_msg_drop() argument
1453 log_msg_ack(msg, path_options, ack_type); in log_msg_drop()
1596 log_msg_ack(LogMessage *self, const LogPathOptions *path_options, AckType ack_type) in log_msg_ack() argument
1608 logmsg_cached_abort |= IS_ACK_ABORTED(ack_type); in log_msg_ack()
1609 logmsg_cached_suspend |= IS_ACK_SUSPENDED(ack_type); in log_msg_ack()
1612 …d_value = log_msg_update_ack_and_ref_and_abort_and_suspended(self, 0, -1, IS_ACK_ABORTED(ack_type), in log_msg_ack()
1613 IS_ACK_SUSPENDED(ack_type)); in log_msg_ack()
1616 if (ack_type == AT_SUSPENDED) in log_msg_ack()
[all …]
|
| H A D | logmsg.h | 63 typedef void (*LMAckFunc)(LogMessage *lm, AckType ack_type);
384 void log_msg_ack(LogMessage *msg, const LogPathOptions *path_options, AckType ack_type);
385 void log_msg_drop(LogMessage *msg, const LogPathOptions *path_options, AckType ack_type);
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/libtest/ |
| H A D | queue_utils_lib.h | 34 void test_ack(LogMessage *msg, AckType ack_type);
|
| H A D | queue_utils_lib.c | 54 test_ack(LogMessage *msg, AckType ack_type) in test_ack() argument
|
| /dports/net/ndisc6/ndisc6-1.0.5/src/ |
| H A D | traceroute.h | 52 extern const tracetype udp_type, udplite_type, echo_type, syn_type, ack_type;
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/gpu/drm/msm/adreno/ |
| H A D | a6xx_hfi.h | 160 u32 ack_type; member
|