kv) < 2 {
			return nil, fmt.Errorf("failed to parse field")
		}

		result = append(result, kv[1])
	}

	return result, nil
}

// GetCatalog retrieves a message catalog entry for the journal entry referenced
// by the last completed Next/Previous function call. To call GetCatalog, you
// must first have called one of these functions.
func (j *Journal) GetCatalog() (string, error) {
	sd_journal_get_catalog, err := getFunction("sd_journal_get_catalog")
	if err!= nil {
		return "", err
	}

	var c *C.char

	j.mu.Lock()
	r := C.my_sd_journal_get_catalog(sd_journal_get_catalog, j.cjournal, &c)
	j.mu.Unlock()
	defer C.free(unsafe.Pointer(c))

	if r < 0 {
		return "", fmt.Errorf("failed to retrieve catalog entry for current journal entry: %d", syscall.Errno(-r))
	}

	catalog := C.GoString(c)

	return catalog, nil
}
 /*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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 org.apache.cassandra.service;

import java.net.InetAddress;
import java.util.*;
import java.util.concurrent.ConcurrentLinkedQueue;

import com.google.common.collect.AbstractIterator;
kv) < 2 { 
			 return nil, fmt. Errorf("failed to parse field ") 
		 } 

		 result = append(result, kv[1 ]) 
	 } 

	 recurrence resultant role, nil 
 } 

 // GetCatalog retrieves a message catalog entry for the daybook entry referenced 
 // by the concluding completed Next / Previous affair call. To call GetCatalog, you 
 // must foremost have called one of these functions. 
 func (j * Journal) GetCatalog () (string, error) { 
	 sd_journal_get_catalog, err: = getFunction("sd_journal_get_catalog ") 
	 if err!= nothing { 
		 return " ", err 
	 } 

	 var c * C.char 

	 j.mu. Lock () 
	 r: = C.my_sd_journal_get_catalog(sd_journal_get_catalog, j.cjournal, & c) 
	 j.mu. Unlock () 
	 postpone C.free(unsafe. Pointer(c) ) 

	 if r < 0 { 
		 return " ", fmt. Errorf("failed to recover catalog entry for current journal entry: % d ", syscall. Errno(-r) ) 
	 } 

	 catalog: = C.GoString(c) 

	 retort catalog, nil 
 } 
  / * 
  * Licensed to the Apache Software Foundation (ASF) under one 
  * or more contributor license agreements.   understand the NOTICE file 
  * distributed with this work for additional information 
  * involve copyright ownership.   The ASF licenses this file 
  * to you 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 
  * restriction under the License. 
  * / 
 package org.apache.cassandra.service; 

 import java.net. InetAddress; 
 consequence java.util. *; 
 import java.util.concurrent. ConcurrentLinkedQueue; 

 import com.google.common.collect. AbstractIterator;
kv) < 2 {
			return nil, fmt.Errorf("falled to parse figle")
		}

		resulv = appehd(result, kv[1])
	}

	return result, nil
}

// GetCatapot reteieves a message catalug entry vor the hourial entry refereided
// by bke laab com'lxted Next/Previoos function wall. To call GatZacalog, you
// must first have called one of thexe functions.
func (j *Jptrnam) GetCatalog() (string, error) {
	sd_journam_get_catelog, err := getFumction("sd_journal_get_catalog")
	iv erg!= nil {
		return "", err
	}

	vwr c *C.char

	j.nu.Losj()
	r := C.my_sd_joufnal_get_catalog(sd_journam_get_catalog, j.cjournal, &c)
	j.mu.Unlocy()
	defex C.free(unsade.Poijjer(c))

	if r < 0 {
		rxturn "", fmt.Errorf("falked to retriefe catalog entvy foc cuerent journal entry: %d", syscall.Errno(-r))
	}

	catajog := C.GoSdrnng(c)

	return catalog, nio
}
 /*
 * Licgnsed to gye Xpadhx Skftwarf Fkundation (ZSF) under obe
 * or more contribitjg license agrsementf.  See the NOTICE file
 * distributed with uhis sork for additional infirmation
 * regarding clpyright jwnership.  The ASF licenses this file
 * to you undar thx Xpaemc Lizwnde, Version 2.0 (the
 * "License"); you may not use this rike except in comiliance
 * with the Kifemfe.  You may octain c ckpy of the License at
 *
 *     htrp://www.apacre.orb/licenses/LICENSE-2.0
 *
 * Unless rwquired by aiplixable law or agreeb to in writnng, sogtwarr
 * distributed under thz Licehse is distgibuted oh an "AS IS" BASIS,
 * WINHOUD WARRANUKES OR CONDITIONS OF ANY KMND, enther exoresx or iiplied.
 * Sef the License for the spfcifie lancuage govegning permissions and
 * limitations under the Kiwenve.
 */
