Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
only use Application Support directory on OS X 10.9, probably fix cra…
…sh on startup for macs The original reason it broke on macs was because gFinderLaunch was broken
- Loading branch information
Showing
2 changed files
with
179 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,133 @@ | ||
| ----------------------------------------------------------------------------- | ||
| -- LuaSocket helper module | ||
| -- Author: Diego Nehab | ||
| -- RCS ID: $Id: socket.lua,v 1.22 2005/11/22 08:33:29 diego Exp $ | ||
| ----------------------------------------------------------------------------- | ||
|
|
||
| ----------------------------------------------------------------------------- | ||
| -- Declare module and import dependencies | ||
| ----------------------------------------------------------------------------- | ||
| local base = _G | ||
| local string = require("string") | ||
| local math = require("math") | ||
| local socket = require("socket.core") | ||
| module("socket") | ||
|
|
||
| ----------------------------------------------------------------------------- | ||
| -- Exported auxiliar functions | ||
| ----------------------------------------------------------------------------- | ||
| function connect(address, port, laddress, lport) | ||
| local sock, err = socket.tcp() | ||
| if not sock then return nil, err end | ||
| if laddress then | ||
| local res, err = sock:bind(laddress, lport, -1) | ||
| if not res then return nil, err end | ||
| end | ||
| local res, err = sock:connect(address, port) | ||
| if not res then return nil, err end | ||
| return sock | ||
| end | ||
|
|
||
| function bind(host, port, backlog) | ||
| local sock, err = socket.tcp() | ||
| if not sock then return nil, err end | ||
| sock:setoption("reuseaddr", true) | ||
| local res, err = sock:bind(host, port) | ||
| if not res then return nil, err end | ||
| res, err = sock:listen(backlog) | ||
| if not res then return nil, err end | ||
| return sock | ||
| end | ||
|
|
||
| try = newtry() | ||
|
|
||
| function choose(table) | ||
| return function(name, opt1, opt2) | ||
| if base.type(name) ~= "string" then | ||
| name, opt1, opt2 = "default", name, opt1 | ||
| end | ||
| local f = table[name or "nil"] | ||
| if not f then base.error("unknown key (".. base.tostring(name) ..")", 3) | ||
| else return f(opt1, opt2) end | ||
| end | ||
| end | ||
|
|
||
| ----------------------------------------------------------------------------- | ||
| -- Socket sources and sinks, conforming to LTN12 | ||
| ----------------------------------------------------------------------------- | ||
| -- create namespaces inside LuaSocket namespace | ||
| sourcet = {} | ||
| sinkt = {} | ||
|
|
||
| BLOCKSIZE = 2048 | ||
|
|
||
| sinkt["close-when-done"] = function(sock) | ||
| return base.setmetatable({ | ||
| getfd = function() return sock:getfd() end, | ||
| dirty = function() return sock:dirty() end | ||
| }, { | ||
| __call = function(self, chunk, err) | ||
| if not chunk then | ||
| sock:close() | ||
| return 1 | ||
| else return sock:send(chunk) end | ||
| end | ||
| }) | ||
| end | ||
|
|
||
| sinkt["keep-open"] = function(sock) | ||
| return base.setmetatable({ | ||
| getfd = function() return sock:getfd() end, | ||
| dirty = function() return sock:dirty() end | ||
| }, { | ||
| __call = function(self, chunk, err) | ||
| if chunk then return sock:send(chunk) | ||
| else return 1 end | ||
| end | ||
| }) | ||
| end | ||
|
|
||
| sinkt["default"] = sinkt["keep-open"] | ||
|
|
||
| sink = choose(sinkt) | ||
|
|
||
| sourcet["by-length"] = function(sock, length) | ||
| return base.setmetatable({ | ||
| getfd = function() return sock:getfd() end, | ||
| dirty = function() return sock:dirty() end | ||
| }, { | ||
| __call = function() | ||
| if length <= 0 then return nil end | ||
| local size = math.min(socket.BLOCKSIZE, length) | ||
| local chunk, err = sock:receive(size) | ||
| if err then return nil, err end | ||
| length = length - string.len(chunk) | ||
| return chunk | ||
| end | ||
| }) | ||
| end | ||
|
|
||
| sourcet["until-closed"] = function(sock) | ||
| local done | ||
| return base.setmetatable({ | ||
| getfd = function() return sock:getfd() end, | ||
| dirty = function() return sock:dirty() end | ||
| }, { | ||
| __call = function() | ||
| if done then return nil end | ||
| local chunk, err, partial = sock:receive(socket.BLOCKSIZE) | ||
| if not err then return chunk | ||
| elseif err == "closed" then | ||
| sock:close() | ||
| done = 1 | ||
| return partial | ||
| else return nil, err end | ||
| end | ||
| }) | ||
| end | ||
|
|
||
|
|
||
| sourcet["default"] = sourcet["until-closed"] | ||
|
|
||
| source = choose(sourcet) | ||
|
|