Home
last modified time | relevance | path

Searched refs:nwriters (Results 1 – 25 of 61) sorted by relevance

123

/dports/databases/db18/db-18.1.40/examples/c/
H A Dex_thread.c112 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 Dex_thread.c74 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 DTestEngineCommon.cpp102 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DBasic.java399 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 DTestStagingMPMD.cpp264 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 Dfile.go47 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 Decma119.c96 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 Drpc_pipe.c179 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 Drpc_pipe.c179 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 Drpc_pipe.c179 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 Drpc_pipe_fs.h49 int nwriters; member
/dports/multimedia/v4l_compat/linux-5.13-rc2/include/linux/sunrpc/
H A Drpc_pipe_fs.h49 int nwriters; member
/dports/multimedia/v4l-utils/linux-5.13-rc2/include/linux/sunrpc/
H A Drpc_pipe_fs.h49 int nwriters; member
/dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/tar-0.4.37/
H A DCargo.toml19 …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 DCargo.toml19 …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 DCargo.toml19 …rrently handle compression, but it is abstract over all I/O readers and\nwriters. Additionally, gr…

123