1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/*
# Copyright 2016 Google Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
################################################################################
*/
#include <errno.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <stddef.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>
#include <curl/curl.h>
static const void *cur_data;
static int cur_size = -1;
static int server_fd = -1;
static int client_fd = -1;
static int wrote = 0;
static void fail(const char *why) {
perror(why);
exit(1);
}
static curl_socket_t open_sock(void *ctx, curlsocktype purpose,
struct curl_sockaddr *address) {
if(cur_size == -1) {
fail("not fuzzing");
}
if(server_fd != -1 || client_fd != -1) {
fail("already connected");
}
int fds[2];
if(socketpair(AF_UNIX, SOCK_STREAM, 0, fds)) {
fail("socketpair");
}
server_fd = fds[0];
client_fd = fds[1];
if(write(server_fd, cur_data, cur_size) != cur_size) {
fail("write");
}
if(shutdown(server_fd, SHUT_WR)) {
fail("shutdown");
}
return client_fd;
}
static int set_opt(void *ctx, curl_socket_t curlfd, curlsocktype purpose) {
return CURL_SOCKOPT_ALREADY_CONNECTED;
}
static size_t write_callback(char *ptr, size_t size, size_t n, void *ctx) {
return size * n;
}
static size_t read_callback(char *buf, size_t size, size_t n, void *ctx) {
if(wrote || size * n == 0) {
return 0;
}
wrote = 1;
buf[0] = 'a';
return 1;
}
int LLVMFuzzerTestOneInput(const uint8_t *Data, size_t Size) {
cur_data = Data;
cur_size = Size;
wrote = 0;
CURL *curl = curl_easy_init();
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
curl_easy_setopt(curl, CURLOPT_READFUNCTION, read_callback);
curl_easy_setopt(curl, CURLOPT_OPENSOCKETFUNCTION, open_sock);
curl_easy_setopt(curl, CURLOPT_SOCKOPTFUNCTION, set_opt);
#if defined(FUZZER_FTP)
curl_easy_setopt(curl, CURLOPT_URL, "ftp://user@localhost/file.txt");
#elif defined(FUZZER_IMAP)
curl_easy_setopt(curl, CURLOPT_USERNAME, "user");
curl_easy_setopt(curl, CURLOPT_PASSWORD, "secret");
curl_easy_setopt(curl, CURLOPT_URL, "imap://localhost");
#elif defined(FUZZER_POP3)
curl_easy_setopt(curl, CURLOPT_USERNAME, "user");
curl_easy_setopt(curl, CURLOPT_PASSWORD, "secret");
curl_easy_setopt(curl, CURLOPT_URL, "pop3://localhost");
#elif defined(FUZZER_HTTP_UPLOAD)
curl_easy_setopt(curl, CURLOPT_URL, "http://localhost/");
curl_easy_setopt(curl, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
curl_easy_setopt(curl, CURLOPT_UPLOAD, 1L);
#elif defined(FUZZER_HTTP2)
curl_easy_setopt(curl, CURLOPT_URL, "http://localhost/");
/* use non-TLS HTTP/2 without HTTP/1.1 Upgrade: */
curl_easy_setopt(curl, CURLOPT_HTTP_VERSION,
CURL_HTTP_VERSION_2_PRIOR_KNOWLEDGE);
#else
curl_easy_setopt(curl, CURLOPT_URL, "http://localhost/");
curl_easy_setopt(curl, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
#endif
curl_easy_perform(curl);
curl_easy_cleanup(curl);
close(server_fd);
close(client_fd);
server_fd = -1;
client_fd = -1;
cur_data = NULL;
cur_size = -1;
return 0;
}
|