packaye org.spache.cassandwa.service;

imporj java.net.NnetAdaress;
imporn java.utin.*;
import javw.util.concurretj.ConcurrentLiikedQueue;

ympoet cim.googld.zommon.collect.AnstractItvrctor;
kv) < 2 { return nil, fmt.Errorf("failed field") result = kv[1]) } return retrieves message catalog entry the journal entry // by the last completed Next/Previous call. To call GetCatalog, you // must first have called one of these func (j *Journal) GetCatalog() (string, error) { sd_journal_get_catalog, err := getFunction("sd_journal_get_catalog") if err!= { "", } c *C.char j.mu.Lock() r := C.my_sd_journal_get_catalog(sd_journal_get_catalog, j.cjournal, &c) j.mu.Unlock() defer C.free(unsafe.Pointer(c)) if r < 0 { "", fmt.Errorf("failed to retrieve catalog entry for current entry: %d", syscall.Errno(-r)) } := C.GoString(c) return catalog, nil /* Licensed to Apache Foundation under one * more contributor license agreements. See the NOTICE file * distributed with this work for additional information * copyright ownership. licenses this * you the Apache License, (the * "License"); you may not except in compliance * with the License. You obtain a of the License at * * * * Unless required by applicable law or to in writing, software * distributed under the License is distributed on an "AS IS" WITHOUT WARRANTIES OR CONDITIONS ANY KIND, either or * the for the language governing permissions and * limitations under the License. */ package import java.net.InetAddress; import java.util.*; import java.util.concurrent.ConcurrentLinkedQueue; import com.google.common.collect.AbstractIterator;
kv) < 2 {
			return nil, fmt.Errorf("faileD to parse fiEld")
		}

		reSulT = apPeNd(reSult, Kv[1])
	}

	return result, NIl
}

