数据通信源代码(牧云水务信息大数据存储与分析系统).docx

《数据通信源代码(牧云水务信息大数据存储与分析系统).docx》由会员分享，可在线阅读，更多相关《数据通信源代码(牧云水务信息大数据存储与分析系统).docx（60页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、牧云水务信息大数据存储与分析系统 V1.0 60/* linenoise.c - guerrilla line editing library against the idea that a * * Copyright (c) 2010, Salvatore Sanfilippo * Copyright (c) 2010, Pieter Noordhuis * * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are perm

2、itted provided that the following conditions are met: * * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the f

3、ollowing disclaimer in the * documentation and/or other materials provided with the distribution. * * Neither the name of Redis nor the names of its contributors may be used * to endorse or promote products derived from this software without * specific prior written permission. * * THIS SOFTWARE IS

4、PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS AS IS * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE * LIABLE FOR AN

5、Y DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABIL

6、ITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. * * line editing lib needs to be 20,000 lines of C code. * * You can find the latest source code at: * * * * Does a number of crazy assumptions

7、that happen to be true in 99.9999% of * the 2010 UNIX computers around. * * References: * - http:/invisible- * - * * Todo list: * - Switch to gets() if $TERM is something we cant support. * - Filter bogus Ctrl+ combinations. * - Win32 support * * Bloat: * - Completion? * - History search like Ctrl+r

8、 in readline? * * List of escape sequences used by this program, we do everything just * with three sequences. In order to be so cheap we may have some * flickering effect with some slow terminal, but the lesser sequences * the more compatible. * * CHA (Cursor Horizontal Absolute) * Sequence: ESC n

9、G * Effect: moves cursor to column n (1 based) * * EL (Erase Line) * Sequence: ESC n K * Effect: if n is 0 or missing, clear from cursor to end of line * Effect: if n is 1, clear from beginning of line to cursor * Effect: if n is 2, clear entire line * * CUF (Cursor Forward) * Sequence: ESC n C * Ef

10、fect: moves cursor forward of n chars * * The following are used to clear the screen: ESC H ESC 2 J * This is actually composed of two sequences: * * cursorhome * Sequence: ESC H * Effect: moves the cursor to upper left corner * * ED2 (Clear entire screen) * Sequence: ESC 2 J * Effect: clear the who

11、le screen * */#ifdef _WIN32#include #include #include #define snprintf _snprintf / Microsoft headers use underscores in some names#define strcasecmp _stricmp#define strdup _strdup#define isatty _isatty#define write _write#define STDIN_FILENO 0#else /* _WIN32 */#include #include #include #include #in

12、clude #include #include #include #include #endif /* _WIN32 */#include #include #include #include linenoise.h#include linenoise_utf8.h#include mk_wcwidth.h#include #include #include using std:string;using std:vector;using boost:scoped_array;using linenoise_utf8:UChar8;using linenoise_utf8:UChar32;usi

13、ng linenoise_utf8:copyString8to32;using linenoise_utf8:copyString32;using linenoise_utf8:copyString32to8;using linenoise_utf8:strlen32;using linenoise_utf8:strncmp32;using linenoise_utf8:write32;using linenoise_utf8:Utf8String;using linenoise_utf8:Utf32String;struct linenoiseCompletions vector compl

14、etionStrings;#define LINENOISE_DEFAULT_HISTORY_MAX_LEN 100#define LINENOISE_MAX_LINE 4096/ make control-characters more readable#define ctrlChar( upperCaseASCII ) ( upperCaseASCII - 0x40 )/* * Recompute widths of all characters in a UChar32 buffer * param text input buffer of Unicode characters * pa

15、ram widths output buffer of character widths * param charCount number of characters in buffer */static void recomputeCharacterWidths( const UChar32* text, char* widths, int charCount ) for ( int i = 0; i 0 ) int charsThisRow = ( x + charsRemaining screenColumns ) ? charsRemaining : screenColumns - x

16、; xOut = x + charsThisRow; yOut = y; charsRemaining -= charsThisRow; x = 0; +y; if ( xOut = screenColumns ) / we have to special-case line wrap xOut = 0; +yOut; /* * Calculate a column width using mk_wcswidth() * param buf32 text to calculate * param len length of text to calculate */static int calc

17、ulateColumnPosition( UChar32* buf32, int len) int width = mk_wcswidth( reinterpret_cast( buf32 ), len ); if ( width = -1 ) return len; else return width;static bool isControlChar( UChar32 testChar ) return ( testChar = 0x7F & testChar = 0x9F ); / DEL and C1 controlsstruct PromptBase / a convenience

18、struct for grouping prompt info Utf32String promptText; / our copy of the prompt text, edited char* promptCharWidths; / character widths from mk_wcwidth() int promptChars; / chars in promptText int promptExtraLines; / extra lines (beyond 1) occupied by prompt int promptIndentation; / column offset t

19、o end of prompt int promptLastLinePosition; / index into promptText where last line begins int promptPreviousInputLen; / promptChars of previous input line, for clearing int promptCursorRowOffset; / where the cursor is relative to the start of the prompt int promptScreenColumns; / width of screen in

20、 columns int promptPreviousLen; / help erasing int promptErrorCode; / error code (invalid UTF-8) or zero PromptBase() : promptPreviousInputLen( 0 ) ;struct PromptInfo : public PromptBase PromptInfo( const UChar8* textPtr, int columns ) promptExtraLines = 0; promptLastLinePosition = 0; promptPrevious

