/dports/devel/p5-IO-Pipely/IO-Pipely-0.005/lib/IO/ |
H A D | Pipely.pm | 209 my ($b_read, $b_write) = (gensym(), gensym()); 212 return ($a_read, $a_write, $b_read, $b_write) if _try_twoway_type( 215 \$b_read, \$b_write 223 \$b_read, \$b_write 323 my ($type, $debug, $a_read, $a_write, $b_read, $b_write) = @_; 328 socketpair($$a_read, $$b_read, AF_UNIX, SOCK_STREAM, PF_UNSPEC) 340 warn "ar($$a_read) aw($$a_write) br($$b_read) bw($$b_write)\n"; 345 $$b_write = $$b_read; 358 pipe($$b_read, $$a_write) or die "pipe 2 failed: $!"; 382 ($$a_read, $$b_read) = _make_socket(); [all …]
|
/dports/www/libwww/w3c-libwww-5.4.2/Library/src/SSL/ |
H A D | HTSSLReader.c | 49 int b_read; member 152 me->b_read = 0; in HTSSLReader_read() 155 status = HTSSL_getError(me->htssl, me->b_read); in HTSSLReader_read() 163 HTTRACEDATA(me->data, me->b_read, "Reading from socket %d" _ soc); in HTSSLReader_read() 165 me->read = me->data + me->b_read; in HTSSLReader_read() 167 me->b_read _ soc); in HTSSLReader_read() 173 HTNet_addBytesRead(net, me->b_read); in HTSSLReader_read() 219 int len = me->b_read; in HTSSLReader_read() 239 (net->readStream, me->write, me->b_read)) != HT_OK) { in HTSSLReader_read() 298 me->b_read -= bytes; in HTSSLReader_consumed() [all …]
|
/dports/devel/p5-POE/POE-1.368/t/20_resources/00_base/ |
H A D | filehandles.pm | 223 "second read add", $b_read, "r" 228 "second read add", $b_read, 234 "second read add", $b_read, "event-rd", undef, undef 240 [ [$a_read => 'r'], [$b_read => 'r'] ], 276 [ [$a_read => 'rw'], [$b_read => 'r'] ], 308 [ [$a_read => 'rw'], [$b_read => 'rx'] ], 339 $poe_kernel->_data_handle_is_good($b_read, MODE_RD), 466 [ [$a_read => 'w'], [$b_read => 'rx'] ], 502 [ [$fh => 'rw'], [$b_read => 'rx'] ]); 558 [ [$fh => 'wx'], [$b_read => 'rx'] ]); [all …]
|
/dports/www/libwww/w3c-libwww-5.4.2/Library/src/ |
H A D | HTReader.c | 30 int b_read; member 116 if ((me->b_read = NETREAD(soc, me->data, INPUT_BUFFER_SIZE)) < 0) { in HTReader_read() 173 } else if (!me->b_read) { in HTReader_read() 183 HTTRACEDATA(me->data, me->b_read, "Reading from socket %d" _ soc); in HTReader_read() 185 me->read = me->data + me->b_read; in HTReader_read() 189 int len = me->b_read; in HTReader_read() 208 me->b_read _ soc); in HTReader_read() 212 HTNet_addBytesRead(net, me->b_read); in HTReader_read() 222 (net->readStream, me->write, me->b_read)) != HT_OK) { in HTReader_read() 281 me->b_read -= bytes; in HTReader_consumed() [all …]
|
H A D | HTANSI.c | 32 int b_read; member 83 if ((me->b_read = fread(me->data, 1, FILE_BUFFER_SIZE, fp)) == 0){ in HTANSIReader_read() 95 HTTRACEDATA(me->data, me->b_read, "HTANSIReader_read me->data:"); in HTANSIReader_read() 97 me->read = me->data + me->b_read; in HTANSIReader_read() 101 HTNet_addBytesRead(net, me->b_read); in HTANSIReader_read() 110 (net->readStream, me->data, me->b_read)) != HT_OK) { in HTANSIReader_read() 119 me->write = me->data + me->b_read; in HTANSIReader_read() 126 me->write = me->data + me->b_read; in HTANSIReader_read()
|
/dports/net/kamailio/kamailio-5.4.5/src/core/ |
H A D | pass_fd.c | 64 int b_read; in recv_all() local 70 b_read=0; in recv_all() 88 b_read+=n; in recv_all() 89 while( (b_read!=data_len) && (n)){ in recv_all() 93 n=recv(socket, (char*)data+b_read, data_len-b_read, 0); in recv_all() 95 n=recv(socket, (char*)data+b_read, data_len-b_read, MSG_WAITALL); in recv_all() 119 b_read+=n; in recv_all() 121 return b_read; in recv_all()
|
/dports/cad/verilator/verilator-4.216/test_regress/t/ |
H A D | t_dpi_accessors.cpp | 79 int b = (int)b_read(); in main() 143 b = (int)b_read(); in main() 220 b = (int)b_read(); in main() 227 b = (int)b_read(); in main() 282 b = (int)b_read(); in main() 337 b = (int)b_read(); in main() 344 b = (int)b_read(); in main() 393 b = (int)b_read(); in main() 402 b = (int)b_read(); in main() 425 b = (int)b_read(); in main() [all …]
|
/dports/security/distcache/distcache-1.5.1/libnal/ |
H A D | proto_fd.c | 121 NAL_BUFFER *b_read; member 322 if((fd_read != -1) && !NAL_BUFFER_set_size(ctx_conn->b_read, buf_size)) in conn_ctx_setup() 334 if(!ctx->b_read) ctx->b_read = NAL_BUFFER_new(); in conn_on_create() 336 if(!ctx->b_read || !ctx->b_send) return 0; in conn_on_create() 347 NAL_BUFFER_free(ctx->b_read); in conn_on_destroy() 356 NAL_BUFFER_reset(ctx->b_read); in conn_on_reset() 395 if((ctx_conn->fd_read != -1) && !NAL_BUFFER_set_size(ctx_conn->b_read, size)) in conn_set_size() 405 return ctx_conn->b_read; in conn_get_read() 444 (NAL_BUFFER_notfull(ctx->b_read) ? SELECTOR_FLAG_READ : 0); in conn_pre_select() 482 int io_ret = nal_fd_buffer_from_fd(ctx->b_read, ctx->fd_read, 0); in conn_do_io()
|
H A D | proto_std.c | 117 NAL_BUFFER *b_read; member 374 if(!NAL_BUFFER_set_size(ctx_conn->b_read, buf_size) || in conn_ctx_setup() 385 if(!ctx->b_read) ctx->b_read = NAL_BUFFER_new(); in conn_on_create() 387 if(!ctx->b_read || !ctx->b_send) return 0; in conn_on_create() 396 NAL_BUFFER_free(ctx->b_read); in conn_on_destroy() 404 NAL_BUFFER_reset(ctx->b_read); in conn_on_reset() 465 if(!NAL_BUFFER_set_size(ctx_conn->b_read, size) || in conn_set_size() 474 return ctx_conn->b_read; in conn_get_read() 516 (ctx->established && NAL_BUFFER_notfull(ctx->b_read) ? in conn_pre_select() 551 int io_ret = nal_fd_buffer_from_fd(ctx->b_read, ctx->fd, 0); in conn_do_io()
|
/dports/misc/vxl/vxl-3.3.2/contrib/brl/bseg/boxm2/volm/ |
H A D | boxm2_volm_io.cxx | 20 m.b_read(is); in vsl_b_read() 31 void vsl_b_read(vsl_b_istream& is, boxm2_volm_loc_hypotheses* p){p->b_read(is);} in vsl_b_read() 33 void vsl_b_read(vsl_b_istream& is, boxm2_volm_loc_hypotheses_sptr& sptr){sptr->b_read(is);} in vsl_b_read()
|
/dports/misc/vxl/vxl-3.3.2/core/vsl/tests/ |
H A D | test_polymorphic_io.cxx | 38 b_read(vsl_b_istream & /*is*/) in b_read() function in test_base_class 108 v.b_read(is); in vsl_b_read() 139 b_read(vsl_b_istream & is) override; 167 test_derived_class::b_read(vsl_b_istream & is) in b_read() function in test_derived_class
|
/dports/misc/vxl/vxl-3.3.2/contrib/mul/mbl/ |
H A D | mbl_chord.h | 48 inline void b_read(vsl_b_istream& bfs); 63 inline void mbl_chord::b_read(vsl_b_istream& bfs) in b_read() function 90 t.b_read(bfs); in vsl_b_read()
|
H A D | mbl_chord_3d.h | 51 inline void b_read(vsl_b_istream& bfs); 67 inline void mbl_chord_3d::b_read(vsl_b_istream& bfs) in b_read() function 95 t.b_read(bfs); in vsl_b_read()
|
H A D | mbl_cloneable_ptr.h | 114 void b_read(vsl_b_istream& bfs) in b_read() function 127 { p.b_read(bfs); } in vsl_b_read() 237 void b_read(vsl_b_istream& bfs) in b_read() function 251 { p.b_read(bfs); } in vsl_b_read()
|
/dports/sysutils/hourglass/hourglass-1.0.1b/src/ |
H A D | work.c | 216 size_t b_read, b_write; in io_dumb_test() local 221 b_read = fread(thrd_data[id].dbuf, 1, thrd_data[id].dsize, in io_dumb_test() 223 if(b_read < thrd_data[id].dsize) in io_dumb_test() 228 id, (unsigned int) b_read); in io_dumb_test() 245 b_write = fwrite(thrd_data[id].dbuf, 1, b_read, thrd_data[id].fd); in io_dumb_test() 246 if(b_write < b_read) in io_dumb_test()
|
/dports/net-im/loudmouth/loudmouth-1.5.4/loudmouth/ |
H A D | lm-ssl-gnutls.c | 331 gint b_read; in _lm_ssl_read() local 334 b_read = gnutls_record_recv (ssl->gnutls_session, buf, len); in _lm_ssl_read() 336 if (b_read == GNUTLS_E_AGAIN) { in _lm_ssl_read() 339 else if (b_read == 0) { in _lm_ssl_read() 342 else if (b_read < 0) { in _lm_ssl_read() 345 *bytes_read = (guint) b_read; in _lm_ssl_read()
|
/dports/misc/vxl/vxl-3.3.2/contrib/brl/bbas/volm/conf/ |
H A D | volm_conf_score.cxx | 47 void volm_conf_score::b_read(vsl_b_istream& is) in b_read() function in volm_conf_score 96 score.b_read(is); in vsl_b_read() 107 score_ptr->b_read(is); in vsl_b_read()
|
/dports/misc/vxl/vxl-3.3.2/contrib/mul/vil3d/ |
H A D | vil3d_chord.h | 55 inline void b_read(vsl_b_istream& bfs); 84 inline void vil3d_chord::b_read(vsl_b_istream& bfs) in b_read() function 120 t.b_read(bfs); in vsl_b_read() 130 for (unsigned i=0;i<n;++i) t[i].b_read(bfs); in vsl_b_read()
|
/dports/misc/vxl/vxl-3.3.2/contrib/gel/vsol/ |
H A D | vsol_point_2d.cxx | 147 void vsol_point_2d::b_read(vsl_b_istream &is) in b_read() function in vsol_point_2d 156 vsol_spatial_object_2d::b_read(is); in b_read() 207 p->b_read(is); in vsl_b_read()
|
H A D | vsol_cylinder.cxx | 48 void vsol_cylinder::b_read(vsl_b_istream &is) in b_read() function in vsol_cylinder 122 cyl->b_read(is); in vsl_b_read() 134 cyl->b_read(is); in vsl_b_read()
|
H A D | vsol_point_3d.cxx | 156 void vsol_point_3d::b_read(vsl_b_istream &is) in b_read() function in vsol_point_3d 165 vsol_spatial_object_3d::b_read(is); in b_read() 216 p->b_read(is); in vsl_b_read()
|
/dports/databases/rrdtool/rrdtool-1.7.2/src/ |
H A D | rrd_resize.c | 254 ssize_t b_read; in rrd_resize() local 255 if ((b_read=rrd_read(rrd_file, &buffer, sizeof(rrd_value_t) * 1)) <= 0) in rrd_resize() 257 if(rrd_out_file->pos+b_read > rrd_out_file->file_len) { in rrd_resize() 258 …s\nWARNING: if you see this message multiple times for a single file you're in trouble\n", b_read); in rrd_resize() 261 rrd_write(rrd_out_file, &buffer, b_read); in rrd_resize()
|
/dports/misc/bdelta/BDelta-0.3.1/test/ |
H A D | library.cpp | 16 void *b_read(unsigned place, unsigned num) { in b_read() function 20 void *bi = bdelta_init_alg(strlen(a), strlen(b), a_read, b_read); in main()
|
/dports/misc/vxl/vxl-3.3.2/contrib/mul/msm/ |
H A D | msm_shape_model.cxx | 121 void msm_shape_model::b_read(vsl_b_istream& bfs) in b_read() function in msm_shape_model 128 msm_ref_shape_model::b_read(bfs); // Load base in b_read() 156 b.b_read(bfs); in vsl_b_read()
|
/dports/net/multicat/multicat-2.3/ |
H A D | util.h | 100 int OpenFile( const char *psz_arg, bool b_read, bool b_append ); 102 FILE *OpenAuxFile( const char *psz_arg, bool b_read, bool b_append ); 108 int OpenDirFile( const char *psz_dir_path, uint64_t i_file, bool b_read,
|