aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDaniel Stenberg <daniel@haxx.se>2014-01-30 00:11:56 +0100
committerDaniel Stenberg <daniel@haxx.se>2014-01-30 00:11:56 +0100
commitc3fe3d9926836ab2587dbab1e9192637db9d3cf5 (patch)
tree48efc1f7898517b1fb8189f2c968ac1b608bfc33
parent62e3d66cc626ae0d56c81e96d96beb7d1aa4e339 (diff)
http2: added stubs for all nghttp2 callbacks
This makes it easier to trace what's happening.
-rw-r--r--lib/http2.c127
1 files changed, 114 insertions, 13 deletions
diff --git a/lib/http2.c b/lib/http2.c
index b7edbc590..c3ed3c6cd 100644
--- a/lib/http2.c
+++ b/lib/http2.c
@@ -130,9 +130,110 @@ static ssize_t recv_callback(nghttp2_session *h2,
return nread;
}
+static int on_frame_recv(nghttp2_session *session, const nghttp2_frame *frame,
+ void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)frame;
+ infof(conn->data, "on_frame_recv() was called with header %x\n",
+ frame->hd.type);
+ return 0;
+}
+
+static int on_invalid_frame_recv(nghttp2_session *session,
+ const nghttp2_frame *frame,
+ nghttp2_error_code error_code, void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)frame;
+ infof(conn->data, "on_invalid_frame_recv() was called, error_code = %d\n",
+ error_code);
+ return 0;
+}
+
+static int on_data_chunk_recv(nghttp2_session *session, uint8_t flags,
+ int32_t stream_id,
+ const uint8_t *data, size_t len, void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)flags;
+ (void)stream_id;
+ (void)data;
+ infof(conn->data, "on_data_chunk_recv() was called with len = %u\n", len);
+ return 0;
+}
+
+static int before_frame_send(nghttp2_session *session,
+ const nghttp2_frame *frame,
+ void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)frame;
+ infof(conn->data, "before_frame_send() was called\n");
+ return 0;
+}
+static int on_frame_send(nghttp2_session *session,
+ const nghttp2_frame *frame,
+ void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)frame;
+ infof(conn->data, "on_frame_send() was called\n");
+ return 0;
+}
+static int on_frame_not_send(nghttp2_session *session,
+ const nghttp2_frame *frame,
+ int lib_error_code, void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)frame;
+ infof(conn->data, "on_frame_not_send() was called, lib_error_code = %d\n",
+ lib_error_code);
+ return 0;
+}
+static int on_stream_close(nghttp2_session *session, int32_t stream_id,
+ nghttp2_error_code error_code, void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)stream_id;
+ infof(conn->data, "on_stream_close() was called, error_code = %d\n",
+ error_code);
+ return 0;
+}
+
+static int on_unknown_frame_recv(nghttp2_session *session,
+ const uint8_t *head, size_t headlen,
+ const uint8_t *payload, size_t payloadlen,
+ void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)head;
+ (void)headlen;
+ (void)payload;
+ (void)payloadlen;
+ infof(conn->data, "on_unknown_frame_recv() was called\n");
+ return 0;
+}
+static int on_begin_headers(nghttp2_session *session,
+ const nghttp2_frame *frame, void *userp)
+{
+ struct connectdata *conn = (struct connectdata *)userp;
+ (void)session;
+ (void)frame;
+ infof(conn->data, "on_begin_headers() was called\n");
+ return 0;
+}
/* frame->hd.type is either NGHTTP2_HEADERS or NGHTTP2_PUSH_PROMISE */
-static int got_header(nghttp2_session *session, const nghttp2_frame *frame,
+static int on_header(nghttp2_session *session, const nghttp2_frame *frame,
const uint8_t *name, size_t namelen,
const uint8_t *value, size_t valuelen,
void *userp)
@@ -162,18 +263,18 @@ static int got_header(nghttp2_session *session, const nghttp2_frame *frame,
* This is all callbacks nghttp2 calls
*/
static const nghttp2_session_callbacks callbacks = {
- send_callback, /* nghttp2_send_callback */
- recv_callback, /* nghttp2_recv_callback */
- NULL, /* nghttp2_on_frame_recv_callback */
- NULL, /* nghttp2_on_invalid_frame_recv_callback */
- NULL, /* nghttp2_on_data_chunk_recv_callback */
- NULL, /* nghttp2_before_frame_send_callback */
- NULL, /* nghttp2_on_frame_send_callback */
- NULL, /* nghttp2_on_frame_not_send_callback */
- NULL, /* nghttp2_on_stream_close_callback */
- NULL, /* nghttp2_on_unknown_frame_recv_callback */
- NULL, /* nghttp2_on_begin_headers_callback */
- got_header /* nghttp2_on_header_callback */
+ send_callback, /* nghttp2_send_callback */
+ recv_callback, /* nghttp2_recv_callback */
+ on_frame_recv, /* nghttp2_on_frame_recv_callback */
+ on_invalid_frame_recv, /* nghttp2_on_invalid_frame_recv_callback */
+ on_data_chunk_recv, /* nghttp2_on_data_chunk_recv_callback */
+ before_frame_send, /* nghttp2_before_frame_send_callback */
+ on_frame_send, /* nghttp2_on_frame_send_callback */
+ on_frame_not_send, /* nghttp2_on_frame_not_send_callback */
+ on_stream_close, /* nghttp2_on_stream_close_callback */
+ on_unknown_frame_recv, /* nghttp2_on_unknown_frame_recv_callback */
+ on_begin_headers, /* nghttp2_on_begin_headers_callback */
+ on_header /* nghttp2_on_header_callback */
};
/*