ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/IO-AIO/AIO.xs
(Generate patch)

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.250 by root, Fri Sep 22 05:20:39 2017 UTC vs.
Revision 1.252 by root, Sat Jan 6 02:11:10 2018 UTC

… …
171# define PAGESIZE sysconf (_SC_PAGESIZE) 171# define PAGESIZE sysconf (_SC_PAGESIZE)
172#endif 172#endif
173 173
174/*****************************************************************************/ 174/*****************************************************************************/
175 175
176#if !_POSIX_MAPPED_FILES
177# define mmap(addr,length,prot,flags,fd,offs) EIO_ENOSYS ()
178# define munmap(addr,length) EIO_ENOSYS ()
179#endif
180
181#if !_POSIX_MEMORY_PROTECTION
182# define mprotect(addr,len,prot) EIO_ENOSYS ()
183#endif
184
185#define FOREIGN_MAGIC PERL_MAGIC_ext
186
187static int ecb_cold
188mmap_free (pTHX_ SV *sv, MAGIC *mg)
189{
190 int old_errno = errno;
191 munmap (mg->mg_ptr, (size_t)mg->mg_obj);
192 errno = old_errno;
193
194 mg->mg_obj = 0; /* just in case */
195
196 SvREADONLY_off (sv);
197
198 if (SvPVX (sv) != mg->mg_ptr)
199 croak ("ERROR: IO::AIO::mmap-mapped scalar changed location, detected");
200
201 SvCUR_set (sv, 0);
202 SvPVX (sv) = 0;
203 SvOK_off (sv);
204
205 return 0;
206}
207
208static MGVTBL mmap_vtbl = {
209 0, 0, 0, 0, mmap_free
210};
211
212static int ecb_cold
213sysfree_free (pTHX_ SV *sv, MAGIC *mg)
214{
215 free (mg->mg_ptr);
216 mg->mg_obj = 0; /* just in case */
217
218 SvREADONLY_off (sv);
219
220 if (SvPVX (sv) != mg->mg_ptr)
221 croak ("ERROR: IO::AIO mapped scalar changed location, detected");
222
223 SvCUR_set (sv, 0);
224 SvPVX (sv) = 0;
225 SvOK_off (sv);
226
227 return 0;
228}
229
230static MGVTBL sysfree_vtbl = {
231 0, 0, 0, 0, sysfree_free
232};
233
234/*****************************************************************************/
235
236/* helper: set scalar to foreign ptr with custom free */
237static void
238sv_set_foreign (SV *sv, const MGVTBL *const vtbl, void *addr, IV length)
239{
240 sv_force_normal (sv);
241
242 /* we store the length in mg_obj, as namlen is I32 :/ */
243 sv_magicext (sv, 0, FOREIGN_MAGIC, vtbl, (char *)addr, 0)
244 ->mg_obj = (SV *)length;
245
246 SvUPGRADE (sv, SVt_PV); /* nop... */
247
248 if (SvLEN (sv))
249 Safefree (SvPVX (sv));
250
251 SvPVX (sv) = (char *)addr;
252 SvCUR_set (sv, length);
253 SvLEN_set (sv, 0);
254 SvPOK_only (sv);
255}
256
257static void
258sv_clear_foreign (SV *sv)
259{
260 /* todo: iterate over magic and only free ours, but of course */
261 /* the perl5porters will call that (correct) behaviour buggy */
262 sv_unmagic (sv, FOREIGN_MAGIC);
263}
264
265/*****************************************************************************/
266
176static void 267static void
177fiemap (eio_req *req) 268fiemap (eio_req *req)
178{ 269{
179 req->result = -1; 270 req->result = -1;
180 271
… …
597 SvSETMAGIC (req->sv2); 688 SvSETMAGIC (req->sv2);
598 PUSHs (sv_result); 689 PUSHs (sv_result);
599 } 690 }
600 break; 691 break;
601 692
693 case EIO_SLURP:
694 {
695 if (req->result >= 0)
696 {
697 /* if length was originally not known, we steal the malloc'ed memory */
698 if (req->flags & EIO_FLAG_PTR2_FREE)
699 {
700 req->flags &= ~EIO_FLAG_PTR2_FREE;
701 sv_set_foreign (req->sv2, &sysfree_vtbl, req->ptr2, req->result);
702 }
703 else
704 {
705 SvCUR_set (req->sv2, req->result);
706 *SvEND (req->sv2) = 0;
707 SvPOK_only (req->sv2);
708 }
709
710 SvSETMAGIC (req->sv2);
711 }
712
713 PUSHs (sv_result);
714 }
715 break;
716
602 case EIO_CUSTOM: 717 case EIO_CUSTOM:
603 if (req->feed == fiemap) 718 if (req->feed == fiemap)
604 { 719 {
605#if HAVE_FIEMAP 720#if HAVE_FIEMAP
606 if (!req->result) 721 if (!req->result)
… …
749 create_respipe (); 864 create_respipe ();
750 865
751 if (eio_init (want_poll, done_poll) < 0) 866 if (eio_init (want_poll, done_poll) < 0)
752 croak ("IO::AIO: unable to initialise eio library"); 867 croak ("IO::AIO: unable to initialise eio library");
753} 868}
754
755/*****************************************************************************/
756
757#if !_POSIX_MAPPED_FILES
758# define mmap(addr,length,prot,flags,fd,offs) EIO_ENOSYS ()
759# define munmap(addr,length) EIO_ENOSYS ()
760#endif
761
762#if !_POSIX_MEMORY_PROTECTION
763# define mprotect(addr,len,prot) EIO_ENOSYS ()
764#endif
765
766#define MMAP_MAGIC PERL_MAGIC_ext
767
768static int ecb_cold
769mmap_free (pTHX_ SV *sv, MAGIC *mg)
770{
771 int old_errno = errno;
772 munmap (mg->mg_ptr, (size_t)mg->mg_obj);
773 errno = old_errno;
774
775 mg->mg_obj = 0; /* just in case */
776
777 SvREADONLY_off (sv);
778
779 if (SvPVX (sv) != mg->mg_ptr)
780 croak ("ERROR: IO::AIO::mmap-mapped scalar changed location, detected");
781
782 SvCUR_set (sv, 0);
783 SvPVX (sv) = 0;
784 SvOK_off (sv);
785
786 return 0;
787}
788
789static MGVTBL mmap_vtbl = {
790 0, 0, 0, 0, mmap_free
791};
792 869
793/*****************************************************************************/ 870/*****************************************************************************/
794 871
795static SV * 872static SV *
796get_cb (SV *cb_sv) 873get_cb (SV *cb_sv)
… …
1738 1815
1739 REQ_SEND; 1816 REQ_SEND;
1740} 1817}
1741 1818
1742void 1819void
1820aio_slurp (SV *pathname, off_t offset, UV length, SV8 *data, SV *callback = &PL_sv_undef)
1821 PPCODE:
1822{
1823 char *svptr = 0;
1824
1825 sv_clear_foreign (data);
1826
1827 if (length) /* known length, directly read into scalar */
1828 {
1829 if (!SvPOK (data) || SvLEN (data) >= SvCUR (data))
1830 svptr = sv_grow (data, length + 1);
1831 else if (SvCUR (data) < length)
1832 croak ("length outside of scalar, and cannot grow");
1833 else
1834 svptr = SvPVbyte_nolen (data);
1835 }
1836
1837 {
1838 dREQ;
1839
1840 req->type = EIO_SLURP;
1841 req_set_path1 (req, pathname);
1842 req->offs = offset;
1843 req->size = length;
1844 req->sv2 = SvREFCNT_inc (data);
1845 req->ptr2 = svptr;
1846
1847 if (!SvREADONLY (data))
1848 {
1849 SvREADONLY_on (data);
1850 req->flags |= FLAG_SV2_RO_OFF;
1851 }
1852
1853 REQ_SEND;
1854 }
1855}
1856
1857void
1743aio_busy (double delay, SV *callback = &PL_sv_undef) 1858aio_busy (double delay, SV *callback = &PL_sv_undef)
1744 PPCODE: 1859 PPCODE:
1745{ 1860{
1746 dREQ; 1861 dREQ;
1747 1862
… …
1881 RETVAL 1996 RETVAL
1882 1997
1883void 1998void
1884mmap (SV *scalar, STRLEN length, int prot, int flags, SV *fh = &PL_sv_undef, off_t offset = 0) 1999mmap (SV *scalar, STRLEN length, int prot, int flags, SV *fh = &PL_sv_undef, off_t offset = 0)
1885 PPCODE: 2000 PPCODE:
1886 sv_unmagic (scalar, MMAP_MAGIC); 2001 sv_clear_foreign (scalar);
1887{ 2002{
1888 int fd = SvOK (fh) ? s_fileno_croak (fh, flags & PROT_WRITE) : -1; 2003 int fd = SvOK (fh) ? s_fileno_croak (fh, flags & PROT_WRITE) : -1;
1889 void *addr = (void *)mmap (0, length, prot, flags, fd, offset); 2004 void *addr = (void *)mmap (0, length, prot, flags, fd, offset);
1890 if (addr == (void *)-1) 2005 if (addr == (void *)-1)
1891 XSRETURN_NO; 2006 XSRETURN_NO;
1892 2007
1893 sv_force_normal (scalar); 2008 sv_set_foreign (scalar, &mmap_vtbl, addr, length);
1894
1895 /* we store the length in mg_obj, as namlen is I32 :/ */
1896 sv_magicext (scalar, 0, MMAP_MAGIC, &mmap_vtbl, (char *)addr, 0)
1897 ->mg_obj = (SV *)length;
1898
1899 SvUPGRADE (scalar, SVt_PV); /* nop... */
1900 2009
1901 if (!(prot & PROT_WRITE)) 2010 if (!(prot & PROT_WRITE))
1902 SvREADONLY_on (scalar); 2011 SvREADONLY_on (scalar);
1903 2012
1904 if (SvLEN (scalar))
1905 Safefree (SvPVX (scalar));
1906
1907 SvPVX (scalar) = (char *)addr;
1908 SvCUR_set (scalar, length);
1909 SvLEN_set (scalar, 0);
1910 SvPOK_only (scalar);
1911
1912 XSRETURN_YES; 2013 XSRETURN_YES;
1913} 2014}
1914 2015
1915void 2016void
1916munmap (SV *scalar) 2017munmap (SV *scalar)
1917 CODE: 2018 CODE:
1918 sv_unmagic (scalar, MMAP_MAGIC); 2019 sv_clear_foreign (scalar);
1919 2020
1920int 2021int
1921madvise (SV *scalar, STRLEN offset = 0, SV *length = &PL_sv_undef, IV advice_or_prot) 2022madvise (SV *scalar, STRLEN offset = 0, SV *length = &PL_sv_undef, IV advice_or_prot)
1922 ALIAS: 2023 ALIAS:
1923 mprotect = 1 2024 mprotect = 1

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines