Home
last modified time | relevance | path

Searched refs:max_recv (Results 1 – 25 of 100) sorted by relevance

1234

/dports/net/libdaq/libdaq-3.0.5/modules/fst/
H A Ddaq_fst.cc292 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 DDcerpcBind.java45 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 DDcerpcPipeHandle.java78 if (buf.length < max_recv) in doReceiveFragment()
95 if (length > max_recv) in doReceiveFragment()
H A DDcerpcHandle.java107 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 Dsfdaq_instance.cc186 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 Dsfdaq_instance.h52 DAQ_RecvStatus receive_messages(unsigned max_recv);
/dports/security/snort3/snort3-3.1.19.0/src/main/
H A Danalyzer.cc818 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 Dcompat_win32.c326 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 Ddaq_bpf.c177 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 Ddaq_instance_api_defaults.h38 unsigned daq_default_msg_receive(void *handle, const unsigned max_recv, const DAQ_Msg_t *msgs[], DA…
H A Ddaq_instance_api_defaults.c102 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 Ddaq_mod_ops.c436 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 Ddaq_module_api.h46 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 Dapi.c808 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 Ddaq_test_module.c103 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 Dnegprot.c147 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 Dnegprot.c155 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 Dnegprot.c108 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 Ddaq_file.c398 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 Dserver_base_controlcommands.py555 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 Dldap_pvt.h281 ber_len_t *max_recv);
305 ber_len_t max_recv; member
/dports/net/openldap24-client/openldap-2.4.59/include/
H A Dldap_pvt.h281 ber_len_t *max_recv);
305 ber_len_t max_recv; member
/dports/net/libdaq/libdaq-3.0.5/modules/divert/
H A Ddaq_divert.c263 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 Ddaq_dump.c384 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 Ddaq_savefile.c418 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()

1234