21、Len = 0; promptScreenColumns = columns; Utf32String tempUnicode( textPtr ); / strip control characters from the prompt - we do allow newline UChar32* pIn = tempUnicode.get(); UChar32* pOut = pIn; while ( *pIn ) UChar32 c = *pIn; if ( n = c | !isControlChar( c ) ) *pOut = c; +pOut; +pIn; *pOut = 0; p

22、romptChars = pOut - tempUnicode.get(); promptText = tempUnicode; int x = 0; for ( int i = 0; i = promptScreenColumns ) x = 0; +promptExtraLines; promptLastLinePosition = i + 1; promptIndentation = promptChars - promptLastLinePosition; promptCursorRowOffset = promptExtraLines; ;/ Used with DynamicPro

23、mpt (history search)/static const Utf32String forwardSearchBasePrompt( reinterpret_cast( (i-search) ) );static const Utf32String reverseSearchBasePrompt( reinterpret_cast( (reverse-i-search) ) );static const Utf32String endSearchBasePrompt( reinterpret_cast( : ) );static Utf32String previousSearchTe

24、xt; / remembered across invocations of linenoise()/ changing prompt for (reverse-i-search)text: etc./struct DynamicPrompt : public PromptBase Utf32String searchText; / text we are searching for char* searchCharWidths; / character widths from mk_wcwidth() int searchTextLen; / chars in searchText int

25、direction; / current search direction, 1=forward, -1=reverse DynamicPrompt( PromptBase& pi, int initialDirection ) : searchTextLen( 0 ), direction( initialDirection ) promptScreenColumns = pi.promptScreenColumns; promptCursorRowOffset = 0; Utf32String emptyString( 1 ); searchText = emptyString; cons

26、t Utf32String* basePrompt = ( direction 0 ) ? &forwardSearchBasePrompt : &reverseSearchBasePrompt; size_t promptStartLength = basePrompt-length(); promptChars = promptStartLength + endSearchBasePrompt.length(); promptLastLinePosition = promptChars; / TODO fix this, we are asssuming that the history

27、prompt wont wrap (!) promptPreviousLen = promptChars; Utf32String tempUnicode( promptChars + 1 ); memcpy( tempUnicode.get(), basePrompt-get(), sizeof( UChar32 ) * promptStartLength ); memcpy( &tempUnicodepromptStartLength, endSearchBasePrompt.get(), sizeof( UChar32 ) * ( endSearchBasePrompt.length()

28、 + 1 ) ); tempUnicode.initFromBuffer(); promptText = tempUnicode; calculateScreenPosition( 0, 0, pi.promptScreenColumns, promptChars, promptIndentation, promptExtraLines ); void updateSearchPrompt( void ) const Utf32String* basePrompt = ( direction 0 ) ? &forwardSearchBasePrompt : &reverseSearchBase

29、Prompt; size_t promptStartLength = basePrompt-length(); promptChars = promptStartLength + searchTextLen + endSearchBasePrompt.length(); Utf32String tempUnicode( promptChars + 1 ); memcpy( tempUnicode.get(), basePrompt-get(), sizeof( UChar32 ) * promptStartLength ); memcpy( &tempUnicodepromptStartLen

30、gth, searchText.get(), sizeof( UChar32 ) * searchTextLen ); size_t endIndex = promptStartLength + searchTextLen; memcpy( &tempUnicodeendIndex, endSearchBasePrompt.get(), sizeof( UChar32 ) * ( endSearchBasePrompt.length() + 1 ) ); tempUnicode.initFromBuffer(); promptText = tempUnicode; void updateSea

31、rchText( const UChar32* textPtr ) Utf32String tempUnicode( textPtr ); searchTextLen = tempUnicode.chars(); searchText = tempUnicode; updateSearchPrompt(); ;class KillRing static const int capacity = 10; int size; int index; char indexToSlot10; vector theRing;public: enum action actionOther, actionKi

32、ll, actionYank ; action lastAction; size_t lastYankSize; KillRing() : size( 0 ), index( 0 ), lastAction( actionOther ) theRing.reserve( capacity ); void kill( const UChar32* text, int textLen, bool forward ) if ( textLen = 0 ) return; Utf32String killedText( text, textLen ); if ( lastAction = action

33、Kill & size 0 ) int slot = indexToSlot0; int currentLen = theRingslot.length(); int resultLen = currentLen + textLen; Utf32String temp( resultLen + 1 ); if ( forward ) memcpy( temp.get(), theRingslot.get(), currentLen * sizeof( UChar32 ) ); memcpy( &tempcurrentLen, killedText.get(), textLen * sizeof

34、( UChar32 ) ); else memcpy( temp.get(), killedText.get(), textLen * sizeof( UChar32 ) ); memcpy( &temptextLen, theRingslot.get(), currentLen * sizeof( UChar32 ) ); tempresultLen = 0; temp.initFromBuffer(); theRingslot = temp; else if ( size 0 ) memmove( &indexToSlot1, &indexToSlot0, size ); indexToS

35、lot0 = size; size+; theRing.push_back( killedText ); else int slot = indexToSlotcapacity - 1; theRingslot = killedText; memmove( &indexToSlot1, &indexToSlot0, capacity - 1 ); indexToSlot0 = slot; index = 0; Utf32String* yank() return ( size 0 ) ? &theRingindexToSlotindex : 0; Utf32String* yankPop() if ( size = 0 ) return 0; +index; if ( index = size ) index = 0; return &theRingindexToSlotindex; ;class InputBuf