Compare commits
	
		
			1 Commits 
		
	
	
		
			b8d1fd6978
			...
			082b1044db
		
	
	| Author | SHA1 | Date | 
|---|---|---|
|  | 082b1044db | 
|  | @ -1,3 +1,22 @@ | |||
| # tractor: structured concurrent "actors". | ||||
| # Copyright 2018-eternity Tyler Goodlet. | ||||
| 
 | ||||
| # This program is free software: you can redistribute it and/or modify | ||||
| # it under the terms of the GNU Affero General Public License as published by | ||||
| # the Free Software Foundation, either version 3 of the License, or | ||||
| # (at your option) any later version. | ||||
| 
 | ||||
| # This program is distributed in the hope that it will be useful, | ||||
| # but WITHOUT ANY WARRANTY; without even the implied warranty of | ||||
| # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | ||||
| # GNU Affero General Public License for more details. | ||||
| 
 | ||||
| # You should have received a copy of the GNU Affero General Public License | ||||
| # along with this program.  If not, see <https://www.gnu.org/licenses/>. | ||||
| ''' | ||||
| Ring buffer ipc publish-subscribe mechanism brokered by ringd | ||||
| can dynamically add new outputs (publisher) or inputs (subscriber) | ||||
| ''' | ||||
| import time | ||||
| from abc import ( | ||||
|     ABC, | ||||
|  |  | |||
|  | @ -1,3 +1,28 @@ | |||
| # tractor: structured concurrent "actors". | ||||
| # Copyright 2018-eternity Tyler Goodlet. | ||||
| 
 | ||||
| # This program is free software: you can redistribute it and/or modify | ||||
| # it under the terms of the GNU Affero General Public License as published by | ||||
| # the Free Software Foundation, either version 3 of the License, or | ||||
| # (at your option) any later version. | ||||
| 
 | ||||
| # This program is distributed in the hope that it will be useful, | ||||
| # but WITHOUT ANY WARRANTY; without even the implied warranty of | ||||
| # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | ||||
| # GNU Affero General Public License for more details. | ||||
| 
 | ||||
| # You should have received a copy of the GNU Affero General Public License | ||||
| # along with this program.  If not, see <https://www.gnu.org/licenses/>. | ||||
| ''' | ||||
| Actor to broker ringbuf resources, creates and allocates | ||||
| the resources, then automatically does fd passing. | ||||
| 
 | ||||
| call open_ringd in your root actor | ||||
| 
 | ||||
| then on actors that need a ringbuf resource use | ||||
| 
 | ||||
| open_ringbuf acm, will automatically contact ringd. | ||||
| ''' | ||||
| import os | ||||
| import tempfile | ||||
| from pathlib import Path | ||||
|  |  | |||
|  | @ -14,7 +14,7 @@ | |||
| # You should have received a copy of the GNU Affero General Public License | ||||
| # along with this program.  If not, see <https://www.gnu.org/licenses/>. | ||||
| ''' | ||||
| Linux specifics, for now we are only exposing EventFD | ||||
| Expose libc eventfd APIs | ||||
| 
 | ||||
| ''' | ||||
| import os | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue