| /dports/security/distcache/distcache-1.5.1/libnal/ |
| H A D | util_fd.c | 96 int nal_fd_buffer_from_fd(NAL_BUFFER *buf, int fd, unsigned int max_read) in nal_fd_buffer_from_fd() argument
102 if((max_read == 0) || (max_read > buf_avail)) in nal_fd_buffer_from_fd()
103 max_read = buf_avail; in nal_fd_buffer_from_fd()
105 if(!max_read) in nal_fd_buffer_from_fd()
108 ret = recv(fd, NAL_BUFFER_write_ptr(buf), max_read, 0); in nal_fd_buffer_from_fd()
110 ret = read(fd, NAL_BUFFER_write_ptr(buf), max_read); in nal_fd_buffer_from_fd()
113 ret = recv(fd, NAL_BUFFER_write_ptr(buf), max_read, MSG_NOSIGNAL); in nal_fd_buffer_from_fd()
|
| /dports/science/py-dlib/dlib-19.22/dlib/test/ |
| H A D | read_write_mutex.cpp | 48 int max_read; member in __anona84f13080111::read_write_mutex_tester
94 max_read = max(num_read, max_read); in do_readonly_stuff()
112 max_read = max(num_read, max_read); in do_readonly_stuff()
166 max_read = 0; in perform_test()
198 DLIB_TEST_MSG(max_read == 6, "max_read: "<< max_read); in perform_test()
|
| /dports/science/dlib-cpp/dlib-19.22/dlib/test/ |
| H A D | read_write_mutex.cpp | 48 int max_read; member in __anonc76f9d420111::read_write_mutex_tester
94 max_read = max(num_read, max_read); in do_readonly_stuff()
112 max_read = max(num_read, max_read); in do_readonly_stuff()
166 max_read = 0; in perform_test()
198 DLIB_TEST_MSG(max_read == 6, "max_read: "<< max_read); in perform_test()
|
| /dports/comms/liquid-dsp/liquid-dsp-1.3.2/src/buffer/src/ |
| H A D | cbuffer.c | 45 unsigned int max_read; in CBUFFER() local
81 q->max_read = _max_read; in CBUFFER()
84 q->num_allocated = q->max_size + q->max_read - 1; in CBUFFER()
112 _q->max_read, in CBUFFER()
129 _q->max_read, in CBUFFER()
184 return _q->max_read; in CBUFFER()
291 if (_num_requested > _q->max_read) in CBUFFER()
292 _num_requested = _q->max_read; in CBUFFER()
335 memmove(_q->v + _q->max_size, _q->v, (_q->max_read-1)*sizeof(T)); in CBUFFER()
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tdutils/td/utils/ |
| H A D | BufferedFd.h | 30 …Result<size_t> flush_read(size_t max_read = std::numeric_limits<size_t>::max()) TD_WARN_UNUSED_RES…
84 …Result<size_t> flush_read(size_t max_read = std::numeric_limits<size_t>::max()) TD_WARN_UNUSED_RES…
100 Result<size_t> BufferedFdBase<FdT>::flush_read(size_t max_read) { in flush_read() argument
103 while (::td::can_read_local(*this) && max_read) { in flush_read()
105 slice.truncate(max_read); in flush_read()
110 max_read -= x; in flush_read()
193 Result<size_t> BufferedFd<FdT>::flush_read(size_t max_read) { in flush_read() argument
194 TRY_RESULT(result, Parent::flush_read(max_read)); in flush_read()
|
| /dports/biology/rainbow/rainbow_2.0.4/ |
| H A D | rbasm_main.c | 6 uint32_t min_ol, min_read, max_read; in main() local
15 max_read = 200; in main()
23 case 'R': max_read = atoi(optarg); break; in main()
37 asm_ef(in, out, min_ol, min_sm, min_read, max_read); in main()
|
| /dports/lang/ruby26/ruby-2.6.9/lib/rubygems/package/tar_reader/ |
| H A D | entry.rb | 138 max_read = [len, @header.size - @read].min
140 ret = @io.read max_read
152 max_read = [maxlen, @header.size - @read].min
154 @io.readpartial(max_read, outbuf)
|
| /dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tdutils/td/utils/port/ |
| H A D | StdStreams.cpp | 106 …Result<size_t> flush_read(size_t max_read = std::numeric_limits<size_t>::max()) TD_WARN_UNUSED_RES… in flush_read() argument
201 …Result<size_t> flush_read(size_t max_read = std::numeric_limits<size_t>::max()) TD_WARN_UNUSED_RES… in flush_read() argument
204 while (::td::can_read_local(*this) && max_read) { in flush_read()
206 slice.truncate(max_read); in flush_read()
211 max_read -= x; in flush_read()
245 Result<size_t> BufferedStdin::flush_read(size_t max_read) { in flush_read() argument
246 return impl_->flush_read(max_read); in flush_read()
|
| /dports/ftp/lftp/lftp-4.9.2/src/ |
| H A D | buffer_ssl.cc | 63 int max_read=0; in Get_LL() local
65 while(total<size-max_read) { in Get_LL()
82 if(max_read<res) in Get_LL()
83 max_read=res; in Get_LL()
|
| /dports/x11-toolkits/plib/plib-1.8.5/src/net/ |
| H A D | netBuffer.cxx | 29 int max_read = in_buffer.getMaxLength() - in_buffer.getLength() ; in handleRead() local
30 if (max_read) in handleRead()
33 int num_read = recv (data, max_read) ; in handleRead()
|
| /dports/net-im/libpurple/pidgin-2.14.8/libpurple/ |
| H A D | circbuffer.c | 124 gsize max_read; in purple_circ_buffer_get_max_read() local
129 max_read = 0; in purple_circ_buffer_get_max_read()
131 max_read = buf->buflen - (buf->outptr - buf->buffer); in purple_circ_buffer_get_max_read()
133 max_read = buf->inptr - buf->outptr; in purple_circ_buffer_get_max_read()
135 return max_read; in purple_circ_buffer_get_max_read()
|
| /dports/net-im/pidgin/pidgin-2.14.8/libpurple/ |
| H A D | circbuffer.c | 124 gsize max_read; in purple_circ_buffer_get_max_read() local
129 max_read = 0; in purple_circ_buffer_get_max_read()
131 max_read = buf->buflen - (buf->outptr - buf->buffer); in purple_circ_buffer_get_max_read()
133 max_read = buf->inptr - buf->outptr; in purple_circ_buffer_get_max_read()
135 return max_read; in purple_circ_buffer_get_max_read()
|
| /dports/net-im/finch/pidgin-2.14.8/libpurple/ |
| H A D | circbuffer.c | 124 gsize max_read; in purple_circ_buffer_get_max_read() local
129 max_read = 0; in purple_circ_buffer_get_max_read()
131 max_read = buf->buflen - (buf->outptr - buf->buffer); in purple_circ_buffer_get_max_read()
133 max_read = buf->inptr - buf->outptr; in purple_circ_buffer_get_max_read()
135 return max_read; in purple_circ_buffer_get_max_read()
|
| /dports/www/davix/davix-0.7.6/test/functional/ |
| H A D | test_opendir_partial.cpp | 34 int max_read= atoi(argv[2]); in main() local
35 std::cout << " end of the dir number " << max_read << std::endl; in main()
58 }while(dir!= NULL && max_read > n); in main()
|
| /dports/devel/android-tools-fastboot/platform_system_core-platform-tools-29.0.5/libunwindstack/ |
| H A D | Memory.cpp | 161 bool Memory::ReadString(uint64_t addr, std::string* string, uint64_t max_read) { in ReadString() argument
164 while (bytes_read < max_read) { in ReadString()
451 size_t max_read = ((addr_page + 1) << kCacheBits) - addr; in Read() local
452 if (size <= max_read) { in Read()
459 memcpy(dst, &cache_dst[addr & kCacheMask], max_read); in Read()
460 dst = &reinterpret_cast<uint8_t*>(dst)[max_read]; in Read()
471 return impl_->Read(addr_page << kCacheBits, dst, size - max_read) + max_read; in Read()
474 memcpy(dst, cache_dst, size - max_read); in Read()
|
| /dports/devel/simgear/simgear-2020.3.11/simgear/io/ |
| H A D | sg_netBuffer.cxx | 118 int max_read = in_buffer.getMaxLength() - in_buffer.getLength() ; in handleRead() local
119 if (max_read) in handleRead()
122 int num_read = recv (data, max_read) ; in handleRead()
|
| /dports/security/modsecurity3-nginx/nginx-1.20.0/src/event/modules/ |
| H A D | ngx_win32_select_module.c | 31 static ngx_uint_t max_read; variable
111 max_read = 0; in ngx_select_init()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
163 max_read++; in ngx_select_add_event()
199 max_read--; in ngx_select_del_event()
257 if (max_read || max_write) { in ngx_select_process_events()
|
| /dports/www/nginx-full/nginx-1.20.2/src/event/modules/ |
| H A D | ngx_win32_select_module.c | 31 static ngx_uint_t max_read; variable
111 max_read = 0; in ngx_select_init()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
163 max_read++; in ngx_select_add_event()
199 max_read--; in ngx_select_del_event()
257 if (max_read || max_write) { in ngx_select_process_events()
|
| /dports/www/nginx-naxsi/nginx-1.20.2/src/event/modules/ |
| H A D | ngx_win32_select_module.c | 31 static ngx_uint_t max_read; variable
111 max_read = 0; in ngx_select_init()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
163 max_read++; in ngx_select_add_event()
199 max_read--; in ngx_select_del_event()
257 if (max_read || max_write) { in ngx_select_process_events()
|
| /dports/www/nginx-lite/nginx-1.20.2/src/event/modules/ |
| H A D | ngx_win32_select_module.c | 31 static ngx_uint_t max_read; variable
111 max_read = 0; in ngx_select_init()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
163 max_read++; in ngx_select_add_event()
199 max_read--; in ngx_select_del_event()
257 if (max_read || max_write) { in ngx_select_process_events()
|
| /dports/www/nginx/nginx-1.20.2/src/event/modules/ |
| H A D | ngx_win32_select_module.c | 31 static ngx_uint_t max_read; variable
111 max_read = 0; in ngx_select_init()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
163 max_read++; in ngx_select_add_event()
199 max_read--; in ngx_select_del_event()
257 if (max_read || max_write) { in ngx_select_process_events()
|
| /dports/www/nginx-devel/nginx-1.21.5/src/event/modules/ |
| H A D | ngx_win32_select_module.c | 31 static ngx_uint_t max_read; variable
111 max_read = 0; in ngx_select_init()
152 if ((event == NGX_READ_EVENT && max_read >= FD_SETSIZE) in ngx_select_add_event()
163 max_read++; in ngx_select_add_event()
199 max_read--; in ngx_select_del_event()
257 if (max_read || max_write) { in ngx_select_process_events()
|
| /dports/net/gsk/gsk-1.0.63/src/programs/ |
| H A D | gsk-throttle-proxy.c | 192 guint max_read; in handle_side_readable() local
197 max_read = side->max_xfer_per_second - side->xferred_in_last_second; in handle_side_readable()
203 max_read = side->max_xfer_per_second; in handle_side_readable()
205 if (max_read + side->buffer.size > side->max_buffer) in handle_side_readable()
208 max_read = 0; in handle_side_readable()
210 max_read = side->max_buffer - side->buffer.size; in handle_side_readable()
213 tmp = g_malloc (max_read); in handle_side_readable()
214 nread = gsk_stream_read (stream, tmp, max_read, &error); in handle_side_readable()
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/tools/mediaserver/upnpsdk/Neptune/Source/Core/ |
| H A D | NptStreams.cpp | 51 NPT_InputStream::Load(NPT_DataBuffer& buffer, NPT_Size max_read /* = 0 */) in Load() argument
60 if (max_read > NPT_INPUT_STREAM_LOAD_MAX_SIZE) { in Load()
68 if (max_read && max_read < size) size = max_read; in Load()
73 size = max_read; in Load()
|
| /dports/multimedia/kodi/xbmc-19.3-Matrix/lib/libUPnP/Neptune/Source/Core/ |
| H A D | NptStreams.cpp | 51 NPT_InputStream::Load(NPT_DataBuffer& buffer, NPT_Size max_read /* = 0 */) in Load() argument
60 if (max_read > NPT_INPUT_STREAM_LOAD_MAX_SIZE) { in Load()
68 if (max_read && max_read < size) size = max_read; in Load()
73 size = max_read; in Load()
|