blob: c5ff65031f2554220da93d8dcd028a5b159571bd [file] [log] [blame]
Damien Miller4af51302000-04-16 11:18:38 +10001/*
2 * Copyright (c) 2000 Markus Friedl. All rights reserved.
3 *
4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions
6 * are met:
7 * 1. Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer.
9 * 2. Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution.
Damien Miller4af51302000-04-16 11:18:38 +100012 *
13 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
14 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
15 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
16 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
17 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
18 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
19 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
20 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
21 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
22 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
23 */
24#include "includes.h"
Damien Millerd5580922003-05-14 13:40:06 +100025RCSID("$OpenBSD: dispatch.c,v 1.16 2003/04/08 20:21:28 itojun Exp $");
Ben Lindstrom226cfa02001-01-22 05:34:40 +000026
27#include "ssh1.h"
Ben Lindstromef1cf5d2001-01-29 07:55:07 +000028#include "ssh2.h"
Ben Lindstrom226cfa02001-01-22 05:34:40 +000029#include "log.h"
Damien Miller4af51302000-04-16 11:18:38 +100030#include "dispatch.h"
31#include "packet.h"
Ben Lindstromef1cf5d2001-01-29 07:55:07 +000032#include "compat.h"
Damien Miller4af51302000-04-16 11:18:38 +100033
34#define DISPATCH_MIN 0
35#define DISPATCH_MAX 255
36
37dispatch_fn *dispatch[DISPATCH_MAX];
38
39void
Damien Miller630d6f42002-01-22 23:17:30 +110040dispatch_protocol_error(int type, u_int32_t seq, void *ctxt)
Damien Miller4af51302000-04-16 11:18:38 +100041{
Damien Miller996acd22003-04-09 20:59:48 +100042 logit("dispatch_protocol_error: type %d seq %u", type, seq);
Damien Miller7d053392002-01-22 23:24:13 +110043 if (!compat20)
44 fatal("protocol error");
45 packet_start(SSH2_MSG_UNIMPLEMENTED);
46 packet_put_int(seq);
47 packet_send();
48 packet_write_wait();
49}
50void
51dispatch_protocol_ignore(int type, u_int32_t seq, void *ctxt)
52{
Damien Miller996acd22003-04-09 20:59:48 +100053 logit("dispatch_protocol_ignore: type %d seq %u", type, seq);
Damien Miller4af51302000-04-16 11:18:38 +100054}
55void
56dispatch_init(dispatch_fn *dflt)
57{
Damien Miller7d053392002-01-22 23:24:13 +110058 u_int i;
Damien Miller4af51302000-04-16 11:18:38 +100059 for (i = 0; i < DISPATCH_MAX; i++)
60 dispatch[i] = dflt;
61}
62void
Damien Miller7d053392002-01-22 23:24:13 +110063dispatch_range(u_int from, u_int to, dispatch_fn *fn)
64{
65 u_int i;
66
67 for (i = from; i <= to; i++) {
68 if (i >= DISPATCH_MAX)
69 break;
70 dispatch[i] = fn;
71 }
72}
73void
Damien Miller4af51302000-04-16 11:18:38 +100074dispatch_set(int type, dispatch_fn *fn)
75{
76 dispatch[type] = fn;
77}
78void
Damien Miller62cee002000-09-23 17:15:56 +110079dispatch_run(int mode, int *done, void *ctxt)
Damien Miller4af51302000-04-16 11:18:38 +100080{
81 for (;;) {
Damien Miller4af51302000-04-16 11:18:38 +100082 int type;
Damien Miller278f9072001-12-21 15:00:19 +110083 u_int32_t seqnr;
Damien Miller4af51302000-04-16 11:18:38 +100084
85 if (mode == DISPATCH_BLOCK) {
Damien Millerdff50992002-01-22 23:16:32 +110086 type = packet_read_seqnr(&seqnr);
Damien Miller4af51302000-04-16 11:18:38 +100087 } else {
Damien Millerdff50992002-01-22 23:16:32 +110088 type = packet_read_poll_seqnr(&seqnr);
Damien Miller4af51302000-04-16 11:18:38 +100089 if (type == SSH_MSG_NONE)
90 return;
91 }
92 if (type > 0 && type < DISPATCH_MAX && dispatch[type] != NULL)
Damien Miller630d6f42002-01-22 23:17:30 +110093 (*dispatch[type])(type, seqnr, ctxt);
Damien Miller4af51302000-04-16 11:18:38 +100094 else
Kevin Stevesef4eea92001-02-05 12:42:17 +000095 packet_disconnect("protocol error: rcvd type %d", type);
Damien Miller4af51302000-04-16 11:18:38 +100096 if (done != NULL && *done)
97 return;
98 }
99}