text:
@article{IstatGeo2020,
  url = {https://www.istat.it/it/archivio/222527},
  year = {2020},
  title = {Confini delle unità amministrative a fini statistici al 1° Gennaio 2020},
  author={ISTAT}
}

@article{IstatPop2020,
  url = {http://demo.istat.it/pop2020/index_e.html},
  year = {2020},
  title = {Resident Population by Sex, Age and Marital Status},
  author={ISTAT}
}

@article{Hale2020,
  url = {https://www.bsg.ox.ac.uk/research/research-projects/oxford-covid-19-government-response-tracker},
  year = {2020},
  title = {Oxford COVID-19 Government Response Tracker},
  author = {Thomas Hale, Sam Webster, Anna Petherick, Toby Phillips, and Beatriz Kira},
  editor = {Blavatnik School of Government}
}

@article{Ajelli2010,
  doi = {10.1186/1471-2334-10-190},
  url = {https://doi.org/10.1186/1471-2334-10-190},
  year = {2010},
  month = jun,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {10},
  number = {1},
  author = {Marco Ajelli and Bruno Gon{\c{c}}alves and Duygu Balcan and Vittoria Colizza and Hao Hu and Jos{\'{e}} J Ramasco and Stefano Merler and Alessandro Vespignani},
  title = {Comparing large-scale computational approaches to epidemic modeling: Agent-based versus structured metapopulation models},
  journal = {{BMC} Infectious Diseases}
}

@article{Mossong2008,
  doi = {10.1371/journal.pmed.0050074},
  url = {https://doi.org/10.1371/journal.pmed.0050074},
  year = {2008},
  month = mar,
  publisher = {Public Library of Science ({PLoS})},
  volume = {5},
  number = {3},
  pages = {e74},
  author = {Joël Mossong and Niel Hens and Mark Jit and Philippe Beutels and Kari Auranen and Rafael Mikolajczyk and Marco Massari and Stefania Salmaso and Gianpaolo Scalia Tomba and Jacco Wallinga and Janneke Heijne and Malgorzata Sadkowska-Todys and Magdalena Rosinska and W. John Edmunds},
  editor = {Steven Riley},
  title = {Social Contacts and Mixing Patterns Relevant to the Spread of Infectious Diseases},
  journal = {{PLoS} Medicine}
}

@article{Prem2017,
  doi = {10.1371/journal.pcbi.1005697},
  url = {https://doi.org/10.1371/journal.pcbi.1005697},
  year = {2017},
  month = sep,
  publisher = {Public Library of Science ({PLoS})},
  volume = {13},
  number = {9},
  pages = {e1005697},
  author = {Kiesha Prem and Alex R. Cook and Mark Jit},
  editor = {Betz Halloran},
  title = {Projecting social contact matrices in 152 countries using contact surveys and demographic data},
  journal = {{PLOS} Computational Biology}
}

@article{Prem2020,
  doi = {10.1101/2020.07.22.20159772},
  url = {https://doi.org/10.1101/2020.07.22.20159772},
  year = {2020},
  month = jul,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Kiesha Prem and Kevin van Zandvoort and Petra Klepac and Rosalind M Eggo and Nicholas G Davies and Alex R Cook and Mark Jit and},
  title = {Projecting contact matrices in 177 geographical regions: an update and comparison with empirical data for the {COVID}-19 era}
}

@article{Pepe2020,
  doi = {10.1038/s41597-020-00575-2},
  url = {https://doi.org/10.1038/s41597-020-00575-2},
  year = {2020},
  month = jul,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {7},
  number = {1},
  author = {Emanuele Pepe and Paolo Bajardi and Laetitia Gauvin and Filippo Privitera and Brennan Lake and Ciro Cattuto and Michele Tizzoni},
  title = {{COVID}-19 outbreak response,  a dataset to assess mobility changes in Italy following national lockdown},
  journal = {Scientific Data}
}

@article{Stites2020,
  doi = {10.1016/j.medj.2020.08.001},
  url = {https://doi.org/10.1016/j.medj.2020.08.001},
  year = {2020},
  month = aug,
  publisher = {Elsevier {BV}},
  author = {Edward C. Stites and Craig B. Wilen},
  title = {The Interpretation of {SARS}-{CoV}-2 Diagnostic Tests},
  journal = {Med}
}

@article{Sethuraman2020,
  doi = {10.1001/jama.2020.8259},
  url = {https://doi.org/10.1001/jama.2020.8259},
  year = {2020},
  month = jun,
  publisher = {American Medical Association ({AMA})},
  volume = {323},
  number = {22},
  pages = {2249},
  author = {Nandini Sethuraman and Sundararaj Stanleyraj Jeremiah and Akihide Ryo},
  title = {Interpreting Diagnostic Tests for {SARS}-{CoV}-2},
  journal = {{JAMA}}
}

@article{Hanson2020,
  doi = {10.1093/cid/ciaa508},
  url = {https://doi.org/10.1093/cid/ciaa508},
  year = {2020},
  month = may,
  publisher = {Oxford University Press ({OUP})},
  author = {Kimberly E Hanson and Marwan M Azar and Ritu Banerjee and Andrew Chou and Robert C Colgrove and Christine C Ginocchio and Mary K Hayden and Mark Holodiny and Seema Jain and Sophia Koo and Jaclyn Levy and Tristan T Timbrook and Angela M Caliendo},
  title = {Molecular Testing for Acute Respiratory Tract Infections: Clinical and Diagnostic Recommendations From the {IDSA}'s Diagnostics Committee},
  journal = {Clinical Infectious Diseases}
}

@article{Woloshin2020,
  doi = {10.1056/nejmp2015897},
  url = {https://doi.org/10.1056/nejmp2015897},
  year = {2020},
  month = aug,
  publisher = {Massachusetts Medical Society},
  volume = {383},
  number = {6},
  pages = {e38},
  author = {Steven Woloshin and Neeraj Patel and Aaron S. Kesselheim},
  title = {False Negative Tests for {SARS}-{CoV}-2 Infection {\textemdash} Challenges and Implications},
  journal = {New England Journal of Medicine}
}

@article{Wyllie2020,
  doi = {10.1056/nejmc2016359},
  url = {https://doi.org/10.1056/nejmc2016359},
  year = {2020},
  month = aug,
  publisher = {Massachusetts Medical Society},
  author = {Anne L. Wyllie and John Fournier and Arnau Casanovas-Massana and Melissa Campbell and Maria Tokuyama and Pavithra Vijayakumar and Joshua L. Warren and Bertie Geng and M. Catherine Muenker and Adam J. Moore and Chantal B.F. Vogels and Mary E. Petrone and Isabel M. Ott and Peiwen Lu and Arvind Venkataraman and Alice Lu-Culligan and Jonathan Klein and Rebecca Earnest and Michael Simonov and Rupak Datta and Ryan Handoko and Nida Naushad and Lorenzo R. Sewanan and Jordan Valdez and Elizabeth B. White and Sarah Lapidus and Chaney C. Kalinich and Xiaodong Jiang and Daniel J. Kim and Eriko Kudo and Melissa Linehan and Tianyang Mao and Miyu Moriyama and Ji E. Oh and Annsea Park and Julio Silva and Eric Song and Takehiro Takahashi and Manabu Taura and Orr-El Weizman and Patrick Wong and Yexin Yang and Santos Bermejo and Camila D. Odio and Saad B. Omer and Charles S. Dela Cruz and Shelli Farhadian and Richard A. Martinello and Akiko Iwasaki and Nathan D. Grubaugh and Albert I. Ko},
  title = {Saliva or Nasopharyngeal Swab Specimens for Detection of {SARS}-{CoV}-2},
  journal = {New England Journal of Medicine}
}

@article{LisboaBastos2020,
  doi = {10.1136/bmj.m2516},
  url = {https://doi.org/10.1136/bmj.m2516},
  year = {2020},
  month = jul,
  publisher = {{BMJ}},
  pages = {m2516},
  author = {Mayara Lisboa Bastos and Gamuchirai Tavaziva and Syed Kunal Abidi and Jonathon R Campbell and Louis-Patrick Haraoui and James C Johnston and Zhiyi Lan and Stephanie Law and Emily MacLean and Anete Trajman and Dick Menzies and Andrea Benedetti and Faiz Ahmad Khan},
  title = {Diagnostic accuracy of serological tests for covid-19: systematic review and meta-analysis},
  journal = {{BMJ}}
}

@article{Kucirka2020,
  doi = {10.7326/m20-1495},
  url = {https://doi.org/10.7326/m20-1495},
  year = {2020},
  month = aug,
  publisher = {American College of Physicians},
  volume = {173},
  number = {4},
  pages = {262--267},
  author = {Lauren M. Kucirka and Stephen A. Lauer and Oliver Laeyendecker and Denali Boon and Justin Lessler},
  title = {Variation in False-Negative Rate of Reverse Transcriptase Polymerase Chain Reaction{\textendash}Based {SARS}-{CoV}-2 Tests by Time Since Exposure},
  journal = {Annals of Internal Medicine}
}

@article{Davies2020,
  doi = {10.1038/s41591-020-0962-9},
  url = {https://doi.org/10.1038/s41591-020-0962-9},
  year = {2020},
  month = jun,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {26},
  number = {8},
  pages = {1205--1211},
  author = {Nicholas G. Davies and   and Petra Klepac and Yang Liu and Kiesha Prem and Mark Jit and Rosalind M. Eggo},
  title = {Age-dependent effects in the transmission and control of {COVID}-19 epidemics},
  journal = {Nature Medicine}
}

@article{Prem2020,
  doi = {10.1101/2020.07.22.20159772},
  url = {https://doi.org/10.1101/2020.07.22.20159772},
  year = {2020},
  month = jul,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Kiesha Prem and Kevin van Zandvoort and Petra Klepac and Rosalind M Eggo and Nicholas G Davies and Alex R Cook and Mark Jit and},
  title = {Projecting contact matrices in 177 geographical regions: an update and comparison with empirical data for the {COVID}-19 era}
}

@article{Khalili2020,
  doi = {10.1017/s0950268820001430},
  url = {https://doi.org/10.1017/s0950268820001430},
  year = {2020},
  publisher = {Cambridge University Press ({CUP})},
  volume = {148},
  author = {Malahat Khalili and Mohammad Karamouzian and Naser Nasiri and Sara Javadi and Ali Mirzazadeh and Hamid Sharifi},
  title = {Epidemiological characteristics of {COVID}-19: a systematic review and meta-analysis},
  journal = {Epidemiology and Infection}
}

@article{VanVinhChau2020,
  doi = {10.1093/cid/ciaa711},
  url = {https://doi.org/10.1093/cid/ciaa711},
  year = {2020},
  month = jun,
  publisher = {Oxford University Press ({OUP})},
  author = {Nguyen Van Vinh Chau and Vo Thanh Lam and Nguyen Thanh Dung and Lam Minh Yen and Ngo Ngoc Quang Minh and Le Manh Hung and Nghiem My Ngoc and Nguyen Tri Dung and Dinh Nguyen Huy Man and Lam Anh Nguyet and Le Thanh Hoang Nhat and Le Nguyen Truc Nhu and Nguyen Thi Han Ny and Nguyen Thi Thu Hong and Evelyne Kestelyn and Nguyen Thi Phuong Dung and Tran Chanh Xuan and Tran Tinh Hien and Nguyen Thanh Phong and Tran Nguyen Hoang Tu and Ronald B Geskus and Tran Tan Thanh and Nguyen Thanh Truong and Nguyen Tan Binh and Tang Chi Thuong and Guy Thwaites and Le Van Tan and Nguyen Van Vinh Chau and Nguyen Thanh Dung and Le Manh Hung and Huynh Thi Loan and Nguyen Thanh Truong and Nguyen Thanh Phong and Dinh Nguyen Huy Man and Nguyen Van Hao and Duong Bich Thuy and Nghiem My Ngoc and Nguyen Phu Huong Lan and Pham Thi Ngoc Thoa and Tran Nguyen Phuong Thao and Tran Thi Lan Phuong and Le Thi Tam Uyen and Tran Thi Thanh Tam and Bui Thi Ton That and Huynh Kim Nhung and Ngo Tan Tai and Tran Nguyen Hoang Tu and Vo Trong Vuong and Dinh Thi Bich Ty and Le Thi Dung and Thai Lam Uyen and Nguyen Thi My Tien and Ho Thi Thu Thao and Nguyen Ngoc Thao and Huynh Ngoc Thien Vuong and Pham Ngoc Phuong Thao and Phan Minh Phuong and Dong Thi Hoai Tam and Evelyne Kestelyn and Donovan Joseph and Ronald Geskus and Guy Thwaites and H Rogier van Doorn and Ho Van Hien and Huynh Le Anh Huy and Huynh Ngan Ha and Huynh Xuan Yen and Jennifer Van Nuil and Jeremy Day and Joseph Donovan and Katrina Lawson and Lam Anh Nguyet and Lam Minh Yen and Le Nguyen Truc Nhu and Le Thanh Hoang Nhat and Le Van Tan and Sonia Lewycka Odette and Louise Thwaites and Maia Rabaa and Marc Choisy and Mary Chambers and Motiur Rahman and Ngo Thi Hoa and Nguyen Thanh Thuy Nhien and Nguyen Thi Han Ny and Nguyen Thi Kim Tuyen and Nguyen Thi Phuong Dung and Nguyen Thi Thu Hong and Nguyen Xuan Truong and Phan Nguyen Quoc Khanh and Phung Le Kim Yen and Sophie Yacoub and Thomas Kesteman and Nguyen Thuy Thuong Thuong and Tran Tan Thanh and Tran Tinh Hien and Vu Thi Ty Hang and Nguyen Tri Dung and Le Hong Nga and},
  title = {The Natural History and Transmission Potential of Asymptomatic Severe Acute Respiratory Syndrome Coronavirus 2 Infection},
  journal = {Clinical Infectious Diseases}
}

@article{Ferretti2020,
  doi = {10.1101/2020.09.04.20188516},
  url = {https://doi.org/10.1101/2020.09.04.20188516},
  year = {2020},
  month = sep,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Luca Ferretti and Alice Ledda and Chris Wymant and Lele Zhao and Virginia Ledda and Lucie Abeler- Dorner and Michelle Kendall and Anel Nurtay and Hao-Yuan Cheng and Ta-Chou Ng and Hsien-Ho Lin and Rob Hinch and Joanna Masel and A. Marm Kilpatrick and Christophe Fraser},
  title = {The timing of {COVID}-19 transmission}
}

@article{Poletti2020,
  doi = {10.2807/1560-7917.es.2020.25.31.2001383},
  url = {https://doi.org/10.2807/1560-7917.es.2020.25.31.2001383},
  year = {2020},
  month = aug,
  publisher = {European Centre for Disease Control and Prevention ({ECDC})},
  volume = {25},
  number = {31},
  author = {Piero Poletti and Marcello Tirani and Danilo Cereda and Filippo Trentini and Giorgio Guzzetta and Valentina Marziano and Sabrina Buoro and Simona Riboli and Lucia Crottogini and Raffaella Piccarreta and Alessandra Piatti and Giacomo Grasselli and Alessia Melegaro and Maria Gramegna and Marco Ajelli and Stefano Merler},
  title = {Age-specific {SARS}-{CoV}-2 infection fatality ratio and associated risk factors,  Italy,  February to April 2020},
  journal = {Eurosurveillance}
}

@misc{poletti2020probability,
    title={Probability of symptoms and critical disease after SARS-CoV-2 infection},
    author={Piero Poletti and Marcello Tirani and Danilo Cereda and Filippo Trentini and Giorgio Guzzetta and Giuliana Sabatino and Valentina Marziano and Ambra Castrofino and Francesca Grosso and Gabriele Del Castillo and Raffaella Piccarreta and ATS Lombardy COVID-19 Task Force and Aida Andreassi and Alessia Melegaro and Maria Gramegna and Marco Ajelli and Stefano Merler},
    year={2020},
    eprint={2006.08471},
    archivePrefix={arXiv},
    primaryClass={q-bio.PE}
}

@article{Levin2020,
  doi = {10.1101/2020.07.23.20160895},
  url = {https://doi.org/10.1101/2020.07.23.20160895},
  year = {2020},
  month = jul,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Andrew T Levin and Gideon Meyerowitz-Katz and Nana Owusu-Boaitey and Kensington B. Cochran and Seamus P. Walsh},
  title = {{ASSESSING} {THE} {AGE} {SPECIFICITY} {OF} {INFECTION} {FATALITY} {RATES} {FOR} {COVID}-19: {SYSTEMATIC} {REVIEW},  {META}-{ANALYSIS},  {AND} {PUBLIC} {POLICY} {IMPLICATIONS}}
}

@article{DesvarsLarrive2020,
  doi = {10.1038/s41597-020-00609-9},
  url = {https://doi.org/10.1038/s41597-020-00609-9},
  year = {2020},
  month = aug,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {7},
  number = {1},
  author = {Am{\'{e}}lie Desvars-Larrive and Elma Dervic and Nils Haug and Thomas Niederkrotenthaler and Jiaying Chen and Anna Di Natale and Jana Lasser and Diana S. Gliga and Alexandra Roux and Johannes Sorger and Abhijit Chakraborty and Alexandr Ten and Alija Dervic and Andrea Pacheco and Ania Jurczak and David Cserjan and Diana Lederhilger and Dominika Bulska and Dorontinë Berishaj and Erwin Flores Tames and Francisco S. {\'{A}}lvarez and Huda Takriti and Jan Korbel and Jenny Reddish and Joanna Grzyma{\l}a-Moszczy{\'{n}}ska and Johannes Stangl and Lamija Hadziavdic and Laura Stoeger and Leana Gooriah and Lukas Geyrhofer and Marcia R. Ferreira and Marta Bartoszek and Rainer Vierlinger and Samantha Holder and Simon Haberfellner and Verena Ahne and Viktoria Reisch and Vito D. P. Servedio and Xiao Chen and Xochilt Mar{\'{\i}}a Pocasangre-Orellana and Zuzanna Garncarek and David Garcia and Stefan Thurner},
  title = {A structured open dataset of government interventions in response to {COVID}-19},
  journal = {Scientific Data}
}

@article{Vespignani2020,
  doi = {10.1038/s42254-020-0178-4},
  url = {https://doi.org/10.1038/s42254-020-0178-4},
  year = {2020},
  month = may,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {2},
  number = {6},
  pages = {279--281},
  author = {Alessandro Vespignani and Huaiyu Tian and Christopher Dye and James O. Lloyd-Smith and Rosalind M. Eggo and Munik Shrestha and Samuel V. Scarpino and Bernardo Gutierrez and Moritz U. G. Kraemer and Joseph Wu and Kathy Leung and Gabriel M. Leung},
  title = {Modelling {COVID}-19},
  journal = {Nature Reviews Physics}
}

@article{Estrada2020,
  doi = {10.1016/j.physrep.2020.07.005},
  url = {https://doi.org/10.1016/j.physrep.2020.07.005},
  year = {2020},
  month = jul,
  publisher = {Elsevier {BV}},
  volume = {869},
  pages = {1--51},
  author = {Ernesto Estrada},
  title = {{COVID}-19 and {SARS}-{CoV}-2. Modeling the present,  looking at the future},
  journal = {Physics Reports}
}

@article{Bjrnstad2020,
  doi = {10.1038/s41592-020-0856-2},
  url = {https://doi.org/10.1038/s41592-020-0856-2},
  year = {2020},
  month = jun,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {17},
  number = {6},
  pages = {557--558},
  author = {Ottar N. Bj{\o}rnstad and Katriona Shea and Martin Krzywinski and Naomi Altman},
  title = {The {SEIRS} model for infectious disease dynamics},
  journal = {Nature Methods}
}

@article{Lloyd2004,
  doi = {10.1016/j.mbs.2003.09.003},
  url = {https://doi.org/10.1016/j.mbs.2003.09.003},
  year = {2004},
  month = mar,
  publisher = {Elsevier {BV}},
  volume = {188},
  number = {1-2},
  pages = {1--16},
  author = {Alun L Lloyd and Vincent A.A Jansen},
  title = {Spatiotemporal dynamics of epidemics: synchrony in metapopulation models},
  journal = {Mathematical Biosciences}
}

@article{Watts2005,
  doi = {10.1073/pnas.0501226102},
  url = {https://doi.org/10.1073/pnas.0501226102},
  year = {2005},
  month = jul,
  publisher = {Proceedings of the National Academy of Sciences},
  volume = {102},
  number = {32},
  pages = {11157--11162},
  author = {D. J. Watts and R. Muhamad and D. C. Medina and P. S. Dodds},
  title = {Multiscale,  resurgent epidemics in a hierarchical metapopulation model},
  journal = {Proceedings of the National Academy of Sciences}
}

@article{Colizza2008,
  doi = {10.1016/j.jtbi.2007.11.028},
  url = {https://doi.org/10.1016/j.jtbi.2007.11.028},
  year = {2008},
  month = apr,
  publisher = {Elsevier {BV}},
  volume = {251},
  number = {3},
  pages = {450--467},
  author = {Vittoria Colizza and Alessandro Vespignani},
  title = {Epidemic modeling in metapopulation systems with heterogeneous coupling pattern: Theory and simulations},
  journal = {Journal of Theoretical Biology}
}

@article{Balcan2009,
  doi = {10.1073/pnas.0906910106},
  url = {https://doi.org/10.1073/pnas.0906910106},
  year = {2009},
  month = dec,
  publisher = {Proceedings of the National Academy of Sciences},
  volume = {106},
  number = {51},
  pages = {21484--21489},
  author = {D. Balcan and V. Colizza and B. Goncalves and H. Hu and J. J. Ramasco and A. Vespignani},
  title = {Multiscale mobility networks and the spatial spreading of infectious diseases},
  journal = {Proceedings of the National Academy of Sciences}
}

@article{Balcan2010,
  doi = {10.1016/j.jocs.2010.07.002},
  url = {https://doi.org/10.1016/j.jocs.2010.07.002},
  year = {2010},
  month = aug,
  publisher = {Elsevier {BV}},
  volume = {1},
  number = {3},
  pages = {132--145},
  author = {Duygu Balcan and Bruno Gon{\c{c}}alves and Hao Hu and Jos{\'{e}} J. Ramasco and Vittoria Colizza and Alessandro Vespignani},
  title = {Modeling the spatial spread of infectious diseases: The {GLobal} Epidemic and Mobility computational model},
  journal = {Journal of Computational Science}
}

@article{Ross2010,
  doi = {10.1371/journal.pone.0009666},
  url = {https://doi.org/10.1371/journal.pone.0009666},
  year = {2010},
  month = mar,
  publisher = {Public Library of Science ({PLoS})},
  volume = {5},
  number = {3},
  pages = {e9666},
  author = {Joshua V. Ross and Thomas House and Matt J. Keeling},
  editor = {Mike B. Gravenor},
  title = {Calculation of Disease Dynamics in a Population of Households},
  journal = {{PLoS} {ONE}}
}

@article{Salath2010,
  doi = {10.1371/journal.pcbi.1000736},
  url = {https://doi.org/10.1371/journal.pcbi.1000736},
  year = {2010},
  month = apr,
  publisher = {Public Library of Science ({PLoS})},
  volume = {6},
  number = {4},
  pages = {e1000736},
  author = {Marcel Salath{\'{e}} and James H. Jones},
  editor = {Christophe Fraser},
  title = {Dynamics and Control of Diseases in Networks with Community Structure},
  journal = {{PLoS} Computational Biology}
}

@article{Apolloni2014,
  doi = {10.1186/1742-4682-11-3},
  url = {https://doi.org/10.1186/1742-4682-11-3},
  year = {2014},
  publisher = {Springer Science and Business Media {LLC}},
  volume = {11},
  number = {1},
  pages = {3},
  author = {Andrea Apolloni and Chiara Poletto and Jos{\'{e}} J Ramasco and Pablo Jensen and Vittoria Colizza},
  title = {Metapopulation epidemic models with heterogeneous mixing and travel behaviour},
  journal = {Theoretical Biology and Medical Modelling}
}

@article{Calvetti2020,
  doi = {10.3389/fphy.2020.00261},
  url = {https://doi.org/10.3389/fphy.2020.00261},
  year = {2020},
  month = jun,
  publisher = {Frontiers Media {SA}},
  volume = {8},
  author = {Daniela Calvetti and Alexander P. Hoover and Johnie Rose and Erkki Somersalo},
  title = {Metapopulation Network Models for Understanding,  Predicting,  and Managing the Coronavirus Disease {COVID}-19},
  journal = {Frontiers in Physics}
}

@article{Hassan2020,
  doi = {10.1101/2020.06.03.20121517},
  url = {https://doi.org/10.1101/2020.06.03.20121517},
  year = {2020},
  month = jun,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Sohaib Hassan and Bilal Javed Mughal and Marian Siwiak and Zafar Yasin},
  title = {A modified {SEIR} meta-population transmission based Modeling and Forecasting of the {COVID}-19 pandemic in Pakistan}
}

@article{Beckett2020,
  doi = {10.1101/2020.05.28.20115642},
  url = {https://doi.org/10.1101/2020.05.28.20115642},
  year = {2020},
  month = may,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Stephen J Beckett and Marian Dominguez-Mirazo and Seolha Lee and Clio Andris and Joshua S Weitz},
  title = {Spread of {COVID}-19 through Georgia,  {USA}. Near-term projections and impacts of social distancing via a metapopulation model}
}

@article{Hazelbag2020,
  doi = {10.1371/journal.pcbi.1007893},
  url = {https://doi.org/10.1371/journal.pcbi.1007893},
  year = {2020},
  month = may,
  publisher = {Public Library of Science ({PLoS})},
  volume = {16},
  number = {5},
  pages = {e1007893},
  author = {C. Marijn Hazelbag and Jonathan Dushoff and Emanuel M. Dominic and Zinhle E. Mthombothi and Wim Delva},
  editor = {Roger Dimitri Kouyos},
  title = {Calibration of individual-based models to epidemiological data: A systematic review},
  journal = {{PLOS} Computational Biology}
}

@article{Larremore2020,
  doi = {10.1101/2020.06.22.20136309},
  url = {https://doi.org/10.1101/2020.06.22.20136309},
  year = {2020},
  month = jun,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Daniel B Larremore and Bryan Wilder and Evan Lester and Soraya Shehata and James M Burke and James A Hay and Milind Tambe and Michael J Mina and Roy Parker},
  title = {Test sensitivity is secondary to frequency and turnaround time for {COVID}-19 surveillance}
}

@article{Liu2020,
  doi = {10.1101/2020.06.27.20141440},
  url = {https://doi.org/10.1101/2020.06.27.20141440},
  year = {2020},
  month = jun,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Yang Liu and Wenfeng Gong and Samuel Clifford and Maria E Sundaram and Mark Jit and Stefan Flasche and Petra Klepac and},
  title = {A Modelling Study for Designing a Multi-layered Surveillance Approach to Detect the Potential Resurgence of {SARS}-{CoV}-2}
}

@article{Sandmann2020,
  doi = {10.1093/cid/ciaa901},
  url = {https://doi.org/10.1093/cid/ciaa901},
  year = {2020},
  month = jul,
  publisher = {Oxford University Press ({OUP})},
  author = {Frank G Sandmann and Peter J White and Mary Ramsay and Mark Jit},
  title = {Optimizing Benefits of Testing Key Workers for Infection with {SARS}-{CoV}-2: A Mathematical Modeling Analysis},
  journal = {Clinical Infectious Diseases}
}

@article{Colman2019,
  doi = {10.1371/journal.pcbi.1007517},
  url = {https://doi.org/10.1371/journal.pcbi.1007517},
  year = {2019},
  month = nov,
  publisher = {Public Library of Science ({PLoS})},
  volume = {15},
  number = {11},
  pages = {e1007517},
  author = {Ewan Colman and Petter Holme and Hiroki Sayama and Carlos Gershenson},
  editor = {Daniela Paolotti},
  title = {Efficient sentinel surveillance strategies for preventing epidemics on networks},
  journal = {{PLOS} Computational Biology}
}

@article{Grassly2020,
  doi = {10.1016/s1473-3099(20)30630-7},
  url = {https://doi.org/10.1016/s1473-3099(20)30630-7},
  year = {2020},
  month = aug,
  publisher = {Elsevier {BV}},
  author = {Nicholas C Grassly and Margarita Pons-Salort and Edward P K Parker and Peter J White and Neil M Ferguson and Kylie Ainslie and Marc Baguelin and Samir Bhatt and Adhiratha Boonyasiri and Nick Brazeau and Lorenzo Cattarino and Helen Coupland and Zulma Cucunuba and Gina Cuomo-Dannenburg and Amy Dighe and Christl Donnelly and Sabine L van Elsland and Richard FitzJohn and Seth Flaxman and Keith Fraser and Katy Gaythorpe and Will Green and Arran Hamlet and Wes Hinsley and Natsuko Imai and Edward Knock and Daniel Laydon and Thomas Mellan and Swapnil Mishra and Gemma Nedjati-Gilani and Pierre Nouvellet and Lucy Okell and Manon Ragonnet-Cronin and Hayley A Thompson and H. Juliette T Unwin and Michaela Vollmer and Erik Volz and Caroline Walters and Yuanrong Wang and Oliver J Watson and Charles Whittaker and Lilith Whittles and Xiaoyue Xi},
  title = {Comparison of molecular testing strategies for {COVID}-19 control: a mathematical modelling study},
  journal = {The Lancet Infectious Diseases}
}

@article{Bergstrom2020,
  doi = {10.1101/2020.09.05.20188839},
  url = {https://doi.org/10.1101/2020.09.05.20188839},
  year = {2020},
  month = sep,
  publisher = {Cold Spring Harbor Laboratory},
  author = {Ted Bergstrom and Carl T. Bergstrom and Haoran Li},
  title = {Frequency and accuracy of proactive testing for {COVID}-19}
}

@article{Giordano2020,
  doi = {10.1038/s41591-020-0883-7},
  url = {https://doi.org/10.1038/s41591-020-0883-7},
  year = {2020},
  month = apr,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {26},
  number = {6},
  pages = {855--860},
  author = {Giulia Giordano and Franco Blanchini and Raffaele Bruno and Patrizio Colaneri and Alessandro Di Filippo and Angela Di Matteo and Marta Colaneri},
  title = {Modelling the {COVID}-19 epidemic and implementation of population-wide interventions in Italy},
  journal = {Nature Medicine}
}

@article{Gatto2020,
  doi = {10.1073/pnas.2004978117},
  url = {https://doi.org/10.1073/pnas.2004978117},
  year = {2020},
  month = apr,
  publisher = {Proceedings of the National Academy of Sciences},
  volume = {117},
  number = {19},
  pages = {10484--10491},
  author = {Marino Gatto and Enrico Bertuzzo and Lorenzo Mari and Stefano Miccoli and Luca Carraro and Renato Casagrandi and Andrea Rinaldo},
  title = {Spread and dynamics of the {COVID}-19 epidemic in Italy: Effects of emergency containment measures},
  journal = {Proceedings of the National Academy of Sciences}
}

@article{Bertuzzo2020,
  doi = {10.1038/s41467-020-18050-2},
  url = {https://doi.org/10.1038/s41467-020-18050-2},
  year = {2020},
  month = aug,
  publisher = {Springer Science and Business Media {LLC}},
  volume = {11},
  number = {1},
  author = {Enrico Bertuzzo and Lorenzo Mari and Damiano Pasetto and Stefano Miccoli and Renato Casagrandi and Marino Gatto and Andrea Rinaldo},
  title = {The geography of {COVID}-19 spread in Italy and implications for the relaxation of confinement measures},
  journal = {Nature Communications}
}

@article{Aleta2020,
  doi = {10.1038/s41562-020-0931-9},
  url = {https://doi.org/10.1038/s41562-020-0931-9},
  year = {2020},
  month = aug,
  publisher = {Springer Science and Business Media {LLC}},
  author = {Alberto Aleta and David Mart{\'{\i}}n-Corral and Ana Pastore y Piontti and Marco Ajelli and Maria Litvinova and Matteo Chinazzi and Natalie E. Dean and M. Elizabeth Halloran and Ira M. Longini Jr and Stefano Merler and Alex Pentland and Alessandro Vespignani and Esteban Moro and Yamir Moreno},
  title = {Modelling the impact of testing,  contact tracing and household quarantine on second waves of {COVID}-19},
  journal = {Nature Human Behaviour}
}

@article{Perra2011,
  doi = {10.1371/journal.pone.0023084},
  url = {https://doi.org/10.1371/journal.pone.0023084},
  year = {2011},
  month = aug,
  publisher = {Public Library of Science ({PLoS})},
  volume = {6},
  number = {8},
  pages = {e23084},
  author = {Nicola Perra and Duygu Balcan and Bruno Gon{\c{c}}alves and Alessandro Vespignani},
  editor = {C{\'{e}}cile Viboud},
  title = {Towards a Characterization of Behavior-Disease Models},
  journal = {{PLoS} {ONE}}
}

@article{Verelst2016,
  doi = {10.1098/rsif.2016.0820},
  url = {https://doi.org/10.1098/rsif.2016.0820},
  year = {2016},
  month = dec,
  publisher = {The Royal Society},
  volume = {13},
  number = {125},
  pages = {20160820},
  author = {Frederik Verelst and Lander Willem and Philippe Beutels},
  title = {Behavioural change models for infectious disease transmission: a systematic review (2010{\textendash}2015)},
  journal = {Journal of The Royal Society Interface}
}

@article{Granell2013,
  doi = {10.1103/physrevlett.111.128701},
  url = {https://doi.org/10.1103/physrevlett.111.128701},
  year = {2013},
  month = sep,
  publisher = {American Physical Society ({APS})},
  volume = {111},
  number = {12},
  author = {Clara Granell and Sergio G{\'{o}}mez and Alex Arenas},
  title = {Dynamical Interplay between Awareness and Epidemic Spreading in Multiplex Networks},
  journal = {Physical Review Letters}
}

@article{Massaro2014,
  doi = {10.1103/physreve.90.052817},
  url = {https://doi.org/10.1103/physreve.90.052817},
  year = {2014},
  month = nov,
  publisher = {American Physical Society ({APS})},
  volume = {90},
  number = {5},
  author = {Emanuele Massaro and Franco Bagnoli},
  title = {Epidemic spreading and risk perception in multiplex networks: A self-organized percolation method},
  journal = {Physical Review E}
}

@article{Abdulkareem2020,
  doi = {10.1371/journal.pone.0226483},
  url = {https://doi.org/10.1371/journal.pone.0226483},
  year = {2020},
  month = jan,
  publisher = {Public Library of Science ({PLoS})},
  volume = {15},
  number = {1},
  pages = {e0226483},
  author = {Shaheen A. Abdulkareem and Ellen-Wien Augustijn and Tatiana Filatova and Katarzyna Musial and Yaseen T. Mustafa},
  editor = {Chiara Poletto},
  title = {Risk perception and behavioral change during epidemics: Comparing models of individual and collective learning},
  journal = {{PLOS} {ONE}}
}

@article{Hunter2018,
  doi = {10.1371/journal.pone.0208775},
  url = {https://doi.org/10.1371/journal.pone.0208775},
  year = {2018},
  month = dec,
  publisher = {Public Library of Science ({PLoS})},
  volume = {13},
  number = {12},
  pages = {e0208775},
  author = {Elizabeth Hunter and Brian Mac Namee and John Kelleher},
  editor = {Yury E Khudyakov},
  title = {An open-data-driven agent-based model to simulate infectious disease outbreaks},
  journal = {{PLOS} {ONE}}
}

@article{Biggerstaff2020,
  doi = {10.3201/eid2611.201074},
  url = {https://doi.org/10.3201/eid2611.201074},
  year = {2020},
  month = nov,
  publisher = {Centers for Disease Control and Prevention ({CDC})},
  volume = {26},
  number = {11},
  author = {Matthew Biggerstaff and Benjamin J. Cowling and Zulma M. Cucunub{\'{a}} and Linh Dinh and Neil M. Ferguson and Huizhi Gao and Verity Hill and Natsuko Imai and Michael A. Johansson and Sarah Kada and Oliver Morgan and Ana Pastore y Piontti and Jonathan A. Polonsky and Pragati Venkata Prasad and Talia M. Quandelacy and Andrew Rambaut and Jordan W. Tappero and Katelijn A. Vandemaele and Alessandro Vespignani and K. Lane Warmbrod and Jessica Y. Wong and},
  title = {Early Insights from Statistical and Mathematical Modeling of Key Epidemiologic Parameters of {COVID}-19},
  journal = {Emerging Infectious Diseases}
}

repository: pitmonticone/EpiSimulator

repo_name: pitmonticone/EpiSimulator

extension: bibtex


text:
PR = "r2"
TOOLCHAIN_TARGET_TASK = "\
    task-sdk-base \
    task-sdk-sbox \
    task-sdk-sbox-gpe \
    task-sdk-x11 \
    task-sdk-x11-ext \
    task-sdk-gpe"

require meta-toolchain.bb

SDK_SUFFIX = "toolchain-gpe-sbox"

license: MIT

repository: overo/overo-oe-natty

license_type: permissive

repo_name: overo/overo-oe-natty

branch_name: HEAD

extension: bb


text:
SECTION = "devel/chicken"
DESCRIPTION = "A library to parse and unparse Ethernet frames"
LICENSE = "BSD"
LIC_FILES_CHKSUM = "file://ethernet.meta;md5=d30ae29b51c53d4b18de393e8b9510eb"
DEPENDS_append_class-cross = " chicken-egg-defstruct-cross"
DEPENDS_append_class-crosssdk = " chicken-egg-defstruct-crosssdk"
DEPENDS_append_class-nativesdk = " nativesdk-chicken-egg-defstruct chicken-egg-defstruct-crosssdk"
DEPENDS = " chicken-egg-defstruct chicken-egg-defstruct-cross"
RDEPENDS_${PN} = " chicken-egg-defstruct"

SRC_URI = "http://code.call-cc.org/egg-tarballs/4/ethernet/ethernet-${PV}.tar.gz"

SRC_URI[md5sum] = "9c8d7f32aef68bbd8b649ea4e1df286b"
SRC_URI[sha256sum] = "030d8e526750d11593efd7ec61d3f3c0506b482b8d628c0644c549c6ff186795"

S = "${WORKDIR}/ethernet-${PV}"

inherit chicken_install

BBCLASSEXTEND = "cross crosssdk nativesdk"

repository: OSSystems/meta-chicken

repo_name: OSSystems/meta-chicken

branch_name: refs/heads/master


text:
package common

import (
	"log"
	"os"
	"testing"
)

// 获取部门列表
func TestDingDing_ListDepartment(t *testing.T) {

	ding := DingDing{
		AgentId:     0,
		AppKey:      os.Getenv("DINGDING_APP_KEY"),
		AppSecret:   os.Getenv("DINGDING_APP_SECRET"),
		AccessToken: "",
	}

	if departments, err := ding.ListDepartment(); err != nil {
		t.Error(err.Error())
		return
	} else {
		log.Println("获取到部门的长度是：", len(departments))
		for _, department := range departments {
			log.Println(department)
		}
	}
}

func TestDingDing_GetDepartmentUserList(t *testing.T) {
	ding := DingDing{
		AgentId:     0,
		AppKey:      os.Getenv("DINGDING_APP_KEY"),
		AppSecret:   os.Getenv("DINGDING_APP_SECRET"),
		AccessToken: "",
	}
	//departmentId := 118434421
	if departments, err := ding.ListDepartment(); err != nil {
		t.Error(err.Error())
		return
	} else {
		log.Println("获取到部门的长度是：", len(departments))
		for _, department := range departments {
			log.Println(department)
			//	获取部门用户
			if userList, err := ding.GetDepartmentUserList(department.ID, 0, 10); err != nil {
				t.Error(err.Error())
				return
			} else {
				log.Printf("部门：%s，获取到用户%d个\n", department.Name, len(userList))
				for _, user := range userList {
					log.Println(user)
				}
			}
		}
	}

}

repository: codelieche/cronjob

repo_name: codelieche/cronjob

gha_license_id: MIT

gha_language: Go

extension: go


text:
SUMMARY = "A collection of configuration plugins used in cinnamon-settings"
LICENSE = "GPL-2.0-only"
LIC_FILES_CHKSUM = "file://COPYING;md5=75859989545e37968a99b631ef42722e"

DEPENDS = " \
    colord \
    libgnomekbd \
    libxklavier \
    libnotify \
    iso-codes \
    polkit \
    libnma \
    modemmanager \
    pulseaudio \
    gnome-online-accounts \
    cinnamon-desktop \
    cinnamon-menus \
"
inherit meson pkgconfig features_check gtk-icon-cache gettext gsettings

REQUIRED_DISTRO_FEATURES += "polkit pulseaudio x11"

SRC_URI = "git://github.com/linuxmint/cinnamon-control-center.git;branch=master;protocol=https"
SRCREV = "30728a0a142ac0deffde5267263c3b345f1c6556"
PV = "5.2.1+git${SRCPV}"
S = "${WORKDIR}/git"

EXTRA_OEMESON += " \
    -Dwacom=false \
"

FILES:${PN} += "${libdir}/cinnamon-control-center-1/panels"

repository: schnitzeltony/meta-gnome-forks

repo_name: schnitzeltony/meta-gnome-forks


text:
DESCRIPTION = "libjpeg is a library for handling the JPEG (JFIF) image format."
LICENSE = "jpeg"
SECTION = "libs"
PRIORITY = "required"
PR = "r1"

# TODO: really needed?
RPROVIDES_${PN} = "jpeg"

SRC_URI = "\
    http://www.ijg.org/files/jpegsrc.v${PV}.tar.gz \
    "
S = "${WORKDIR}/jpeg-${PV}"

inherit autotools

EXTRA_OECONF = "--enable-static --enable-shared"
CFLAGS_append = " -D_REENTRANT"

PACKAGES =+ "${PN}-tools "
FILES_${PN}-tools = "${bindir}/*"

BBCLASSEXTEND = "native"

SRC_URI[md5sum] = "a2c10c04f396a9ce72894beb18b4e1f9"
SRC_URI[sha256sum] = "edfc0b3e004b2fe58ffeeec89f96e3a3c28972c46725ec127d01edf8a1cc7c9a"

gha_language: C


text:
### the directory name
set(directory include/OpenMS/COMPARISON/SPECTRA)

### list all header files of the directory here
set(sources_list_h
BinnedSharedPeakCount.h
BinnedSpectralContrastAngle.h
BinnedSpectrum.h
BinnedSpectrumCompareFunctor.h
BinnedSumAgreeingIntensities.h
PeakAlignment.h
PeakSpectrumCompareFunctor.h
SpectraSTSimilarityScore.h
SpectrumAlignment.h
SpectrumAlignmentScore.h
SpectrumCheapDPCorr.h
SpectrumPrecursorComparator.h
SteinScottImproveScore.h
ZhangSimilarityScore.h
)

### add path to the filenames
set(sources_h)
foreach(i ${sources_list_h})
	list(APPEND sources_h ${directory}/${i})
endforeach(i)

### source group definition
source_group("Header Files\\OpenMS\\COMPARISON\\SPECTRA" FILES ${sources_h})

set(OpenMS_sources_h ${OpenMS_sources_h} ${sources_h})

repository: OpenMS/OpenMS

repo_name: OpenMS/OpenMS

branch_name: refs/heads/develop

gha_license_id: NOASSERTION

extension: cmake


text:
// Code generated by go-swagger; DO NOT EDIT.

// Copyright 2017-2020 Authors of Cilium
// SPDX-License-Identifier: Apache-2.0

package storage_v1

// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the generate command

import (
	"net/http"

	"github.com/go-openapi/runtime/middleware"
)

// PatchStorageV1CSIDriverHandlerFunc turns a function with the right signature into a patch storage v1 c s i driver handler
type PatchStorageV1CSIDriverHandlerFunc func(PatchStorageV1CSIDriverParams) middleware.Responder

// Handle executing the request and returning a response
func (fn PatchStorageV1CSIDriverHandlerFunc) Handle(params PatchStorageV1CSIDriverParams) middleware.Responder {
	return fn(params)
}

// PatchStorageV1CSIDriverHandler interface for that can handle valid patch storage v1 c s i driver params
type PatchStorageV1CSIDriverHandler interface {
	Handle(PatchStorageV1CSIDriverParams) middleware.Responder
}

// NewPatchStorageV1CSIDriver creates a new http.Handler for the patch storage v1 c s i driver operation
func NewPatchStorageV1CSIDriver(ctx *middleware.Context, handler PatchStorageV1CSIDriverHandler) *PatchStorageV1CSIDriver {
	return &PatchStorageV1CSIDriver{Context: ctx, Handler: handler}
}

/*PatchStorageV1CSIDriver swagger:route PATCH /apis/storage.k8s.io/v1/csidrivers/{name} storage_v1 patchStorageV1CSIDriver

partially update the specified CSIDriver

*/
type PatchStorageV1CSIDriver struct {
	Context *middleware.Context
	Handler PatchStorageV1CSIDriverHandler
}

func (o *PatchStorageV1CSIDriver) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
	route, rCtx, _ := o.Context.RouteInfo(r)
	if rCtx != nil {
		r = rCtx
	}
	var Params = NewPatchStorageV1CSIDriverParams()

	if err := o.Context.BindValidRequest(r, route, &Params); err != nil { // bind params
		o.Context.Respond(rw, r, route.Produces, route, err)
		return
	}

	res := o.Handler.Handle(Params) // actually handle the request

	o.Context.Respond(rw, r, route.Produces, route, res)

}

repository: cilium/kube-apate

repo_name: cilium/kube-apate

branch_name: refs/heads/main


text:
require tangogps.inc

SRC_URI[archive.md5sum] = "0f07ede94a21eb84f5e017fa88a1fc3d"
SRC_URI[archive.sha256sum] = "660fdf89ef3c379f2fc0c2a9d0c9d3bfa5345835786b72bf9f513ba9ec2c812a"


text:
/*
Copyright 2022 The Kubernetes Authors.

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

    http://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.
*/

package actuation

import (
	"fmt"
	"testing"
	"time"

	apiv1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/runtime"
	testprovider "k8s.io/autoscaler/cluster-autoscaler/cloudprovider/test"
	"k8s.io/autoscaler/cluster-autoscaler/clusterstate"
	clusterstate_utils "k8s.io/autoscaler/cluster-autoscaler/clusterstate/utils"
	"k8s.io/autoscaler/cluster-autoscaler/config"
	"k8s.io/autoscaler/cluster-autoscaler/core/scaledown/deletiontracker"
	. "k8s.io/autoscaler/cluster-autoscaler/core/test"
	"k8s.io/autoscaler/cluster-autoscaler/processors/nodegroupconfig"
	"k8s.io/autoscaler/cluster-autoscaler/utils/taints"
	"k8s.io/client-go/kubernetes/fake"
	core "k8s.io/client-go/testing"
	kube_record "k8s.io/client-go/tools/record"
)

func TestAddNodeToBucket(t *testing.T) {
	provider := testprovider.NewTestCloudProvider(nil, nil)
	ctx, err := NewScaleTestAutoscalingContext(config.AutoscalingOptions{}, nil, nil, provider, nil, nil)
	if err != nil {
		t.Fatalf("Couldn't set up autoscaling context: %v", err)
	}
	nodeGroup1 := "ng-1"
	nodeGroup2 := "ng-2"
	nodes1 := generateNodes(0, 5, "ng-1")
	nodes2 := generateNodes(0, 5, "ng-2")
	provider.AddNodeGroup(nodeGroup1, 1, 10, 5)
	provider.AddNodeGroup(nodeGroup2, 1, 10, 5)
	for _, node := range nodes1 {
		provider.AddNode(nodeGroup1, node)
	}
	for _, node := range nodes2 {
		provider.AddNode(nodeGroup2, node)
	}
	testcases := []struct {
		name        string
		nodes       []*apiv1.Node
		wantBatches int
		drained     bool
	}{
		{
			name:        "Add 1 node",
			nodes:       []*apiv1.Node{nodes1[0]},
			wantBatches: 1,
		},
		{
			name:        "Add nodes that belong to one nodeGroup",
			nodes:       nodes1,
			wantBatches: 1,
		},
		{
			name:        "Add 3 nodes that belong to 2 nodeGroups",
			nodes:       []*apiv1.Node{nodes1[0], nodes2[0], nodes2[1]},
			wantBatches: 2,
		},
		{
			name:        "Add 3 nodes that belong to 2 nodeGroups, all nodes are drained",
			nodes:       []*apiv1.Node{nodes1[0], nodes2[0], nodes2[1]},
			wantBatches: 2,
			drained:     true,
		},
	}
	for _, test := range testcases {
		d := NodeDeletionBatcher{
			ctx:                   &ctx,
			clusterState:          nil,
			nodeDeletionTracker:   nil,
			deletionsPerNodeGroup: make(map[string][]*apiv1.Node),
			drainedNodeDeletions:  make(map[string]bool),
		}
		batchCount := 0
		for _, node := range test.nodes {
			nodeGroup, err := provider.NodeGroupForNode(node)
			if err != nil {
				t.Errorf("couldn't get node info for node %s: %s", node.Name, err)
			}
			first := d.addNodesToBucket([]*apiv1.Node{node}, nodeGroup, test.drained)
			if first {
				batchCount += 1
			}
		}
		if batchCount != test.wantBatches {
			t.Errorf("Want %d batches, got %d batches", test.wantBatches, batchCount)
		}

	}
}

func TestRemove(t *testing.T) {
	testCases := []struct {
		name           string
		err            bool
		numNodes       int
		failedDeletion int
		addNgToBucket  bool
	}{
		{
			name:          "Remove NodeGroup that is not present in bucket",
			err:           true,
			addNgToBucket: false,
		},
		{
			name:           "Regular successful remove",
			err:            false,
			numNodes:       5,
			failedDeletion: 0,
			addNgToBucket:  true,
		},
		{
			name:           "Unsuccessful remove",
			numNodes:       5,
			failedDeletion: 1,
			addNgToBucket:  true,
		},
	}
	for _, test := range testCases {
		t.Run(test.name, func(t *testing.T) {
			test := test
			fakeClient := &fake.Clientset{}
			fakeLogRecorder, _ := clusterstate_utils.NewStatusMapRecorder(fakeClient, "kube-system", kube_record.NewFakeRecorder(5), false, "my-cool-configmap")

			failedNodeDeletion := make(map[string]bool)
			deletedNodes := make(chan string, 10)
			notDeletedNodes := make(chan string, 10)
			// Hook node deletion at the level of cloud provider, to gather which nodes were deleted, and to fail the deletion for
			// certain nodes to simulate errors.
			provider := testprovider.NewTestCloudProvider(nil, func(nodeGroup string, node string) error {
				if failedNodeDeletion[node] {
					notDeletedNodes <- node
					return fmt.Errorf("SIMULATED ERROR: won't remove node")
				}
				deletedNodes <- node
				return nil
			})

			fakeClient.Fake.AddReactor("update", "nodes",
				func(action core.Action) (bool, runtime.Object, error) {
					update := action.(core.UpdateAction)
					obj := update.GetObject().(*apiv1.Node)
					return true, obj, nil
				})

			ctx, err := NewScaleTestAutoscalingContext(config.AutoscalingOptions{}, fakeClient, nil, provider, nil, nil)
			clusterStateRegistry := clusterstate.NewClusterStateRegistry(provider, clusterstate.ClusterStateRegistryConfig{}, fakeLogRecorder, NewBackoff(), nodegroupconfig.NewDefaultNodeGroupConfigProcessor(config.NodeGroupAutoscalingOptions{MaxNodeProvisionTime: 15 * time.Minute}))
			if err != nil {
				t.Fatalf("Couldn't set up autoscaling context: %v", err)
			}

			ng := "ng"
			provider.AddNodeGroup(ng, 1, 10, test.numNodes)
			nodeGroup := provider.GetNodeGroup(ng)

			d := NodeDeletionBatcher{
				ctx:                   &ctx,
				clusterState:          clusterStateRegistry,
				nodeDeletionTracker:   deletiontracker.NewNodeDeletionTracker(1 * time.Minute),
				deletionsPerNodeGroup: make(map[string][]*apiv1.Node),
				drainedNodeDeletions:  make(map[string]bool),
			}
			nodes := generateNodes(0, test.numNodes, ng)
			failedDeletion := test.failedDeletion
			for _, node := range nodes {
				if failedDeletion > 0 {
					failedNodeDeletion[node.Name] = true
					failedDeletion -= 1
				}
				provider.AddNode(ng, node)
			}
			if test.addNgToBucket {
				for _, node := range nodes {
					node.Spec.Taints = append(node.Spec.Taints, apiv1.Taint{
						Key:    taints.ToBeDeletedTaint,
						Effect: apiv1.TaintEffectNoSchedule,
					})
					d.addNodesToBucket([]*apiv1.Node{node}, nodeGroup, true)
				}
			}

			err = d.remove(nodeGroup.Id())
			if test.err {
				if err == nil {
					t.Errorf("remove() should return error, but return nil")
				}
				return
			}
			if err != nil {
				t.Errorf("remove() return error, but shouldn't")
			}
			if test.failedDeletion == 0 {
				gotDeletedNodes := []string{}
				for i := 0; i < test.numNodes; i++ {
					select {
					case deletedNode := <-deletedNodes:
						gotDeletedNodes = append(gotDeletedNodes, deletedNode)
					case <-time.After(4 * time.Second):
						t.Errorf("Timeout while waiting for deleted nodes.")
					}
				}
			} else {
				select {
				case <-notDeletedNodes:
				case <-time.After(4 * time.Second):
					t.Errorf("Timeout while waiting for deleted nodes.")
				}
			}
			if len(d.deletionsPerNodeGroup) > 0 {
				t.Errorf("Number of bathces hasn't reach 0 after remove(), got: %v", len(d.deletionsPerNodeGroup))
			}
			if len(d.drainedNodeDeletions) > 0 {
				t.Errorf(" Drained node map is not empty, got: %v", len(d.drainedNodeDeletions))
			}
		})
	}
}

repository: kubernetes/autoscaler

repo_name: kubernetes/autoscaler


text:
@techreport{chu__2017,
 author = {Chu, Chenhui and Otani, Mayu and Nakashima, Yuta},
 month = {September},
 number = {NLP若手の会 第12回シンポジウム},
 pages = {1},
 title = {画像ピボットパラフレーズ抽出に向けて},
 year = {2017}
}

extension: bib


text:
package storagepostgres

import (
	"context"
	"strings"

	"github.com/jackc/pgx/v4/pgxpool"
)

const Schema = `
CREATE SCHEMA IF NOT EXISTS gulfstream;

CREATE TABLE IF NOT EXISTS gulfstream.versions
(
    stream_id      uuid         NOT NULL,
    stream_name    VARCHAR(128) NOT NULL,
    version integer,
    PRIMARY KEY (stream_name, stream_id)
);

CREATE TABLE IF NOT EXISTS gulfstream.states
(
    stream_id      uuid         NOT NULL,
    stream_name    VARCHAR(128) NOT NULL,
    version integer,
    raw_data  bytea,
    PRIMARY KEY (stream_name, stream_id)
);

CREATE TABLE IF NOT EXISTS gulfstream.events
(
    stream_id        uuid         NOT NULL,
    stream_name      VARCHAR(128) NOT NULL,
    event_name      VARCHAR(256) NOT NULL,
    version    integer,
    created_at BIGINT,
    raw_data    bytea,
    PRIMARY KEY (stream_name, stream_id, version)
);

CREATE TABLE IF NOT EXISTS gulfstream.outbox
(
    stream_id        uuid         NOT NULL,
    stream_name      VARCHAR(128) NOT NULL,
    event_name      VARCHAR(256) NOT NULL,
    version integer,
    raw_data    bytea,
    PRIMARY KEY (stream_name, stream_id, version)
);
`

func CreateSchema(ctx context.Context, pool *pgxpool.Pool) error {
	queries := strings.Split(Schema, ";")
	for _, query := range queries {
		if len(query) == 0 {
			continue
		}

		query = strings.TrimSpace(query)
		query = strings.ReplaceAll(query, "\n", "")
		query = query + ";"

		_, err := pool.Exec(ctx, query)
		if err != nil {
			return err
		}
	}
	return nil
}

func DropSchema(ctx context.Context, pool *pgxpool.Pool) error {
	rows, err := pool.Query(ctx, selectTablesSQL)
	if err != nil {
		return err
	}
	defer rows.Close()
	tables := make([]string, 0, 12)
	var tableName string
	for rows.Next() {
		if err := rows.Scan(&tableName); err != nil {
			return err
		}
		tables = append(tables, "gulfstream."+tableName)
	}
	sql := dropTableSQL + " " + strings.Join(tables, ",")
	_, err = pool.Exec(ctx, sql)
	return err
}

const (
	selectTablesSQL = `
SELECT table_name
FROM information_schema.tables
WHERE table_schema = 'gulfstream'`

	dropTableSQL = `DROP TABLE IF EXISTS`

	insertVersionSQL = `
INSERT INTO gulfstream.versions (stream_name, stream_id, version)
VALUES ($1, $2, $3)`

	updateVersionSQL = `
UPDATE gulfstream.versions
SET version=$1
WHERE stream_name=$2 AND stream_id=$3 AND version=$4`

	insertEventSQL = `
INSERT INTO gulfstream.events (stream_id, stream_name, event_name, version, created_at, raw_data)
VALUES ($1, $2, $3, $4, $5, $6)`

	insertStateSQL = `
INSERT INTO  gulfstream.states (stream_name, stream_id, version, raw_data)
VALUES ($1, $2, $3, $4)`

	updateStateSQL = `
UPDATE gulfstream.states SET version=$1, raw_data=$2
WHERE stream_name=$3 AND stream_id=$4`

	selectStateSQL = `
SELECT raw_data
FROM gulfstream.states
WHERE stream_name=$1 AND stream_id=$2`

	insertOutboxSQL = `
INSERT INTO gulfstream.outbox (stream_id, stream_name, event_name, version, raw_data)
VALUES ($1, $2, $3, $4, $5)`

	deleteOutboxSQL = `DELETE FROM gulfstream.outbox WHERE stream_name=$1 AND stream_id=$2 AND version <= $3`
)

repository: go-gulfstream/gulfstream

repo_name: go-gulfstream/gulfstream


text:
@INPROCEEDINGS{Zangar16,
author={N. Zangar and S. Gharbi and M. Abdennebi},
booktitle={2016 13th IEEE Annual Consumer Communications Networking Conference (CCNC)},
title={Service differentiation strategy based on MACB factor for M2M Communications in LTE-A Networks},
year={2016},
pages={693-698},
keywords={5G mobile communication;Long Term Evolution;probability;5G standard Long Term Evolution;ACB factors;LTE-A Networks;LTE-A networks;M2M Communications;M2M traffic category;MACB factor;RACH;access class barring factor concept;access probability;machine-to-machine communication;random access channel;service differentiation strategy;Conferences;Delays;Mobile communication;Mobile computing;Radiation detectors;Telecommunication traffic;Time-frequency analysis;LTE-A;M2M;MACB;QoS;RAN Overload},
doi={10.1109/CCNC.2016.7444864},
month={Jan},}
@INPROCEEDINGS{Guan16,
author={Lu Guan and Bo Yan and Zhiyong Guo and Yejiang Gong},
booktitle={2016 2nd IEEE International Conference on Computer and Communications (ICCC)},
title={Priority-Based Random Access control mechanism for M2M communications},
year={2016},
pages={2313-2317},
keywords={Long Term Evolution;radio equipment;ACB method;LTE networks;M2M communications devices;PBRA control mechanism;UE;access class barring method;access overload problem;long term evolution networks;machine-to-machine communications;priority based random access;radio access network;random access control mechanism;user equipment;Delays;Long Term Evolution;Machine-to-machine communications;Power systems;Vehicle dynamics;Wireless networks;LTE;network overload;priority-based;random access},
doi={10.1109/CompComm.2016.7925112},
month={Oct},}
@article{HanHS17,
  author    = {Bin Han and Mohammad Asif Habibi andHans D. Schotten},
  title     = {Optimal Resource Dedication in Grouped Random Access for Massive Machine-Type Communications},
  journal   = {CoRR},
  volume    = {abs/1707.09811},
  year      = {2017},
  month     = {Jul}
}
@article{HanHSDS17,
  author    = {Bin Han and Oliver Holland and Vincenzo Sciancalepore and Mischa Dohler and Hans D. Schotten},
  title     = {D2D-Based Grouped Random Access to Mitigate Radio Access Network Congestion in Massive Machine-Type Communications},
  journal   = {CoRR},
  volume    = {abs/1705.02777},
  year      = {2017},
  month     = {May}
}
@online{OAI,
  author = {Adlen Ksentini},
  title = {openairinterface5G},
  year = 2017,
  url = {https://gitlab.eurecom.fr/oai/openairinterface5g/tree/develop-nb-iot},
  urldate = {2017-09-05}
}
@online{whitepaper,
  title = {Narrowband Internet of Things},
  url = {https://cdn.rohde-schwarz.com/pws/dl_downloads/dl_application/application_notes/1ma266/1MA266_0e_NB_IoT.pdf}
}


text:
package http

//JWTToken represents jwt token
type JWTToken struct {
	Token string `json:"access_token"`
	Type  string `json:"token_type"`
}

repository: viant/bqtail

repo_name: viant/bqtail


text:
package call

import (
	"unsafe"

	"github.com/criticalstack/swoll/pkg/types"
)

type Alarm struct {
	Seconds uint32 `json:"seconds"`
}

func (a *Alarm) CallName() string  { return "alarm" }
func (a *Alarm) Return() *Argument { return nil }
func (a *Alarm) DecodeArguments(data []*byte, arglen int) error {
	a.Seconds = types.MakeCU32(unsafe.Pointer(data[0]))
	return nil
}

func (a *Alarm) Arguments() Arguments {
	return Arguments{
		{"seconds", "unsigned int", a.Seconds},
	}
}

repository: andrewalexander/swoll

repo_name: andrewalexander/swoll


text:
COMPATIBLE_MACHINE = "omap4430-panda"

require linux.inc

# The main PR is now using MACHINE_KERNEL_PR, for omap4 see conf/machine/include/omap4.inc
MACHINE_KERNEL_PR_append = "b"

CORTEXA8FIXUP = "no"

SRCREV = "ti-ubuntu-2.6.35-980.1release13"

SRC_URI = "git://dev.omapzoom.org/pub/scm/integration/kernel-ubuntu.git;protocol=git;branch=ti-ubuntu-L24.11 \
           file://0001-tiler-avoid-lock-ups-due-to-unmapped-DMM-entries.patch \
           file://0002-ARM-Add-prompt-for-CONFIG_ALIGNMENT_TRAP.patch \
           file://0003-ARM-Print-warning-on-alignment-trap-in-kernel-mode.patch \
           file://0004-ARM-Expose-some-CPU-control-registers-via-sysfs.patch \
           file://0005-ARM-Add-option-to-allow-userspace-PLE-access.patch \
           file://0006-ARM-Add-option-to-allow-userspace-access-to-performa.patch \
           file://0007-OMAP4-do-not-force-select-options-which-are-not-requ.patch \
           file://0008-omap4-pandaboard-add-support-for-DVI-output.patch \
           file://0001-UBUNTU-Config-Fix-FTBS-caused-by-new-binutils.patch \
           file://0002-Add-AFLAGS-for-sleep44xx-to-fix-FTBS.patch \
           file://defconfig \
           "

S = "${WORKDIR}/git"


text:
@misc{MixedModeDebugger.jl,
	author  = {Lyndon White},
	title   = {{MixedModeDebugger.jl}},
	url     = {https://github.com/oxinabox/MixedModeDebugger.jl},
	version = {v0.1.0},
	year    = {2019},
	month   = {9}
}

gha_language: Julia


text:
@inproceedings{fingerprinting2019globecom,
 author = {Gopalakrishnan, Soorya and Cekic, Metehan and Madhow, Upamanyu},
 booktitle = {IEEE Global Communications Conference (Globecom)},
 location = {Waikoloa, Hawaii},
 title = {Robust Wireless Fingerprinting via Complex-Valued Neural Networks},
 year = {2019}
}

@misc{cekic2020robust,
    title={Robust Wireless Fingerprinting: Generalizing Across Space and Time},
    author={Metehan Cekic and Soorya Gopalakrishnan and Upamanyu Madhow},
    year={2020},
    eprint={2002.10791},
    archivePrefix={arXiv},
    primaryClass={eess.SP}
}

@misc{bakiskan2020polarizing,
    title={Polarizing Front Ends for Robust CNNs},
    author={Can Bakiskan and Soorya Gopalakrishnan and Metehan Cekic and Upamanyu Madhow and Ramtin Pedarsani},
    year={2020},
    eprint={2002.09580},
    archivePrefix={arXiv},
    primaryClass={stat.ML}
}

repository: metehancekic/web

repo_name: metehancekic/web


text:
@article{RN1964,
 author = {Sun, Xiankui and Fontaine, Jean-Marc and Rest, Joshua S and Shelden, Eric A and Welsh, Michael J and Benndorf, Rainer},
 issn = {0021-9258},
 journal = {Journal of biological chemistry},
 number = {4},
 pages = {2394-2402},
 title = {Interaction of human HSP22 (HSPB8) with other small heat shock proteins},
 type = {Journal Article},
 volume = {279},
 year = {2004}
}


text:
@incollection{specht2013innovation,
 author = {Specht, Marcus and Kalz, Marco and Börner, Dirk},
 booktitle = {Mobile Learning},
 pages = {55--74},
 publisher = {Springer Fachmedien Wiesbaden},
 title = {Innovation und Trends für mobiles Lernen},
 year = {2013}
}

repository: mkalz/mkalz-academic

repo_name: mkalz/mkalz-academic


text:
file(REMOVE_RECURSE
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/compress.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/conv.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/crypto.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/debug.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/memcpy.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/memset.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/recv_bytes.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/send_bytes.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/lib/string.c.o"
  "CMakeFiles/OUTLAW_3_patched.dir/cb_3/src/service.c.o"
  "OUTLAW_3_patched.pdb"
  "OUTLAW_3_patched"
)

# Per-language clean rules from dependency scanning.
foreach(lang C)
  include(CMakeFiles/OUTLAW_3_patched.dir/cmake_clean_${lang}.cmake OPTIONAL)
endforeach()

repository: siddk/driller-lite

repo_name: siddk/driller-lite


text:
package udwBinary

import (
	"bytes"
	"github.com/tachyon-protocol/udw/udwBytes"
	"github.com/tachyon-protocol/udw/udwTest"
	"io"
	"runtime"
	"testing"
)

func TestReadByteSliceWithUint32LenNoAlloc(t *testing.T) {
	buf := make([]byte, 1024)
	out, err := ReadByteSliceWithUint32LenNoAlloc(bytes.NewReader([]byte{1, 0, 0, 0, 0x30}), buf)
	udwTest.Equal(err, nil)
	udwTest.Equal(out, []byte{0x30})
	buf2 := bytes.NewReader([]byte{0xff, 0xff, 0xff, 0xff, 0x30})
	var before runtime.MemStats
	var after runtime.MemStats
	runtime.ReadMemStats(&before)
	out, err = ReadByteSliceWithUint32LenNoAlloc(buf2, buf)
	runtime.ReadMemStats(&after)
	udwTest.Equal(err, io.ErrUnexpectedEOF)
	udwTest.Ok(after.TotalAlloc-before.TotalAlloc < 1024*1024*1024)
}

func TestReadUint32NoAllocV2(t *testing.T) {
	out, err := ReadUint32NoAllocV2(bytes.NewBuffer([]byte{1, 0, 0, 0, 0x30}))
	udwTest.Equal(err, nil)
	udwTest.Equal(out, uint32(1))

	buf := bytes.NewBuffer([]byte{100, 0, 0, 0})
	bufReader := io.Reader(buf)
	out, err = ReadUint32NoAllocV2(bufReader)
	udwTest.Equal(err, nil)
	udwTest.Equal(out, uint32(100))
}

func TestWriteByteSliceWithUint32LenNoAlloc(t *testing.T) {
	buf := &bytes.Buffer{}
	content := []byte{1, 2, 3, 4, 5, 6}
	resultContent := []byte{6, 0, 0, 0, 1, 2, 3, 4, 5, 6}
	err := WriteByteSliceWithUint32LenNoAllocV2(buf, content)
	udwTest.Equal(err, nil)
	udwTest.Equal(buf.Bytes(), resultContent)

	tmpB := make([]byte, 16)
	buf.Reset()
	err = WriteByteSliceWithUint32LenNoAlloc(buf, content, tmpB)
	udwTest.Equal(err, nil)
	udwTest.Equal(buf.Bytes(), resultContent)

	tmpB2 := udwBytes.NewBufWriter(tmpB)
	tmpB2.Reset()
	buf.Reset()
	err = WriteByteSliceWithUint32LenNoAlloc(buf, content, tmpB)
	udwTest.Equal(err, nil)
	udwTest.Equal(buf.Bytes(), resultContent)

	const num = 1e3

	udwTest.Benchmark(func() {
		udwTest.BenchmarkSetNum(num)
		udwTest.BenchmarkSetBytePerRun(len(content))
		for i := 0; i < num; i++ {
			buf.Reset()
			WriteByteSliceWithUint32LenNoAllocV3(buf, content, tmpB2)
		}
	})
}

repository: daniel-henderson-ty/udw

repo_name: daniel-henderson-ty/udw


text:
SECTION = "devel/chicken"
DESCRIPTION = "Obtain list of all interned symbols and variables"
LICENSE = "BSD"
LIC_FILES_CHKSUM = "file://oblist.meta;md5=6c21602d49e82e8011a73dbcd53a5e12"
DEPENDS_append_class-cross = " chicken-egg-regex-cross"
DEPENDS_append_class-crosssdk = " chicken-egg-regex-crosssdk"
DEPENDS_append_class-nativesdk = " nativesdk-chicken-egg-regex chicken-egg-regex-crosssdk"
DEPENDS = " chicken-egg-regex chicken-egg-regex-cross"
RDEPENDS_${PN} = " chicken-egg-regex"

SRC_URI = "http://code.call-cc.org/egg-tarballs/4/oblist/oblist-${PV}.tar.gz"

SRC_URI[md5sum] = "8afd4376c9263768b9717c54c66405ce"
SRC_URI[sha256sum] = "05ca578e7529e6191b1e1f15cdfd9910d32a3d66ccc3502003bf125c6eea9f79"

S = "${WORKDIR}/oblist-${PV}"

inherit chicken_install

BBCLASSEXTEND = "cross crosssdk nativesdk"


text:
@inproceedings{semwal2015tartarus,
 author = {Semwal, Tushar and Bode, Manoj and Singh, Vivek and Jha, Shashi Shekhar and Nair, Shivashankar B},
 booktitle = {Proceedings of the 2015 Conference on Advances In Robotics},
 organization = {ACM},
 pages = {20},
 title = {Tartarus: a multi-agent platform for integrating cyber-physical systems and robots},
 year = {2015}
}

repository: tushar-semwal/academic-kickstart

repo_name: tushar-semwal/academic-kickstart


text:
package svc

import (
	"github.com/tal-tech/go-zero/core/stores/redis"
	"github.com/tal-tech/go-zero/core/stores/sqlx"

	"zero_examples/service/user/api/internal/config"
	"zero_examples/service/user/model"
)

type ServiceContext struct {
	Config config.Config
	UserModel model.UserModel
	UserModelNoCache model.UserModelNoCache
}

func NewServiceContext(c config.Config) *ServiceContext {
	conn:=sqlx.NewMysql(c.MysqlRead.DataSource)

	for _, redisItem := range c.CacheRedis {
		r := redisItem.RedisConf.NewRedis()
		r.Pipelined(func (pipe redis.Pipeliner) error {
			pipe.Do("select" ,1)
			return nil
		})
	}

	return &ServiceContext{
		Config: c,
		UserModel: model.NewUserModel(conn, c.CacheRedis),
		UserModelNoCache: model.NewUserModelNoCache(conn),
	}
}


text:
DESCRIPTION = "Python Packet Capture Library"
SECTION = "devel/python"
PRIORITY = "optional"
RDEPENDS_${PN} = "python-core"
DEPENDS = "libpcap libnet"
SRCNAME = "pycap"
PR = "r2"

SRC_URI = "${SOURCEFORGE_MIRROR}/${SRCNAME}/${SRCNAME}-${PV}.tar.gz"
S = "${WORKDIR}/${SRCNAME}-${PV}"

inherit distutils

SRC_URI[md5sum] = "c90bc5382dede1a941e023e7bc27c473"
SRC_URI[sha256sum] = "961e37f49afeda70d89c21830751548a2ac4912a35122bf70bf29091eef5c4a0"


text:
@valuesSlashes {a,
    braced = {\\\\"\\\%\\},
    quoted = "\\\{\vphantom{\}}\\{"}\\\%\\"
}

repository: FlamingTempura/bibtex-tidy

repo_name: FlamingTempura/bibtex-tidy

gha_language: TeX


text:
DESCRIPTION = "compiler cache"
HOMEPAGE = "http:/ccache.samba.org"
SECTION = "devel"
LICENSE = "GPL"
PR = "r1"

SRC_URI = "http://samba.org/ftp/ccache/ccache-${PV}.tar.gz \
	file://ccache-gcov.patch;patch=1 \
	"

inherit autotools

repository: demsey/openembedded

repo_name: demsey/openembedded


text:
package handlers

import (
	"errors"
	"fmt"
	"github.com/goguardian/aws-xray-go/segment"
	"github.com/goguardian/aws-xray-go/utils"
	"sync"
	"time"

	"github.com/patrickmn/go-cache"
	"golang.org/x/net/context"
	"google.golang.org/grpc"
	"google.golang.org/grpc/metadata"
)

const (
	mdParentKey  = "xray-parentid"
	mdRootKey    = "xray-rootid"
	mdSampledKey = "xray-sampled"
	mdSegmentKey = "xray-segment"
)

var (
	segmentCache          *cache.Cache
	cacheCleanupFrequency = 30 * time.Second
	cacheDuration         = 10 * time.Minute
	cacheDurationMutex    = &sync.RWMutex{}
)

func init() {
	segmentCache = cache.New(cache.NoExpiration, cacheCleanupFrequency)
}

// SetSegmentCacheDuration updates the duration of segments in in-memory cache
func SetSegmentCacheDuration(duration time.Duration) {
	cacheDurationMutex.Lock()
	defer cacheDurationMutex.Unlock()
	cacheDuration = duration
}

// NewGRPCClientConn creates a new gRPC client connection with a unary
// interceptor that performs traces of gRPC requests.
func NewGRPCClientConn(
	target string,
	opts ...grpc.DialOption,
) (*grpc.ClientConn, error) {

	opts = append(opts,
		grpc.WithUnaryInterceptor(GRPCClientUnaryInterceptor))

	return grpc.Dial(target, opts...)
}

// GRPCClientUnaryInterceptor is a gRPC unary interceptor for tracing
// outbound gRPC requests
func GRPCClientUnaryInterceptor(
	ctx context.Context,
	method string,
	req interface{},
	reply interface{},
	cc *grpc.ClientConn,
	invoker grpc.UnaryInvoker,
	opts ...grpc.CallOption,
) error {

	seg, err := GetSegmentFromContext(ctx)
	if err != nil {
		return invoker(ctx, method, req, reply, cc, opts...)
	}

	subseg := seg.AddNewSubsegment(method)
	subseg.AddRemote()

	sampled := "0"
	if seg.Traced {
		sampled = "1"
	}

	mdctx := metadata.NewContext(ctx, metadata.New(map[string]string{
		mdRootKey:    seg.TraceID,
		mdParentKey:  subseg.ID,
		mdSampledKey: sampled,
	}))

	err = invoker(mdctx, method, req, reply, cc, opts...)

	subseg.Close(err, utils.ErrorType)

	return err
}

// GRPCServerUnaryInterceptor is a gRPC unary interceptor for tracing
// inbound gRPC requests.
func GRPCServerUnaryInterceptor(name string) func(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error) {

	return func(
		ctx context.Context,
		req interface{},
		info *grpc.UnaryServerInfo,
		handler grpc.UnaryHandler,
	) (interface{}, error) {

		seg := segment.New(name, ctx)
		ctx = AddSegmentToContext(seg, ctx)
		defer seg.Close()

		return handler(ctx, req)
	}
}

// AddSegmentToContext adds a segment reference to a context.Context instance.
func AddSegmentToContext(seg *segment.Segment, ctx context.Context) context.Context {
	sampled := "0"
	if seg.Traced {
		sampled = "1"
	}

	newctx := metadata.NewContext(ctx, metadata.MD{
		mdParentKey:  []string{seg.ParentID},
		mdRootKey:    []string{seg.TraceID},
		mdSampledKey: []string{sampled},
		mdSegmentKey: []string{seg.TraceID},
	})

	cacheDurationMutex.RLock()
	defer cacheDurationMutex.RUnlock()

	segmentCache.Add(seg.TraceID, seg, cacheDuration)

	return newctx
}

// GetSegmentFromContext retrieves a segment from a context.Context instance.
func GetSegmentFromContext(ctx context.Context) (*segment.Segment, error) {
	md, ok := metadata.FromContext(ctx)
	if !ok {
		return nil, errors.New("Unable to load metadata from context")
	}

	str := md[mdSegmentKey]
	if len(str) < 1 || len(str[0]) < 1 {
		return nil, errors.New("Segment not found in context")
	}

	segmentTraceID := str[0]

	result, found := segmentCache.Get(segmentTraceID)
	if !found {
		return nil, fmt.Errorf("Segment not found in cache: %s", segmentTraceID)
	}

	seg, ok := result.(*segment.Segment)
	if !ok {
		return nil, errors.New("Unable to assert type for segment from cache")
	}

	return seg, nil
}

repository: goguardian/aws-xray-go

repo_name: goguardian/aws-xray-go


text:
package system

import (
	"github.com/flipped-aurora/gf-vue-admin/app/model/system"
	"github.com/flipped-aurora/gf-vue-admin/library/global"
)

// AutoCreateApi 自动创建api数据
// Author [SliverHorn](https://github.com/SliverHorn)
func (s *autoCode) AutoCreateApi(info *system.AutoCodeStruct) (entities []system.Api, err error) {
	entities = []system.Api{
		{Path: "/" + info.Abbreviation + "/" + "create", Description: "新增" + info.Description, ApiGroup: info.Abbreviation, Method: "POST"},
		{Path: "/" + info.Abbreviation + "/" + "first", Description: "根据ID获取" + info.Description, ApiGroup: info.Abbreviation, Method: "GET"},
		{Path: "/" + info.Abbreviation + "/" + "update", Description: "更新" + info.Description, ApiGroup: info.Abbreviation, Method: "PUT"},
		{Path: "/" + info.Abbreviation + "/" + "delete", Description: "删除" + info.Description, ApiGroup: info.Abbreviation, Method: "DELETE"},
		{Path: "/" + info.Abbreviation + "/" + "deletes", Description: "批量删除" + info.Description, ApiGroup: info.Abbreviation, Method: "DELETE"},
		{Path: "/" + info.Abbreviation + "/" + "getList", Description: "获取" + info.Description + "列表", ApiGroup: info.Abbreviation, Method: "POST"},
	}
	err = global.Db.Create(&entities).Error
	return entities, err
}

repository: damonchen/gf-vue-admin

repo_name: damonchen/gf-vue-admin


text:
package main

import (
	"fmt"
	"runtime"
	"time"
)

func main() {
	//创建新建的协程
	go func() {
		fmt.Println("goroutine开始。。。")

		//调用了别的函数
		fun()

		fmt.Println("goroutine结束。。")
	}() //别忘了()

	//睡一会儿，不让主协程结束
	time.Sleep(3 * time.Second)
}

func fun() {
	defer fmt.Println("defer。。。")

	//return           //终止此函数
	runtime.Goexit() //终止所在的协程

	fmt.Println("fun函数。。。")
}


text:
@inproceedings{Andrews2014,
	Author = {R. W. Andrews and J. S. Stein and C. Hansen and D. Riley},
	Booktitle = {2014 IEEE 40th Photovoltaic Specialist Conference (PVSC)},
	doi = {10.1109/PVSC.2014.6925501},
	Title = {Introduction to the open source PV LIB for python Photovoltaic system modelling package},
	Year = {2014}}

@online{DOESF2,
    author = {Department of Energy},
    title = {Solar Forecasting 2},
    year = 2018,
    url = {https://www.energy.gov/eere/solar/solar-forecasting-2},
    urldate = {2018-08-02}}

@article{Gagne2017,
	Author = {Gagne II, David John and McGovern, Amy and Haupt, Sue Ellen and Williams, John K.},
	Journal = {Solar Energy},
	Pages = {383- 393},
	doi = {10.1016/j.solener.2017.04.031},
	Title = {Evaluation of statistical learning configurations for gridded solar irradiance forecasting},
	Volume = {150},
	Year = {2017}}

@inproceedings{Holmgren2015,
	Author = {W. F. Holmgren and R. W. Andrews and A. T. Lorenzo and J. S. Stein},
	Booktitle = {2015 IEEE 42nd Photovoltaic Specialist Conference (PVSC)},
	Month = {June},
	Pages = {1-5},
	Title = {PVLIB Python 2015},
	Year = {2015},
	doi = {10.1109/PVSC.2015.7356005}}

@inproceedings{Holmgren2016,
	Author = {W. F. Holmgren and D. G. Groenendyk},
	Booktitle = {2016 IEEE 43rd Photovoltaic Specialists Conference (PVSC)},
	Month = {June},
	Pages = {0972-0975},
	Title = {An open source solar power forecasting tool using PVLIB-Python},
	Year = {2016},
	doi = {10.1109/PVSC.2016.7749755}}

@inproceedings{Holmgren2017,
	Author = {William F. Holmgren and Antonio T. Lorenzo and Clifford Hansen},
	Booktitle = {2017 IEEE 44th Photovoltaic Specialists Conference},
	Title = {A Comparison of PV Power Forecasts Using PVLib-Python},
	Year = {2017},
	doi = {10.5281/zenodo.1400857}}

@inproceedings{Holmgren2018,
	Author = {William F. Holmgren and Clifford W. Hansen and Joshua S. Stein and Mark A. Mikofski},
	Booktitle = {2018 IEEE 45th Photovoltaic Specialists Conference},
	Title = {Review of open source tools for PV modeling},
	Year = {2018},
	doi = {10.5281/zenodo.1401378}}

@article{Louwen2017,
	Author = {Atse Louwen and Ruud E.I. Schropp and Wilfried G.J.H.M. van Sark and Andr{\'e} P.C. Faaij},
	Journal = {Solar Energy},
	Pages = {1339 - 1353},
	Title = {Geospatial analysis of the energy yield and environmental footprint of different photovoltaic module technologies},
	Volume = {155},
	Year = {2017},
	doi = {10.1016/j.solener.2017.07.056}}

@inproceedings{Mikofski2016,
	Author = {M. Mikofski and A. Oumbe and C. Li and B. Bourne},
	Booktitle = {2016 IEEE 43rd Photovoltaic Specialists Conference (PVSC)},
	Month = {June},
	Pages = {1357-1362},
	Title = {Evaluation and correction of the impact of spectral variation of irradiance on PV performance},
	Year = {2016},
	doi = {10.1109/PVSC.2016.7749837}}

@inproceedings{Mikofski2017,
	Author = {Mark A. Mikofski and Clifford W. Hansen and William F. Holmgren and Gregory M. Kimball},
	Booktitle = {2017 IEEE 44th Photovoltaic Specialists Conference},
	Title = {Use of Measured Aerosol Optical Depth and Precipitable Water to Model Clear Sky Irradiance},
	Year = {2017},
	doi = {10.5281/zenodo.1403238}}

@article{Polo2016,
	Author = {J. Polo, S. Garcia-Bouhaben, M. C. Alonso-Garcia},
	Journal = {Journal of Renewable and Sustainable Energy},
	Title = {A comparative study of the impact of horizontal-to-tilted solar irradiance conversion in modelling small PV array performance},
	Year = {2016},
	doi = {10.1063/1.4964363}}

@misc{pvlibZenodo,
    author = {pvlib python Contributors},
    title = {pvlib python},
    doi = {10.5281/zenodo.1246152},
    howpublished = {\url{http://doi.org/10.5281/zenodo.1246152}}}

@inproceedings{Stein2012,
	Author = {J. S. Stein},
	Booktitle = {2012 38th IEEE Photovoltaic Specialists Conference},
	Month = {June},
	Pages = {003048-003052},
	Title = {The photovoltaic Performance Modeling Collaborative (PVPMC)},
	Year = {2012},
	doi = {10.1109/PVSC.2012.6318225}}

@inproceedings{Stein2016,
    Author = {J. S. Stein and W. F. Holmgren and J. Forbess and C. W. Hansen},
    Booktitle = {2016 IEEE 43rd Photovoltaic Specialists Conference (PVSC)},
    Month = {June},
    Pages = {3425-3430},
    Title = {PVLIB: Open source photovoltaic performance modeling functions for Matlab and Python},
    Year = {2016},
    doi = {10.1109/PVSC.2016.7750303}}

repository: wholmgren/pvlib-python

repo_name: wholmgren/pvlib-python

gha_language: Python


text:
SUMMARY = "SSH pub keys of GARDENA developers"
LICENSE = "MIT"
LIC_FILES_CHKSUM = "file://${COMMON_LICENSE_DIR}/MIT;md5=0835ade698e0bcf8506ecda2f7b4f302"

FILESEXTRAPATHS:prepend := "${THISDIR}/files:"

PV = "0.11"

SRC_URI = " \
    file://adrian-friedli.pub \
    file://agash-thamo.pub \
    file://alexey-nezhdanov.pub \
    file://andreas-müller.pub \
    file://andreas_boerrnert.pub \
    file://andreas-koeppel.pub \
    file://boris-ruch.pub \
    file://christoph-schnetzler.pub \
    file://cornel-bruelisauer.pub \
    file://dusan-markovic.pub \
    file://ezra-buehler.pub \
    file://fabian-frei.pub \
    file://felix-bruelisauer.pub \
    file://florian-schweikert.pub \
    file://gerald-reisinger.pub \
    file://jessica-eichberg.pub \
    file://maintenance-access.pub \
    file://manuel-knobel.pub \
    file://marc-lasch.pub \
    file://marcel-mueller.pub \
    file://markus-gruber.pub \
    file://michel-werren.pub \
    file://nicola-ochsenbein.pub \
    file://pascal-brogle.pub \
    file://peter-penkalla.pub \
    file://peter-tonz.pub \
    file://renato-staehli.pub \
    file://reto-schneider_homeoffice.pub \
    file://reto-schneider_office.pub \
    file://sandro-klarer.pub \
    file://sebastian-schoch.pub \
    file://sshportal-dev.pub \
    file://timon-braendli.pub \
    file://tobias-greuter.pub \
"

inherit ssh-authorized-keys


text:
package tree

type BTNode struct {
	Data  interface{}
	Found bool
	Size  int
	Left  *BTNode
	Right *BTNode
}
type BBTNode struct {
	Data   interface{}
	Left   *BBTNode
	Right  *BBTNode
	Parent *BBTNode
}

repository: ajanthan/playground

repo_name: ajanthan/playground


text:
file(REMOVE_RECURSE
  "CMakeFiles/Mensacount.dir/main.cpp.o"
  "Mensacount"
  "Mensacount.pdb"
)

# Per-language clean rules from dependency scanning.
foreach(lang CXX)
  include(CMakeFiles/Mensacount.dir/cmake_clean_${lang}.cmake OPTIONAL)
endforeach()

repository: wdjpng/soi

repo_name: wdjpng/soi


text:
@inproceedings{valenzuela-escarcega-etal-2016-odins,
    title = "Odin{'}s Runes: A Rule Language for Information Extraction",
    author = "Valenzuela-Esc{\'a}rcega, Marco A.  and
      Hahn-Powell, Gus  and
      Surdeanu, Mihai",
    booktitle = "Proceedings of the Tenth International Conference on Language Resources and Evaluation ({LREC}'16)",
    month = may,
    year = "2016",
    address = "Portoro{\v{z}}, Slovenia",
    publisher = "European Language Resources Association (ELRA)",
    url = "https://aclanthology.org/L16-1050",
    pages = "322--329",
}

@misc{pyarelal_2022,
 title={ToMCAT (UAZ + TAMU) Study 3 Preregistration},
 url={osf.io/hsy32},
 DOI={10.17605/OSF.IO/HSY32},
 publisher={OSF},
 author={Pyarelal, Adarsh},
 year={2022},
 month={May}
}

@misc{huang_freeman_cooke_colonna-romano_wood_buchanan_caufman_2022,
 title={Exercises for Artificial Social Intelligence in Minecraft Search and Rescue for Teams},
 url={osf.io/jwyvf},
 DOI={10.17605/OSF.IO/JWYVF},
 publisher={OSF},
 author={Huang, Lixiao and Freeman, Jared and Cooke, Nancy and Colonna-Romano, John and Wood, Matthew D and Buchanan, Verica and Caufman, Stephen J},
 year={2022},
 month={Apr}
}

@misc{huang_freeman_cooke_dubrow_colonna-romano_wood_buchanan_caufman_2021,
 title={ASIST Study 2 June 2021 Exercises for Artificial Social Intelligence in Minecraft Search and Rescue for Teams},
 url={osf.io/gxpq5},
 DOI={10.17605/OSF.IO/GXPQ5},
 publisher={OSF},
 author={Huang, Lixiao and Freeman, Jared and Cooke, Nancy and Dubrow, Samantha and Colonna-Romano, John and Wood, Matthew D and Buchanan, Verica and Caufman, Stephen J},
 year={2021},
 month={Jun}
}


text:
require libnl.inc

LICENSE = "LGPLv2.1"

PE = "1"
PR = "${INC_PR}.1"

DEPENDS = "flex-native bison-native"

SRC_URI = "\
  http://www.infradead.org/~tgr/libnl/files/libnl-${PV}.tar.gz \
  file://fix-pc-file.patch \
  file://fix-pktloc-dep-race.patch \
"

SRC_URI[md5sum] = "6aaf1e9802a17a7d702bb0638044ffa7"
SRC_URI[sha256sum] = "5a40dc903d3ca1074da7424b908bec8ff16936484798c7e46e53e9db8bc87a9c"

PACKAGES =+ "${PN}-route ${PN}-nf ${PN}-genl ${PN}-cli"
FILES_${PN}-route = "${libdir}/libnl-route.so.*"
FILES_${PN}-nf    = "${libdir}/libnl-nf.so.*"
FILES_${PN}-genl  = "${libdir}/libnl-genl.so.*"
FILES_${PN}-cli   = "${libdir}/libnl-cli.so.*"

repository: mrchapp/arago-oe-dev

repo_name: mrchapp/arago-oe-dev


text:
SUMMARY = "Serial Port Support for Python"
SECTION = "devel/python"
LICENSE = "PSF"
LIC_FILES_CHKSUM = "file://LICENSE.txt;md5=c557c64905dac5b725980b9505bf8d7b"
SRCNAME = "pyserial"
PR = "r1"

SRC_URI = "https://pypi.python.org/packages/source/p/${SRCNAME}/${SRCNAME}-${PV}.tar.gz"
S = "${WORKDIR}/${SRCNAME}-${PV}"

inherit setuptools3

# FIXME might stop packaging serialwin32 and serialjava files

RDEPENDS_${PN} = "\
    python3-fcntl \
    python3-io \
    python3-stringold \
"

SRC_URI[md5sum] = "794506184df83ef2290de0d18803dd11"
SRC_URI[sha256sum] = "3542ec0838793e61d6224e27ff05e8ce4ba5a5c5cc4ec5c6a3e8d49247985477"

repository: exmachina-dev/meta-exm-core

repo_name: exmachina-dev/meta-exm-core


text:
vtk_module(vtkIOXMLParser
  GROUPS
    StandAlone
  DEPENDS
    vtkCommonDataModel
    vtkCommonSystem
    vtkCommonMisc
    vtkIOCore
  PRIVATE_DEPENDS
    vtkexpat
  )

repository: Starlink/vtk

repo_name: Starlink/vtk


text:
package jsutil

import (
	"errors"

	"github.com/dop251/goja"
)

var (
	ErrUndefined    = errors.New("value is not defined")
	ErrNotAFunction = errors.New("value is not a function")
)

func FnInvoke(vm *goja.Runtime, name string, args ...goja.Value) (goja.Value, error) {
	val := vm.Get(name)
	if val == nil {
		return nil, ErrUndefined
	}
	fn, ok := goja.AssertFunction(val)
	if !ok {
		return nil, ErrNotAFunction
	}

	return fn(goja.Undefined(), args...)
}


text:
// Copyright 2018 The Vogo Authors. All rights reserved.
// Use of this source code is governed by a Apache license
// that can be found in the LICENSE file.

package apigateway

import (
	"context"

	"github.com/grpc-ecosystem/grpc-gateway/runtime"
	"github.com/vogo/grpcapi/pkg/config"
	"github.com/vogo/grpcapi/pkg/pb"
	"google.golang.org/grpc"
)

type register struct {
	endpoint string
	f        func(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
}

var (
	registers = []register{
		{config.EndpointEcho, pb.RegisterEchoServiceHandlerFromEndpoint},
		{config.EndpointHello, pb.RegisterHelloServiceHandlerFromEndpoint},
	}
)

repository: vogo/grpcapi

repo_name: vogo/grpcapi


text:
package server

import (
	"errors"
	"gopkg.in/go-playground/validator.v9"
	"strconv"
)

type Server struct {
	Name string `validate:"required"`
	Ip   string `validate:"ip4_addr"`
	Port int    `validate:"gt=0,lt=65536"`
}

func New(name string, ip string, port int) (*Server, error) {
	server := &Server{
		Name: name,
		Ip:   ip,
		Port: port,
	}

	err := server.validate()
	if err != nil {
		return nil, err
	}

	return server, nil
}

func (server *Server) validate() error {
	validate := validator.New()
	err := validate.Struct(server)
	if err != nil {
		errorMessage := "Validate errors:\n"
		for _, err := range err.(validator.ValidationErrors) {
			switch err.StructField() {
			case "Name":
				errorMessage += "Name is required.\n"
			case "Ip":
				errorMessage += "Ip '" + server.Ip + "' is not valid.\n"
			case "Port":
				errorMessage += "Port '" + strconv.Itoa(server.Port) + "' must be between 1 and 65535.\n"
			}
		}

		return errors.New(errorMessage)
	}

	return nil
}

repository: philippe-vandermoere/docker-proxy-go

repo_name: philippe-vandermoere/docker-proxy-go


text:
package main

import (
	"html/template"
	"log"
	"net/http"
)

func main() {
	templates := populateTemplates()
	//http.ListenAndServe(":3006", http.FileServer(http.Dir("/Users/Admin/Desktop/go-workspace/Web-application-with-golang/public/")))
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		requestedFile := r.URL.Path[1:]
		t := templates.Lookup(requestedFile + ".html")
		if t != nil {
			err := t.Execute(w, nil)
			if err != nil {
				log.Println(err)
			}
		} else {
			w.WriteHeader(http.StatusNotFound)
		}
	})
	http.Handle("/img/", http.FileServer(http.Dir("/Users/Admin/Desktop/go-workspace/Web-application-with-golang/public/")))
	http.Handle("/css/", http.FileServer(http.Dir("/Users/Admin/Desktop/go-workspace/Web-application-with-golang/public/")))
	http.ListenAndServe(":8080", nil)
}

func populateTemplates() map[string]*template.Template {
	/*const templates = "/Users/Admin/Desktop/go-workspace/Web-application-with-golang/templates/"
	result := template.New("template")
	const basePath = templates
	template.Must(result.ParseGlob(basePath + "/*.html"))
	return result */

	result := make(map[string]*template.Template)
	const basePath = "templetes"
	layout := template.Must(template.ParseFiles(basePath + "/_layout,html"))

}


text:
package json

import (
	"testing"

	"packetbeat/libbeat/common"
)

func TestJsonCodec(t *testing.T) {
	expectedValue := "{\"msg\":\"message\"}"

	codec := New(false)
	output, err := codec.Encode(common.MapStr{"msg": "message"})

	if err != nil {
		t.Errorf("Error during event write %v", err)
	} else {
		if string(output) != expectedValue {
			t.Errorf("Expected value (%s) does not equal with output (%s)", expectedValue, output)
		}
	}
}

func TestJsonWriterPrettyPrint(t *testing.T) {
	expectedValue := "{\n  \"msg\": \"message\"\n}"

	codec := New(true)
	output, err := codec.Encode(common.MapStr{"msg": "message"})

	if err != nil {
		t.Errorf("Error during event write %v", err)
	} else {
		if string(output) != expectedValue {
			t.Errorf("Expected value (%s) does not equal with output (%s)", expectedValue, output)
		}
	}
}

repository: njcx/packetbeat

repo_name: njcx/packetbeat


text:
@article{one-dimensional-k-means,
    id: "pmid:27942416",
    title = {Ckmeans.1d.dp: Optimal <i>k</i>-means Clustering in One Dimension by Dynamic Programming},
    author= {Haizhou Wang and Mingzhou Song}
    journal= "The R journal",
    ISSN= "2073-4859",
    year = {2011},
    month={12},
    pages= {29-33},
    volume=3,
    issue=2,
    PMID = "27942416",
    PMCID= "PMC5148156",
}

@INPROCEEDINGS{Chen2000,
    author = {Fei Chen and Diane Lambert and Josˇ C. Pinheiro},
    title = {Incremental Quantile Estimation for Massive Tracking},
    booktitle = {In Proceedings of KDD},
    year = {2000},
    pages = {516--522}
}

@INPROCEEDINGS{qdigest,
    author = {Nisheeth Shrivastava and Chiranjeeb Buragohain and Divyakant Agrawal and Subhash Suri},
    title = {Medians and Beyond: New Aggregation Techniques for Sensor Networks},
    booktitle = {},
    year = {2004},
    pages = {239--249},
    publisher = {ACM Press}
}

@misc{wiki:welford,
   title = "Algorithms for Calculating Variance, Online Algorithm",
   author = "Wikipedia",
   howpublished = "\url{http://en.wikipedia.org/wiki/Algorithms_for_calculating_variance#Online_algorithm}",
   note = "[Online; accessed 19-October-2013]"
 }

@misc{github:stream,
   title = "Algorithms for Calculating Variance, Online Algorithm",
   author = "Add This",
   howpublished = "\url{https://github.com/addthis/stream-lib}",
   note = "[Online; accessed 28-November-2013]"
 }

@misc{mathworld:normal,
   title = "Normal Distribution Function",
   author = "MathWorld",
   howpublished = "\url{http://mathworld.wolfram.com/NormalDistributionFunction.html}",
   note = "[Online; accessed 20-October-2013]"
 }

@inbook{knuth2welford,
  author={Donald E. Knuth},
  edition=3,
  pages=232,
  year=1998,
  title= {The Art of Computer Programming, volume 2: Seminumerical Algorithms},
  publisher= {Addison-Wesley},
  address= {Boston}
}

@ARTICLE{welford62,
    author = {B. P. Welford },
    title = {Note on a method for calculating corrected sums of squares and products},
    journal = {Technometrics},
    year = {1962},
    pages = {419--420}
}

repository: tool-recommender-bot/t-digest

repo_name: tool-recommender-bot/t-digest


text:
@incollection{las12fg-bookchapter,
 author = {Geoffrey C. Fox and Gregor von Laszewski and Javier Diaz and Kate Keahey and Jose Fortes and Renato Figueiredo and Shava Smallen and Warren Smith and Andrew Grimshaw},
 booktitle = {Contemporary HPC Architectures},
 edition = {draft},
 title = {FutureGrid - a reconfigurable testbed for Cloud, HPC and Grid Computing},
 url = {https://laszewski.github.io/papers/vonLaszewski-12-fg-bookchapter.pdf},
 year = {2012}
}


text:
package dproxy

import (
	"context"
	"crypto/tls"
	"io"
	"time"

	"github.com/pkg/errors"
	"github.com/sirupsen/logrus"
	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials"

	"github.com/batchcorp/plumber/cli"
	"github.com/batchcorp/schemas/build/go/events"
	"github.com/batchcorp/schemas/build/go/services"
)

const (
	// ReconnectSleep determines the length of time to wait between reconnect attempts to dProxy
	ReconnectSleep = time.Second * 5
)

type DProxyClient struct {
	Client            services.DProxyClient
	Conn              *grpc.ClientConn
	Token             string
	log               *logrus.Entry
	MessageBus        string
	OutboundMessageCh chan *events.Outbound

	Options *cli.Options
}

// New validates CLI options and returns a new DProxyClient struct
func New(opts *cli.Options, bus string) (*DProxyClient, error) {
	ctx, _ := context.WithTimeout(context.Background(), opts.DproxyGRPCTimeout)

	conn, err := grpc.DialContext(ctx, opts.DProxyAddress, getDialOptions(opts)...)
	if err != nil {
		return nil, errors.Wrapf(err, "unable to open connection to %s", opts.DProxyAddress)
	}

	dClient := &DProxyClient{
		Client:            services.NewDProxyClient(conn),
		Conn:              conn,
		Token:             opts.DProxyAPIToken,
		log:               logrus.WithField("pkg", "dproxy"),
		OutboundMessageCh: make(chan *events.Outbound, 1),
		MessageBus:        bus,
		Options:           opts,
	}

	return dClient, nil
}

func (d *DProxyClient) reconnect() error {
	conn, err := grpc.Dial(d.Options.DProxyAddress, getDialOptions(d.Options)...)
	if err != nil {
		return errors.Wrapf(err, "unable to open connection to %s", d.Options.DProxyAddress)
	}

	d.Client = services.NewDProxyClient(conn)
	return nil
}

// getDialOptions returns all necessary grpc dial options to connect to dProxy
func getDialOptions(opts *cli.Options) []grpc.DialOption {
	dialOpts := []grpc.DialOption{grpc.WithBlock()}

	if opts.DProxyInsecure {
		dialOpts = append(dialOpts, grpc.WithInsecure())
	} else {
		dialOpts = append(dialOpts, grpc.WithTransportCredentials(credentials.NewTLS(
			&tls.Config{
				InsecureSkipVerify: true,
			},
		)))
	}

	return dialOpts
}

// Start is called by a backend's Dynamic() method. It authorizes the connection and begins reading a GRPC stream of
// responses consisting of DynamicReplay protobuf messages
func (d *DProxyClient) Start() {
	d.log.Debug("Starting new dynamic destination client")
	var err error
	var stream services.DProxy_ConnectClient

	for {
		if stream == nil {
			// TODO: exponential backoff
			stream, err = d.authorize()
			if err != nil {
				d.log.Error(err)
				stream = nil
				time.Sleep(ReconnectSleep)
				continue
			}
		}

		response, err := stream.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				// Nice reconnect messages
				d.log.Errorf("dProxy server is unavailable, retrying in %s...", ReconnectSleep.String())
			} else {
				d.log.Errorf("Error receiving message: %s", err)
			}

			// Stream is no longer useful. Need to get a new one on reconnect
			stream = nil

			// Attempt reconnect. On the next loop iteration, stream == nil check will be hit, and assuming we've
			// reconnected at that point, a new stream will be opened and authorized
			d.reconnect()

			time.Sleep(ReconnectSleep)
			continue
		}

		d.handleResponse(response)
	}
}

// authorize opens a GRPC connection to dProxy. It is called by Start
func (d *DProxyClient) authorize() (services.DProxy_ConnectClient, error) {
	authRequest := &services.DynamicReplay{
		Type: services.DynamicReplay_AUTH_REQUEST,
		Payload: &services.DynamicReplay_AuthRequest{
			AuthRequest: &services.AuthRequest{
				Token:      d.Token,
				MessageBus: d.MessageBus,
			},
		},
	}

	return d.Client.Connect(context.TODO(), authRequest)
}

// handleResponse receives a dynamic replay message and determines which method should handle it based on the payload
func (d *DProxyClient) handleResponse(resp *services.DynamicReplay) {
	switch resp.Type {
	case services.DynamicReplay_AUTH_RESPONSE:
		d.handleAuthResponse(resp)
	case services.DynamicReplay_OUTBOUND_MESSAGE:
		d.handleOutboundMessage(resp)
	case services.DynamicReplay_REPLAY_EVENT:
		d.handleReplayEvent(resp)
	}
}

// handleAuthResponse handles a AUTH_RESPONSE payload from a DynamicReplay protobuf message
func (d *DProxyClient) handleAuthResponse(resp *services.DynamicReplay) {
	authResponse := resp.GetAuthResponse()
	if authResponse == nil {
		if err := d.Conn.Close(); err != nil {
			d.log.Error("could not cleanly disconnect from server")
		}
		d.log.Fatalf("Received invalid authentication response from server")
	}

	if authResponse.Authorized == false {
		if err := d.Conn.Close(); err != nil {
			d.log.Error("could not cleanly disconnect from server")
		}
		d.log.Fatalf("Could not authenticate: %s", authResponse.Message)
	}

	d.log.Info("Connection authorized. Waiting for replay messages...")
}

// handleOutboundMessage handles a REPLAY_MESSAGE payload from a DynamicReplay protobuf message
func (d *DProxyClient) handleOutboundMessage(resp *services.DynamicReplay) {
	d.log.Debugf("received message for replay '%s'", resp.ReplayId)

	outbound := resp.GetOutboundMessage()

	// Ignore
	if outbound.Last {
		return
	}

	d.OutboundMessageCh <- outbound
}

// handleOutboundMessage handles a REPLAY_MESSAGE payload from a DynamicReplay protobuf message
func (d *DProxyClient) handleReplayEvent(resp *services.DynamicReplay) {
	llog := d.log.WithField("replay_id", resp.ReplayId)
	event := resp.GetReplayMessage()
	switch event.Type {
	case services.ReplayEvent_CREATE_REPLAY:
		llog.Info("Replay starting")
	case services.ReplayEvent_PAUSE_REPLAY:
		llog.Info("Replay paused")
	case services.ReplayEvent_RESUME_REPLAY:
		llog.Info("Replay resuming")
	case services.ReplayEvent_ABORT_REPLAY:
		llog.Error("Replay aborted")
	case services.ReplayEvent_FINISH_REPLAY:
		llog.Info("Replay finished!")
	}
}

repository: vklimontovich/plumber

repo_name: vklimontovich/plumber


text:
SUMMARY = "Simple generic functions (similar to Python's own len(), pickle.dump(), etc.)"
SECTION = "devel/python"
LICENSE = "ZPL2.1"
LIC_FILES_CHKSUM = "file://PKG-INFO;md5=2ee72c527f0c22ea0bf9a8812053efd0"

SRC_URI = "https://pypi.python.org/packages/3d/57/4d9c9e3ae9a255cd4e1106bb57e24056d3d0709fc01b2e3e345898e49d5b/simplegeneric-0.8.1.zip"

SRC_URI[md5sum] = "f9c1fab00fd981be588fc32759f474e3"
SRC_URI[sha256sum] = "dc972e06094b9af5b855b3df4a646395e43d1c9d0d39ed345b7393560d0b9173"

UPSTREAM_CHECK_URI = "https://pypi.python.org/pypi/simplegeneric/"
UPSTREAM_CHECK_REGEX = "/simplegeneric/(?P<pver>(\d+[\.\-_]*)+)"

S = "${WORKDIR}/simplegeneric-${PV}"

inherit setuptools3

repository: qtec/meta-qtec-core

repo_name: qtec/meta-qtec-core


text:
*,
*::after,
*::before {
  margin: 0;
  padding: 0;
  box-sizing: border-box;
}

/* The Body */
html,
body {
  font-family: 'Acme', sans-serif;
  font-weight: 300;
  font-size: 20px;
  scroll-behavior: smooth;
  background-color: #f7fff9;
  position: relative;
  }
  .fa-shopping-cart{
      color:#b7d972 ;
    padding:-10px;
  }
.fa{
    padding: 10px;
    font-size: 30px;
    width: 45px;
    height: 45px;
    text-align: center;
    text-decoration: none;
    margin: 2px 2px;
    border-radius: 5px;
  }

  /* img{
    width: 30%;
    height: 30%;
  } */

  .fa:hover {
      opacity: 0.7;
  }

  .fa-facebook {
    background: #3B5998;
    color: white;
  }
  .fa-google {
    background: #dd4b39;
    color: white;
  }
  .fa-instagram {
    background: #125688;
    color: white;
  }

  /* Header */

  header {
    font-family: 'Acme', sans-serif;
    height: 100px;
    background-image: linear-gradient(rgba(0, 0, 0, 0.8), rgba(0, 0, 0, 0.8));
      /* url("../img/bghome.jpg"); */
    background-position: center;
    background-repeat: no-repeat;
    background-size: cover;
    }

  header div {
    padding: 25px;
  }

  /* Title */
  .title-logo {
    color: #fff;
    float: left;
    text-transform: uppercase;
  }
  .title-logo span,
  .title-logo--footer span {
    margin: 0 5px;
    color: #b7d972 ;
    transition: transform 0.25s;

  }

  /* Menu right side */
  .main-nav {
    float: right;
  }
  .main-nav-list {
    list-style: none;
  }

  .main-nav-item {
    display: inline-block;
    margin: 0 7px;
  }

  .main-nav-item a:link,
  .main-nav-item a:visited {
    color: #fff;
    font-size: 25px;
    text-decoration: none;
    text-transform: uppercase;
    padding: 7px 0;
    border-bottom: 2px solid transparent;
    transition: border-bottom 0.25s;
  }

  .main-nav-item a:hover,
  .main-nav-item a:active {
    border-bottom: 2px solid #b7d972 ;
  }

  /* footer */
footer {
    width: 100%;
    padding: 30px 0 10px 0;
    background-color: #202020  ;
    color: #fdf1fd;
  }

  .title-logo--footer {
    float: right;
    padding-right: 40px;
    text-transform: uppercase;
  }

  .footer-nav {
    float: left;
    margin-right: 25px;
  }

  .footer-nav-list {
    list-style: none;
  }
  .footer-nav-item {
    display: inline-block;
    margin: 0 5px;
  }

  .footer-nav-item a:link,
  .footer-nav-item a:visited {
    text-decoration: none;
    color: #fefaec;
    transition: opacity 0.25s;
    text-transform: uppercase;
  }

  .footer-nav-item a:hover,
  .footer-nav-item a:active {
    opacity: 0.75;
  }

  .copy-rights,
  .contactus-bar {
    font-size: 80%;
    font-weight: 200;
  }
  .contact-us{
    clear: both;
    margin-left: 10px;
  }

  .copy-rights {
    width: 90%;
    text-align: center;
    margin-top: 90px;
    margin-left: 60px;
  }

  .contactus-bar {
    padding-left: 2px;
    width: 100%;
    margin-top: 30px;
    margin-left: 20px;
    text-align: center;
  }

  .contactus-bar-list {
    list-style: none;
  }
  .social-bar{
    margin-top: 60px;
    margin-left: 87%;
    padding-left: 20px;
    position: absolute;
  }
  footer{
    position: relative;
    height: 150px;
  }

  span{
    color: #b7d972 ;
  }

  /* main */
main h1{
    text-align: center;
    margin-top: 2% ;
    color:rgba(0, 0, 0, 0.6);

}

main p{
    text-align: center;
    margin: auto;
    padding-top: 30px;
    padding-bottom: 50px;
    color: #8fb445;
    font-size:25px;
    width: 60%;
}
main{
    margin-bottom: 6%;

}

#exchangeProductForm{
    border: 5px solid #8fb445;
    width: 90%;
    margin-top: 7%;
    background-color: #e4f3c2 ;
    margin-bottom: 10%;
    padding: 4%;
    border-radius: 3%;;
    display: flex;
    color: rgba(0, 0, 0, 0.8);
    margin: auto;
    flex-wrap: wrap;
    align-content: center;
}

#pImage{
    width: 100%;
    padding: 12px 20px;
    border: 1px solid #ccc;
    border-radius: 4px;
    resize: vertical;
    margin: 8px 0;
    display: inline-block;

}

#pPrice{
    width: 100%;
    padding: 12px 20px;
    border: 1px solid #ccc;
    border-radius: 4px;
    resize: vertical;
    margin: 8px 0;
    display: inline-block;

}

input[type=text], select {
    width: 100%;
    padding: 12px 20px;
    border: 1px solid #ccc;
    border-radius: 4px;
    resize: vertical;
    margin: 8px 0;
    display: inline-block;
  }

  label {
    padding: 12px 12px 12px 0;
    display: inline-block;
  }

  input[type=submit] {
    background-color:#faab34;
    color: white;
    padding: 20px 20px;
    border: none;
    font-size: 30px;
    border-radius: 4px;
    cursor: pointer;
    width: 30%;
    /* margin: auto; */
    /* top: 20px; */
    margin-top: 2%;
    margin-left: 35%;
  }

input[type=submit]:hover {
    background-color: #bd770f;
  }

repository: PowerFull-Team/JOstainable

repo_name: PowerFull-Team/JOstainable

gha_language: HTML

extension: css


text:
add_library(empty1 empty.cpp)
add_library(empty2 empty.cpp)

# This is OK, because evaluating the INCLUDE_DIRECTORIES is not affected by
# the content of the INTERFACE_LINK_LIBRARIES.
target_link_libraries(empty1
  INTERFACE
    $<$<STREQUAL:$<TARGET_PROPERTY:INCLUDE_DIRECTORIES>,/foo/bar>:empty2>
)


text:
package listener

import (
	"fgame/fgame/core/event"
	"fgame/fgame/cross/arenapvp/pbutil"
	battleeventtypes "fgame/fgame/game/battle/event/types"
	gameevent "fgame/fgame/game/event"
	"fgame/fgame/game/scene/scene"
	scenetypes "fgame/fgame/game/scene/types"
)

//退出竞技场场景
func playerExit(target event.EventTarget, data event.EventData) (err error) {
	pl, ok := target.(scene.Player)
	if !ok {
		return
	}
	active, ok := data.(bool)
	if !ok {
		return
	}
	s := pl.GetScene()
	if s == nil {
		return
	}
	if s.MapTemplate().GetMapType() != scenetypes.SceneTypeArenapvp {
		return
	}

	if !active {
		scArenaPlayerDataOfflineChanged := pbutil.BuildSCArenapvpPlayerOfflineChanged(pl)
		s.BroadcastMsg(scArenaPlayerDataOfflineChanged)
	}
	return
}

func init() {
	gameevent.AddEventListener(battleeventtypes.EventTypeBattlePlayerExitScene, event.EventListenerFunc(playerExit))
}

repository: rebider/Fgame

repo_name: rebider/Fgame


text:
DESCRIPTION = "Packaging for URG Helper URG Widget URG Library urg_c Original Source at: http://sourceforge.net/projects/urgwidget This project introduces sample programs of the URG library. Applications using URG and URG library are also introduced here. URG is Scanning Laser Range Finder of Hokuyo Automatic Co., for robots, autonomous systems and security systems."
SECTION = "devel"
LICENSE = "BSD"
LIC_FILES_CHKSUM = "file://package.xml;beginline=9;endline=9;md5=d566ef916e9dedc494f5f793a6690ba5"

DEPENDS = "catkin"

SRC_URI = "https://github.com/ros-drivers/${ROS_SPN}/archive/${PV}.tar.gz;downloadfilename=${ROS_SP}.tar.gz"
SRC_URI[md5sum] = "fbcf82518cf341612518bcb8421dd72d"
SRC_URI[sha256sum] = "cb51032301515297b3839f6dec0c7124bc533936da1e7bbd28989dcb51fa1da4"

S = "${WORKDIR}/${ROS_SP}"

inherit catkin


text:
require nandlogical_${PV}.bb

do_compile () {
	${CC} -o nandlogical ${WORKDIR}/nandlogical.c -static
}