Page MenuHomeFreeBSD
Files F177539283

D25182.1794665139.diff
No OneTemporary
Actions

Authored By
Unknown
Size
3 KB
Referenced Files
None
Subscribers
None

D25182.1794665139.diff
View Options

Index: kern/kern_mbuf.c
===================================================================
--- kern/kern_mbuf.c
+++ kern/kern_mbuf.c
@@ -60,6 +60,7 @@
#include <vm/vm_extern.h>
#include <vm/vm_kern.h>
#include <vm/vm_page.h>
+#include <vm/vm_pageout.h>
#include <vm/vm_map.h>
#include <vm/uma.h>
#include <vm/uma_dbg.h>
@@ -1536,4 +1537,107 @@
ifp->if_snd_tag_free(mst);
if_rele(ifp);
counter_u64_add(snd_tag_count, -1);
+}
+
+/*
+ * Allocate an mbuf with anonymous external pages.
+ */
+struct mbuf *
+mb_alloc_ext_plus_pages(int len, int how)
+{
+ struct mbuf *m;
+ vm_page_t pg;
+ int i, npgs;
+
+ m = mb_alloc_ext_pgs(how, mb_free_mext_pgs);
+ if (m == NULL)
+ return (NULL);
+ m->m_epg_flags |= EPG_FLAG_ANON;
+ npgs = howmany(len, PAGE_SIZE);
+ for (i = 0; i < npgs; i++) {
+ do {
+ pg = vm_page_alloc(NULL, 0, VM_ALLOC_NORMAL |
+ VM_ALLOC_NOOBJ | VM_ALLOC_NODUMP | VM_ALLOC_WIRED);
+ if (pg == NULL) {
+ if (how == M_NOWAIT) {
+ m->m_epg_npgs = i;
+ m_free(m);
+ return (NULL);
+ }
+ vm_wait(NULL);
+ }
+ } while (pg == NULL);
+ m->m_epg_pa[i] = VM_PAGE_TO_PHYS(pg);
+ }
+ m->m_epg_npgs = npgs;
+ return (m);
+}
+
+/*
+ * Copy the data in the mbuf chain to a chain of mbufs with anonymous external
+ * unmapped pages.
+ * len is the length of data in the input mbuf chain.
+ * mlen is the maximum number of bytes put into each ext_page mbuf.
+ */
+struct mbuf *
+mb_mapped_to_unmapped(struct mbuf *mp, int len, int mlen, int how,
+ struct mbuf **mlast)
+{
+ struct mbuf *m, *mout = NULL;
+ char *pgpos = NULL, *mbpos;
+ int i = 0, mblen, mbufsiz, pglen, xfer;
+
+ if (len == 0)
+ return (NULL);
+ m = NULL;
+ pglen = mblen = 0;
+ do {
+ if (pglen == 0) {
+ if (m == NULL || ++i == m->m_epg_npgs) {
+ mbufsiz = min(mlen, len);
+ if (m == NULL) {
+ m = mout = mb_alloc_ext_plus_pages(
+ mbufsiz, how);
+ if (m == NULL)
+ return (m);
+ } else {
+ m->m_epg_last_len = PAGE_SIZE;
+ m->m_next = mb_alloc_ext_plus_pages(
+ mbufsiz, how);
+ m = m->m_next;
+ if (m == NULL) {
+ m_freem(mout);
+ return (m);
+ }
+ }
+ i = 0;
+ }
+ pgpos = (char *)(void *)
+ PHYS_TO_DMAP(m->m_epg_pa[i]);
+ pglen = PAGE_SIZE;
+ }
+ while (mblen == 0) {
+ if (mp == NULL) {
+ m_freem(mout);
+ return (NULL);
+ }
+ KASSERT((mp->m_flags & M_EXTPG) == 0,
+ ("mb_copym_ext_pgs: ext_pgs input mbuf"));
+ mbpos = mtod(mp, char *);
+ mblen = mp->m_len;
+ mp = mp->m_next;
+ }
+ xfer = min(mblen, pglen);
+ bcopy(mbpos, pgpos, xfer);
+ pgpos += xfer;
+ mbpos += xfer;
+ pglen -= xfer;
+ mblen -= xfer;
+ len -= xfer;
+ m->m_len += xfer;
+ } while (len > 0);
+ m->m_epg_last_len = PAGE_SIZE - pglen;
+ if (mlast != NULL)
+ *mlast = m;
+ return (mout);
}
Index: sys/mbuf.h
===================================================================
--- sys/mbuf.h
+++ sys/mbuf.h
@@ -741,6 +741,9 @@
void mb_free_extpg(struct mbuf *);
void mb_free_mext_pgs(struct mbuf *);
struct mbuf *mb_alloc_ext_pgs(int, m_ext_free_t);
+struct mbuf *mb_alloc_ext_plus_pages(int, int);
+struct mbuf *mb_mapped_to_unmapped(struct mbuf *, int, int, int,
+ struct mbuf **);
int mb_unmapped_compress(struct mbuf *m);
struct mbuf *mb_unmapped_to_ext(struct mbuf *m);
void mb_free_notready(struct mbuf *m, int count);

File Metadata

Mime Type
text/plain
Expires
Sat, Nov 14, 2:05 PM (11 h, 46 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
41724722
Default Alt Text
D25182.1794665139.diff (3 KB)

Event Timeline