/dports/net/libdaq/libdaq-3.0.5/modules/fst/ |
H A D | daq_fst.cc | 292 return idx < max_recv; in process_lost_souls() 330 if (!process_lost_souls(fc, msgs, max_recv, idx)) in process_daq_msg() 377 if (idx == max_recv) in process_daq_msg() 574 while (idx < max_recv && !fc->limbo.empty()) in process_unjudged_souls() 583 return idx < max_recv; in process_unjudged_souls() 593 if (!process_unjudged_souls(fc, msgs, max_recv, idx)) in fst_daq_msg_receive() 595 if (idx != max_recv) in fst_daq_msg_receive() 599 if (!process_lost_souls(fc, msgs, max_recv, idx)) in fst_daq_msg_receive() 601 if (idx != max_recv) in fst_daq_msg_receive() 619 const DAQ_Msg_t *orig_msgs[max_recv]; in fst_daq_msg_receive() [all …]
|
/dports/net/jcifs/jcifs_1.3.19/src/jcifs/dcerpc/ |
H A D | DcerpcBind.java | 45 int max_xmit, max_recv; field in DcerpcBind 52 max_recv = handle.max_recv; in DcerpcBind() 62 buf.enc_ndr_short(max_recv); in encode_in()
|
H A D | DcerpcPipeHandle.java | 78 if (buf.length < max_recv) in doReceiveFragment() 95 if (length > max_recv) in doReceiveFragment()
|
H A D | DcerpcHandle.java | 107 protected int max_recv = max_xmit; field in DcerpcHandle 216 frag = new byte[max_recv]; in sendrecv()
|
/dports/security/snort3/snort3-3.1.19.0/src/packet_io/ |
H A D | sfdaq_instance.cc | 186 DAQ_RecvStatus SFDAQInstance::receive_messages(unsigned max_recv) in receive_messages() argument 188 assert(max_recv <= batch_size); in receive_messages() 190 if (max_recv > pool_available) in receive_messages() 191 max_recv = pool_available; in receive_messages() 194 curr_batch_size = daq_instance_msg_receive(instance, max_recv, daq_msgs, &rstat); in receive_messages()
|
H A D | sfdaq_instance.h | 52 DAQ_RecvStatus receive_messages(unsigned max_recv);
|
/dports/security/snort3/snort3-3.1.19.0/src/main/ |
H A D | analyzer.cc | 818 unsigned max_recv = daq_instance->get_batch_size(); in process_messages() local 819 if (exit_after_cnt && exit_after_cnt < max_recv) in process_messages() 820 max_recv = exit_after_cnt; in process_messages() 821 if (pause_after_cnt && pause_after_cnt < max_recv) in process_messages() 822 max_recv = pause_after_cnt; in process_messages() 827 rstat = daq_instance->receive_messages(max_recv); in process_messages()
|
/dports/www/shttpd/shttpd-1.42/src/ |
H A D | compat_win32.c | 326 size_t max_recv; in stdoutput() local 328 max_recv = min(sizeof(buf), tp->content_len - total); in stdoutput() 330 max_recv > 0 && in stdoutput() 332 (n = recv(tp->s, buf, max_recv, 0)) > 0) { in stdoutput() 339 max_recv = min(sizeof(buf), tp->content_len - total); in stdoutput()
|
/dports/net/libdaq/libdaq-3.0.5/modules/bpf/ |
H A D | daq_bpf.c | 177 static unsigned bpf_daq_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs[],… in bpf_daq_msg_receive() argument 180 unsigned num_receive = CALL_SUBAPI(bc, msg_receive, max_recv, msgs, rstat); in bpf_daq_msg_receive()
|
/dports/net/libdaq/libdaq-3.0.5/api/ |
H A D | daq_instance_api_defaults.h | 38 unsigned daq_default_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs[], DA…
|
H A D | daq_instance_api_defaults.c | 102 unsigned daq_default_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs[], DA… in daq_default_msg_receive() argument
|
H A D | daq_mod_ops.c | 436 DAQ_LINKAGE unsigned daq_instance_msg_receive(DAQ_Instance_t *instance, const unsigned max_recv, DA… in daq_instance_msg_receive() argument 457 if (!max_recv) in daq_instance_msg_receive() 463 return instance->api.msg_receive.func(instance->api.msg_receive.context, max_recv, msgs, rstat); in daq_instance_msg_receive()
|
H A D | daq_module_api.h | 46 typedef unsigned (*daq_module_msg_receive_func) (void *handle, const unsigned max_recv, const DAQ_M…
|
/dports/net/owamp/owamp-3.3/owamp/ |
H A D | api.c | 808 uint32_t *max_recv = &max_recv_data; in _OWPCleanDataRecs() local 813 max_recv = max_recv_rtn; in _OWPCleanDataRecs() 814 *max_recv = 0; in _OWPCleanDataRecs() 1105 *max_recv = MAX(rec.seq_no,*max_recv); in _OWPCleanDataRecs() 1336 uint32_t max_recv,num_recs; in _OWPCleanUpSessions() local 1374 max_recv = 0; in _OWPCleanUpSessions() 1375 if( !_OWPCleanDataRecs(cntrl->ctx,tptr,0xFFFFFFFF,stoptime,&max_recv, in _OWPCleanUpSessions() 1399 if(!max_recv){ in _OWPCleanUpSessions() 1431 max_recv = maxrec.maxrecv; in _OWPCleanUpSessions() 1469 if(rec.seq_no > max_recv){ in _OWPCleanUpSessions()
|
/dports/net/libdaq/libdaq-3.0.5/test/ |
H A D | daq_test_module.c | 103 static unsigned daq_test_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs[]… in daq_test_msg_receive() argument
|
/dports/net-mgmt/wmi-client/wmi-1.3.16/Samba/source/smb_server/smb/ |
H A D | negprot.c | 147 SSVAL(req->out.vwv, VWV(2), req->smb_conn->negotiate.max_recv); in reply_lanman1() 201 SSVAL(req->out.vwv, VWV(2), req->smb_conn->negotiate.max_recv); in reply_lanman2() 335 SIVAL(req->out.vwv+1, VWV(3), req->smb_conn->negotiate.max_recv); in reply_nt1()
|
/dports/net/samba412/samba-4.12.15/source4/smb_server/smb/ |
H A D | negprot.c | 155 SSVAL(req->out.vwv, VWV(2), req->smb_conn->negotiate.max_recv); in reply_lanman1() 212 SSVAL(req->out.vwv, VWV(2), req->smb_conn->negotiate.max_recv); in reply_lanman2() 360 SIVAL(req->out.vwv+1, VWV(3), req->smb_conn->negotiate.max_recv); in reply_nt1()
|
/dports/net/samba412/samba-4.12.15/source3/smbd/ |
H A D | negprot.c | 108 SSVAL(req->outbuf,smb_vwv2, xconn->smb1.negprot.max_recv); in reply_lanman1() 166 SSVAL(req->outbuf,smb_vwv2,xconn->smb1.negprot.max_recv); in reply_lanman2() 369 xconn->smb1.negprot.max_recv); /* max buffer. LOTS! */ in reply_nt1()
|
/dports/security/snort3/snort3-3.1.19.0/daqs/ |
H A D | daq_file.c | 398 static unsigned file_daq_msg_receive(void* handle, const unsigned max_recv, const DAQ_Msg_t* msgs[]… in file_daq_msg_receive() argument 404 while (idx < max_recv) in file_daq_msg_receive()
|
/dports/x11/xpra/xpra-4.3/xpra/server/mixins/ |
H A D | server_base_controlcommands.py | 555 def control_command_clipboard_limits(self, max_send, max_recv, *_args): argument 558 ch.set_limits(max_send, max_recv) 559 …= "clipboard send limit set to %d, recv limit set to %d (single copy/paste)" % (max_send, max_recv) 561 self.setting_changed("clipboard-limits", {'send': max_send, 'recv': max_recv})
|
/dports/net/openldap24-server/openldap-2.4.59/include/ |
H A D | ldap_pvt.h | 281 ber_len_t *max_recv); 305 ber_len_t max_recv; member
|
/dports/net/openldap24-client/openldap-2.4.59/include/ |
H A D | ldap_pvt.h | 281 ber_len_t *max_recv); 305 ber_len_t max_recv; member
|
/dports/net/libdaq/libdaq-3.0.5/modules/divert/ |
H A D | daq_divert.c | 263 static unsigned divert_daq_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs… in divert_daq_msg_receive() argument 270 while (idx < max_recv) in divert_daq_msg_receive()
|
/dports/net/libdaq/libdaq-3.0.5/modules/dump/ |
H A D | daq_dump.c | 384 static unsigned dump_daq_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs[]… in dump_daq_msg_receive() argument 387 unsigned num_receive = CALL_SUBAPI(dc, msg_receive, max_recv, msgs, rstat); in dump_daq_msg_receive()
|
/dports/net/libdaq/libdaq-3.0.5/modules/savefile/ |
H A D | daq_savefile.c | 418 static unsigned savefile_daq_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *ms… in savefile_daq_msg_receive() argument 424 while (idx < max_recv && status == DAQ_RSTAT_OK) in savefile_daq_msg_receive()
|