/dports/databases/db18/db-18.1.40/examples/c/ |
H A D | ex_thread.c | 112 int nwriters; /* -w */ variable 146 nreaders = nwriters = 4; 170 nwriters = atoi(optarg); 221 nthreads = nreaders + nwriters + 2; 222 printf("Running: readers %d, writers %d\n", nreaders, nwriters); 226 if ((perf = calloc(nreaders + nwriters + 1, sizeof(*perf))) == NULL) 234 for (i = 0; i < nreaders + nwriters; ++i) 485 for (id = 0; id < nreaders + nwriters;) in stats() 486 if (id++ < nwriters) in stats() 564 if (id <= (u_int)nwriters) {
|
/dports/databases/db5/db-5.3.28/examples/c/ |
H A D | ex_thread.c | 74 int nwriters; /* -w */ variable 106 nreaders = nwriters = 4; 126 nwriters = atoi(optarg); 175 nthreads = nreaders + nwriters + 2; 176 printf("Running: readers %d, writers %d\n", nreaders, nwriters); 180 if ((perf = calloc(nreaders + nwriters + 1, sizeof(*perf))) == NULL) 188 for (i = 0; i < nreaders + nwriters; ++i) 413 for (id = 0; id < nreaders + nwriters;) in stats() 414 if (id++ < nwriters) in stats() 478 if (id <= (u_int)nwriters) {
|
/dports/misc/adios2/ADIOS2-2.7.1/testing/adios2/engine/common/ |
H A D | TestEngineCommon.cpp | 102 const int nwriters = 1; in TEST_F() local 106 std::cout << "test " << nwriters << " writers with " << nreaders in TEST_F() 112 if (nwriters + nreaders > numprocs) in TEST_F() 123 if (wrank < nwriters) in TEST_F() 127 else if (wrank < nwriters + nreaders) in TEST_F() 252 double d[nwriters]; in TEST_F()
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in newThread() 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in newThread() 401 long[] position = new long[nwriters]; in newThread() 402 for (int i=0; i<nwriters; i++) { in newThread() 408 Future[] result = new Future[nwriters]; in newThread() 409 for (int i=0; i<nwriters; i++) { in newThread() 417 for (int i=0; i<nwriters; i++) { in newThread()
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/java/nio/channels/AsynchronousFileChannel/ |
H A D | Basic.java | 399 int nwriters = 1 + rand.nextInt(8); in testAsynchronousClose() local 400 ByteBuffer[] buf = new ByteBuffer[nwriters]; in testAsynchronousClose() 401 long[] position = new long[nwriters]; in testAsynchronousClose() 402 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 408 Future[] result = new Future[nwriters]; in testAsynchronousClose() 409 for (int i=0; i<nwriters; i++) { in testAsynchronousClose() 417 for (int i=0; i<nwriters; i++) { in testAsynchronousClose()
|
/dports/misc/adios2/ADIOS2-2.7.1/testing/adios2/engine/staging-common/ |
H A D | TestStagingMPMD.cpp | 264 size_t nwriters = p.npx_w * p.npy_w; in TestCommon() local 266 if (nwriters + nreaders > numprocs) in TestCommon() 281 if (wrank < nwriters) in TestCommon() 285 else if (wrank < nwriters + nreaders) in TestCommon()
|
/dports/net/rclone/rclone-1.57.0/vfs/ |
H A D | file.go | 47 nwriters int32 // len(writers) which is read/updated with atomic member 260 atomic.AddInt32(&f.nwriters, 1) 278 atomic.AddInt32(&f.nwriters, -1) 289 return int(atomic.LoadInt32(&f.nwriters)) 494 nwriters := len(f.writers) 499 if nwriters == 0 {
|
/dports/devel/libisofs/libisofs-1.5.4/libisofs/ |
H A D | ecma119.c | 96 for (i = 0; i < t->nwriters; ++i) { in ecma119_image_free() 1002 target->writers[target->nwriters++] = writer; in ecma119_writer_create() 2779 nwriters++; in ecma119_image_new() 2782 nwriters++; in ecma119_image_new() 2785 nwriters++; in ecma119_image_new() 2787 nwriters++; /* Partition Prepend writer */ in ecma119_image_new() 2789 nwriters+= 2; in ecma119_image_new() 2794 nwriters++; /* part_align_blocks writer */ in ecma119_image_new() 2804 nwriters++; /* GPT backup tail writer */ in ecma119_image_new() 2805 nwriters++; /* Tail padding writer */ in ecma119_image_new() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/sunrpc/ |
H A D | rpc_pipe.c | 179 need_release = pipe->nreaders != 0 || pipe->nwriters != 0; in rpc_close_pipes() 187 pipe->nwriters = 0; in rpc_close_pipes() 223 first_open = pipe->nreaders == 0 && pipe->nwriters == 0; in rpc_pipe_open() 232 pipe->nwriters++; in rpc_pipe_open() 259 pipe->nwriters --; in rpc_pipe_release() 272 last_close = pipe->nwriters == 0 && pipe->nreaders == 0; in rpc_pipe_release() 546 pipe->nwriters = 0; in init_pipe() 1416 return pipe->nreaders || pipe->nwriters; in gssd_running()
|
/dports/multimedia/libv4l/linux-5.13-rc2/net/sunrpc/ |
H A D | rpc_pipe.c | 179 need_release = pipe->nreaders != 0 || pipe->nwriters != 0; in rpc_close_pipes() 187 pipe->nwriters = 0; in rpc_close_pipes() 223 first_open = pipe->nreaders == 0 && pipe->nwriters == 0; in rpc_pipe_open() 232 pipe->nwriters++; in rpc_pipe_open() 259 pipe->nwriters --; in rpc_pipe_release() 272 last_close = pipe->nwriters == 0 && pipe->nreaders == 0; in rpc_pipe_release() 546 pipe->nwriters = 0; in init_pipe() 1416 return pipe->nreaders || pipe->nwriters; in gssd_running()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/sunrpc/ |
H A D | rpc_pipe.c | 179 need_release = pipe->nreaders != 0 || pipe->nwriters != 0; in rpc_close_pipes() 187 pipe->nwriters = 0; in rpc_close_pipes() 223 first_open = pipe->nreaders == 0 && pipe->nwriters == 0; in rpc_pipe_open() 232 pipe->nwriters++; in rpc_pipe_open() 259 pipe->nwriters --; in rpc_pipe_release() 272 last_close = pipe->nwriters == 0 && pipe->nreaders == 0; in rpc_pipe_release() 546 pipe->nwriters = 0; in init_pipe() 1416 return pipe->nreaders || pipe->nwriters; in gssd_running()
|
/dports/multimedia/libv4l/linux-5.13-rc2/include/linux/sunrpc/ |
H A D | rpc_pipe_fs.h | 49 int nwriters; member
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/include/linux/sunrpc/ |
H A D | rpc_pipe_fs.h | 49 int nwriters; member
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/include/linux/sunrpc/ |
H A D | rpc_pipe_fs.h | 49 int nwriters; member
|
/dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/tar-0.4.37/ |
H A D | Cargo.toml | 19 …rrently handle compression, but it is abstract over all I/O readers and\nwriters. Additionally, gr…
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/tar-0.4.30/ |
H A D | Cargo.toml | 19 …rrently handle compression, but it is abstract over all I/O readers and\nwriters. Additionally, gr…
|
/dports/dns/encrypted-dns-server/encrypted-dns-server-0.9.1/cargo-crates/tar-0.4.37/ |
H A D | Cargo.toml | 19 …rrently handle compression, but it is abstract over all I/O readers and\nwriters. Additionally, gr…
|