mirror of
https://github.com/xcat2/confluent.git
synced 2025-01-17 21:23:18 +00:00
commit
1467e1f172
@ -17,7 +17,7 @@
|
||||
|
||||
# This is the socket api layer.
|
||||
# It implement unix and tls sockets
|
||||
#
|
||||
#
|
||||
|
||||
import atexit
|
||||
import errno
|
||||
@ -271,6 +271,8 @@ def _unixdomainhandler():
|
||||
os.remove("/var/run/confluent/api.sock")
|
||||
except OSError: # if file does not exist, no big deal
|
||||
pass
|
||||
if not os.path.isdir("/var/run/confluent"):
|
||||
os.makedirs('/var/run/confluent', 0755)
|
||||
unixsocket.bind("/var/run/confluent/api.sock")
|
||||
os.chmod("/var/run/confluent/api.sock",
|
||||
stat.S_IWOTH | stat.S_IROTH | stat.S_IWGRP |
|
||||
|
Loading…
x
Reference in New Issue
Block a user