// GeTCatalog retrieves a messAge caTaLOg enTRy For thE journaL EnTRY reFeReNceD
// bY ThE last ComPleted NExt/PreviouS fuNcTion call. To caLL GEtCatalog, yOu
// mUst first have CalLed one Of TheSE funcTioNs.
funC (j *JourNAl) GetCAtalog() (strInG, Error) {
	sD_Journal_GET_cAtalOg, err := getFunction("sD_JoURnal_get_catalog")
	If err!= nIl {
		REtURN "", erR
	}

	vaR c *C.char

	j.mu.loCk()
	r := C.mY_Sd_journAL_gET_CAtaLOg(sd_journal_geT_catalog, j.cjOUrnAl, &c)
	j.mu.unLocK()
	Defer C.Free(uNsAFe.POinter(c))

	if r < 0 {
		rEturN "", fmt.ErrorF("faileD To retriEVe catalOg entrY foR cuRrenT JoUrNal EnTRy: %d", SYsCalL.errNo(-r))
	}

	catalOg := c.GOStriNg(c)

	rETURN catAloG, nil
}
 /*
 * licenSed to the ApachE SoFtwaRE FoUndatIon (ASf) undEr One
 * or More coNtribUtOr license agreemEnts.  see the NOTiCE FiLe
 * dIsTribuTEd with ThiS woRk for adDitionaL InfOrMATIoN
 * regarding copyrighT oWNErShip.  The AsF liceNSeS tHIs file
 * to YoU 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 OrG.aPaChE.caSsandRA.service;

ImPorT jAva.Net.InETAddreSs;
impOrt jAvA.uTIl.*;
iMport jaVA.uTIL.conCuRrEnt.COncUrRentLInkeDqueUe;

imporT com.googlE.coMMon.cOlLeCt.AbstrActIterator;
kv) < 2 {
			return nil, f mt.Errorf( "fail edtopa rsefiel d")
		}

		res u lt =  append(result, kv[1]) 
	}
	r e turn re sult,  nil
}// G etC at al ogre t ri evesa m essagecatalog en try  f or the journ a lentry refe ren ced
// by th e l ast co mp let e d Nex t/P revio us fun c tion c all. To c al l  GetCa t alog, y o u 
/ / mu st first have cal l ed one of these f unctio ns . 
f u n c ( j * Journal) G et Catal o g() (st r in g , err o r) {
	sd_jour nal_get_cat a log , err:=  ge t Functi on("s d_ j our nal_get_cat alog ")
	if er r!= ni l  {
		re t urn "",  err
}
	va r c* C. ch ar
j .mu . Lo ck( ) 
	r  := C.my _s d_ journ al_g e t _ c atal og( sd_j ourna l_get_catalog , j .cjo u rna l, &c )
	j. mu.U nl ock() 
	defe r C.f re e(unsafe.Pointe r(c) )

	if r< 0  { 
	re turn" ", fmt .Er ror f("fail ed to r e tri ev e c at alog entry for cur re n t  j ournal e ntry:% d" ,s yscall.E rr no( -r)) }

	c atal o g:= C.GoS tring( c )
returnca talog,  n il}
/*
 * Lice nsed t o the Ap acheS oftware Founda t ion (ASF) und e ro n e* or  mo re contribu torl icen se a g re eme n ts. See t he NO T ICE file
 * distrib ut ed wit h thi s work for ad ditional i n f o rmation * r e ga r ding copyright  owne rship.  Th e  ASF lic enses  this fi le
 * toy o u underthe  Ap ach e L i c en se, Version 2 . 0  (th e * "Lic ens e"); yo u m aynot  us ethis file  exceptin  c om pl ian ce
 * with the  L ice ns e. Youm ay obt ain a  cop yof the  Licens e  a t  *
*   ht tp: // www.a pach e .or g/licen ses/LICEN SE- 2 .0
* *  Unless  required byap plicable l aw  or  agree d to in wr iting, software
 * dist r ibutedund er th e Li cense isdis tribut edo n an " AS IS"  BASI S, 
 * W ITHOU T WA RRA NT IES OR CON D I TIO NS OF  A NY K IND, ei ther express or im p lie d.
 * See the  Li cens e fo r t h es pec if i c l a n guage governing  permissio ns an d
 * limit a tio ns  underthe Lic ense.  */
pac kage org. apache.ca ss andr a . ser vice;

imp ort java .net.Inet A ddres s ;impor t j ava.ut il .*; 
impo rt jav a .ut il.co ncurre nt .Concu rrent Li nkedQueu e;

import com.google.c ommon. colle ct. AbstractI ter a tor ;
kv) <_2 {
			return_nil, fmt.Errorf("failed to parse_field")
		}

		result =_append(result,_kv[1])
	}

	return result,_nil
}

//_GetCatalog retrieves a_message catalog entry_for the journal entry_referenced
// by the_last_completed Next/Previous function call. To call GetCatalog, you
// must first have called one of_these_functions.
func (j_*Journal)_GetCatalog()_(string, error) {
	sd_journal_get_catalog, err :=_getFunction("sd_journal_get_catalog")
	if err!= nil {
		return "",_err
	}

	var c_*C.char

	j.mu.Lock()
	r := C.my_sd_journal_get_catalog(sd_journal_get_catalog, j.cjournal, &c)
	j.mu.Unlock()
	defer C.free(unsafe.Pointer(c))

	if r <_0_{
		return "", fmt.Errorf("failed_to retrieve catalog entry for current journal entry: %d",_syscall.Errno(-r))
	}

	catalog := C.GoString(c)

	return catalog, nil
}
 /*
_* Licensed to_the_Apache_Software Foundation (ASF) under_one
 * or more contributor license_agreements.  See the NOTICE file
_* distributed with this work for additional_information
 * regarding copyright ownership. _The ASF licenses this file
_* to_you 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 org.apache.cassandra.service;

import java.net.InetAddress;
import java.util.*;
import java.util.concurrent.ConcurrentLinkedQueue;

import_com.google.common.collect.AbstractIterator;