Function on_request_recv

modules/http2d/server.c:535–627

static int on_request_recv(nghttp2_session *session,
                           http2_session_data *session_data,
                           http2_stream_data *stream_data) {
	int rc;
	struct timespec wait_until;
	struct timeval now, wait_time, res;
	struct timespec begin;
	unsigned long long diff_ns;
	char *H;

	if (!stream_data->path) {
		if (error_reply(session, stream_data) != 0) {
			return NGHTTP2_ERR_CALLBACK_FAILURE;
		}
		return 0;
	}

	LM_INFO("%s GET %s (stream_id: %d)\n", session_data->client_addr,
	        stream_data->path, stream_data->stream_id);
	if (stream_data->data.len)
		LM_INFO("body: (%d) %.*s\n", stream_data->data.len, stream_data->data.len, stream_data->data.s);
	else
		LM_INFO("body: (none)\n");

	if (!check_path(stream_data->path)) {
		if (error_reply(session, stream_data) != 0) {
			return NGHTTP2_ERR_CALLBACK_FAILURE;
		}
		return 0;
	}

	pthread_mutex_lock(&ng_h2_response->mutex);

	H = cJSON_PrintUnformatted(stream_data->hdrs);
	h2_raise_event_request(stream_data->method, stream_data->path,
	                         H, &stream_data->data);
	cJSON_PurgeString(H);

	gettimeofday(&now, NULL);
	wait_time.tv_sec = h2_response_timeout / 1000;
	wait_time.tv_usec = h2_response_timeout % 1000 * 1000UL;
	LM_DBG("awaiting HTTP2 reply (%ld s, %ld us)...\n", wait_time.tv_sec, wait_time.tv_usec);

	timeradd(&now, &wait_time, &res);

	wait_until.tv_sec = res.tv_sec;
	wait_until.tv_nsec = res.tv_usec * 1000UL;

	clock_gettime(CLOCK_REALTIME, &begin);
	rc = pthread_cond_timedwait(&ng_h2_response->cond,
			&ng_h2_response->mutex, &wait_until);
	diff_ns = get_clock_diff(&begin);
	LM_DBG("waited %llu ns in total\n", diff_ns);
	if (rc != 0) {
		pthread_mutex_unlock(&ng_h2_response->mutex);

		LM_ERR("timeout (errno: %d '%s') while awaiting "
				"HTTP2 reply from opensips.cfg\n", rc, strerror(rc));