173174175176177178179180181
protected void output(EHandle caller, ByteBuffer data) throws IOException, Pausable { if (outs != null) { if (data.hasArray()) { outs.write(data.array(), data.arrayOffset() + data.position(), data.remaining()); } else { throw new NotImplemented(); } } }
558559560561562563564
return (data >= '0' && data <= '9'); } public static <T> int parse_ssl(byte[] buf, int start, int len, PacketCallbacks<T> pcb, T arg) { throw new NotImplemented(); }
660661662663664665666667668669670
} } } default: throw new NotImplemented("packet parser for " + htype); } // remain case... int tlen = hlen + plen; if ((max_plen != 0 && plen > max_plen) || tlen < hlen) {
169170171172173174175176177
} reply_buf(contents); } break; default: throw new NotImplemented("ram_file output command:" + ((int) cmd) + " " + EBinary.make(data)); } // switch }
272273274275276277278279280281282
} catch (IOException e) { nbytes = 0; } } else { throw new NotImplemented("mode=" + task.mode); } if (nbytes <= 0) { return false; }
372373374375376377378379380381382
default: throw new Error("should not happen"); } case LINE: throw new NotImplemented(); } this.out.flush(); }
128129130131132133134135136137138
resp = resp.cons( EBinary.make(ev[i]) ); } } } else { throw new NotImplemented(); } hdr.flip(); EBinList res = new EBinList(hdr, resp);
156157158159160161162163164165166
task.node().net_message(task.self_handle(), null, buf); return; } if ((status & EDriverTask.ERTS_PORT_SFLG_LINEBUF_IO) != 0) { throw new NotImplemented(); } EObject tail = null; if (buf == null || !buf.hasRemaining()) { tail = ERT.NIL;
189190191192193194195196197198199
task.node().net_message(task.self_handle(), null, buf); return; } if ((status & EDriverTask.ERTS_PORT_SFLG_LINEBUF_IO) != 0) { throw new NotImplemented(); } EObject out;
520521522523524525526527528529530
} else { return null; } } else { throw new NotImplemented(); } } private ETuple update(ETuple rec, int idx, EInteger incr) {