mirror of
https://github.com/freebsd/freebsd-src.git
synced 2026-10-30 20:35:03 +01:00
Compare commits
13
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b45fc3da3c | ||
|
|
52c7bd5fc7 | ||
|
|
f5ed8b8141 | ||
|
|
d25707270f | ||
|
|
1441f4fb5c | ||
|
|
be5f6c3836 | ||
|
|
1159173b33 | ||
|
|
0e2c244041 | ||
|
|
62c84489b6 | ||
|
|
d81d108bf6 | ||
|
|
b0a603f233 | ||
|
|
a56ae0463d | ||
|
|
e11e5a6d8a |
No files matched your search
@@ -8,6 +8,55 @@ Items affecting the ports and packages system can be found in
|
||||
/usr/ports/UPDATING. Please read that file before running
|
||||
portupgrade.
|
||||
|
||||
20080416: p12 FreeBSD-SA-08:05.openssh
|
||||
Fix logic error in sshd(8) concerning the handling of failed
|
||||
attempts to bind ports for X11 forwarding.
|
||||
|
||||
20080214: p11 FreeBSD-SA-08:02.sendfile
|
||||
Fix sendfile(2) write-only file permission bypass.
|
||||
|
||||
20080114: p10 FreeBSD-SA-08:01.pty, FreeBSD-SA-08:02.libc
|
||||
Fix issues which allow snooping on ptys. [08:01]
|
||||
Fix an off-by-one error in inet_network(3). [08:02]
|
||||
|
||||
20071129: p9 FreeBSD-SA-07:09.random
|
||||
Correct a random value disclosure in random(4).
|
||||
|
||||
20071003: p8 FreeBSD-SA-07:08.openssl
|
||||
Correct a buffer overflow in OpenSSL SSL_get_shared_ciphers().
|
||||
|
||||
20070801: p7 FreeBSD-SA-07:06.tcpdump, FreeBSD-SA-07:07.bind
|
||||
Correct a buffer overflow in tcpdump(1). [07:06]
|
||||
|
||||
Correct predictable query ids in named(8). [07:07]
|
||||
|
||||
20070712: p6 FreeBSD-SA-07:05.libarchive
|
||||
Correct multiple security issues in how libarchive handles
|
||||
corrupt tar archives, including a potentially exploitable
|
||||
buffer overflow.
|
||||
|
||||
20070523: p5 FreeBSD-SA-07:04.file
|
||||
Fix buffer overflow in libmagic(3).
|
||||
|
||||
20070426: p4 FreeBSD-SA-07:03.ipv6
|
||||
Disable processing of IPv6 type 0 Routing Headers. This behaviour
|
||||
can be changed via the (newly added) net.inet6.ip6.rthdr0_allowed
|
||||
sysctl.
|
||||
|
||||
20070315: p3 FreeBSD-EN-07:05.freebsd-update
|
||||
Fix problems in FreeBSD Update concerning the updating of SMP
|
||||
kernels.
|
||||
|
||||
20070228: p2 FreeBSD-EN-07:02.net FreeBSD-EN-07:03.rc.d_jail
|
||||
Fix behavior of IPv6 over point-to-point gif(4) interfaces.
|
||||
[EN-07:02]
|
||||
|
||||
Fix rc.d jail script interface IP alias removal. [EN-07:03]
|
||||
|
||||
20070209: p1 FreeBSD-SA-07:02.bind
|
||||
Correct two remote denials of service in BIND involving DNSSEC and
|
||||
recursive DNS queries respectively.
|
||||
|
||||
20070114:
|
||||
FreeBSD 6.2-RELEASE.
|
||||
|
||||
|
||||
@@ -1348,6 +1348,14 @@ client_request(isc_task_t *task, isc_event_t *event) {
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* Hash the incoming request here as it is after
|
||||
* dns_dispatch_importrecv().
|
||||
*/
|
||||
dns_dispatch_hash(&client->now, sizeof(client->now));
|
||||
dns_dispatch_hash(isc_buffer_base(buffer),
|
||||
isc_buffer_usedlength(buffer));
|
||||
|
||||
/*
|
||||
* It's a request. Parse it.
|
||||
*/
|
||||
|
||||
@@ -20,14 +20,16 @@
|
||||
#include <config.h>
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <sys/types.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#include <isc/entropy.h>
|
||||
#include <isc/lfsr.h>
|
||||
#include <isc/mem.h>
|
||||
#include <isc/mutex.h>
|
||||
#include <isc/print.h>
|
||||
#include <isc/string.h>
|
||||
#include <isc/task.h>
|
||||
#include <isc/time.h>
|
||||
#include <isc/util.h>
|
||||
|
||||
#include <dns/acl.h>
|
||||
@@ -41,13 +43,22 @@
|
||||
|
||||
typedef ISC_LIST(dns_dispentry_t) dns_displist_t;
|
||||
|
||||
typedef struct dns_nsid {
|
||||
isc_uint16_t nsid_state;
|
||||
isc_uint16_t *nsid_vtable;
|
||||
isc_uint16_t *nsid_pool;
|
||||
isc_uint16_t nsid_a1, nsid_a2, nsid_a3;
|
||||
isc_uint16_t nsid_c1, nsid_c2, nsid_c3;
|
||||
isc_uint16_t nsid_state2;
|
||||
isc_boolean_t nsid_usepool;
|
||||
} dns_nsid_t;
|
||||
|
||||
typedef struct dns_qid {
|
||||
unsigned int magic;
|
||||
unsigned int qid_nbuckets; /* hash table size */
|
||||
unsigned int qid_increment; /* id increment on collision */
|
||||
isc_mutex_t lock;
|
||||
isc_lfsr_t qid_lfsr1; /* state generator info */
|
||||
isc_lfsr_t qid_lfsr2; /* state generator info */
|
||||
dns_nsid_t nsid;
|
||||
dns_displist_t *qid_table; /* the table itself */
|
||||
} dns_qid_t;
|
||||
|
||||
@@ -156,7 +167,7 @@ static void destroy_disp(isc_task_t *task, isc_event_t *event);
|
||||
static void udp_recv(isc_task_t *, isc_event_t *);
|
||||
static void tcp_recv(isc_task_t *, isc_event_t *);
|
||||
static void startrecv(dns_dispatch_t *);
|
||||
static dns_messageid_t dns_randomid(dns_qid_t *);
|
||||
static dns_messageid_t dns_randomid(dns_nsid_t *);
|
||||
static isc_uint32_t dns_hash(dns_qid_t *, isc_sockaddr_t *, dns_messageid_t);
|
||||
static void free_buffer(dns_dispatch_t *disp, void *buf, unsigned int len);
|
||||
static void *allocate_udp_buffer(dns_dispatch_t *disp);
|
||||
@@ -177,8 +188,12 @@ static isc_result_t dispatch_createudp(dns_dispatchmgr_t *mgr,
|
||||
static isc_boolean_t destroy_mgr_ok(dns_dispatchmgr_t *mgr);
|
||||
static void destroy_mgr(dns_dispatchmgr_t **mgrp);
|
||||
static isc_result_t qid_allocate(dns_dispatchmgr_t *mgr, unsigned int buckets,
|
||||
unsigned int increment, dns_qid_t **qidp);
|
||||
unsigned int increment, isc_boolean_t usepool,
|
||||
dns_qid_t **qidp);
|
||||
static void qid_destroy(isc_mem_t *mctx, dns_qid_t **qidp);
|
||||
static isc_uint16_t nsid_next(dns_nsid_t *nsid);
|
||||
static isc_result_t nsid_init(isc_mem_t *mctx, dns_nsid_t *nsid, isc_boolean_t usepool);
|
||||
static void nsid_destroy(isc_mem_t *mctx, dns_nsid_t *nsid);
|
||||
|
||||
#define LVL(x) ISC_LOG_DEBUG(x)
|
||||
|
||||
@@ -258,38 +273,16 @@ request_log(dns_dispatch_t *disp, dns_dispentry_t *resp,
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
reseed_lfsr(isc_lfsr_t *lfsr, void *arg)
|
||||
{
|
||||
dns_dispatchmgr_t *mgr = arg;
|
||||
isc_result_t result;
|
||||
isc_uint32_t val;
|
||||
|
||||
REQUIRE(VALID_DISPATCHMGR(mgr));
|
||||
|
||||
if (mgr->entropy != NULL) {
|
||||
result = isc_entropy_getdata(mgr->entropy, &val, sizeof(val),
|
||||
NULL, 0);
|
||||
INSIST(result == ISC_R_SUCCESS);
|
||||
lfsr->count = (val & 0x1f) + 32;
|
||||
lfsr->state = val;
|
||||
return;
|
||||
}
|
||||
|
||||
lfsr->count = (random() & 0x1f) + 32; /* From 32 to 63 states */
|
||||
lfsr->state = random();
|
||||
}
|
||||
|
||||
/*
|
||||
* Return an unpredictable message ID.
|
||||
*/
|
||||
static dns_messageid_t
|
||||
dns_randomid(dns_qid_t *qid) {
|
||||
dns_randomid(dns_nsid_t *nsid) {
|
||||
isc_uint32_t id;
|
||||
|
||||
id = isc_lfsr_generate32(&qid->qid_lfsr1, &qid->qid_lfsr2);
|
||||
id = nsid_next(nsid);
|
||||
|
||||
return (dns_messageid_t)(id & 0xFFFF);
|
||||
return ((dns_messageid_t)id);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -629,6 +622,9 @@ udp_recv(isc_task_t *task, isc_event_t *ev_in) {
|
||||
goto restart;
|
||||
}
|
||||
|
||||
dns_dispatch_hash(&ev->timestamp, sizeof(&ev->timestamp));
|
||||
dns_dispatch_hash(ev->region.base, ev->region.length);
|
||||
|
||||
/* response */
|
||||
bucket = dns_hash(qid, &ev->address, id);
|
||||
LOCK(&qid->lock);
|
||||
@@ -863,6 +859,8 @@ tcp_recv(isc_task_t *task, isc_event_t *ev_in) {
|
||||
goto restart;
|
||||
}
|
||||
|
||||
dns_dispatch_hash(tcpmsg->buffer.base, tcpmsg->buffer.length);
|
||||
|
||||
/*
|
||||
* Response.
|
||||
*/
|
||||
@@ -1246,7 +1244,7 @@ dns_dispatchmgr_setudp(dns_dispatchmgr_t *mgr,
|
||||
isc_mempool_setmaxalloc(mgr->bpool, maxbuffers);
|
||||
isc_mempool_associatelock(mgr->bpool, &mgr->pool_lock);
|
||||
|
||||
result = qid_allocate(mgr, buckets, increment, &mgr->qid);
|
||||
result = qid_allocate(mgr, buckets, increment, ISC_TRUE, &mgr->qid);
|
||||
if (result != ISC_R_SUCCESS)
|
||||
goto cleanup;
|
||||
|
||||
@@ -1392,7 +1390,7 @@ dispatch_find(dns_dispatchmgr_t *mgr, isc_sockaddr_t *local,
|
||||
|
||||
static isc_result_t
|
||||
qid_allocate(dns_dispatchmgr_t *mgr, unsigned int buckets,
|
||||
unsigned int increment, dns_qid_t **qidp)
|
||||
unsigned int increment, isc_boolean_t usepool, dns_qid_t **qidp)
|
||||
{
|
||||
dns_qid_t *qid;
|
||||
unsigned int i;
|
||||
@@ -1413,8 +1411,16 @@ qid_allocate(dns_dispatchmgr_t *mgr, unsigned int buckets,
|
||||
return (ISC_R_NOMEMORY);
|
||||
}
|
||||
|
||||
if (nsid_init(mgr->mctx, &qid->nsid, usepool) != ISC_R_SUCCESS) {
|
||||
isc_mem_put(mgr->mctx, qid->qid_table,
|
||||
buckets * sizeof(dns_displist_t));
|
||||
isc_mem_put(mgr->mctx, qid, sizeof(*qid));
|
||||
return (ISC_R_NOMEMORY);
|
||||
}
|
||||
|
||||
if (isc_mutex_init(&qid->lock) != ISC_R_SUCCESS) {
|
||||
UNEXPECTED_ERROR(__FILE__, __LINE__, "isc_mutex_init failed");
|
||||
nsid_destroy(mgr->mctx, &qid->nsid);
|
||||
isc_mem_put(mgr->mctx, qid->qid_table,
|
||||
buckets * sizeof(dns_displist_t));
|
||||
isc_mem_put(mgr->mctx, qid, sizeof(*qid));
|
||||
@@ -1427,21 +1433,6 @@ qid_allocate(dns_dispatchmgr_t *mgr, unsigned int buckets,
|
||||
qid->qid_nbuckets = buckets;
|
||||
qid->qid_increment = increment;
|
||||
qid->magic = QID_MAGIC;
|
||||
|
||||
/*
|
||||
* Initialize to a 32-bit LFSR. Both of these are from Applied
|
||||
* Cryptography.
|
||||
*
|
||||
* lfsr1:
|
||||
* x^32 + x^7 + x^5 + x^3 + x^2 + x + 1
|
||||
*
|
||||
* lfsr2:
|
||||
* x^32 + x^7 + x^6 + x^2 + 1
|
||||
*/
|
||||
isc_lfsr_init(&qid->qid_lfsr1, 0, 32, 0x80000057U,
|
||||
0, reseed_lfsr, mgr);
|
||||
isc_lfsr_init(&qid->qid_lfsr2, 0, 32, 0x80000062U,
|
||||
0, reseed_lfsr, mgr);
|
||||
*qidp = qid;
|
||||
return (ISC_R_SUCCESS);
|
||||
}
|
||||
@@ -1457,6 +1448,7 @@ qid_destroy(isc_mem_t *mctx, dns_qid_t **qidp) {
|
||||
|
||||
*qidp = NULL;
|
||||
qid->magic = 0;
|
||||
nsid_destroy(mctx, &qid->nsid);
|
||||
isc_mem_put(mctx, qid->qid_table,
|
||||
qid->qid_nbuckets * sizeof(dns_displist_t));
|
||||
DESTROYLOCK(&qid->lock);
|
||||
@@ -1600,7 +1592,7 @@ dns_dispatch_createtcp(dns_dispatchmgr_t *mgr, isc_socket_t *sock,
|
||||
return (result);
|
||||
}
|
||||
|
||||
result = qid_allocate(mgr, buckets, increment, &disp->qid);
|
||||
result = qid_allocate(mgr, buckets, increment, ISC_FALSE, &disp->qid);
|
||||
if (result != ISC_R_SUCCESS)
|
||||
goto deallocate_dispatch;
|
||||
|
||||
@@ -1921,7 +1913,7 @@ dns_dispatch_addresponse(dns_dispatch_t *disp, isc_sockaddr_t *dest,
|
||||
*/
|
||||
qid = DNS_QID(disp);
|
||||
LOCK(&qid->lock);
|
||||
id = dns_randomid(qid);
|
||||
id = dns_randomid(&qid->nsid);
|
||||
bucket = dns_hash(qid, dest, id);
|
||||
ok = ISC_FALSE;
|
||||
for (i = 0; i < 64; i++) {
|
||||
@@ -2264,3 +2256,409 @@ dns_dispatchmgr_dump(dns_dispatchmgr_t *mgr) {
|
||||
}
|
||||
}
|
||||
#endif
|
||||
|
||||
/*
|
||||
* Allow the user to pick one of two ID randomization algorithms.
|
||||
*
|
||||
* The first algorithm is an adaptation of the sequence shuffling
|
||||
* algorithm discovered by Carter Bays and S. D. Durham [ACM Trans. Math.
|
||||
* Software 2 (1976), 59-64], as documented as Algorithm B in Chapter
|
||||
* 3.2.2 in Volume 2 of Knuth's "The Art of Computer Programming". We use
|
||||
* a randomly selected linear congruential random number generator with a
|
||||
* modulus of 2^16, whose increment is a randomly picked odd number, and
|
||||
* whose multiplier is picked from a set which meets the following
|
||||
* criteria:
|
||||
* Is of the form 8*n+5, which ensures "high potency" according to
|
||||
* principle iii in the summary chapter 3.6. This form also has a
|
||||
* gcd(a-1,m) of 4 which is good according to principle iv.
|
||||
*
|
||||
* Is between 0.01 and 0.99 times the modulus as specified by
|
||||
* principle iv.
|
||||
*
|
||||
* Passes the spectral test "with flying colors" (ut >= 1) in
|
||||
* dimensions 2 through 6 as calculated by Algorithm S in Chapter
|
||||
* 3.3.4 and the ratings calculated by formula 35 in section E.
|
||||
*
|
||||
* Of the multipliers that pass this test, pick the set that is
|
||||
* best according to the theoretical bounds of the serial
|
||||
* correlation test. This was calculated using a simplified
|
||||
* version of Knuth's Theorem K in Chapter 3.3.3.
|
||||
*
|
||||
* These criteria may not be important for this use, but we might as well
|
||||
* pick from the best generators since there are so many possible ones and
|
||||
* we don't have that many random bits to do the picking.
|
||||
*
|
||||
* We use a modulus of 2^16 instead of something bigger so that we will
|
||||
* tend to cycle through all the possible IDs before repeating any,
|
||||
* however the shuffling will perturb this somewhat. Theoretically there
|
||||
* is no minimimum interval between two uses of the same ID, but in
|
||||
* practice it seems to be >64000.
|
||||
*
|
||||
* Our adaptatation of Algorithm B mixes the hash state which has
|
||||
* captured various random events into the shuffler to perturb the
|
||||
* sequence.
|
||||
*
|
||||
* One disadvantage of this algorithm is that if the generator parameters
|
||||
* were to be guessed, it would be possible to mount a limited brute force
|
||||
* attack on the ID space since the IDs are only shuffled within a limited
|
||||
* range.
|
||||
*
|
||||
* The second algorithm uses the same random number generator to populate
|
||||
* a pool of 65536 IDs. The hash state is used to pick an ID from a window
|
||||
* of 4096 IDs in this pool, then the chosen ID is swapped with the ID
|
||||
* at the beginning of the window and the window position is advanced.
|
||||
* This means that the interval between uses of the ID will be no less
|
||||
* than 65536-4096. The ID sequence in the pool will become more random
|
||||
* over time.
|
||||
*
|
||||
* For both algorithms, two more linear congruential random number generators
|
||||
* are selected. The ID from the first part of algorithm is used to seed
|
||||
* the first of these generators, and its output is used to seed the second.
|
||||
* The strategy is use these generators as 1 to 1 hashes to obfuscate the
|
||||
* properties of the generator used in the first part of either algorithm.
|
||||
*
|
||||
* The first algorithm may be suitable for use in a client resolver since
|
||||
* its memory requirements are fairly low and it's pretty random out of
|
||||
* the box. It is somewhat succeptible to a limited brute force attack,
|
||||
* so the second algorithm is probably preferable for a longer running
|
||||
* program that issues a large number of queries and has time to randomize
|
||||
* the pool.
|
||||
*/
|
||||
|
||||
#define NSID_SHUFFLE_TABLE_SIZE 100 /* Suggested by Knuth */
|
||||
/*
|
||||
* Pick one of the next 4096 IDs in the pool.
|
||||
* There is a tradeoff here between randomness and how often and ID is reused.
|
||||
*/
|
||||
#define NSID_LOOKAHEAD 4096 /* Must be a power of 2 */
|
||||
#define NSID_SHUFFLE_ONLY 1 /* algorithm 1 */
|
||||
#define NSID_USE_POOL 2 /* algorithm 2 */
|
||||
#define NSID_HASHSHIFT 3
|
||||
#define NSID_HASHROTATE(v) \
|
||||
(((v) << NSID_HASHSHIFT) | ((v) >> ((sizeof(v) * 8) - NSID_HASHSHIFT)))
|
||||
|
||||
static isc_uint32_t nsid_hash_state;
|
||||
|
||||
/*
|
||||
* Keep a running hash of various bits of data that we'll use to
|
||||
* stir the ID pool or perturb the ID generator
|
||||
*/
|
||||
static void
|
||||
nsid_hash(void *data, size_t len) {
|
||||
unsigned char *p = data;
|
||||
/*
|
||||
* Hash function similar to the one we use for hashing names.
|
||||
* We don't fold case or toss the upper bit here, though.
|
||||
* This hash doesn't do much interesting when fed binary zeros,
|
||||
* so there may be a better hash function.
|
||||
* This function doesn't need to be very strong since we're
|
||||
* only using it to stir the pool, but it should be reasonably
|
||||
* fast.
|
||||
*/
|
||||
/*
|
||||
* We don't care about locking access to nsid_hash_state.
|
||||
* In fact races make the result even more non deteministic.
|
||||
*/
|
||||
while (len-- > 0U) {
|
||||
nsid_hash_state = NSID_HASHROTATE(nsid_hash_state);
|
||||
nsid_hash_state += *p++;
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* Table of good linear congruential multipliers for modulus 2^16
|
||||
* in order of increasing serial correlation bounds (so trim from
|
||||
* the end).
|
||||
*/
|
||||
static const isc_uint16_t nsid_multiplier_table[] = {
|
||||
17565, 25013, 11733, 19877, 23989, 23997, 24997, 25421,
|
||||
26781, 27413, 35901, 35917, 35973, 36229, 38317, 38437,
|
||||
39941, 40493, 41853, 46317, 50581, 51429, 53453, 53805,
|
||||
11317, 11789, 12045, 12413, 14277, 14821, 14917, 18989,
|
||||
19821, 23005, 23533, 23573, 23693, 27549, 27709, 28461,
|
||||
29365, 35605, 37693, 37757, 38309, 41285, 45261, 47061,
|
||||
47269, 48133, 48597, 50277, 50717, 50757, 50805, 51341,
|
||||
51413, 51581, 51597, 53445, 11493, 14229, 20365, 20653,
|
||||
23485, 25541, 27429, 29421, 30173, 35445, 35653, 36789,
|
||||
36797, 37109, 37157, 37669, 38661, 39773, 40397, 41837,
|
||||
41877, 45293, 47277, 47845, 49853, 51085, 51349, 54085,
|
||||
56933, 8877, 8973, 9885, 11365, 11813, 13581, 13589,
|
||||
13613, 14109, 14317, 15765, 15789, 16925, 17069, 17205,
|
||||
17621, 17941, 19077, 19381, 20245, 22845, 23733, 24869,
|
||||
25453, 27213, 28381, 28965, 29245, 29997, 30733, 30901,
|
||||
34877, 35485, 35613, 36133, 36661, 36917, 38597, 40285,
|
||||
40693, 41413, 41541, 41637, 42053, 42349, 45245, 45469,
|
||||
46493, 48205, 48613, 50861, 51861, 52877, 53933, 54397,
|
||||
55669, 56453, 56965, 58021, 7757, 7781, 8333, 9661,
|
||||
12229, 14373, 14453, 17549, 18141, 19085, 20773, 23701,
|
||||
24205, 24333, 25261, 25317, 27181, 30117, 30477, 34757,
|
||||
34885, 35565, 35885, 36541, 37957, 39733, 39813, 41157,
|
||||
41893, 42317, 46621, 48117, 48181, 49525, 55261, 55389,
|
||||
56845, 7045, 7749, 7965, 8469, 9133, 9549, 9789,
|
||||
10173, 11181, 11285, 12253, 13453, 13533, 13757, 14477,
|
||||
15053, 16901, 17213, 17269, 17525, 17629, 18605, 19013,
|
||||
19829, 19933, 20069, 20093, 23261, 23333, 24949, 25309,
|
||||
27613, 28453, 28709, 29301, 29541, 34165, 34413, 37301,
|
||||
37773, 38045, 38405, 41077, 41781, 41925, 42717, 44437,
|
||||
44525, 44613, 45933, 45941, 47077, 50077, 50893, 52117,
|
||||
5293, 55069, 55989, 58125, 59205, 6869, 14685, 15453,
|
||||
16821, 17045, 17613, 18437, 21029, 22773, 22909, 25445,
|
||||
25757, 26541, 30709, 30909, 31093, 31149, 37069, 37725,
|
||||
37925, 38949, 39637, 39701, 40765, 40861, 42965, 44813,
|
||||
45077, 45733, 47045, 50093, 52861, 52957, 54181, 56325,
|
||||
56365, 56381, 56877, 57013, 5741, 58101, 58669, 8613,
|
||||
10045, 10261, 10653, 10733, 11461, 12261, 14069, 15877,
|
||||
17757, 21165, 23885, 24701, 26429, 26645, 27925, 28765,
|
||||
29197, 30189, 31293, 39781, 39909, 40365, 41229, 41453,
|
||||
41653, 42165, 42365, 47421, 48029, 48085, 52773, 5573,
|
||||
57037, 57637, 58341, 58357, 58901, 6357, 7789, 9093,
|
||||
10125, 10709, 10765, 11957, 12469, 13437, 13509, 14773,
|
||||
15437, 15773, 17813, 18829, 19565, 20237, 23461, 23685,
|
||||
23725, 23941, 24877, 25461, 26405, 29509, 30285, 35181,
|
||||
37229, 37893, 38565, 40293, 44189, 44581, 45701, 47381,
|
||||
47589, 48557, 4941, 51069, 5165, 52797, 53149, 5341,
|
||||
56301, 56765, 58581, 59493, 59677, 6085, 6349, 8293,
|
||||
8501, 8517, 11597, 11709, 12589, 12693, 13517, 14909,
|
||||
17397, 18085, 21101, 21269, 22717, 25237, 25661, 29189,
|
||||
30101, 31397, 33933, 34213, 34661, 35533, 36493, 37309,
|
||||
40037, 4189, 42909, 44309, 44357, 44389, 4541, 45461,
|
||||
46445, 48237, 54149, 55301, 55853, 56621, 56717, 56901,
|
||||
5813, 58437, 12493, 15365, 15989, 17829, 18229, 19341,
|
||||
21013, 21357, 22925, 24885, 26053, 27581, 28221, 28485,
|
||||
30605, 30613, 30789, 35437, 36285, 37189, 3941, 41797,
|
||||
4269, 42901, 43293, 44645, 45221, 46893, 4893, 50301,
|
||||
50325, 5189, 52109, 53517, 54053, 54485, 5525, 55949,
|
||||
56973, 59069, 59421, 60733, 61253, 6421, 6701, 6709,
|
||||
7101, 8669, 15797, 19221, 19837, 20133, 20957, 21293,
|
||||
21461, 22461, 29085, 29861, 30869, 34973, 36469, 37565,
|
||||
38125, 38829, 39469, 40061, 40117, 44093, 47429, 48341,
|
||||
50597, 51757, 5541, 57629, 58405, 59621, 59693, 59701,
|
||||
61837, 7061, 10421, 11949, 15405, 20861, 25397, 25509,
|
||||
25893, 26037, 28629, 28869, 29605, 30213, 34205, 35637,
|
||||
36365, 37285, 3773, 39117, 4021, 41061, 42653, 44509,
|
||||
4461, 44829, 4725, 5125, 52269, 56469, 59085, 5917,
|
||||
60973, 8349, 17725, 18637, 19773, 20293, 21453, 22533,
|
||||
24285, 26333, 26997, 31501, 34541, 34805, 37509, 38477,
|
||||
41333, 44125, 46285, 46997, 47637, 48173, 4925, 50253,
|
||||
50381, 50917, 51205, 51325, 52165, 52229, 5253, 5269,
|
||||
53509, 56253, 56341, 5821, 58373, 60301, 61653, 61973,
|
||||
62373, 8397, 11981, 14341, 14509, 15077, 22261, 22429,
|
||||
24261, 28165, 28685, 30661, 34021, 34445, 39149, 3917,
|
||||
43013, 43317, 44053, 44101, 4533, 49541, 49981, 5277,
|
||||
54477, 56357, 57261, 57765, 58573, 59061, 60197, 61197,
|
||||
62189, 7725, 8477, 9565, 10229, 11437, 14613, 14709,
|
||||
16813, 20029, 20677, 31445, 3165, 31957, 3229, 33541,
|
||||
36645, 3805, 38973, 3965, 4029, 44293, 44557, 46245,
|
||||
48917, 4909, 51749, 53709, 55733, 56445, 5925, 6093,
|
||||
61053, 62637, 8661, 9109, 10821, 11389, 13813, 14325,
|
||||
15501, 16149, 18845, 22669, 26437, 29869, 31837, 33709,
|
||||
33973, 34173, 3677, 3877, 3981, 39885, 42117, 4421,
|
||||
44221, 44245, 44693, 46157, 47309, 5005, 51461, 52037,
|
||||
55333, 55693, 56277, 58949, 6205, 62141, 62469, 6293,
|
||||
10101, 12509, 14029, 17997, 20469, 21149, 25221, 27109,
|
||||
2773, 2877, 29405, 31493, 31645, 4077, 42005, 42077,
|
||||
42469, 42501, 44013, 48653, 49349, 4997, 50101, 55405,
|
||||
56957, 58037, 59429, 60749, 61797, 62381, 62837, 6605,
|
||||
10541, 23981, 24533, 2701, 27333, 27341, 31197, 33805,
|
||||
3621, 37381, 3749, 3829, 38533, 42613, 44381, 45901,
|
||||
48517, 51269, 57725, 59461, 60045, 62029, 13805, 14013,
|
||||
15461, 16069, 16157, 18573, 2309, 23501, 28645, 3077,
|
||||
31541, 36357, 36877, 3789, 39429, 39805, 47685, 47949,
|
||||
49413, 5485, 56757, 57549, 57805, 58317, 59549, 62213,
|
||||
62613, 62853, 62933, 8909, 12941, 16677, 20333, 21541,
|
||||
24429, 26077, 26421, 2885, 31269, 33381, 3661, 40925,
|
||||
42925, 45173, 4525, 4709, 53133, 55941, 57413, 57797,
|
||||
62125, 62237, 62733, 6773, 12317, 13197, 16533, 16933,
|
||||
18245, 2213, 2477, 29757, 33293, 35517, 40133, 40749,
|
||||
4661, 49941, 62757, 7853, 8149, 8573, 11029, 13421,
|
||||
21549, 22709, 22725, 24629, 2469, 26125, 2669, 34253,
|
||||
36709, 41013, 45597, 46637, 52285, 52333, 54685, 59013,
|
||||
60997, 61189, 61981, 62605, 62821, 7077, 7525, 8781,
|
||||
10861, 15277, 2205, 22077, 28517, 28949, 32109, 33493,
|
||||
4661, 49941, 62757, 7853, 8149, 8573, 11029, 13421,
|
||||
21549, 22709, 22725, 24629, 2469, 26125, 2669, 34253,
|
||||
36709, 41013, 45597, 46637, 52285, 52333, 54685, 59013,
|
||||
60997, 61189, 61981, 62605, 62821, 7077, 7525, 8781,
|
||||
10861, 15277, 2205, 22077, 28517, 28949, 32109, 33493,
|
||||
3685, 39197, 39869, 42621, 44997, 48565, 5221, 57381,
|
||||
61749, 62317, 63245, 63381, 23149, 2549, 28661, 31653,
|
||||
33885, 36341, 37053, 39517, 42805, 45853, 48997, 59349,
|
||||
60053, 62509, 63069, 6525, 1893, 20181, 2365, 24893,
|
||||
27397, 31357, 32277, 33357, 34437, 36677, 37661, 43469,
|
||||
43917, 50997, 53869, 5653, 13221, 16741, 17893, 2157,
|
||||
28653, 31789, 35301, 35821, 61613, 62245, 12405, 14517,
|
||||
17453, 18421, 3149, 3205, 40341, 4109, 43941, 46869,
|
||||
48837, 50621, 57405, 60509, 62877, 8157, 12933, 12957,
|
||||
16501, 19533, 3461, 36829, 52357, 58189, 58293, 63053,
|
||||
17109, 1933, 32157, 37701, 59005, 61621, 13029, 15085,
|
||||
16493, 32317, 35093, 5061, 51557, 62221, 20765, 24613,
|
||||
2629, 30861, 33197, 33749, 35365, 37933, 40317, 48045,
|
||||
56229, 61157, 63797, 7917, 17965, 1917, 1973, 20301,
|
||||
2253, 33157, 58629, 59861, 61085, 63909, 8141, 9221,
|
||||
14757, 1581, 21637, 26557, 33869, 34285, 35733, 40933,
|
||||
42517, 43501, 53653, 61885, 63805, 7141, 21653, 54973,
|
||||
31189, 60061, 60341, 63357, 16045, 2053, 26069, 33997,
|
||||
43901, 54565, 63837, 8949, 17909, 18693, 32349, 33125,
|
||||
37293, 48821, 49053, 51309, 64037, 7117, 1445, 20405,
|
||||
23085, 26269, 26293, 27349, 32381, 33141, 34525, 36461,
|
||||
37581, 43525, 4357, 43877, 5069, 55197, 63965, 9845,
|
||||
12093, 2197, 2229, 32165, 33469, 40981, 42397, 8749,
|
||||
10853, 1453, 18069, 21693, 30573, 36261, 37421, 42533
|
||||
};
|
||||
|
||||
#define NSID_MULT_TABLE_SIZE \
|
||||
((sizeof nsid_multiplier_table)/(sizeof nsid_multiplier_table[0]))
|
||||
#define NSID_RANGE_MASK (NSID_LOOKAHEAD - 1)
|
||||
#define NSID_POOL_MASK 0xFFFF /* used to wrap the pool index */
|
||||
#define NSID_SHUFFLE_ONLY 1
|
||||
#define NSID_USE_POOL 2
|
||||
|
||||
static isc_uint16_t
|
||||
nsid_next(dns_nsid_t *nsid) {
|
||||
isc_uint16_t id, compressed_hash;
|
||||
isc_uint16_t j;
|
||||
|
||||
compressed_hash = ((nsid_hash_state >> 16) ^
|
||||
(nsid_hash_state)) & 0xFFFF;
|
||||
|
||||
if (nsid->nsid_usepool) {
|
||||
isc_uint16_t pick;
|
||||
|
||||
pick = compressed_hash & NSID_RANGE_MASK;
|
||||
pick = (nsid->nsid_state + pick) & NSID_POOL_MASK;
|
||||
id = nsid->nsid_pool[pick];
|
||||
if (pick != 0) {
|
||||
/* Swap two IDs to stir the pool */
|
||||
nsid->nsid_pool[pick] =
|
||||
nsid->nsid_pool[nsid->nsid_state];
|
||||
nsid->nsid_pool[nsid->nsid_state] = id;
|
||||
}
|
||||
|
||||
/* increment the base pointer into the pool */
|
||||
if (nsid->nsid_state == 65535)
|
||||
nsid->nsid_state = 0;
|
||||
else
|
||||
nsid->nsid_state++;
|
||||
} else {
|
||||
/*
|
||||
* This is the original Algorithm B
|
||||
* j = ((u_long) NSID_SHUFFLE_TABLE_SIZE * nsid_state2) >> 16;
|
||||
*
|
||||
* We'll perturb it with some random stuff ...
|
||||
*/
|
||||
j = ((isc_uint32_t) NSID_SHUFFLE_TABLE_SIZE *
|
||||
(nsid->nsid_state2 ^ compressed_hash)) >> 16;
|
||||
nsid->nsid_state2 = id = nsid->nsid_vtable[j];
|
||||
nsid->nsid_state = (((isc_uint32_t) nsid->nsid_a1 * nsid->nsid_state) +
|
||||
nsid->nsid_c1) & 0xFFFF;
|
||||
nsid->nsid_vtable[j] = nsid->nsid_state;
|
||||
}
|
||||
|
||||
/* Now lets obfuscate ... */
|
||||
id = (((isc_uint32_t) nsid->nsid_a2 * id) + nsid->nsid_c2) & 0xFFFF;
|
||||
id = (((isc_uint32_t) nsid->nsid_a3 * id) + nsid->nsid_c3) & 0xFFFF;
|
||||
|
||||
return (id);
|
||||
}
|
||||
|
||||
static isc_result_t
|
||||
nsid_init(isc_mem_t *mctx, dns_nsid_t *nsid, isc_boolean_t usepool) {
|
||||
isc_time_t now;
|
||||
pid_t mypid;
|
||||
isc_uint16_t a1ndx, a2ndx, a3ndx, c1ndx, c2ndx, c3ndx;
|
||||
int i;
|
||||
|
||||
isc_time_now(&now);
|
||||
mypid = getpid();
|
||||
|
||||
/* Initialize the state */
|
||||
memset(nsid, 0, sizeof(*nsid));
|
||||
nsid_hash(&now, sizeof now);
|
||||
nsid_hash(&mypid, sizeof mypid);
|
||||
|
||||
/*
|
||||
* Select our random number generators and initial seed.
|
||||
* We could really use more random bits at this point,
|
||||
* but we'll try to make a silk purse out of a sows ear ...
|
||||
*/
|
||||
/* generator 1 */
|
||||
a1ndx = ((isc_uint32_t) NSID_MULT_TABLE_SIZE *
|
||||
(nsid_hash_state & 0xFFFF)) >> 16;
|
||||
nsid->nsid_a1 = nsid_multiplier_table[a1ndx];
|
||||
c1ndx = (nsid_hash_state >> 9) & 0x7FFF;
|
||||
nsid->nsid_c1 = 2 * c1ndx + 1;
|
||||
|
||||
/* generator 2, distinct from 1 */
|
||||
a2ndx = ((isc_uint32_t) (NSID_MULT_TABLE_SIZE - 1) *
|
||||
((nsid_hash_state >> 10) & 0xFFFF)) >> 16;
|
||||
if (a2ndx >= a1ndx)
|
||||
a2ndx++;
|
||||
nsid->nsid_a2 = nsid_multiplier_table[a2ndx];
|
||||
c2ndx = nsid_hash_state % 32767;
|
||||
if (c2ndx >= c1ndx)
|
||||
c2ndx++;
|
||||
nsid->nsid_c2 = 2*c2ndx + 1;
|
||||
|
||||
/* generator 3, distinct from 1 and 2 */
|
||||
a3ndx = ((isc_uint32_t) (NSID_MULT_TABLE_SIZE - 2) *
|
||||
((nsid_hash_state >> 20) & 0xFFFF)) >> 16;
|
||||
if (a3ndx >= a1ndx || a3ndx >= a2ndx)
|
||||
a3ndx++;
|
||||
if (a3ndx >= a1ndx && a3ndx >= a2ndx)
|
||||
a3ndx++;
|
||||
nsid->nsid_a3 = nsid_multiplier_table[a3ndx];
|
||||
c3ndx = nsid_hash_state % 32766;
|
||||
if (c3ndx >= c1ndx || c3ndx >= c2ndx)
|
||||
c3ndx++;
|
||||
if (c3ndx >= c1ndx && c3ndx >= c2ndx)
|
||||
c3ndx++;
|
||||
nsid->nsid_c3 = 2*c3ndx + 1;
|
||||
|
||||
nsid->nsid_state =
|
||||
((nsid_hash_state >> 16) ^ (nsid_hash_state)) & 0xFFFF;
|
||||
|
||||
nsid->nsid_usepool = usepool;
|
||||
if (nsid->nsid_usepool) {
|
||||
nsid->nsid_pool = isc_mem_get(mctx, 0x10000 * sizeof(isc_uint16_t));
|
||||
if (nsid->nsid_pool == NULL)
|
||||
return (ISC_R_NOMEMORY);
|
||||
for (i = 0; ; i++) {
|
||||
nsid->nsid_pool[i] = nsid->nsid_state;
|
||||
nsid->nsid_state =
|
||||
(((u_long) nsid->nsid_a1 * nsid->nsid_state) +
|
||||
nsid->nsid_c1) & 0xFFFF;
|
||||
if (i == 0xFFFF)
|
||||
break;
|
||||
}
|
||||
} else {
|
||||
nsid->nsid_vtable = isc_mem_get(mctx, NSID_SHUFFLE_TABLE_SIZE *
|
||||
(sizeof(isc_uint16_t)) );
|
||||
if (nsid->nsid_vtable == NULL)
|
||||
return (ISC_R_NOMEMORY);
|
||||
|
||||
for (i = 0; i < NSID_SHUFFLE_TABLE_SIZE; i++) {
|
||||
nsid->nsid_vtable[i] = nsid->nsid_state;
|
||||
nsid->nsid_state =
|
||||
(((isc_uint32_t) nsid->nsid_a1 * nsid->nsid_state) +
|
||||
nsid->nsid_c1) & 0xFFFF;
|
||||
}
|
||||
nsid->nsid_state2 = nsid->nsid_state;
|
||||
}
|
||||
return (ISC_R_SUCCESS);
|
||||
}
|
||||
|
||||
static void
|
||||
nsid_destroy(isc_mem_t *mctx, dns_nsid_t *nsid) {
|
||||
if (nsid->nsid_usepool)
|
||||
isc_mem_put(mctx, nsid->nsid_pool,
|
||||
0x10000 * sizeof(isc_uint16_t));
|
||||
else
|
||||
isc_mem_put(mctx, nsid->nsid_vtable,
|
||||
NSID_SHUFFLE_TABLE_SIZE * (sizeof(isc_uint16_t)) );
|
||||
memset(nsid, 0, sizeof(*nsid));
|
||||
}
|
||||
|
||||
void
|
||||
dns_dispatch_hash(void *data, size_t len) {
|
||||
nsid_hash(data, len);
|
||||
}
|
||||
@@ -437,6 +437,13 @@ dns_dispatch_importrecv(dns_dispatch_t *disp, isc_event_t *event);
|
||||
* event != NULL
|
||||
*/
|
||||
|
||||
void
|
||||
dns_dispatch_hash(void *data, size_t len);
|
||||
/*%<
|
||||
* Feed 'data' to the dispatch query id generator where 'len' is the size
|
||||
* of 'data'.
|
||||
*/
|
||||
|
||||
ISC_LANG_ENDDECLS
|
||||
|
||||
#endif /* DNS_DISPATCH_H */
|
||||
@@ -144,6 +144,7 @@ struct dns_validator {
|
||||
* dns_validator_create() options.
|
||||
*/
|
||||
#define DNS_VALIDATOR_DLV 1U
|
||||
#define DNS_VALIDATOR_DEFER 2U
|
||||
|
||||
ISC_LANG_BEGINDECLS
|
||||
|
||||
@@ -191,6 +192,15 @@ dns_validator_create(dns_view_t *view, dns_name_t *name, dns_rdatatype_t type,
|
||||
* the answer by looking for a appopriate DLV RRset.
|
||||
*/
|
||||
|
||||
void
|
||||
dns_validator_send(dns_validator_t *validator);
|
||||
/*%<
|
||||
* Send a deferred validation request
|
||||
*
|
||||
* Requires:
|
||||
* 'validator' to points to a valid DNSSEC validator.
|
||||
*/
|
||||
|
||||
void
|
||||
dns_validator_cancel(dns_validator_t *validator);
|
||||
/*%<
|
||||
|
||||
@@ -218,6 +218,11 @@ struct fetchctx {
|
||||
dns_name_t nsname;
|
||||
dns_fetch_t * nsfetch;
|
||||
dns_rdataset_t nsrrset;
|
||||
|
||||
/*%
|
||||
* Number of queries that reference this context.
|
||||
*/
|
||||
unsigned int nqueries;
|
||||
};
|
||||
|
||||
#define FCTX_MAGIC ISC_MAGIC('F', '!', '!', '!')
|
||||
@@ -351,6 +356,7 @@ static isc_result_t ncache_adderesult(dns_message_t *message,
|
||||
dns_rdataset_t *ardataset,
|
||||
isc_result_t *eresultp);
|
||||
static void validated(isc_task_t *task, isc_event_t *event);
|
||||
static void maybe_destroy(fetchctx_t *fctx);
|
||||
|
||||
static isc_result_t
|
||||
valcreate(fetchctx_t *fctx, dns_adbaddrinfo_t *addrinfo, dns_name_t *name,
|
||||
@@ -369,6 +375,9 @@ valcreate(fetchctx_t *fctx, dns_adbaddrinfo_t *addrinfo, dns_name_t *name,
|
||||
valarg->fctx = fctx;
|
||||
valarg->addrinfo = addrinfo;
|
||||
|
||||
if (!ISC_LIST_EMPTY(fctx->validators))
|
||||
INSIST((valoptions & DNS_VALIDATOR_DEFER) != 0);
|
||||
|
||||
result = dns_validator_create(fctx->res->view, name, type, rdataset,
|
||||
sigrdataset, fctx->rmessage,
|
||||
valoptions, task, validated, valarg,
|
||||
@@ -515,6 +524,9 @@ resquery_destroy(resquery_t **queryp) {
|
||||
|
||||
INSIST(query->tcpsocket == NULL);
|
||||
|
||||
query->fctx->nqueries--;
|
||||
if (SHUTTINGDOWN(query->fctx))
|
||||
maybe_destroy(query->fctx); /* Locks bucket. */
|
||||
query->magic = 0;
|
||||
isc_mem_put(query->mctx, query, sizeof(*query));
|
||||
*queryp = NULL;
|
||||
@@ -973,6 +985,8 @@ fctx_query(fetchctx_t *fctx, dns_adbaddrinfo_t *addrinfo,
|
||||
if (result != ISC_R_SUCCESS)
|
||||
return (result);
|
||||
|
||||
INSIST(ISC_LIST_EMPTY(fctx->validators));
|
||||
|
||||
dns_message_reset(fctx->rmessage, DNS_MESSAGE_INTENTPARSE);
|
||||
|
||||
query = isc_mem_get(res->mctx, sizeof(*query));
|
||||
@@ -1088,6 +1102,7 @@ fctx_query(fetchctx_t *fctx, dns_adbaddrinfo_t *addrinfo,
|
||||
}
|
||||
|
||||
ISC_LIST_APPEND(fctx->queries, query, link);
|
||||
query->fctx->nqueries++;
|
||||
|
||||
return (ISC_R_SUCCESS);
|
||||
|
||||
@@ -1540,7 +1555,7 @@ fctx_finddone(isc_task_t *task, isc_event_t *event) {
|
||||
want_done = ISC_TRUE;
|
||||
}
|
||||
} else if (SHUTTINGDOWN(fctx) && fctx->pending == 0 &&
|
||||
ISC_LIST_EMPTY(fctx->validators)) {
|
||||
fctx->nqueries == 0 && ISC_LIST_EMPTY(fctx->validators)) {
|
||||
bucketnum = fctx->bucketnum;
|
||||
LOCK(&res->buckets[bucketnum].lock);
|
||||
/*
|
||||
@@ -2394,8 +2409,8 @@ fctx_destroy(fetchctx_t *fctx) {
|
||||
REQUIRE(ISC_LIST_EMPTY(fctx->finds));
|
||||
REQUIRE(ISC_LIST_EMPTY(fctx->altfinds));
|
||||
REQUIRE(fctx->pending == 0);
|
||||
REQUIRE(ISC_LIST_EMPTY(fctx->validators));
|
||||
REQUIRE(fctx->references == 0);
|
||||
REQUIRE(ISC_LIST_EMPTY(fctx->validators));
|
||||
|
||||
FCTXTRACE("destroy");
|
||||
|
||||
@@ -2569,7 +2584,7 @@ fctx_doshutdown(isc_task_t *task, isc_event_t *event) {
|
||||
}
|
||||
|
||||
if (fctx->references == 0 && fctx->pending == 0 &&
|
||||
ISC_LIST_EMPTY(fctx->validators))
|
||||
fctx->nqueries == 0 && ISC_LIST_EMPTY(fctx->validators))
|
||||
bucket_empty = fctx_destroy(fctx);
|
||||
|
||||
UNLOCK(&res->buckets[bucketnum].lock);
|
||||
@@ -2610,6 +2625,7 @@ fctx_start(isc_task_t *task, isc_event_t *event) {
|
||||
* pending ADB finds and no pending validations.
|
||||
*/
|
||||
INSIST(fctx->pending == 0);
|
||||
INSIST(fctx->nqueries == 0);
|
||||
INSIST(ISC_LIST_EMPTY(fctx->validators));
|
||||
if (fctx->references == 0) {
|
||||
/*
|
||||
@@ -2771,6 +2787,7 @@ fctx_create(dns_resolver_t *res, dns_name_t *name, dns_rdatatype_t type,
|
||||
fctx->restarts = 0;
|
||||
fctx->timeouts = 0;
|
||||
fctx->attributes = 0;
|
||||
fctx->nqueries = 0;
|
||||
|
||||
dns_name_init(&fctx->nsname, NULL);
|
||||
fctx->nsfetch = NULL;
|
||||
@@ -3093,12 +3110,21 @@ maybe_destroy(fetchctx_t *fctx) {
|
||||
unsigned int bucketnum;
|
||||
isc_boolean_t bucket_empty = ISC_FALSE;
|
||||
dns_resolver_t *res = fctx->res;
|
||||
dns_validator_t *validator;
|
||||
|
||||
REQUIRE(SHUTTINGDOWN(fctx));
|
||||
|
||||
if (fctx->pending != 0 || !ISC_LIST_EMPTY(fctx->validators))
|
||||
if (fctx->pending != 0 || fctx->nqueries != 0)
|
||||
return;
|
||||
|
||||
for (validator = ISC_LIST_HEAD(fctx->validators);
|
||||
validator != NULL;
|
||||
validator = ISC_LIST_HEAD(fctx->validators)) {
|
||||
ISC_LIST_UNLINK(fctx->validators, validator, link);
|
||||
dns_validator_cancel(validator);
|
||||
dns_validator_destroy(&validator);
|
||||
}
|
||||
|
||||
bucketnum = fctx->bucketnum;
|
||||
LOCK(&res->buckets[bucketnum].lock);
|
||||
if (fctx->references == 0)
|
||||
@@ -3232,7 +3258,9 @@ validated(isc_task_t *task, isc_event_t *event) {
|
||||
add_bad(fctx, &addrinfo->sockaddr, result);
|
||||
isc_event_free(&event);
|
||||
UNLOCK(&fctx->res->buckets[fctx->bucketnum].lock);
|
||||
if (sentresponse)
|
||||
if (!ISC_LIST_EMPTY(fctx->validators))
|
||||
dns_validator_send(ISC_LIST_HEAD(fctx->validators));
|
||||
else if (sentresponse)
|
||||
fctx_done(fctx, result); /* Locks bucket. */
|
||||
else
|
||||
fctx_try(fctx); /* Locks bucket. */
|
||||
@@ -3330,6 +3358,7 @@ validated(isc_task_t *task, isc_event_t *event) {
|
||||
* be validated.
|
||||
*/
|
||||
UNLOCK(&fctx->res->buckets[fctx->bucketnum].lock);
|
||||
dns_validator_send(ISC_LIST_HEAD(fctx->validators));
|
||||
goto cleanup_event;
|
||||
}
|
||||
|
||||
@@ -3640,6 +3669,13 @@ cache_name(fetchctx_t *fctx, dns_name_t *name, dns_adbaddrinfo_t *addrinfo,
|
||||
rdataset,
|
||||
sigrdataset,
|
||||
valoptions, task);
|
||||
/*
|
||||
* Defer any further validations.
|
||||
* This prevents multiple validators
|
||||
* from manipulating fctx->rmessage
|
||||
* simultaniously.
|
||||
*/
|
||||
valoptions |= DNS_VALIDATOR_DEFER;
|
||||
}
|
||||
} else if (CHAINING(rdataset)) {
|
||||
if (rdataset->type == dns_rdatatype_cname)
|
||||
@@ -6371,7 +6407,8 @@ dns_resolver_destroyfetch(dns_fetch_t **fetchp) {
|
||||
/*
|
||||
* No one cares about the result of this fetch anymore.
|
||||
*/
|
||||
if (fctx->pending == 0 && ISC_LIST_EMPTY(fctx->validators) &&
|
||||
if (fctx->pending == 0 && fctx->nqueries == 0 &&
|
||||
ISC_LIST_EMPTY(fctx->validators) &&
|
||||
SHUTTINGDOWN(fctx)) {
|
||||
/*
|
||||
* This fctx is already shutdown; we were just
|
||||
|
||||
@@ -2825,7 +2825,8 @@ dns_validator_create(dns_view_t *view, dns_name_t *name, dns_rdatatype_t type,
|
||||
ISC_LINK_INIT(val, link);
|
||||
val->magic = VALIDATOR_MAGIC;
|
||||
|
||||
isc_task_send(task, ISC_EVENT_PTR(&event));
|
||||
if ((options & DNS_VALIDATOR_DEFER) == 0)
|
||||
isc_task_send(task, ISC_EVENT_PTR(&event));
|
||||
|
||||
*validatorp = val;
|
||||
|
||||
@@ -2842,6 +2843,21 @@ dns_validator_create(dns_view_t *view, dns_name_t *name, dns_rdatatype_t type,
|
||||
return (result);
|
||||
}
|
||||
|
||||
void
|
||||
dns_validator_send(dns_validator_t *validator) {
|
||||
isc_event_t *event;
|
||||
REQUIRE(VALID_VALIDATOR(validator));
|
||||
|
||||
LOCK(&validator->lock);
|
||||
|
||||
INSIST((validator->options & DNS_VALIDATOR_DEFER) != 0);
|
||||
event = (isc_event_t *)validator->event;
|
||||
validator->options &= ~DNS_VALIDATOR_DEFER;
|
||||
UNLOCK(&validator->lock);
|
||||
|
||||
isc_task_send(validator->task, ISC_EVENT_PTR(&event));
|
||||
}
|
||||
|
||||
void
|
||||
dns_validator_cancel(dns_validator_t *validator) {
|
||||
REQUIRE(VALID_VALIDATOR(validator));
|
||||
@@ -2856,6 +2872,12 @@ dns_validator_cancel(dns_validator_t *validator) {
|
||||
|
||||
if (validator->subvalidator != NULL)
|
||||
dns_validator_cancel(validator->subvalidator);
|
||||
if ((validator->options & DNS_VALIDATOR_DEFER) != 0) {
|
||||
isc_task_t *task = validator->event->ev_sender;
|
||||
validator->options &= ~DNS_VALIDATOR_DEFER;
|
||||
isc_event_free((isc_event_t **)&validator->event);
|
||||
isc_task_detach(&task);
|
||||
}
|
||||
}
|
||||
UNLOCK(&validator->lock);
|
||||
}
|
||||
|
||||
+1
-1
@@ -226,7 +226,7 @@ struct magic_set {
|
||||
/* Accumulation buffer */
|
||||
char *buf;
|
||||
char *ptr;
|
||||
size_t len;
|
||||
size_t left;
|
||||
size_t size;
|
||||
/* Printable buffer */
|
||||
char *pbuf;
|
||||
|
||||
+26
-15
@@ -26,6 +26,7 @@
|
||||
*/
|
||||
#include "file.h"
|
||||
#include "magic.h"
|
||||
#include <limits.h>
|
||||
#include <stdarg.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
@@ -41,27 +42,31 @@ protected int
|
||||
file_printf(struct magic_set *ms, const char *fmt, ...)
|
||||
{
|
||||
va_list ap;
|
||||
size_t len;
|
||||
size_t len, size;
|
||||
char *buf;
|
||||
|
||||
va_start(ap, fmt);
|
||||
|
||||
if ((len = vsnprintf(ms->o.ptr, ms->o.len, fmt, ap)) >= ms->o.len) {
|
||||
if ((len = vsnprintf(ms->o.ptr, ms->o.left, fmt, ap)) >= ms->o.left) {
|
||||
long diff; /* XXX: really ptrdiff_t */
|
||||
|
||||
va_end(ap);
|
||||
if ((buf = realloc(ms->o.buf, len + 1024)) == NULL) {
|
||||
size = (ms->o.size - ms->o.left) + len + 1024;
|
||||
if ((buf = realloc(ms->o.buf, size)) == NULL) {
|
||||
file_oomem(ms);
|
||||
return -1;
|
||||
}
|
||||
ms->o.ptr = buf + (ms->o.ptr - ms->o.buf);
|
||||
diff = ms->o.ptr - ms->o.buf;
|
||||
ms->o.ptr = buf + diff;
|
||||
ms->o.buf = buf;
|
||||
ms->o.len = ms->o.size - (ms->o.ptr - ms->o.buf);
|
||||
ms->o.size = len + 1024;
|
||||
ms->o.left = size - diff;
|
||||
ms->o.size = size;
|
||||
|
||||
va_start(ap, fmt);
|
||||
len = vsnprintf(ms->o.ptr, ms->o.len, fmt, ap);
|
||||
len = vsnprintf(ms->o.ptr, ms->o.left, fmt, ap);
|
||||
}
|
||||
ms->o.ptr += len;
|
||||
ms->o.len -= len;
|
||||
ms->o.left -= len;
|
||||
va_end(ap);
|
||||
return 0;
|
||||
}
|
||||
@@ -150,8 +155,8 @@ file_reset(struct magic_set *ms)
|
||||
protected const char *
|
||||
file_getbuffer(struct magic_set *ms)
|
||||
{
|
||||
char *nbuf, *op, *np;
|
||||
size_t nsize;
|
||||
char *pbuf, *op, *np;
|
||||
size_t psize, len;
|
||||
|
||||
if (ms->haderr)
|
||||
return NULL;
|
||||
@@ -159,14 +164,20 @@ file_getbuffer(struct magic_set *ms)
|
||||
if (ms->flags & MAGIC_RAW)
|
||||
return ms->o.buf;
|
||||
|
||||
nsize = ms->o.len * 4 + 1;
|
||||
if (ms->o.psize < nsize) {
|
||||
if ((nbuf = realloc(ms->o.pbuf, nsize)) == NULL) {
|
||||
len = ms->o.size - ms->o.left;
|
||||
if (len > (SIZE_T_MAX - 1) / 4) {
|
||||
file_oomem(ms);
|
||||
return NULL;
|
||||
}
|
||||
/* * 4 is for octal representation, + 1 is for NUL */
|
||||
psize = len * 4 + 1;
|
||||
if (ms->o.psize < psize) {
|
||||
if ((pbuf = realloc(ms->o.pbuf, psize)) == NULL) {
|
||||
file_oomem(ms);
|
||||
return NULL;
|
||||
}
|
||||
ms->o.psize = nsize;
|
||||
ms->o.pbuf = nbuf;
|
||||
ms->o.psize = psize;
|
||||
ms->o.pbuf = pbuf;
|
||||
}
|
||||
|
||||
for (np = ms->o.pbuf, op = ms->o.buf; *op; op++) {
|
||||
|
||||
@@ -89,7 +89,7 @@ magic_open(int flags)
|
||||
goto free1;
|
||||
}
|
||||
|
||||
ms->o.ptr = ms->o.buf = malloc(ms->o.size = 1024);
|
||||
ms->o.ptr = ms->o.buf = malloc(ms->o.left = ms->o.size = 1024);
|
||||
if (ms->o.buf == NULL)
|
||||
goto free1;
|
||||
|
||||
@@ -101,7 +101,6 @@ magic_open(int flags)
|
||||
if (ms->c.off == NULL)
|
||||
goto free3;
|
||||
|
||||
ms->o.len = 0;
|
||||
ms->haderr = 0;
|
||||
ms->error = -1;
|
||||
ms->mlist = NULL;
|
||||
|
||||
@@ -622,6 +622,26 @@ trunc:
|
||||
return -2;
|
||||
}
|
||||
|
||||
/*
|
||||
* As I remember, some versions of systems have an snprintf() that
|
||||
* returns -1 if the buffer would have overflowed. If the return
|
||||
* value is negative, set buflen to 0, to indicate that we've filled
|
||||
* the buffer up.
|
||||
*
|
||||
* If the return value is greater than buflen, that means that
|
||||
* the buffer would have overflowed; again, set buflen to 0 in
|
||||
* that case.
|
||||
*/
|
||||
#define UPDATE_BUF_BUFLEN(buf, buflen, strlen) \
|
||||
if (strlen<0) \
|
||||
buflen=0; \
|
||||
else if ((u_int)strlen>buflen) \
|
||||
buflen=0; \
|
||||
else { \
|
||||
buflen-=strlen; \
|
||||
buf+=strlen; \
|
||||
}
|
||||
|
||||
static int
|
||||
decode_labeled_vpn_l2(const u_char *pptr, char *buf, u_int buflen)
|
||||
{
|
||||
@@ -632,11 +652,13 @@ decode_labeled_vpn_l2(const u_char *pptr, char *buf, u_int buflen)
|
||||
tlen=plen;
|
||||
pptr+=2;
|
||||
TCHECK2(pptr[0],15);
|
||||
buf[0]='\0';
|
||||
strlen=snprintf(buf, buflen, "RD: %s, CE-ID: %u, Label-Block Offset: %u, Label Base %u",
|
||||
bgp_vpn_rd_print(pptr),
|
||||
EXTRACT_16BITS(pptr+8),
|
||||
EXTRACT_16BITS(pptr+10),
|
||||
EXTRACT_24BITS(pptr+12)>>4); /* the label is offsetted by 4 bits so lets shift it right */
|
||||
UPDATE_BUF_BUFLEN(buf, buflen, strlen);
|
||||
pptr+=15;
|
||||
tlen-=15;
|
||||
|
||||
@@ -652,23 +674,32 @@ decode_labeled_vpn_l2(const u_char *pptr, char *buf, u_int buflen)
|
||||
|
||||
switch(tlv_type) {
|
||||
case 1:
|
||||
strlen+=snprintf(buf+strlen,buflen-strlen, "\n\t\tcircuit status vector (%u) length: %u: 0x",
|
||||
tlv_type,
|
||||
tlv_len);
|
||||
if (buflen!=0) {
|
||||
strlen=snprintf(buf,buflen, "\n\t\tcircuit status vector (%u) length: %u: 0x",
|
||||
tlv_type,
|
||||
tlv_len);
|
||||
UPDATE_BUF_BUFLEN(buf, buflen, strlen);
|
||||
}
|
||||
ttlv_len=ttlv_len/8+1; /* how many bytes do we need to read ? */
|
||||
while (ttlv_len>0) {
|
||||
TCHECK(pptr[0]);
|
||||
strlen+=snprintf(buf+strlen,buflen-strlen, "%02x",*pptr++);
|
||||
if (buflen!=0) {
|
||||
strlen=snprintf(buf,buflen, "%02x",*pptr++);
|
||||
UPDATE_BUF_BUFLEN(buf, buflen, strlen);
|
||||
}
|
||||
ttlv_len--;
|
||||
}
|
||||
break;
|
||||
default:
|
||||
snprintf(buf+strlen,buflen-strlen, "\n\t\tunknown TLV #%u, length: %u",
|
||||
tlv_type,
|
||||
tlv_len);
|
||||
if (buflen!=0) {
|
||||
strlen=snprintf(buf,buflen, "\n\t\tunknown TLV #%u, length: %u",
|
||||
tlv_type,
|
||||
tlv_len);
|
||||
UPDATE_BUF_BUFLEN(buf, buflen, strlen);
|
||||
}
|
||||
break;
|
||||
}
|
||||
tlen-=(tlv_len<<3); /* the tlv-length is expressed in bits so lets shift it tright */
|
||||
tlen-=(tlv_len<<3); /* the tlv-length is expressed in bits so lets shift it right */
|
||||
}
|
||||
return plen+2;
|
||||
|
||||
|
||||
@@ -2895,9 +2895,6 @@ x11_create_display_inet(int x11_display_offset, int x11_use_localhost,
|
||||
debug2("bind port %d: %.100s", port, strerror(errno));
|
||||
close(sock);
|
||||
|
||||
if (ai->ai_next)
|
||||
continue;
|
||||
|
||||
for (n = 0; n < num_socks; n++) {
|
||||
close(socks[n]);
|
||||
}
|
||||
|
||||
@@ -1149,7 +1149,6 @@ int SSL_set_cipher_list(SSL *s,const char *str)
|
||||
char *SSL_get_shared_ciphers(SSL *s,char *buf,int len)
|
||||
{
|
||||
char *p;
|
||||
const char *cp;
|
||||
STACK_OF(SSL_CIPHER) *sk;
|
||||
SSL_CIPHER *c;
|
||||
int i;
|
||||
@@ -1162,20 +1161,21 @@ char *SSL_get_shared_ciphers(SSL *s,char *buf,int len)
|
||||
sk=s->session->ciphers;
|
||||
for (i=0; i<sk_SSL_CIPHER_num(sk); i++)
|
||||
{
|
||||
/* Decrement for either the ':' or a '\0' */
|
||||
len--;
|
||||
int n;
|
||||
|
||||
c=sk_SSL_CIPHER_value(sk,i);
|
||||
for (cp=c->name; *cp; )
|
||||
n=strlen(c->name);
|
||||
if (n+1 > len)
|
||||
{
|
||||
if (len-- <= 0)
|
||||
{
|
||||
*p='\0';
|
||||
return(buf);
|
||||
}
|
||||
else
|
||||
*(p++)= *(cp++);
|
||||
if (p != buf)
|
||||
--p;
|
||||
*p='\0';
|
||||
return buf;
|
||||
}
|
||||
strcpy(p,c->name);
|
||||
p+=n;
|
||||
*(p++)=':';
|
||||
len-=n+1;
|
||||
}
|
||||
p[-1]='\0';
|
||||
return(buf);
|
||||
|
||||
+2
-2
@@ -331,8 +331,8 @@ jail_start()
|
||||
echo ${_jail_id} > /var/run/jail_${_jail}.id
|
||||
else
|
||||
jail_umount_fs
|
||||
if [ -n "${jail_interface}" ]; then
|
||||
ifconfig ${jail_interface} -alias ${jail_ip}
|
||||
if [ -n "${_interface}" ]; then
|
||||
ifconfig ${_interface} -alias ${_ip}
|
||||
fi
|
||||
echo " cannot start jail \"${_jail}\": "
|
||||
tail +2 ${_tmp_jail}
|
||||
|
||||
@@ -670,7 +670,13 @@ tar_read_header(struct archive *a, struct tar *tar,
|
||||
}
|
||||
}
|
||||
--tar->header_recursion_depth;
|
||||
return (err);
|
||||
/* We return warnings or success as-is. Anything else is fatal. */
|
||||
if (err == ARCHIVE_WARN || err == ARCHIVE_OK)
|
||||
return (err);
|
||||
if (err == ARCHIVE_EOF)
|
||||
/* EOF when recursively reading a header is bad. */
|
||||
archive_set_error(a, EINVAL, "Damaged tar archive");
|
||||
return (ARCHIVE_FATAL);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -741,32 +747,55 @@ static int
|
||||
header_Solaris_ACL(struct archive *a, struct tar *tar,
|
||||
struct archive_entry *entry, struct stat *st, const void *h)
|
||||
{
|
||||
int err, err2;
|
||||
char *p;
|
||||
const struct archive_entry_header_ustar *header;
|
||||
size_t size;
|
||||
int err;
|
||||
char *acl, *p;
|
||||
wchar_t *wp;
|
||||
|
||||
/*
|
||||
* read_body_to_string adds a NUL terminator, but we need a little
|
||||
* more to make sure that we don't overrun acl_text later.
|
||||
*/
|
||||
header = (const struct archive_entry_header_ustar *)h;
|
||||
size = tar_atol(header->size, sizeof(header->size));
|
||||
err = read_body_to_string(a, tar, &(tar->acl_text), h);
|
||||
err2 = tar_read_header(a, tar, entry, st);
|
||||
err = err_combine(err, err2);
|
||||
|
||||
/* XXX Ensure p doesn't overrun acl_text */
|
||||
if (err != ARCHIVE_OK)
|
||||
return (err);
|
||||
err = tar_read_header(a, tar, entry, st);
|
||||
if ((err != ARCHIVE_OK) && (err != ARCHIVE_WARN))
|
||||
return (err);
|
||||
|
||||
/* Skip leading octal number. */
|
||||
/* XXX TODO: Parse the octal number and sanity-check it. */
|
||||
p = tar->acl_text.s;
|
||||
while (*p != '\0')
|
||||
p = acl = tar->acl_text.s;
|
||||
while (*p != '\0' && p < acl + size)
|
||||
p++;
|
||||
p++;
|
||||
|
||||
wp = malloc((strlen(p) + 1) * sizeof(wchar_t));
|
||||
if (wp != NULL) {
|
||||
utf8_decode(wp, p, strlen(p));
|
||||
err2 = __archive_entry_acl_parse_w(entry, wp,
|
||||
ARCHIVE_ENTRY_ACL_TYPE_ACCESS);
|
||||
err = err_combine(err, err2);
|
||||
free(wp);
|
||||
if (p >= acl + size) {
|
||||
archive_set_error(a, ARCHIVE_ERRNO_MISC,
|
||||
"Malformed Solaris ACL attribute");
|
||||
return(ARCHIVE_WARN);
|
||||
}
|
||||
|
||||
/* Skip leading octal number. */
|
||||
size -= (p - acl);
|
||||
acl = p;
|
||||
|
||||
while (*p != '\0' && p < acl + size)
|
||||
p++;
|
||||
|
||||
wp = malloc((p - acl + 1) * sizeof(wchar_t));
|
||||
if (wp == NULL) {
|
||||
archive_set_error(a, ENOMEM,
|
||||
"Can't allocate work buffer for ACL parsing");
|
||||
return (ARCHIVE_FATAL);
|
||||
}
|
||||
utf8_decode(wp, acl, p - acl);
|
||||
err = __archive_entry_acl_parse_w(entry, wp,
|
||||
ARCHIVE_ENTRY_ACL_TYPE_ACCESS);
|
||||
free(wp);
|
||||
return (err);
|
||||
}
|
||||
|
||||
@@ -777,15 +806,17 @@ static int
|
||||
header_longlink(struct archive *a, struct tar *tar,
|
||||
struct archive_entry *entry, struct stat *st, const void *h)
|
||||
{
|
||||
int err, err2;
|
||||
int err;
|
||||
|
||||
err = read_body_to_string(a, tar, &(tar->longlink), h);
|
||||
err2 = tar_read_header(a, tar, entry, st);
|
||||
if (err == ARCHIVE_OK && err2 == ARCHIVE_OK) {
|
||||
/* Set symlink if symlink already set, else hardlink. */
|
||||
archive_entry_set_link(entry, tar->longlink.s);
|
||||
}
|
||||
return (err_combine(err, err2));
|
||||
if (err != ARCHIVE_OK)
|
||||
return (err);
|
||||
err = tar_read_header(a, tar, entry, st);
|
||||
if ((err != ARCHIVE_OK) && (err != ARCHIVE_WARN))
|
||||
return (err);
|
||||
/* Set symlink if symlink already set, else hardlink. */
|
||||
archive_entry_set_link(entry, tar->longlink.s);
|
||||
return (ARCHIVE_OK);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -795,14 +826,17 @@ static int
|
||||
header_longname(struct archive *a, struct tar *tar,
|
||||
struct archive_entry *entry, struct stat *st, const void *h)
|
||||
{
|
||||
int err, err2;
|
||||
int err;
|
||||
|
||||
err = read_body_to_string(a, tar, &(tar->longname), h);
|
||||
if (err != ARCHIVE_OK)
|
||||
return (err);
|
||||
/* Read and parse "real" header, then override name. */
|
||||
err2 = tar_read_header(a, tar, entry, st);
|
||||
if (err == ARCHIVE_OK && err2 == ARCHIVE_OK)
|
||||
archive_entry_set_pathname(entry, tar->longname.s);
|
||||
return (err_combine(err, err2));
|
||||
err = tar_read_header(a, tar, entry, st);
|
||||
if ((err != ARCHIVE_OK) && (err != ARCHIVE_WARN))
|
||||
return (err);
|
||||
archive_entry_set_pathname(entry, tar->longname.s);
|
||||
return (ARCHIVE_OK);
|
||||
}
|
||||
|
||||
|
||||
@@ -836,12 +870,20 @@ read_body_to_string(struct archive *a, struct tar *tar,
|
||||
header = h;
|
||||
size = tar_atol(header->size, sizeof(header->size));
|
||||
|
||||
/* Sanity check. */
|
||||
if ((size > 1048576) || (size < 0)) {
|
||||
archive_set_error(a, EINVAL, "Special header too large");
|
||||
return (ARCHIVE_FATAL);
|
||||
}
|
||||
|
||||
/* Read the body into the string. */
|
||||
archive_string_ensure(as, size+1);
|
||||
padded_size = (size + 511) & ~ 511;
|
||||
dest = as->s;
|
||||
while (padded_size > 0) {
|
||||
bytes_read = (a->compression_read_ahead)(a, &src, padded_size);
|
||||
if (bytes_read == 0)
|
||||
return (ARCHIVE_EOF);
|
||||
if (bytes_read < 0)
|
||||
return (ARCHIVE_FATAL);
|
||||
if (bytes_read > padded_size)
|
||||
@@ -1027,11 +1069,13 @@ static int
|
||||
header_pax_global(struct archive *a, struct tar *tar,
|
||||
struct archive_entry *entry, struct stat *st, const void *h)
|
||||
{
|
||||
int err, err2;
|
||||
int err;
|
||||
|
||||
err = read_body_to_string(a, tar, &(tar->pax_global), h);
|
||||
err2 = tar_read_header(a, tar, entry, st);
|
||||
return (err_combine(err, err2));
|
||||
if (err != ARCHIVE_OK)
|
||||
return (err);
|
||||
err = tar_read_header(a, tar, entry, st);
|
||||
return (err);
|
||||
}
|
||||
|
||||
static int
|
||||
@@ -1040,10 +1084,14 @@ header_pax_extensions(struct archive *a, struct tar *tar,
|
||||
{
|
||||
int err, err2;
|
||||
|
||||
read_body_to_string(a, tar, &(tar->pax_header), h);
|
||||
err = read_body_to_string(a, tar, &(tar->pax_header), h);
|
||||
if (err != ARCHIVE_OK)
|
||||
return (err);
|
||||
|
||||
/* Parse the next header. */
|
||||
err = tar_read_header(a, tar, entry, st);
|
||||
if ((err != ARCHIVE_OK) && (err != ARCHIVE_WARN))
|
||||
return (err);
|
||||
|
||||
/*
|
||||
* TODO: Parse global/default options into 'entry' struct here
|
||||
@@ -1141,8 +1189,11 @@ pax_header(struct archive *a, struct tar *tar, struct archive_entry *entry,
|
||||
l--;
|
||||
break;
|
||||
}
|
||||
if (*p < '0' || *p > '9')
|
||||
return (-1);
|
||||
if (*p < '0' || *p > '9') {
|
||||
archive_set_error(a, ARCHIVE_ERRNO_MISC,
|
||||
"Ignoring malformed pax extended attributes");
|
||||
return (ARCHIVE_WARN);
|
||||
}
|
||||
line_length *= 10;
|
||||
line_length += *p - '0';
|
||||
if (line_length > 999999) {
|
||||
@@ -1154,8 +1205,19 @@ pax_header(struct archive *a, struct tar *tar, struct archive_entry *entry,
|
||||
l--;
|
||||
}
|
||||
|
||||
if (line_length > attr_length)
|
||||
return (0);
|
||||
/*
|
||||
* Parsed length must be no bigger than available data,
|
||||
* at least 1, and the last character of the line must
|
||||
* be '\n'.
|
||||
*/
|
||||
if (line_length > attr_length
|
||||
|| line_length < 1
|
||||
|| attr[line_length - 1] != '\n')
|
||||
{
|
||||
archive_set_error(a, ARCHIVE_ERRNO_MISC,
|
||||
"Ignoring malformed pax extended attribute");
|
||||
return (ARCHIVE_WARN);
|
||||
}
|
||||
|
||||
/* Ensure pax_entry buffer is big enough. */
|
||||
if (tar->pax_entry_length <= line_length) {
|
||||
|
||||
@@ -86,9 +86,9 @@ again:
|
||||
}
|
||||
if (!digit)
|
||||
return (INADDR_NONE);
|
||||
if (pp >= parts + 4 || val > 0xffU)
|
||||
return (INADDR_NONE);
|
||||
if (*cp == '.') {
|
||||
if (pp >= parts + 4 || val > 0xffU)
|
||||
return (INADDR_NONE);
|
||||
*pp++ = val, cp++;
|
||||
goto again;
|
||||
}
|
||||
|
||||
+23
-21
@@ -214,24 +214,30 @@ char *
|
||||
ptsname(int fildes)
|
||||
{
|
||||
static char slave[] = _PATH_DEV PTS_PREFIX "XY";
|
||||
char *retval;
|
||||
const char *master;
|
||||
struct stat sbuf;
|
||||
|
||||
retval = NULL;
|
||||
/* All master pty's must be char devices. */
|
||||
if (_fstat(fildes, &sbuf) == -1)
|
||||
goto invalid;
|
||||
if (!S_ISCHR(sbuf.st_mode))
|
||||
goto invalid;
|
||||
|
||||
if (_fstat(fildes, &sbuf) == 0) {
|
||||
if (!ISPTM(sbuf))
|
||||
errno = EINVAL;
|
||||
else {
|
||||
(void)snprintf(slave, sizeof(slave),
|
||||
_PATH_DEV PTS_PREFIX "%s",
|
||||
devname(sbuf.st_rdev, S_IFCHR) +
|
||||
strlen(PTM_PREFIX));
|
||||
retval = slave;
|
||||
}
|
||||
}
|
||||
/* Check to see if this device is a pty(4) master. */
|
||||
master = devname(sbuf.st_rdev, S_IFCHR);
|
||||
if (strlen(master) != strlen(PTM_PREFIX "XY"))
|
||||
goto invalid;
|
||||
if (strncmp(master, PTM_PREFIX, strlen(PTM_PREFIX)) != 0)
|
||||
goto invalid;
|
||||
|
||||
return (retval);
|
||||
/* It is, so generate the corresponding pty(4) slave name. */
|
||||
(void)snprintf(slave, sizeof(slave), _PATH_DEV PTS_PREFIX "%s",
|
||||
master + strlen(PTM_PREFIX));
|
||||
return (slave);
|
||||
|
||||
invalid:
|
||||
errno = EINVAL;
|
||||
return (NULL);
|
||||
}
|
||||
|
||||
/*
|
||||
@@ -240,18 +246,14 @@ ptsname(int fildes)
|
||||
int
|
||||
unlockpt(int fildes)
|
||||
{
|
||||
int retval;
|
||||
struct stat sbuf;
|
||||
|
||||
/*
|
||||
* Unlocking a master/slave pseudo-terminal pair has no meaning in a
|
||||
* non-streams PTY environment. However, we do ensure fildes is a
|
||||
* valid master pseudo-terminal device.
|
||||
*/
|
||||
if ((retval = _fstat(fildes, &sbuf)) == 0 && !ISPTM(sbuf)) {
|
||||
errno = EINVAL;
|
||||
retval = -1;
|
||||
}
|
||||
if (ptsname(fildes) == NULL)
|
||||
return (-1);
|
||||
|
||||
return (retval);
|
||||
return (0);
|
||||
}
|
||||
+1
-2
@@ -76,8 +76,7 @@ openpty(int *amaster, int *aslave, char *name, struct termios *termp, struct win
|
||||
break; /* try the next pty group */
|
||||
} else {
|
||||
line[5] = 't';
|
||||
(void) chown(line, getuid(), ttygid);
|
||||
(void) chmod(line, S_IRUSR|S_IWUSR|S_IWGRP);
|
||||
(void) grantpt(master);
|
||||
(void) revoke(line);
|
||||
if ((slave = open(line, O_RDWR, 0)) != -1) {
|
||||
*amaster = master;
|
||||
|
||||
+1
-1
@@ -32,7 +32,7 @@
|
||||
|
||||
TYPE="FreeBSD"
|
||||
REVISION="6.2"
|
||||
BRANCH="RELEASE"
|
||||
BRANCH="RELEASE-p12"
|
||||
if [ "X${BRANCH_OVERRIDE}" != "X" ]; then
|
||||
BRANCH=${BRANCH_OVERRIDE}
|
||||
fi
|
||||
|
||||
@@ -298,6 +298,7 @@ random_yarrow_read(void *buf, int count)
|
||||
random_state.outputblocks = 0;
|
||||
}
|
||||
retval += (int)tomove;
|
||||
cur = 0;
|
||||
}
|
||||
}
|
||||
else {
|
||||
|
||||
@@ -2043,7 +2043,7 @@ _fgetvp(struct thread *td, int fd, struct vnode **vpp, int flags)
|
||||
int error;
|
||||
|
||||
*vpp = NULL;
|
||||
if ((error = _fget(td, fd, &fp, 0, 0)) != 0)
|
||||
if ((error = _fget(td, fd, &fp, flags, 0)) != 0)
|
||||
return (error);
|
||||
if (fp->f_vnode == NULL) {
|
||||
error = EINVAL;
|
||||
|
||||
+17
-14
@@ -1818,20 +1818,23 @@ kern_sendfile(struct thread *td, struct sendfile_args *uap,
|
||||
goto done;
|
||||
vfslocked = VFS_LOCK_GIANT(vp->v_mount);
|
||||
vn_lock(vp, LK_EXCLUSIVE | LK_RETRY, td);
|
||||
obj = vp->v_object;
|
||||
if (obj != NULL) {
|
||||
/*
|
||||
* Temporarily increase the backing VM object's reference
|
||||
* count so that a forced reclamation of its vnode does not
|
||||
* immediately destroy it.
|
||||
*/
|
||||
VM_OBJECT_LOCK(obj);
|
||||
if ((obj->flags & OBJ_DEAD) == 0) {
|
||||
vm_object_reference_locked(obj);
|
||||
VM_OBJECT_UNLOCK(obj);
|
||||
} else {
|
||||
VM_OBJECT_UNLOCK(obj);
|
||||
obj = NULL;
|
||||
if (vp->v_type == VREG) {
|
||||
obj = vp->v_object;
|
||||
if (obj != NULL) {
|
||||
/*
|
||||
* Temporarily increase the backing VM
|
||||
* object's reference count so that a forced
|
||||
* reclamation of its vnode does not
|
||||
* immediately destroy it.
|
||||
*/
|
||||
VM_OBJECT_LOCK(obj);
|
||||
if ((obj->flags & OBJ_DEAD) == 0) {
|
||||
vm_object_reference_locked(obj);
|
||||
VM_OBJECT_UNLOCK(obj);
|
||||
} else {
|
||||
VM_OBJECT_UNLOCK(obj);
|
||||
obj = NULL;
|
||||
}
|
||||
}
|
||||
}
|
||||
VOP_UNLOCK(vp, 0, td);
|
||||
|
||||
+2
-1
@@ -574,7 +574,8 @@ struct ip6_mtuinfo {
|
||||
/* New entries should be added here from current IPV6CTL_MAXID value. */
|
||||
/* to define items, should talk with KAME guys first, for *BSD compatibility */
|
||||
#define IPV6CTL_STEALTH 45
|
||||
#define IPV6CTL_MAXID 46
|
||||
#define IPV6CTL_RTHDR0_ALLOWED 46
|
||||
#define IPV6CTL_MAXID 47
|
||||
#endif /* __BSD_VISIBLE */
|
||||
|
||||
/*
|
||||
|
||||
@@ -376,6 +376,8 @@ time_t ip6_log_time = (time_t)0L;
|
||||
#ifdef IPSTEALTH
|
||||
int ip6stealth = 0;
|
||||
#endif
|
||||
int ip6_rthdr0_allowed = 0; /* Disallow use of routing header 0 */
|
||||
/* by default. */
|
||||
|
||||
/* icmp6 */
|
||||
/*
|
||||
@@ -519,6 +521,9 @@ SYSCTL_INT(_net_inet6_ip6, IPV6CTL_MCAST_PMTU,
|
||||
SYSCTL_INT(_net_inet6_ip6, IPV6CTL_STEALTH, stealth, CTLFLAG_RW,
|
||||
&ip6stealth, 0, "");
|
||||
#endif
|
||||
SYSCTL_INT(_net_inet6_ip6, IPV6CTL_RTHDR0_ALLOWED,
|
||||
rthdr0_allowed, CTLFLAG_RW, &ip6_rthdr0_allowed, 0, "");
|
||||
|
||||
|
||||
/* net.inet6.icmp6 */
|
||||
SYSCTL_INT(_net_inet6_icmp6, ICMPV6CTL_REDIRACCEPT,
|
||||
|
||||
+1
-1
@@ -1315,7 +1315,7 @@ nd6_rtrequest(req, rt, info)
|
||||
callout_init(&ln->ln_timer_ch, 0);
|
||||
|
||||
/* this is required for "ndp" command. - shin */
|
||||
if (req == RTM_ADD && (rt->rt_flags & RTF_STATIC)) {
|
||||
if (req == RTM_ADD) {
|
||||
/*
|
||||
* gate should have some valid AF_LINK entry,
|
||||
* and ln->ln_expire should have some lifetime
|
||||
|
||||
@@ -49,6 +49,8 @@
|
||||
|
||||
#include <netinet/icmp6.h>
|
||||
|
||||
extern int ip6_rthdr0_allowed;
|
||||
|
||||
static int ip6_rthdr0 __P((struct mbuf *, struct ip6_hdr *,
|
||||
struct ip6_rthdr0 *));
|
||||
|
||||
@@ -88,6 +90,8 @@ route6_input(mp, offp, proto)
|
||||
|
||||
switch (rh->ip6r_type) {
|
||||
case IPV6_RTHDR_TYPE_0:
|
||||
if (!ip6_rthdr0_allowed)
|
||||
return (IPPROTO_DONE);
|
||||
rhlen = (rh->ip6r_len + 1) << 3;
|
||||
#ifndef PULLDOWN_TEST
|
||||
/*
|
||||
|
||||
@@ -499,6 +499,24 @@ fetch_check_params () {
|
||||
exit 1
|
||||
fi
|
||||
|
||||
# Figure out what kernel configuration is running. We start with
|
||||
# the output of `uname -i`, and then make the following adjustments:
|
||||
# 1. Replace "SMP-GENERIC" with "SMP". Why the SMP kernel config
|
||||
# file says "ident SMP-GENERIC", I don't know...
|
||||
# 2. If the kernel claims to be GENERIC _and_ ${ARCH} is "amd64"
|
||||
# _and_ `sysctl kern.version` contains a line which ends "/SMP", then
|
||||
# we're running an SMP kernel. This mis-identification is a bug
|
||||
# which was fixed in 6.2-STABLE.
|
||||
KERNCONF=`uname -i`
|
||||
if [ ${KERNCONF} = "SMP-GENERIC" ]; then
|
||||
KERNCONF=SMP
|
||||
fi
|
||||
if [ ${KERNCONF} = "GENERIC" ] && [ ${ARCH} = "amd64" ]; then
|
||||
if sysctl kern.version | grep -qE '/SMP$'; then
|
||||
KERNCONF=SMP
|
||||
fi
|
||||
fi
|
||||
|
||||
# Define some paths
|
||||
BSPATCH=/usr/bin/bspatch
|
||||
SHA256=/sbin/sha256
|
||||
@@ -1084,8 +1102,8 @@ fetch_filter_metadata () {
|
||||
# /boot/kernel
|
||||
# (or more generally, `sysctl -n kern.bootfile` minus the trailing "/kernel").
|
||||
fetch_filter_kernel_names () {
|
||||
grep ^/boot/`uname -i` $1 |
|
||||
sed -e "s,/boot/`uname -i`,${KERNELDIR}," |
|
||||
grep ^/boot/${KERNCONF} $1 |
|
||||
sed -e "s,/boot/${KERNCONF},${KERNELDIR},g" |
|
||||
sort - $1 > $1.tmp
|
||||
mv $1.tmp $1
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user