Package java.nio

Examples of java.nio.ByteBuffer.clear()

105
106
107
108
109
110
111
112
113
114
115
        hasMore = false;
        while (rs.next())
        {
          hasMore = true;
          buffer.clear();
          buffer.put(rs.getBytes("val"));
          curId = rs.getLong("id");
          event = event.reset(buffer, 0);
          GenericRecord record = _decoder.getGenericRecord(event);
          if (checkFilters(event, record))
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
            currentReadPosition += limit;
            readTasks.add(ListenableFutureTask.create(new Callable<ByteBuffer>() {
                @Override
                public ByteBuffer call() throws Exception {
                    final ByteBuffer buffer = availableBuffers.take();
                    buffer.clear();
                    buffer.limit(limit);
                    while (buffer.hasRemaining()) {
                        int read = channel.read(buffer, readStartingAt);
                        if (read == -1) {
                            throw new EOFException();
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
            final int allCRCExpected = allCRCBytes.getInt();
            final CRC32 allCRC = new CRC32();
            ByteBuffer entryBuffer = ByteBuffer.allocate(ENTRY_WITH_CHECKSUM_SIZE).order(ByteOrder.nativeOrder());

            while (true) {
                entryBuffer.clear();
                int read = 0;

                while (read < ENTRY_WITH_CHECKSUM_SIZE) {
                    final int readThisTime = pis.read(entryBuffer.array(), read, entryBuffer.capacity() - read);
                    if (readThisTime == -1) break;
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
                    pauseReset();
//                    System.out.println("Writing " + index);
                    final int size = excerpt.capacity();
                    int remaining;

                    bb.clear();
                    if (first) {
//                        System.out.println("wi " + index);
                        bb.putLong(index);
                        first = false;
                        remaining = size + TcpUtil.HEADER_SIZE;
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
                    while (!excerpt.index(index))
                        pause(delayNS);
                    int size = excerpt.capacity();
                    int remaining = size + TcpUtil.HEADER_SIZE;

                    bb.clear();
                    bb.putLong(index);
                    bb.putInt(size);
                    while (remaining > 0) {
                        int size2 = Math.min(remaining, bb.capacity());
                        bb.limit(size2);
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
                while (!closed) {
                    while (!excerpt.index(index)) {
//                        System.out.println("Waiting for " + index);
                        long now = System.currentTimeMillis();
                        if (sendInSync <= now && !first) {
                            bb.clear();
                            bb.putInt(IN_SYNC_LEN);
                            bb.flip();
                            IOTools.writeAll(socket, bb);
                            sendInSync = now + HEARTBEAT_INTERVAL_MS;
                        }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
                        sc.socket().setTcpNoDelay(true);
                        while (sc.read(bb) >= 0) {
                            bb.flip();
//                            System.out.println("e "+bb.remaining());
                            IOTools.writeAllOrEOF(sc, bb);
                            bb.clear();
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    } finally {
                        sc.close();
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
                for (int i = 1; i <= WARMUP + RUNS; i++) {
                    long next = start + i * 1000000L / RATE;
                    do {
                        /* busy wait */
                    } while (System.nanoTime() < next);
                    time.clear();
                    // when it should have been sent, not when it was.
                    time.putInt(i);
                    time.putLong(next);
                    time.flip();
//                    System.out.println("w " + time.getInt(0) + " " + time.remaining());
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
            OutputStream out = response.getOutputStream();

            // read the bytes, returning them in the response
            while (in.read(buffer) != -1) {
                out.write(buffer.array(), 0, buffer.position());
                buffer.clear();
            }
            out.close();

        } catch (NotModifiedException e) {
            response.setStatus(HttpServletResponse.SC_NOT_MODIFIED);
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
            {
                if (buf.position() > 0)
                {
                    // flush encoded chars first...
                    sb.append(decode(buf, decoder));
                    buf.clear();
                }

                sb.append(ch);
            }
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.